<?php#==================================================================================================# Filename: /db/db_mysqli.php# Note : 连接数据库类，MySQLi版#==================================================================================================#[类库sql]class db_mysqli{ var $query_count = 0; var $host; var $user; var $pass; var $data; var $conn; var $result; var $prefix = 'qinggan_'; //返回结果集类型，默认是数字 字符 var $rs_type = MYSQLI_ASSOC; var $query_times = 0;#[查询时间] var $conn_times = 0;#[连接数据库时间] var $unbuffered = false; //定义查询列表 var $querylist; var $debug = false; #[构造函数] function __construct($config=array()) { $this->host = $config['host'] ? $config['host'] : 'localhost'; $this->port = $config['port'] ? $config['port'] : '3306'; $this->user = $config['user'] ? $config['user'] : 'root'; $this->pass = $config['pass'] ? $config['pass'] : ''; $this->data = $config['data'] ? $config['data'] : ''; $this->debug = $config['debug'] ? $config['debug'] : false; $this->prefix = $config['prefix'] ? $config['prefix'] : 'qinggan_'; if($this->data) { $ifconnect = $this->connect($this->data); if(!$ifconnect) { $this->conn = false; return false; } } return true; } #[兼容PHP4] function db_mysqli($config=array()) { return $this->__construct($config); } #[连接数据库] function connect($database='') { $start_time = $this->time_used(); if(!$this->port) $this->port = '3306'; $this->conn = @mysqli_connect($this->host,$this->user,$this->pass,'',$this->port) or false; if(!$this->conn) { return false; } $version = $this->get_version(); if($version>'4.1') { mysqli_query($this->conn,'SET NAMES 'utf8''); if($version>'5.0.1') { mysqli_query($this->conn,'SET sql_mode='''); } } $end_time = $this->time_used(); $this->conn_times = round($end_time - $start_time,5);#[连接数据库的时间] $ifok = $this->select_db($database); return $ifok ? true : false; } function select_db($data='') { $database = $data ? $data : $this->data; if(!$database) { return false; } $this->data = $database; $start_time = $this->time_used(); $ifok = mysqli_select_db($this->conn,$database); if(!$ifok) { return false; } $end_time = $this->time_used(); $this->conn_times = round($end_time - $start_time,5);#[连接数据库的时间] return true; } #[关闭数据库连接，当您使用持续连接时该功能失效] function close() { if(is_resource($this->conn)) { return mysqli_close($this->conn); } else { return true; } } function __destruct() { return $this->close(); } function set($name,$value) { if($name == 'rs_type') { $value = strtolower($value) == 'num' ? MYSQLI_NUM : MYSQLI_ASSOC; } $this->$name = $value; } function query($sql) { if(!is_resource($this->conn)) { $this->connect(); } else { if(!mysql_ping($this->conn)) { $this->close(); $this->connect(); } } if($this->debug) { $sqlkey = md5($sql); if($this->querylist) { $qlist = array_keys($this->querylist); if(in_array($sqlkey,$qlist)) { $count = $this->querylist[$sqlkey]['count'] 1; $this->querylist[$sqlkey] = array('sql'=>$sql,'count'=>$count); }else{ $this->querylist[$sqlkey] = array('sql'=>$sql,'count'=>1); } } else{ $this->querylist[$sqlkey] = array('sql'=>$sql,'count'=>1); } } $start_time = $this->time_used(); $func = $this->unbuffered && function_exists('mysqli_multi_query') ? 'mysqli_multi_query' : 'mysqli_query'; $this->result = @$func($this->conn,$sql); $this->query_count ; $end_time = $this->time_used(); $this->query_times = round($end_time - $start_time,5);#[查询时间] if(!$this->result) { return false; } return $this->result; } function get_all($sql='',$primary='') { $result = $sql ? $this->query($sql) : $this->result; if(!$result) { return false; } $start_time = $this->time_used(); $rs = array(); $is_rs = false; while($rows = mysqli_fetch_array($result,$this->rs_type)) { if($primary && $rows[$primary]) { $rs[$rows[$primary]] = $rows; } else { $rs[] = $rows; } $is_rs = true; } $end_time = $this->time_used(); $this->query_times = round($end_time - $start_time,5);#[查询时间] return ($is_rs ? $rs : false); } function get_one($sql='') { $start_time = $this->time_used(); $result = $sql ? $this->query($sql) : $this->result; if(!$result) { return false; } $rows = mysqli_fetch_array($result,$this->rs_type); $end_time = $this->time_used(); $this->query_times = round($end_time - $start_time,5);#[查询时间] return $rows; } function insert_id($sql='') { if($sql) { $rs = $this->get_one($sql); return $rs; } else { return mysqli_insert_id($this->conn); } } function insert($sql) { $this->result = $this->query($sql); $id = $this->insert_id(); return $id; } function all_array($table,$condition='',$orderby='') { if(!$table) { return false; } $table = $this->prefix.$table; $sql = 'SELECT * FROM '.$table; if($condition && is_array($condition) && count($condition)>0) { $sql_fields = array(); foreach($condition AS $key=>$value) { $sql_fields[] = '`'.$key.'`=''.$value.'' '; } $sql .= ' WHERE '.implode(' AND ',$sql_fields); } if($orderby) { $sql .= ' ORDER BY '.$orderby; } $rslist = $this->get_all($sql); return $rslist; } function one_array($table,$condition='') { if(!$table) { return false; } $table = $this->prefix.$table; $sql = 'SELECT * FROM '.$table; if($condition && is_array($condition) && count($condition)>0) { $sql_fields = array(); foreach($condition AS $key=>$value) { $sql_fields[] = '`'.$key.'`=''.$value.'' '; } $sql .= ' WHERE '.implode(' AND ',$sql_fields); } $rslist = $this->get_one($sql); return $rslist; } //将数组写入数据中 function insert_array($data,$table,$insert_type='insert') { if(!$table || !is_array($data) || !$data) { return false; } $table = $this->prefix.$table;//自动增加表前缀 if($insert_type == 'insert') { $sql = 'INSERT INTO '.$table; } else { $sql = 'REPLACE INTO '.$table; } $sql_fields = array(); $sql_val = array(); foreach($data AS $key=>$value) { $sql_fields[] = '`'.$key.'`'; $sql_val[] = '''.$value.'''; } $sql.= '('.(implode(',',$sql_fields)).') VALUES('.(implode(',',$sql_val)).')'; return $this->insert($sql); } //更新数据 function update_array($data,$table,$condition) { if(!$data || !$table || !$condition || !is_array($data) || !is_array($condition)) { return false; } $table = $this->prefix.$table;//自动增加表前缀 $sql = 'UPDATE '.$table.' SET '; $sql_fields = array(); foreach($data AS $key=>$value) { $sql_fields[] = '`'.$key.'`=''.$value.'''; } $sql.= implode(',',$sql_fields); $sql_fields = array(); foreach($condition AS $key=>$value) { $sql_fields[] = '`'.$key.'`=''.$value.'' '; } $sql .= ' WHERE '.implode(' AND ',$sql_fields); return $this->query($sql); } function count($sql='') { if($sql) { $this->rs_type = MYSQLI_NUM; $this->query($sql); $rs = $this->get_one(); $this->rs_type = MYSQLI_ASSOC; return $rs[0]; } else { return mysqli_num_rows($this->result); } } function num_fields($sql='') { if($sql) { $this->query($sql); } return mysqli_num_fields($this->result); } function list_fields($table) { $rs = $this->get_all('SHOW COLUMNS FROM '.$table); if(!$rs) { return false; } foreach($rs AS $key=>$value) { $rslist[] = $value['Field']; } return $rslist; } #[显示表名] function list_tables() { $rs = $this->get_all('SHOW TABLES'); return $rs; } function table_name($table_list,$i) { return $table_list[$i]; } function escape_string($char) { if(!$char) { return false; } return mysqli_escape_string($this->conn,$char); } function get_version() { return mysqli_get_server_info($this->conn); } function time_used() { $time = explode(' ',microtime()); $used_time = $time[0] $time[1]; return $used_time; } //Mysql的查询时间 function conn_times() { return $this->conn_times $this->query_times; } //MySQL查询资料 function conn_count() { return $this->query_count; } # 高效SQL生成查询，仅适合单表查询 function phpok_one($tbl,$condition='',$fields='*') { $sql = 'SELECT '.$fields.' FROM '.$this->db->prefix.$tbl; if($condition) { $sql .= ' WHERE '.$condition; } return $this->get_one($sql); } function debug() { if(!$this->querylist || !is_array($this->querylist) || count($this->querylist) < 1) { return false; } $html = '<table cellpadding='0' cellspacing='0' width='100%' bgcolor='#CECECE'><tr><td>'; $html.= '<table cellpadding='1' cellspacing='1' width='100%'>'; $html.= '<tr><th bgcolor='#EFEFEF' height='30px'>SQL</th><th bgcolor='#EFEFEF' width='80px'>查询</th></tr>'; foreach($this->querylist AS $key=>$value) { $html .= '<tr><td bgcolor='#FFFFFF'><div style='padding:3px;color:#6E6E6E;'>'.$value['sql'].'</div></td>'; $html .= '<td align='center' bgcolor='#FFFFFF'><div style='padding:3px;color:#000000;'>'.$value['count'].'</div></td></tr>'; } $html.= '</table>'; $html.= '</td></tr></table>'; return $html; } function conn_status() { if(!$this->conn) return false; return true; }}?>
联系客服
