当前位置:首页 > PHP教程 > php类库 > 列表

mysql数据库连接类

发布:smiling 来源: PHP粉丝网  添加日期:2014-09-11 22:40:39 浏览: 评论:0 

本款php连接mysql数据库连接程序代码是一款比较简单实用的连接代码,希望本教程对各位同学会有所帮助,代码如下:

  1. class mysql { 
  2.       public $sqlserver = 'localhost'
  3.       public $sqluser = 'root'
  4.       public $sqlpassword = ''
  5.       public $database
  6.       public $last_query = ''
  7.       private $connection
  8.       private $query_result
  9.       public function __construct() {} 
  10.       public function __destruct() { 
  11.        $this->close(); 
  12.       } 
  13.     //+======================================================+ 
  14.     // create a connection to the mysql database 
  15.     //+======================================================+ 
  16.     public function connect($server = null, $user = null, $password = null, $database = null){ 
  17.      if (isset($server)) $this->sqlserver = $server
  18.      if (isset($user)) $this->sqluser = $user
  19.      if (isset($password)) $this->sqlpassword = $password
  20.      if (isset($database)) $this->database = $database
  21.     $this->connection = mysql_connect($this->sqlserver, $this->sqluser, $this->sqlpassword); 
  22.     if($this->connection){ 
  23.     if (mysql_select_db($this->database)){ 
  24.     return $this->connection; 
  25.     }else
  26.     return $this->error(); 
  27.     } 
  28.     }else
  29.     return $this->error(); 
  30.     } 
  31.     } 
  32.     //+======================================================+ 
  33.     // execute a query 
  34.     //+======================================================+ 
  35.     public function query($query$die = false){ 
  36.       if ($query != null){ 
  37.        $this->last_query = $query
  38.        $this->query_result = mysql_query($query$this->connection); 
  39.        if(!$this->query_result){ 
  40.         if ($diedie("die: ".$this->query_result); 
  41.         return $this->error(); 
  42.        }else
  43.         if ($diedie("die: ".$this->query_result); 
  44.         return $this->query_result; 
  45.        } 
  46.       }else
  47.        echo "empty query cannot be executed!"
  48.       } 
  49.     } 
  50.     //+======================================================+ 
  51.     // returns the result 
  52.     //+======================================================+ 
  53.     public function getresult(){ 
  54.        return $this->query_result; 
  55.     } 
  56.     //+======================================================+ 
  57.     // returns the connection 
  58.     //+======================================================+ 
  59.     public function getconnection(){ 
  60.        return $this->connection; 
  61.     } 
  62.     //+======================================================+ 
  63.     // returns an object with properties rep 
  64.     //     resenting the result fields www.111cn.net and values 
  65.     //+======================================================+ 
  66.     public function getobject($qry = null){ 
  67.      if (isset($qry)) $this->query($qry); 
  68.      return mysql_fetch_object($this->getresult()); 
  69.     } 
  70.     //+======================================================+ 
  71.     // returns an array with keys representi 
  72.     //     ng the result fields and values 
  73.     //+======================================================+ 
  74.     public function getarray($query_id = ""){ 
  75.       if($query_id == null){ 
  76.        $return = mysql_fetch_array($this->getresult()); 
  77.       }else
  78.        $return = mysql_fetch_array($query_id); 
  79.       } 
  80.       return $return ? $return : $this->error(); 
  81.     } 
  82.     //+======================================================+ 
  83.     // returns the number of rows in the res 
  84.     //     ult 
  85.     //+======================================================+ 
  86.       public function getnumrows($qry = null){ 
  87.        if (isset($qry)) $this->query($qry); 
  88.        $amount = mysql_num_rows($this->getresult()); 
  89.        return emptyempty($amount) ? 0 : $amount
  90.     } 
  91.     //+======================================================+ 
  92.     // returns if the result contains rows 
  93.     //+======================================================+ 
  94.     public function hasresults($qry = null) { 
  95.       if (isset($qry)) $this->query($qry); 
  96.      return $this->getnumrows($qry) > 0; 
  97.     } 
  98.     //+======================================================+ 
  99.     // returns the number of rows that where 
  100.     //     affected by the last action 
  101.     //+======================================================+ 
  102.     public function getaffectedrows($qry = null, $query_id = null){ 
  103.       if (isset($qry)) $this->query($qry); 
  104.       if(emptyempty($query_id)){ 
  105.        $return = mysql_affected_rows($this->getresult()); 
  106.       }else
  107.        $return = mysql_affected_rows($query_id); 
  108.       } 
  109.       return $return ? $return : $this->error(); 
  110.     } 
  111.     //+======================================================+ 
  112.     // returns the auto generated id from th 
  113.     //     e last insert action 
  114.     //+======================================================+ 
  115.     public function getinsertid($connection_link = null){ 
  116.     return mysql_insert_id(isset($connection_link) ? $connection_link : $this->connection); 
  117.     } 
  118.     //+======================================================+ 
  119.     // close the connection to the mysql dat 
  120.     //     abase 
  121.     //+======================================================+ 
  122.     public function close(){ 
  123.     if(isset($this->connection)){ 
  124.     return @mysql_close($this->connection); 
  125.     } 
  126.     else { 
  127.      return $this->error(); 
  128.     } 
  129.     } 
  130.     //+======================================================+ 
  131.     // outputs the mysql error 
  132.     //+======================================================+ 
  133.     private function error(){ 
  134.     if(mysql_error() != ''){ 
  135.     echo '<b>mysql errorwww.111cn.net</b>: '.mysql_error().'<br/>'
  136.     } 
  137.     } 
  138.     } 
  139.     //demo 
  140.     // database object initialization 
  141. $db = new mysql(); 
  142. $db->connect("localhost""root""123456""user"); 
  143. // update query 
  144. //$db->query("update table_name set field_name = value where another_field = another_value"); 
  145. // select with check for record amount 
  146. if ($db->hasresults("select * from userinfo")) { 
  147. //   loop through the user records, and get them as objects 
  148. //   note that the getobject method will use the last executed query when not provided with a new one 
  149.   while ($user = $db->getobject()) { 
  150.     echo "user $user->username is called $user->password<br /> "
  151.   }//开源代码phpfensi.com 
  152. else { 
  153.   echo "no results where found"
  154. }

Tags: mysql数据库连接类

分享到: