databaseaccess.java

用JAVA开发的~使用RMI进行异地访问的简单实例程序

// 在JDBC基础上提供连接与访问数据库的方法

package Database;

public class DatabaseAccess {
    // 属性定义
    protected java.sql.Connection conn = null;		// 为数据库建立的连接

    // 构造方法，建立与ODBC数据源dataSourceName的连接
    public DatabaseAccess(String dataSourceName) {
        try {
            // 建立与指定数据源的连接
            conn = java.sql.DriverManager.getConnection(dataSourceName);
            // 如果连接成功则检测是否有警告信息
            java.sql.SQLWarning warn = conn.getWarnings();
            while (warn != null) {
                System.out.println(warn.getMessage());
                warn = warn.getNextWarning();
            }
        } catch(java.sql.SQLException exc) {
            exc.printStackTrace();
        }
    }
    // 当前对象作为垃圾被收集时的回调方法，尽量撤销与数据库的连接
    public synchronized void finalize() {
        if (conn != null) {
            try {
                conn.close();
            } catch(java.sql.SQLException exc) {
                exc.printStackTrace();
            }
            conn = null;
        }
    }
    // 调用名为procedureName的存储过程查询数据库，返回查询结果集
    public synchronized java.sql.ResultSet callQuery(String procedureName)
        throws java.sql.SQLException
    {
        return conn.prepareCall("{call " + procedureName + "}").executeQuery();
    }
}