diff options
Diffstat (limited to 'das-java/trunk/samples/transaction/src/main/java')
4 files changed, 500 insertions, 0 deletions
diff --git a/das-java/trunk/samples/transaction/src/main/java/org/apache/tuscany/samples/das/databaseSetup/DatabaseSetupUtil.java b/das-java/trunk/samples/transaction/src/main/java/org/apache/tuscany/samples/das/databaseSetup/DatabaseSetupUtil.java new file mode 100644 index 0000000000..fbcbe1a5f7 --- /dev/null +++ b/das-java/trunk/samples/transaction/src/main/java/org/apache/tuscany/samples/das/databaseSetup/DatabaseSetupUtil.java @@ -0,0 +1,67 @@ +/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tuscany.samples.das.databaseSetup;
+
+import java.sql.Connection;
+import java.sql.ResultSet;
+
+import org.apache.tuscany.das.rdb.dbconfig.DBConfig;
+import org.apache.tuscany.das.rdb.dbconfig.DBConfigUtil;
+import org.apache.tuscany.das.rdb.dbconfig.DBInitializer;
+import org.apache.tuscany.samples.das.tx.manager.GeronimoTransactionManagerUtil;
+
+/**
+ * Setup database, XA resources required by the sample
+ *
+ *
+ */
+public class DatabaseSetupUtil {
+ private static DBConfig dbConfig = null;
+ /**
+ * Constructor for DatabaseSetupUtil.
+ */
+ public DatabaseSetupUtil(String dbConfigFile) throws Exception {
+ //create database tables, data
+ DBInitializer dbInitializer = new DBInitializer(dbConfigFile);
+ dbInitializer.refreshDatabaseData();
+ //read DAS Config
+ dbConfig = DBConfigUtil.loadDBConfig(ClassLoader.getSystemResourceAsStream(dbConfigFile));
+ }
+
+ public static DBConfig getDBConfig() {
+ return DatabaseSetupUtil.dbConfig;
+ }
+
+ public static void main(String[] args) throws Exception{
+ //test program
+ new DatabaseSetupUtil("BankAccountDBConfig.xml");
+ GeronimoTransactionManagerUtil tmUtil = new GeronimoTransactionManagerUtil();
+ tmUtil.initTransactionManager();
+ tmUtil.startTransaction();
+ Connection conn = tmUtil.getConnection();
+
+ ResultSet rs = conn.createStatement().executeQuery("select id, balance from bankaccount");
+ while(rs.next()){
+ System.out.println("result row: "+rs.getInt(1)+","+rs.getString(2));
+ }
+
+ tmUtil.commitTransaction();
+
+ }
+}
diff --git a/das-java/trunk/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/manager/GeronimoTransactionManagerService.java b/das-java/trunk/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/manager/GeronimoTransactionManagerService.java new file mode 100644 index 0000000000..ee106bec0c --- /dev/null +++ b/das-java/trunk/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/manager/GeronimoTransactionManagerService.java @@ -0,0 +1,118 @@ +/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tuscany.samples.das.tx.manager;
+
+import javax.transaction.HeuristicMixedException;
+import javax.transaction.HeuristicRollbackException;
+import javax.transaction.InvalidTransactionException;
+import javax.transaction.NotSupportedException;
+import javax.transaction.RollbackException;
+import javax.transaction.SystemException;
+import javax.transaction.Transaction;
+import javax.transaction.TransactionManager;
+
+import org.apache.geronimo.transaction.manager.TransactionManagerImpl;
+import org.apache.geronimo.transaction.manager.XidFactoryImpl;
+
+/**
+ * A <code>TransactionManager</code> that delegates to a Geronimo JTA transaction manager. This class serves as a
+ * wrapper for initializing the Geronimo TM as a system service.
+ *
+ * @version $Rev$ $Date$
+ */
+public class GeronimoTransactionManagerService implements TransactionManager {
+ private TransactionManager transactionManager;
+ private int timeout = 250;
+
+ public GeronimoTransactionManagerService() {
+ }
+
+ /**
+ * Returns the transaction timeout in seconds
+ *
+ * @return the transaction timeout in seconds
+ */
+ public int getTimeout() {
+ return timeout;
+ }
+
+ /**
+ * Sets the transaction timeout in seconds
+ */
+ public void setTimeout(int timeout) {
+ this.timeout = timeout;
+ }
+
+ public void init() throws Exception {
+ XidFactoryImpl factory = new XidFactoryImpl();
+ transactionManager = new TransactionManagerImpl(timeout, factory, null);
+ }
+
+ public void begin() throws NotSupportedException, SystemException {
+ transactionManager.begin();
+ }
+
+ public void commit() throws HeuristicMixedException,
+ HeuristicRollbackException,
+ IllegalStateException,
+ RollbackException,
+ SecurityException,
+ SystemException {
+ transactionManager.commit();
+ }
+
+ public TransactionManager getTransactionManager() {
+ return transactionManager;
+ }
+
+ public int getStatus() throws SystemException {
+ return transactionManager.getStatus();
+ }
+
+ public Transaction getTransaction() throws SystemException {
+ return transactionManager.getTransaction();
+ }
+
+ public void resume(Transaction transaction)
+ throws IllegalStateException, InvalidTransactionException, SystemException {
+ transactionManager.resume(transaction);
+ }
+
+ public void rollback() throws IllegalStateException, SecurityException, SystemException {
+ transactionManager.rollback();
+ }
+
+ public void setRollbackOnly() throws IllegalStateException, SystemException {
+ transactionManager.setRollbackOnly();
+ }
+
+ public void setTransactionTimeout(int i) throws SystemException {
+ transactionManager.setTransactionTimeout(i);
+ }
+
+ public Transaction suspend() throws SystemException {
+ return transactionManager.suspend();
+ }
+
+ public void begin(long timeout) throws NotSupportedException, SystemException {
+ transactionManager.begin();
+ return;
+ }
+
+}
diff --git a/das-java/trunk/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/manager/GeronimoTransactionManagerUtil.java b/das-java/trunk/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/manager/GeronimoTransactionManagerUtil.java new file mode 100644 index 0000000000..084e735117 --- /dev/null +++ b/das-java/trunk/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/manager/GeronimoTransactionManagerUtil.java @@ -0,0 +1,122 @@ +/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tuscany.samples.das.tx.manager;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+
+import javax.sql.XAConnection;
+import javax.sql.XADataSource;
+import javax.transaction.xa.XAResource;
+import javax.transaction.xa.Xid;
+
+import org.apache.geronimo.transaction.manager.XidFactory;
+import org.apache.geronimo.transaction.manager.XidFactoryImpl;
+import org.apache.tuscany.das.rdb.dbconfig.DBConfig;
+import org.apache.tuscany.samples.das.databaseSetup.DatabaseSetupUtil;
+
+import com.mysql.jdbc.jdbc2.optional.MysqlXADataSource;
+
+public class GeronimoTransactionManagerUtil {
+ private GeronimoTransactionManagerService service;
+ private static XADataSource xads;
+ private static XAConnection xaconn = null;
+ private static XAResource xares = null;
+ private static XidFactory xidFact = null;
+ private static Xid xid = null;
+
+ public void initTransactionManager() {
+ // Get a transction manager
+ try {
+ xidFact = new XidFactoryImpl();
+ // creates an instance of Geronimo TM Service
+ service = new GeronimoTransactionManagerService();
+ service.init();
+ service.begin();
+ initDataSource();
+ initXAConnection();
+ } catch (Exception e) {
+ e.printStackTrace();
+ System.exit(1);
+ }
+ }
+
+ private void initDataSource() {
+ //setup XADataSource
+ xads = new MysqlXADataSource();
+ try {
+ DBConfig dbcfg = DatabaseSetupUtil.getDBConfig();
+ ((MysqlXADataSource) xads).setUser(dbcfg.getConnectionInfo().getConnectionProperties().getUserName());
+ ((MysqlXADataSource) xads).setPassword(dbcfg.getConnectionInfo().getConnectionProperties().getPassword());
+ ((MysqlXADataSource) xads).setUrl(dbcfg.getConnectionInfo().getConnectionProperties().getDatabaseURL());
+ ((MysqlXADataSource) xads).setURL(dbcfg.getConnectionInfo().getConnectionProperties().getDatabaseURL());
+ } catch (Exception e) {
+ e.printStackTrace();
+ System.exit(1);
+ }
+ }
+
+ private void initXAConnection() throws SQLException{
+ DBConfig dbcfg = DatabaseSetupUtil.getDBConfig();
+ xaconn = xads.getXAConnection(dbcfg.getConnectionInfo().getConnectionProperties().getUserName(),
+ dbcfg.getConnectionInfo().getConnectionProperties().getPassword());
+ }
+
+ public void startTransaction() throws Exception {
+ try{
+ //create XAResource
+ xid= xidFact.createXid();
+ xares = xaconn.getXAResource();
+ xares.setTransactionTimeout(250); //something
+ xares.start(xid, XAResource.TMNOFLAGS);
+ return;
+ }catch(Exception e) {
+ e.printStackTrace();
+ throw e;
+ }
+ }
+
+ public void commitTransaction() throws Exception {
+ xares.end(xid, XAResource.TMSUCCESS);
+ xares.prepare(xid);
+ xares.commit(xid, false); //onePhase=true/false
+ }
+
+ public void rollbackTransaction() throws Exception {
+ xares.end(xid, XAResource.TMFAIL);
+ xares.prepare(xid);
+ xares.rollback(xid);
+ }
+
+ public Connection getConnection() throws SQLException {
+ return xaconn.getConnection();
+ }
+
+ /**
+ * cleanup
+ */
+ public void cleanup() throws Exception{
+ xaconn.close();
+ xid = null;
+ xares = null;
+ xaconn = null;
+ xads = null;
+ service.commit();
+ }
+}
diff --git a/das-java/trunk/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/sample/MoneyTransfer.java b/das-java/trunk/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/sample/MoneyTransfer.java new file mode 100644 index 0000000000..650f60f089 --- /dev/null +++ b/das-java/trunk/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/sample/MoneyTransfer.java @@ -0,0 +1,193 @@ +/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.tuscany.samples.das.tx.sample;
+
+import java.io.InputStream;
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.Statement;
+
+import org.apache.tuscany.das.rdb.Command;
+import org.apache.tuscany.das.rdb.DAS;
+import org.apache.tuscany.samples.das.databaseSetup.DatabaseSetupUtil;
+import org.apache.tuscany.samples.das.tx.manager.GeronimoTransactionManagerUtil;
+
+import commonj.sdo.DataObject;
+
+/**
+ * Sample using Geronimo TM to execute multiple DAS applyChanges() under one transaction.
+ *
+ */
+public class MoneyTransfer {
+
+ private static final String USAGE = "usage: java MoneyTransfer [commit|rollback] [transferAmount]";
+ private static final String SQL_REQUEST = "select id, name, balance from bankaccount";
+ private static Connection conn = null;
+ private static DAS das = null;
+
+ private static void printTable() {
+ try {
+ Statement stmt = conn.createStatement();
+ ResultSet rset = stmt.executeQuery(SQL_REQUEST);
+ int numcols = rset.getMetaData().getColumnCount();
+ for (int i = 1; i <= numcols; i++) {
+ System.out.print("\t" + rset.getMetaData().getColumnName(i));
+ }
+ System.out.println();
+ while (rset.next()) {
+ for (int i = 1; i <= numcols; i++) {
+ System.out.print("\t" + rset.getString(i));
+ }
+ System.out.println("");
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+ public static void main(String[] args) {
+ GeronimoTransactionManagerUtil tmUtil = null;
+
+ if (args.length != 2 || (!args[0].equals("commit") && !args[0].equals("rollback"))) {
+ System.out.println(USAGE + "\n");
+ System.exit(1);
+ }
+
+ String completion = args[0];
+ float transferAmount = 0;
+ try {
+ transferAmount = Float.parseFloat(args[1]);
+ } catch (NumberFormatException e) {
+ System.out.println(USAGE);
+ System.out.println("[transferAmount] has to be a float\n");
+ System.exit(1);
+ }
+
+ System.out.println("INIT database");
+ try{
+ new DatabaseSetupUtil("BankAccountDBConfig.xml");
+ }catch(Exception e){
+ e.printStackTrace();
+ System.exit(1);
+ }
+
+ try {
+ System.out.println("INIT transaction manager");
+ tmUtil = new GeronimoTransactionManagerUtil();
+ tmUtil.initTransactionManager();
+ tmUtil.startTransaction();
+ } catch (Exception e) {
+ System.out.println("Exception of type :" + e.getClass().getName() + " has been thrown");
+ System.out.println("Exception message :" + e.getMessage());
+ e.printStackTrace();
+ System.exit(1);
+ }
+
+ try {
+ System.out.println("Get a connection");
+ conn = tmUtil.getConnection();
+ conn.setAutoCommit(false);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+
+ System.out.println("Before transaction, table is:");
+ printTable();
+
+ try {
+ System.out.println("Begin a transaction");
+ init(); //initialize DAS instance
+ System.out.println("Update the table - 2 accounts");
+ withdrawFromBankAccount1(transferAmount);
+ depositToBankAccount2(transferAmount);
+
+ if (completion.equals("commit")) {
+ System.out.println("*commit* the transaction");
+ tmUtil.commitTransaction();
+ } else {
+ System.out.println("*rollback* the transaction");
+ tmUtil.rollbackTransaction();
+ }
+ } catch (Exception e) {
+ System.out.println("Exception of type :" + e.getClass().getName() + " has been thrown");
+ System.out.println("Exception message :" + e.getMessage());
+ e.printStackTrace();
+ System.exit(1);
+ }
+
+ System.out.println("After transaction, table is:");
+ printTable();
+
+ System.out.println("Cleanup");
+ try {
+ tmUtil.cleanup();
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+
+ System.out.println("End MoneyTransfer\n");
+ System.exit(0);
+ }
+
+ private static void init(){
+ try{
+ das = DAS.FACTORY.createDAS(getConfig("BankAccounts.xml"), conn);
+ }catch(Exception e){
+ e.printStackTrace();
+ }
+ }
+
+ /**
+ * Withdraw asked amount from account1
+ * @return
+ */
+ public static final void withdrawFromBankAccount1(float transferAmount) {
+ Command read = das.getCommand("BankAccount1Data");
+ DataObject root = read.executeQuery();
+ DataObject account1 = (DataObject)root.getList("BANKACCOUNT").get(0);
+ float currentBalance = account1.getFloat("BALANCE");
+ float newBalance = currentBalance - transferAmount;
+ account1.setFloat("BALANCE", newBalance);
+ das.applyChanges(root);
+ }
+
+ /**
+ * Deposit asked amount into account2
+ * @return
+ */
+ public static final void depositToBankAccount2(float transferAmount) {
+ Command read = das.getCommand("BankAccount2Data");
+ DataObject root = read.executeQuery();
+ DataObject account2 = (DataObject)root.getList("BANKACCOUNT").get(0);
+ float currentBalance = account2.getFloat("BALANCE");
+ float newBalance = currentBalance + transferAmount;
+ account2.setFloat("BALANCE", newBalance);
+ das.applyChanges(root);
+ }
+
+ /**Utilities
+ *
+ * @param fileName
+ * @return
+ */
+ private static InputStream getConfig(String fileName) {
+ MoneyTransfer jdbcExample = new MoneyTransfer();
+ return jdbcExample.getClass().getClassLoader().getResourceAsStream(fileName);
+ }
+}
|