1 17 18 package org.sape.carbon.services.sql.connection.test; 19 20 import java.sql.Connection ; 21 22 import javax.sql.DataSource ; 23 24 import org.sape.carbon.core.component.Lookup; 25 import org.sape.carbon.services.sql.connection.ConnectionFactory; 26 27 import junit.extensions.ActiveTestSuite; 28 import junit.framework.Test; 29 import junit.framework.TestCase; 30 import junit.framework.TestSuite; 31 32 public class NamedDataSourceConnectionFactoryTest extends TestCase { 33 public NamedDataSourceConnectionFactoryTest(String name){ 34 super(name); 35 } 36 37 40 public void testObtainConnection() throws Exception { 41 Connection conn = null; 42 try { 43 ConnectionFactory connFac = 44 (ConnectionFactory) Lookup.getInstance().fetchComponent( 45 NAMED_DATASOURCE_CONNECTION_FACTORY); 46 conn = connFac.getConnection(); 47 super.assertNotNull("Null connection returned from DataSource at: "+ 48 "["+NAMED_DATASOURCE_CONNECTION_FACTORY+"]", conn); 49 } 50 finally{ 51 if(null != conn){ 52 conn.close(); 53 } 54 } 55 } 56 57 58 62 public void testOverriddenUserId() throws Exception { 63 Connection conn = null; 64 try { 65 DataSource ds = 66 (DataSource ) Lookup.getInstance().fetchComponent( 67 NAMED_DATASOURCE_CONNECTION_FACTORY); 68 conn = ds.getConnection("j2ee", "j2ee"); 69 super.assertNotNull("Null connection returned from DataSource at: "+ 70 "["+NAMED_DATASOURCE_CONNECTION_FACTORY+"]", conn); 71 } 72 finally{ 73 if(null != conn){ 74 conn.close(); 75 } 76 } 77 } 78 79 public static final String NAMED_DATASOURCE_CONNECTION_FACTORY = 80 "/sql/connection/test/NamedDataSourceConnectionFactory"; 81 82 86 public static Test suite() { 87 TestSuite masterSuite = new TestSuite(); 88 Test singleThreadedTests = getSingleThreadedTests(); 90 if (singleThreadedTests != null) { 91 masterSuite.addTest(singleThreadedTests); 92 } 93 Test multiThreadedTests = getMultiThreadedTests(); 95 if (multiThreadedTests != null) { 96 masterSuite.addTest(multiThreadedTests); 97 } 98 return masterSuite; 99 } 100 101 107 private static Test getSingleThreadedTests() { 108 TestSuite suite = new TestSuite(); 109 110 115 return suite; 121 } 122 123 128 private static Test getMultiThreadedTests() { 129 TestSuite suite = new ActiveTestSuite(); 130 131 137 138 return suite; 139 } 140 141 142 } 143 | Popular Tags |