preparedstatementupdatedemo.java

Eclipse程序设计经典教程+源代码 学习java的朋友可以看看

package preparedstatement;

import java.sql.*;

public class PreparedStatementUpdateDemo {
  public PreparedStatementUpdateDemo() {
    //定义数据库连接的驱动程序
    String driver = "org.gjt.mm.mysql.Driver";
    //定义MySQL数据库的连接地址
    String url = "jdbc:mysql://localhost:3306/EmployeeEBKC10";
    //声明连接类
    Connection conn = null;
    //employee数据表的更新SQL语句
    String updateSql = "update employeeTable set departmentId = ?, employeeName = ?," +
        " phone = ?, address = ?, joinDate = ?, resignDate = ?, employeeStatus = ?" +
        " where employeeId = ?";
    //employee数据表的选择SQL语句
    String selectSql = "select * from employeeTable where employeeId = ?";
    try {
      //使用JDBC技术创建数据库连接
      Class.forName(driver);
      //使用DriverManager类的getConnection()方法建立连接
      conn = DriverManager.getConnection(url, "root", "test");
      //通过PreparedStatement更新记录
      PreparedStatement pstmt = conn.prepareStatement(updateSql);
      //设置参数
      pstmt.setString(1, "部门编号25(更新)");
      pstmt.setString(2, "员工25(更新)");
      pstmt.setString(3, "电话25(更新)");
      pstmt.setString(4, "地址25(更新)");
      pstmt.setTimestamp(5, this.transferDate("2004-7-9"));
      pstmt.setTimestamp(6, this.transferDate("2007-11-13"));
      pstmt.setInt(7, 1);
      pstmt.setString(8, "2007010025");
      int result = pstmt.executeUpdate();
      if(result > 0){
        System.out.println("2007010025记录更新成功.");
      }
      //取得记录
      pstmt = conn.prepareStatement(selectSql);
      //设置参数
      pstmt.setString(1, "2007010025");
      ResultSet rs = pstmt.executeQuery();
      System.out.println("更新后的记录");
      while(rs.next()){
        String employeeId = rs.getString("employeeId");
        String departmentId = rs.getString("departmentId");
        String employeeName = rs.getString("employeeName");
        String phone = rs.getString("phone");
        String address = rs.getString("address");
        java.sql.Timestamp joinDate = rs.getTimestamp("joinDate");
        java.sql.Timestamp resignDate = rs.getTimestamp("resignDate");
        int employeeStatus = rs.getInt("employeeStatus");
        System.out.println(employeeId + "\t" + departmentId + "\t" +
                           employeeName + "\t" + phone + "\t" +
                           address + "\t" + joinDate + "\t" +
                           resignDate + "\t" +employeeStatus);
      }
    }catch(Exception e){
      e.printStackTrace();
    }
  }

  //返回java.sql的日期时间类的方法
  public java.sql.Timestamp transferDate(String dateStr){
    //声明java.sql类包的时间变量
    java.sql.Timestamp timeStamp = null;
    try{
      //创建日期转换类
      java.text.DateFormat dateShortFormat = java.text.DateFormat.getDateInstance();
      timeStamp = new java.sql.Timestamp(dateShortFormat.parse(dateStr).getTime());
    }catch(Exception ex){}
    return timeStamp;
  }

  public static void main(String[] args) {
    new PreparedStatementUpdateDemo();
  }
}