[jboss-svn-commits] JBL Code SVN: r7231 - in labs/jbossesb/trunk/product: install/message-store/sql/hsqldb samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/mockup

[jboss-svn-commits at lists.jboss.org]

Author: daniel.brum at jboss.com
Date: 2006-10-30 09:55:11 -0500 (Mon, 30 Oct 2006)
New Revision: 7231

Modified:
   labs/jbossesb/trunk/product/install/message-store/sql/hsqldb/create_database.sql
   labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/mockup/MockLauncher.java
Log:


Modified: labs/jbossesb/trunk/product/install/message-store/sql/hsqldb/create_database.sql
===================================================================
--- labs/jbossesb/trunk/product/install/message-store/sql/hsqldb/create_database.sql	2006-10-30 13:39:12 UTC (rev 7230)
+++ labs/jbossesb/trunk/product/install/message-store/sql/hsqldb/create_database.sql	2006-10-30 14:55:11 UTC (rev 7231)
@@ -5,8 +5,8 @@
 
 CREATE TABLE message
 (
-  uid text NOT NULL,
-  "type" text NOT NULL,
-  message text NOT NULL,
+  uid VARCHAR NOT NULL,
+  type VARCHAR NOT NULL,
+  message VARCHAR NOT NULL,
   CONSTRAINT pk_uid PRIMARY KEY (uid)
 );

Modified: labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/mockup/MockLauncher.java
===================================================================
--- labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/mockup/MockLauncher.java	2006-10-30 13:39:12 UTC (rev 7230)
+++ labs/jbossesb/trunk/product/samples/trailblazer2/esb/src/org/jboss/soa/esb/samples/trailblazer/mockup/MockLauncher.java	2006-10-30 14:55:11 UTC (rev 7231)
@@ -1,12 +1,20 @@
 package org.jboss.soa.esb.samples.trailblazer.mockup;
 
+import java.io.File;
+import java.sql.Connection;
+import java.sql.Statement;
+
 import org.apache.log4j.Logger;
+import org.jboss.internal.soa.esb.persistence.format.db.DBConnectionManager;
 import org.jboss.soa.esb.addressing.EPR;
+import org.jboss.soa.esb.common.Configuration;
 import org.jboss.soa.esb.couriers.Courier;
 import org.jboss.soa.esb.couriers.CourierFactory;
 import org.jboss.soa.esb.listeners.message.EsbListenerController;
 import org.jboss.soa.esb.message.Message;
 import org.jboss.soa.esb.message.format.MessageFactory;
+import org.jboss.soa.esb.messagestore.HsqldbUtil;
+import org.jboss.soa.esb.messagestore.TestUtil;
 
 public class MockLauncher {
 	
@@ -18,6 +26,7 @@
 	private static Logger _logger = Logger.getLogger(MockLauncher.class);
 	
 	public static void main (String args[]) throws Exception {
+		MockLauncher.runBeforeAllTests();
 		triggerListener("/home/dbrum/dev/jbossesb/product/samples/trailblazer2/esb/conf/loanbroker-esb.xml");
 		// give the listener time to register
 		Thread.sleep(2000);
@@ -28,6 +37,7 @@
 
 		EsbListenerController.State oS = _proc.getState();
 		System.out.println("Exit state = "+oS.toString());
+		MockLauncher.runAfterAllTests();
 	}
 	
 	private static void triggerListener(String paramFile) throws Exception {
@@ -48,5 +58,35 @@
 		courier.deliver(msg);
 		
 	}
+	
+protected static void runBeforeAllTests() throws Exception{		
+								
+		if (Configuration.getStoreDriver().equals("org.hsqldb.jdbcDriver")) {
+			HsqldbUtil.startHsqldb(TestUtil.getPrefix() + "build/hsqltestdb", "jbossesb");
+			//Get the registry-schema create scripts
+			String database = "hsqldb";
+			String sqlDir = TestUtil.getPrefix() + "install/message-store/sql/" + database + "/";
+			//Drop what is there now, if exists. We want to start fresh.				
+			String sqlCreateCmd    = TestUtil.readTextFile(new File(sqlDir + "create_database.sql"));
+			String sqlDropCmd      = TestUtil.readTextFile(new File(sqlDir + "drop_database.sql"));
+			
+			DBConnectionManager mgr = DBConnectionManager.getInstance();
+			Connection con = mgr.getConnection();
+			Statement stmnt = con.createStatement();
+			System.out.println("Dropping the schema if exist");
+			stmnt.execute(sqlDropCmd);
+			System.out.println("Creating the message store schema");
+			stmnt.execute(sqlCreateCmd);
+		}
+		
+	}
+	
+	private static void runAfterAllTests() throws Exception{
+		
+		if (Configuration.getStoreDriver().equals("org.hsqldb.jdbcDriver")) {
+			HsqldbUtil.stopHsqldb(Configuration.getStoreUrl(),
+					Configuration.getStoreUser(),Configuration.getStorePwd() );
+		}
+	}
 
 }