package hzvtc.util;import java.sql.Connection;import java.sql.DriverManager;import java.sql.SQLException;import java.util.ArrayList;import mons.dbutils.DbUtils;import mons.dbutils.QueryRunner;import mons.dbutils.ResultSetHandler;import mons.dbutils.handlers.BeanHandler;import mons.dbutils.handlers.BeanListHandler;import mons.logging.Log;import mons.logging.LogFactory;public class DbHelper private String dbms; / 數據庫類型private String dbmsDriver; / 數據庫驅動private String host; / 主機private String port; / 端口private String db; / 數據庫名private String user; / 用戶名private String password; / 密碼private Class beanClass = null;private Connection conn = null;private final Log logger = LogFactory.getLog(DbHelper.class);/* 根據數據庫類型設置驅動程序* param dbms 數據庫類型，如mysql、postgresql等*/private void fillDbmsDriver(String dbms) if (dbms.equalsIgnoreCase(postgresql) dbmsDriver = org.postgresql.Driver; else if (dbms.equalsIgnoreCase(mysql) dbmsDriver = org.gjt.mm.mysql.Driver;/* 根據數據庫類型設置端口* param dbms 數據庫類型*/private void fillDbmsPort(String dbms) if (dbms.equalsIgnoreCase(postgresql) port = 5432; else if (dbms.equalsIgnoreCase(mysql) port = 3306;/* 設置數據連接時需要的參數* param dbms 數據庫類型* param host 主機* param db 數據庫名* param user 用戶名* param password 密碼*/public DbHelper(String dbms, String host, String db, String user, String password) this.dbms = dbms; fillDbmsDriver(dbms); this.host = host; fillDbmsPort(dbms); this.db = db; this.user = user; this.password = password;/* 設置數據連接時需要的參數* param dbms 數據庫類型* param host 主機* param port 端口* param db 數據庫名* param user 用戶* param password 密碼*/public DbHelper(String dbms, String host, String port, String db, String user, String password) this.dbms = dbms; fillDbmsDriver(dbms); this.host = host; this.port = port; this.db = db; this.user = user; this.password = password;/* 加載驅動*/public void connect() if (conn != null) return; String strConn = String.format(jdbc:%s:/%s:%s/%s, dbms, host, port, db); DbUtils.loadDriver(dbmsDriver); try conn = DriverManager.getConnection(strConn, user, password); catch (SQLException e) logger.error(Database connection failed!); logger.error(e.getMessage(); /* 關閉Connection*/public void close() try DbUtils.close(conn); conn = null; catch (SQLException e) logger.error(Database close failed!); logger.error(e.getMessage(); /* 根據無參sql語句進行查詢，并返回一個對象，用于單條記錄的查詢* param sql * return Object*/public Object query(String sql) if (conn = null | beanClass = null) return null; QueryRunner run = new QueryRunner(); ResultSetHandler h = new BeanHandler(beanClass); Object result = null; try result = run.query(conn, sql, h); catch (SQLException e) (SQLException in + sql + ); logger.error(e.getMessage(); return result;/* 根據有參sql語句進行查詢，并返回一個對象，用于單條記錄的查詢* param sql * param args * return Object*/public Object query(String sql, Object. args) if (conn = null | beanClass = null) return null; QueryRunner run = new QueryRunner(); ResultSetHandler h = new BeanHandler(beanClass); Object result = null; try result = run.query(conn, sql, args, h); catch (SQLException e) (SQLException in + sql + ); logger.error(e.getMessage(); return result;/* 根據無參sql語句進行查詢，并返回一個數據集，用于多條記錄的查詢* param sql* return ArrayList*/public ArrayList queryRecords(String sql) if (conn = null | beanClass = null) return null; QueryRunner run = new QueryRunner(); ResultSetHandler h = new BeanListHandler(beanClass); ArrayList result = null; try result = (ArrayList) run.query(conn, sql, h); / obtain the quaried records catch (SQLException e) (SQLException in + sql + ); logger.error(e.getMessage(); return result;/* 根據有參sql語句進行查詢，并返回一個數據集，用于多條記錄的查詢* param sql* param args* return*/public ArrayList queryRecords(String sql, Object. args) if (conn = null | beanClass = null) return null; QueryRunner run = new QueryRunner(); ResultSetHandler h = new BeanListHandler(beanClass); ArrayList result = null; try result = (ArrayList) run.query(conn, sql, args, h); System.out.println(result.size(); / obtain the quaried records catch (SQLException e) (SQLException in + sql + ); logger.error(e.getMessage(); return result;/* 根據無參sql語句進行數據更新，并返回更新后影響的記錄數* param sql* return int*/public int update(String sql) if (conn = null) return 0; QueryRunner run = new QueryRunner(); int result = 0; try result = run.update(conn, sql); catch (SQLException e) (SQLException in + sql + ); logger.error(e.getMessage(); return result;/* 根據有參sql語句進行數據更新，并返回更新后影響的記錄數* param sql* param args* return int*/public int update(String sql, Object. args) if (conn = null) return -1; QueryRunner run = new QueryRunner(); int result = 0; try result = run.update(conn, sql, args); catch (SQLException e) (SQLException in + sql + ); logger.error(e.getMessage(); return result;/* 設置存放查詢結果的Bean類，每個Bean類對象對應一條查詢的結果記錄* param beanClass，如User.class*/public void setBeanClass(Class beanClass) this.beanClass = beanClass;/* 設置使用外部的Connection對象，如來自數據庫連接池的連接* param conn Connection對象*/public void setConn(Connection conn) this.conn = conn;Overrideprotected void finalize() throws Throwable / TODO Auto-generated method stub close(); super.finalize();DbTestpackage hzvtc.util.test;import hzvtc.util.DbHelper;import java.util.List;public class DbTest /* param args*/public static void main(String args) / TODO Auto-generated method stub int n = 3; DbHelper dh = new DbHelper(mysql, localhost, test, root, 123456); dh.connect(); dh.setBeanClass(User.class); /u是從數據庫查詢出來的記錄對象 User u = (User) dh.query(SELECT id,name,age,address FROM t_user WHERE id=9); /u2是從數據庫查詢出來的記錄對象 User u2 = (User) dh.query(SELECT id,name,age,address FROM t_user WHERE id=?, n); / users和user2存放著從數據庫查詢