jsp 数据库连接查询类代码

jsp 数据库连接查询类代码
define('DB_HOST', 'localhost'); //数据库服务器主机地址

define('DB_USER', 'zkh131'); //数据库帐号

define('DB_PW', 'n3a9q2e3'); //数据库密码

define('DB_NAME', 'zkh131_db'); //数据库名

define('DB_PRE', 'hl_'); //数据库表前缀，同一数据库安装多套Phpcms时，请修改表前缀

define('DB_CHARSET', 'gbk'); //数据库字符集

define('DB_PCONNECT', 0); //0 或1，是否使用持久连接

define('DB_DATABASE', 'mysql'); //数据库类型

$db = new db_mysql;

$db->connect(DB_HOST, DB_USER, DB_PW, DB_NAME, DB_PCONNECT, DB_CHARSET);

class db_mysql

{

 var $connid;

 var $dbname;

 var $querynum = 0;

 var $debug = 1;

 var $search = array('/union(s*(/*.**/)?s*)+select/i', '/load_file(s*(/*.**/)?s*)+(/i', '/into(s*(/*.**/)?s*)+outfile/i');

 var $replace = array('union   select', 'load_file   (', 'into   outfile');

 

 function connect($dbhost, $dbuser, $dbpw, $dbname = '', $pconnect = 0, $charset = '')

 {

  $func = $pconnect == 1 ? 'mysql_pconnect' : 'mysql_connect';

  if(!$this->connid = @$func($dbhost, $dbuser, $dbpw))

  {

   if(DB_NAME == '' && file_exists(PHPCMS_ROOT.'install.php'))

   {

    header('location:./install.php');

    exit;

   }

   $this->halt('Can not connect to MySQL server');

   return false;

  }

  if($this->version() > '4.1')

  {

   $serverset = $charset ? "character_set_connection='$charset',character_set_results='$charset',character_set_client=binary" : '';

   $serverset .= $this->version() > '5.0.1' ? ((empty($serverset) ? '' : ',')." sql_mode='' ") : '';

   $serverset && mysql_query("SET $serverset", $this->connid);

  }

  if($dbname && !@mysql_select_db($dbname , $this->connid))

  {

   $this->halt('Cannot use database '.$dbname);

   return false;

  }

  $this->dbname = $dbname;

  return $this->connid;

 }

 

 function select_db($dbname)

 {

  if(!@mysql_select_db($dbname , $this->connid)) return false;

  $this->dbname = $dbname;

  return true;

    }

 

 function query($sql , $type = '')

 {

  $func = $type == 'UNBUFFERED' ? 'mysql_unbuffered_query' : 'mysql_query';

  if(!($query = @$func($sql , $this->connid)) && $type != 'SILENT')

  {

   $this->halt('MySQL Query Error', $sql);

   return false;

  }

  $this->querynum++;

  return $query;

 }

 

 function select($sql, $keyfield = '')

 {

  $array = array();

  $result = $this->query($sql);

  while($r = $this->fetch_array($result))

  {

   if($keyfield)

   {

    $key = $r[$keyfield];

    $array[$key] = $r;

   }

   else

   {

    $array[] = $r;

   }

  }

  $this->free_result($result);

  return $array;

 }

 

 function insert($tablename, $array)

 {

  return $this->query("INSERT INTO `$tablename`(`".implode('`,`', array_keys($array))."`) VALUES('".implode("','", $array)."')");

 }

 

 function update($tablename, $array, $where = '')

 {

  if($where)

  {

   $sql = '';

   foreach($array as $k=>$v)

   {

    $sql .= ", `$k`='$v'";

   }

   $sql = substr($sql, 1);

   $sql = "UPDATE `$tablename` SET $sql WHERE $where";

  }

  else

  {

   $sql = "REPLACE INTO `$tablename`(`".implode('`,`', array_keys($array))."`) VALUES('".implode("','", $array)."')";

  }

  return $this->query($sql);

 }

 

 function get_primary($table)

 {

  $result = $this->query("SHOW COLUMNS FROM $table");

  while($r = $this->fetch_array($result))

  {

   if($r['Key'] == 'PRI') break;

  }

  $this->free_result($result);

  return $r['Field'];

 }

 

 function get_fields($table)

 {

  $fields = array();

  $result = $this->query("SHOW COLUMNS FROM $table");

  while($r = $this->fetch_array($result))

  {

   $fields[] = $r['Field'];

  }

  $this->free_result($result);

  return $fields;

 }

 

 function get_one($sql, $type = '', $expires = 3600, $dbname = '')

 {

  $query = $this->query($sql, $type, $expires, $dbname);

  $rs = $this->fetch_array($query);

  $this->free_result($query);

  return $rs ;

 }

 

 function fetch_array($query, $result_type = MYSQL_ASSOC)

 {

  return mysql_fetch_array($query, $result_type);

 }

 

 function affected_rows()

 {

  return mysql_affected_rows($this->connid);

 }

 

 function num_rows($query)

 {

  return mysql_num_rows($query);

 }

 

 function num_fields($query)

 {

  return mysql_num_fields($query);

 }

 

 function result($query, $row)

 {

  return @mysql_result($query, $row);

 }

 

 function free_result(&$query)

 {

  return mysql_free_result($query);

 }

 

 function insert_id()

 {

  return mysql_insert_id($this->connid);

 }

 

 function fetch_row($query)

 {

  return mysql_fetch_row($query);

 }

 

 function escape($string)

 {

  if(!is_array($string)) return str_replace(array('n', 'r'), array(chr(10), chr(13)), mysql_real_escape_string(preg_replace($this->search, $this->replace, $string), $this->connid));

  foreach($string as $key=>$val) $string[$key] = $this->escape($val);

  return $string;

 }

 

 function table_status($table)

 {

  return $this->get_one("SHOW TABLE STATUS LIKE '$table'");

 }

 

 function tables()

 {

  $tables = array();

  $result = $this->query("SHOW TABLES");

  while($r = $this->fetch_array($result))

  {

   $tables[] = $r['Tables_in_'.$this->dbname];

  }

  $this->free_result($result);

  return $tables;

 }

 

 function table_exists($table)

 {

  $tables = $this->tables($table);

  return in_array($table, $tables);

 }

 

 function field_exists($table, $field)

 {

  $fields = $this->get_fields($table);

  return in_array($field, $fields);

 }

 

 function version()

 {

  return mysql_get_server_info($this->connid);

 }

 

 function close()

 {

  return mysql_close($this->connid);

 }

 

 function error()

 {

  return @mysql_error($this->connid);

 }

 

 function errno()

 {

  return intval(@mysql_errno($this->connid)) ;

 }

 

 function halt($message = '', $sql = '')

 {

  $this->errormsg = "MySQL Query : $sql
MySQL Error : ".$this->error()."
MySQL Errno : ".$this->errno()."
Message : $message";

  if($this->debug)

  {

   $msg = (defined('IN_ADMIN') || DEBUG) ? $this->errormsg : "Bad Request. $LANG[illegal_request_return]";

   echo '

';

   exit;

  }

 }

}