mybatis批量update(mysql)

女爷i 2022-06-08 04:49 215阅读 0赞

转自：http://www.cnblogs.com/softidea/p/5775546.html

批量插入：

![复制代码][copycode.gif]

<insert id="batchInsert">
        insert into testTable (id,content)
        values
        <foreach collection="list" item="item" index="index"  separator="," >
          (
          #{item.id},
          #{item.content},
          )
        </foreach>
      </insert>

![复制代码][copycode.gif]

Mapper文件中的写法

![复制代码][copycode.gif]

<insert id="batchUpdateTjData">
            <foreach collection="list" item="item" index="index" open="" close="" separator=";">
                UPDATE test_table
                    SET c_a = #{item.ca},
                         c_b = #{item.cb}
                WHERE id = #{item.id}
            </foreach>
     </insert>

![复制代码][copycode.gif]

这样写总是报错，调试了很长时间也没找到问题原因

最后找到这里http://my.oschina.net/jsonavaj/blog/265112 找到了答案

数据库的链接必须加上 allowMultiQueries=true

url="jdbc:mysql://localhost:3306/testDatabase?allowMultiQueries=true" />

http://www.cnblogs.com/modprobe/p/4683274.html

利用MyBatis对数据库进行DDL（create table，drop table等等）操作  
【具体代码】  
1、mapper接口文件内容如下

![复制代码][copycode.gif]

/**
     * 执行备份数据库相关表的Mapper
     */
    public interface BackupDataMapper {
        
        /**
         * 修改数据库的表名字
         * @param originalTableName
         * @param newTableName
         * @return
         */
        int alterTableName(@Param("originalTableName") String originalTableName,
                @Param("newTableName") String newTableName);
        
        /**
         * truncate指定数据库表的数据
         * @param tableName
         * @return
         */
        int truncateTable(@Param("tableName") String tableName);
    
        
        /**
         * 根据传入的表明，创建新的表并且将原表的数据插入到新的Occur表中
         * @param newTableName
         * @param originalTableName
         */
        void createNewTableAndInsertData(@Param("newTableName") String newTableName,
                @Param("originalTableName") String originalTableName);
        
        /**
         * 统计某张表中的总数据条数。
         * @param tableName
         * @return 指定表中的总记录条数。
         */
        int getRecordCount(@Param("tableName") String tableName);
        
        /**
         * 获得当前数据库的名字
         * @return
         */
        String getCurDataBaseName();
        
        /**
         * 从指定数据库中，查询是否存在某张表
         * @param dataBaseName
         * @param tableName
         * @return
         */
        String isTargetTableExistInDB(@Param("dataBaseName") String dataBaseName, 
                @Param("tableName") String tableName);
    }

![复制代码][copycode.gif]

2、mapper.xml文件内容如下

![复制代码][copycode.gif]

<mapper namespace="com.dao.BackupDataMapper">
    
        <update id="alterTableName">
            alter table ${originalTableName} rename ${newTableName}
        </update>
    
        <update id="truncateTable">
            truncate table ${tableName}
        </update>
        
        <update id="createNewTableAndInsertData">
            create table ${newTableName} as select * from ${originalTableName}
        </update>
        
        <select id="getRecordCount" resultType="int">
            select count(1) from ${tableName}
        </select>
        
        <select id="getCurDataBaseName" resultType="string">
            select database();
        </select>
        
        <select id="isTargetTableExistInDB" resultType="string">
            SELECT table_name FROM information_schema.tables WHERE table_schema = #{dataBaseName} and TABLE_NAME = #{tableName}
        </select>
    
    </mapper>

![复制代码][copycode.gif]

3、注意点  
在传入“表名”作为参数时，一定要使用“$\{tableName\}”的格式，而不能使用“\#\{tableName\}”的格式。因为表名是sql语法要求的一部分，而不是参数。

[copycode.gif]: /images/20220608/6bfc6ad003c641039aabb31023849a63.png