ICode9

精准搜索请尝试: 精确搜索
首页 > 数据库> 文章详细

java – Ibatis startBatch()仅适用于SqlMapClient自己的启动和提交事务,而不适用于Spring管理的事务

2019-07-05 06:15:16  阅读:439  来源: 互联网

标签:java mysql spring ibatis


我发现即使我有Spring事务包装的代码,并且它在我期望的时候提交/回滚,为了在使用Ibatis和Spring时使用JDBC批处理,我需要使用显式的SqlMapClient事务方法.

即这按照我的预期进行批处理:

dao.getSqlMapClient().startTransaction();
dao.getSqlMapClient().startBatch();

int i = 0;
for (MyObject obj : allObjects)
{
    dao.storeChange(obj);

    i++;
    if (i % DB_BATCH_SIZE == 0)
    {
        dao.getSqlMapClient().executeBatch();
        dao.getSqlMapClient().startBatch();
    }
}

dao.getSqlMapClient().executeBatch();
dao.getSqlMapClient().commitTransaction();

但是如果我没有开启和关闭事务语句,并依靠Spring来管理事物(这就是我想做的事情!),批处理就不会发生.

鉴于Spring似乎在交易管理方面处理其讨价还价的一方,有人可以就此处的任何已知问题提出建议吗?

(数据库是MySQL;我知道有关其INSERT语句重写的JDBC伪批处理方法的问题,这绝对不是问题)

解决方法:

通过阅读各种资源和反复试验找到了这个背后的原因,我在这里记录了我们的结果,因为它可以帮助其他人.

事实证明,不同的行为是由于我们的DAO类扩展了Spring的SqlMapClientTemplate.在那个班级,你有两个“选择”(我说选择;一个是正确的,一个不是):

>直接使用insert(),update()等;一直使用完整的Spring对象
> getSqlMapClient().insert(),update()等;这个实际上使用getSqlMapClient()返回的com.ibatis …对象,而不是Spring

两者通常都有效,但从我的阅读中可以看出第一个选项更好,例如如果你正在使用Spring,你想要完全基于Spring,而不是“跳出”到Ibatis对象.

现在,SqlMapClientTemplate不直接提供对startBatch()/ executeBatch()的访问,只是方便的insert(),update()东西,所以这样的代码是必要的.下面的代码完全适用于我们的Spring托管事务,而不是显式代码startTransaction().

(免责声明这可能包含由于我的“匿名”工作代码而导致的错误)

public class MyFunkyDao extends SqlMapClientDaoSupport
{
    private static final int DB_BATCH_SIZE = 1000;

    public void storeMyData(final List<MyData> listData)
    {
        getSqlMapClientTemplate().execute( new SqlMapClientCallback()
        {
            @Override
            public Object doInSqlMapClient(SqlMapExecutor executor) throws SQLException
            {
                int count = 0, total = 0;

                Map<String, Object> params = new HashMap<String, Object>();

                executor.startBatch();

                for (MyData data: listData)
                {
                    params.put("param name 1", data.getValue());

                    executor.insert("insertData", params);

                    count++;
                    if (count % DB_BATCH_SIZE == 0) 
                    {
                        total += executor.executeBatch();
                        executor.startBatch();
                    }

                    params.clear();
                }

                total += executor.executeBatch();

                return new Integer(total);
            }
        });
    }
}

链接:http://static.springsource.org/spring/docs/2.5.x/api/org/springframework/orm/ibatis/SqlMapClientTemplate.html

标签:java,mysql,spring,ibatis
来源: https://codeday.me/bug/20190705/1384493.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有