首页 > php教程 > PHP开发 > 正文

全新的PDO数据库操作类php版

高洛峰
发布: 2016-12-02 13:55:56
原创
1317人浏览过

复制代码 代码如下: 

class hrdb{ 
protected $pdo; 
protected $res; 
protected $config; 

/*构造函数*/ 
function __construct($config){ 
$this->config = $config; 
$this->connect(); 


/*数据库连接*/ 
public function connect(){ 
$this->pdo = new pdo($this->config['dsn'], $this->config['name'], $this->config['password']); 
$this->pdo->query('set names utf8;'); 
//把结果序列化成stdclass 
//$this->pdo->setattribute(pdo::attr_default_fetch_mode, pdo::fetch_obj); 
//自己写代码捕获exception 
$this->pdo->setattribute(pdo::attr_errmode, pdo::errmode_exception); 


/*数据库关闭*/ 
public function close(){ 
$this->pdo = null; 


public function query($sql){ 
$res = $this->pdo->query($sql); 
if($res){ 
$this->res = $res; 


public function exec($sql){ 
$res = $this->pdo->exec($sql); 
if($res){ 
$this->res = $res; 


public function fetchall(){ 
return $this->res->fetchall(); 

public function fetch(){ 
return $this->res->fetch(); 

public function fetchcolumn(){ 
return $this->res->fetchcolumn(); 

public function lastinsertid(){ 
return $this->res->lastinsertid(); 


/** 
* 参数说明 
* int $debug 是否开启调试,开启则输出sql语句 
* 0 不开启 
* 1 开启 
* 2 开启并终止程序 
* int $mode 返回类型 
* 0 返回多条记录 
* 1 返回单条记录 
* 2 返回行数 
* string/array $table 数据库表,两种传值模式 
* 普通模式: 
* 'tb_member, tb_money' 
* 数组模式: 
* array('tb_member', 'tb_money') 
* string/array $fields 需要查询的数据库字段,允许为空,默认为查找全部,两种传值模式 
* 普通模式: 
* 'username, password' 
* 数组模式: 
* array('username', 'password') 
* string/array $sqlwhere 查询条件,允许为空,两种传值模式 
* 普通模式: 
* 'and type = 1 and username like "%os%"' 
* 数组模式: 
* array('type = 1', 'username like "%os%"') 
* string $orderby 排序,默认为id倒序 
*/ 
public function select($debug, $mode, $table, $fields="*", $sqlwhere="", $orderby="tbid desc"){ 
//参数处理 
if(is_array($table)){ 
$table = implode(', ', $table); 

if(is_array($fields)){ 
$fields = implode(', ', $fields); 

if(is_array($sqlwhere)){ 
$sqlwhere = ' and '.implode(' and ', $sqlwhere); 

//数据库操作 
if($debug === 0){ 
if($mode === 2){ 
$this->query("select count(tbid) from $table where 1=1 $sqlwhere"); 
$return = $this->fetchcolumn(); 
}else if($mode === 1){ 
$this->query("select $fields from $table where 1=1 $sqlwhere order by $orderby"); 
$return = $this->fetch(); 
}else{ 
$this->query("select $fields from $table where 1=1 $sqlwhere order by $orderby"); 
$return = $this->fetchall(); 

return $return; 
}else{ 
if($mode === 2){ 
echo "select count(tbid) from $table where 1=1 $sqlwhere"; 
}else if($mode === 1){ 
echo "select $fields from $table where 1=1 $sqlwhere order by $orderby"; 

else{ 
echo "select $fields from $table where 1=1 $sqlwhere order by $orderby"; 

if($debug === 2){ 
exit; 




/** 
* 参数说明 
* int $debug 是否开启调试,开启则输出sql语句 
* 0 不开启 
* 1 开启 
* 2 开启并终止程序 
* int $mode 返回类型 
* 0 无返回信息 
* 1 返回执行条目数 
* 2 返回最后一次插入记录的id 
* string/array $table 数据库表,两种传值模式 
* 普通模式: 
* 'tb_member, tb_money' 
* 数组模式: 
* array('tb_member', 'tb_money') 
* string/array $set 需要插入的字段及内容,两种传值模式 
* 普通模式: 
* 'username = "test", type = 1, dt = now()' 
* 数组模式: 
* array('username = "test"', 'type = 1', 'dt = now()') 
*/ 
public function insert($debug, $mode, $table, $set){ 
//参数处理 
if(is_array($table)){ 
$table = implode(', ', $table); 

if(is_array($set)){ 
$set = implode(', ', $set); 

//数据库操作 
if($debug === 0){ 
if($mode === 2){ 
$this->query("insert into $table set $set"); 
$return = $this->lastinsertid(); 
}else if($mode === 1){ 
$this->exec("insert into $table set $set"); 
$return = $this->res; 
}else{ 
$this->query("insert into $table set $set"); 
$return = null; 

return $return; 
}else{ 
echo "insert into $table set $set"; 
if($debug === 2){ 
exit; 




/** 
* 参数说明 
* int $debug 是否开启调试,开启则输出sql语句 
* 0 不开启 
* 1 开启 
* 2 开启并终止程序 
* int $mode 返回类型 
* 0 无返回信息 
* 1 返回执行条目数 
* string $table 数据库表,两种传值模式 
* 普通模式: 
* 'tb_member, tb_money' 
* 数组模式: 
* array('tb_member', 'tb_money') 
* string/array $set 需要更新的字段及内容,两种传值模式 
* 普通模式: 
* 'username = "test", type = 1, dt = now()' 
* 数组模式: 
* array('username = "test"', 'type = 1', 'dt = now()') 
* string/array $sqlwhere 修改条件,允许为空,两种传值模式 
* 普通模式: 
* 'and type = 1 and username like "%os%"' 
* 数组模式: 
* array('type = 1', 'username like "%os%"') 
*/ 
public function update($debug, $mode, $table, $set, $sqlwhere=""){ 
//参数处理 
if(is_array($table)){ 
$table = implode(', ', $table); 

if(is_array($set)){ 
$set = implode(', ', $set); 

if(is_array($sqlwhere)){ 
$sqlwhere = ' and '.implode(' and ', $sqlwhere); 

//数据库操作 
if($debug === 0){ 
if($mode === 1){ 
$this->exec("update $table set $set where 1=1 $sqlwhere"); 
$return = $this->res; 
}else{ 
$this->query("update $table set $set where 1=1 $sqlwhere"); 
$return = null; 

return $return; 
}else{ 
echo "update $table set $set where 1=1 $sqlwhere"; 
if($debug === 2){ 
exit; 




/** 
* 参数说明 
* int $debug 是否开启调试,开启则输出sql语句 
* 0 不开启 
* 1 开启 
* 2 开启并终止程序 
* int $mode 返回类型 
* 0 无返回信息 
* 1 返回执行条目数 
* string $table 数据库表 
* string/array $sqlwhere 删除条件,允许为空,两种传值模式 
* 普通模式: 
* 'and type = 1 and username like "%os%"' 
* 数组模式: 
* array('type = 1', 'username like "%os%"') 
*/ 
public function delete($debug, $mode, $table, $sqlwhere=""){ 
//参数处理 
if(is_array($sqlwhere)){ 
$sqlwhere = ' and '.implode(' and ', $sqlwhere); 

//数据库操作 
if($debug === 0){ 
if($mode === 1){ 
$this->exec("delete from $table where 1=1 $sqlwhere"); 
$return = $this->res; 
}else{ 
$this->query("delete from $table where 1=1 $sqlwhere"); 
$return = null; 

return $return; 
}else{ 
echo "delete from $table where 1=1 $sqlwhere"; 
if($debug === 2){ 
exit; 





其实使用上,和之前的相差不大,目的就是为了方便移植。 

  本次重写着重处理了几个问题: 

  ① insert语句太复杂,fields与values对应容易出现误差 

  我们看下最常见的一句sql插入语句 

复制代码 代码如下:insert into tb_member (username, type, dt) values ('test', 1, now()) 
  在传统模式下,fields和values参数是分开传入的,但却要保证两者参数传入的顺序一致。这很容易导致顺序错乱或者漏传某个参数。 

  这次已经把问题修改了,采用了mysql独有的insert语法,同样是上面那功能,就可以换成这样的写法 

复制代码 代码如下:insert into tb_member set username = "test", type = 1, lastlogindt = now() 
  就像update一样,一目了然。 

  ② 部分参数可以用数组代替 

  比如这样一句sql 

复制代码 代码如下:delete from tb_member where 1=1 and tbid = 1 and username = "hooray" 
  在原先调用方法的时候,需要手动拼装好where条件,这样操作的成本很高,现在完全可以用这种形式 
复制代码 代码如下: 
$where = array( 
'tbid = 1', 
'username = "hooray"' 
); 
$db->delete(1, 0, 'tb_member', $where); 

  条件再多也不会打乱你的思路。同样,不仅仅是where参数,update里的set也可以以这种形式(具体可参见完整源码) 

复制代码 代码如下: 
$set = array('username = "123"', 'type = 1', 'lastlogindt = now()'); 
$where = array('tbid = 1'); 
$db->update(1, 0, 'tb_member', $set, $where); 

  ③ 可自定义sql语句 

  有时候,sql过于复杂,导致无法使用类里提供的方法去组装sql语句,这时候就需要一个功能,就是能直接传入我已经组装好的sql语句执行,并返回信息。现在,这功能也有了 

复制代码 代码如下: 
$db->query('select username, password from tb_member'); 
$rs = $db->fetchall(); 

  是不是很像pdo原生态的写法? 

  ④ 支持创建多数据库连接 

  原先的因为只是数据库操作方法,所以并不支持多数据库连接,在实现上需要复制出2个相同的文件,修改部分变量,操作实属复杂。现在这问题也解决了。 

复制代码 代码如下: 
$db_hoorayos_config = array( 
'dsn'=>'mysql:host=localhost;dbname=hoorayos', 
'name'=>'root', 
'password'=>'hooray' 
); 
$db = new hrdb($db_hoorayos_config); 

$db_hoorayos_config2 = array( 
'dsn'=>'mysql:host=localhost;dbname=hoorayos2', 
'name'=>'root', 
'password'=>'hooray' 
); 
$db2 = new hrdb($db_hoorayos_config2); 

  这样就能同时创建2个数据库连接,方便处理数据库与数据库交互的情况。 

  大致新功能就是这么多了,整个代码并不多,欢迎阅读了解。下面是我在编写时写的测试代码,也一并提供上来,方便大家学习。 

复制代码 代码如下: 
require_once('global.php'); 
require_once('inc/setting.inc.php'); 

$db = new hrdb($db_hoorayos_config); 

echo '


select测试
'; 
echo '普通模式,直接字符串传入
'; 
$rs = $db->select(1, 0, 'tb_member', 'username, password', 'and type = 1 and username like "%os%"'); 
echo '
数组模式,可传入数组
'; 
$fields = array('username', 'password'); 
$where = array('type = 1', 'username like "%os%"'); 
$rs = $db->select(1, 0, 'tb_member', $fields, $where); 

echo '
insert测试
'; 
echo '普通模式,直接字符串传入
'; 
$db->insert(1, 0, 'tb_member', 'username = "test", type = 1, lastlogindt = now()'); 
echo '
数组模式,可传入数组
'; 
$set = array('username = "test"', 'type = 1', 'lastlogindt = now()'); 
$db->insert(1, 0, 'tb_member', $set); 

echo '
update测试
'; 
echo '普通模式,直接字符串传入
'; 
$db->update(1, 0, 'tb_member', 'username = "123", type = 1, lastlogindt = now()', 'and tbid = 7'); 
echo '
数组模式,可传入数组
'; 
$set = array('username = "123"', 'type = 1', 'lastlogindt = now()'); 
$where = array('tbid = 1'); 
$db->update(1, 0, 'tb_member', $set, $where); 

echo '
delete测试
'; 
echo '普通模式,直接字符串传入
'; 
$db->delete(1, 0, 'tb_member', 'and tbid = 1 and username = "hooray"'); 
echo '
数组模式,可传入数组
'; 
$where = array( 
'tbid = 1', 
'username = "hooray"' 
); 
$db->delete(1, 0, 'tb_member', $where); 

echo '
自定义sql
'; 
$db->query('select username, password from tb_member'); 
$rs = $db->fetchall(); 
var_dump($rs); 

$db->close(); 
PHP速学教程(入门到精通)
PHP速学教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载
来源:php中文网
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
最新问题
开源免费商场系统广告
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习
PHP中文网抖音号
发现有趣的

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号