databaseconnectorpostgres.java

OR Mapping工具

/**
 * Title:        DatabaseConnectorPostgres<p>
 * Description:  Class to manage a connection to a PostgreSQL database.<p>
 * Copyright:	Copyright (c) 2001 Paul Bethe and Richie Bielak<p>
 * @author       Paul Bethe
 * @version 1.0
 */
package org.ephman.abra.database;

import java.sql.*;

public class DatabaseConnectorPostgres implements DatabaseConnectorInterface {

	private String dbName;

	private String hostName;

	private int defaultPort = 5432;

	private Connection conn;

	public DatabaseConnectorPostgres(String host) {
		conn = null;
		hostName = host;

		try {
			/* Load the oracle driver */
			DriverManager.registerDriver(new postgresql.Driver());
		}
		catch (SQLException e) {
			System.out.println("ERROR:* Unable to load PostgreSQL driver");
			e.printStackTrace ();
		}
	}

	/** Connect to the named database.
	 *
	 *  @param db name of the database to connect to
	 *  @param user user name with which to login into db server
	 *  @param pass password for the user
	 *
	 *  @throws SQLException - when connection fails
	 */
	public void connect (String db,
						 String user,
						 String pass) throws SQLException {
		dbName = db;
		String url = jdbc_url() + "/" + dbName;
		/* Load the appropriate driver */
		try {
			conn = DriverManager.getConnection (url, user, pass);
		}
		catch (SQLException e) {
			System.out.println ("Unable to connect to: " + url + " - " + e.getMessage());
			e.printStackTrace();
			throw e;
		}
	}


	/** Create the first part of the URL needed for specifying
	 *  the database in JDBC db connection.
	 */
	public String jdbc_url () {
		/* This is a pure Java version of JDBC. Should try to get the oci version working */
		// String result = "jdbc:oracle:oci8:@";
		String result = "jdbc:postgresql://" + hostName +":" + defaultPort;
		return (result);
	}


	/** Disconnect from this database. If no connection is active
	 *  nothing is done.
	 */
	public void disconnect () {
		if (conn != null) {
			try {
				conn.close();
			}
			catch (SQLException ignored) {};
                  dbName = null;
		}

	};

	/**
	 * Get the value of conn.
	 * @return Value of conn.
	 */
	public Connection getConn() {return (conn);};

	/**
	 * Get the value of dbName.
	 * @return Value of dbName.
	 */
	public String getDbName() {return (dbName);};

	/**
	 * Get the value of dbServerHost.
	 * @return Value of dbServerHost.
	 */
	public String getDbServerHost() {return (hostName);};

	/**
	 * Set the value of dbServerHost.
	 * @param v  Value to assign to dbServerHost.
	 */
	public void setDbServerHost(String  v) {hostName = v;};

	/**
	 * Get the value of dbServerPort.
	 * @return Value of dbServerPort.
	 */
	public int getDbServerPort() {return (defaultPort);};

	/**
	 * Set the value of dbServerPort.
	 * @param v  Value to assign to dbServerPort.
	 */
	public void setDbServerPort(int  v) {};



}