View Javadoc
1   /*
2    * Copyright 2004-2026 the original author or authors.
3    *
4    * Licensed under the Apache License, Version 2.0 (the "License");
5    * you may not use this file except in compliance with the License.
6    * You may obtain a copy of the License at
7    *
8    *    https://www.apache.org/licenses/LICENSE-2.0
9    *
10   * Unless required by applicable law or agreed to in writing, software
11   * distributed under the License is distributed on an "AS IS" BASIS,
12   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13   * See the License for the specific language governing permissions and
14   * limitations under the License.
15   */
16  package com.ibatis.sqlmap.engine.transaction.jta;
17  
18  import com.ibatis.sqlmap.client.SqlMapException;
19  import com.ibatis.sqlmap.engine.transaction.BaseTransactionConfig;
20  import com.ibatis.sqlmap.engine.transaction.Transaction;
21  import com.ibatis.sqlmap.engine.transaction.TransactionException;
22  
23  import java.sql.SQLException;
24  import java.util.Properties;
25  
26  import javax.naming.InitialContext;
27  import javax.naming.NamingException;
28  import javax.transaction.UserTransaction;
29  
30  /**
31   * The Class JtaTransactionConfig.
32   */
33  public class JavaxTransactionConfig extends BaseTransactionConfig {
34  
35    /** The user transaction. */
36    private UserTransaction userTransaction;
37  
38    @Override
39    public Transaction newTransaction(int transactionIsolation) throws SQLException, TransactionException {
40      return new JavaxTransaction(userTransaction, dataSource, transactionIsolation);
41    }
42  
43    /**
44     * Gets the user transaction.
45     *
46     * @return the user transaction
47     */
48    public UserTransaction getUserTransaction() {
49      return userTransaction;
50    }
51  
52    /**
53     * Sets the user transaction.
54     *
55     * @param userTransaction
56     *          the new user transaction
57     */
58    public void setUserTransaction(UserTransaction userTransaction) {
59      this.userTransaction = userTransaction;
60    }
61  
62    @Override
63    public void setProperties(Properties props) throws SQLException, TransactionException {
64      String utxName = null;
65      try {
66        utxName = (String) props.get("UserTransaction");
67        InitialContext initCtx = new InitialContext();
68        userTransaction = (UserTransaction) initCtx.lookup(utxName);
69      } catch (NamingException e) {
70        throw new SqlMapException(
71            "Error initializing JtaTransactionConfig while looking up UserTransaction (" + utxName + ").  Cause: " + e);
72      }
73    }
74  
75  }