databasepool.java

java数据库连接池源代码,主要用于java与数据库的连接

package com;

import javax.naming.*;
import javax.sql.*;
import java.sql.*;
public class DataBasePool 
{
	private Context initCtx=null;//声明初使化上下文对象
	private Context ctx =null;//声明一DataSource对象
	private DataSource ds=null;//JNDI名称name
	private Connection conn;
	private ResultSet rs = null;
	private Statement stmt=null;
	public DataBasePool()
	{
		try {
			//利用JNDI查找数据源
			initCtx = new InitialContext();
		} catch (NamingException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		try {
				//查找上下文资源
			ctx = (Context)initCtx.lookup("java:comp/env");
		} catch (NamingException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		try {
			//查找数据源
			ds=(DataSource)ctx.lookup("test");
		} catch (NamingException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	public ResultSet search(String sql)
	{
		try {
			conn = ds.getConnection();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		try {
			stmt = conn.createStatement();
			rs = stmt.executeQuery(sql);
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return rs;
	}
	public void update(String sql)
	{
		try {
			conn = ds.getConnection();
			stmt = conn.createStatement();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		try {
			conn.setAutoCommit(false);
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		try {
			stmt.executeUpdate(sql);
			conn.commit();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		try {
			conn.rollback();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	public void close()
	{
		try {
			rs.close();
			stmt.close();
			conn.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	}
}