封裝mysql數據庫連接類（mysql 封裝）

本文目錄一覽：

• 1、求個好用的php mysql封裝類
• 2、PHP訪問MYSQL數據庫封裝類(附函數說明)
• 3、python如何使用pymysql連接數據庫封裝類
• 4、本地安裝好MYSQL數據庫後怎麼連接
• 5、jdbc連接數據庫的代碼問題jdbc連接mysql數據庫

求個好用的php mysql封裝類

?php

class MMysql {

protected static $_dbh = null; //靜態屬性,所有數據庫實例共用,避免重複連接數據庫

    protected $_dbType = ‘mysql’;

protected $_pconnect = true; //是否使用長連接

    protected $_host = ‘localhost’;

protected $_port = 3306;

    protected $_user = ‘root’;

    protected $_pass = ‘root’;

    protected $_dbName = null; //數據庫名

protected $_sql = false; //最後一條sql語句

    protected $_where = ”;

    protected $_order = ”;

    protected $_limit = ”;

    protected $_field = ‘*’;

    protected $_clear = 0; //狀態，0表示查詢條件乾淨，1表示查詢條件污染

    protected $_trans = 0; //事務指令數 

    /**

     * 初始化類

     * @param array $conf 數據庫配置

     */

    public function __construct(array $conf) {

class_exists(‘PDO’) or die(“PDO: class not exists.”);

$this-_host = $conf[‘host’];

$this-_port = $conf[‘port’];

$this-_user = $conf[‘user’];

$this-_pass = $conf[‘passwd’];

$this-_dbName = $conf[‘dbname’];

//連接數據庫

        if ( is_null(self::$_dbh) ) {

            $this-_connect();

        }

    }

/**

     * 連接數據庫的方法

     */

protected function _connect() {

$dsn = $this-_dbType.’:host=’.$this-_host.’;port=’.$this-_port.’;dbname=’.$this-_dbName;

$options = $this-_pconnect ? array(PDO::ATTR_PERSISTENT=true) : array();

try { 

$dbh = new PDO($dsn, $this-_user, $this-_pass, $options);

            $dbh-setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);  //設置如果sql語句執行錯誤則拋出異常，事務會自動回滾

            $dbh-setAttribute(PDO::ATTR_EMULATE_PREPARES, false); //禁用prepared statements的仿真效果(防SQL注入)

} catch (PDOException $e) { 

            die(‘Connection failed: ‘ . $e-getMessage());

}

$dbh-exec(‘SET NAMES utf8’);

self::$_dbh = $dbh;

}

    /** 

    * 字段和表名添加 `符號

    * 保證指令中使用關鍵字不出錯 針對mysql 

    * @param string $value 

    * @return string 

    */ 

    protected function _addChar($value) { 

        if (‘*’==$value || false!==strpos($value,'(‘) || false!==strpos($value,’.’) || false!==strpos($value,’`’)) { 

            //如果包含* 或者 使用了sql方法 則不作處理 

        } elseif (false === strpos($value,’`’) ) { 

            $value = ‘`’.trim($value).’`’;

        } 

        return $value; 

    }

    /** 

    * 取得數據表的字段信息 

    * @param string $tbName 表名

    * @return array 

    */ 

    protected function _tbFields($tbName) {

        $sql = ‘SELECT COLUMN_NAME FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME=”‘.$tbName.'” AND TABLE_SCHEMA=”‘.$this-_dbName.'”‘;

        $stmt = self::$_dbh-prepare($sql);

        $stmt-execute();

        $result = $stmt-fetchAll(PDO::FETCH_ASSOC);

        $ret = array();

        foreach ($result as $key=$value) {

            $ret[$value[‘COLUMN_NAME’]] = 1;

        }

        return $ret;

    }

    /** 

    * 過濾並格式化數據表字段

    * @param string $tbName 數據表名 

    * @param array $data POST提交數據 

    * @return array $newdata 

    */

    protected function _dataFormat($tbName,$data) {

        if (!is_array($data)) return array();

        $table_column = $this-_tbFields($tbName);

        $ret=array();

        foreach ($data as $key=$val) {

            if (!is_scalar($val)) continue; //值不是標量則跳過

            if (array_key_exists($key,$table_column)) {

                $key = $this-_addChar($key);

                if (is_int($val)) { 

                    $val = intval($val); 

                } elseif (is_float($val)) { 

                    $val = floatval($val); 

                } elseif (preg_match(‘/^\(\w*(\+|\-|\*|\/)?\w*\)$/i’, $val)) {

                    // 支持在字段的值裏面直接使用其它字段 ,例如 (score+1) (name) 必須包含括號

                    $val = $val;

                } elseif (is_string($val)) { 

                    $val = ‘”‘.addslashes($val).'”‘;

                }

                $ret[$key] = $val;

            }

        }

        return $ret;

    }

    /**

    * 執行查詢 主要針對 SELECT, SHOW 等指令

    * @param string $sql sql指令 

    * @return mixed 

    */ 

    protected function _doQuery($sql=”) {

        $this-_sql = $sql;

        $pdostmt = self::$_dbh-prepare($this-_sql); //prepare或者query 返回一個PDOStatement

        $pdostmt-execute();

        $result = $pdostmt-fetchAll(PDO::FETCH_ASSOC);

        return $result;

    }

    /** 

    * 執行語句 針對 INSERT, UPDATE 以及DELETE,exec結果返回受影響的行數

    * @param string $sql sql指令 

    * @return integer 

    */ 

    protected function _doExec($sql=”) {

        $this-_sql = $sql;

        return self::$_dbh-exec($this-_sql);

    }

    /** 

    * 執行sql語句，自動判斷進行查詢或者執行操作 

    * @param string $sql SQL指令 

    * @return mixed 

    */ 

    public function doSql($sql=”) {

        $queryIps = ‘INSERT|UPDATE|DELETE|REPLACE|CREATE|DROP|LOAD DATA|SELECT .* INTO|COPY|ALTER|GRANT|REVOKE|LOCK|UNLOCK’; 

        if (preg_match(‘/^\s*”?(‘ . $queryIps . ‘)\s+/i’, $sql)) { 

            return $this-_doExec($sql);

        }

        else {

            //查詢操作

            return $this-_doQuery($sql);

        }

    }

    /** 

    * 獲取最近一次查詢的sql語句 

    * @return String 執行的SQL 

    */ 

    public function getLastSql() { 

        return $this-_sql;

    }

    /**

     * 插入方法

     * @param string $tbName 操作的數據表名

     * @param array $data 字段-值的一維數組

     * @return int 受影響的行數

     */

    public function insert($tbName,array $data){

        $data = $this-_dataFormat($tbName,$data);

        if (!$data) return;

        $sql = “insert into “.$tbName.”(“.implode(‘,’,array_keys($data)).”) values(“.implode(‘,’,array_values($data)).”)”;

return $this-_doExec($sql);

    }

    /**

     * 刪除方法

     * @param string $tbName 操作的數據表名

     * @return int 受影響的行數

     */

    public function delete($tbName) {

        //安全考慮,阻止全表刪除

        if (!trim($this-_where)) return false;

        $sql = “delete from “.$tbName.” “.$this-_where;

        $this-_clear = 1;

        $this-_clear();

        return $this-_doExec($sql);

    }

    /**

     * 更新函數

     * @param string $tbName 操作的數據表名

     * @param array $data 參數數組

     * @return int 受影響的行數

     */

    public function update($tbName,array $data) {

        //安全考慮,阻止全表更新

        if (!trim($this-_where)) return false;

        $data = $this-_dataFormat($tbName,$data);

        if (!$data) return;

        $valArr = ”;

        foreach($data as $k=$v){

            $valArr[] = $k.’=’.$v;

        }

        $valStr = implode(‘,’, $valArr);

        $sql = “update “.trim($tbName).” set “.trim($valStr).” “.trim($this-_where);

        return $this-_doExec($sql);

    }

    /**

     * 查詢函數

     * @param string $tbName 操作的數據表名

     * @return array 結果集

     */

    public function select($tbName=”) {

        $sql = “select “.trim($this-_field).” from “.$tbName.” “.trim($this-_where).” “.trim($this-_order).” “.trim($this-_limit);

        $this-_clear = 1;

        $this-_clear();

        return $this-_doQuery(trim($sql));

    }

    /**

     * @param mixed $option 組合條件的二維數組，例：$option[‘field1′] = array(1,’=’,’or’)

     * @return $this

     */

    public function where($option) {

        if ($this-_clear0) $this-_clear();

        $this-_where = ‘ where ‘;

        $logic = ‘and’;

        if (is_string($option)) {

            $this-_where .= $option;

        }

        elseif (is_array($option)) {

            foreach($option as $k=$v) {

                if (is_array($v)) {

                    $relative = isset($v[1]) ? $v[1] : ‘=’;

                    $logic    = isset($v[2]) ? $v[2] : ‘and’;

                    $condition = ‘ (‘.$this-_addChar($k).’ ‘.$relative.’ ‘.$v[0].’) ‘;

                }

                else {

                    $logic = ‘and’;

                    $condition = ‘ (‘.$this-_addChar($k).’=’.$v.’) ‘;

                }

                $this-_where .= isset($mark) ? $logic.$condition : $condition;

                $mark = 1;

            }

        }

        return $this;

    }

    /**

     * 設置排序

     * @param mixed $option 排序條件數組 例:array(‘sort’=’desc’)

     * @return $this

     */

    public function order($option) {

        if ($this-_clear0) $this-_clear();

        $this-_order = ‘ order by ‘;

        if (is_string($option)) {

            $this-_order .= $option;

        }

        elseif (is_array($option)) {

            foreach($option as $k=$v){

                $order = $this-_addChar($k).’ ‘.$v;

                $this-_order .= isset($mark) ? ‘,’.$order : $order;

                $mark = 1;

            }

        }

        return $this;

    }

    /**

     * 設置查詢行數及頁數

     * @param int $page pageSize不為空時為頁數，否則為行數

     * @param int $pageSize 為空則函數設定取出行數，不為空則設定取出行數及頁數

     * @return $this

     */

    public function limit($page,$pageSize=null) {

        if ($this-_clear0) $this-_clear();

        if ($pageSize===null) {

            $this-_limit = “limit “.$page;

        }

        else {

            $pageval = intval( ($page – 1) * $pageSize);

            $this-_limit = “limit “.$pageval.”,”.$pageSize;

        }

        return $this;

    }

    /**

     * 設置查詢字段

     * @param mixed $field 字段數組

     * @return $this

     */

    public function field($field){

        if ($this-_clear0) $this-_clear();

        if (is_string($field)) {

            $field = explode(‘,’, $field);

        }

        $nField = array_map(array($this,’_addChar’), $field);

        $this-_field = implode(‘,’, $nField);

        return $this;

    }

    /**

     * 清理標記函數

     */

    protected function _clear() {

        $this-_where = ”;

        $this-_order = ”;

        $this-_limit = ”;

        $this-_field = ‘*’;

        $this-_clear = 0;

    }

    /**

     * 手動清理標記

     * @return $this

     */

    public function clearKey() {

        $this-_clear();

        return $this;

    }

    /**

    * 啟動事務 

    * @return void 

    */ 

    public function startTrans() { 

        //數據rollback 支持 

        if ($this-_trans==0) self::$_dbh-beginTransaction();

        $this-_trans++; 

        return; 

    }

    /** 

    * 用於非自動提交狀態下面的查詢提交 

    * @return boolen 

    */

    public function commit() {

        $result = true;

        if ($this-_trans0) { 

            $result = self::$_dbh-commit(); 

            $this-_trans = 0;

        } 

        return $result;

    }

    /** 

    * 事務回滾 

    * @return boolen 

    */ 

    public function rollback() {

        $result = true;

        if ($this-_trans0) {

            $result = self::$_dbh-rollback();

            $this-_trans = 0;

        }

        return $result;

    }

    /**

    * 關閉連接

    * PHP 在腳本結束時會自動關閉連接。

    */

    public function close() {

        if (!is_null(self::$_dbh)) self::$_dbh = null;

    }

}

PHP訪問MYSQL數據庫封裝類(附函數說明)

複製代碼

代碼如下:

?php

/*

MYSQL

數據庫訪問封裝類

MYSQL

數據訪問方式，php4支持以mysql_開頭的過程訪問方式，php5開始支持以mysqli_開頭的過程和mysqli面向對象

訪問方式，本封裝類以mysql_封裝

數據訪問的一般流程：

1,連接數據庫

mysql_connect

or

mysql_pconnect

2,選擇數據庫

mysql_select_db

3,執行SQL查詢

mysql_query

4,處理返回的數據

mysql_fetch_array

mysql_num_rows

mysql_fetch_assoc

mysql_fetch_row

etc

*/

class

db_mysql

{

var

$querynum

=

;

//當前頁面進程查詢數據庫的次數

var

$dblink

;

//數據庫連接資源

//鏈接數據庫

function

connect($dbhost,$dbuser,$dbpw,$dbname=”,$dbcharset=’utf-8′,$pconnect=0

,

$halt=true)

{

$func

=

empty($pconnect)

?

‘mysql_connect’

:

‘mysql_pconnect’

;

$this-dblink

=

@$func($dbhost,$dbuser,$dbpw)

;

if

($halt

!$this-dblink)

{

$this-halt(“無法鏈接數據庫！”);

}

//設置查詢字符集

mysql_query(“SET

character_set_connection={$dbcharset},character_set_results={$dbcharset},character_set_client=binary”,$this-dblink)

;

//選擇數據庫

$dbname

@mysql_select_db($dbname,$this-dblink)

;

}

//選擇數據庫

function

select_db($dbname)

{

return

mysql_select_db($dbname,$this-dblink);

}

//執行SQL查詢

function

query($sql)

{

$this-querynum++

;

return

mysql_query($sql,$this-dblink)

;

}

//返回最近一次與連接句柄關聯的INSERT，UPDATE

或DELETE

查詢所影響的記錄行數

function

affected_rows()

{

return

mysql_affected_rows($this-dblink)

;

}

//取得結果集中行的數目,只對select查詢的結果集有效

function

num_rows($result)

{

return

mysql_num_rows($result)

;

}

//獲得單格的查詢結果

function

result($result,$row=0)

{

return

mysql_result($result,$row)

;

}

//取得上一步

INSERT

操作產生的

ID,只對錶有AUTO_INCREMENT

ID的操作有效

function

insert_id()

{

return

($id

=

mysql_insert_id($this-dblink))

=

?

$id

:

$this-result($this-query(“SELECT

last_insert_id()”),

0);

}

//從結果集提取當前行，以數字為key表示的關聯數組形式返回

function

fetch_row($result)

{

return

mysql_fetch_row($result)

;

}

//從結果集提取當前行，以字段名為key表示的關聯數組形式返回

function

fetch_assoc($result)

{

return

mysql_fetch_assoc($result);

}

//從結果集提取當前行，以字段名和數字為key表示的關聯數組形式返回

function

fetch_array($result)

{

return

mysql_fetch_array($result);

}

//關閉鏈接

function

close()

{

return

mysql_close($this-dblink)

;

}

//輸出簡單的錯誤html提示信息並終止程序

function

halt($msg)

{

$message

=

“html\nhead\n”

;

$message

.=

“meta

content=’text/html;charset=gb2312’\n”

;

$message

.=

“/head\n”

;

$message

.=

“body\n”

;

$message

.=

“數據庫出錯：”.htmlspecialchars($msg).”\n”

;

$message

.=

“/body\n”

;

$message

.=

“/html”

;

echo

$message

;

exit

;

}

}

?

python如何使用pymysql連接數據庫封裝類

1、python安裝目錄設定為d:/python34

2、pymysql安裝方法為：解壓下載的文件，在cmd中運行: python setup.py install。

檢驗安裝安裝是否成功的方法：import pymysql 。 如果不報錯 說明安裝成功。

3、mysql安裝目錄為D:/phpStudy/MySQL。為避免更多配置問題，可在啟動phpstudy後，將其設為系統服務

4、基本操作：

（1）導入pymysql: import pymysql

（2）連接數據庫：

conn=pymysql.connect(host=’localhost’,user=’root’,passwd=’root’,db=’ere’，charset=’utf8′)

務必注意各等號前面的內容！charset參數可避免中文亂碼

（3）獲取操作游標：cur=conn.cursor()

（4）執行sql語句,插入記錄：sta=cur.execute(“insert 語句”) 執行成功後sta值為1。更新、刪除語句與此類似。

（5）執行sql語句，查詢記錄：cur.execute(“select語句”) 執行成功後cur變量中保存了查詢結果記錄集，然後再用循環打印結果：

for each in cur:

print(each[1].decode(‘utf-8’)) # each[1] 表示當前游標所在行的的第2列值，如果是中文則需要處理編碼

本地安裝好MYSQL數據庫後怎麼連接

1、進行打開電腦Navicat for mysql已經安裝好的，然後進行點擊右上角的「連接」選項。

2、這樣就會彈出了一個新建連接的窗口的界面中，在連接名中輸入名稱，而在主機名在本地的數據庫，所以使用localhost即可，密碼為空即可。

3、然後方便連接的數據庫是否連接成功的話，那麼就需要先測試下，進行點擊連接測試。

4、可以看到的顯示連接成功了，然後進行點擊確定即可。

5、進入連接數據界面中，現在不能顯示為需要的數據庫，需要進行雙擊即可。

6、可以看到顯示這個用戶名的所有的數據庫。

jdbc連接數據庫的代碼問題jdbc連接mysql數據庫

用這個類吧.好的話,給我加加分.

import java.sql.*;

/**

* @功能: 一個JDBC的本地化API連接類,封裝了數據操作方法,只用傳一個SQL語句即可

* @作者: 李開歡

* @日期: 2007/

*/

public class ConnectionDemo {

/*

* 這裡可以將常量全部放入另一個類中,以方便修改

*/

private static Connection conn;

private static Statement ps;

private static ResultSet rs;

private static final String DRIVER = “com.microsoft.jdbc.sqlserver.SQLServerDriver”;

private static final String URL = “jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=mydb”;

private static final String USER =”sa”;

private static final String PASS = “sa”;

public ConnectionDemo() {

// TODO Auto-generated constructor stub

ConnectionDemo.getConnection();

}

public static Connection getConnection(){

System.out.println(“連接中…”);

try {

Class.forName(ConnectionDemo.DRIVER);

conn = DriverManager.getConnection(ConnectionDemo.URL, ConnectionDemo.USER, ConnectionDemo.PASS);

System.out.println(“成功連接”);

} catch (ClassNotFoundException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return conn;

}

public static Statement getStatement(String sql){

System.out.println(“執行SQL語句中…”);

try {

ps = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);

if(sql.substring(0, 6).equals(“select”)){

rs = ps.executeQuery(sql);

System.out.println(“執行完查詢操作,結果已返回ResultSet集合”);

}else if(sql.substring(0, 6).equals(“delete”)){

ps.executeUpdate(sql);

System.out.println(“已執行完畢刪除操作”);

}else if(sql.substring(0, 6).equals(“insert”)){

ps.executeUpdate(sql);

System.out.println(“已執行完畢增加操作”);

}else{

ps.executeUpdate(sql);

System.out.println(“已執行完畢更新操作”);

}

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

return ps;

}

public static ResultSet getResultSet(){

System.out.println(“查詢結果為:”);

return rs;

}

public static void closeConnection(){

System.out.println(“關閉連接中…”);

try {

if (rs != null) {

rs.close();

System.out.println(“已關閉ResultSet”);

}

if (ps != null) {

ps.close();

System.out.println(“已關閉Statement”);

}

if (conn != null) {

conn.close();

System.out.println(“已關閉Connection”);

}

} catch (Exception e) {

// TODO: handle exception

}

}

public static void main(String[] args) {

// TODO Auto-generated method stub

ConnectionDemo.getConnection();

String sql = “delete from type where id = 1”;

ConnectionDemo.getStatement(sql);

String sql2 = “insert into type values(1,’教學設備’)”;

ConnectionDemo.getStatement(sql2);

String sql1 = “select * from type”;

ConnectionDemo.getStatement(sql1);

ResultSet rs = ConnectionDemo.getResultSet();

System.out.println(“編號 “+”類 型”);

try {

while(rs.next()){

System.out.print(” “+rs.getInt(1)+” “);

System.out.println(rs.getString(2));

}

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

ConnectionDemo.closeConnection();

}

}