databasetest2.java.bak

Java程序设计培训教程2

import java.sql.*;
/**类JDBCAdapter用于建立数据库连接*/
class JDBCAdapter{
    /*声明一个Connection对象,用于和数据库建立连接*/
    Connection          connection;
    /*声明一个Statement对象,用于对数据库执行SQL语句*/
    Statement           statement;
	/*声明一个ResultSet对象,用于存放SQL语句执行的结果*/
    ResultSet           resultSet;
     /**下面是构造方法,四个参数分别代表要连接的数据库,驱动程序,用户名和密码*/
    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语句,对数据库进行更新*/
            resultSet = 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();
    }
}
public class DatabaseTest2{
    public static void main(String args[]){
    	/*url指定需要访问的数据库名称*/
        String url="jdbc:odbc:MyDatabase";
        /*driver指定访问数据库的驱动程序的名称*/
        String driver="sun.jdbc.odbc.JdbcOdbcDriver";
        /*user和password用于指定访问数据库时使用的用户名和密码*/
        String user="sa";
        String password="";
        /*query代表需要执行的SQL语句*/
        String query1="alter table book add column type char(10)";
        String query2="alter table book drop column type";
        JDBCAdapter dt;
        /*通过构造一个JDBCAdapter类的对象来访问数据库*/
        dt=new JDBCAdapter(url,driver,user,password);
		/*对指定的数据库MyDatabase执行SQL语句,executeQuery方法是类JDBCAdapter中定义的*/
        dt.executeUpdate(query1);
        //dt.executeUpdate(query2);
    }
}