| S2DBCPの機能を使って、コネクションプーリングを実現できます。JTAと連動するので、トランザクション中にコネクションを取得し閉じるということを何度か行っても、トランザクションは維持されます。JDBCで行っていたようなトランザクションを維持したいがために複数のクラスでコネクションを持ちまわるようなことはもう必要なくなります。S2Txを使えば、トランザクションもAspectで自動的に処理することができます。 XADataSource、ConnectionPoolの設定をおこないます。JDBC DriverがXADataSourceの機能を提供している場合は、 それをそのまま使えますが、提供されていない場合、S2で用意しているXADataSourceImplを使って、XAの機能をエミュレートします。 org.seasar.extension.dbcp.impl.XADataSourceImpl
| プロパティ | 説明 | 例 |  
| driverClassName | JDBC Driverのクラス名 | "oracle.jdbc.driver.OracleDriver" |  
| URL | RDBMS固有のURL | "jdbc:oracle:thin:@xxx:1521:yyy" |  
| user | ユーザ名 | "hoge" |  
| password | パスワード | "password" |  org.seasar.extension.dbcp.impl.ConnectionPoolImpl
| プロパティ | 説明 | 例 |  
| XADataSource | XADataSourceのインスタンスを設定します。S2Containerで設定する場合は、XADataSourceのコンポーネント名を設定します。 | xaDataSource |  
| transactionManager | TransactionManagerのインスタンスを設定します。S2Containerで設定する場合は、TransactionManagerのコンポーネント名を設定します。 | transactionManager |  
| timeout | プールに戻されたコネクションがここで指定された秒数以上未使用だった場合、物理的にクローズされて破棄されます。デフォルトは600(10分)です。 | 600 |  
| maxPoolSize | 同時にアクティブになれる コネクションの数を指定します。 この数を超える要求があると、コネクションがプールに返されるまで その要求はブロックされます。 デフォルトは10です。 | 10 |  コンポーネントの設定は以下のようになります。環境に合わせて書き換えてください。 j2ee.dicon<components namespace="j2ee"><component name="transactionManager"
 class="org.seasar.extension.jta.TransactionManagerImpl"/>
 <component name="requiredTx"
 class="org.seasar.extension.tx.RequiredAdvice"/>
 <component name="requiresNewTx"
 class="org.seasar.extension.tx.RequiresNewAdvice"/>
 <component name="mandatoryTx"
 class="org.seasar.extension.tx.MandatoryAdvice"/>
 <component name="xaDataSource"
 class="org.seasar.extension.dbcp.impl.XADataSourceImpl">
 <property name="driverClassName">
 "oracle.jdbc.driver.OracleDriver"
 </property>
 <property name="URL">
 "jdbc:oracle:thin:@xxx:1521:yyy"
 </property>
 <property name="user">"aaa"</property>
 <property name="password">"bbb"</property>
 </component>
 <component name="connectionPool"
 class="org.seasar.extension.dbcp.impl.ConnectionPoolImpl">
 <property name="timeout">600</property>
 <property name="maxPoolSize">10</property>
 <destroyMethod name="close"/>
 </component>
 <component name="dataSource"
 class="org.seasar.extension.dbcp.impl.DataSourceImpl"/>
 
 </components>
 EmployeeDao.java
package examples.dbcp;
import java.sql.SQLException;
public interface EmployeeDao {
    public String getEmployeeName(int empno) throws SQLException;
}
EmployeeDaoImpl.java
package examples.dbcp;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.sql.DataSource;
public class EmployeeDaoImpl implements EmployeeDao {
    private DataSource dataSource_;
    
    public EmployeeDaoImpl(DataSource dataSource) {
        dataSource_ = dataSource;
    }
    public String getEmployeeName(int empno) throws SQLException {
        String ename = null;
        Connection con = dataSource_.getConnection();
        try {
            PreparedStatement ps = con.prepareStatement(
                "SELECT ename FROM emp WHERE empno = ?");
            try {
                ps.setInt(1, empno);
                ResultSet rs = ps.executeQuery();
                try {
                    if (rs.next()) {
                        ename = rs.getString("ename");
                    }
                } finally {
                    rs.close();
                }
            } finally {
                ps.close();
            }
        } finally {
            con.close();
        }
        return ename;
    }
}
EmployeeService.java
package examples.dbcp;
import java.sql.SQLException;
public interface EmployeeService {
    public String getEmployeeName(int empno) throws SQLException;
}
EmployeeServiceImpl.java
package examples.dbcp;
import java.sql.SQLException;
public class EmployeeServiceImpl implements EmployeeService {
    private EmployeeDao dao_;
    
    public EmployeeServiceImpl(EmployeeDao dao) {
        dao_ = dao;
    }
    public String getEmployeeName(int empno) throws SQLException {
        return dao_.getEmployeeName(empno);
    }
}
Employee.dicon<components><include path="j2ee.dicon"/>
 <component class="examples.dbcp.EmployeeDaoImpl"/>
 <component class="examples.dbcp.EmployeeServiceImpl">
 <aspect>j2ee.requiredTx</aspect>
 </component>
 </components>
 EmployeeClient.java
package examples.dbcp;
import java.sql.SQLException;
import org.seasar.framework.container.S2Container;
import org.seasar.framework.container.factory.S2ContainerFactory;
public class EmployeeClient {
    private static final String PATH =
        "examples/dbcp/Employee.dicon";
        
    public static void main(String[] args) {
        S2Container container = S2ContainerFactory.create(PATH);
        container.init();try {
 EmployeeService service = (EmployeeService)
 container.getComponent(EmployeeService.class);
 System.out.println(service.getEmployeeName(7788));
 } catch (SQLException ex) {
 ex.printStackTrace();
 } finally {
 container.destroy();
 } 
    }
}
実行結果
DEBUG 2004-03-21 12:51:35,653 [main] Transaction.begin()
DEBUG 2004-03-21 12:51:37,075 [main] Transaction.commit()
SCOTT 
これまで、JTAやJTAと連動したコネクションプールに対して、敷居が高いなぁと感じていた方も、POJOでこんなに簡単に利用できるということが分かっていただけたと思います。
 |