当前位置:Gxlcms > mysql > java从mysql导出数据例子

java从mysql导出数据例子

时间:2021-07-01 10:21:17 帮助过:16人阅读

欢迎进入Java社区论坛,与200万技术人员互动交流 >>进入 * 导出一小时内的数据 * @param conn */ public static void Exp(Connection conn) { int counter = 0; //一小时内的数据 Long timestamp = System.currentTimeMillis() - (600 * 60 * 1000);

欢迎进入Java社区论坛,与200万技术人员互动交流 >>进入

  * 导出一小时内的数据

  * @param conn

  */

  public static void Exp(Connection conn) {

  int counter = 0;

  //一小时内的数据

  Long timestamp = System.currentTimeMillis() - (600 * 60 * 1000);

  boolean flag = true;

  while (flag) {

  flag = false;

  String Sql = "SELECT * FROM t_test WHERE createTime>"

  + timestamp + " LIMIT 50";

  System.out.println("sql===" + Sql);

  try {

  Statement stmt = conn.createStatement();

  ResultSet rs = stmt.executeQuery(Sql);

  while (rs.next()) {

  flag = true;

  int id = rs.getInt("id");

  String title = rs.getString("title");

  Long lastmodifytime = rs.getLong("createTime");

  timestamp = lastmodifytime;

  counter++;

  System.out.println("i="+counter+"--id--"+id+"--title-"+title);

  }

  rs.close();

  stmt.close();

  } catch (SQLException e) {

  e.printStackTrace();

  }

  }

  }

  public static void Test() {

  Connection Conn=null;

  try {

  Class.forName("com.mysql.jdbc.Driver")。newInstance();

  String jdbcUrl = "jdbc:mysql://127.0.0.1:3306/test?characterEncoding=GBK";

  String jdbcUsername = "root";

  String jdbcPassword = "mysql";

  Conn = DriverManager.getConnection(jdbcUrl, jdbcUsername, jdbcPassword);

  System.out.println("conn"+Conn);

  for(int i=1;i<=10000;i++)

  {

  add(Conn,"testTitle"+i+"-"+System.currentTimeMillis());

  }

  } catch (SQLException e) {

  e.printStackTrace();

  }

  catch (InstantiationException e) {

  // TODO Auto-generated catch block

  e.printStackTrace();

  } catch (IllegalAccessException e) {

  // TODO Auto-generated catch block

  e.printStackTrace();

  } catch (ClassNotFoundException e) {

  // TODO Auto-generated catch block

  e.printStackTrace();

  }

  finally

  {

  try {

  Conn.close();

  } catch (SQLException e) {

  // TODO Auto-generated catch block

  e.printStackTrace();

  }

  }

  }

  public static void add(Connection conn,String title)

  {

  PreparedStatement pstmt = null;

  String insert_sql = "insert into t_test(title,createTime) values (?,?)";

  System.out.println("sql="+insert_sql);

  try {

  pstmt = conn.prepareStatement(insert_sql);

  pstmt.setString(1,title);

  pstmt.setLong(2,System.currentTimeMillis());

  int ret = pstmt.executeUpdate();

  } catch (SQLException e) {

  // TODO Auto-generated catch block

  e.printStackTrace();

  }

  finally{

  try {

  pstmt.close();

  } catch (SQLException e) {

  // TODO Auto-generated catch block

  e.printStackTrace();

  }

  }

  }

[1] [2] [3]

人气教程排行