我正在将 Spring 4.0.0 以及 jOOQ 3.2.0 和 BoneCP 0.8.0 用于 Web 应用程序。
我的 PersistenceContext 配置与本指南相同（请浏览一下，代码有点太多，无法粘贴到此处）
http://www.petrikainulainen.net/programming/jooq/using-jooq-with-spring-configuration/ http://www.petrikainulainen.net/programming/jooq/using-jooq-with-spring-configuration/
但最大连接数较少，并且 closeConnectionWatch = true 用于错误检查。
据我所知，本指南是 jOOQ 网站自己的指南的非 XML 版本，请参见此处
http://www.jooq.org/doc/3.2/manual/getting-started/tutorials/jooq-with-spring/ http://www.jooq.org/doc/3.2/manual/getting-started/tutorials/jooq-with-spring/
我的问题来自于可能不知道如何使用 jOOQ 生成的 DAO 或 @Transactional 注释。我遇到了大量的“连接关闭两次”异常，这使我的应用程序从根本上崩溃了。下面的堆栈跟踪实际上并没有说它被关闭了两次，但是 closeConnectionWatch 的输出说了类似的内容
bonecp connection closed twice detected: first location connection was closed in thread[blah]
closed again in thread[blah2]
连接监视执行操作后 SQL 异常的堆栈跟踪：
Jan 28, 2014 10:51:51 AM org.apache.catalina.core.StandardWrapperValve invoke
SEVERE: Servlet.service() for servlet [appServlet] in context with path [/application] threw exception [Request processing failed; nested exception is org.springframework.jdbc.UncategorizedSQLException: jOOQ; uncategorized SQLException for SQL
<snip> error code [0]; Connection is closed!; nested exception is java.sql.SQLException: Connection is closed!] with root cause java.sql.SQLException: Connection is closed!
at com.jolbox.bonecp.ConnectionHandle.checkClosed(ConnectionHandle.java:459)
at com.jolbox.bonecp.ConnectionHandle.prepareStatement(ConnectionHandle.java:1011)
at sun.reflect.GeneratedMethodAccessor40.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at org.springframework.jdbc.datasource.LazyConnectionDataSourceProxy$LazyConnectionInvocationHandler.invoke(LazyConnectionDataSourceProxy.java:376)
at com.sun.proxy.$Proxy73.prepareStatement(Unknown Source)
at sun.reflect.GeneratedMethodAccessor40.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at org.springframework.jdbc.datasource.TransactionAwareDataSourceProxy$TransactionAwareInvocationHandler.invoke(TransactionAwareDataSourceProxy.java:240)
at com.sun.proxy.$Proxy73.prepareStatement(Unknown Source)
at org.jooq.impl.ProviderEnabledConnection.prepareStatement(ProviderEnabledConnection.java:112)
at org.jooq.impl.SettingsEnabledConnection.prepareStatement(SettingsEnabledConnection.java:76)
at org.jooq.impl.AbstractResultQuery.prepare(AbstractResultQuery.java:224)
at org.jooq.impl.AbstractQuery.execute(AbstractQuery.java:295)
at org.jooq.impl.AbstractResultQuery.fetch(AbstractResultQuery.java:324)
at org.jooq.impl.SelectImpl.fetch(SelectImpl.java:1034)
at org.jooq.impl.DAOImpl.fetch(DAOImpl.java:249)
----> at com.myapplication.spring.services.UserService.authenticate(UserService.java:32)
at com.myapplication.spring.controllers.LoginController.doLogin(LoginController.java:35)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at org.springframework.web.method.support.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:214)
at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:132)
at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:104)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandleMethod(RequestMappingHandlerAdapter.java:748)
at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:689)
at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:83)
at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:945)
at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:876)
at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:931)
at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:833)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:647)
at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:807)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:728)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:305)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210)
at com.github.dandelion.datatables.core.web.filter.DatatablesFilter.doFilter(DatatablesFilter.java:73)
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:243)
at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210)
at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:222)
at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:123)
at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:472)
at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:171)
at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:99)
at org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:931)
at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:118)
at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:407)
at org.apache.coyote.http11.AbstractHttp11Processor.process(AbstractHttp11Processor.java:1004)
at org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:589)
at org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:312)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
我所指向的行是服务中调用数据库的行。我的服务中有 @Autowired DAO 对象，如下所示
@Service("UserService")
public class UserService implements UserServiceInterface{
@Autowired UsersDao userDao;
@Autowired PasswordServiceInterface passwordService;
@Override
public Users authenticate(String user,String password) {
boolean allowedIn = false;
List<Users> users = userDao.fetch(USERS.USERNAME, user);
//do something here
我在类似服务中使用的其他函数包含使用 DSLContext 对象的调用，例如
DSL.select(SOMETHING).from(SOMETABLE).fetch()
DAO 和 DSLContext 作为 bean 存储在 PersistenceContext 中，如下所示。
我自动装配为 DSLContext，而不是 *Default*DSLContext，因为 jOOQ 指南底部有一个测试方法，仅显示 DSLContext。
@Bean
public DefaultDSLContext dsl() {
return new DefaultDSLContext(configuration());
}
@Bean
public UsersDao userDao() { //bad because UsersDao isn't an interface???
return new UsersDao(configuration());
}
这是控制器
@Controller
public class LoginController {
@Autowired UserServiceInterface userService;
@RequestMapping(value = "/login", method = RequestMethod.GET)
public String login() {
return "login";
}
@RequestMapping(value = "/login/doLogin", method = RequestMethod.POST)
public String doLogin(@RequestParam("username")String username, @RequestParam("password") String password, HttpSession session) {
Users u = userService.authenticate(username, password);
if(u == null)
return "redirect:/error";
else {
session.setAttribute("user", u.getUserid());
session.setAttribute("role", u.getRoleid());
session.setAttribute("retailgroup", u.getGroupid());
return "redirect:/dashboard";
}
}
UserService 并不是我遇到错误的唯一服务——我的所有服务都相似，因为它们都包含一个/两个 DAO 和 DSLContext Autowired 对象，具有与 usersDao() 相同的 DAO 配置构造函数，例如 productsDao()。 Products 服务有这个 DAO 和一个 DSLContext 对象，与它调用数据库的 UsersService 非常相似。
有时我会在登录时遇到此连接问题，其他时候会很好，我可以浏览网站并查看产品一段时间，但随后我会随机收到“连接已关闭！”来自另一个服务的错误（大约有 5 个以相同的方式编写）。
所以我的问题是
我在哪里使用 @Transactional 注释，它的实际作用是什么。我省略了 @Transactional 注释是否意味着我给自己带来了问题？我之前已将其添加到使用数据库的所有位置，但我无法确定它是否真的有帮助，因为我仍然遇到相同的错误。
我的范围有问题吗？我知道bean默认为单例 - 我以这样的方式编写了控制器，它们使用会话存储的属性传递给服务（它们都保留为默认单例），以便它们只能选择特定用户的数据被允许看到。
由于连接池两次关闭连接，这是否意味着问题是线程 A 和线程 B 同时获取连接，对其执行某些操作，然后都关闭？为什么使用上述指南中的配置会发生这种情况？我如何确保线程安全或者这不是问题？
-
DAO bean 是否应该是接口，从我使用 Spring 的简短历史来看，我相信很多（很多/全部？）@Autowired beans 应该是接口？我是否应该使用 org.jooq.DAOImpl 接口，这是所有 jOOQ 生成的 DAO 似乎都实现的接口？
@Bean
public org.jooq.impl.DAOImpl usersDao() {
return new usersDao(configuration());
}
对于这个长问题表示歉意，任何帮助将不胜感激。谢谢。
编辑：这是我在 PersistenceContext 类中的配置
@Configuration
@PropertySource("classpath:config.properties")
public class PersistenceContext {
@Autowired
private Environment env;
@Bean(destroyMethod = "close")
public DataSource dataSource() {
BoneCPDataSource dataSource = new BoneCPDataSource();
dataSource.setDriverClass(env.getRequiredProperty("db.driver"));
dataSource.setJdbcUrl(env.getRequiredProperty("db.url"));
dataSource.setUsername(env.getRequiredProperty("db.username"));
dataSource.setPassword(env.getRequiredProperty("db.password"));
dataSource.setMaxConnectionsPerPartition(20);
dataSource.setPartitionCount(2);
dataSource.setCloseConnectionWatch(true);
return dataSource;
}
@Bean
public LazyConnectionDataSourceProxy lazyConnectionDataSource() {
return new LazyConnectionDataSourceProxy(dataSource());
}
@Bean
public TransactionAwareDataSourceProxy transactionAwareDataSource() {
return new TransactionAwareDataSourceProxy(lazyConnectionDataSource());
}
@Bean
public DataSourceTransactionManager transactionManager() {
return new DataSourceTransactionManager(lazyConnectionDataSource());
}
@Bean
public DataSourceConnectionProvider connectionProvider() {
return new DataSourceConnectionProvider(transactionAwareDataSource());
}
@Bean
public JOOQToSpringExceptionTransformer jooqToSpringExceptionTransformer() {
return new JOOQToSpringExceptionTransformer();
}
@Bean
public DefaultConfiguration configuration() {
DefaultConfiguration jooqConfiguration = new DefaultConfiguration();
jooqConfiguration.set(connectionProvider());
jooqConfiguration.set(new DefaultExecuteListenerProvider(
jooqToSpringExceptionTransformer()
));
String sqlDialectName = env.getRequiredProperty("jooq.sql.dialect");
SQLDialect dialect = SQLDialect.valueOf(sqlDialectName);
jooqConfiguration.set(dialect);
return jooqConfiguration;
}
@Bean
public DefaultDSLContext dsl() {
return new DefaultDSLContext(configuration());
}
@Bean
public UsersDao userDao() {
return new UsersDao(configuration());
}
}
