java – c3p0如何关闭所有数据库连接并在需要时重新打开它们?

我有一个TimerTask,每天运行一次(大约1或2个小时).并且在每次运行时,它将创建数百个线程来为MySQL数据库中的每个表执行一些计算工作.我使用c3p0作为数据库源连接池(每个线程在计算之前获得连接并在计算之后关闭连接).我设置连接池配置如下,

cpDs = new ComboPooledDataSource();
cpDs.setMinPoolSize(10);
cpDs.setMaxPoolSize(20);
cpDs.setMaxStatementsPerConnection(10);

在测试期间,我发现在第二天运行时所有数据库连接都丢失了,并且日志文件显示了许多“由于底层异常导致的通信链路故障”.所以我添加了以下配置,以便在使用之前测试连接.

// 7 hours,less than MysqL default value - 8 hours
cpDs.setMaxIdleTime(25200);
cpDs.setTestConnectionOnCheckout(true);
cpDs.setPreferredTestQuery("select 1");

但我观察到当TimerTask没有运行时,总有10个连接保持睡眠/空闲状态(通过sql’show processlist;’),我经常看到着名的“APPARENT DEADLOCK !!!”警告(错误在c3p0项目http://sourceforge.net/tracker/?func=detail&aid=3432139&group_id=25357&atid=383690中仍处于打开状态).

那么有什么方法可以在完成所有计算工作时关闭所有连接,并在第二天重新构建连接时再次执行任务?谢谢.

问候,
乔伊

最佳答案
如果您希望关闭所有连接,请将minPoolSize和initialPoolSize设置为0.此外,我建议将maxIdleTime减小为较小的值,如600(10分钟).这种设置组合将使工作池在工作完成后快速“消耗”.

您还可以使用ComboPooledDataSource中公开的重置方法之一强制关闭所有连接,但是如果池配置正确则不需要.

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


应用场景 C端用户提交工单、工单创建完成之后、会发布一条工单创建完成的消息事件(异步消息)、MQ消费者收到消息之后、会通知各处理器处理该消息、各处理器处理完后都会发布一条将该工单写入搜索引擎的消息、最终该工单出现在搜索引擎、被工单处理人检索和处理。 事故异常体现 1、异常体现 从工单的流转记录发现、
线程类,设置有一个公共资源 package cn.org.chris.concurrent; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /** * @Descrip
Java中的数字(带有0前缀和字符串)
在Java 9中使用JLink的目的是什么?
Java Stream API Filter(过滤器)
在Java中找到正数和负数数组元素的数量
Java 9中JShell中的不同启动脚本是什么?
使用Java的位填充错误检测技术
java中string是什么
如何使用Java中的JSON-lib API将Map转换为JSON对象?
Java菜单驱动程序以检查数字类型
使用Junit的Maven项目 - 检查银行账号
JAVA编程基础
在Java中使用throw、catch和instanceof来处理异常
在Java中,将数组分割为基于给定查询的子数组后,找到子数组的最大子数组和
如何在Java中从给定的字符串中删除HTML标签?
在PHP中,IntlChar getBlockCode()函数的翻译如下:
如何在Android中实现按下返回键再次退出的功能?
如何使用Java中的流式API解析JSON字符串?
Java中的模式类