f03a61cc9e9d001c1359bcc0dbb2db98

源代码

/**
 *  Title  staff
 *  Author: Wangmin
 *  Filename:DBConnect.java
 **/

package staff.database; 

import java.io.*;
import java.sql.*;
import java.util.*;

public class DBConnect {
	private String dbUrl;
    private String password;
    private String username;
    private String jdbcClassName;
	private Connection conn = null;
	private Statement stmt = null;
	private ResultSet rs=null;

	public DBConnect() throws Exception
    {
		dbUrl = "jdbc:postgresql:postgres";
		jdbcClassName = "org.postgresql.Driver";
		username = "postgres";
		password = "010551";
		connect();
    }

    public DBConnect( String inUrl, String inJdbcClassName, String inUserName, String inPassWord )
    		throws Exception
    {
		dbUrl = inUrl;
		jdbcClassName = inJdbcClassName;
		username = inUserName;
		password = inPassWord;
		connect();
    }
	private boolean connect()throws Exception 
    {
		boolean opened = false;
		Driver driver = (Driver) Class.forName(jdbcClassName).newInstance();
		DriverManager.registerDriver(driver);
		conn = DriverManager.getConnection(dbUrl, username, password);
		stmt = conn.createStatement ();
		opened = true;
	return opened;
    }

    public Connection getDBConnection()
    {
    	return conn;
    }

	/**
	 * 执行SQL语句返回字段集
	 * 
	 * @param sql
	 *            SQL语句
	 * @return ResultSet 字段集
	 */
	public ResultSet executeQuery(String sql) throws SQLException
	{
		if (stmt != null) 
		{
			return stmt.executeQuery(sql);
		} 
		else
			return null;
	}

	/**
	 * 执行SQL语句
	 * 
	 * @param sql
	 *            SQL语句
	 */
	public void executeUpdate(String sql) throws SQLException 
	{
		if (stmt != null)
			stmt.executeUpdate(sql);
	}


	/**
	 * 关闭连接
	 */
	public void close() throws Exception
	{
		if (stmt != null) 
		{
			stmt.close();
			stmt = null;
		}		
		if (conn != null)
			conn.close();
    }
}