dbconnection.java

一个自制的DB framework,使用的配置方式新颖

package bits;

import java.sql.*;

public class DBconnection {
	//指定驱动程序
	private DbConfig dbconfig;
	private String strdriver;
	private String urlprotocal;
	private String port;
	private String hostname;
	private String databasename;
	//创建指定数据库的URL
	private String url = "";
	//提供用户名和密码
	private String user = "";
	private String pwd = "";
	Connection connect = null;
	ResultSet rs = null;

	public void DBInit(String strDBconfig) {
		dbconfig = new DbConfig(strDBconfig);
		dbconfig.parsed();
		this.hostname = dbconfig.getHostName();
		this.urlprotocal = dbconfig.getUrlprotocal();
		this.port = dbconfig.getPort();
		this.databasename = dbconfig.getDatabasement();
		this.user = dbconfig.getUser();
		this.pwd = dbconfig.getPwd();
		this.strdriver = dbconfig.getDriver();
		if (!"".equals(this.user.trim())) {
			this.url = this.urlprotocal + "://" + this.hostname + ":"
					+ this.port + ";DatabaseName=" + this.databasename;
		} else {
			this.url = this.urlprotocal;
		}
		try {
			Class.forName(strdriver.trim());
		} catch (java.lang.ClassNotFoundException e) {
			System.out.println(e.getMessage());
		}
	}

	private void getMyConn() throws Exception {
		if (connect == null) {
			if ("".equals(this.user)) {
				connect = DriverManager.getConnection(this.url);
			} else {
				connect = DriverManager.getConnection(url, user, pwd);
			}
		}
	}

	public ResultSet executeQuery(String sql) {
		try {
			getMyConn();
			Statement stmt = connect.createStatement(
					ResultSet.TYPE_SCROLL_INSENSITIVE,
					ResultSet.CONCUR_READ_ONLY);
			rs = stmt.executeQuery(sql);
		} catch (Exception ex) {
			System.out.println(ex.getMessage());
		}
		return rs;
	}

	public int executeUpdate(String sql) {
		int result = 0;
		try {
			getMyConn();
			Statement stmt = connect.createStatement(
					ResultSet.TYPE_SCROLL_INSENSITIVE,
					ResultSet.CONCUR_READ_ONLY);
			result = stmt.executeUpdate(sql);
		} catch (Exception ex) {
			System.out.println(ex.getMessage());
		}
		return result;
	}

	public Statement execute(String sql) {
		Boolean result = false;
		Statement stmt = null;
		try {
			getMyConn();
			stmt = connect.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
					ResultSet.CONCUR_READ_ONLY);
			result = stmt.execute(sql);
		} catch (Exception ex) {
			System.out.println(ex);
		}
		return stmt;
	}
}