Jetty 数据源与 Atomikos UserTransaction

Question

我的 Web 应用程序中有两个数据源（principalDB 和 backupDB），位于两个 Postgresql DB 上，还有一个 Web 容器管理的事务管理器（带有 Atomikos）。 Spring FW 和 Hibernate 是我的应用程序构建块。我遇到的问题是 Jetty 6.1.3 Web 容器似乎没有加载声明资源的应用程序特定的 WEB-INF/jetty-env.xml，因此我遇到了异常：

Caused by: javax.naming.NameNotFoundException; remaining name 'env/jdbc/principalDB'
 at org.mortbay.naming.NamingContext.lookup(NamingContext.java:634)
 at org.mortbay.naming.NamingContext.lookup(NamingContext.java:665)
 at org.mortbay.naming.NamingContext.lookup(NamingContext.java:680)
 at org.mortbay.naming.java.javaRootURLContext.lookup(javaRootURLContext.java:112)
 at javax.naming.InitialContext.lookup(InitialContext.java:351)
 at org.springframework.jndi.JndiTemplate$1.doInContext(JndiTemplate.java:155)
 at org.springframework.jndi.JndiTemplate.execute(JndiTemplate.java:88)
 at org.springframework.jndi.JndiTemplate.lookup(JndiTemplate.java:153)
 at org.springframework.jndi.JndiTemplate.lookup(JndiTemplate.java:178)
 at org.springframework.jndi.JndiLocatorSupport.lookup(JndiLocatorSupport.java:95)
 at org.springframework.jndi.JndiObjectLocator.lookup(JndiObjectLocator.java:105)
 at org.springframework.jndi.JndiObjectFactoryBean.lookupWithFallback(JndiObjectFactoryBean.java:200)
 at org.springframework.jndi.JndiObjectFactoryBean.afterPropertiesSet(JndiObjectFactoryBean.java:186)
 at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1368)
 at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1334)
 ... 43 more

这是我配置两个数据源的方式

1. 在WEB-INF/web.xml中，我已使用resource-ref声明了两个资源：

   <资源引用>
    <描述>主要数据源
    javax.sql.DataSource
    容器
    jdbc/principalDB;
   
   <资源引用>
    <描述>备份数据源
    javax.sql.DataSource
    容器
    jdbc/backupDB;
   
   

2. 在 WEB-INF/jetty- env.xml 我有

   <新 id="principalDB" class="org.mortbay.jetty.plus.naming.Resource">
   
     jdbc/principalDB;
     
       <新类=“com.atomikos.jdbc.nonxa.NonXADataSourceBean”>
         <设置名称=“driverClassName”>org.postgresql.jdbc3.Jdbc3ConnectionPool
         <设置名称=“服务器名称”>本地主机
         <设置名称=“端口号”>5432
         <设置名称=“数据库名称”>第一个
         <设置名称=“Url”>jdbc:postgresql://localhost:5432/first
         <设置名称=“用户”>测试
         <设置名称=“密码”>密码
       
     
   
   
   <新 id="backupDB" class="org.mortbay.jetty.plus.naming.Resource">
   
     <参数>jdbc/backupDB
     
       <新类=“com.atomikos.jdbc.nonxa.NonXADataSourceBean”>
         <设置名称=“driverClassName”>org.postgresql.jdbc3.Jdbc3ConnectionPool
         <设置名称=“服务器名称”>本地主机
         <设置名称=“端口号”>5432
         <设置名称=“数据库名称”>第二个
         <设置名称=“Url”>jdbc:postgresql://localhost:5432/second
         <设置名称=“用户”>testSec
         <设置名称=“密码”>密码
       
     
   
   

我做错了什么？

Answer 1

确保您遵循了http://docs.codehaus.org/display/JETTY/Atomikos（假设您使用的是 Atomikos 3.3 及更高版本）。

然后，对于步骤 3，请特别注意以下注释：

由于 NonXADataSourceBean 仅使用 java.sql.Driver 的类名和 url，因此您可以将其与提供的任何数据库一起使用JDBC 驱动程序。

所以你当前的设置包含了太多的东西，但更重要的是，驱动程序类名看起来错误，它应该是org.postgresql.Driver。

但是 PostgreSQL JDBC 驱动程序确实支持 XADatasource （使用 org.postgresql.xa.PGXADataSource 实现），所以我宁愿配置一个 AtomikosDataSourceBean （ 第 3 步的第一个选项）。像这样的东西：

<New id="mydatasource" class="org.mortbay.jetty.plus.naming.Resource">
  <Arg><Ref id='wac'/></Arg>
  <Arg>jdbc/mydatasource</Arg>
  <Arg>
    <New class="com.atomikos.jdbc.AtomikosDataSourceBean">
      <Set name="minPoolSize">2</Set>
      <Set name="maxPoolSize">20</Set>
      <Set name="xaDataSourceClassName">org.postgresql.xa.PGXADataSource</Set>
      <Set name="xaProperties">
        <New class="java.util.Properties">
          <Call name="setProperty"><Arg>databaseName</Arg><Arg>testdb</Arg></Call>
          <Call name="setProperty"><Arg>serverName</Arg><Arg>localhost</Arg></Call>
          <Call name="setProperty"><Arg>portNumber</Arg><Arg>5432</Arg></Call>
          <Call name="setProperty"><Arg>user</Arg><Arg>test</Arg></Call>
          <Call name="setProperty"><Arg>password</Arg><Arg>p4ssw0rd</Arg>/Call>
        </New>
      </Set>
      <Set name="UniqueResourceName">mydatasource</Set>
    </New>
  </Arg>
</New>