java实现批量插入

/**
* 批量插入
*
* @param tableName
* @param datas
* @return
*/
public boolean insertBatch(String tableName, List<Map<String, Object>> datas) {
PreparedStatement prepared = null;
Connection connect = new Mysql().getConnection();
try {
connect.setAutoCommit(false); // 设置手动提交
StringBuffer fieldString = new StringBuffer();
StringBuffer paraNo = new StringBuffer(); // 预处理字段“？”
List values = new ArrayList();
boolean flag = true;
for (int i = 0; i < datas.size(); i++) {
for (Object element : datas.get(i).keySet()) {
if (flag) {
fieldString.append("," + element);
paraNo.append(",?");
}
values.add(datas.get(i).get(element));
}
flag = false;

         if (prepared == null) {// 所有参数组成的数组String queryString = "INSERT INTO " + tableName + " (" + fieldString.toString().substring(1)+ ") VALUES (" + paraNo.substring(1) + ")";prepared = connect.prepareStatement(queryString);}// 设置对应参数值for (int j = 0; j < datas.get(i).size(); j++) {prepared.setObject(j + 1, values.get(j));}prepared.addBatch();if (i % 10000 == 0) {prepared.executeBatch();connect.commit();}values.clear();}prepared.executeBatch();connect.commit();return true;} catch (Exception e) {e.printStackTrace();throw new RuntimeException(e.getMessage());} finally {try {if (connect != null) {connect.close();}if (prepared != null) {prepared.close();}} catch (SQLException e) {e.printStackTrace();}}
}

import java.io.IOException;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;

/**

单数据库模式单数据库模式需要扩展多数据库或使用主从数据库在此处进行扩展指定连接数据库同时修改数据库配置

*/
public class Mysql {
// 连接数据库的参数
private static String url = null;
private static String username = null;
private static String driver = null;
private static String passwd = null;

private static Properties propertie = null;
private static InputStream configStream = null;
/*** 加载驱动，只需要一次，用静态代码块 单数据库模式，需要扩展多数据库或使用主从数据库在此处进行扩展*/
static {try {propertie = new Properties();configStream = Mysql.class.getClassLoader().getResourceAsStream("mysql.properties");propertie.load(configStream);url = propertie.getProperty("url");driver = propertie.getProperty("driver");username = propertie.getProperty("username");passwd = propertie.getProperty("password");Class.forName(driver);} catch (Exception e) {e.printStackTrace();} finally {try {configStream.close();} catch (IOException e) {e.printStackTrace();}configStream = null;}}/*** 获取数据库链接* * @return*/
public Connection getConnection() {Connection con = null;try {con = DriverManager.getConnection(url, username, passwd);} catch (Exception e) {e.printStackTrace();}return con;
}

}

//调用方法

List<Map<String, Object>> datas = new ArrayList<>();
Map<String,Object> user = new HashMap<>();
user.put(字段,对应值);
datas.add(user);
insertBatch(表名, datas);

java实现批量插入相关推荐

【java】批量插入数据库数据
在项目中往往需要一次向数据库中插入多条数据,如果使用for循环的方式插入,效率慢且资源消耗高接下来看看如何批量将数据写入数据库中一.Dao ReportSampleDao.java文件 impor ...
java多线程批量插入实战
批量写入的难点是困扰很多程序员的地方,在这里提供一下自己的思路拆大为小,把一个大集合拆分成小集合,可以通过工具类实现.list拆分工具类开启线程池,针对集合的大小进行调参,对小集合进行批量更新操作 ...
java实现批量插入数据
//业务背景:在实现一次性插入上万条数据会报错误,所有要批量插入数据 public void addCouponCode(List<CouponCodeEntity> lists){if ...
java 高效批量插入 sqlserver 数据库
@Testpublic void clockingIn_Img() throws Exception{DbJdbc idb = DbMaster.getIDB("JXT");Lis ...
java mvc 批量插入_请教mysql spring mvc +mybatis中批量插入的问题?
dao实现文件中函数: @Override public int insertContentList( List list) { Map params = createMap(); params.pu ...
java sqls.add(),java 高效批量插入 sqlserver 数据库
PHP读取Excel数据写入数据库(包含图片和文字) public function test(){ $exts = 'xlsx'; //导入PHPExcel类库,因为PHPExcel没有用命名空间, ...
Oracle model iterate,ibatis组合Oracle的iterate insert批量插入
ibatis批量插入oracle数据库 INSERT INTO SYS_ROLE_MENU( ROLE_ID, MENU_ID ) SELECT A.* FROM ( SELECT #list[].k ...
java 原生sql批量插入,Java对象集合转MySQL批量插入语句
Mybatis的批量插入确实很好用,但是当数据量特别大的时候可能一次批量插入2000条数据就死翘翘了.怎么办呢?当然是原生sql是最快的啦,10000条数据秒入无压力.下面是将对象集合拼接成批量插入M ...
Java mybatis实现mysql批量插入
记录下来方便自己,同时也希望能对比较迷惑的小盆友有所帮助 1.把批量插入的数据生成一个List集合 2.用java控制一次插入的条数和集合 // 每次插入10条int len = count, inc ...

java实现批量插入

java实现批量插入相关推荐

最新文章

热门文章