ibatis批量插入-iterate标签应用

      项目开发中在很多地方可能会遇到同时插入多条记录到数据库的业务场景，如果业务级别循环单条插入数据会不断建立连接且有多个事务，这个时候如果业务的事务执行频率相当较高的话（高并发），对数据库的性能影响是比较大的；为了提高效率，批量操作会是不错的选择，一次批量操作只需要建立一次连接且一个事务，能很大程度上提高数据库的效率。

      批量插入操作的sql语句原型如下：

insert   into
    wsjiang_test(col1, col2, col3)
values
    (col1_v, col2_v, col3_v),
    (col1_v, col2_v, col3_v),
     ...

      这里我们以ibatis为例，进行应用说明！

 

     一、 ibatis iterate标签配置说明

< iterate
    property =""  /*可选,
        从传入的参数集合中使用属性名去获取值,
        这个必须是一个List类型,
        否则会出现OutofRangeException,
        通常是参数使用java.util.Map时才使用,
        如果传入的参数本身是一个java.util.List, 不能只用这个属性.
        不知道为啥官网: http://ibatis.apache.org/docs/dotnet/datamapper/ch03s09.html#id386679
        说这个属性是必须的, 但是测试的时候是可以不设置这个属性的, 还望那位大虾知道, 讲解一下.
        */
    conjunction =""  /*可选,
        iterate可以看作是一个循环,
        这个属性指定每一次循环结束后添加的符号,
         比如使每次循环是OR的, 则设置这个属性为OR*/
    open =""  /*可选, 循环的开始符号*/
    close =""  /*可选, 循环的结束符号*/
    prepend =""  /*可选, 加在open指定的符号之前的符号*/
> </ iterate >

 

       二、 ibatis iterate标签使用示例

              1、批量查询

< select  id ="iterate_query"  parameterClass ="java.util.List" >
    <![CDATA[
        selelct * from wsjiang_test where id=1
    ]]>
    < iterate  prepend ="prepend"  conjunction ="conn"  open ="open"  colse ="close" >
        /*使用java.util.List作为参数不能设置property属性*/
        <![CDATA[
            #v[]#
        ]]> /*这里的"[]"是必须的, 要不然ibatis会把v直接解析为一个String*/
    </ iterate >
</ select >

             如果传入一个List为[123,234,345], 上面的配置将得到一个sql语句:

                   select * from wsjiang_test where id=1 prepend open 123 conn 234 conn 345 close

 

            2、批量插入

               A、不使用open/close属性

< insert  id ="  iterate_insert1  "  parameterClass ="java.util.List" >
    <![CDATA[
        insert into wsjinag_test(  col1 ,   col2 ,   col3 ) values
    ]]>
    < iterate  conjunction ="," >
        <![CDATA[
            (#test[].  col1 #, #  test  [].  col2 #, #  test  [].  col3 #)
        ]]>
    </ iterate >
</ insert >

              上面的配置将得到一个sql语句:

                   insert  into wsjiang_test( col1, col2, col3 ) values  (?, ?, ?) , (?, ?, ?) , (?, ?, ?) 

 

              B、使用open/close属性

< insert  id ="betchAddNewActiveCode"  parameterClass ="java.util.List" >
   <![CDATA[
        insert into wsjinag_test(  col1 ,   col2 ,   col3 ) values
    ]]>
    < iterate  conjunction =","  open ="("  close =")" >
        <![CDATA[
            /*这里不加"("和")"*/
              #test[].  col1 #, #  test  [].  col2 #, #  test  [].  col3 #
        ]]>
    </ iterate >
</ insert >

             上面的配置将得到一个sql语句:

                  insert  into wsjiang_test( col1, col2, col3 ) values  (?, ?, ?    ,     ?, ?, ?     ,     ?, ?, ?)

 

         这两种使用方式区别是相当大的. conjunction, open 和close这几个属性需小心使用，将其区分开.

 

    三、单条插入返回新增记录主键

          通常情况，ibatis的insert方法需要返回新增记录的主键,但并非任何表的insert操作都会返回主键（这是一个陷阱）;要返回这个新增记录的主键，前提是表的主键是自增型的，或者是Sequence的;且必须启用ibatis的selectKey 标签; 否则获取新增记录主键的值为0或者null。

         ibatis的配置：

< insert  id ="  iterate_insert1  "  parameterClass ="Object" >
    <![CDATA[
        insert into wsjinag_test(  col1 ,   col2 ,   col3 )
        values    (#  col1 #, #  col2 #, #  col3 #)
    ]]>
    < selectKey   keyProperty ="id"  resultClass=  "Long"  >
        <![CDATA[
            SELECT LAST_INSERT_ID() AS value
        ]]>
    </  selectKey  >
</ insert >

 

  四、 插入返回 新增记录数

      在第三节中已经讲清楚通过ibatis的insert方法只能得到新增记录的ID; 如果对于无需知道新增记录ID，只需要知道有没有插入成功的业务场景时，特别是对于批量插入，配置的selectKey 可能会有问题时，一次插入多条，拿不到新增的ID，这时我们就只能返回插入成功的记录数来区分是否新增成功！但是insert方法是不会返回记录数；于是我们可以使用ibatis的update方法来调用没有配置 selectKey 标签的insert语句，这样就能返回影响（插入）的记录数了！

 

     某些地方理解不是很深刻，还请不吝赐教！

 

评论

6 楼 wsjiang 2014-11-07  

神幻领域.神丿隐 写道

原来是这样啊.

是的，你可以测试下！

5 楼 神幻领域.神丿隐 2014-10-31  

wsjiang 写道

神幻领域.神丿隐 写道

< insert  id ="betchAddNewActiveCode"  parameterClass ="java.util.List" >   
   <![CDATA[ 
        insert into wsjinag_test( col1 , col2 , col3 ) values 
    ]]>
    < iterate  conjunction =","  open ="("  close =")" >  
        <![CDATA[ 
            /*这里不加"("和")"*/ 
            #test[]. col1 #, # test []. col2 #, # test []. col3 #
        ]]>  
    </ iterate >  
</ insert >


这里面的 #test[]   是那来的？？？ 不懂啊。。。

这里的test[]就是在dao层调用SqlMapClient时传入的需要插入数据库的对象数组

原来是这样啊

4 楼 神幻领域.神丿隐 2014-10-31  

原来是这样啊.

3 楼 wsjiang 2014-10-23  

神幻领域.神丿隐 写道

< insert  id ="betchAddNewActiveCode"  parameterClass ="java.util.List" >   
   <![CDATA[ 
        insert into wsjinag_test( col1 , col2 , col3 ) values 
    ]]>
    < iterate  conjunction =","  open ="("  close =")" >  
        <![CDATA[ 
            /*这里不加"("和")"*/ 
            #test[]. col1 #, # test []. col2 #, # test []. col3 #
        ]]>  
    </ iterate >  
</ insert >


这里面的 #test[]   是那来的？？？ 不懂啊。。。

这里的test[]就是在dao层调用SqlMapClient时传入的需要插入数据库的对象数组

2 楼 神幻领域.神丿隐 2014-10-08  

< insert  id ="betchAddNewActiveCode"  parameterClass ="java.util.List" >   
   <![CDATA[ 
        insert into wsjinag_test( col1 , col2 , col3 ) values 
    ]]>
    < iterate  conjunction =","  open ="("  close =")" >  
        <![CDATA[ 
            /*这里不加"("和")"*/ 
            #test[]. col1 #, # test []. col2 #, # test []. col3 #
        ]]>  
    </ iterate >  
</ insert >


这里面的 #test[]   是那来的？？？ 不懂啊。。。

1 楼 hechiheng 2013-04-25  

insert  into   
    wsjiang_test(col1, col2, col3)  
values   
    (col1_v, col2_v, col3_v),  
    (col1_v, col2_v, col3_v), 
     ...

sql的这种写法，在oracle中不支持吧？