时间：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]
