preparedstatementadddemo.java

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

package preparedstatement;

import java.sql.*;

public class PreparedStatementAddDemo {
  public PreparedStatementAddDemo() {
    //定义数据库连接的驱动程序
    String driver = "org.gjt.mm.mysql.Driver";
    //定义MySQL数据库的连接地址
    String url = "jdbc:mysql://localhost:3306/EmployeeEBKC10";
    //声明连接类
    Connection conn = null;
    int employeeId = 2007010025;
    //employee数据表的增加SQL语句
    String sql = "insert into employeeTable values(?,?,?,?,?,?,?,?)";
    try {
      //使用JDBC技术创建数据库连接
      Class.forName(driver);
      //使用DriverManager类的getConnection()方法建立连接
      conn = DriverManager.getConnection(url, "root", "test");
      //通过PreparedStatement增加记录
      PreparedStatement pstmt = conn.prepareStatement(sql);
      int rowCount = 0;
      for(int i = 25; i < 31; i++){
        //设置参数值
        pstmt.setString(1, String.valueOf(employeeId));
        pstmt.setString(2, "部门编号" + i);
        pstmt.setString(3, "员工" + i);
        pstmt.setString(4, "电话" + i);
        pstmt.setString(5, "地址" + i);
        pstmt.setTimestamp(6, this.transferDate("2007-2-1"));
        pstmt.setTimestamp(7, this.transferDate("2007-10-2"));
        pstmt.setInt(8, 0);
        //增加员工的序号
        employeeId++;
        //向数据表增加记录
        rowCount += pstmt.executeUpdate();
      }
      System.out.println("成功在数据表employeeTable创建" + rowCount + "条记录.");
    }catch(Exception e){
      System.out.println("数据表employeeTable记录创建失败.");
      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) {
    PreparedStatementAddDemo preparedStatementAddDemo1 = new PreparedStatementAddDemo();
  }
}