首页 > 数据库 > MySQL > 正文

自己编了一个mysql类。请指正

2024-07-24 12:56:25
字体:
来源:转载
供稿:网友
文件名mysql.class.php
<?
//###################### start introduce #######################################
// mysql连接类
// author: bluemaple , emaile: [email protected]
// 可以执行一般mysql命令,如insert,delete,select,update
// 使用方法:在需要的文件前面加入
// require("./mysql.class.php");
// $db=new db_mysql;            // 加载类
// $db->dbserver="localhost";   // 连接数据库地址
// $db->dbuser="root";          // 用户名
// $db->dbpwd="";               // 密码
// $db->dbdatabase="we";        // 数据库名称
// $db->connect();             // 连接数据库
// 使用中可以更改数据库
// 可以用到的函数说明
// query($sql,$dbbase);         // 可以直接执行
// query_first($sql,$dbbase);   // 查询返回只有一条记录,$sql为sql语句,$dbbase为你选者数据库(可以不要)
// fetch_array($sql,$dbbase);   // 查询返回一组记录,可以用num_rows得到返回的数字
// insert,update,delete 皆为执行命令,其中可用$affected_rows;得到返回的数目
// 在insert时,可以用insert_id得到插入结果的返回id数
// count_records($table,$index,$where,$dbbase)// 为得到一个表记录的数目,$table为表名,$index为key,$where为条件,$dbbase为数据库,后两个可以不选
//####################### end introduce ########################################

class db_mysql          // 数据库mysql查询的类
{   
  var $dbserver;        // 数据库连接服务地址
  var $dbdatabase;      // 所选择的数据库,初始状态
  var $dbbase="";       // 后面可以改变的
  var $dbuser;          // 登陆用户名
  var $dbpwd;           // 登陆用户密码  
  var $dblink;          // 数据库连接指针
  var $query_id;        // 执行query命令的指针
  var $num_rows;        // 返回的条目数
  var $insert_id;       // 传回最后一次使用 insert 指令的 id
  var $affected_rows;   // 传回query命令所影响的列数目
                  // insert、update 或 delete 所影响的列 (row) 数目。
                  // delete 如果不带where,那么则返回0
     
  function connect($dbbase="")    // 连接数据库函数,包括连接数据库
        {
         global $usepconnect;   // 是否采用永久连接,$userpconnect在外部设置。
         if ($usepconnect==1){
                $this->[email protected]_pconnect($this->dbserver,$this->dbuser,$this->dbpwd);
                              } else {
                $this->[email protected]_connect($this->dbserver,$this->dbuser,$this->dbpwd);
                }
          if(!$this->dblink) $this->halt("连接出错,无法连接!!!");
          if ($dbbase=="") {
            $dbbase=$this->dbdatabase;
            }                        
        if(!mysql_select_db($dbbase, $this->dblink))  // 连接数据库
                          { $this->halt("不能够用这个数据库,请检查这个数据库是否正确!!!");}
          }
  
  function change_db($dbbase=""){ // 改变数据库
      $this->connect($dbbase);
      }

  function query_first($sql,$dbbase=""){ // 返回一个值的sql命令
      $query_id=$this->query($sql,$dbbase);
        $returnarray=mysql_fetch_array($query_id);
        $this->num_rows=mysql_num_rows($query_id);
      $this->free_result($query_id);      
      return $returnarray;
      }
  
  function fetch_array($sql,$dbbase="",$type=0){ // 返回一个值的sql命令
                           // type为传递值是name=>value,还是4=>value
      $query_id=$this->query($sql,$dbbase);
      $this->num_rows=mysql_num_rows($query_id);
      for($i=0;$i<$this->num_rows;$i++){
          if($type==0)
              $array[$i]=mysql_fetch_array($query_id);
          else
              $array[$i]=mysql_fetch_row($query_id);
          }
      $this->free_result($query_id);
      return $array;
      }
  
  function delete($sql,$dbbase=""){ // 删除命令
      $query_id=$this->query($sql,$dbbase);
      $this->affected_rows=mysql_affected_rows($this->dblink);
      $this->free_result($query_id);
        }
  
  function insert($sql,$dbbase=""){ // 插入命令
      $query_id=$this->query($sql,$dbbase);
      $this->insert_id=mysql_insert_id($this->dblink);
      $this->affected_rows=mysql_affected_rows($this->dblink);
      $this->free_result($query_id);
        }
  
  function update($sql,$dbbase=""){  //  更新命令
      $query_id=$this->query($sql,$dbbase);
      $this->affected_rows=mysql_affected_rows($this->dblink);      
      $this->free_result($query_id);
      }
  
  function count_records($table,$index="id",$where="",$dbbase=""){ // 记录总共表的数目
                                                   // where为条件
                                                   // dbbase为数据库
                                                   // index为所选key,默认为id
        if($dbbase!="") $this->change_db($dbbase);
        $[email protected]_query("select count(".$index.") as 'num' from $table ".$where,$this->dblink);
        if(!$result) $this->halt("错误的sql语句: ".$sql);
        @$num = mysql_result($result,0,"num");     
        return $num;
      }
  
  function query($sql,$dbbase=""){   // 执行queyr指令
      if($dbbase!="") $this->change_db($dbbase);
    $this->[email protected]_query($sql,$this->dblink);
    echo "d";
    if(!$this->query_id) $this->halt("错误的sql语句: ".$sql);
    return $this->query_id;
      }
    
  function halt($errmsg)  // 数据库出错,无法连接成功
        {
            $msg="<h3><b>数据库出错!</b></h3><br>";
            $msg.=$errmsg;
            echo $msg;
            die();
      }

  function free_result($query_id)  // 释放query选者
        {
        @mysql_free_result($query_id);
        }

  function close()        //关闭数据库连接
        {
      mysql_close($this->dblink);
        }
}
?>

以下是使用方法

text.php
<?
require("./mysql.class.php");
$db=new db_mysql;
$db->dbserver="localhost";
$db->dbuser="root";
$db->dbpwd="";
$db->dbdatabase="we";
$db->connect(); // 连接数据库
?>
  • 网站运营seo文章大全
  • 提供全面的站长运营经验及seo技术!
  • 发表评论 共有条评论
    用户名: 密码:
    验证码: 匿名发表