Java 批量插入

  1. JdbcTemplate
public int insertContractAch(List list) throws DataAccessException {  
    final List temList = list;  
    String sql = "insert into contract_ach_t " +  
            " values(?,to_date(?,‘yyyy-mm-dd‘),?,?) ";  
    try{  
        int[] ii = this.getJdbcTemplate().batchUpdate(sql, new MyBatchPreparedStatementSetter(temList));  
        return ii.length;  
    }catch (org.springframework.dao.DataAccessException e) {  
        e.printStackTrace();  
        throw new DataAccessException(e.getMessage());  
    }  
}  
  
private class MyBatchPreparedStatementSetter implements BatchPreparedStatementSetter{  
    final List temList;  
      
    public MyBatchPreparedStatementSetter(List list){  
        temList = list;  
    }  
    public int getBatchSize() {  
        return temList.size();  
    }  
  
    public void setValues(PreparedStatement ps, int i)  
            throws SQLException {  
        ContractAchVO contractAchVO = (ContractAchVO)temList.get(i);  
        ps.setString(1, contractAchVO.getContractCode());  
        ps.setString(2, contractAchVO.getCreateDate());  
        ps.setString(3, contractAchVO.getEmployeeId());  
        ps.setString(4, contractAchVO.getPercent());  
    }  
}

2.JPA data,Hibernate的思路

 public  void batchSave(String sql,int batchSize,List<Object[]> list) throws SQLException{
		   if (CollectionUtils.isEmpty(list)){
			   return;
		   }
		  
		   SessionImplementor session =em.unwrap(SessionImplementor.class);
	   	   Connection connection =   session.connection();
		   PreparedStatement st = connection.prepareStatement(sql);

		   for(int i=0;i<list.size();i++){ 
			   Object[] params = list.get(i);
			   if (ArrayUtils.isEmpty(params)){
				   continue;
			   }
			   
			   for (int j=1;j<=params.length;j++){
				   if(params[j-1] instanceof String)
					   st.setString(j,String.valueOf(params[j-1]));
				   else if(params[j-1] instanceof Date)
					   st.setDate(j, new java.sql.Date( ((Date) params[j-1]).getTime()));
				   else if(params[j-1] instanceof BigDecimal)
					   st.setBigDecimal(j, (BigDecimal) params[j-1]);
				   else if(params[j-1] ==null)
					   st.setNull(j, java.sql.Types.VARCHAR);
				   else 
					   st.setString(j, String.valueOf(params[j-1]));
			   }
			   st.addBatch();
			   if(i > 0 && i%batchSize==0){
				   st.executeBatch();
				   st.clearBatch();
			   }
		   }
		  st.executeBatch();
	   }
时间: 2025-01-08 10:31:19

Java 批量插入的相关文章

java 批量插入10万条数据

for (int i = 0; i < 100000; i++) { dbHelper.insert("INSERT aaa(name) Values ('1')"); } 运行时间==780450ms conn = getConn(); // JAVA默认为TRUE,我们自己处理需要设置为FALSE,并且修改为手动提交,才可以调用rollback()函数 conn.setAutoCommit(false); st = conn.createStatement(); long s

java批量插入或更新的问题

在批量插入或者更新中,setXXX的时候字段类型必须一致.例如:在普通sql中 pstmt8.setBigDecimal(j ,xxx);可以写成pstmt8.setString(j,xxx.toString()); 但在批量插入时必须写成pstmt8.setBigDecimal(j,xxx);否则批处理会报提交中至少有一条不成功的问题.折腾一下午,终于搞好了.顺便记下来,方便参考.

Java批量插入、更新数据

Java的批量添加数据,多个字段同时添加多条数据,我不知道你遇到过没有.今天我们就以一个具体的实例来说一下Java的批量添加数据,面向的是Oracle数据库. 前台页面: <span style="font-size:14px;"><body class="main_body" scroll="no"> <div class="employee_gun_dong"> <form nam

java批量插入数据进数据库中

方式1: for循环,每一次进行一次插入数据. 方式2: jdbc的preparedStatement的batch操作 PreparedStatement.addBatch(); ...... PreparedStatement.executeBatch(); 一次最多不要超过50条:1.因为当你插入的时候 数据库已经锁定,然而如果你一次性插入太多会造成其他业务的等待.2.会造成内存的溢出 方式2的本质是:insert into table (a,b,c,d) values(av,bv,cv.d

Java 批量插入数据(Oracle)

//批量添加20000条数据用时8秒. try { String url = "jdbc:oracle:thin:@IP:1521:orcl"; // orcl为数据库的SID String user = "oracle"; String password = "oracle"; StringBuffer sql = new StringBuffer(); sql.append("insert into ex_log (EX_LOG_I

java 批量插入数据 到数据库

//大数据插入方式 String sql = "insert into T_DR_RF(CUSTOMER_CODE,RFID_TAG) values(?,?)"; Connection connection =db.getConnection(); connection.setAutoCommit(false); PreparedStatement ps = connection.prepareStatement(sql); for (Map<String, Object>

java mysql大数据量批量插入与流式读取分析

总结下这周帮助客户解决报表生成操作的mysql 驱动的使用上的一些问题,与解决方案.由于生成报表逻辑要从数据库读取大量数据并在内存中加工处理后在 生成大量的汇总数据然后写入到数据库.基本流程是 读取->处理->写入. 1 读取操作开始遇到的问题是当sql查询数据量比较大时候基本读不出来.开始以为是server端处理太慢.但是在控制台是可以立即返回数据的.于是在应用 这边抓包,发现也是发送sql后立即有数据返回.但是执行ResultSet的next方法确实阻塞的.查文档翻代码原来mysql驱动默

Java通过Mybatis实现批量插入数据到Oracle中

最近项目中遇到一个问题:导入数据到后台并将数据插入到数据库中,导入的数据量有上万条数据,考虑采用批量插入数据的方式: 结合网上资料,写了个小demo,文章末尾附上demo下载地址 1.新建项目:项目目录结构如下图所示,添加相应的jar包 2.新建数据库表:ACCOUNT_INFO 1 CREATE TABLE ACCOUNT_INFO ( 2 "ID" NUMBER(12) NOT NULL , 3 "USERNAME" VARCHAR2(64 BYTE) NULL

Java MySql 批量插入数据库addBatch

//addBatch批量插入数据库 public static void insertCommentToMySql(Set<String> commentList) { Iterator<String> it = commentList.iterator(); Statement st=null; try { st = DBConnection.getConnection(dbName,dbUser,dbPwd).createStatement(); } catch (SQLExc