resultsetadddemo.java

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

package resultset;

import java.sql.*;

public class ResultSetAddDemo {

  public ResultSetAddDemo() {
    //定义数据库连接的驱动程序
    String driver = "org.gjt.mm.mysql.Driver";
    //定义MySQL数据库的连接地址
    String url = "jdbc:mysql://localhost:3306/EmployeeEBKC10";
    //声明连接类
    Connection conn = null;
    //employee数据表的选择SQL语句
    String sql = "select * from employeeTable";
    try {
      //使用JDBC技术创建数据库连接
      Class.forName(driver);
      //使用DriverManager类的getConnection()方法建立连接
      conn = DriverManager.getConnection(url, "root", "test");
      //通过Statement查询记录，使返回数据集可以前后移动和可以进行增加、更改和删除操作
      Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
                                            ResultSet.CONCUR_UPDATABLE);
      //取得返回的记录集
      ResultSet rs = stmt.executeQuery(sql);
      //移到新增加的记录行
      rs.moveToInsertRow();
      //设置记录值
      rs.updateString("employeeId", "2007010021");
      rs.updateString("departmentId", "部门编号21");
      rs.updateString("employeeName", "员工21");
      rs.updateString("phone", "电话21");
      rs.updateString("address", "地址21");
      rs.updateTimestamp("joinDate", this.transferDate("2007-1-2"));
      rs.updateTimestamp("resignDate", this.transferDate("2007-2-10"));
      rs.updateInt("employeeStatus", 0);
      //将增加记录保存入数据库
      rs.insertRow();
      //移到最后一行，显示新增加记录值
      rs.last();
      this.showCurrentRow(rs);
    }catch(Exception e){
      e.printStackTrace();
    }
  }

  //显示当前记录的方法
  public void showCurrentRow(ResultSet rs) throws Exception{
    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);
  }

  //返回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) {
    ResultSetAddDemo resultSetAddDemo1 = new ResultSetAddDemo();
  }
}