这篇文章主要介绍了PHP基于pdo的数据库操作类,可实现基本的数据库连接、增删改查、关闭连接等操作,还支持针对mysql、sqlserver及oracle等数据库的操作,需要的朋友可以参考下
<?php
class Pdodb{
protected $pdo;
protected $res;
protected $config;
/*构造函数*/
function __construct($config){
$this->Config = $config;
$this->connect();
}
/*数据库连接*/
public function connect(){
try {
$this->pdo= new PDO($this->Config['dsn'], $this->Config['username'], $this->Config['password']);//$dbh = new PDO('mysql:host=localhost;dbname=test', $user, $pass);
$this->pdo->query("set names utf8");
}catch(Exception $e){
echo '数据库连接失败,详情: ' . $e->getMessage () . ' 请在配置文件中数据库连接信息';
exit ();
}
/*
if($this->Config['type']=='oracle'){
$this->pdo->query("set names {$this->Config['charset']};");
}else{
$this->pdo->query("set names {$this->Config['charset']};");
}
*/
//把结果序列化成stdClass
//$this->pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ);
//自己写代码捕获Exception
//$this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
$this->pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);//属性名 属性值 数组以关联数组返回
}
/*数据库关闭*/
public function close(){
$this->pdo = null;
}
//用于有记录结果返回的操作，特别是SELECT操作
public function query($sql,$return=false){
$res = $this->pdo->query($sql);
if($res){
$this->res = $res; // 未返回 return $this->res;
}
if($return){
return $res;
}
}
//主要是针对没有结果集合返回的操作，比如INSERT、UPDATE、DELETE等操作
public function exec($sql,$return=false){
$res = $this->pdo->exec($sql);
if($res){
$this->res = $res;
}
if($return){//返回操作是否成功 成功返回1 失败0
return $res;
}
}
//将$this->res以数组返回(全部返回)
public function fetchAll(){
return $this->res->fetchAll();
}
//将$this->res以数组返回(一条记录)
public function fetch(){
return $this->res->fetch();
}
//返回所有字段
public function fetchColumn(){
return $this->res->fetchColumn();
}
//返回最后插入的id
public function lastInsertId(){
return $this->res->lastInsertId();
}
//返回最后插入的id
public function lastInsertId2(){
return $this->pdo->lastInsertId();
}
/**
* 参数说明
* string/array $table 数据库表，两种传值模式
* 普通模式：
* 'tb_member, tb_money'
* 数组模式：
* array('tb_member', 'tb_money')
* string/array $fields 需要查询的数据库字段，允许为空，默认为查找全部，两种传值模式
* 普通模式：
* 'username, password'
* 数组模式：
* array('username', 'password')
* string/array $sqlwhere 查询条件，允许为空，两种传值模式
* 普通模式(必须加上and,$sqlwhere为空 1=1 正常查询)：
* 'and type = 1 and username like "%os%"'
* 数组模式：
* array('type = 1', 'username like "%os%"')
* string $orderby 排序，默认为id倒序
*int $debug 是否开启调试，开启则输出sql语句
* 0 不开启
* 1 开启
* 2 开启并终止程序
* int $mode 返回类型
* 0 返回多条记录
* 1 返回单条记录
* 2 返回行数
*/
public function select($table, $fields="*", $sqlwhere="", $orderby="", $debug=0, $mode=0){
//参数处理
if(is_array($table)){
$table = implode(', ', $table);
}
if(is_array($fields)){
$fields = implode(',',$fields);
/*
if($this->Config['type']=='oracle'){
//$fields = implode(',',$fields);//CUSTOMER_ID,FIRST_NAME,LAST_NAME,EMAIL
//$fields = implode(",'UTF8','ZHS16GBK') ,convert(",$fields);
//$fields="convert(".$fields.",'UTF8','ZHS16GBK')";
}else{
$fields = implode(',',$fields);
}
*/
}
if(is_array($sqlwhere)){
$sqlwhere = ' and '.implode(' and ', $sqlwhere);
}
//数据库操作
if($debug === 0){
if($mode === 2){ //统计
$this->query("select count(*) from $table where 1=1 $sqlwhere");
$return = $this->fetchColumn();
}else if($mode === 1){ //返回一条
$this->query("select $fields from $table where 1=1 $sqlwhere $orderby");
$return = $this->fetch();
}else{
$this->query("select $fields from $table where 1=1 $sqlwhere $orderby");
$return = $this->fetchAll();//如果 $this->res为空即sql语句错误 会提示Call to a member function fetchAll() on a non-object
}
return $return;
}else{
if($mode === 2){
echo "select count(*) from $table where 1=1 $sqlwhere";
}else if($mode === 1){
echo "select $fields from $table where 1=1 $sqlwhere $orderby";
}else{
echo "select $fields from $table where 1=1 $sqlwhere $orderby";
}
if($debug === 2){
exit;
}
}
}
/**
* 参数说明
* 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()')
* int $debug 是否开启调试，开启则输出sql语句
* 0 不开启
* 1 开启
* 2 开启并终止程序
* int $mode 返回类型
* 0 无返回信息
* 1 返回执行条目数
* 2 返回最后一次插入记录的id
*/
public function oic_insert($table, $set, $debug=0, $mode=0){
//参数处理
if(is_array($table)){
$table = implode(', ', $table);
}
if(is_array($set)){
$s='';$i=0;
foreach($set as $k=>$v){
$i++;
$s[$i]=$k;//,连接
$val[$i]=$v;
}
$sarr=implode(",",$s);//去掉最后一个,
//array_pop($sarr);
$set=implode("','",$val);////15221579236','张三','','2001','8','4','女','是
//$set = implode(', ', $set);
}
//数据库操作
if($debug === 0){
if($mode === 2){
$this->query("insert into $table ($sarr) values('".$set."')");
//$return = $this->lastInsertId();
}else if($mode === 1){
$this->exec("insert into $table ($sarr) values('".$set."')");
$return = $this->res;
}else{
$this->query("insert into $table ($sarr) values('".$set."')");
$return = NULL;
}
return $return;
}else{
echo "insert into $table ($sarr) values('".$set."')";
if($debug === 2){
exit;
}
}
}
public function insert($table, $set, $debug=0, $mode=0){
//参数处理
if(is_array($table)){
$table = implode(', ', $table);
}
if(is_array($set)){
$s='';
foreach($set as $k=>$v){
$s.=$k."='".$v."',";//,连接
}
$sarr=explode(',',$s);//去掉最后一个,
array_pop($sarr);
$set=implode(',',$sarr);
//$set = implode(', ', $set);
}
//数据库操作
if($debug === 0){
if($mode === 2){
$this->query("insert into $table set $set");
$return = $this->pdo->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;
}
}
}
/**
* 参数说明
* 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%"')
* int $debug 是否开启调试，开启则输出sql语句
* 0 不开启
* 1 开启
* 2 开启并终止程序
* int $mode 返回类型
* 0 无返回信息
* 1 返回执行条目数
*/
public function update($table, $set, $sqlwhere="", $debug=0, $mode=0){
//参数处理
if(is_array($table)){
$table = implode(', ', $table);
}
if(is_array($set)){
$s='';
foreach($set as $k=>$v){
$s.=$k."='".$v."',";
}
$sarr=explode(',',$s);//去掉最后一个,
array_pop($sarr);
$set=implode(',',$sarr);
//$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 = true;
}
return $return;
}else{
echo "update $table set $set where 1=1 $sqlwhere";
if($debug === 2){
exit;
}
}
}
/**
* 参数说明
* string $table 数据库表
* string/array $sqlwhere 删除条件，允许为空，两种传值模式
* 普通模式：
* 'and type = 1 and username like "%os%"'
* 数组模式：
* array('type = 1', 'username like "%os%"')
* int $debug 是否开启调试，开启则输出sql语句
* 0 不开启
* 1 开启
* 2 开启并终止程序
* int $mode 返回类型
* 0 无返回信息
* 1 返回执行条目数
*/
public function delete($table, $sqlwhere="", $debug=0, $mode=0){
//参数处理
if(is_array($sqlwhere)){
$sqlwhere = ' and '.implode(' and ', $sqlwhere); //是字符串需自己加上and
}
//数据库操作
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;
}
}
}
}
/*
sqlserver 配置 extension=php_pdo_mssql.dll和extension=php_pdo_sqlsrv.dll 安装对应的 ntwdblib.dll
http://msdn.microsoft.com/en-us/library/cc296170.aspx 下载php版本对应的sqlsrv扩展
sqlserver 配置 odbc连接需开启extension=php_pdo_odbc.dll
*/
$mssql2008_config=array(
'dsn'=>'odbc:Driver={SQL Server};Server=192.168.1.60;Database=his',//数据库服务器地址
'username'=>'sa',
'password'=>'xxxxx',
);
$mssql=new Pdodb($mssql2008_config);
$sql="select * from
(
select row_number()over(order by tempcolumn)temprownumber,*
from (
select top 10 tempcolumn=0,a.*
from DA_GR_HBFS a
where 1=1
) t
) tt
where temprownumber>0";
$mssql->query($sql);
while($res=$mssql->fetch()){
$data[]=$res;
}
print_r($data);exit;
//mysql 操作
$msyql_config=array(
'dsn'=>'mysql:host=localhost;dbname=talk',
'username'=>'root',
'password'=>'123456'
);
$mysql=new PDO_DB($msyql_config);
$sql = 'SELECT user_id, user_name, nickname FROM et_users ';
$mysql->query($sql);
$data=$mysql->fetchAll();
print_r($data);exit;
//oracle 操作
$oci_config=array(
'dsn'=>'oci:dbname=orcl',
'username'=>'BAOCRM',
'password'=>'BAOCRM'
);
$oracle=new PDO_DB($oci_config);
//print_r($oracle);exit;//PDO_DB Object ( [pdo:protected] => PDO Object ( ) [res:protected] => [config:protected] => [Config] => Array ( [dsn] => oci:dbname=orcl [name] => PWACRM [password] => PWACRM ) )
$sql="select * from CUSTOMER_LEVEL t";
$oracle->query($sql);
$data=$oracle->fetchAll();
print_r($data);exit;
/*
Array
(
[0] => Array
(
[LEVEL_ID] => 1
[0] => 1
[LEVEL_NAME] => 普通会员
[1] => 普通会员
[LEVEL_DETAIL] => 普通会员
[2] => 普通会员
[SORT_NUMBER] => 15
[3] => 15
[CREATE_TIME] => 12-7月 -12
[4] => 12-7月 -12
[CREATE_BY] => 1
[5] => 1
[UPDATE_TIME] => 12-7月 -12
[6] => 12-7月 -12
[UPDATE_BY] => 1
[7] => 1
[STATE] => 正常
[8] => 正常
)
)*/
?>登录后复制
