php操作mysqli(示例代码)_PHP教程_ThinkSAAS
php操作mysqli(示例代码)
php操作mysqli(示例代码)
&?php define("MYSQL_OPEN_LOGS",true); class mysqliHelp {
public function __construct()
//如果要查询日志log的话，怎么办
public function __get($name )
//echo "__GET:",$
if(in_array($name,array("db"),true))//或者isset($this-&$name)
return $this-&$
public function connect($host,$user,$pass,$db,$charSet='utf8',$force=false)
if($this-&db && ($this-&db instanceof mysqli) && !$force)
$this-&db=new mysqli($host,$user,$pass,$db);
if (mysqli_connect_error()) {
die('Connect Error (' . mysqli_connect_errno() . ') '
. mysqli_connect_error());
$this-&db-&set_charset($charSet);
//$dbname string
//返回值 如果成功则返回 TRUE，失败则返回 FALSE。
function select_db ($dbname )
return $this-&db-&select_db($dbname);
//$query mysqli_result
//$resulttype int
MYSQLI_ASSOC, MYSQLI_NUM, or MYSQLI_BOTH. Defaults to MYSQLI_BOTH.
//返回值 Returns an array of strings that corresponds to the fetched row or NULL if there are no more rows in resultset.
function fetch_array(/*mysqli_result*/ $query, $resulttype = MYSQLI_ASSOC)
//var_dump(!null);
if(!$query || !($query instanceof mysqli_result))
return NULL;
return $query-&fetch_array($resulttype);//
function data_seek($result,$offset)
return $result-&data_seek($offset);
function fetch_assoc($query)
return $query-&fetch_assoc();// 关联数组
function fetch_row($query)
return $query-&fetch_row();// 索引数组，数字0,1。eg。。。
function fetch_fields($query)
return $query-&fetch_fields();
//$query string
//$resultmode int
//返回值 如果成功则返回 TRUE，失败则返回 FALSE。 For SELECT, SHOW, DESCRIBE or EXPLAIN mysqli_query() will return a result object.
public function query($sql ,$resultmode=MYSQLI_STORE_RESULT
if(MYSQL_OPEN_LOGS) {
$sqlstarttime = $sqlendttime = 0;
$mtime = explode(' ', microtime());
$sqlstarttime = $mtime[1]+ $mtime[0] ;
//真正查询
$query=$this-&db-&query($sql,$resultmode);
if(MYSQL_OPEN_LOGS) {
// sleep(1);
$mtime = explode(' ', microtime());
$sqlendttime =
$mtime[1] + $mtime[0]
$sqlQueryTime = number_format($sqlendttime - $sqlstarttime,6);
//dblogs($sql, $sqlQueryTime,1);
$explain = array();
$info = $this-&db-&
if($query && preg_match("/^(select )/i", $sql)) {
$explain = $this-&fetch_array($this-&db-&query('EXPLAIN '.$sql), MYSQLI_ASSOC );
$GLOBALS['mysql_debug_query'][] = array('sql'=&$sql, 'time'=&$sqlQueryTime, 'info'=&$info, 'explain'=&$explain);
if(!$query)
$this-&halt('MySQL Query Error', $sql);
//返回值 mysqli_stmt对象
function prepare($sql)
return $this-&db-&prepare($sql);
function affected_rows() {
$this-&db-&affected_
$this-&db-&
function errno()
$this-&db-&
//result 没有
function num_rows($query)
return $query-&num_
//返回值　int
The number of fields from a result set.
//也可以用另外一种方式
mysqliHelp-&db-&field_count返回。
function num_fields($query)
$query-&field_
function free_result($query)
$query-&free();
//$query-&free_result();
//$query-&close();
function insert_id()
if(($id = $this-&db-&insert_id)&= 0)
$idArr=$this-&fetch_array($this-&query("SELECT last_insert_id() as id"));
intval($idArr[0]);
//return ($idArr=$this-&fetch_array($this-&query("SELECT last_insert_id() as id")))[0]
//return ($id = $this-&db-insert_id)&= 0 ? $id : 0 ;
function close() {
return $this-&db-&close();
function halt($message,$sql)
$dberror = $this-&error();
$dberrno = $this-&errno();
$help_link = "/?type=mysql&dberrno=".rawurlencode($dberrno)."&dberror=".rawurlencode($dberror);
echo "&div style="position:font-size:11font-family:verdana,background:#EBEBEB;padding:0.5"&
&b&MySQL Error&/b&&br&
&b&Message&/b&: $message&br&
&b&SQL&/b&: $sql&br&
&b&Error&/b&: $dberror&br&
&b&Errno.&/b&: $dberrno&br&
&a href="$help_link" target="_blank"&Click here to seek help.&/a&
function __destruct()
$this-&db=
面向对象接口
面向过程接口
$mysqli-&affected_rows
mysqli_affected_rows()
N/A 获取前一个Mysql操作的受影响行数
$mysqli-&client_info mysqli_get_client_info()
N/A 返回字符串类型的Mysql客户端版本信息
$mysqli-&client_version
mysqli_get_client_version() N/A 返回整型的Mysql客户端版本信息
$mysqli-&connect_errno
mysqli_connect_errno()
N/A 返回最后一次连接调用的错误代码
$mysqli-&connect_error
mysqli_connect_error()
N/A 返回一个字符串描述的最后一次连接调用的错误代码
$mysqli-&errno
mysqli_errno()
N/A 返回最近的函数调用产生的错误代码
$mysqli-&error
mysqli_error()
N/A 返回字符串描述的最近一次函数调用产生的错误代码
$mysqli-&field_count mysqli_field_count()
N/A 返回最近一次查询获取到的列的数目
$mysqli-&host_info
mysqli_get_host_info()
N/A 返回一个能够代表使用的连接类型的字符串
$mysqli-&protocol_version
mysqli_get_proto_info() N/A 返回使用的Mysql协议的版本信息
$mysqli-&server_info mysqli_get_server_info()
N/A 返回Mysql服务端版本的信息
$mysqli-&server_version
mysqli_get_server_version() N/A 返回整型的Mysql服务端版本信息
$mysqli-&info
mysqli_info()
N/A 最近一次执行的查询的检索信息
$mysqli-&insert_id
mysqli_insert_id()
N/A 返回最后一次查询自动生成并使用的id
$mysqli-&sqlstate
mysqli_sqlstate()
N/A 返回前一个Mysql操作的SQLSTATE错误
$mysqli-&warning_count
mysqli_warning_count()
N/A 返回给定链接最后一次查询的警告数量
mysqli-&autocommit() mysqli_autocommit() N/A 打开或关闭数据库的自动提交功能
mysqli-&change_user()
mysqli_change_user()
N/A 更改指定数据库连接的用户
mysqli-&character_set_name(), mysqli-&client_encoding mysqli_character_set_name() mysqli_client_encoding()
返回数据库连接的默认字符集
mysqli-&close()
mysqli_close()
N/A 关闭先前打开的数据库连接
mysqli-&commit() mysqli_commit() N/A 提交当前事务
mysqli::__construct()
mysqli_connect()
N/A 打开一个到Mysql服务端的新的连接［注意：静态方法］
mysqli-&debug()
mysqli_debug()
N/A 执行调试操作
mysqli-&dump_debug_info()
mysqli_dump_debug_info()
N/A 将调试信息转储到日志中
mysqli-&get_charset()
mysqli_get_charset()
N/A 返回对象的字符集
mysqli-&get_connection_stats()
mysqli_get_connection_stats()
N/A 返回客户端连接的统计信息。 仅可用于 mysqlnd。
mysqli-&get_client_info()
mysqli_get_client_info()
N/A 返回字符串描述的Mysql客户端版本
mysqli-&get_client_stats()
mysqli_get_client_stats()
N/A 返回每个客户端进程的统计信息。 仅可用于 mysqlnd。
mysqli-&get_cache_stats()
mysqli_get_cache_stats()
N/A 返回客户端的zval缓存统计信息。 仅可用于 mysqlnd。
mysqli-&get_server_info()
mysqli_get_server_info()
N/A 没有文档
mysqli-&get_warnings()
mysqli_get_warnings()
N/A 没有文档
mysqli::init()
mysqli_init()
N/A 初始化mysqli并且返回一个由mysqli_real_connect使用的资源类型。［不是在对象上，是它返回的$mysqli对象］
mysqli-&kill()
mysqli_kill()
N/A 请求服务器杀死一个Mysql线程
mysqli-&more_results()
mysqli_more_results()
N/A 检查一个多语句查询是否还有其他查询结果集
mysqli-&multi_query()
mysqli_multi_query()
N/A 在数据库上执行一个多语句查询
mysqli-&next_result()
mysqli_next_result()
N/A 从multi_query中准备下一个结果集
mysqli-&options()
mysqli_options()
mysqli_set_opt()
mysqli-&ping()
mysqli_ping()
N/A ping一个服务器连接，或者如果那个连接断了尝试重连
mysqli-&prepare()
mysqli_prepare()
N/A 准备一个用于执行的SQL语句
mysqli-&query()
mysqli_query()
N/A 在数据库上执行一个查询
mysqli-&real_connect()
mysqli_real_connect()
N/A 打开一个到Mysql服务端的连接
mysqli-&real_escape_string(), mysqli-&escape_string() mysqli_real_escape_string() mysqli_escape_string()
转义字符串中用于SQL语句中的特殊字符，这个转换会考虑连接的当前字符集。
mysqli-&real_query() mysqli_real_query() N/A 执行一个SQL查询
mysqli-&rollback()
mysqli_rollback()
N/A 回滚当前事务
mysqli-&select_db()
mysqli_select_db()
N/A 为数据库查询选择默认数据库
mysqli-&set_charset()
mysqli_set_charset()
N/A 设置默认的客户端字符集
mysqli-&set_local_infile_default()
mysqli_set_local_infile_default()
N/A 清除用户为load data local infile命令定义的处理程序
mysqli-&set_local_infile_handler()
mysqli_set_local_infile_handler()
N/A 设置LOAD DATA LOCAL INFILE命令执行的回调函数
mysqli-&ssl_set()
mysqli_ssl_set()
N/A 使用SSL建立安装连接
mysqli-&stat()
mysqli_stat()
N/A 获取当前系统状态
mysqli-&stmt_init()
mysqli_stmt_init()
N/A 初始化一个语句并且返回一个mysqli_stmt_prepare使用的对象
mysqli-&store_result()
mysqli_store_result()
N/A 传输最后一个查询的结果集
mysqli-&thread_id()
mysqli_thread_id()
N/A 返回当前连接的线程ID
mysqli-&thread_safe()
mysqli_thread_safe()
N/A 返回是否设定了线程安全
mysqli-&use_result() mysqli_use_result() N/A 初始化一个结果集的取回
MySQL_STMT
面向对象接口
过程化接口
别名（不要使用）
$mysqli_stmt-&affected_rows
mysqli_stmt_affected_rows() N/A 返回最后一条倍执行的语句改变，删除或插入的总行数
$mysqli_stmt-&errno
mysqli_stmt_errno() N/A 返回最近一次语句调用的错误代码
$mysqli_stmt-&error
mysqli_stmt_error() N/A 返回最后一条语句错误的字符串描述
$mysqli_stmt-&field_count
mysqli_stmt_field_count()
N/A 返回给定语句得到的字段数量
$mysqli_stmt-&insert_id
mysqli_stmt_insert_id() N/A 获取前一个INSERT操作生成的ID
$mysqli_stmt-&num_rows
mysqli_stmt_num_rows()
N/A 返回语句结果集中的行数
$mysqli_stmt-&param_count
mysqli_stmt_param_count()
mysqli_param_count()
返回给定语句中参数数量
$mysqli_stmt-&sqlstate
mysqli_stmt_sqlstate()
N/A 返回前一个语句操作的SQLSTATE错误代码
mysqli_stmt-&attr_get()
mysqli_stmt_attr_get()
N/A 用于获取语句属性的当前值
mysqli_stmt-&attr_set()
mysqli_stmt_attr_set()
N/A 用于修改prepared语句的行为
mysqli_stmt-&bind_param()
mysqli_stmt_bind_param()
mysqli_bind_param() 将一个变量作为参数绑定到prepared语句上
mysqli_stmt-&bind_result()
mysqli_stmt_bind_result()
mysqli_bind_result()
将一个变量绑定到一个prepared语句上用于结果存储
mysqli_stmt-&close() mysqli_stmt_close() N/A 关闭一个prepared语句
mysqli_stmt-&data_seek() mysqli_stmt_data_seek() N/A 查看语句结果集中的任意行
mysqli_stmt-&execute()
mysqli_stmt_execute()
mysqli_execute()
执行一个prepared查询
mysqli_stmt-&fetch() mysqli_stmt_fetch() mysqli_fetch()
从一个prepared语句中抓取结果到限定变量中
mysqli_stmt-&free_result()
mysqli_stmt_free_result()
N/A 释放给定语句处理存储的结果集所占内存
$mysqli_stmt-&get_result()
mysqli_stmt_get_result
N/A 没有文档 仅可用于 mysqlnd。
mysqli_stmt-&get_warnings()
mysqli_stmt_get_warnings()
N/A 没有文档
$mysqli_stmt-&more_results() mysqli_stmt_more_results()
N/A 没有文档 仅可用于 mysqlnd。
$mysqli_stmt-&next_result()
mysqli_stmt_next_result()
N/A 没有文档 仅可用于 mysqlnd。
mysqli_stmt-&num_rows()
mysqli_stmt_num_rows()
N/A 查阅属性$mysqli_stmt-&num_rows
mysqli_stmt-&prepare()
mysqli_stmt_prepare()
N/A 准备一个SQL语句用于执行
mysqli_stmt-&reset() mysqli_stmt_reset() N/A 重置一个prepared语句
mysqli_stmt-&result_metadata()
mysqli_stmt_result_metadata()
mysqli_get_metadata()
从一个prepared语句返回结果集元数据
mysqli_stmt-&send_long_data()
mysqli_stmt_send_long_data()
mysqli_send_long_data() 发送数据块
mysqli_stmt-&store_result()
mysqli_stmt_store_result()
N/A 从一个prepared语句中传输一个结果集
MySQLi_RESULT
面向对象接口
过程化接口
别名（不要使用）
$mysqli_result-&current_field
mysqli_field_tell() N/A 获取当前字段在结果集指针中的开始位置
$mysqli_result-&field_count
mysqli_num_fields() N/A 获取结果中字段数量
$mysqli_result-&lengths
mysqli_fetch_lengths()
N/A 返回结果集中当前行的每列的值得长度，返回数组
$mysqli_result-&num_rows mysqli_num_rows()
N/A 获取结果中行的数量
mysqli_result-&data_seek()
mysqli_data_seek()
N/A 将结果中的结果指针调整到任意行
mysqli_result-&fetch_all()
mysqli_fetch_all()
N/A 抓取所有的结果行并且以关联数据，数值索引数组，或者两者皆有的方式返回结果集。仅可用于 mysqlnd。
mysqli_result-&fetch_array() mysqli_fetch_array()
N/A 以一个关联数组，数值索引数组，或者两者皆有的方式抓取一行结果
mysqli_result-&fetch_assoc() mysqli_fetch_assoc()
N/A 以一个关联数组方式抓取一行结果
mysqli_result-&fetch_field_direct()
mysqli_fetch_field_direct() N/A 抓取一个单字段的元数据
mysqli_result-&fetch_field() mysqli_fetch_field()
N/A 返回结果集中的下一个字段
mysqli_result-&fetch_fields()
mysqli_fetch_fields()
N/A 返回一个代表结果集字段的对象数组
mysqli_result-&fetch_object()
mysqli_fetch_object()
N/A 以一个对象的方式返回一个结果集中的当前行
mysqli_result-&fetch_row()
mysqli_fetch_row()
N/A 以一个枚举数组方式返回一行结果
mysqli_result-&field_seek()
mysqli_field_seek() N/A 设置结果指针到特定的字段开始位置
mysqli_result-&free(), mysqli_result-&close, mysqli_result-&free_result
mysqli_free_result()
N/A 释放与一个结果集相关的内存
/*注意 MYSQLI_STORE_RESULT和MYSQLI_USE_RESULT的区别
其实这两个参数的区别还是很大的。
（1）区别在于从服务器上检索结果集的行。
（2）MYSQLI_USE_RESULT 启动查询，但实际上并未获取任何行
（3）MYSQLI_STORE_RESULT 立即检索所有的行
（4）MYSQLI_STORE_RESULT 从服务器上检索结果集时，就提取了行，并为之分配内存，存储到客户机中，随后调用
mysqli_fetch_array()就再也不会返回错误，因为它仅仅是把行脱离了已经保留结果集的数据结 构，mysqli_fetch_array()返回 NULL始终表示已经到达结果集的末端。
（5）MYSQLI_USE_RESULT 本身不检索任何行，而只是启动一个逐行的检索，就是说必须对每行调 用
mysqli_fetch_array()来自己完成。既然如此，虽然正常情况下，mysqli_fetch_array()返回NULL仍然表示此 时已到达结果集的末端，但也可能表示在与服务器通信时发生错误。
如果是MYSQLI_USE_RESULT，query以后得到mysqli_result对象后，执行data_seek会出错，因为
mysqli_result::data_seek() [mysqli-result.data-seek]: Function cannot be used with MYSQL_USE_RESULT
与MYSQLI_USE_RESULT相比，MYSQLI_STORE_RESULT 有着较高的内存和处理需求，因为是在客户机上维护整个结果集，所以内存分配和创建数据结构的耗费是非常巨大的，如果想一次检索多个行，可用 MYSQLI_USE_RESULT。
MYSQLI_USE_RESULT有着较低的内存需求，因为只需给每次处理的单行分配足够的空间。这样速度就较快，因为不必为结果集建立复杂的数据结构。
另一方面，MYSQLI_USE_RESULT把较大的负载加到了服务器上，它必须保留结果集中的行，直到客户机看起来适合检索所有的行。
*/} $dbHelper=new mysqliH $dbHelper-&connect('localhost', 'root', '', 'tt'); //$dbHelper-&db-&select_db("tt"); //$dbHelper-&db-&set_charset("utf8");
//这里如果是MYSQLI_USE_RESULT，下面的$dbHelper-&data_seek($query,10);就会出错 $query=$dbHelper-&query("select id,cateid,title from product limit 22",MYSQLI_STORE_RESULT ); //$query=$dbHelper-&query("update product set
createtime=UNIX_TIMESTAMP()
limit 22"); //$query=$dbHelper-&query("insert
into `product`(`cateid`,`title`,`text`,`createtime`) values (2,'test','content',)"); //$query=$dbHelper-&query("delete from `product` where id=1"); //$query=$dbHelper-&query("replace into product(id,cateid,title,text,createtime) values(1,2,'this is demo','test',UNIX_TIMESTAMP())");
echo $query-&num_rows."总数"; //var_dump($query);
//$row=$dbHelper-&fetch_array($query); //var_dump($row);
//finfo = $dbHelper-&fetch_fields($query); //var_dump($finfo); // foreach ($finfo as $val) {
// printf("Name:
%sn", $val-&name);
// printf("Table:
%sn", $val-&table);
// printf("max. Len: %dn", $val-&max_length);
// printf("Flags:
%dn", $val-&flags);
// printf("Type:
%dnn", $val-&type); // } //如果是查询操作affected_rows行数为1，num_rows为查询结果行数，num_fields为字段数目 //如果是更新或者删除操作affected_rows为受影响的行数，num_rows为null,num_fields为null // $dbHelper-&data_seek($query,10); $row=$dbHelper-&fetch_row($query); var_dump($row);
echo "影响行数:", "&br/&"; var_dump($dbHelper-&affected_rows()); //var_dump($dbHelper-&db-&affected_rows ); echo "查询行数","&br/&"; var_dump($dbHelper-&num_rows($query)); echo "列数：","&br/&"; var_dump($dbHelper-&num_fields($query));
$sql="select id,cateid,title from product where cateid=? and title like
? and createtime&".time(); $stmt=$dbHelper-&prepare($sql); var_dump($stmt); $stmt-&bind_param('is',$cateid,$title); $title="%%"; $cateid=10; $stmt-&execute(); $stmt-&bind_result($col1, $col2,$col3);
/* fetch values */while ($stmt-&fetch()) {
printf("%s %s"."&br/&", $col1, $col3); } echo "&br/&"; $title="%%"; $cateid=4; $stmt-&execute(); $stmt-&bind_result($col1, $col2,$col3);
/* fetch values */while ($stmt-&fetch()) {
printf("%s %s %s"."&br/&", $col1, $col2,$col3); } $stmt-&close();
//第2种 $stmt=$dbHelper-&db-&stmt_init(); $stmt-&prepare($sql); $stmt-&bind_param('is',$cateid,$title); $title="%%"; $cateid=10; $stmt-&execute(); $stmt-&bind_result($col1, $col2,$col3);
/* fetch values */while ($stmt-&fetch()) {
//printf("%s %s"."&br/&", $col1, $col3); } echo "&br/&开始multi_query:&br/&";
//multi_query实例 //multi_query()方法的返回值，以及 //mysqli的属性errno、error、info等只与第一条SQL命令有关，无法判断第二条及以后的命令是否在执行时发生了错误。所以在执行 //multi_query()方法的返回值是TRUE时，并不意味着后续命令在执行时没有出错。 $sql="select id,cateid,title from product where cateid=4;"; $sql.="select id,cateid,title from product where cateid=10"; $query=$dbHelper-&db-&multi_query($sql); if($query) {
/* store first result set */
//下面两种方法有什么区别?
// if ($result = $dbHelper-&db-&store_result()) {
// while ($row = $result-&fetch_row()) {
// $data[]=$
// $result-&free();
if ($result = $dbHelper-&db-&use_result()) {//返回mysqli_result类型
//$result-&data_seek(0);//返回bool
while ($row = $result-&fetch_row()) {
//$result-&close();
/* print divider */
if ($dbHelper-&db-&more_results()) {
printf("-----------------n");
$data[]="_______________________________";
} while ($dbHelper-&db-&next_result()); } var_dump($data); // //执行事务 实例 //确保操作的表时innodb类型的表 //如果是MyISAM，逻辑出错的话， 会执行所有操作，不回滚 $price=1; $success= $dbHelper-&db-&autocommit(0); $result=$dbHelper-&query("update product set cateid=cateid-$price where id=1000" ); if(!$result
|| $dbHelper-&affected_rows()!=1) {
$success= } $result=$dbHelper-&query("update product set cateid=cateid+$price where id=2"); if(!$result
|| $dbHelper-&affected_rows()!=1) {
$success= } if($success) { $dbHelper-&db-&commit(); echo "成功"; }else{ $dbHelper-&db-&rollback(); echo "失败"; } $dbHelper-&db-&autocommit(1);
//var_dump(
$dbHelper-&insert_id()); var_dump($mysql_debug_query);
//打印sql查询信息
PHP开发框架
开发工具/编程工具
服务器环境
ThinkSAAS商业授权：
ThinkSAAS为用户提供有偿个性定制开发服务
ThinkSAAS将为商业授权用户提供二次开发指导和技术支持
让ThinkSAAS更好，把建议拿来。
开发客服微信PHP以mysqli方式连接类完整代码实例
投稿：shichen2014
字体：[ ] 类型：转载 时间：
这篇文章主要介绍了PHP以mysqli方式连接类完整代码实例,对于学习和了解mysqli都有很大的帮助,需要的朋友可以参考下
本文所述的是一个在PHP中以mysqli方式连接数据库的一个数据库类实例，该数据库类是从一个PHP的CMS中整理出来的，可实现PHP连接数据库类，MySQLi版，兼容PHP4，对于有针对性需要的朋友可根据此代码进行优化和修改。
#==================================================================================================
# Filename: /db/db_mysqli.php
# Note : 连接数据库类，MySQLi版
#==================================================================================================
#[类库sql]
class db_mysqli
var $query_count = 0;
var $prefix = "qinggan_";
//返回结果集类型，默认是数字+字符
var $rs_type = MYSQLI_ASSOC;
var $query_times = 0;#[查询时间]
var $conn_times = 0;#[连接数据库时间]
var $unbuffered =
//定义查询列表
var $debug =
#[构造函数]
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"] :
$this-&prefix = $config['prefix'] ? $config['prefix'] : 'qinggan_';
if($this-&data)
$ifconnect = $this-&connect($this-&data);
if(!$ifconnect)
$this-&conn =
#[兼容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)
if(!$this-&conn)
$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 :
function select_db($data="")
$database = $data ? $data : $this-&
if(!$database)
$this-&data = $
$start_time = $this-&time_used();
$ifok = mysqli_select_db($this-&conn,$database);
if(!$ifok)
$end_time = $this-&time_used();
$this-&conn_times += round($end_time - $start_time,5);#[连接数据库的时间]
#[关闭数据库连接，当您使用持续连接时该功能失效]
function close()
if(is_resource($this-&conn))
return mysqli_close($this-&conn);
function __destruct()
return $this-&close();
function set($name,$value)
if($name == "rs_type")
$value = strtolower($value) == "num" ? MYSQLI_NUM : MYSQLI_ASSOC;
$this-&$name = $
function query($sql)
if(!is_resource($this-&conn))
$this-&connect();
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);
$this-&querylist[$sqlkey] = array("sql"=&$sql,"count"=&1);
$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 $this-&
function get_all($sql="",$primary="")
$result = $sql ? $this-&query($sql) : $this-&
if(!$result)
$start_time = $this-&time_used();
$rs = array();
while($rows = mysqli_fetch_array($result,$this-&rs_type))
if($primary && $rows[$primary])
$rs[$rows[$primary]] = $
$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-&
if(!$result)
$rows = mysqli_fetch_array($result,$this-&rs_type);
$end_time = $this-&time_used();
$this-&query_times += round($end_time - $start_time,5);#[查询时间]
function insert_id($sql="")
$rs = $this-&get_one($sql);
return mysqli_insert_id($this-&conn);
function insert($sql)
$this-&result = $this-&query($sql);
$id = $this-&insert_id();
function all_array($table,$condition="",$orderby="")
if(!$table)
$table = $this-&prefix.$
$sql = "SELECT * FROM ".$
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 ".$
$rslist = $this-&get_all($sql);
function one_array($table,$condition="")
if(!$table)
$table = $this-&prefix.$
$sql = "SELECT * FROM ".$
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);
//将数组写入数据中
function insert_array($data,$table,$insert_type="insert")
if(!$table || !is_array($data) || !$data)
$table = $this-&prefix.$//自动增加表前缀
if($insert_type == "insert")
$sql = "INSERT INTO ".$
$sql = "REPLACE INTO ".$
$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))
$table = $this-&prefix.$//自动增加表前缀
$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="")
$this-&rs_type = MYSQLI_NUM;
$this-&query($sql);
$rs = $this-&get_one();
$this-&rs_type = MYSQLI_ASSOC;
return $rs[0];
return mysqli_num_rows($this-&result);
function num_fields($sql="")
$this-&query($sql);
return mysqli_num_fields($this-&result);
function list_fields($table)
$rs = $this-&get_all("SHOW COLUMNS FROM ".$table);
foreach($rs AS $key=&$value)
$rslist[] = $value["Field"];
#[显示表名]
function list_tables()
$rs = $this-&get_all("SHOW TABLES");
function table_name($table_list,$i)
return $table_list[$i];
function escape_string($char)
if(!$char)
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_
//Mysql的查询时间
function conn_times()
return $this-&conn_times + $this-&query_
//MySQL查询资料
function conn_count()
return $this-&query_
# 高效SQL生成查询，仅适合单表查询
function phpok_one($tbl,$condition="",$fields="*")
$sql = "SELECT ".$fields." FROM ".$this-&db-&prefix.$
if($condition)
$sql .= " WHERE ".$
return $this-&get_one($sql);
function debug()
if(!$this-&querylist || !is_array($this-&querylist) || count($this-&querylist) & 1)
$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:3color:#6E6E6E;"&'.$value['sql'].'&/div&&/td&';
$html .= '&td align="center" bgcolor="#FFFFFF"&&div style="padding:3color:#000000;"&'.$value["count"].'&/div&&/td&&/tr&';
$html.= "&/table&";
$html.= "&/td&&/tr&&/table&";
function conn_status()
if(!$this-&conn)
您可能感兴趣的文章:
大家感兴趣的内容
12345678910
最近更新的内容
常用在线小工具}