sqlcommandtest.java

ACCP 软件工程java 教程学生用书

/**
 * (c)北大青鸟APTECH
 * 版权所有
 */
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.ResultSetMetaData;
import java.sql.DriverManager;

/**
 * 这个类使用 Prepared Statement 搜索记录.
 * @version 1.0, 2005 年 6 月 15 日
 * @author Michael
 */

class SQLCommandDemo {

  /** 声明一个 statement 对象.*/
  private Statement stmtObj;

  /** 声明一个 string 变量.*/
  private String strSql;

  /** 声明一个 Connection 对象.*/
  private Connection con;

  /**
   * 构造方法.
   **/
  SQLCommandDemo() {
  }

  /**
   * 建立连接的方法.
   */
  void establishConnection() {
    try {

      Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
    }
    catch (ClassNotFoundException ce) {
      System.out.println(ce);
    }

    try {
      String url = "jdbc:odbc:test";
      con = DriverManager.getConnection(url, "sa", "sa");
      stmtObj = con.createStatement();
    }
    catch (SQLException ce) {
      System.out.println("Error... " + ce);
    }

  }

  /**
   * 执行 sql 命令的方法.
   */
  void execute() {

    try {     

      stmtObj.executeUpdate("Insert into Staff Values"
                            + "(1, '张三' , '北京' , 35000 , 34652 , '管理部')");
      stmtObj.executeUpdate("Insert into Staff Values"
                            + "(2 , '李四' , '上海' , 43000 , 128965, '财务部')");
      stmtObj.executeUpdate("Insert into Staff Values"
                            + "(3,'王五' , '广州' , 65000 , 45213, '市场部')");

      PreparedStatement updates =
          con.prepareStatement("UPDATE Staff SET"
                               + " Employee_Salary = ? WHERE Employee_Id = ?");
      updates.setFloat(1, 3000);
      updates.setInt(2, 1);
      updates.execute();

      ResultSet rs = stmtObj.executeQuery("Select * from Staff");
      System.out.println();
      System.out.println("插入后的表!!!");
      System.out.println();
      System.out.print("员工编号");
      System.out.print("\t员工姓名");
      System.out.print("\t\t城市");
      System.out.print("\t\t工资");
      System.out.println("\t\t电话");

      System.out.print("___________");
      System.out.print("\t_____________");
      System.out.print("\t\t_____");
      System.out.print("\t\t________");
      System.out.println("\t______");
      while (rs.next()) {
        System.out.print(rs.getString(1));
        System.out.print("\t\t" + rs.getString(2));
        System.out.print("\t\t\t" + rs.getString(3));
        System.out.print("\t\t" + rs.getString(4));
        System.out.println("\t\t" + rs.getInt(5));

      }
      System.out.println();

      stmtObj.close();
      updates.close();
      con.close();

    }
    catch (Exception sqle) {
      System.out.println("出现异常" + sqle);

    }

  }
}

/**
 * 测试 SQLCommandDemo 类.
 * @version 1.0, 2005 年 5 月 20 日
 * @author Michael
 */


class SQLCommandTest {

  /**
   * 构造方法.
   */
  protected SQLCommandTest() {
  }

  /**
   * 这是执行任何应用程序的起始点.
   * @param args 被传递至 main 方法
   */
  public static void main(String[] args) {
    SQLCommandDemo sqlObj = new SQLCommandDemo();
    sqlObj.establishConnection();
    sqlObj.execute();
  }
}