[php]mysql数据库操作——DB类


<?php
/*
 * mysql数据库 DB类
 * @package db
 * @author  yytcpt(无影)
 * @version 2008-03-27
 * @copyrigth http://www.d5s.cn/
 */
class db {
 var $connection_id = "";
 var $pconnect = 0;
 var $shutdown_queries = array();
 var $queries = array();
 var $query_id = "";
 var $query_count = 0;
 var $record_row = array();
 var $failed = 0;
 var $halt = "";
 var $query_log = array();
 function connect($db_config){
  if ($this->pconnect){
   $this->connection_id = mysql_pconnect($db_config["hostname"], $db_config["username"], $db_config["password"]);
  }else{
   $this->connection_id = mysql_connect($db_config["hostname"], $db_config["username"], $db_config["password"]);
  }
  if ( ! $this->connection_id ){
   $this->halt("Can not connect MySQL Server");
  }
  if ( ! @mysql_select_db($db_config["database"], $this->connection_id) ){
   $this->halt("Can not connect MySQL Database");
  }
  if ($db_config["charset"]) {
   @mysql_unbuffered_query("SET NAMES '".$db_config["charset"]."'");
  }
  return true;
 }
 //发送SQL 查询,并返回结果集
    function query($query_id, $query_type='mysql_query'){
        $this->query_id = $query_type($query_id, $this->connection_id);
  $this->queries[] = $query_id;
        if (! $this->query_id ) {
            $this->halt("查询失败:\n$query_id");
  }
  $this->query_count++;
  $this->query_log[] = $str;
        return $this->query_id;
    }
 //发送SQL 查询,并不获取和缓存结果的行
 function query_unbuffered($sql=""){
  return $this->query($sql, 'mysql_unbuffered_query');
 }
 //从结果集中取得一行作为关联数组
    function fetch_array($sql = ""){
     if ($sql == "") $sql = $this->query_id;
        $this->record_row = @mysql_fetch_array($sql, MYSQL_ASSOC);
        return $this->record_row;
    }
 function shutdown_query($query_id = ""){
  $this->shutdown_queries[] = $query_id;
    }
 //取得结果集中行的数目,仅对 INSERT,<a href="/tag/2859/index.html" target="_blank">UPDATE</a> 或者 DELETE
 function affected_rows() {
        return @mysql_affected_rows($this->connection_id);
    }
 //取得结果集中行的数目,仅对 SELECT 语句有效
    function num_rows($query_id="") {
  if ($query_id == "") $query_id = $this->query_id;
        return @mysql_num_rows($query_id);
    }
 //返回上一个 MySQL 操作中的错误信息的数字编码
 function get_errno(){
  $this->errno = @mysql_errno($this->connection_id);
  return $this->errno;
 }
 //取得上一步 INSERT 操作产生的 ID
    function insert_id(){
        return @mysql_insert_id($this->connection_id);
    }
 //得到查询次数
    function query_count() {
        return $this->query_count;
    }
 //释放结果内存
    function free_result($query_id=""){
     if ($query_id == "") $query_id = $this->query_id;
     @mysql_free_result($query_id);
    }
 //关闭 MySQL 连接
    function close_db(){
     if ( $this->connection_id ) return @mysql_close( $this->connection_id );
    }
 //列出 MySQL 数据库中的表
    function get_table_names(){
     global $db_config;
  $result = mysql_list_tables($db_config["database"]);
  $num_tables = @mysql_numrows($result);
  for ($i = 0; $i < $num_tables; $i++) {
   $tables[] = mysql_tablename($result, $i);
  }
  mysql_free_result($result);
  return $tables;
    }
 //从结果集中取得列信息并作为对象返回,取得所有字段
    function get_result_fields($query_id=""){
     if ($query_id == "") $query_id = $this->query_id;
  while ($field = mysql_fetch_field($query_id)) {
            $fields[] = $field;
  }
  return $fields;
    }
 //错误提示
    function halt($the_error=""){
  $message = $the_error."<br/>\r\n";
  $message.= $this->get_errno() . "<br/>\r\n";
  $sql = "INSERT INTO `db_error`(pagename, errstr, timer) VALUES('". [php]mysql数据库操作——DB类 - 站长学院


Copyright © 2016 phpStudy | 皖ICP备18014864号-4