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

mysql数据库连接类

发布:smiling 来源: PHP粉丝网  添加日期:2014-09-12 09:01:01 浏览: 评论:0 

这是一款比较常用的mysql+php的数据库连接类文件代码,这款连接类支持pconnect与mysql_connect来连接,用户可以根据自己的WEB应用类型来处理作选择,mysql数据库连接类代码如下:

  1. $dbhost = 'localhost';    // 数据库服务器 
  2.  $dbuser = 'root';     // 数据库用户名 
  3.  $dbpw = 'qwaszx';             // 数据库密码 
  4.  $dbname = 'movie';  // 数据库名 
  5.  $adminemail = 'haha@163.com'// 系统管理员 Email 
  6.  
  7.  $database = 'mysql';  // 不能修改此处 
  8.  $tplrefresh = 1;  // 模板自动刷新开关 0=关闭, 1=打开 
  9.  $pconnect = 0;   // 数据库连接方式 0=connect, 1=pconnect 
  10.  
  11. class db_class { 
  12.  var $querynum = 0; 
  13.  //function dbstuff() { global $fp; $fp = fopen("./tempdata/dblog.txt", "w"); } 
  14.  
  15.  function connect($dbhost$dbuser$dbpw$dbname$pconnect = 0) { 
  16.   if($pconnect) { 
  17.    if(!@mysql_pconnect($dbhost$dbuser$dbpw)) { 
  18.     $this->halt('Can not connect to MySQL server'); 
  19.    } 
  20.   } else { 
  21.    if(!@mysql_connect($dbhost$dbuser$dbpw)) { 
  22.     $this->halt('Can not connect to MySQL server'); 
  23.    } 
  24.   } 
  25.   mysql_query("SET NAMES 'GB2312'");//www.111cn.net 
  26.  } 
  27.  
  28.  function select_db($dbname) { 
  29.   return mysql_select_db($dbname); 
  30.  } 
  31.  
  32.  function fetch_array($query$result_type = MYSQL_ASSOC){ 
  33.  
  34.  
  35.   $query = mysql_fetch_array($query$result_type); 
  36.  
  37.   return $query
  38.  } 
  39.  
  40.  function query($sql$silence = 0) { 
  41.   //echo "|$sql|<br>"; //debug 
  42.   //@fwrite($GLOBALS[fp], $sql." "); //debug 
  43.   $query = mysql_query($sql); 
  44.         //echo 'query:'.$query.'<br>'; 
  45.      if(!$query && !$silence
  46.         { 
  47.          $this->halt('MySQL Query Error'$sql); 
  48.   } 
  49.         $this->querynum++; 
  50.   return $query
  51.  } 
  52.  
  53.  function unbuffered_query($sql$silence = 0) { 
  54.   $func_unbuffered_query = @function_exists('mysql_unbuffered_query') ? 'mysql_unbuffered_query' : 'mysql_query'
  55.   $query = $func_unbuffered_query($sql); 
  56.   if(!$query && !$silence) { 
  57.    $this->halt('MySQL Query Error'$sql); 
  58.   } 
  59.   $this->querynum++; 
  60.   return $query;//www.111cn.net 
  61.  } 
  62.  function get_one($sql){ 
  63.         $SQL=$sql
  64.   if(function_exists('mysql_unbuffered_query')){ 
  65.    $query = mysql_unbuffered_query($SQL); 
  66.   }else
  67.    $query = mysql_query($SQL); 
  68.   } 
  69.   $this->querynum++; 
  70.   if (!$query)  $this->halt('Query Error: ' . $SQL); 
  71.    
  72.   $rs =& mysql_fetch_array($query, MYSQL_ASSOC); 
  73.   mysql_free_result($query); 
  74.   return $rs
  75.  } 
  76.  
  77.  function affected_rows() { 
  78.   return mysql_affected_rows(); 
  79.  } 
  80.  
  81.  function error() { 
  82.   return mysql_error(); 
  83.  } 
  84.  
  85.  function errno() { 
  86.   return mysql_errno(); 
  87.  } 
  88.  
  89.  function result($query$row) { 
  90.   $query = @mysql_result($query$row); 
  91.   return $query;www.111cn.net 
  92.  } 
  93.  
  94.  function num_rows($query) { 
  95.   $query = mysql_num_rows($query); 
  96.   return $query
  97.  } 
  98.  
  99.  function num_fields($query) { 
  100.   return mysql_num_fields($query); 
  101.  } 
  102.  
  103.  function free_result($query) { 
  104.   return mysql_free_result($query); 
  105.  } 
  106.  
  107.  function insert_id() { 
  108.   $id = mysql_insert_id(); 
  109.   return $id
  110.  } 
  111.  
  112.  function fetch_row($query) { 
  113.   $query = mysql_fetch_row($query); 
  114.   return $query
  115.  } 
  116.  
  117.  function close() { 
  118.   return mysql_close(); 
  119.  } 
  120.  function halt($message = ''$sql = '') { 
  121.           echo $message
  122.               } 
  123.  
  124.  
  125. // ========= 连接数据库 
  126.  
  127. $db = new db_class; 
  128. $db->connect($dbhost$dbuser$dbpw$pconnect); 
  129. //开源代码phpfensi.com 
  130. $db->select_db($dbname); 
  131. unset($dbhost$dbuser$dbpw$dbname$pconnect);

Tags: mysql数据库连接类 php连接类

分享到: