dbconnection.java

基于j2ee的物流软件

package com.wuliu.DBConnection;

import java.sql.*;


public class DBConnection {
	/**
	 * @by void 2009-1-9
	 * 修改 by void 09.2.12
	 * 添加了数据库参数的动态绑定
	 */
//	private String dbUrl = "jdbc:sqlserver://localhost:1433;databasename=wuliu";
//	private String dbUser = "sa";
//	private String dbPwd = "sa";
	private DataBase db=DBparse.parseDbXML();

	public DBConnection() {
		try {
			Class.forName(this.db.getDbdriver())
					.newInstance();
		} catch (InstantiationException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IllegalAccessException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

	public Connection getConnection() {
		Connection cn = null;
		try {
			cn = DriverManager.getConnection(this.db.getDbUrl(), this.db.getDbUser(),
					this.db.getDbPwd());
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return cn;

	}

	public void closeConnection(Connection cn) {
		if (cn != null) {
			try {
				cn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}

	}

	public void closePrepStmt(PreparedStatement ps) {
		if (ps != null) {
			try {
				ps.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}

	public void closeResultSet(ResultSet rs) {
		if (rs != null) {
			try {
				rs.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}

	public void closeCallableStatement(CallableStatement cstm) {
		if (cstm != null) {
			try {
				cstm.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}

}