zoukankan      html  css  js  c++  java
  • JDBC大批量写入数据到SQLServer2000,记录数大于10000

    		SpObserver.putSp("sessionFactory1"); 
    		SimpleDateFormat fomat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    		Session s=null;
    		s=daoSupport.getSessionFactory().openSession();
    		Connection con=s.connection();
    		Statement stmt = null;
    		try {
    			stmt=con.createStatement();
    			con.setAutoCommit(false);
    			Iterator it=list.iterator();
    			int iCount = 1;
    			long start = System.currentTimeMillis();
    			while(it.hasNext()){
    				TResultWaterZId t = (TResultWaterZId)it.next();
    				StringBuffer sb = new StringBuffer();
    				sb.append("insert into T_result_water_z(schemeid,stcd,z,tm) values('");
    				sb.append(t.getSchemeid()).append("','").append(t.getStcd()).append("','");
    				sb.append(t.getZ()).append("','").append(fomat.format(t.getTm())).append("')");
    				stmt.addBatch(sb.toString());
    				if(iCount % 1000 == 0){
    					stmt.executeBatch();
    					stmt.clearBatch();
    				}
    				iCount++;
    			}
    			stmt.executeBatch();
    			stmt.clearBatch();
    			con.commit();
    			long end = System.currentTimeMillis();
    			System.out.println("addTResultWaterZId used time:"+(end-start));
    			stmt.close();
    			con.close();
    		} catch (SQLException e) {
    			try {
    				con.rollback();
    			} catch (SQLException e1) {
    				e1.printStackTrace();
    			}
    			e.printStackTrace();
    		}finally{
    			try {
    				stmt.close();
    				con.close();
    			} catch (SQLException e) {
    				e.printStackTrace();
    			}
    		}
    
  • 相关阅读:
    ajax提交转码解码
    关于idea开发工具常用的快捷键
    oracle 查询某个时间段数据
    hibernate : object references an unsaved transient instance 问题
    log4j日志
    JS关键字 import
    代码正常,junit却报错原因及解决方法
    hdu 5868 Polya计数
    hdu 5893 (树链剖分+合并)
    hdu 5895 广义Fibonacci数列
  • 原文地址:https://www.cnblogs.com/qumao5736/p/1618547.html
Copyright © 2011-2022 走看看