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

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);

+    }

+}