dbase.java

本系统是投票系统

package com;

import java.sql.*;
import java.util.ResourceBundle;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.sql.DataSource;
import javax.sql.PooledConnection;
import oracle.jdbc.pool.OracleConnectionPoolDataSource;

public class Dbase {

	public Dbase() {
		Url = null;
		UserID = null;
		PassWord = null;
		con = null;
		dbpool = null;
		ReadParams();
		if (Url != null)
			try {
				OracleConnectionPoolDataSource oracleconnectionpooldatasource = new OracleConnectionPoolDataSource();
				oracleconnectionpooldatasource.setURL(Url);
				oracleconnectionpooldatasource.setUser(UserID);
				oracleconnectionpooldatasource.setPassword(PassWord);
				dbpool = oracleconnectionpooldatasource.getPooledConnection();
			} catch (Exception exception) {
				System.err.println("Create Connection Failed!");
				exception.printStackTrace(System.err);
			}
		else
			System.out.println("Read Params Failed!");
	}

	public void ReadParams() {
		ResourceBundle resourcebundle = ResourceBundle.getBundle("db");
		if (resourcebundle != null) {
			Url = resourcebundle.getString("url");
			UserID = resourcebundle.getString("user");
			PassWord = resourcebundle.getString("password");
		} else {
			System.out.println("rb is null!");
		}
	}

	public Connection getConn() throws SQLException {
		return dbpool.getConnection();
	}

	public void close() {
		if (dbpool != null)
			try {
				con.close();
				dbpool.close();
			} catch (Exception exception) {
				System.err.println("Close Pool Failed!");
				exception.printStackTrace(System.err);
			}
	}

	public static final Connection getConnection() throws SQLException {
		try {// 先尝试使用连接池
			Connection conn = null;
			Context ctx = new InitialContext();
			DataSource ds = (DataSource) ctx.lookup("oraJndi");
			conn = ds.getConnection();
			System.out.println("haoxuewu111");
			return conn;
		} catch (Exception e) {
			// "获取连接池失败，使用直接连接数据库的方式！"
			Dbase dbase = new Dbase();
			System.out.println("haoxuewu222");
			return dbase.getConn();
		}
	}

	public static final Connection getConnection(String connectPool) throws SQLException {
		try {// 先尝试使用 连接池
			Connection conn = null;
			Context ctx = new InitialContext();
			DataSource ds = (DataSource) ctx.lookup(connectPool);
			conn = ds.getConnection();
			return conn;
		} catch (Exception e) {
			// "获取连接池失败，使用直接连接数据库的方式！"
			Dbase dbase = new Dbase();
			return dbase.getConn();
		}
	}
	
	public static final void close(ResultSet resultset, Object obj,
			Connection connection) {
		if (resultset != null)
			try {
				resultset.close();
				resultset = null;
			} catch (SQLException sqlexception) {
			}
		if (obj != null && (obj instanceof Statement))
			try {
				((Statement) obj).close();
				obj = null;
			} catch (SQLException sqlexception1) {
			}
		if (connection != null)
			try {
				connection.close();
				connection = null;
			} catch (SQLException sqlexception2) {
			}
	}

	private PooledConnection dbpool;

	private String Url;

	private String UserID;

	private String PassWord;

	private Connection con;
	public static void main(String a[])
	{
		Dbase db=new Dbase();
		try
		{
			db.getConnection();
		}catch(Exception e)
		{
			e.printStackTrace();
		}
	}
}