session.java

一个OR Mapping工具

//-< Session.java >--------------------------------------------------*--------*
// JORA                       Version 2.0        (c) 1998  GARRET    *     ?  *
// (Java Object Relational Adapter)                                  *   /\|  *
//                                                                   *  /  \  *
//                          Created:     10-Jun-98    K.A. Knizhnik  * / [] \ *
//                          Last update: 20-Jun-98    K.A. Knizhnik  * GARRET *
//-------------------------------------------------------------------*--------*
// Database session abstraction  
//-------------------------------------------------------------------*--------*

package jora;

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

/**
 * This class is reposnsible for establishing connection with database
 * and handling database errors.
 */
public class Session { 
    public Connection connection;

    /** Session consructor
     * 
     * @param driverClass class of database driver
     */
    public Session(String driverClass)
    {
        driver = driverClass;
        preparedStmtHash = new Hashtable();
	connectionID = 0;
    }

    /** Session consructor for ODBC bridge driver
     */
    public Session() { this("sun.jdbc.odbc.JdbcOdbcDriver"); }
     
    /** Handler of database session errors. Programmer should override
     *  this method in derived class in order to provide application
     *  dependent error handling.
     * 
     * @param ex exception thrown by some of JDBC methods
     */
    public void handleSQLException(SQLException ex) {
        // A SQLException was generated.  Catch it and
        // display the error information.  Note that there
   	// could be multiple error objects chained
	// together
	System.out.println ("*** SQLException caught ***");
	SQLException x = ex; 
	while (ex != null) {
	    System.out.println("SQLState: " + ex.getSQLState ());
	    System.out.println("Message:  " + ex.getMessage ());
	    System.out.println("Vendor:   " + ex.getErrorCode ());
	    ex = ex.getNextException();
	    System.out.println ("");
	}
	throw new SQLError(x); // terminate program execution
    }

    /** Open database session. 
     *  Attempt to establish a connection to the given database URL.
     *  The DriverManager attempts to select an appropriate driver from
     *  the set of registered JDBC drivers.
     *
     * @param url a database url of the form 
     *  jdbc:<em>subprotocol</em>:<em>subname</em>
     * @param user the database user on whose behalf the Connection is being made
     * @param password the user's password
     * @return true if session is succesfully openned, false otherwise
     */      
    public boolean open(String dataSource, String user, String password)
    {
        try {
	     Class.forName(driver);

	     connection = 
	       DriverManager.getConnection(dataSource, user, password);	
	     connectionID += 1;
	} 
	catch(SQLException ex) { 
	    handleSQLException(ex); 
	    return false;
	}
	catch(ClassNotFoundException ex) { 
	    return false;
	}
	return true;
    }

    /** Close database session and release all resources holded by session.
     */
    public void close() { 
        try { 
	    Enumeration items = preparedStmtHash.elements();
	    while (items.hasMoreElements()) { 
	        ((PreparedStatement)items.nextElement()).close();
	    }
	    preparedStmtHash.clear();
	    connection.close();
	} 
	catch (SQLException ex) { handleSQLException(ex); }
    }
  
    /**
     * Execute a SQL INSERT, UPDATE or DELETE statement. In addition,
     * SQL statements that return nothing such as SQL DDL statements
     * can be executed.
     *
     * @param sql a SQL INSERT, UPDATE or DELETE statement or a SQL
     * statement that returns nothing
     * @return either the row count for INSERT, UPDATE or DELETE or 0
     * for SQL statements that return nothing
     */
    public int execute(String sql) {
        try { 
	    Statement stmt = connection.createStatement();
	    int result = stmt.executeUpdate(sql);
	    stmt.close();
	    return result;
	} catch(SQLException ex) { handleSQLException(ex); }
	return -1;
    }

    /**
     * Commit makes all changes made since the previous
     * commit/rollback permanent and releases any database locks
     * currently held by the Connection. This method should only be
     * used when auto commit has been disabled.
     */
    public void commit() { 
        try { 
	    connection.commit();
	} catch(SQLException ex) { handleSQLException(ex); }
    }

    /**
     * Rollback drops all changes made since the previous
     * commit/rollback and releases any database locks currently held
     * by the Connection. This method should only be used when auto
     * commit has been disabled.
     */
    public void rollback() { 
        try { 
	    connection.rollback();
	} catch(SQLException ex) { handleSQLException(ex); }
    }

    protected String    driver;   // driver class name
    protected Hashtable preparedStmtHash;
    protected int       connectionID;
}