mybatis学习之路mysql批量新增数据的方法

<!-- 跟普通的insert没有什么不同的地方 ，主要用来跟下面的批量插入做对比。-->

  <insert id= "insert" parametertype= "com.soft.mybatis.model.customer" >

    <!-- 跟自增主键方式相比，这里的不同之处只有两点

          1 insert语句需要写id字段了，并且 values里面也不能省略

          2 selectkey 的order属性需要写成before 因为这样才能将生成的uuid主键放入到model中，

          这样后面的insert的values里面的id才不会获取为空

       跟自增主键相比就这点区别，当然了这里的获取主键id的方式为 select uuid()

       当然也可以另写别生成函数。-->

    <selectkey keyproperty= "id" order= "before" resulttype= "string" >

      select uuid()

    </selectkey>

    insert into t_customer (id,c_name,c_sex,c_cerono,c_cerotype,c_age)

    values (#{id},#{name},#{sex},#{cerono},#{cerotype},#{age})

  </insert>

  <!-- 批量插入， -->

  <insert id= "batchinsert" parametertype= "java.util.map" >

    <!-- 这里只做演示用，真正项目中不会写的这么简单。 -->

    insert into

     t_customer (id,c_name,c_sex,c_cerono,c_cerotype,c_age)

    values

    <!-- foreach mybatis循环集合用的

       collection= "list" 接收的map集合中的key 用以循环key对应的属性

         separator= "," 表示每次循环完毕，在sql后面放一个逗号

         item= "cus" 每次循环的实体对象 名称随意-->

    <foreach collection= "list" separator= "," item= "cus" >

      <!-- 组装values对象，因为这张表的主键为非自增主键，所以这里 (select uuid()) 用于生成id的值-->

      ((select uuid()),#{cus.name},#{cus.sex},#{cus.cerono},#{cus.cerotype},#{cus.age})

    </foreach>

  </insert>

package com.soft.mybatis.model;

/**

  * created by xuweiwei on 2017/9/10.

  */

public class customer {

   private string id;

   private string name;

   private integer age;

   private integer sex;

   private string cerono;

   private integer cerotype;

   public string getid() {

     return id;

   }

   public void setid(string id) {

     this .id = id;

   }

   public string getname() {

     return name;

   }

   public void setname(string name) {

     this .name = name;

   }

   public integer getage() {

     return age;

   }

   public void setage(integer age) {

     this .age = age;

   }

   public integer getsex() {

     return sex;

   }

   public void setsex(integer sex) {

     this .sex = sex;

   }

   public string getcerono() {

     return cerono;

   }

   public void setcerono(string cerono) {

     this .cerono = cerono;

   }

   public integer getcerotype() {

     return cerotype;

   }

   public void setcerotype(integer cerotype) {

     this .cerotype = cerotype;

   }

   @override

   public string tostring() {

     return "customer{" +

         "id='" + id + '\ '' +

         ", name='" + name + '\ '' +

         ", age=" + age +

         ", sex=" + sex +

         ", cerono='" + cerono + '\ '' +

         ", cerotype='" + cerotype + '\ '' +

         '}' ;

   }

}

int add(customer customer);

int batchinsert(map<string,object> param);

/**

   * 新增数据

   * @param customer

   * @return

   */

  public int add(customer customer) {

    return insert( "customer.insert" , customer);

  }

  /**

   * 批量插入数据

   * @param param

   * @return

   */

  public int batchinsert(map<string,object> param) {

    return insert( "customer.batchinsert" , param);

  }

  /**

   * 公共部分

   * @param statementid

   * @param obj

   * @return

   */

  private int insert(string statementid, object obj){

    sqlsession sqlsession = null ;

    try {

      sqlsession = sqlsessionutil.getsqlsession();

      int key = sqlsession.insert(statementid, obj);

      // commit

      sqlsession.commit();

      return key;

    } catch (exception e) {

      sqlsession.rollback();

      e.printstacktrace();

    } finally {

      sqlsessionutil.closesession(sqlsession);

    }

    return 0 ;

  }

@test

  public void add() throws exception {

    long start = system.currenttimemillis();

    for ( int i= 0 ;i< 1000 ;i++){

      customer customer = new customer();

      customer.setname( "普通一条条插入 " + i);

      customer.setage( 15 );

      customer.setcerono( "000000000000" + i);

      customer.setcerotype( 2 );

      customer.setsex( 1 );

      int result = customerdao.add(customer);

    }

    system.out.println( "耗时 ： " +(system.currenttimemillis() - start));

  }

  @test

  public void batchinsert() throws exception {

    map<string,object> param = new hashmap<string,object>();

    list<customer> list = new arraylist<customer>();

    for ( int i= 0 ;i< 1000 ;i++){

      customer customer = new customer();

      customer.setname( "批量插入" + i);

      customer.setage( 15 );

      customer.setcerono( "111111111111" +i);

      customer.setcerotype( 2 );

      customer.setsex( 1 );

      list.add(customer);

    }

    param.put( "list" ,list);

    long start = system.currenttimemillis();

    int result = customerdao.batchinsert(param);

    system.out.println( "耗时 ： " +(system.currenttimemillis() - start));

  }