您的位置:

封装mysql数据库连接类(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();

}

}