PHP PDO封装静态类代码分享 -php教程-PHP中文網

/**
* Class DB
* 数据库操作类
*/
class DB {
/**
* @var
* @return CDB
*/
private static $db;
/**获取CDb类
* @param $table_name 表名称
* @param string $db_setting 调用数据库配置项
* @param array $db_config 数据库配置
* @return CDb
*/
public static function cdb($table_name='',$db_setting='default',$db_config=array()){
if(!isset(self::$db)){
$db = new CDb($table_name,$db_setting,$db_config);
self::$db=$db;
}else{
$db=self::$db;
}
return $db;
}
/** 配置
* @param $table_name 表名称
* @param string $db_setting 调用数据库配置项
* @param array $db_config 数据库配置
* @return CDb
*/
public static function init($table_name='',$db_setting='default',$db_config=array()) {
return self::cdb($table_name,$db_setting,$db_config);
}
/**
* 执行删除记录操作
* @param $table 表名称
* @param $condition 删除数据条件,不充许为空。可以为数组
* @return boolean
*/
public static function delete($table, $condition) {
$db=self::cdb();
$db->setTableName($table);
return $db->delete($condition);
}
/**
* 执行添加记录操作
* @param $table 表名称
* @param array $data要增加的数据，参数为数组。数组key为字段值，数组值为数据取值
* @param bool $return_insert_id 是否返回新建ID号
* @param bool $replace 是否采用 replace into的方式添加数据
* @return boolean
*/
public static function insert($table, $data, $return_insert_id = false, $replace = false) {
$db=self::cdb();
$db->setTableName($table);
return $db->insert($data, $return_insert_id, $replace);
}
/**
* 获取最后一次添加记录的主键号
* @return int
*/
public static function insertID() {
$db=self::cdb();
return $db->insert_id();
}
/**
* 执行更新记录操作
* @param $table 表名称
* @param $data 要更新的数据内容，参数为数组
* 为数组时数组key为字段值，数组值为数据取值
* 为数组时[例: array('name'=>'lanmps','password'=>'123456')]
* 数组的另一种使用array('name'=>'+=1', 'base'=>'-=1');程序会自动解析为`name` = `name` + 1, `base` = `base` - 1
* 字符串,请按照格式：
* 字符串 [例2：array('catid=:catid AND time>=:time ',array(':catid'=>10,':time'=>'2012-02-10')) ]
* @param $where 更新数据时的条件,
* 字符串,请按照格式：
* 字符串 [例1：" id=1 and time>$time " ]
* 字符串 [例2：array('catid=:catid AND time>=:time ',array(':catid'=>10,':time'=>'2012-02-10')) ]
* 数组时 [例: array('name'=>'lanmps','password'=>'123456')]
* @return boolean
*/ bbs.it-home.org
public static function update($table, $data, $where) {
$db=self::cdb();
$db->setTableName($table);
return $db->update($data,$where);
}
/**
* 获取单条记录查询
* @param array $sql 查询条件语句
* @return array/null数据查询结果集,如果不存在，则返回空
*/
public static function fetchFirst($sql) {
$db=self::cdb();
return $db->fetch($sql);
}
/**
* 执行sql查询
* @param $sql查询条件
* @return array 查询结果集数组
*/
public static function fetchAll($sql) {
$db=self::cdb();
return $db->fetchAll($sql);
}
/**
* 直接执行sql查询
* @param $sql 查询sql语句
* @return
*/
public static function query($sql) {
$db=self::cdb();
return $db->exec($sql);
}
/**
* 执行sql查询
* @param $table 表名称
* @param $where 查询条件
* 字符串,请按照格式：
* 字符串 [例1：" id=1 and time>$time " ]
* 字符串 [例2：array('catid=:catid AND time>=:time ',array(':catid'=>10,':time'=>'2012-02-10')) ]
* 数组时 [例: array('name'=>'lanmps','password'=>'123456')]
* @param $fields需要查询的字段值[例`name`,`gender`,`birthday`]
* @param $limit 返回结果范围[例：10或10,10 默认为空]
* @param $order 排序方式 [默认按数据库默认方式排序]
* @param $group 分组方式 [默认为空]
* @return array 查询结果集数组
*/
public static function select($table,$where = '', $fields = '*', $limit = '', $order = '', $group = '') {
$db=self::cdb();
$db->setTableName($table);
return $db->select($where , $fields , $limit, $order , $group);
}
/**
* 获取单条记录查询
* @param $table 表名称
* @param array $where查询条件语句
* 字符串,请按照格式：
* 字符串 [例2：array('catid=:catid AND time>=:time ',array(':catid'=>10,':time'=>'2012-02-10')) ]
* 数组时 [例: array('name'=>'lanmps','password'=>'123456')]
* @param string $fields 需要查询的字段值[例`name`,`gender`,`birthday`]
* @param string $order 排序方式 [默认按数据库默认方式排序]
* @param string $group 分组方式 [默认为空]
* @return array/null数据查询结果集,如果不存在，则返回空
*/
public static function getOne($table,$where,$fields = '*', $order = '', $group = '') {
$db=self::cdb();
$db->setTableName($table);
return $db->get_one($where , $fields,$order, $group);
}
/**
* 查询多条数据并分页
* @param $table 表名称
* @param $where 查询条件
* 字符串,请按照格式：
* 字符串 [例1：" id=1 and time>$time " ]
* 字符串 [例2：array('catid=:catid AND time>=:time ',array(':catid'=>10,':time'=>'2012-02-10')) ]
* 数组时 [例: array('name'=>'lanmps','password'=>'123456')]
* @param $fields字段 *,id
* @param $order 排序 id desc ,orderlist asc
* @param $page 页码 1
* @param $pagesize 每页条数
* @return array('data'=>数据,'count'=>记录总数)
*/
public static function listInfo($table,$where = '',$fields='*', $order = '', $page = 1, $pagesize = 20) {
$db=self::cdb();
$db->setTableName($table);
$d=$db->listinfo($where,$fields, $order, $page, $pagesize);
return array('data'=>$d,'count'=>self::$db->number);
}
/**第一个参数值
* @param $sql
* @return mixed
*/
public static function resultFirst($sql){
$db=self::cdb();
return $db->resultFirst($sql);
}
}

复制代码

调用方法：

DB::insert('test',array('name'=>'test'));