From c6103c7c9a6b6971d2aa0b8e3997608cb5f2c36f Mon Sep 17 00:00:00 2001 From: lresende Date: Mon, 2 Nov 2009 22:22:29 +0000 Subject: Move the das folder as new trunk for das sub project git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@832144 13f79535-47bb-0310-9956-ffa450edef68 --- .../das/databaseSetup/DatabaseSetupUtil.java | 67 +++++++ .../manager/GeronimoTransactionManagerService.java | 118 +++++++++++++ .../tx/manager/GeronimoTransactionManagerUtil.java | 122 +++++++++++++ .../samples/das/tx/sample/MoneyTransfer.java | 193 +++++++++++++++++++++ .../src/main/resources/BankAccountDBConfig.xml | 34 ++++ .../src/main/resources/BankAccounts.xml | 30 ++++ 6 files changed, 564 insertions(+) create mode 100644 das-java/trunk/samples/transaction/src/main/java/org/apache/tuscany/samples/das/databaseSetup/DatabaseSetupUtil.java create mode 100644 das-java/trunk/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/manager/GeronimoTransactionManagerService.java create mode 100644 das-java/trunk/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/manager/GeronimoTransactionManagerUtil.java create mode 100644 das-java/trunk/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/sample/MoneyTransfer.java create mode 100644 das-java/trunk/samples/transaction/src/main/resources/BankAccountDBConfig.xml create mode 100644 das-java/trunk/samples/transaction/src/main/resources/BankAccounts.xml (limited to 'das-java/trunk/samples/transaction/src/main') 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 TransactionManager 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); + } +} diff --git a/das-java/trunk/samples/transaction/src/main/resources/BankAccountDBConfig.xml b/das-java/trunk/samples/transaction/src/main/resources/BankAccountDBConfig.xml new file mode 100644 index 0000000000..1ade9f2341 --- /dev/null +++ b/das-java/trunk/samples/transaction/src/main/resources/BankAccountDBConfig.xml @@ -0,0 +1,34 @@ + + + + + + + + + 1, 'John Feng', 1200 + 2, 'John Feng', 0 +
+ + diff --git a/das-java/trunk/samples/transaction/src/main/resources/BankAccounts.xml b/das-java/trunk/samples/transaction/src/main/resources/BankAccounts.xml new file mode 100644 index 0000000000..09c1a5bb04 --- /dev/null +++ b/das-java/trunk/samples/transaction/src/main/resources/BankAccounts.xml @@ -0,0 +1,30 @@ + + + + + + + + + + +
+ + -- cgit v1.2.3