赞
踩
最近遇到一个需求,每隔15分钟汇总一次数据推送到第三方,由于数据量较大,所以采取的方式是每天汇总一次档案数据, 每隔15分钟用档案数据关联实时数据汇总推送。这种情况下容易出现档案数据还未汇总完成时就已经到了去关联实时数据表推送的时候了,毫无意外推送的数据会为空,为了避免这种情况,采用事务进行控制,先将档案数据汇总到临时表,然后从临时表写数据到正式表,在同一个事务中处理删除数据和插入数据,就不会出现档案数据为空的时候了。
- public void saveData(String dbname)
- {
- StringBuffer str=new StringBuffer();
- String tableNameTmp="stu_info_tmp";
- String tableNameEnd="stu_info";
-
- String driver ="oracle.jdbc.driver.OracleDriver";
- String jdbcUrl="jdbc:oracle:thin:@127.0.0.1:1521:orcl";
- PreparedStatement psi = null;
- Connection conn=null;
-
- try {
- Class.forName(driver); //装载一个驱动
- conn = DriverManager.getConnection(jdbcUrl,"stu","stu") ; //建立一个连接
- conn.setAutoCommit(false) ; // 事物要进行整体提交,故我们必须关闭自动提交
-
- String sqlStr=" delete from "+tableNameEnd+" ";
- psi=conn.prepareStatement(sqlStr);
- psi.executeUpdate();
-
- str.append("insert into "+tableNameEnd+" ");
- str.append(" (id, name, class, subject, grade) ");
- str.append("select id, name, class, subject, grade from "+tableNameTmp+" ");
- psi=conn.prepareStatement(str.toString());
- int num=psi.executeUpdate();
-
- conn.commit();
- psi.close();
- conn.close();
-
- } catch (SQLException ex) {
- if (conn!=null) {
- try {
- conn.rollback();
- } catch (Exception e) {
- }
- }
- ex.printStackTrace();
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
注意:truncate table 是不走事务的,如果使用truncate table删除表数据,那么在事务未提交之前,数据库就已经执行了删除操作!!
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。