Spring数据库连接没有关闭答案

【问题标题】：Spring Database connection not getting closedSpring数据库连接没有关闭
【发布时间】：2015-01-08 14:05:20
【问题描述】：

我正在使用 SPRING BatchPreparedStatementSetter 对象在 1 个表中批量插入记录。

一旦完成，它将在另一个表中执行批量更新。

此过程根据记录数重复多次。

现在，我遇到的问题是，在修复没有迭代之后，没有获得数据库连接并且系统只是挂起，因为 Spring 没有返回任何输出。

经过分析发现系统达到了最大允许连接限制，这是完全有效的，但我理解 Spring 框架应该在每次 CRUD 操作后处理连接释放过程。

有没有办法处理这个连接池问题。我使用 Apache BasicDataSource 作为 DataSource 对象。

提前致谢。

【问题讨论】：

你能分享一些源代码吗？
贴出使用spring批量插入的方法实现

标签： java spring

【解决方案1】：

    Code detail is something like this -

    Service class -

public class ServiceImpl {
----
    if (list.size() == 1000) {
           daoInstance.storeRecordsinDB(list);
           daoInstance.updateRecordsInDB(list2);
    }
-----
   }
    Another class DaoInstance -

    public class DaoInstance extends JdbcTemplate {

    private JdbcTemplate jdbcTemplate;

    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
    this.jdbcTemplate =jdbcTemplate;
    }

    public void storeRecords(List<dtoObj> valueList) {

           getJdbcTemplate().batchUpdate(insertSql, new BatchPreparedStatementSetter() {

                @Override
                public void setValues(PreparedStatement ps, int i) throws SQLException {


                     dtoObj dto = valueList.get(i);             
                     ps.setLong(1, dto.getId());
                     ps.setString(2, dto.getName();


                }

                @Override
                public int getBatchSize() {
                    return valueList.size();                    
                }
            }) ;
    }


    public void updateRecordsInDB(final List<Long> idList)  {


            try {

                getJdbcTemplate().batchUpdate(updateSQL, new BatchPreparedStatementSetter() {

                    @Override
                    public void setValues(PreparedStatement ps, int i) throws SQLException {
                                              long id = idList.get(i)
                        ps.setLong(1, id);
                    }

                    @Override
                    public int getBatchSize() {
                        if (idList != null ) {
                            return idList.size();
                        }else {
                            return 0;
                        }
                    }
                });
            }

Implemented transaction management on service class in Spring xml file as -

<tx:advice id = "txAdvice" transaction-manager="txManager">
        <tx:attributes>
            <tx:method name="*" propagation="REQUIRED" read-only="false"/>
            <!-- <tx:method name="*" read-only="true"/> -->
        </tx:attributes>
    </tx:advice>

    <aop:config>
    <aop:pointcut expression="execution(* com.package.serviceImpl.process*(..))" id="accuracyOperation"/>
    <aop:advisor advice-ref="txAdvice" pointcut-ref="accuracyOperation"/>
    </aop:config>

【讨论】：

你为什么要发布代码作为答案？？？您需要使用此代码编辑您的答案。

【解决方案2】：

这已通过在代码中实现事务管理来解决。

另一个主要问题是在其中一个 select 子句中，连接没有关闭。因此，通过在 Connection 对象上显式调用 close 方法，它会被关闭，因此系统不会超过最大连接限制。

【讨论】：