数据库BEAN：RESIN连接池

文章作者 100test 发表时间 2007:03:14 16:36:05
来源 100Test.Com百考试题网

package net.asales.mysql.
　　
　　import java.sql.Connection.
　　import java.sql.Statement.
　　import java.sql.ResultSet.
　　import java.sql.SQLException.
　　import javax.sql.DataSource.
　　import javax.naming.Context.
　　import javax.naming.InitialContext.
　　
　　public class DBConnection {
　　　　private Connection conn = null.
　　　　private Statement stmt = null.
　　　　private ResultSet rs = null.
　　　　private int resultNum = 0.
　　
　　　　/**
　　　　 * 构造函数
　　　　 * 找到数据源，并用这个数据源创建连接
　　　　 */
　　　　public DBConnection() {
　　　　　　try {
　　　　　　　　Context env = new InitialContext().
　　　　　　　　DataSource pool = (DataSource) env.lookup(java:comp/env/jdbc/asales).
　　　　　　　　if (pool == null)
　　　　　　　　　 throw new Exception(jdbc/asales is an unknown DataSource).
　　　　　　　　conn = pool.getConnection().
　　　　　　　　stmt = conn.createStatement().
　　　　　　} catch (Exception e) {
　　　　　　　　System.out.println(naming: e.getMessage()).
　　　　　　}
　　　　}
　　
　　　　/**
　　　　 * 执行SQL语句：查询记录
　　　　 * @param sql SQL语句
　　　　 * @return ResultSet 记录集
　　　　 */
　　　　public ResultSet executeQuery(String sql) {
　　　　　　rs = null.
　　　　　　try {
　　　　　　　　rs = stmt.executeQuery(sql).
　　　　　　} catch(SQLException se) {
　　　　　　　　System.out.println(Query error: se.getMessage()).
　　　　　　}
　　　　　　return rs.
　　　　}