| /*========================================================================= |
| * Copyright (c) 2010-2014 Pivotal Software, Inc. All Rights Reserved. |
| * This product is protected by U.S. and international copyright |
| * and intellectual property laws. Pivotal products are covered by |
| * one or more patents listed at http://www.pivotal.io/patents. |
| *========================================================================= |
| */ |
| package com.gemstone.gemfire.internal.jta.dunit; |
| |
| import dunit.*; |
| |
| import java.io.*; |
| import java.util.*; |
| |
| //import java.net.*; |
| import com.gemstone.gemfire.cache.*; |
| import com.gemstone.gemfire.distributed.*; |
| import com.gemstone.gemfire.internal.OSProcess; |
| import com.gemstone.gemfire.internal.jta.CacheUtils; |
| import com.gemstone.gemfire.util.test.TestUtil; |
| |
| |
| |
| //import java.util.Hashtable; |
| //import javax.naming.InitialContext; |
| import javax.naming.Context; |
| import javax.sql.*; |
| import javax.transaction.*; |
| |
| import java.sql.*; |
| |
| //import java.lang.Exception.*; |
| //import java.lang.RuntimeException; |
| //import java.sql.SQLException.*; |
| import javax.naming.NamingException; |
| //import javax.naming.NoInitialContextException; |
| //import javax.transaction.*; |
| |
| public class ExceptionsDUnitTest extends DistributedTestCase { |
| |
| static DistributedSystem ds; |
| static Cache cache; |
| // private static String tblName; |
| |
| private static String readFile(String filename) throws IOException { |
| // String lineSep = System.getProperty("\n"); |
| BufferedReader br = new BufferedReader(new FileReader(filename)); |
| String nextLine = ""; |
| StringBuffer sb = new StringBuffer(); |
| while ((nextLine = br.readLine()) != null) { |
| sb.append(nextLine); |
| // |
| // note: |
| // BufferedReader strips the EOL character. |
| // |
| // sb.append(lineSep); |
| } |
| getLogWriter().fine("***********\n " + sb); |
| return sb.toString(); |
| } |
| |
| public ExceptionsDUnitTest(String name) { |
| super(name); |
| } |
| |
| private static String modifyFile(String str) throws IOException { |
| String search = "<jndi-binding type=\"XAPooledDataSource\""; |
| String last_search = "</jndi-binding>"; |
| String newDB = "newDB_" + OSProcess.getId(); |
| String jndi_str = "<jndi-binding type=\"XAPooledDataSource\" jndi-name=\"XAPooledDataSource\" jdbc-driver-class=\"org.apache.derby.jdbc.EmbeddedDriver\" init-pool-size=\"5\" max-pool-size=\"5\" idle-timeout-seconds=\"600\" blocking-timeout-seconds=\"6\" login-timeout-seconds=\"2\" conn-pooled-datasource-class=\"org.apache.derby.jdbc.EmbeddedConnectionPoolDataSource\" xa-datasource-class=\"org.apache.derby.jdbc.EmbeddedXADataSource\" user-name=\"mitul\" password=\"83f0069202c571faf1ae6c42b4ad46030e4e31c17409e19a\" connection-url=\"jdbc:derby:"+newDB+";create=true\" >"; |
| String config_prop = "<config-property>" |
| + "<config-property-name>description</config-property-name>" |
| + "<config-property-type>java.lang.String</config-property-type>" |
| + "<config-property-value>hi</config-property-value>" |
| + "</config-property>" |
| + "<config-property>" |
| + "<config-property-name>user</config-property-name>" |
| + "<config-property-type>java.lang.String</config-property-type>" |
| + "<config-property-value>jeeves</config-property-value>" |
| + "</config-property>" |
| + "<config-property>" |
| + "<config-property-name>password</config-property-name>" |
| + "<config-property-type>java.lang.String</config-property-type>" |
| + "<config-property-value>83f0069202c571faf1ae6c42b4ad46030e4e31c17409e19a</config-property-value> " |
| + "</config-property>" + "<config-property>" |
| + "<config-property-name>databaseName</config-property-name>" |
| + "<config-property-type>java.lang.String</config-property-type>" |
| + "<config-property-value>"+newDB+"</config-property-value>" |
| + "</config-property>\n"; |
| String new_str = jndi_str + config_prop; |
| /* |
| * String new_str = " <jndi-binding type=\"XAPooledDataSource\" |
| * jndi-name=\"XAPooledDataSource\" |
| * jdbc-driver-class=\"org.apache.derby.jdbc.EmbeddedDriver\" |
| * init-pool-size=\"5\" max-pool-size=\"5\" idle-timeout-seconds=\"600\" |
| * blocking-timeout-seconds=\"6\" login-timeout-seconds=\"2\" |
| * conn-pooled-datasource-class=\"org.apache.derby.jdbc.EmbeddedConnectionPoolDataSource\" |
| * xa-datasource-class=\"org.apache.derby.jdbc.EmbeddedXADataSource\" |
| * user-name=\"mitul\" |
| * password=\"83f0069202c571faf1ae6c42b4ad46030e4e31c17409e19a\" |
| * connection-url=\"jdbc:derby:"+newDB+";create=true\" > <property |
| * key=\"description\" value=\"hi\"/> <property key=\"databaseName\" |
| * value=\""+newDB+"\"/> <property key=\"user\" value=\"mitul\"/> <property |
| * key=\"password\" |
| * value=\"83f0069202c571faf1ae6c42b4ad46030e4e31c17409e19a\"/>"; |
| */ |
| int n1 = str.indexOf(search); |
| getLogWriter().fine("Start Index = " + n1); |
| int n2 = str.indexOf(last_search, n1); |
| StringBuffer sbuff = new StringBuffer(str); |
| getLogWriter().fine("END Index = " + n2); |
| String modified_str = sbuff.replace(n1, n2, new_str).toString(); |
| return modified_str; |
| } |
| |
| public static void init() throws Exception { |
| Properties props = new Properties(); |
| int pid = OSProcess.getId(); |
| String path = File.createTempFile("dunit-cachejta_", ".xml").getAbsolutePath(); |
| /** * Return file as string and then modify the string accordingly ** */ |
| String file_as_str = readFile(TestUtil.getResourcePath(CacheUtils.class, "cachejta.xml")); |
| file_as_str = file_as_str.replaceAll("newDB", "newDB_" + pid); |
| String modified_file_str = modifyFile(file_as_str); |
| FileOutputStream fos = new FileOutputStream(path); |
| BufferedWriter wr = new BufferedWriter(new OutputStreamWriter(fos)); |
| wr.write(modified_file_str); |
| wr.flush(); |
| wr.close(); |
| props.setProperty("cache-xml-file", path); |
| // String tableName = ""; |
| // props.setProperty("mcast-port", "10339"); |
| try { |
| // ds = DistributedSystem.connect(props); |
| ds = (new ExceptionsDUnitTest("temp")).getSystem(props); |
| cache = CacheFactory.create(ds); |
| } |
| catch (Exception e) { |
| e.printStackTrace(System.err); |
| throw new Exception("" + e); |
| } |
| } |
| |
| public static Cache getCache() { |
| return cache; |
| } |
| |
| public static void startCache() { |
| try { |
| if (cache == null || cache.isClosed()) { |
| cache = CacheFactory.create(ds); |
| } |
| } |
| catch (Exception e) { |
| e.printStackTrace(); |
| } |
| } |
| |
| public static void closeCache() { |
| try { |
| if (cache != null && !cache.isClosed()) { |
| cache.close(); |
| } |
| } |
| catch (Exception e) { |
| e.printStackTrace(); |
| } |
| try { |
| if (ds != null) ds.disconnect(); |
| } |
| catch (Exception e) { |
| getLogWriter().fine("Error in disconnecting from Distributed System"); |
| } |
| } |
| |
| public void setUp() throws Exception { |
| super.setUp(); |
| Host host = Host.getHost(0); |
| VM vm0 = host.getVM(0); |
| vm0.invoke(ExceptionsDUnitTest.class, "init"); |
| } |
| |
| public void tearDown2() throws NamingException, SQLException { |
| Host host = Host.getHost(0); |
| VM vm0 = host.getVM(0); |
| vm0.invoke(ExceptionsDUnitTest.class, "closeCache"); |
| } |
| |
| public static void testBlockingTimeOut() { |
| Host host = Host.getHost(0); |
| VM vm0 = host.getVM(0); |
| vm0.invoke(ExceptionsDUnitTest.class, "runTest1"); |
| } |
| |
| public static void testLoginTimeOut() { |
| Host host = Host.getHost(0); |
| VM vm0 = host.getVM(0); |
| vm0.invoke(ExceptionsDUnitTest.class, "runTest2"); |
| } |
| |
| public static void testTransactionTimeOut() { |
| Host host = Host.getHost(0); |
| VM vm0 = host.getVM(0); |
| vm0.invoke(ExceptionsDUnitTest.class, "runTest3"); |
| } |
| |
| public static void runTest1() throws Exception { |
| boolean exceptionOccured = false; |
| try { |
| Context ctx = cache.getJNDIContext(); |
| DataSource ds1 = null; |
| DataSource ds2 = null; |
| ds1 = (DataSource) ctx.lookup("java:/XAPooledDataSource"); |
| ds2 = (DataSource) ctx.lookup("java:/SimpleDataSource"); |
| ds2.getConnection(); |
| ds1 = (DataSource) ctx.lookup("java:/XAPooledDataSource"); |
| UserTransaction utx = (UserTransaction) ctx |
| .lookup("java:/UserTransaction"); |
| utx.begin(); |
| ds1.getConnection(); |
| Thread.sleep(8000); |
| try { |
| utx.commit(); |
| } |
| catch (Exception e) { |
| exceptionOccured = true; |
| } |
| if (!exceptionOccured) |
| fail("Exception did not occur on commit although was supposed" |
| + "occur"); |
| } |
| catch (Exception e) { |
| getLogWriter().fine("Exception caught in runTest1 due to : " + e); |
| fail("failed in runTest1 due to " + e); |
| } |
| } |
| |
| public static void runTest2() throws Exception { |
| boolean exceptionOccured1 = false; |
| boolean exceptionOccured2 = false; |
| try { |
| Context ctx = cache.getJNDIContext(); |
| DataSource ds1 = null; |
| DataSource ds2 = null; |
| ds1 = (DataSource) ctx.lookup("java:/XAPooledDataSource"); |
| ds2 = (DataSource) ctx.lookup("java:/SimpleDataSource"); |
| ds2.getConnection(); |
| ds1.getConnection(); |
| ds1.getConnection(); |
| ds1.getConnection(); |
| ds1.getConnection(); |
| ds1.getConnection(); |
| UserTransaction utx = (UserTransaction) ctx |
| .lookup("java:/UserTransaction"); |
| utx.begin(); |
| try { |
| ds1.getConnection(); |
| Thread.sleep(8000); |
| } |
| catch (SQLException e) { |
| exceptionOccured1 = true; |
| } |
| try { |
| utx.commit(); |
| } |
| catch (Exception e) { |
| exceptionOccured2 = true; |
| } |
| if (!exceptionOccured1) |
| fail("Exception (Login-Time-Out)did not occur although was supposed" |
| + "to occur"); |
| if (exceptionOccured2) |
| fail("Exception did occur on commit, although was not supposed" |
| + "to occur"); |
| } |
| catch (Exception e) { |
| fail("failed in runTest2 due to " + e); |
| } |
| } |
| |
| public static void runTest3() throws Exception { |
| boolean exceptionOccured = false; |
| try { |
| Context ctx = cache.getJNDIContext(); |
| DataSource ds1 = null; |
| DataSource ds2 = null; |
| ds1 = (DataSource) ctx.lookup("java:/XAPooledDataSource"); |
| ds2 = (DataSource) ctx.lookup("java:/SimpleDataSource"); |
| ds2.getConnection(); |
| UserTransaction utx = (UserTransaction) ctx |
| .lookup("java:/UserTransaction"); |
| utx.begin(); |
| utx.setTransactionTimeout(2); |
| ds1.getConnection(); |
| Thread.sleep(4000); |
| try { |
| utx.commit(); |
| } |
| catch (Exception e) { |
| exceptionOccured = true; |
| } |
| if (!exceptionOccured) |
| fail("Exception (Transaction-Time-Out)did not occur although was supposed" |
| + "to occur"); |
| } |
| catch (Exception e) { |
| fail("failed in runTest3 due to " + e); |
| } |
| } |
| } |
