php
class db{
private $db;
const MYSQL_OPT_READ_TIMEOUT = 11;
private $tbl_name;
private $where;
private $sort;
private $fields;
private $limit;
public static $_instance = null;
function __construct(){
$cfg = loadConfig('db');
$db = mysqli_init();
$db-options(self::MYSQL_OPT_WRITE_TIMEOUT, 1);
@$db-real_connect($cfg['host'],$cfg['user'],$cfg['pwd'],$cfg['db']);
if ($db-connect_error) {
$this-crash($db-errno,$db-error);
}
$this-db = $db;
//echo $this-db-stat;
public static function getInstance(){
if(!(self::$_instance instanceof self)){
self::$_instance = new self();
return self::$_instance;
private function __clone() {} //覆盖__clone()方法,禁止克隆
public function find($conditions = null){
if($conditions) $this-where($conditions);
return $this-getArray($this-buildSql(),1);
public function findAll($conditions = null){
return $this-getArray($this-buildSql());
//表
public function t($table){ $this-tbl_name = $table; return $this;}
//条件
public function where($conditions){
$where = '';
if(is_array($conditions)){
$join = array();
foreach( $conditions as $key = $condition ){
$condition = $this-db-real_escape_string($condition);
$join[] = "+{$key}+ = '{$condition}'";
$where = "WHERE ".join(" AND ",$join);
}else{
if(null != $conditions) $where = "WHERE ".$conditions;
$this-where = $where;
return $this;
//排序
public function sort($sort){
if(null != $sort) $sort = "ORDER BY {$sort}";
$this-sort = $sort;
//字段
public function fields($fields){ $this-fields = $fields; return $this; }
public function limit($limit){$this-limit = $limit; return $this;}
private function buildSql(){
$this-fields = empty($this-fields) ? "*" : $this-fields;
$sql = "SELECT {$this-fields} FROM {$this-tbl_name} {$this-where} {$this-sort}";
accessLog('db_access',$sql);
if(null != $this-limit)$sql .= " limit {$this-limit}";
return $sql;
/**
* 返回查询数据
* @param $sql
* @param bool $hasOne
* @return array|bool|mixed
*/
private function getArray($sql,$hasOne = false){
if($this-db-real_query($sql) ){
if ($result = $this-db-use_result()) {
$row = array();
if($hasOne){
$row = $result-fetch_assoc();
while($d = $result-fetch_assoc()) $row[] = $d;
$result-close();
$this-fields = "*";
return $row;
return false;
if($this-db-error){
$this-crash($this-db-errno,$this-db-error,$sql);
public function findSql($sql,$hasOne = false){
public function create($row){
if(!is_array($row))return FALSE;
$row = $this-prepera_format($row);
if(empty($row))return FALSE;
foreach($row as $key = $value){
$cols[] = '+'.$key.'+';
$vals[] = "'".$this-db-real_escape_string($value)."'";
$col = implode(',', $cols);
$val = implode(',', $vals);
$sql = "INSERT INTO +{$this-tbl_name}+ ({$col}) VALUES ({$val})";
if( FALSE != $this-db-query($sql) ){ // 获取当前新增的ID
if($this-db-insert_id){
return $this-db-insert_id;
if($this-db-affected_rows){
return true;
return FALSE;
//直接执行sql
public function runSql($sql){
public function update($row){
$where = "";
$value = $this-db-real_escape_string($value);
$vals[] = "+{$key}+ = '{$value}'";
$values = join(", ",$vals);
$sql = "UPDATE {$this-tbl_name} SET {$values} {$this-where}";
if( $this-db-affected_rows){
function delete(){
$sql = "DELETE FROM {$this-tbl_name} {$this-where}";
private function prepera_format($rows){
$columns = $this-getArray("DESCRIBE {$this-tbl_name}");
$newcol = array();
foreach( $columns as $col ){
$newcol[$col['Field']] = $col['Field'];
return array_intersect_key($rows,$newcol);
//崩溃信息
private function crash($number,$message,$sql=''){
$msg = 'Db Error '.$number.':'.$message ;
if(empty($sql)){
echo t('db_crash');
$msg .= " SQL:".$sql;
echo t('db_query_err');
accessLog('db_error',$msg);
exit;
复制代码
代码如下:
/*
MYSQL
数据库访问封装类
访问方式,本封装类以mysql_封装
数据访问的一般流程：
①.,连接数据库
mysql_connect
or
mysql_pconnect
mysql_select_db
mysql_query
mysql_fetch_array
mysql_num_rows
mysql_fetch_assoc
mysql_fetch_row
etc
class
db_mysql
{
var
$querynum
=
;
//当前页面进程查询数据库的次数
$dblink
//数据库连接资源
//链接数据库
function
,
$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)
select_db($dbname)
return
mysql_select_db($dbname,$this-dblink);
//执行SQL查询
query($sql)
$this-querynum++
mysql_query($sql,$this-dblink)
//返回最近一次与连接句柄关联的INSERT,UPDATE
或DELETE
查询所影响的记录行数
affected_rows()
mysql_affected_rows($this-dblink)
//取得结果集中行的数目,只对select查询的结果集有效
num_rows($result)
mysql_num_rows($result)
//获得单格的查询结果
result($result,$row=0)
mysql_result($result,$row)
//取得上一步
INSERT
操作产生的
ID,只对表有AUTO_INCREMENT
ID的操作有效
insert_id()
($id
mysql_insert_id($this-dblink))
$id
$this-result($this-query("SELECT
last_insert_id()"),
0);
//从结果集提取当前行,以数字为key表示的关联数组形式返回
fetch_row($result)
mysql_fetch_row($result)
//从结果集提取当前行,以字段名为key表示的关联数组形式返回
fetch_assoc($result)
mysql_fetch_assoc($result);
//从结果集提取当前行,以字段名和数字为key表示的关联数组形式返回
fetch_array($result)
mysql_fetch_array($result);
//关闭链接
close()
mysql_close($this-dblink)
//输出简单的错误html提示信息并终止程序
halt($msg)
$message
"html\nhead\n"
.=
"meta
"/head\n"
"body\n"
"数据库出错：".htmlspecialchars($msg)."\n"
"/body\n"
"/html"
echo
exit
class MySQL{
private $host; //服务器地址
private $name; //登录账号
private $pwd; //登录密码
private $dBase; //数据库名称
private $conn; //数据库链接资源
private $result; //结果集
private $msg; //返回结果
private $fields;//返回字段
private $fieldsNum; //返回字段数
private $rowsNum; //返回结果数
private $rowsRst; //返回单条记录的字段数组
private $filesArray = array();//返回字段数组
private $rowsArray = array();//返回结果数组
private $query_count=0; //查询结果次数
static private $_instance; //存储对象
//初始化类
private function __construct($host='',$name='',$pwd='',$dBase=''){
if($host != '') $this-host = $host;
if($name != '') $this-name = $name;
if($pwd != '') $this-pwd = $pwd;
if($dBase != '') $this-dBase = $dBase;
$this-init_conn();
//防止被克隆
private function __clone(){}
public static function getInstance($host='',$name='',$pwd='',$dBase=''){
if(FALSE == (self::$_instance instanceof self)){
self::$_instance = new self($host,$name,$pwd,$dBase);
public function __set($name,$value){
$this-$name=$value;
public function __get($name){
return $this-$name;
function init_conn(){
@mysql_select_db($this-dBase,$this-conn) or die('select db fail !');
mysql_query("set names ".$this-charset);
//查询结果
function mysql_query_rst($sql){
if($this-conn == '') $this-init_conn();
$this-result = @mysql_query($sql,$this-conn);
$this-query_count++;
//取得字段数
function getFieldsNum($sql){
$this-mysql_query_rst($sql);
$this-fieldsNum = @mysql_num_fields($this-result);
//取得查询结果数
function getRowsNum($sql){
if(mysql_errno() == 0){
return @mysql_num_rows($this-result);
return '';
//取得记录数组（单条记录）
function getRowsRst($sql,$type=MYSQL_BOTH){
if(empty($this-result)) return '';
if(mysql_error() == 0){
$this-rowsRst = mysql_fetch_array($this-result,$type);
return $this-rowsRst;
//取得记录数组（多条记录）
function getRowsArray($sql,$type=MYSQL_BOTH){
!empty($this-rowsArray) ? $this-rowsArray=array() : '';
while($row = mysql_fetch_array($this-result,$type)) {
$this-rowsArray[] = $row;
return $this-rowsArray;
//更新、删除、添加记录数
function uidRst($sql){
if($this-conn == ''){
@mysql_query($sql);
$this-rowsNum = @mysql_affected_rows();
return $this-rowsNum;
//返回最近插入的一条数据库的id值
function returnRstId($sql){
return mysql_insert_id();
//获取对应的字段值
function getFields($sql,$fields){
if(mysql_num_rows($this-result) 0){
$tmpfld = @mysql_fetch_row($this-result);
$this-fields = $tmpfld[$fields];
return $this-fields;
//错误信息
function msg_error(){
if(mysql_errno() != 0) {
$this-msg = mysql_error();
return $this-msg;
//释放结果集
function close_rst(){
mysql_free_result($this-result);
$this-msg = '';
$this-fieldsNum = 0;
$this-rowsNum = 0;
$this-filesArray = '';
$this-rowsArray = '';
//关闭数据库
function close_conn(){
$this-close_rst();
mysql_close($this-conn);
$this-conn = '';
//取得数据库版本
function db_version() {
return mysql_get_server_info();
* 执行更新记录操作
* @param $data 要更新的数据内容,参数可以为数组也可以为字符串,建议数组.
* 为数组时数组key为字段值,数组值为数据取值
* 为字符串时[例：+name+='phpcms',+hits+=+hits++1].
*数组可使用array('name'='+=1', 'base'='-=1');程序会自动解析为+name+ = +name+ + 1, +base+ = +base+ - 1
* @param $table 数据表
* @param $where 更新数据时的条件
* @return boolean
public function update($data, $table, $where = '') {
if($table == '' or $where == '') {
$where = ' WHERE '.$where;
$field = '';
if(is_string($data) $data != '') {
$field = $data;
} elseif (is_array($data) count($data) 0) {
$fields = array();
foreach($data as $k=$v) {
case '+=':
if (is_numeric($v)) {
$fields[] = $this-add_special_char($k).'='.$this-add_special_char($k).'+'.$this-escape_string($v, '', false);
} else {
continue;
break;
case '-=':
$fields[] = $this-add_special_char($k).'='.$this-add_special_char($k).'-'.$this-escape_string($v, '', false);
default:
$fields[] = $this-add_special_char($k).'='.$this-escape_string($v);
$field = implode(',', $fields);
$sql = 'UPDATE +'.$this-config['database'].'+.+'.$table.'+ SET '.$field.$where;
return $this-execute($sql);
* 数据库查询执行方法
* @param $sql 要执行的sql语句
* @return 查询资源句柄
private function execute($sql) {
if(!is_resource($this-link)) {
$this-connect();
$this-lastqueryid = mysql_query($sql, $this-link) or $this-halt(mysql_error(), $sql);
$this-querycount++;
return $this-lastqueryid;
以上就是土嘎嘎小编为大家整理的php封装操作数据库的类相关主题介绍,如果您觉得小编更新的文章只要能对粉丝们有用,就是我们最大的鼓励和动力,不要忘记讲本站分享给您身边的朋友哦！！