Spring启动：数据库连接未正确关闭

Question

我正在使用我的Spring Boot应用程序定期（由调度程序）执行查询

application.properties

src_mssqlserver_url=jdbc:sqlserver://192.168.0.1;databaseName=Test;
src_mssqlserver_username=tester
src_mssqlserver_password=tester1
src_mssqlserver_driverClassName=com.microsoft.sqlserver.jdbc.SQLServerDriver

数据源和JdbcTemplate Bean

@Primary
    @Bean(name = "src_mssqlserver")
    @ConfigurationProperties(prefix = "spring.ds_mssqlserver")
    public DataSource srcDataSource() {

        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName(env.getProperty("src_mssqlserver_driverClassName"));
        dataSource.setUrl(env.getProperty("src_mssqlserver_url"));
        dataSource.setUsername(env.getProperty("src_mssqlserver_username"));
        dataSource.setPassword(env.getProperty("src_mssqlserver_password"));
        return dataSource;
    }

    @Bean(name = "srcJdbcTemplate")
    public JdbcTemplate srcJdbcTemplate(@Qualifier("src_mssqlserver") DataSource dsSrcSqlServer) {
        return new JdbcTemplate(dsSrcSqlServer);
    }

用法：从调度程序调用此方法，该调度程序包含要处理的项目列表（通常为1000条记录），此过程在一小时内运行一次。

@Autowired
@Qualifier("srcJdbcTemplate")
private JdbcTemplate srcJdbcTemplate;

public void batchInsertUsers(final List<User> users) {
        String queryInsert = "INSERT INTO [User] ([Name]"
                + "     , [Created_Date]"
                + "     , [Notes])"
                + " VALUES (?, SYSDATETIMEOFFSET(), ?)";

        srcJdbcTemplate.batchUpdate(queryInsert, new BatchPreparedStatementSetter() {
            @Override
            public void setValues(PreparedStatement ps, int i) throws SQLException {
                User user = users.get(i);

                ps.setString(1, user.getName());
                ps.setString(2, user.getNotes());
            }

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

我收到数据库管理员的警告，我的代码保持太多连接打开。请分享一些标准和可行的方法来处理这种情况。

谢谢。

Answer 1

DriverManagerDataSource不用于生产，它每次需要时都会打开和关闭连接。

使用像c3p0DataSource这样的连接池。