jdbcadapter.java.bak

Java程序设计培训教程2

import java.sql.*;
/**类JDBCAdapter用于建立数据库连接*/
class JDBCAdapter{
    /*声明一个Connection对象,用于和数据库建立连接*/
    Connection          connection;
    /*声明一个Statement对象,用于对数据库执行SQL语句*/
    Statement           statement;

     /**下面是构造方法,四个参数分别代表要连接的数据库,驱动程序,用户名和密码*/
    public JDBCAdapter(String url, String driverName,
                       String user, String passwd) {
        try {
        	/*返回driverName字符串对应的类对象*/
            Class.forName(driverName);
            /*输出"Opening db connection"提示信息*/
            System.out.println("Opening db connection");
			/*下面的语句进行数据库的连接*/
            connection = DriverManager.getConnection(url, user, passwd);
            /*创建SQL语句*/
            statement = connection.createStatement();
        }
        catch (ClassNotFoundException ex) {
            /*输出没有找到数据库驱动程序类的信息*/
            System.err.println("Cannot find the database driver classes.");
            System.err.println(ex);
        }
        catch (SQLException ex) {
        	/*输出不能连接到数据库的信息*/
            System.err.println("Cannot connect to database.");
            System.err.println(ex);
        }
     }
    /**方法executeUpdate用于对数据库进行更新，参数query指定更新操作的SQL语句*/
    public void executeUpdate(String query) {
    	/*if语句中的条件表示数据库连接不成功或者没有创建SQL语句*/
        if (connection == null || statement == null) {
            System.err.println("There is no database to execute the query.");
            return;
        }
        try {
        	/*执行SQL语句,对数据库进行更新*/
            statement.executeUpdate(query);
        }
        catch (SQLException ex) {
            System.err.println(ex);
        }
    }
    /**方法executeQuery用于对数据库进行查询，参数query指定查询操作的SQL语句*/
    public void executeQuery(String query) {
    	/*if语句中的条件表示数据库连接不成功或者没有创建SQL语句*/
        if (connection == null || statement == null) {
            System.err.println("There is no database to execute the query.");
            return;
        }
        try {
        	/*执行SQL语句,对数据库进行更新*/
            statement.executeQuery(query);
        }
        catch (SQLException ex) {
            System.err.println(ex);
        }
    }
    /**将前面生成的SQL语句对象和数据库连接对象关闭*/
    public void close() throws SQLException {
        System.out.println("Closing db connection");
        statement.close();
        connection.close();
    }
    /*通过finalize()执行上面的close()方法*/
    protected void finalize() throws Throwable {
        close();
        super.finalize();
    }
}