java 高效批量插入 sqlserver 數據庫


@Test
	public void clockingIn_Img() throws Exception{
		DbJdbc idb = DbMaster.getIDB("JXT");
		List<Jxt_pay_info> pays=idb.getBeanList("select top 100000 * from jxt_pay_info", Jxt_pay_info.class);
		//可以用idb進行測試了。。。。
		//大數據插入方式
		String sql = "insert into Jxt_pay_info1 (id ,card_id ,pay_money ,pay_time ,pay_date ,pay_address ,school_id ,source_id ,lasttime ,card_sn,paid_after) values (?,?,?,?,?,?,?,?,?,?,?)";
		Connection connection = idb.DbConnection;
		PreparedStatement ps = connection.prepareStatement(sql);
		final int batchSize = 1000;
		int count = 0;
		long start=System.currentTimeMillis();
		System.err.println("Start");
		for (Jxt_pay_info pay: pays) {
		    ps.setInt(1, pay.getId());
		    ps.setString(2, pay.getCard_id());
		    ps.setFloat(3, pay.getPay_money());
		    ps.setString(4, pay.getPay_time());
		    ps.setString(5, pay.getPay_date());
		    ps.setString(6, pay.getPay_address());
		    ps.setString(7, pay.getSchool_id());
		    ps.setString(8, pay.getSource_id());
		    ps.setString(9, pay.getLasttime());
		    ps.setInt(10, pay.getCard_sn());
		    ps.setString(11, pay.getPaid_after());
		    ps.addBatch();
		    
		}
		ps.executeBatch(); // insert remaining records
		ps.close();
		connection.close();
		DbMaster.closeIDB(idb);
		long end=System.currentTimeMillis();
		System.err.println("End"+(end-start));
		}
}

  

插入1000條:347毫秒

插入1W條:4086毫秒

插入10W條:47953毫秒

同理,批量更新也可以用此方法,只不過沒有插入的快,

更新1000條:90秒

更新100條:9秒


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM