您的位置:

php连接mysql的封装类(php与mysql集成)

本文目录一览:

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列值,如果是中文则需要处理编码

php实现mysql封装类示例

php封装mysql类

复制代码

代码如下:

?php

class

Mysql

{

private

$host;

private

$user;

private

$pwd;

private

$dbName;

private

$charset;

private

$conn

=

null;

public

function

__construct()

{

$this-host

=

'localhost';

$this-user

=

'root';

$this-pwd

=

'root';

$this-dbName

=

'test';

$this-connect($this-host,$this-user,$this-pwd);

$this-switchDb($this-dbName);

$this-setChar($this-charset);

}

//负责链接

private

function

connect($h,$u,$p)

{

$conn

=

mysql_connect($h,$u,$p);

$this-conn

=

$conn;

}

//负责切换数据库

public

function

switchDb($db)

{

$sql

=

'use'

.

$db;

$this-query($sql);

}

//负责设置字符集

public

function

setChar($char)

{

$sql

=

'set

names'

.

$char;

$this-query($sql);

}

//负责发送sql查询

public

function

query($sql)

{

return

mysql_query($sql,$this-conn);

}

//负责获取多行多列的select结果

public

function

getAll($sql)

{

$list

=

array();

$rs

=

$this-query($sql);

if

(!$rs)

{

return

false;

}

while

($row

=

mysql_fetch_assoc($rs))

{

$list[]

=

$row;

}

return

$list;

}

public

function

getRow($sql)

{

$rs

=

$this-query($sql);

if(!$rs)

{

return

false;

}

return

mysql_fetch_assoc($rs);

}

public

function

getOne($sql)

{

$rs

=

$this-query($sql);

if

(!$rs)

{

return

false;

}

return

mysql_fetch_assoc($rs);

return

$row[0];

}

public

function

close()

{

mysql_close($this-conn);

}

}

echo

'pre';

$mysql

=

new

Mysql();

print_r($mysql);

$sql

=

"insert

into

stu

values

(4,'wangwu','99998')";

if($mysql-query($sql)){

echo

"query成功";

}else

{

echo

"失败";

}

echo

"br

/";

$sql

=

"select

*

from

stu";

$arr

=

$mysql-getAll($sql);

print_r($arr);

?

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

;

}

}

?

求个好用的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;

    }

}