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 = "<b>MySQL Query : </b>$sql <br /><b> MySQL Error : </b>".$this->error()." <br /> <b>MySQL Errno : </b>".$this->errno()." <br /><b> Message : </b> $message";

  if($this->debug)

  {

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

   echo '<div style="font-size:12px;text-align:left; border:1px solid #9cc9e0; padding:1px 4px;color:#000000;font-family:Arial, Helvetica,sans-serif;"><span>'.$msg.'</span></div>';

   exit;

  }

 }

}

时间: 2024-09-24 20:54:43

jsp 数据库连接查询类代码的相关文章

php mssql 数据库连接类代码(1/2)

php教程 mssql 数据库教程连接类代码  代码如下 复制代码 class DB_Sql {   var $Host     = "";   var $Database = "";   var $User     = "";   var $Password = "";   var $Link_ID  = 0;   var $Query_ID = 0;   var $Record   = array();   var $Ro

JSP简单添加,查询功能代码_JSP编程

本文实例讲述了JSP简单添加,查询功能.分享给大家供大家参考.具体如下: JSP技术: public class ISOtoGb2312 { public static String convert( String str ) { try { byte<> bytesStr=str.getBytes( "ISO-8859-1" ) ; return new String( bytesStr, "gb2312" ) ; } catch( Exception

适用初学者的JSP连接Access数据库代码

js|初学|access|数据库 适用初学者的JSP连接Access数据库代码,刚刚写的一个Java Web 中连接Access数据库的代码.这些天讲到数据库操作,但是我的本子是XP home版,安装SQL Server比较麻烦,干脆弄个ACCESS来演示好了.有时小型桌面数据库还是蛮实用的嘛,哈-复制内容到剪贴板代码:<%@ page contentType="text/html; charset=GB18030" %><%@page import="ja

ssh框架jsp分页查询中如何对迭代器生成的表格中的一行记录进行删除修改操作?

问题描述 ssh框架jsp分页查询中如何对迭代器生成的表格中的一行记录进行删除修改操作? 求此处的链接操作delete及modify的实现代码,求大神帮忙,万分感谢! 解决方案 JSP: //单个删除 function ch(id){ if(confirm("确定要删除吗?")){ window.location.href="user_del.action?delid="+id; } } Action中: private Integer delid; //从页面中获

java开发中通用分页类代码

java开发中通用分页类代码 在java中要分页我们必须要有数据库教程,所以我们先准备下数据库,其数据库脚步如下: --以下是创建数据库和数据库表以及向数据库插入数据   use master  Go  if exists(select * from sysdatabases where name='pagination')  drop database pagination  Go  create database pagination  Go  use pagination  Go  cre

初学MVC,哪个大神能帮忙讲一下这个三表查询的代码是什么意思?感谢!

问题描述 初学MVC,哪个大神能帮忙讲一下这个三表查询的代码是什么意思?感谢! var query3 = from q in db.Customers join qq in db.Orders on q.CustomerID equals qq.CustomerID into tmporder join e in db.Employees on q.City equals e.City into tmpemp select new { q.CompanyName, tmporderCount =

【JSP 随笔之一】JSP常用语法和使用总括&amp;&amp;JSP服务器端和客户端代码互相调用

本站文章均为 李华明Himi 原创,转载务必在明显处注明:  转载自[黑米GameDev街区] 原文链接: http://www.himigame.com/java-servlet/858.html 对于Servlet 学习过后,那么接触到JSP,那么可以发现JSP编程则会突然喜爱上,因为JSP不仅仅也是一个servlet,还能帮我们直接从servlet的容器(Tomcat)为我们直接生成对应的servlet代码.至于更加详细的介绍大家可以自行baidu-goole 下面让我们首先写一个JSP,

JSP+MYSQL+Java类优化分页的实例

在JSP中经常要用到查询数据库中的数据,同常我们的做法是使用SQL语句"select * from tablename order by id desc",这样的做法有 一个缺点,当数据库很大的时候查询的速度会变的很慢,在ASP中有一种方法 "select top "&recpage&" * from tablename where id not in (select top "&(recpage*(currentpage

jsp中调用java代码小结

  大多数情况下, jsp 文档的大部分由静态文本(html)构成, 为处理该页面而创建的 servlet 只是将它们原封不动的传递给客户端 原封不动的传送给客户端有两个小例外: 1. 如果想传送 , 由于它跟jsp的特殊符号一致, 所以必须使用转义字符转义, <% 或 %> 2. 如果想传送注释, 在 jsp 编辑页面中出现, 而在生成的html文档不出现, 那么我们要使用 , 而 这种形式会原封不动的传递给客户端. jsp 调用动态代码策略 使用 mvc, 由一个 servlet 负责处理