mysql封装操作类[原]

直接调用SCM开发Service程序代码下载[codeproject]

修订后带事务功能的操作MYSQL类[感谢刀客]

大 | 中 | 小

2008/07/29 发表时间

12:55

1378

huzhangyou2002

开发语言 » PHP

下载文件 (已下载 48 次)

点击这里下载文件: db_mysql.rar

使用方法：

本代码用于内部项目，开源出来希望对大家有所帮助。

<?
  class operatormysql{
    private static $op_mysql = null;
    private $conn;
    private function __construct($server,$user,$pass,$db){
      $this->conn= mysql_connect($server,$user,$pass);
      mysql_select_db($db,$this->conn);
    //  mysql_query('SET NAMES UTF8',$this->conn);
    }
    //singleton
    public static function instance($server,$user,$pass,$db){
      if(self::$op_mysql == null){
        self::$op_mysql = new operatormysql($server,$user,$pass,$db);
      }
      return self::$op_mysql;
    }
    
    //just query sql
    public function execsql($sql){
      return mysql_query($sql,$this->conn);
    }
    
    //return last insert id
    public function execsql_ex($sql){
      $result = mysql_query($sql,$this->conn);
      if($result){
        return mysql_insert_id($this->conn);
      }else{
        return -1;
      }
    }
    //select count(*) from tablename where condition like '%con%'
    public function getcount($sql){
      $result = mysql_query($sql);
      $myrow = mysql_fetch_array($result);
      mysql_free_result($result);
      return $myrow[0];
    }
    //return affect rows in DELETE, INSERT, REPLACE, or UPDATE statement. 
    public function execsql_ex_($sql){
      $result = mysql_query($sql,$this->conn);
      if($result){
        return mysql_affected_rows($this->conn);
      }else{
        return -1;
      }
    }
    public function opensql($sql){
      $result = mysql_query($sql,$this->conn);
      if($result){
        $return = array();
        while($row = mysql_fetch_array($result)){
          $return[] = $row;
        }
      }
      mysql_free_result($result);
      return $return;
    }
    
    //get $count out
    public function opensql_ex($sql,&$count){
      $result = mysql_query($sql,$this->conn);
      if($result){
        $count = mysql_num_rows($result);
        $return = array();
        while($row = mysql_fetch_array($result)){
          $return[] = $row;
        }
      }
      mysql_free_result($result);
      return $return;
    }
    //mysql_real_escape_string() 
    function mysql_queryf($query) {
        if (func_num_args()>1){
            $args=func_get_args();
            $query=call_user_func_array("sprintf",$args);
        }
        return mysql_query($query,$this->conn);
    }
  }
?>