java中Spring jdbc批量保存数据例子

数据list：list.add(bcHistory);

批量插入：

 代码如下 复制代码

try {
    jt.batchUpdate(
    "insert into b_chat_history (id,from_phone,from_user,to_phone,to_user,type,msg,url,thumb,length,timestamp) value (?,?,?,?,?,?,?,?,?,?,?)",
    new BatchPreparedStatementSetter() {
        public void setValues(PreparedStatement ps, int i)throws SQLException {
            ps.setString(1, UUID.randomUUID().toString());// ID的值
            ps.setString(2, list.get(i).getFrom_phone());
            ps.setString(3, list.get(i).getFrom_user());
            ps.setString(4, list.get(i).getTo_phone());
            ps.setString(5, list.get(i).getTo_user());
            ps.setString(6, list.get(i).getType());
            ps.setString(7, list.get(i).getMsg());
            ps.setString(8, list.get(i).getUrl());
                ps.setString(9, list.get(i).getThumb());
            ps.setInt(10,list.get(i).getLength());
            ps.setTimestamp(11, list.get(i).getTimestamp());
        }
 
public int getBatchSize() {
    return list.size();
    }
     });
} catch (Exception e2) {
    System.out.println("可能有数据异常，同步部分数据异常");
    e2.printStackTrace();
}

补充：

使用JDBCTemplate 进行基本的批量操作

这种方法是网上大多数采用的方法， 但是在实际应用中我感觉不太方便，这个方法能不能做成一个通用的接口呢？一直没有仔细研究过

  

 代码如下 复制代码

 

public class JdbcActorDao implements ActorDao {
  private JdbcTemplate jdbcTemplate;

  public void setDataSource(DataSource dataSource) {
    this.jdbcTemplate = new JdbcTemplate(dataSource);
  }

  public int[] batchUpdate(final List<Actor> actors) {
    int[] updateCounts = jdbcTemplate.batchUpdate("update t_actor set first_name = ?, " +
        "last_name = ? where id = ?",
      new BatchPreparedStatementSetter() {
        public void setValues(PreparedStatement ps, int i) throws SQLException {
            ps.setString(1, actors.get(i).getFirstName());
            ps.setString(2, actors.get(i).getLastName());
            ps.setLong(3, actors.get(i).getId().longValue());
          }

          public int getBatchSize() {
            return actors.size();
          }
        });
    return updateCounts;
  }

  // ... additional methods
}

二、 使用List集合形式的参数的批量操作

    如果使用List集合来进行批量操作，这种方法是比较合适的，spring jdbc core 包中提供了一个SqlParamterSource 对象，然后使用

 代码如下 复制代码

SqlParameterSourceUtils.createBatch
这个方法，把javabean的list  转化成array，spring会循环的进行取值；

public class JdbcActorDao implements ActorDao {
  private NamedParameterTemplate namedParameterJdbcTemplate;

  public void setDataSource(DataSource dataSource) {
    this.namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(dataSource);
  }

  public int[] batchUpdate(final List<Actor> actors) {
    SqlParameterSource[] batch = SqlParameterSourceUtils.createBatch(actors.toArray());
    int[] updateCounts = namedParameterJdbcTemplate.batchUpdate(
        "update t_actor set first_name = :firstName, last_name = :lastName where id = :id",
        batch);
    return updateCounts;
  }

  // ... additional methods
}

当然，你还可以使用类似的方法来进行批量操作，如下代码：（代码来自官方网站示例）

 代码如下 复制代码

public class JdbcActorDao implements ActorDao {

  private JdbcTemplate jdbcTemplate;

  public void setDataSource(DataSource dataSource) {
    this.jdbcTemplate = new JdbcTemplate(dataSource);
  }

  public int[] batchUpdate(final List<Actor> actors) {
    List<Object[]> batch = new ArrayList<Object[]>();
    for (Actor actor : actors) {
      Object[] values = new Object[] {
          actor.getFirstName(),
          actor.getLastName(),
          actor.getId()};
      batch.add(values);
    }
    int[] updateCounts = jdbcTemplate.batchUpdate(
        "update t_actor set first_name = ?, last_name = ? where id = ?",
        batch);
    return updateCounts;
  }

  // ... additional methods

}

三、使用多维数组进行批量操作

 代码如下 复制代码

public class JdbcActorDao implements ActorDao {

  private JdbcTemplate jdbcTemplate;

  public void setDataSource(DataSource dataSource) {
    this.jdbcTemplate = new JdbcTemplate(dataSource);
  }

  public int[][] batchUpdate(final Collection<Actor> actors) {
    int[][] updateCounts = jdbcTemplate.batchUpdate(
        "update t_actor set first_name = ?, last_name = ? where id = ?",
        actors,
        100,
        new ParameterizedPreparedStatementSetter<Actor>() {
          public void setValues(PreparedStatement ps, Actor argument) throws SQLException {
            ps.setString(1, argument.getFirstName());
            ps.setString(2, argument.getLastName());
            ps.setLong(3, argument.getId().longValue());
          }
        });
    return updateCounts;
  }

  // ... additional methods

}

上面的代码中，100表示一次批量操作的容量；

四、使用SimpleJdbcInsert 来进行简单的插入操作

    一般的，我们会使用update来进行插入操作，但是spring提供了更加简洁面向对象插入方法：

 代码如下 复制代码

public class JdbcActorDao implements ActorDao {

  private JdbcTemplate jdbcTemplate;
  private SimpleJdbcInsert insertActor;

  public void setDataSource(DataSource dataSource) {
    this.jdbcTemplate = new JdbcTemplate(dataSource);
    this.insertActor = new SimpleJdbcInsert(dataSource).withTableName("t_actor");
  }

  public void add(Actor actor) {
    Map<String, Object> parameters = new HashMap<String, Object>(3);
    parameters.put("id", actor.getId());
    parameters.put("first_name", actor.getFirstName());
    parameters.put("last_name", actor.getLastName());
    insertActor.execute(parameters);
  }

  // ... additional methods
}

如果我们需要得到插入的返回值呢？

 代码如下 复制代码

public class JdbcActorDao implements ActorDao {

  private JdbcTemplate jdbcTemplate;
  private SimpleJdbcInsert insertActor;

  public void setDataSource(DataSource dataSource) {
    this.jdbcTemplate = new JdbcTemplate(dataSource);
    this.insertActor = new SimpleJdbcInsert(dataSource)
        .withTableName("t_actor")
        .usingGeneratedKeyColumns("id");
  }

  public void add(Actor actor) {
    Map<String, Object> parameters = new HashMap<String, Object>(2);
    parameters.put("first_name", actor.getFirstName());
    parameters.put("last_name", actor.getLastName());
    Number newId = insertActor.executeAndReturnKey(parameters);
    actor.setId(newId.longValue());
  }

  // ... additional methods
}

注意了，此处使用了一个map作为参数，字段名作为键，所以我们可以根据传入的对象来自动去获取参数名及参数值的map，提示：可以利用反射原来处理：

示例代码：

 代码如下 复制代码
/**
   * 获取名称值的map
   * @param class1
   * @return
   */
  public static <M> SqlParameterSource getParamsMap(M bean) {
    if(bean==null)return null;
    MapSqlParameterSource parameters = new MapSqlParameterSource();
    Class<?> _class = bean.getClass();
    Table _table = _class.getAnnotation(Table.class);
    if(_table==null){
      logger.error(_class.getName()+" not find @Table value!please check it!");
      throw(new NotFoundTableAnnotaionException(_class.getName()+" not find @Table value!please check it!"));
    }
    String primaryKey=_table.primaryKey();
    Field[] allFields=getAllFields(_class);
    Object _primaryKeyValue="";
    for (Field field : allFields) {
      if(Modifier.isStatic(field.getModifiers()))continue;
      field.setAccessible(true);
      try {
        if(StringUtil.isEqual(primaryKey, field.getName())){
          _primaryKeyValue=field.get(bean);
          continue;
        }
        parameters.addValue(field.getName(), field.get(bean));
      } catch (IllegalArgumentException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      } catch (IllegalAccessException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }
    }
    return parameters;
  }

提出一个问题：如果我的字段名及数据库的字段名不一样咋办？

解决办法：

 代码如下 复制代码

public class JdbcActorDao implements ActorDao {

  private JdbcTemplate jdbcTemplate;
  private SimpleJdbcInsert insertActor;

  public void setDataSource(DataSource dataSource) {
    this.jdbcTemplate = new JdbcTemplate(dataSource);
    this.insertActor = new SimpleJdbcInsert(dataSource)
        .withTableName("t_actor")
        .usingColumns("first_name", "last_name")
        .usingGeneratedKeyColumns("id");
  }

  public void add(Actor actor) {
    Map<String, Object> parameters = new HashMap<String, Object>(2);
    parameters.put("first_name", actor.getFirstName());
    parameters.put("last_name", actor.getLastName());
    Number newId = insertActor.executeAndReturnKey(parameters);
    actor.setId(newId.longValue());
  }

  // ... additional methods

}
usingColumns("first_name", "last_name") //主要是这句话~

当然，也可以使用我们之前提到过的， SqlParameterSource parameters = new   MapSqlParameterSource()；而且可以进行链式操作。

 代码如下 复制代码

public class JdbcActorDao implements ActorDao {

  private JdbcTemplate jdbcTemplate;
  private SimpleJdbcInsert insertActor;

  public void setDataSource(DataSource dataSource) {
    this.jdbcTemplate = new JdbcTemplate(dataSource);
    this.insertActor = new SimpleJdbcInsert(dataSource)
        .withTableName("t_actor")
        .usingGeneratedKeyColumns("id");
  }

  public void add(Actor actor) {
    SqlParameterSource parameters = new MapSqlParameterSource()
        .addValue("first_name", actor.getFirstName())
        .addValue("last_name", actor.getLastName());
    Number newId = insertActor.executeAndReturnKey(parameters);
    actor.setId(newId.longValue());
  }

  // ... additional methods

}
时间： 2024-10-25 22:31:21

java中Spring jdbc批量保存数据例子的相关文章

java实现jdbc批量插入数据_java

首先介绍三种JDBC批量插入编程方法,进行比较,具体内容如下 JDBC批量插入主要用于数据导入和日志记录因为日志一般都是先写在文件下的等. 我用Mysql 5.1.5的JDBC driver 分别对三种比较常用的方法做了测试 方法一:使用PreparedStatement加批量的方法 try { Class.forName("com.mysql.jdbc.Driver"); conn = DriverManager.getConnection(o_url, userName, pass

使用JDBC在MySQL数据库中如何快速批量插入数据_Mysql

使用JDBC连接MySQL数据库进行数据插入的时候,特别是大批量数据连续插入(10W+),如何提高效率呢? 在JDBC编程接口中Statement 有两个方法特别值得注意: void addBatch() throws SQLException Adds a set of parameters to this PreparedStatement object's batch of commands. int[] executeBatch() throws SQLException Submits

Java中Spring获取bean方法小结_java

Spring是一个轻量级的控制反转(IoC)和面向切面(AOP)的容器框架,如何在程序中获取Spring配置的bean呢? Bean工厂(com.springframework.beans.factory.BeanFactory)是Spring框架最核心的接口,它提供了高级IoC的配置机制.BeanFactory使管理不同类型的Java对象成为可能,应用上下文(com.springframework.context.ApplicationContext)建立在BeanFactory基础之上,提供

java中如何实现批量上传图片，用什么组件？

问题描述 java中如何实现批量上传图片,需要用到什么组件?有具体代码就更好... 解决方案 解决方案二:JDK中冒似没有这样的组建给你用,自己写一个吧解决方案三:用struts就可以实现批量上传...介绍这个文章给你看一下..比较简单.http://lovexuwenhao.javaeye.com/blog/459064解决方案四:swfupload解决方案五:jspSmartUpload;common-fileUpload;structs和spring也可以实现不过这些都限于JAVAWEB开

java文件输入问题-java中把整数数组的数据输入到文件中的问题

问题描述 java中把整数数组的数据输入到文件中的问题 我是java新手,把整形数组输入到文件中去为什么不是数字,是这些问号? 解决方案 BufferedWriter 用这个写 解决方案二: 写入的编码格式不对,用UTF-8格式试试 解决方案三: 我是用BufferedWriter写的啊 解决方案四: write(int c)这个方法其实输出的是c对应的character,会进行类型的转换,你可以看下输出的源码.如果你要输出整型的话,建议你后面加个空字符串输出吧,换成: bw.write(a[i

java中的数组类型的数据能存储到栈空间吗

问题描述 java中的数组类型的数据能存储到栈空间吗 我们知道堆空间存储大数据,栈空间的数据先进后出, java中的数组类型的数据能存储到栈空间吗 解决方案 基本类型产生了一个值存放在栈中,变量的值就是栈的地址处的值. 引用类型则产生了一个对象,存放在内存堆中,同时将内存堆对象的指针地址(引用地址)存放在了栈中,变量的值实际是栈中的引用地址. 解决方案二: java中所有对象和数组都是在堆上分配内存的,,栈内存用来存放局部变量 解决方案三: java 存储不同类型数据Java实现登录.注册(使用

数据库-java中的JDBC问题（mysql连接问题）

问题描述 java中的JDBC问题(mysql连接问题) package myJDBC; import java.sql.*; public class Demo { public Connection Conn = null; public Connection getConnection() throws SQLException{ try { String Url = "jdbc:mysql://localhost:3306/test"; String Username = &q

想问一下Java中常用的配置文件保存格式。例如：我的程序中可以添加很多FTP的信息，我想问一下这些FTP信息最常用什么格式保存成文件？

问题描述 想问一下Java中常用的配置文件保存格式.例如:我的程序中可以添加很多FTP的信息,我想问一下这些FTP信息最常用什么格式保存成文件? 解决方案 解决方案二:我一般用xml文件来保存,用Properties这个类来读取解决方案三:一般用XML文件吧.我用XML保存,用DOM4J来读写

php 批量保存数据与批量更新数据

if ($insert && $insertsql) {php 批量保存数据与批量更新数据   $keystr = $valstr = $tmp = '';   foreach($insertsql as $key => $val) {    if ($val) {     $keystr .= $tmp.$key;     $valstr .= $tmp."'".addslashes($val)."'";     $tmp = ',';