| Revision | 2582 (tree) |
|---|---|
| Time | 2023-07-14 19:47:10 |
| Author | t_nakayama1971 |
(empty log message)
trunk/s2/dbcp/src/main/java/org/seasar/extension/dbcp/impl/ConnectionWrapperImpl.java (diff)| @@ -68,7 +68,7 @@ | ||
| 68 | 68 | /** Connection */ |
| 69 | 69 | private Connection physicalConnection; |
| 70 | 70 | /** クローズ判断 */ |
| 71 | - private boolean closed = false; | |
| 71 | + private boolean closed; | |
| 72 | 72 | /** Transaction */ |
| 73 | 73 | private Transaction transaction; |
| 74 | 74 |
| @@ -79,18 +79,34 @@ | ||
| 79 | 79 | * @param conn 物理コネクション |
| 80 | 80 | * @param pool コネクションプール |
| 81 | 81 | * @param tx トランザクション |
| 82 | - * @throws SQLException SQL例外が発生した場合 | |
| 83 | 82 | */ |
| 84 | 83 | public ConnectionWrapperImpl(final XAConnection xac, final Connection conn, |
| 85 | - final ConnectionPool pool, final Transaction tx) throws SQLException { | |
| 84 | + final ConnectionPool pool, final Transaction tx) { | |
| 86 | 85 | this.xaConnection = xac; |
| 87 | 86 | this.physicalConnection = conn; |
| 88 | - this.xaResource = new XAResourceWrapperImpl(xac.getXAResource(), this); | |
| 87 | + this.xaResource = createXAResource(xac, this); | |
| 89 | 88 | this.connectionPool = pool; |
| 90 | 89 | this.transaction = tx; |
| 91 | 90 | } |
| 92 | 91 | |
| 93 | 92 | /** |
| 93 | + * XAResource作成 | |
| 94 | + * | |
| 95 | + * @param xac XAコネクション | |
| 96 | + * @param wrapper ConnectionWrapper | |
| 97 | + * @return XAResource | |
| 98 | + */ | |
| 99 | + private static XAResource createXAResource( | |
| 100 | + final XAConnection xac, final ConnectionWrapper wrapper) { | |
| 101 | + try { | |
| 102 | + return new XAResourceWrapperImpl(xac.getXAResource(), wrapper); | |
| 103 | + } catch (final SQLException e) { | |
| 104 | + LOGGER.error(e.getMessage(), e); | |
| 105 | + return null; | |
| 106 | + } | |
| 107 | + } | |
| 108 | + | |
| 109 | + /** | |
| 94 | 110 | * @see org.seasar.extension.dbcp.ConnectionWrapper#getPhysicalConnection() |
| 95 | 111 | */ |
| 96 | 112 | @Override |
