spring JDBCTemplate实现批量插入及返回id

1、插入一条记录返回刚插入记录的id

public int addBean(final Bean b){  final String strSql = "insert into buy(id,c,s,remark,line,cdatetime," +  "c_id,a_id,count,type) values(null,?,?,?,?,?,?,?,?,?)";  KeyHolder keyHolder = new GeneratedKeyHolder();  this.getJdbcTemplate().update(  new PreparedStatementCreator(){  public java.sql.PreparedStatement createPreparedStatement(Connection conn) throws SQLException{  int i = 0;  java.sql.PreparedStatement ps = conn.prepareStatement(strSql);   ps = conn.prepareStatement(strSql, Statement.RETURN_GENERATED_KEYS);  ps.setString(++i, b.getC());  ps.setInt(++i,b.getS() );  ps.setString(++i,b.getR() );  ps.setString(++i,b.getline() );  ps.setString(++i,b.getCDatetime() );  ps.setInt(++i,b.getCId() );  ps.setInt(++i,b.getAId());  ps.setInt(++i,b.getCount());  ps.setInt(++i,b.getType());  return ps;  }  },  keyHolder);  return keyHolder.getKey().intValue();  }

2、批量插入数据：

public void addBuyBean(List<BuyBean> list)   {   final List<BuyBean> tempBpplist = list;   String sql="insert into buy_bean(id,bid,pid,s,datetime,mark,count)" +  " values(null,?,?,?,?,?,?)";   this.getJdbcTemplate().batchUpdate(sql,new BatchPreparedStatementSetter() {  @Override  public int getBatchSize() {  return tempBpplist.size();   }  @Override  public void setValues(PreparedStatement ps, int i)  throws SQLException {  ps.setInt(1, tempBpplist.get(i).getBId());   ps.setInt(2, tempBpplist.get(i).getPId());   ps.setInt(3, tempBpplist.get(i).getS());   ps.setString(4, tempBpplist.get(i).getDatetime());   ps.setString(5, tempBpplist.get(i).getMark());                   ps.setInt(6, tempBpplist.get(i).getCount());  }   });   }

public static void batchInsert() throws ClassNotFoundException, SQLException{long start = System.currentTimeMillis();Class.forName("com.mysql.jdbc.Driver");Connection connection = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/kxh?useServerPrepStmts=false&rewriteBatchedStatements=true","root", "root");connection.setAutoCommit(false);PreparedStatement cmd = connection.prepareStatement("insert into test1 values(?,?)");for (int i = 0; i < 1000000; i++) {//100万条数据cmd.setInt(1, i);cmd.setString(2, "test");cmd.addBatch();if(i%1000==0){cmd.executeBatch();}}cmd.executeBatch();connection.commit();cmd.close();connection.close();long end = System.currentTimeMillis();System.out.println("批量插入需要时间:"+(end - start)); //批量插入需要时间:24675}

3、批量插入并返回批量id（由于JDBCTemplate不支持批量插入后返回批量id，所以此处使用jdbc原生的方法实现此功能）

public List<Integer> addProduct(List<ProductBean> expList) throws SQLException {  final List<ProductBean> tempexpList = expList;  String sql="insert into product(id,s_id,status,datetime,"  + " count,o_id,reasons"  + " values(null,?,?,?,?,?,?)";  DbOperation dbOp = new DbOperation();  dbOp.init();  Connection con = dbOp.getConn();  con.setAutoCommit(false);  PreparedStatement pstmt = con.prepareStatement(sql, PreparedStatement.RETURN_GENERATED_KEYS);  for (ProductBean n : tempexpList) {  pstmt.setInt(1,n.getSId());     pstmt.setInt(2,n.getStatus());   pstmt.setString(3,n.getDatetime());   pstmt.setInt(4,n.getCount());  pstmt.setInt(5,n.getOId());  pstmt.setInt(6,n.getReasons());  pstmt.addBatch();  }  pstmt.executeBatch();   con.commit();     ResultSet rs = pstmt.getGeneratedKeys(); //获取结果  List<Integer> list = new ArrayList<Integer>();   while(rs.next()) {  list.add(rs.getInt(1));//取得ID  }  con.close();  pstmt.close();  rs.close();  return list;  }

spring JDBCTemplate实现批量插入及返回id相关推荐

Spring利用JDBCTemplate实现批量插入和返回id
1.先介绍一下java.sql.Connection接口提供的三个在执行插入语句后可取的自动生成的主键的方法: //第一个是 PreparedStatement prepareStatement(St ...
mybatis的插入与批量插入的返回ID的原理
文章目录背景底层调用方法单个对象插入直接保存实体的对象作为参数传入(给伪代码示例) 多个对象,实体对象作为其中一个对象传入列表批量插入直接保存实体的对象作为参数传入(给伪代码示例) 多个对 ...
Mybatis批量插入，返回主键ID不成功，巨坑
一.场景说明批量插入,返回主键ID报错 org.mybatis.spring.MyBatisSystemException: nested exception is org.apache.ibati ...
继解决Spring data jpa 批量插入重写saveAll()后遇到符号不兼容问题
问题描述问题: 之前为解决Spring data jpa 批量插入/删除(saveAll()/deleteAll())速度慢的问题重写了saveAll()方法,用自定义拼接sql的方法组装sql, ...
mysql批量插入没有返回主键id
在大批量新增数据的时候往往会采用批量插入来提高效率,但是经常遇到没有返回主键的情况. 一般会有以下几种可能: 1.升级Mybatis版本到3.3.1.官方在这个版本中加入了批量新增返回主键id的功能 ...
解决Spring data jpa 批量插入/删除(saveAll()/deleteAll())速度慢的问题
问题描述: 项目中使用到了Spring data jpa技术,调用 JpaRepository.saveAll()/deleteAll()方法对list中的数据进行插入/删除时,发现速度特别慢,数据量 ...
oracle批量插入并且返回自增主键_mybatis + （oracle）实现主键自增 + 插入数据并返回主键...
一.实现主键自增在oracle数据库中,主键并没有办法自动增长,无法使用insert对应的useGeneratedKeys和keyProperty属性自动返回增加的主键. 要实现自增需要修改 ID列 ...
oracle批量插入并且返回自增主键_oracle 自增主键实现批量更新和增加sql
增加: 方案1 INSERT INTO WF_TASKTEMP_DEALSTAFF (DEAL_ID, TEMP_ID, STAFF_ID,DEAL_TYPE, STATUS) SELECT WF_T ...
Mybatis Mysql 批量插入返回id
1. 目标: 使用Mybatis 批量插入数据返回自增的id 2. 具体实现注意: MyBatis版本3.3.1或者以上 <insert id="save" useGene ...

spring JDBCTemplate实现批量插入及返回id

spring JDBCTemplate实现批量插入及返回id相关推荐

最新文章

热门文章