当前位置:数据库 > SQLServer >>

mysql操作类

<?php 
/**
 * 数据库操作类
 * 2011/8/25
 * kcj
 * */ 
class MyDB { 
    private $db_host;        //数据库主机名  
    private $db_user;        //数据库用户名  
    private $db_pwd;         //数据库密码  
    private $db_database;    //数据库名  
    private $conn;           //连接标识  
    private $result;         //执行query命令的结果资源标识  
    private $row;            //返回的条目数  
    private $sql;            //sql执行语句  
    private $coding;         //数据库编码  
    private $bulletin=true;       // 是否开启错误记录  
    private $show_error=false;    //测试阶段,显示所有错误,具有安全隐患,默认关闭  
    private $is_error=false;      //发现错误是否立即终止,默认true,建议不启用,因为当有问题时用户什么也看不到是很苦恼的  
    //构造函数  
     function __construct($db_host,$db_user,$db_pwd,$db_database,$conn,$doding){ 
           $this->db_host=$db_host; 
           $this->db_user=$db_user; 
           $this->db_pwd=$db_pwd; 
           $this->db_database=$db_database; 
           $this->conn=$conn; 
           $this->coding=$coding; 
           $this->connect(); 
         
     } 
     //数据库连接  
     public  function connect(){ 
        if($this->conn=="pconn"){ 
            //永久连接  
            $this->conn=mysql_pconnect($this->db_host,$this->db_user,$this->db_pwd); 
        }else{ 
            //即使连接  
            $this->conn=mysql_connect($this->db_host,$this->db_user,$this->db_pwd); 
        } 
        if(!mysql_select_db($this->db_database,$this->conn)){ 
            if($this->show_error){ 
                $this->show_error("数据库不可用:",$this->db_database); 
            } 
        } 
     } 
      
     //数据库执行语句,可执行查询添加修改删除等任何sql语句  
     public  function query($sql){ 
        if($sql==""){ 
            $this->show_error("sql语句错误:","sql语句为空"); 
        } 
        $this->sql=$sql; 
        $result=mysql_query($this->sql,$this->conn); 
        if(!$result){ 
            if($this->show_error){ 
                $this->show_error("错误sql语句:",$this->sql); 
            } 
        }else { 
            $this->result; 
        } 
        return  $result; 
     } 
     //创建添加新的数据库  
     public  function create_database($database_name){ 
         $database=$database_name; 
         $sqlDatabase='create database'.$database; 
         $this->query($sqlDatabase); 
     } 
     //查询服务器所有数据库  
     //将系统数据库与用户分开,更直观的显示  
     public function show_database(){ 
        $this->query("show databases"); 
        echo "现在有的数据库:".$amount=$this->db_num_rows($rs); 
        echo "<br>"; 
        $i=1; 
        while ($row=$this->fetch_array($rs)){ 
            echo "$i $row[Database]"; 
            echo "<br>"; 
            $i++; 
        } 
     } 
     //以数组的形式返回主机中所有的数据库名  
     public function databases(){ 
        $rsPtr=mysql_list_dbs($this->conn); 
        $i=0; 
        $cnt=mysql_num_rows($rsPtr); 
        while ($i<$cnt){ 
            $rs[]=mysql_db_name($rsPtr,$i); 
            $i++; 
        } 
        return $rs; 
     } 
     //查询数据库下所有的表  
     public  function show_tables($database_name){&nbs

补充:Web开发 , php ,
CopyRight © 2022 站长资源库 编程知识问答 zzzyk.com All Rights Reserved
部分文章来自网络,