org.gjt.mm.mysql.Driver的数据库类

  1. package pubcls; 
  2.  
  3. import java.sql.*; 
  4.  
  5. /** 
  6.  * MySql 简单操作类 
  7.  * @author itblt 
  8.  */ 
  9. public class Mysql 
  10. { 
  11.     public Connection liveCon = null; 
  12.     public int dbWaitTime = 3600; 
  13.     public String dbLang = ""; 
  14.     public String errMessage = ""; 
  15.  
  16.     private String linkUrl = ""; 
  17.     private String linkDb = ""; 
  18.     private String linkUser = ""; 
  19.     private String linkPwd = ""; 
  20.  
  21.     /** 
  22.      * 设置默认参数 
  23.      */ 
  24.     private void setDefault() { 
  25.         this.linkUrl = "jdbc:mysql://localhost:3306/"; 
  26.         this.linkDb = "test"; 
  27.         this.linkUser = "root"; 
  28.         this.linkPwd = ""; 
  29.         this.dbLang = "utf8"; 
  30.     } 
  31.  
  32.     /** 
  33.      * 用默认参数初始化 
  34.      */ 
  35.     public Mysql() { 
  36.         this.setDefault(); 
  37.     } 
  38.  
  39.     /** 
  40.      * 指定数据库及编码进行初始化 
  41.      * @parem String sdb 
  42.      * 数据库名 
  43.      * @parem String dblang 
  44.      * 编码（通常是utf8/gbk） 
  45.      * 
  46.      */ 
  47.     public Mysql(String sdb, String dblang) { 
  48.         this.setDefault(); 
  49.         this.linkDb = sdb; 
  50.         this.dbLang = dblang; 
  51.     } 
  52.  
  53.     /** 
  54.      * 用完整的参数初始化 
  55.      * @parem String surl 
  56.      * 连接网址（jdbc:mysql://IP:端口/）: jdbc:mysql://localhost:3306/ 
  57.      * @parem String sdb 
  58.      * 数据库名 
  59.      * @parem String suser 
  60.      * 用户名 
  61.      * @parem String spwd 
  62.      * 密码 
  63.      * @parem String dblang 
  64.      * 数据库编码 
  65.      */ 
  66.     public Mysql(String surl, String sdb, String suser, String spwd, String dblang) { 
  67.         this.linkUrl = surl; 
  68.         this.linkDb = sdb; 
  69.         this.linkUser = suser; 
  70.         this.linkPwd = spwd; 
  71.         this.dbLang = dblang; 
  72.     } 
  73.  
  74.    /** 
  75.     * 获得链接 
  76.     */ 
  77.     public Connection getConnection() throws SQLException, 
  78.             java.lang.ClassNotFoundException 
  79.     { 
  80.         this.liveCon = this.getConnection(this.linkUrl, this.linkDb, this.linkUser, this.linkPwd, this.dbLang); 
  81.         return this.liveCon; 
  82.     } 
  83.  
  84.     /** 
  85.      * 用指定参数获取链接 
  86.      * @parem String surl 
  87.      * 连接网址（jdbc:mysql://IP:端口/）: jdbc:mysql://localhost:3306/ 
  88.      * @parem String sdb 
  89.      * 数据库名 
  90.      * @parem String suser 
  91.      * 用户名 
  92.      * @parem String spwd 
  93.      * 密码 
  94.      * @parem String dblang 
  95.      * 数据库编码 
  96.      * @return Connection 
  97.      */ 
  98.     public Connection getConnection(String surl, String sdb, String suser, String spwd, String dblang) throws SQLException, 
  99.             java.lang.ClassNotFoundException 
  100.     { 
  101.         this.linkUrl = surl; 
  102.         this.linkDb = sdb; 
  103.         this.linkUser = suser; 
  104.         this.linkPwd = spwd; 
  105.         this.dbLang = dblang; 
  106.  
  107.         Class.forName("org.gjt.mm.mysql.Driver"); 
  108.         this.liveCon = DriverManager.getConnection(surl+sdb, suser, spwd); 
  109.         this.preQuery(); 
  110.         return this.liveCon; 
  111.     } 
  112.      
  113.     /** 
  114.      * mysql转义 
  115.      * @return String 
  116.      */ 
  117.     public static String QuoteStr(String str) 
  118.     { 
  119.         String[] searchs = {"", "n", "r", "26", "t", "\", """, "'"}; 
  120.         String[] replaces = {"\0", "\n", "\r", "\Z" , "\t", "\\", "\"", "\'"}; 
  121.         for(int i=0; i < searchs.length; i++) 
  122.         { 
  123.             str = str.replace(searchs[i], replaces[i]); 
  124.         } 
  125.         return str; 
  126.     }  
  127.       
  128.  
  129.     /** 
  130.      * 测试链接 
  131.      * @return boolean 
  132.      */ 
  133.     private boolean testCon() throws SQLException 
  134.     { 
  135.         if(this.liveCon==null || this.liveCon.isClosed() ) 
  136.         { 
  137.             try 
  138.             { 
  139.                 this.getConnection(); 
  140.                 return true; 
  141.             }catch(ClassNotFoundException e) 
  142.             { 
  143.                 return false; 
  144.             } 
  145.             catch(SQLException e2) 
  146.             { 
  147.                 this.errMessage = e2.getMessage(); 
  148.                 return false; 
  149.             } 
  150.         } 
  151.         return true; 
  152.     } 
  153.  
  154.     /** 
  155.      * 执行写入语句 
  156.      * @parem string query 
  157.      * SQL 写入类操作 
  158.      * @return int 
  159.      */ 
  160.     public int execUpdate(String query) throws SQLException 
  161.     { 
  162.         if(!this.testCon()) 
  163.         { 
  164.             return -1; 
  165.         } 
  166.         Statement sql_statement = this.liveCon.createStatement(); 
  167.         int result = sql_statement.executeUpdate(query); 
  168.         sql_statement.close(); 
  169.         return result; 
  170.     } 
  171.  
  172.     /** 
  173.      * 执行insert语句并返回上次插入的主链id 
  174.      * @parem string 
  175.      * sql SQL语句 
  176.      * @return int 
  177.      */ 
  178.     public long execInsert(String query) throws SQLException 
  179.     { 
  180.         if(!this.testCon()) 
  181.         { 
  182.             return -1; 
  183.         } 
  184.         Statement sql_statement = this.liveCon.createStatement(); 
  185.         long result = sql_statement.executeUpdate(query); 
  186.         if(result>0) 
  187.         { 
  188.             sql_statement = this.getStatement(" Select LAST_INSERT_ID(); "); 
  189.             ResultSet rs = sql_statement.getResultSet(); 
  190.             rs.next(); 
  191.             result = rs.getLong(0); 
  192.         } 
  193.         sql_statement.close(); 
  194.         return result; 
  195.     } 
  196.  
  197.     /** 
  198.      * 获得一个记录集 
  199.      * @parem String query 
  200.      * 查询用的SQL语句 
  201.      * @return ResultSet 
  202.      */ 
  203.      public ResultSet getResultSet(String query) throws SQLException 
  204.      { 
  205.         if(!this.testCon()) 
  206.         { 
  207.             return null; 
  208.         } 
  209.         Statement sql_statement = this.getStatement(query); 
  210.         ResultSet result = sql_statement.getResultSet(); 
  211.         return result; 
  212.      } 
  213.  
  214.      /** 
  215.      * 获得一个可用于更新操作的记录集 
  216.      * @parem String query 
  217.      * 查询用的SQL语句 
  218.      * @return ResultSet 
  219.      */ 
  220.      public ResultSet getResultSetUpdate(String query) throws SQLException 
  221.      { 
  222.         if(!this.testCon()) 
  223.         { 
  224.             return null; 
  225.         } 
  226.         Statement sql_statement = this.liveCon.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_UPDATABLE); 
  227.         sql_statement.executeQuery(query); 
  228.         ResultSet result = sql_statement.getResultSet(); 
  229.         return result; 
  230.      } 
  231.  
  232.     /** 
  233.      * 获得一个Statement 
  234.      * @parem String query 
  235.      * 查询sql 
  236.      * @return Statement 
  237.      */ 
  238.      public Statement getStatement(String query) throws SQLException 
  239.      { 
  240.         if(!this.testCon()) 
  241.         { 
  242.             return null; 
  243.         } 
  244.         Statement sql_statement = this.liveCon.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY); 
  245.         sql_statement.executeQuery(query); 
  246.         return sql_statement; 
  247.      } 
  248.  
  249.      /** 
  250.      * 选择数据库 
  251.      */ 
  252.      public void selectDb(String dbname) throws SQLException 
  253.      { 
  254.         this.testCon(); 
  255.         this.execUpdate(" use `"+ dbname +"`; "); 
  256.      } 
  257.  
  258.      /** 
  259.      * 预处理 
  260.      */ 
  261.      private void preQuery() throws SQLException 
  262.      { 
  263.         this.execUpdate(" SET NAMES '"+ this.dbLang +"', character_set_client=binary, sql_mode='', wait_timeout="+ this.dbWaitTime +", interactive_timeout="+ this.dbWaitTime +" ; "); 
  264.      } 
  265.  
  266.    /** 
  267.     * 关闭链接 
  268.     */ 
  269.     public void close() throws SQLException 
  270.     { 
  271.         if(this.liveCon != null && !this.liveCon.isClosed() ) 
  272.         { 
  273.             this.liveCon.close(); 
  274.         } 
  275.         this.liveCon = null; 
  276.     } 
  277.  
  278.    /** 
  279.     * 析放资源 
  280.     */ 
  281.     public void finalize() { 
  282.         try { 
  283.             this.close(); 
  284.         } catch(SQLException e) { 
  285.             e = null; 
  286.         } 
  287.     } 
  288.  
  289. }//end class 
时间： 2024-10-29 02:18:54

org.gjt.mm.mysql.Driver的数据库类的相关文章

org.gjt.mm.mysql.Driver

  org.gjt.mm.mysql.Driver是com.mysql.jdbc.Driver的前身,如果你的项目中用到的是org.gjt.mm.mysql.Driver驱动,只是为了兼容性.和用com.mysql.jdbc.Driver没区别. 但是现在的项目建议使用com.mysql.jdbc.Driver.下面是测试代码: ? 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 p

Jsp 连接 mySQL、Oracle 数据库备忘(Windows平台)

js|mysql|oracle|window|数据|数据库  Jsp 环境目前最流行的是 Tomcat5.0.Tomcat5.0 自己包含一个 Web 服务器,如果是测试,就没必要把 Tomcat 与 IIS 或 Apache 集成起来.在 Tomcat 自带的 Web 服务器下可以进行 Jsp 测试.    安装 Tomcat5.0 前需要安装 JDK(如果是 Windows server 2003 就必须安装 JDK,因为 Windows server 2003 是不带 JVM 的-Wind

同时支持三个MySQL+SQLite+PDO的PHP数据库类

  PHP学习教程文章简介: 同时支持三个MySQL+SQLite+PDO的PHP数据库类使用方法: // mysql connect $db = new SQL(mysql:host=localhost;database=21andy_blog;, 21andy.com_user, 21andy.com_password); // PDO SQLite3 connect $db = new SQL(pdo:database=/21andy.com/21andy.s 同时支持三个MySQL+SQ

MySQL数据库类的定义

俗话说"好的开始是成功的一半",而PHP+MySQL项目中数据库的操作是重点之一,能否简化数据库操作程序的编写,就成了影响工作效率的关键之一. 所以小阳并不是一开始就做页面,而是先建立一个"dbclass.php"文件,开始编写操作MySQL数据库的类"dbClass".即在"dbclass.php"中编写以下程序: $db_username="myusername"; //连接数据库的用户名 $db_pa

一款简单实用的php操作mysql数据库类_php技巧

本文实例讲述了一款简单实用的php操作mysql数据库类.分享给大家供大家参考.具体如下: 复制代码 代码如下: /* 本款数据库连接类,他会自动加载sql防注入功能,过滤一些敏感的sql查询关键词,同时还可以增加判断字段 show table status的性质与show table类 获取数据库所有表名等.*/ @ini_set('mysql.trace_mode','off'); class mysql {  public $dblink;  public $pconnect;  priv

MySQL Driver 5.1.X与6.X日期兼容性问题

1.引言 最近在一个新项目里尝试使用mysql-connector-java-6.0.5.jar,但是从MaxCompute(原名ODPS)中导入MySQL的数据在控制台中看到是正常的,从Java应用里读取的却是相差13或14小时的.甚至SQL里限定了数据的时间在某一天,应用查出来的数据还能是不在那天的.这就很奇怪了,本着求根问底,踩坑识坑的精神,好好地研究了一把. 首先看从http://search.maven.org中可以大概的看到MySQL Driver的发布历史: 5.1.X和6.X版本

codeigniter自带数据库类使用方法说明

 在 CodeIgniter 中,使用数据库是非常频繁的事情.你可以使用框架自带的数据库类,就能便捷地进行数据库操作 初始化数据库类   依据你的数据库配置载入并初始化数据库类:   代码如下: this->load->database();     被载入之后你可以在任何地方使用它.   以对象形式返回查询结果    代码如下: $query = $this->db->query('SELECT name, title, email FROM my_table');   fore

codeigniter自带数据库类使用方法说明_php实例

初始化数据库类 依据你的数据库配置载入并初始化数据库类: 复制代码 代码如下: this->load->database(); 被载入之后你可以在任何地方使用它. 以对象形式返回查询结果 复制代码 代码如下: $query = $this->db->query('SELECT name, title, email FROM my_table'); foreach ($query->result() as $row){    echo $row->title;    ec

mysql driver的bug的深入分析

1 问题描述: 下面是应用上线后的线程个数的曲线图:   通过观察线程数:从0.2k增加到1.4k,然后突然又变成0.2k. 所有增加的线程均为Damon的线程. 有如下几个疑问:    1:为什么线程数会一直增加,出现了线程泄露?    2:在某个时间点线程数突然降了1.2k,why? 1.1 线程泄露排查    通过jstack打印栈信息,发现大部分的线程描述如下.(省略了部分栈信息) "MySQL  Statement Cancellation Timer" #2952daemo