diff options
Diffstat (limited to 'java/das/samples/transaction/src')
6 files changed, 0 insertions, 564 deletions
diff --git a/java/das/samples/transaction/src/main/java/org/apache/tuscany/samples/das/databaseSetup/DatabaseSetupUtil.java b/java/das/samples/transaction/src/main/java/org/apache/tuscany/samples/das/databaseSetup/DatabaseSetupUtil.java deleted file mode 100644 index fbcbe1a5f7..0000000000 --- a/java/das/samples/transaction/src/main/java/org/apache/tuscany/samples/das/databaseSetup/DatabaseSetupUtil.java +++ /dev/null @@ -1,67 +0,0 @@ -/*
- * 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/java/das/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/manager/GeronimoTransactionManagerService.java b/java/das/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/manager/GeronimoTransactionManagerService.java deleted file mode 100644 index ee106bec0c..0000000000 --- a/java/das/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/manager/GeronimoTransactionManagerService.java +++ /dev/null @@ -1,118 +0,0 @@ -/*
- * 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/java/das/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/manager/GeronimoTransactionManagerUtil.java b/java/das/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/manager/GeronimoTransactionManagerUtil.java deleted file mode 100644 index 084e735117..0000000000 --- a/java/das/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/manager/GeronimoTransactionManagerUtil.java +++ /dev/null @@ -1,122 +0,0 @@ -/*
- * 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/java/das/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/sample/MoneyTransfer.java b/java/das/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/sample/MoneyTransfer.java deleted file mode 100644 index 650f60f089..0000000000 --- a/java/das/samples/transaction/src/main/java/org/apache/tuscany/samples/das/tx/sample/MoneyTransfer.java +++ /dev/null @@ -1,193 +0,0 @@ -/*
- * 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/java/das/samples/transaction/src/main/resources/BankAccountDBConfig.xml b/java/das/samples/transaction/src/main/resources/BankAccountDBConfig.xml deleted file mode 100644 index 1ade9f2341..0000000000 --- a/java/das/samples/transaction/src/main/resources/BankAccountDBConfig.xml +++ /dev/null @@ -1,34 +0,0 @@ -<?xml version="1.0" encoding="ASCII"?>
-<!--
- 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.
- -->
-<DBConfig xmlns="http:///org.apache.tuscany.das.rdb/dbconfig.xsd">
- <ConnectionInfo>
- <ConnectionProperties
- driverClass="com.mysql.jdbc.Driver"
- databaseURL="jdbc:mysql://localhost/dastest?createDatabaseIfNotExist=true"
- userName="root"
- password="mypwd"/>
- </ConnectionInfo>
-
- <Table name="BANKACCOUNT" SQLCreate="CREATE TABLE BANKACCOUNT (ID INT PRIMARY KEY NOT NULL, NAME VARCHAR(30), BALANCE float )type=InnoDB">
- <row>1, 'John Feng', 1200</row>
- <row>2, 'John Feng', 0</row>
- </Table>
-
-</DBConfig>
diff --git a/java/das/samples/transaction/src/main/resources/BankAccounts.xml b/java/das/samples/transaction/src/main/resources/BankAccounts.xml deleted file mode 100644 index 09c1a5bb04..0000000000 --- a/java/das/samples/transaction/src/main/resources/BankAccounts.xml +++ /dev/null @@ -1,30 +0,0 @@ -<?xml version="1.0" encoding="ASCII"?>
-<!--
- 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.
- -->
- <Config xmlns="http:///org.apache.tuscany.das.rdb/config.xsd">
- <ConnectionInfo managedtx="false" />
-
- <Command name="BankAccount1Data" SQL="select ID, NAME, BALANCE from BANKACCOUNT where ID=1" kind="Select"/>
- <Command name="BankAccount2Data" SQL="select ID, NAME, BALANCE from BANKACCOUNT where ID=2" kind="Select"/>
-
- <Table tableName="BANKACCOUNT">
- <Column columnName="ID" primaryKey="true"/>
- </Table>
-
-</Config>
|