Author: jeff.yuchang Date: 2010-05-31 03:36:33 -0400 (Mon, 31 May 2010) New Revision: 684 Removed: trunk/runtime/engine-assembly/src/main/resources/bpel-sql/derby.sql Modified: trunk/distribution/src/main/assembly/bin.xml trunk/distribution/src/main/release/db/bpel.properties trunk/distribution/src/main/release/db/jdbc/mysql.properties trunk/pom.xml trunk/runtime/engine-assembly/pom.xml trunk/runtime/engine-assembly/src/main/assembly/sar.xml trunk/runtime/engine-assembly/src/main/resources/bpel-sql/hsql.sql trunk/runtime/engine-assembly/src/main/resources/bpel-sql/mysql.sql trunk/runtime/engine-assembly/src/main/resources/bpel-sql/oracle.sql trunk/runtime/engine-assembly/src/main/resources/bpel-sql/postgres.sql trunk/runtime/engine-assembly/src/main/resources/bpel.properties trunk/runtime/engine/src/main/java/org/apache/ode/store/RiftSawProcessStore.java trunk/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/engine/ode/BPELEngineImpl.java trunk/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/ws/WebServiceClient.java Log: * Update the distribution to use the dao-jpa-hibernate as DAO implementation. * Update the DDL script, remove the derby DB, as we won't support them. * Use the Scheduler.execTransaction, instead of using UserTransaction. * Update it to Use the RiftSaw-ODE 2.1.0.CR1-SNAPSHOT. Modified: trunk/distribution/src/main/assembly/bin.xml =================================================================== --- trunk/distribution/src/main/assembly/bin.xml 2010-05-31 07:27:51 UTC (rev 683) +++ trunk/distribution/src/main/assembly/bin.xml 2010-05-31 07:36:33 UTC (rev 684) @@ -153,7 +153,7 @@ <include>mysql:mysql-connector-java</include> <include>org.apache.derby:derby</include> <include>org.apache.derby:derbytools</include> - <include>com.h2database:h2</include> + <include>com.h2database:h2</include> </includes> </dependencySet> Modified: trunk/distribution/src/main/release/db/bpel.properties =================================================================== --- trunk/distribution/src/main/release/db/bpel.properties 2010-05-31 07:27:51 UTC (rev 683) +++ trunk/distribution/src/main/release/db/bpel.properties 2010-05-31 07:36:33 UTC (rev 684) @@ -53,8 +53,10 @@ ## DAO Connection Factory class. ## uncomment the following for hibernate. -bpel.dao.factory=org.apache.ode.daohib.bpel.BpelDAOConnectionFactoryImpl +bpel.dao.factory=org.apache.ode.dao.jpa.hibernate.BpelDAOConnectionFactoryImpl +bpel.dao.factory.store=org.apache.ode.dao.jpa.hibernate.ConfStoreDAOConnectionFactoryImpl + ## Transaction Factory ## default is org.apache.ode.il.EmbeddedGeronimoFactory ## available alternatives are: @@ -86,6 +88,7 @@ #bpel.extension.bundles.validation = bpel.db.mode=EXTERNAL +db.emb.create=false bpel.db.ext.dataSource=java:BPELDB # if set to true will self-register BPEL endpoints upon deployment to a UDDI. # this uses the juddi-client-3.0.x and the uddi client config can be set in the uddi.xml Modified: trunk/distribution/src/main/release/db/jdbc/mysql.properties =================================================================== --- trunk/distribution/src/main/release/db/jdbc/mysql.properties 2010-05-31 07:27:51 UTC (rev 683) +++ trunk/distribution/src/main/release/db/jdbc/mysql.properties 2010-05-31 07:36:33 UTC (rev 684) @@ -1,5 +1,5 @@ connection.url=jdbc:mysql://localhost:3306/riftsaw driver=com.mysql.jdbc.Driver -username=riftsaw -password=riftsaw -dialect=org.hibernate.dialect.MySQLInnoDBDialect \ No newline at end of file +username=root +password= +dialect=org.hibernate.dialect.MySQLInnoDBDialect Modified: trunk/pom.xml =================================================================== --- trunk/pom.xml 2010-05-31 07:27:51 UTC (rev 683) +++ trunk/pom.xml 2010-05-31 07:36:33 UTC (rev 684) @@ -72,13 +72,13 @@ </profiles> <properties> - <riftsaw.ode.version>2.1.0-SNAPSHOT</riftsaw.ode.version> + <riftsaw.ode.version>2.1.0.CR1-SNAPSHOT</riftsaw.ode.version> <riftsaw.engine.version>2.0.1-SNAPSHOT</riftsaw.engine.version> <bpm.console.version>2.1-SNAPSHOT</bpm.console.version> <commons.logging.version>1.1.1</commons.logging.version> <junit.version>3.8.1</junit.version> - <jboss.version>5.1.0.GA</jboss.version> - <log4j.version>1.2.14</log4j.version> + <jboss.version>5.1.0.GA</jboss.version> + <log4j.version>1.2.14</log4j.version> <jbossesb.version>4.7</jbossesb.version> <wsdl4j.version>1.6.2</wsdl4j.version> <h2.version>1.2.124</h2.version> @@ -209,11 +209,16 @@ </dependency> <dependency> <groupId>org.jboss.soa.bpel</groupId> - <artifactId>riftsaw-dao-hibernate</artifactId> + <artifactId>riftsaw-dao-jpa</artifactId> <version>${riftsaw.ode.version}</version> </dependency> <dependency> <groupId>org.jboss.soa.bpel</groupId> + <artifactId>riftsaw-dao-jpa-hibernate</artifactId> + <version>${riftsaw.ode.version}</version> + </dependency> + <dependency> + <groupId>org.jboss.soa.bpel</groupId> <artifactId>riftsaw-jacob</artifactId> <version>${riftsaw.ode.version}</version> </dependency> Modified: trunk/runtime/engine/src/main/java/org/apache/ode/store/RiftSawProcessStore.java =================================================================== --- trunk/runtime/engine/src/main/java/org/apache/ode/store/RiftSawProcessStore.java 2010-05-31 07:27:51 UTC (rev 683) +++ trunk/runtime/engine/src/main/java/org/apache/ode/store/RiftSawProcessStore.java 2010-05-31 07:36:33 UTC (rev 684) @@ -18,28 +18,23 @@ package org.apache.ode.store; import java.util.ArrayList; -import java.util.HashMap; -import java.util.Iterator; -import java.util.List; -import java.util.Map; import java.util.regex.Matcher; import java.util.regex.Pattern; import javax.naming.InitialContext; -import javax.sql.DataSource; +import javax.transaction.TransactionManager; import javax.xml.namespace.QName; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.ode.bpel.compiler.api.CompilationException; -import org.apache.ode.bpel.engine.BpelProcess; -//import org.apache.ode.bpel.extension.ExtensionValidator; import org.apache.ode.bpel.iapi.ContextException; import org.apache.ode.bpel.iapi.EndpointReferenceContext; import org.apache.ode.bpel.iapi.ProcessState; import org.apache.ode.bpel.iapi.ProcessStoreEvent; -import org.apache.ode.il.config.OdeConfigProperties; -import org.apache.ode.store.ProcessStoreImpl.Callable; +import org.apache.ode.dao.store.ConfStoreDAOConnection; +import org.apache.ode.dao.store.ConfStoreDAOConnectionFactory; +import org.apache.ode.dao.store.DeploymentUnitDAO; import org.jboss.soa.bpel.deployer.BPELDeployer; import org.jboss.soa.bpel.deployer.BPELDeploymentUnit; @@ -48,10 +43,9 @@ private static final Log __log = LogFactory.getLog(RiftSawProcessStore.class); private DeployScheduler m_deployScheduler=new DeployScheduler(); - //private Map<QName, ExtensionValidator> m_extensionValidators = new HashMap<QName, ExtensionValidator>(); - - public RiftSawProcessStore(EndpointReferenceContext eprContext, DataSource ds, String persistenceType, OdeConfigProperties props, boolean createDatamodel) { - super(eprContext, ds, persistenceType, props, createDatamodel); + + public RiftSawProcessStore(EndpointReferenceContext eprContext, TransactionManager txm, ConfStoreDAOConnectionFactory cf) { + super(eprContext, txm, cf); } public void loadAll() { @@ -144,7 +138,7 @@ // Check for the deployment unit associated with the name boolean deploy=exec(new ProcessStoreImpl.Callable<Boolean>() { - public Boolean call(ConfStoreConnection conn) { + public Boolean call(ConfStoreDAOConnection conn) { boolean ret=false; DeploymentUnitDAO dudao = conn.getDeploymentUnit(bdu.getName()); if (dudao == null) Modified: trunk/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/engine/ode/BPELEngineImpl.java =================================================================== --- trunk/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/engine/ode/BPELEngineImpl.java 2010-05-31 07:27:51 UTC (rev 683) +++ trunk/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/engine/ode/BPELEngineImpl.java 2010-05-31 07:36:33 UTC (rev 684) @@ -20,7 +20,6 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.ode.bpel.common.evt.DebugBpelEventListener; -import org.apache.ode.bpel.dao.BpelDAOConnectionFactory; import org.apache.ode.bpel.engine.BpelManagementFacadeImpl; import org.apache.ode.bpel.engine.BpelServerImpl; import org.apache.ode.bpel.engine.CountLRUDehydrationPolicy; @@ -29,6 +28,8 @@ import org.apache.ode.bpel.iapi.*; import org.apache.ode.bpel.intercept.MessageExchangeInterceptor; import org.apache.ode.bpel.memdao.BpelDAOConnectionFactoryImpl; +import org.apache.ode.dao.bpel.BpelDAOConnectionFactory; +import org.apache.ode.dao.store.ConfStoreDAOConnectionFactory; import org.apache.ode.il.config.OdeConfigProperties; import org.apache.ode.il.dbutil.Database; import org.apache.ode.scheduler.simple.JdbcDelegate; @@ -65,6 +66,7 @@ protected OdeConfigProperties _odeConfig; protected TransactionManager _txMgr; protected BpelDAOConnectionFactory _daoCF; + protected ConfStoreDAOConnectionFactory _storeCF; protected Scheduler _scheduler; protected Database _db; protected ExecutorService _executorService; @@ -359,10 +361,19 @@ try { _daoCF.shutdown(); } catch (Throwable ex) { - __log.debug("DOA shutdown failed.", ex); + __log.debug("Bpel DAO shutdown failed.", ex); } finally { _daoCF = null; } + + if (_storeCF != null) + try { + _storeCF.shutdown(); + } catch (Throwable ex) { + __log.debug("Store DAO shutdown failed.", ex); + } finally { + _storeCF = null; + } if (_db != null) try { @@ -422,8 +433,9 @@ __log.debug("USING DAO: "+_odeConfig.getDAOConnectionFactory()); try { _daoCF = _db.createDaoCF(); + _storeCF = _db.createDaoStoreCF(); } catch (Exception ex) { - String errmsg = "DAO INSTANTIATION FAILED: "+_odeConfig.getDAOConnectionFactory(); + String errmsg = "DAO INSTANTIATION FAILED: "+_odeConfig.getDAOConnectionFactory() + " and " + _odeConfig.getDAOConfStoreConnectionFactory(); __log.error(errmsg, ex); throw new Exception(errmsg, ex); @@ -431,12 +443,12 @@ } protected void initProcessStore(EndpointReferenceContext eprContext) { - _store = createProcessStore(eprContext, _db.getDataSource()); + _store = createProcessStore(eprContext, _txMgr, _storeCF); _store.registerListener(new ProcessStoreListenerImpl()); } - protected ProcessStoreImpl createProcessStore(EndpointReferenceContext eprContext, DataSource ds) { - return new RiftSawProcessStore(eprContext, ds, _odeConfig.getDAOConnectionFactory(), _odeConfig, false); + protected ProcessStoreImpl createProcessStore(EndpointReferenceContext eprContext, TransactionManager txm, ConfStoreDAOConnectionFactory cf) { + return new RiftSawProcessStore(eprContext, txm, cf); } protected Scheduler createScheduler() { Modified: trunk/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/ws/WebServiceClient.java =================================================================== --- trunk/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/ws/WebServiceClient.java 2010-05-31 07:27:51 UTC (rev 683) +++ trunk/runtime/engine/src/main/java/org/jboss/soa/bpel/runtime/ws/WebServiceClient.java 2010-05-31 07:36:33 UTC (rev 684) @@ -110,14 +110,15 @@ boolean isTwoWay = mex.getMessageExchangePattern() == org.apache.ode.bpel.iapi.MessageExchange.MessageExchangePattern.REQUEST_RESPONSE; - + + final Callable executionCallable; + if(isTwoWay) { // Defer the invoke until the transaction commits. Scheduler scheduler = executionEnvironment.getScheduler(); - scheduler.registerSynchronizer( - new Scheduler.Synchronizer() - { + executionCallable = new TwoWayCallable(mex); + scheduler.registerSynchronizer(new Scheduler.Synchronizer() { public void afterCompletion(boolean success) { @@ -127,84 +128,9 @@ // The invocation must happen in a separate thread, holding on the afterCompletion // blocks other operations that could have been listed there as well. ExecutorService executorService = executionEnvironment.getExecutorService(); - executorService.submit(new Callable<Object>() { - public Object call() throws Exception { - - // TODO: If we use Scheduler.execTransaction - // we could probably bypass the UserTX - UserTransaction tx = getUserTransaction(); - tx.begin(); - - try - { - // Create SOAPMessage - SOAPMessage soapRequestMessage = MessageFactory.newInstance().createMessage(); - if(log.isDebugEnabled()) - log.debug( "ODE outbound message: \n" +DOMWriter.printNode(mex.getRequest().getMessage(), true) ); - - messageAdapter.createSoapRequest(soapRequestMessage, mex.getRequest(), mex.getOperation()); - - if (log.isDebugEnabled()) { - log.debug("Riftsaw soap request message: \n" + JavaUtils.getSoapMessageASString(soapRequestMessage)); - } - - // The actual WS invocation - Dispatch proxy = getDispatcher(port); - - try { - SOAPMessage soapResponseMessage = (SOAPMessage)proxy.invoke(soapRequestMessage); - - // Create ODE response - Message odeResponse = mex.createMessage(mex.getOperation().getOutput().getMessage().getQName()); - if(soapResponseMessage.getSOAPBody().hasFault()) - { - // fault handling - Document odeMsg = DOMUtils.newDocument(); - Element odeMsgEl = odeMsg.createElementNS(null, "message"); - odeMsg.appendChild(odeMsgEl); - - Fault fault = messageAdapter.parseSoapFault( - odeMsgEl, soapResponseMessage, mex.getOperation() - ); - - handleFault(mex, fault, soapResponseMessage.getSOAPBody().getFault(), odeMsgEl); - - } - else - { - messageAdapter.parseSoapResponse(odeResponse,soapResponseMessage,mex.getOperation()); - mex.reply(odeResponse); - } - - if(log.isDebugEnabled()) - log.debug( "ODE inbound message: \n" +DOMWriter.printNode(odeResponse.getMessage(), true) ); - - } catch(javax.xml.ws.soap.SOAPFaultException fe) { - - // fault handling - Document odeMsg = DOMUtils.newDocument(); - Element odeMsgEl = odeMsg.createElementNS(null, "message"); - odeMsg.appendChild(odeMsgEl); - - Fault fault=messageAdapter.parseSoapFault(odeMsgEl, fe.getFault(), - mex.getOperation()); - - handleFault(mex, fault, fe.getFault(), odeMsgEl); - } - - tx.commit(); - } - catch (Throwable e) - { - tx.rollback(); - log.error("WS invocation failed", e); - mex.replyWithFailure(MessageExchange.FailureType.COMMUNICATION_ERROR, e.getMessage(), null); - } - return null; - } - }); + executorService.submit(executionCallable); } - + public void beforeCompletion(){} } ); @@ -215,48 +141,138 @@ { // one-way invocation ExecutorService executorService = executionEnvironment.getExecutorService(); - executorService.submit( - new Callable<Object>() - { - public Object call() throws Exception - { + executionCallable = new OneWayCallable(mex); + executorService.submit(executionCallable); - UserTransaction tx = getUserTransaction(); - tx.begin(); - try - { - // Create SOAPMessage - SOAPMessage soapRequestMessage = MessageFactory.newInstance().createMessage(); - if(log.isDebugEnabled()) - log.debug( "ODE outbound message: \n" +DOMWriter.printNode(mex.getRequest().getMessage(), true) ); - - messageAdapter.createSoapRequest(soapRequestMessage, mex.getRequest(), mex.getOperation()); + mex.replyOneWayOk(); + } + } + + private class TwoWayCallable implements Callable<Object> { + + private PartnerRoleMessageExchange mex; + + public TwoWayCallable(PartnerRoleMessageExchange mex) { + this.mex = mex; + } + + public Object call() throws Exception { + + return executionEnvironment.getScheduler().execTransaction(new Callable<Object>(){ - if (log.isDebugEnabled()) { - log.debug("Riftsaw soap request message: \n" + JavaUtils.getSoapMessageASString(soapRequestMessage)); - } - - // The actual WS invocation - Dispatch proxy = getDispatcher(port); - proxy.invokeOneWay(soapRequestMessage); + public Object call() throws Exception { + try + { + // Create SOAPMessage + SOAPMessage soapRequestMessage = MessageFactory.newInstance().createMessage(); + if(log.isDebugEnabled()) + log.debug( "ODE outbound message: \n" +DOMWriter.printNode(mex.getRequest().getMessage(), true) ); + + messageAdapter.createSoapRequest(soapRequestMessage, mex.getRequest(), mex.getOperation()); + + if (log.isDebugEnabled()) { + log.debug("Riftsaw soap request message: \n" + JavaUtils.getSoapMessageASString(soapRequestMessage)); + } + + // The actual WS invocation + Dispatch proxy = getDispatcher(port); + + try { + SOAPMessage soapResponseMessage = (SOAPMessage)proxy.invoke(soapRequestMessage); - tx.commit(); - } - catch (Throwable e) - { - tx.rollback(); - log.error("WS invocation failed", e); - mex.replyWithFailure(MessageExchange.FailureType.COMMUNICATION_ERROR, e.getMessage(), null); - } + // Create ODE response + Message odeResponse = mex.createMessage(mex.getOperation().getOutput().getMessage().getQName()); + if(soapResponseMessage.getSOAPBody().hasFault()) + { + // fault handling + Document odeMsg = DOMUtils.newDocument(); + Element odeMsgEl = odeMsg.createElementNS(null, "message"); + odeMsg.appendChild(odeMsgEl); + + Fault fault = messageAdapter.parseSoapFault(odeMsgEl, soapResponseMessage, mex.getOperation()); - return null; - } - } - ); + handleFault(mex, fault, soapResponseMessage.getSOAPBody().getFault(), odeMsgEl); + + } + else + { + messageAdapter.parseSoapResponse(odeResponse,soapResponseMessage,mex.getOperation()); + mex.reply(odeResponse); + } - mex.replyOneWayOk(); - } + if(log.isDebugEnabled()) + log.debug( "ODE inbound message: \n" +DOMWriter.printNode(odeResponse.getMessage(), true) ); + + } catch(javax.xml.ws.soap.SOAPFaultException fe) { + + // fault handling + Document odeMsg = DOMUtils.newDocument(); + Element odeMsgEl = odeMsg.createElementNS(null, "message"); + odeMsg.appendChild(odeMsgEl); + + Fault fault=messageAdapter.parseSoapFault(odeMsgEl, fe.getFault(), + mex.getOperation()); + + handleFault(mex, fault, fe.getFault(), odeMsgEl); + } + } + catch (Throwable e) + { + log.error("WS invocation failed", e); + mex.replyWithFailure(MessageExchange.FailureType.COMMUNICATION_ERROR, e.getMessage(), null); + } + return null; + } + + }); + } + } + + + private class OneWayCallable implements Callable<Object> { + + private PartnerRoleMessageExchange mex; + + public OneWayCallable(PartnerRoleMessageExchange mex) { + this.mex = mex; + } + + public Object call() throws Exception { + return executionEnvironment.getScheduler().execTransaction(new Callable<Object>(){ + + public Object call() throws Exception { + try + { + // Create SOAPMessage + SOAPMessage soapRequestMessage = MessageFactory.newInstance().createMessage(); + if(log.isDebugEnabled()) + log.debug( "ODE outbound message: \n" +DOMWriter.printNode(mex.getRequest().getMessage(), true) ); + + messageAdapter.createSoapRequest(soapRequestMessage, mex.getRequest(), mex.getOperation()); + + if (log.isDebugEnabled()) { + log.debug("Riftsaw soap request message: \n" + JavaUtils.getSoapMessageASString(soapRequestMessage)); + } + + // The actual WS invocation + Dispatch proxy = getDispatcher(port); + proxy.invokeOneWay(soapRequestMessage); + + } + catch (Throwable e) + { + log.error("WS invocation failed", e); + mex.replyWithFailure(MessageExchange.FailureType.COMMUNICATION_ERROR, e.getMessage(), null); + } + + return null; + } + + }); + } + } + private void handleFault(PartnerRoleMessageExchange mex, Fault fault, SOAPFault soapFault, Element odeMsgEl) { Modified: trunk/runtime/engine-assembly/pom.xml =================================================================== --- trunk/runtime/engine-assembly/pom.xml 2010-05-31 07:27:51 UTC (rev 683) +++ trunk/runtime/engine-assembly/pom.xml 2010-05-31 07:36:33 UTC (rev 684) @@ -48,10 +48,14 @@ </dependency> <dependency> <groupId>org.jboss.soa.bpel</groupId> - <artifactId>riftsaw-dao-hibernate</artifactId> + <artifactId>riftsaw-dao-jpa</artifactId> </dependency> <dependency> <groupId>org.jboss.soa.bpel</groupId> + <artifactId>riftsaw-dao-jpa-hibernate</artifactId> + </dependency> + <dependency> + <groupId>org.jboss.soa.bpel</groupId> <artifactId>riftsaw-jacob</artifactId> </dependency> <dependency> Modified: trunk/runtime/engine-assembly/src/main/assembly/sar.xml =================================================================== --- trunk/runtime/engine-assembly/src/main/assembly/sar.xml 2010-05-31 07:27:51 UTC (rev 683) +++ trunk/runtime/engine-assembly/src/main/assembly/sar.xml 2010-05-31 07:36:33 UTC (rev 684) @@ -53,7 +53,9 @@ <include>org.jboss.soa.bpel:riftsaw-bpel-runtime</include> <include>org.jboss.soa.bpel:riftsaw-bpel-schemas</include> <include>org.jboss.soa.bpel:riftsaw-bpel-store</include> - <include>org.jboss.soa.bpel:riftsaw-dao-hibernate</include> + <include>org.jboss.soa.bpel:riftsaw-dao-jpa</include> + <include>org.jboss.soa.bpel:riftsaw-dao-jpa-hibernate</include> + <!--include>org.jboss.soa.bpel:riftsaw-dao-hibernate</include--> <include>org.jboss.soa.bpel.runtime:riftsaw-engine</include> <include>org.jboss.soa.bpel:riftsaw-jacob</include> <include>org.jboss.soa.bpel:riftsaw-scheduler-simple</include> Deleted: trunk/runtime/engine-assembly/src/main/resources/bpel-sql/derby.sql =================================================================== --- trunk/runtime/engine-assembly/src/main/resources/bpel-sql/derby.sql 2010-05-31 07:27:51 UTC (rev 683) +++ trunk/runtime/engine-assembly/src/main/resources/bpel-sql/derby.sql 2010-05-31 07:36:33 UTC (rev 684) @@ -1,54 +0,0 @@ --- Apache ODE - SimpleScheduler Database Schema --- --- Apache Derby scripts by Maciej Szefler. --- --- - -CREATE TABLE ode_job ( - jobid CHAR(64) NOT NULL DEFAULT '', - ts BIGINT NOT NULL DEFAULT 0, - nodeid char(64), - scheduled int NOT NULL DEFAULT 0, - transacted int NOT NULL DEFAULT 0, - details blob(4096), - PRIMARY KEY(jobid)); - -CREATE INDEX IDX_ODE_JOB_TS ON ode_job(ts); -CREATE INDEX IDX_ODE_JOB_NODEID ON ode_job(nodeid); - - -create table ODE_SCHEMA_VERSION(VERSION integer); -insert into ODE_SCHEMA_VERSION values (5); - -create table BPEL_ACTIVITY_RECOVERY (ID bigint not null, PIID bigint, AID bigint, CHANNEL varchar(255), REASON varchar(255), DATE_TIME timestamp, DETAILS blob(2G), ACTIONS varchar(255), RETRIES integer, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_CORRELATION_PROP (ID bigint not null, NAME varchar(255), NAMESPACE varchar(255), VALUE varchar(255), CORR_SET_ID bigint, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_CORRELATION_SET (ID bigint not null, VALUE varchar(255), CORR_SET_NAME varchar(255), SCOPE_ID bigint, PIID bigint, PROCESS_ID bigint, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_CORRELATOR (ID bigint not null, CID varchar(255), PROCESS_ID bigint, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_CORRELATOR_MESSAGE_CKEY (ID bigint not null, CKEY varchar(255), CORRELATOR_MESSAGE_ID bigint, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_EVENT (ID bigint not null, IID bigint, PID bigint, TSTAMP timestamp, TYPE varchar(255), DETAIL clob(32000), DATA blob(2G), SID bigint, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_FAULT (ID bigint not null, FAULTNAME varchar(255), DATA blob(2G), EXPLANATION varchar(4000), LINE_NUM integer, AID integer, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_INSTANCE (ID bigint not null, INSTANTIATING_CORRELATOR bigint, FAULT bigint, JACOB_STATE_DATA blob(2G), PREVIOUS_STATE smallint, PROCESS_ID bigint, STATE smallint, LAST_ACTIVE_DT timestamp, SEQUENCE bigint, FAILURE_COUNT integer, FAILURE_DT timestamp, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_MESSAGE (ID bigint not null, MEX bigint, TYPE varchar(255), MESSAGE_DATA blob(2G), MESSAGE_HEADER blob(2G), INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_MESSAGE_EXCHANGE (ID bigint not null, PORT_TYPE varchar(255), CHANNEL_NAME varchar(255), CLIENTKEY varchar(255), ENDPOINT blob(2G), CALLBACK_ENDPOINT blob(2G), REQUEST bigint, RESPONSE bigint, INSERT_DT timestamp, OPERATION varchar(255), STATE varchar(255), PROCESS bigint, PIID bigint, DIR char(1), PLINK_MODELID integer, PATTERN varchar(255), CORR_STATUS varchar(255), FAULT_TYPE varchar(255), FAULT_EXPL varchar(255), CALLEE varchar(255), PARTNERLINK bigint, PIPED_ID varchar(255), SUBSCRIBER_COUNT integer, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_MEX_PROPS (MEX bigint not null, VALUE varchar(8000), NAME varchar(255) not null, primary key (MEX, NAME)); -create table BPEL_PLINK_VAL (ID bigint not null, PARTNER_LINK varchar(100) not null, PARTNERROLE varchar(100), MYROLE_EPR_DATA blob(2G), PARTNERROLE_EPR_DATA blob(2G), PROCESS bigint, SCOPE bigint, SVCNAME varchar(255), MYROLE varchar(100), MODELID integer, MYSESSIONID varchar(255), PARTNERSESSIONID varchar(255), INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_PROCESS (ID bigint not null, PROCID varchar(255) not null unique, deployer varchar(255), deploydate timestamp, type_name varchar(255), type_ns varchar(255), version bigint, ACTIVE_ smallint, guid varchar(255), INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_SCOPE (ID bigint not null, PIID bigint, PARENT_SCOPE_ID bigint, STATE varchar(255) not null, NAME varchar(255) not null, MODELID integer, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_SELECTORS (ID bigint not null, PIID bigint not null, SELGRPID varchar(255) not null, IDX integer not null, CORRELATION_KEY varchar(255) not null, PROC_TYPE varchar(255) not null, ROUTE_POLICY varchar(255), CORRELATOR bigint not null, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID), unique (CORRELATION_KEY, CORRELATOR)); -create table BPEL_UNMATCHED (ID bigint not null, MEX bigint, CORRELATION_KEY varchar(255), CORRELATOR bigint not null, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_XML_DATA (ID bigint not null, DATA blob(2G), NAME varchar(255) not null, SCOPE_ID bigint, PIID bigint, IS_SIMPLE_TYPE smallint, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table VAR_PROPERTY (ID bigint not null, XML_DATA_ID bigint, PROP_VALUE varchar(255), PROP_NAME varchar(255) not null, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create index IDX_CORRELATOR_CID on BPEL_CORRELATOR (CID); -create index IDX_BPEL_CORRELATOR_MESSAGE_CKEY on BPEL_CORRELATOR_MESSAGE_CKEY (CKEY); -create index IDX_SELECTOR_CORRELATOR on BPEL_SELECTORS (CORRELATOR); -create index IDX_SELECTOR_CKEY on BPEL_SELECTORS (CORRELATION_KEY); -create index IDX_SELECTOR_SELGRPID on BPEL_SELECTORS (SELGRPID); -create index IDX_UNMATCHED_CKEY on BPEL_UNMATCHED (CORRELATION_KEY); -create index IDX_UNMATCHED_CORRELATOR on BPEL_UNMATCHED (CORRELATOR); -create table hibernate_unique_key ( next_hi integer ); -insert into hibernate_unique_key values ( 0 ); - -create table STORE_DU (NAME varchar(255) not null, deployer varchar(255), DEPLOYDT timestamp, DIR varchar(255), primary key (NAME)); -create table STORE_PROCESS (PID varchar(255) not null, DU varchar(255), TYPE varchar(255), version bigint, STATE varchar(255), primary key (PID)); -create table STORE_PROCESS_PROP (propId varchar(255) not null, value varchar(255), name varchar(255) not null, primary key (propId, name)); -create table STORE_VERSIONS (ID integer not null, VERSION bigint, primary key (ID)); Modified: trunk/runtime/engine-assembly/src/main/resources/bpel-sql/hsql.sql =================================================================== --- trunk/runtime/engine-assembly/src/main/resources/bpel-sql/hsql.sql 2010-05-31 07:27:51 UTC (rev 683) +++ trunk/runtime/engine-assembly/src/main/resources/bpel-sql/hsql.sql 2010-05-31 07:36:33 UTC (rev 684) @@ -1,49 +1,250 @@ create table ODE_SCHEMA_VERSION(VERSION integer); -insert into ODE_SCHEMA_VERSION values (5); +insert into ODE_SCHEMA_VERSION values (6); + -- Apache ODE - SimpleScheduler Database Schema -- --- Apache Derby scripts by Maciej Szefler. +-- MySQL scripts by Maciej Szefler. -- -- - CREATE TABLE ode_job ( jobid CHAR(64) NOT NULL DEFAULT '', ts BIGINT NOT NULL DEFAULT 0, nodeid char(64), scheduled int NOT NULL DEFAULT 0, transacted int NOT NULL DEFAULT 0, - details varbinary, + + instanceId BIGINT, + mexId varchar(255), + processId varchar(255), + type varchar(255), + channel varchar(255), + correlatorId varchar(255), + correlationKeySet varchar(255), + retryCount int, + inMem int, + detailsExt varbinary, + PRIMARY KEY(jobid)); CREATE INDEX IDX_ODE_JOB_TS ON ode_job(ts); CREATE INDEX IDX_ODE_JOB_NODEID ON ode_job(nodeid); -create table BPEL_ACTIVITY_RECOVERY (ID bigint not null, PIID bigint, AID bigint, CHANNEL varchar(255), REASON varchar(255), DATE_TIME timestamp, DETAILS varbinary, ACTIONS varchar(255), RETRIES integer, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_CORRELATION_PROP (ID bigint not null, NAME varchar(255), NAMESPACE varchar(255), VALUE varchar(255), CORR_SET_ID bigint, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_CORRELATION_SET (ID bigint not null, VALUE varchar(255), CORR_SET_NAME varchar(255), SCOPE_ID bigint, PIID bigint, PROCESS_ID bigint, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_CORRELATOR (ID bigint not null, CID varchar(255), PROCESS_ID bigint, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_CORRELATOR_MESSAGE_CKEY (ID bigint not null, CKEY varchar(255), CORRELATOR_MESSAGE_ID bigint, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_EVENT (ID bigint not null, IID bigint, PID bigint, TSTAMP timestamp, TYPE varchar(255), DETAIL longvarchar, DATA varbinary, SID bigint, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_FAULT (ID bigint not null, FAULTNAME varchar(255), DATA varbinary, EXPLANATION varchar(4000), LINE_NUM integer, AID integer, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_INSTANCE (ID bigint not null, INSTANTIATING_CORRELATOR bigint, FAULT bigint, JACOB_STATE_DATA varbinary, PREVIOUS_STATE smallint, PROCESS_ID bigint, STATE smallint, LAST_ACTIVE_DT timestamp, SEQUENCE bigint, FAILURE_COUNT integer, FAILURE_DT timestamp, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_MESSAGE (ID bigint not null, MEX bigint, TYPE varchar(255), MESSAGE_DATA varbinary, MESSAGE_HEADER varbinary, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_MESSAGE_EXCHANGE (ID bigint not null, PORT_TYPE varchar(255), CHANNEL_NAME varchar(255), CLIENTKEY varchar(255), ENDPOINT varbinary, CALLBACK_ENDPOINT varbinary, REQUEST bigint, RESPONSE bigint, INSERT_DT timestamp, OPERATION varchar(255), STATE varchar(255), PROCESS bigint, PIID bigint, DIR char(1), PLINK_MODELID integer, PATTERN varchar(255), CORR_STATUS varchar(255), FAULT_TYPE varchar(255), FAULT_EXPL varchar(255), CALLEE varchar(255), PARTNERLINK bigint, PIPED_ID varchar(255), SUBSCRIBER_COUNT integer, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_MEX_PROPS (MEX bigint not null, VALUE varchar(8000), NAME varchar(255) not null, primary key (MEX, NAME)); -create table BPEL_PLINK_VAL (ID bigint not null, PARTNER_LINK varchar(100) not null, PARTNERROLE varchar(100), MYROLE_EPR_DATA varbinary, PARTNERROLE_EPR_DATA varbinary, PROCESS bigint, SCOPE bigint, SVCNAME varchar(255), MYROLE varchar(100), MODELID integer, MYSESSIONID varchar(255), PARTNERSESSIONID varchar(255), INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_PROCESS (ID bigint not null, PROCID varchar(255) not null, deployer varchar(255), deploydate timestamp, type_name varchar(255), type_ns varchar(255), version bigint, ACTIVE_ bit, guid varchar(255), INSERT_TIME timestamp, MLOCK integer not null, primary key (ID), unique (PROCID)); -create table BPEL_SCOPE (ID bigint not null, PIID bigint, PARENT_SCOPE_ID bigint, STATE varchar(255) not null, NAME varchar(255) not null, MODELID integer, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_SELECTORS (ID bigint not null, PIID bigint not null, SELGRPID varchar(255) not null, IDX integer not null, CORRELATION_KEY varchar(255) not null, PROC_TYPE varchar(255) not null, ROUTE_POLICY varchar(255), CORRELATOR bigint not null, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID), unique (CORRELATION_KEY, CORRELATOR)); -create table BPEL_UNMATCHED (ID bigint not null, MEX bigint, CORRELATION_KEY varchar(255), CORRELATOR bigint not null, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table BPEL_XML_DATA (ID bigint not null, DATA varbinary, NAME varchar(255) not null, SCOPE_ID bigint, PIID bigint, IS_SIMPLE_TYPE bit, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create table VAR_PROPERTY (ID bigint not null, XML_DATA_ID bigint, PROP_VALUE varchar(255), PROP_NAME varchar(255) not null, INSERT_TIME timestamp, MLOCK integer not null, primary key (ID)); -create index IDX_CORRELATOR_CID on BPEL_CORRELATOR (CID); -create index IDX_BPEL_CORRELATOR_MESSAGE_CKEY on BPEL_CORRELATOR_MESSAGE_CKEY (CKEY); -create index IDX_SELECTOR_CORRELATOR on BPEL_SELECTORS (CORRELATOR); -create index IDX_SELECTOR_CKEY on BPEL_SELECTORS (CORRELATION_KEY); -create index IDX_SELECTOR_SELGRPID on BPEL_SELECTORS (SELGRPID); -create index IDX_UNMATCHED_CKEY on BPEL_UNMATCHED (CORRELATION_KEY); -create index IDX_UNMATCHED_CORRELATOR on BPEL_UNMATCHED (CORRELATOR); + create table ODE_ACTIVITY_RECOVERY ( + ID bigint generated by default as identity, + ACTIONS varchar(255), + ACTIVITY_ID bigint, + CHANNEL varchar(255), + DATE_TIME timestamp, + DETAILS clob, + INSTANCE_ID bigint, + REASON varchar(255), + RETRIES integer, + primary key (ID) + ); -create sequence hibernate_seqhilo; + create table ODE_CORRELATION_SET ( + CORRELATION_SET_ID bigint generated by default as identity, + CORRELATION_KEY varchar(255), + NAME varchar(255), + SCOPE_ID bigint, + primary key (CORRELATION_SET_ID) + ); + create table ODE_CORRELATOR ( + CORRELATOR_ID bigint generated by default as identity, + CORRELATOR_KEY varchar(255), + PROC_ID bigint, + primary key (CORRELATOR_ID) + ); + + create table ODE_CORSET_PROP ( + ID bigint generated by default as identity, + CORRSET_ID bigint, + PROP_KEY varchar(255), + PROP_VALUE varchar(255), + primary key (ID) + ); + + create table ODE_EVENT ( + EVENT_ID bigint generated by default as identity, + DETAIL varchar(255), + DATA blob, + SCOPE_ID bigint, + TSTAMP timestamp, + TYPE varchar(255), + INSTANCE_ID bigint, + PROCESS_ID bigint, + primary key (EVENT_ID) + ); + + create table ODE_FAULT ( + FAULT_ID bigint generated by default as identity, + ACTIVITY_ID integer, + DATA clob, + MESSAGE varchar(4000), + LINE_NUMBER integer, + NAME varchar(255), + primary key (FAULT_ID) + ); + + create table ODE_MESSAGE ( + MESSAGE_ID bigint generated by default as identity, + DATA clob, + HEADER clob, + TYPE varchar(255), + MESSAGE_EXCHANGE_ID varchar(255), + primary key (MESSAGE_ID) + ); + + create table ODE_MESSAGE_EXCHANGE ( + MESSAGE_EXCHANGE_ID varchar(255) not null, + CALLEE varchar(255), + CHANNEL varchar(255), + CORRELATION_ID varchar(255), + CORRELATION_KEYS varchar(255), + CORRELATION_STATUS varchar(255), + CREATE_TIME timestamp, + DIRECTION char(255), + EPR clob, + FAULT varchar(255), + FAULT_EXPLANATION varchar(255), + OPERATION varchar(255), + PARTNER_LINK_MODEL_ID integer, + PATTERN varchar(255), + PIPED_ID varchar(255), + PORT_TYPE varchar(255), + PROPAGATE_TRANS boolean, + STATUS varchar(255), + SUBSCRIBER_COUNT integer, + CORR_ID bigint, + PARTNER_LINK_ID bigint, + PROCESS_ID bigint, + PROCESS_INSTANCE_ID bigint, + REQUEST_MESSAGE_ID bigint, + RESPONSE_MESSAGE_ID bigint, + primary key (MESSAGE_EXCHANGE_ID) + ); + + create table ODE_MESSAGE_ROUTE ( + MESSAGE_ROUTE_ID bigint generated by default as identity, + CORRELATION_KEY varchar(255), + GROUP_ID varchar(255), + ROUTE_INDEX integer, + PROCESS_INSTANCE_ID bigint, + ROUTE_POLICY varchar(16), + CORR_ID bigint, + primary key (MESSAGE_ROUTE_ID) + ); + + create table ODE_MEX_PROP ( + ID bigint generated by default as identity, + MEX_ID varchar(255), + PROP_KEY varchar(255), + PROP_VALUE varchar(2000), + primary key (ID) + ); + + create table ODE_PARTNER_LINK ( + PARTNER_LINK_ID bigint generated by default as identity, + MY_EPR clob, + MY_ROLE_NAME varchar(255), + MY_ROLE_SERVICE_NAME varchar(255), + MY_SESSION_ID varchar(255), + PARTNER_EPR clob, + PARTNER_LINK_MODEL_ID integer, + PARTNER_LINK_NAME varchar(255), + PARTNER_ROLE_NAME varchar(255), + PARTNER_SESSION_ID varchar(255), + SCOPE_ID bigint, + primary key (PARTNER_LINK_ID) + ); + + create table ODE_PROCESS ( + ID bigint generated by default as identity, + GUID varchar(255), + PROCESS_ID varchar(255), + PROCESS_TYPE varchar(255), + VERSION bigint, + primary key (ID) + ); + + create table ODE_PROCESS_INSTANCE ( + ID bigint generated by default as identity, + DATE_CREATED timestamp, + EXECUTION_STATE blob, + FAULT_ID bigint, + LAST_ACTIVE_TIME timestamp, + LAST_RECOVERY_DATE timestamp, + PREVIOUS_STATE smallint, + SEQUENCE bigint, + INSTANCE_STATE smallint, + INSTANTIATING_CORRELATOR_ID bigint, + PROCESS_ID bigint, + ROOT_SCOPE_ID bigint, + primary key (ID) + ); + + create table ODE_SCOPE ( + SCOPE_ID bigint generated by default as identity, + MODEL_ID integer, + SCOPE_NAME varchar(255), + SCOPE_STATE varchar(255), + PARENT_SCOPE_ID bigint, + PROCESS_INSTANCE_ID bigint, + primary key (SCOPE_ID) + ); + + create table ODE_XML_DATA ( + XML_DATA_ID bigint generated by default as identity, + DATA clob, + IS_SIMPLE_TYPE boolean, + NAME varchar(255), + SCOPE_ID bigint, + primary key (XML_DATA_ID) + ); + + create table ODE_XML_DATA_PROP ( + ID bigint generated by default as identity, + XML_DATA_ID bigint, + PROP_KEY varchar(255), + PROP_VALUE varchar(255), + primary key (ID) + ); + + create table STORE_DU ( + NAME varchar(255) not null, + DEPLOYDT timestamp, + DEPLOYER varchar(255), + DIR varchar(255), + primary key (NAME) + ); + + create table STORE_PROCESS ( + PID varchar(255) not null, + STATE varchar(255), + TYPE varchar(255), + VERSION bigint, + DU varchar(255), + primary key (PID) + ); + + create table STORE_PROCESS_PROP ( + ID bigint generated by default as identity, + PROP_KEY varchar(255), + PROP_VAL varchar(255), + primary key (ID) + ); + + create table STORE_PROC_TO_PROP ( + STORE_PROCESS_PID varchar(255) not null, + STORE_PROPERTY_ID bigint not null, + primary key (STORE_PROCESS_PID, STORE_PROPERTY_ID), + unique (STORE_PROPERTY_ID) + ); + + create table STORE_VERSIONS ( + ID bigint generated by default as identity, + VERSION bigint, + primary key (ID) + ); \ No newline at end of file Modified: trunk/runtime/engine-assembly/src/main/resources/bpel-sql/mysql.sql =================================================================== --- trunk/runtime/engine-assembly/src/main/resources/bpel-sql/mysql.sql 2010-05-31 07:27:51 UTC (rev 683) +++ trunk/runtime/engine-assembly/src/main/resources/bpel-sql/mysql.sql 2010-05-31 07:36:33 UTC (rev 684) @@ -1,5 +1,25 @@ +-- +-- 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. +-- + create table ODE_SCHEMA_VERSION(VERSION integer); -insert into ODE_SCHEMA_VERSION values (5); +insert into ODE_SCHEMA_VERSION values (6); + -- Apache ODE - SimpleScheduler Database Schema -- -- MySQL scripts by Maciej Szefler. @@ -13,7 +33,18 @@ nodeid char(64) NULL, scheduled int NOT NULL DEFAULT 0, transacted int NOT NULL DEFAULT 0, - details blob(4096) NULL, + + instanceId BIGINT, + mexId varchar(255), + processId varchar(255), + type varchar(255), + channel varchar(255), + correlatorId varchar(255), + correlationKeySet varchar(255), + retryCount int, + inMem int, + detailsExt blob(4096), + PRIMARY KEY(jobid), INDEX IDX_ODE_JOB_TS(ts), INDEX IDX_ODE_JOB_NODEID(nodeid) @@ -22,52 +53,222 @@ COMMIT; -create table BPEL_ACTIVITY_RECOVERY (ID bigint not null, PIID bigint, AID bigint, CHANNEL varchar(255), REASON varchar(255), DATE_TIME datetime, DETAILS blob, ACTIONS varchar(255), RETRIES integer, INSERT_TIME datetime, MLOCK integer not null, primary key (ID)); -create table BPEL_CORRELATION_PROP (ID bigint not null, NAME varchar(255), NAMESPACE varchar(255), VALUE varchar(255), CORR_SET_ID bigint, INSERT_TIME datetime, MLOCK integer not null, primary key (ID)); -create table BPEL_CORRELATION_SET (ID bigint not null, VALUE varchar(255), CORR_SET_NAME varchar(255), SCOPE_ID bigint, PIID bigint, PROCESS_ID bigint, INSERT_TIME datetime, MLOCK integer not null, primary key (ID)); -create table BPEL_CORRELATOR (ID bigint not null, CID varchar(255), PROCESS_ID bigint, INSERT_TIME datetime, MLOCK integer not null, primary key (ID)); -create table BPEL_CORRELATOR_MESSAGE_CKEY (ID bigint not null, CKEY varchar(255), CORRELATOR_MESSAGE_ID bigint, INSERT_TIME datetime, MLOCK integer not null, primary key (ID)); -create table BPEL_EVENT (ID bigint not null, IID bigint, PID bigint, TSTAMP datetime, TYPE varchar(255), DETAIL longtext, DATA blob, SID bigint, INSERT_TIME datetime, MLOCK integer not null, primary key (ID)); -create table BPEL_FAULT (ID bigint not null, FAULTNAME varchar(255), DATA blob, EXPLANATION varchar(4000), LINE_NUM integer, AID integer, INSERT_TIME datetime, MLOCK integer not null, primary key (ID)); -create table BPEL_INSTANCE (ID bigint not null, INSTANTIATING_CORRELATOR bigint, FAULT bigint, JACOB_STATE_DATA blob, PREVIOUS_STATE smallint, PROCESS_ID bigint, STATE smallint, LAST_ACTIVE_DT datetime, SEQUENCE bigint, FAILURE_COUNT integer, FAILURE_DT datetime, INSERT_TIME datetime, MLOCK integer not null, primary key (ID)); -create table BPEL_MESSAGE (ID bigint not null, MEX bigint, TYPE varchar(255), MESSAGE_DATA blob, MESSAGE_HEADER blob, INSERT_TIME datetime, MLOCK integer not null, primary key (ID)); -create table BPEL_MESSAGE_EXCHANGE (ID bigint not null, PORT_TYPE varchar(255), CHANNEL_NAME varchar(255), CLIENTKEY varchar(255), ENDPOINT blob, CALLBACK_ENDPOINT blob, REQUEST bigint, RESPONSE bigint, INSERT_DT datetime, OPERATION varchar(255), STATE varchar(255), PROCESS bigint, PIID bigint, DIR char(1), PLINK_MODELID integer, PATTERN varchar(255), CORR_STATUS varchar(255), FAULT_TYPE varchar(255), FAULT_EXPL varchar(255), CALLEE varchar(255), PARTNERLINK bigint, PIPED_ID varchar(255), SUBSCRIBER_COUNT integer, INSERT_TIME datetime, MLOCK integer not null, primary key (ID)); -create table BPEL_MEX_PROPS (MEX bigint not null, VALUE varchar(8000), NAME varchar(255) not null, primary key (MEX, NAME)); -create table BPEL_PLINK_VAL (ID bigint not null, PARTNER_LINK varchar(100) not null, PARTNERROLE varchar(100), MYROLE_EPR_DATA blob, PARTNERROLE_EPR_DATA blob, PROCESS bigint, SCOPE bigint, SVCNAME varchar(255), MYROLE varchar(100), MODELID integer, MYSESSIONID varchar(255), PARTNERSESSIONID varchar(255), INSERT_TIME datetime, MLOCK integer not null, primary key (ID)); -create table BPEL_PROCESS (ID bigint not null, PROCID varchar(255) not null unique, deployer varchar(255), deploydate datetime, type_name varchar(255), type_ns varchar(255), version bigint, ACTIVE_ bit, guid varchar(255), INSERT_TIME datetime, MLOCK integer not null, primary key (ID)); -create table BPEL_SCOPE (ID bigint not null, PIID bigint, PARENT_SCOPE_ID bigint, STATE varchar(255) not null, NAME varchar(255) not null, MODELID integer, INSERT_TIME datetime, MLOCK integer not null, primary key (ID)); -create table BPEL_SELECTORS (ID bigint not null, PIID bigint not null, SELGRPID varchar(255) not null, IDX integer not null, CORRELATION_KEY varchar(255) not null, PROC_TYPE varchar(255) not null, ROUTE_POLICY varchar(255), CORRELATOR bigint not null, INSERT_TIME datetime, MLOCK integer not null, primary key (ID), unique (CORRELATION_KEY, CORRELATOR)); -create table BPEL_UNMATCHED (ID bigint not null, MEX bigint, CORRELATION_KEY varchar(255), CORRELATOR bigint not null, INSERT_TIME datetime, MLOCK integer not null, primary key (ID)); -create table BPEL_XML_DATA (ID bigint not null, DATA blob, NAME varchar(255) not null, SCOPE_ID bigint, PIID bigint, IS_SIMPLE_TYPE bit, INSERT_TIME datetime, MLOCK integer not null, primary key (ID)); -create table VAR_PROPERTY (ID bigint not null, XML_DATA_ID bigint, PROP_VALUE varchar(255), PROP_NAME varchar(255) not null, INSERT_TIME datetime, MLOCK integer not null, primary key (ID)); + create table ODE_ACTIVITY_RECOVERY ( + ID bigint not null auto_increment, + ACTIONS varchar(255), + ACTIVITY_ID bigint, + CHANNEL varchar(255), + DATE_TIME datetime, + DETAILS longtext, + INSTANCE_ID bigint, + REASON varchar(255), + RETRIES integer, + primary key (ID) + ) type=InnoDB; ---create indexes + create table ODE_CORRELATION_SET ( + CORRELATION_SET_ID bigint not null auto_increment, + CORRELATION_KEY varchar(255), + NAME varchar(255), + SCOPE_ID bigint, + primary key (CORRELATION_SET_ID) + ) type=InnoDB; -create index IDX_XMLDATA_IID on BPEL_XML_DATA (PIID) ; -create index IDX_XMLDATA_SID on BPEL_XML_DATA (SCOPE_ID) ; -create index IDX_XMLDATA_NAME on BPEL_XML_DATA (NAME) ; -create index IDX_XMLDATA_NAME_SID on BPEL_XML_DATA (NAME, SCOPE_ID) ; -create index IDX_EVENT_IID on BPEL_EVENT (IID) ; -create index IDX_EVENT_PID on BPEL_EVENT (PID) ; -create index IDX_CORR_SET_NAME on BPEL_CORRELATION_SET (CORR_SET_NAME) ; -create index IDX_CORR_SET_SCOPE_ID on BPEL_CORRELATION_SET (SCOPE_ID) ; -create index IDX_BPEL_INSTANCE_PROCESS_ID on BPEL_INSTANCE (PROCESS_ID) ; -create index IDX_BPEL_INSTANCE_STATE on BPEL_INSTANCE (STATE) ; -create index IDX_BPEL_PROCESS_TYPE_NAME on BPEL_PROCESS (type_name) ; -create index IDX_BPEL_PROCESS_TYPE_NS on BPEL_PROCESS (type_ns) ; -create index IDX_BPEL_CORRELATOR_PROCESS_ID on BPEL_CORRELATOR (PROCESS_ID) ; -create index IDX_UNMATCHED_CORRELATOR_CKEY on BPEL_UNMATCHED (CORRELATOR,CORRELATION_KEY) ; -create index IDX_PLINK_VAL_PROCESS_IDX on BPEL_PLINK_VAL (PROCESS) ; -create index IDX_PLINK_VAL_SCOPE on BPEL_PLINK_VAL (SCOPE) ; -create index IDX_PLINK_VAL_MODELID on BPEL_PLINK_VAL (MODELID) ; -create index IDX_SELECTOR_INSTANCE on BPEL_SELECTORS (PIID) ; -create index IDX_VARPROP_XMLDATA on VAR_PROPERTY (XML_DATA_ID) ; -create index IDX_VARPROP_NAME on VAR_PROPERTY (PROP_NAME) ; -create index IDX_VARPROP_VALUE on VAR_PROPERTY (PROP_VALUE) ; -create index IDX_UNMATCHED_MEX on BPEL_UNMATCHED (MEX) ; + create table ODE_CORRELATOR ( + CORRELATOR_ID bigint not null auto_increment, + CORRELATOR_KEY varchar(255), + PROC_ID bigint, + primary key (CORRELATOR_ID) + ) type=InnoDB; ---Indexes for instance deletion -create index IDX_MESSAGE_MEX on BPEL_MESSAGE(MEX) ; -create index IDX_MESSAGE_EXCHANGE_PIID on BPEL_MESSAGE_EXCHANGE(PIID) ; -create index IDX_SCOPE_PIID on BPEL_SCOPE(PIID) ; + create table ODE_CORSET_PROP ( + ID bigint not null auto_increment, + CORRSET_ID bigint, + PROP_KEY varchar(255), + PROP_VALUE varchar(255), + primary key (ID) + ) type=InnoDB; + + create table ODE_EVENT ( + EVENT_ID bigint not null auto_increment, + DETAIL varchar(255), + DATA longblob, + SCOPE_ID bigint, + TSTAMP datetime, + TYPE varchar(255), + INSTANCE_ID bigint, + PROCESS_ID bigint, + primary key (EVENT_ID) + ) type=InnoDB; + + create table ODE_FAULT ( + FAULT_ID bigint not null auto_increment, + ACTIVITY_ID integer, + DATA longtext, + MESSAGE longtext, + LINE_NUMBER integer, + NAME varchar(255), + primary key (FAULT_ID) + ) type=InnoDB; + + create table ODE_MESSAGE ( + MESSAGE_ID bigint not null auto_increment, + DATA longtext, + HEADER longtext, + TYPE varchar(255), + MESSAGE_EXCHANGE_ID varchar(255), + primary key (MESSAGE_ID) + ) type=InnoDB; + + create table ODE_MESSAGE_EXCHANGE ( + MESSAGE_EXCHANGE_ID varchar(255) not null, + CALLEE varchar(255), + CHANNEL varchar(255), + CORRELATION_ID varchar(255), + CORRELATION_KEYS varchar(255), + CORRELATION_STATUS varchar(255), + CREATE_TIME datetime, + DIRECTION char(1), + EPR longtext, + FAULT varchar(255), + FAULT_EXPLANATION varchar(255), + OPERATION varchar(255), + PARTNER_LINK_MODEL_ID integer, + PATTERN varchar(255), + PIPED_ID varchar(255), + PORT_TYPE varchar(255), + PROPAGATE_TRANS bit, + STATUS varchar(255), + SUBSCRIBER_COUNT integer, + CORR_ID bigint, + PARTNER_LINK_ID bigint, + PROCESS_ID bigint, + PROCESS_INSTANCE_ID bigint, + REQUEST_MESSAGE_ID bigint, + RESPONSE_MESSAGE_ID bigint, + primary key (MESSAGE_EXCHANGE_ID) + ) type=InnoDB; + + create table ODE_MESSAGE_ROUTE ( + MESSAGE_ROUTE_ID bigint not null auto_increment, + CORRELATION_KEY varchar(255), + GROUP_ID varchar(255), + ROUTE_INDEX integer, + PROCESS_INSTANCE_ID bigint, + ROUTE_POLICY varchar(16), + CORR_ID bigint, + primary key (MESSAGE_ROUTE_ID) + ) type=InnoDB; + + create table ODE_MEX_PROP ( + ID bigint not null auto_increment, + MEX_ID varchar(255), + PROP_KEY varchar(255), + PROP_VALUE longtext, + primary key (ID) + ) type=InnoDB; + + create table ODE_PARTNER_LINK ( + PARTNER_LINK_ID bigint not null auto_increment, + MY_EPR longtext, + MY_ROLE_NAME varchar(255), + MY_ROLE_SERVICE_NAME varchar(255), + MY_SESSION_ID varchar(255), + PARTNER_EPR longtext, + PARTNER_LINK_MODEL_ID integer, + PARTNER_LINK_NAME varchar(255), + PARTNER_ROLE_NAME varchar(255), + PARTNER_SESSION_ID varchar(255), + SCOPE_ID bigint, + primary key (PARTNER_LINK_ID) + ) type=InnoDB; + + create table ODE_PROCESS ( + ID bigint not null auto_increment, + GUID varchar(255), + PROCESS_ID varchar(255), + PROCESS_TYPE varchar(255), + VERSION bigint, + primary key (ID) + ) type=InnoDB; + + create table ODE_PROCESS_INSTANCE ( + ID bigint not null auto_increment, + DATE_CREATED datetime, + EXECUTION_STATE longblob, + FAULT_ID bigint, + LAST_ACTIVE_TIME datetime, + LAST_RECOVERY_DATE datetime, + PREVIOUS_STATE smallint, + SEQUENCE bigint, + INSTANCE_STATE smallint, + INSTANTIATING_CORRELATOR_ID bigint, + PROCESS_ID bigint, + ROOT_SCOPE_ID bigint, + primary key (ID) + ) type=InnoDB; + + create table ODE_SCOPE ( + SCOPE_ID bigint not null auto_increment, + MODEL_ID integer, + SCOPE_NAME varchar(255), + SCOPE_STATE varchar(255), + PARENT_SCOPE_ID bigint, + PROCESS_INSTANCE_ID bigint, + primary key (SCOPE_ID) + ) type=InnoDB; + + create table ODE_XML_DATA ( + XML_DATA_ID bigint not null auto_increment, + DATA longtext, + IS_SIMPLE_TYPE bit, + NAME varchar(255), + SCOPE_ID bigint, + primary key (XML_DATA_ID) + ) type=InnoDB; + + create table ODE_XML_DATA_PROP ( + ID bigint not null auto_increment, + XML_DATA_ID bigint, + PROP_KEY varchar(255), + PROP_VALUE varchar(255), + primary key (ID) + ) type=InnoDB; + + create table STORE_DU ( + NAME varchar(255) not null, + DEPLOYDT datetime, + DEPLOYER varchar(255), + DIR varchar(255), + primary key (NAME) + ) type=InnoDB; + + create table STORE_PROCESS ( + PID varchar(255) not null, + STATE varchar(255), + TYPE varchar(255), + VERSION bigint, + DU varchar(255), + primary key (PID) + ) type=InnoDB; + + create table STORE_PROCESS_PROP ( + ID bigint not null auto_increment, + PROP_KEY varchar(255), + PROP_VAL varchar(255), + primary key (ID) + ) type=InnoDB; + + create table STORE_PROC_TO_PROP ( + STORE_PROCESS_PID varchar(255) not null, + STORE_PROPERTY_ID bigint not null, + primary key (STORE_PROCESS_PID, STORE_PROPERTY_ID), + unique (STORE_PROPERTY_ID) + ) type=InnoDB; + + create table STORE_VERSIONS ( + ID bigint not null auto_increment, + VERSION bigint, + primary key (ID) + ) type=InnoDB; \ No newline at end of file Modified: trunk/runtime/engine-assembly/src/main/resources/bpel-sql/oracle.sql =================================================================== --- trunk/runtime/engine-assembly/src/main/resources/bpel-sql/oracle.sql 2010-05-31 07:27:51 UTC (rev 683) +++ trunk/runtime/engine-assembly/src/main/resources/bpel-sql/oracle.sql 2010-05-31 07:36:33 UTC (rev 684) @@ -1,78 +1,275 @@ +-- +-- 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. +-- + create table ODE_SCHEMA_VERSION(VERSION integer); -insert into ODE_SCHEMA_VERSION values (5); +insert into ODE_SCHEMA_VERSION values (6); + -- Apache ODE - SimpleScheduler Database Schema -- -- Apache Derby scripts by Maciej Szefler. -- -- -CREATE TABLE ode_job ( +DROP TABLE ODE_JOB; + +CREATE TABLE ODE_JOB ( jobid VARCHAR(64) NOT NULL, ts number(37) NOT NULL, nodeid varchar(64), scheduled int NOT NULL, transacted int NOT NULL, - details blob, + + instanceId number(37), + mexId varchar(255), + processId varchar(255), + type varchar(255), + channel varchar(255), + correlatorId varchar(255), + correlationKeySet varchar(255), + retryCount int, + inMem int, + detailsExt blob, + PRIMARY KEY(jobid)); -CREATE INDEX IDX_ODE_JOB_TS ON ode_job(ts) ; -CREATE INDEX IDX_ODE_JOB_NODEID ON ode_job(nodeid) ; +CREATE INDEX IDX_ODE_JOB_TS ON ODE_JOB(ts); +CREATE INDEX IDX_ODE_JOB_NODEID ON ODE_JOB(nodeid); -create table BPEL_ACTIVITY_RECOVERY (ID number(19,0) not null, PIID number(19,0), AID number(19,0), CHANNEL varchar2(255 char), REASON varchar2(255 char), DATE_TIME timestamp, DETAILS blob, ACTIONS varchar2(255 char), RETRIES number(10,0), INSERT_TIME timestamp, MLOCK number(10,0) not null, primary key (ID)); -create table BPEL_CORRELATION_PROP (ID number(19,0) not null, NAME varchar2(255 char), NAMESPACE varchar2(255 char), VALUE varchar2(255 char), CORR_SET_ID number(19,0), INSERT_TIME timestamp, MLOCK number(10,0) not null, primary key (ID)); -create table BPEL_CORRELATION_SET (ID number(19,0) not null, VALUE varchar2(255 char), CORR_SET_NAME varchar2(255 char), SCOPE_ID number(19,0), PIID number(19,0), PROCESS_ID number(19,0), INSERT_TIME timestamp, MLOCK number(10,0) not null, primary key (ID)); -create table BPEL_CORRELATOR (ID number(19,0) not null, CID varchar2(255 char), PROCESS_ID number(19,0), INSERT_TIME timestamp, MLOCK number(10,0) not null, primary key (ID)); -create table BPEL_CORRELATOR_MESSAGE_CKEY (ID number(19,0) not null, CKEY varchar2(255 char), CORRELATOR_MESSAGE_ID number(19,0), INSERT_TIME timestamp, MLOCK number(10,0) not null, primary key (ID)); -create table BPEL_EVENT (ID number(19,0) not null, IID number(19,0), PID number(19,0), TSTAMP timestamp, TYPE varchar2(255 char), DETAIL clob, DATA blob, SID number(19,0), INSERT_TIME timestamp, MLOCK number(10,0) not null, primary key (ID)); -create table BPEL_FAULT (ID number(19,0) not null, FAULTNAME varchar2(255 char), DATA blob, EXPLANATION varchar2(4000 char), LINE_NUM number(10,0), AID number(10,0), INSERT_TIME timestamp, MLOCK number(10,0) not null, primary key (ID)); -create table BPEL_INSTANCE (ID number(19,0) not null, INSTANTIATING_CORRELATOR number(19,0), FAULT number(19,0), JACOB_STATE_DATA blob, PREVIOUS_STATE number(5,0), PROCESS_ID number(19,0), STATE number(5,0), LAST_ACTIVE_DT timestamp, SEQUENCE number(19,0), FAILURE_COUNT number(10,0), FAILURE_DT timestamp, INSERT_TIME timestamp, MLOCK number(10,0) not null, primary key (ID)); -create table BPEL_MESSAGE (ID number(19,0) not null, MEX number(19,0), TYPE varchar2(255 char), MESSAGE_DATA blob, MESSAGE_HEADER blob, INSERT_TIME timestamp, MLOCK number(10,0) not null, primary key (ID)); -create table BPEL_MESSAGE_EXCHANGE (ID number(19,0) not null, PORT_TYPE varchar2(255 char), CHANNEL_NAME varchar2(255 char), CLIENTKEY varchar2(255 char), ENDPOINT blob, CALLBACK_ENDPOINT blob, REQUEST number(19,0), RESPONSE number(19,0), INSERT_DT timestamp, OPERATION varchar2(255 char), STATE varchar2(255 char), PROCESS number(19,0), PIID number(19,0), DIR char(1 char), PLINK_MODELID number(10,0), PATTERN varchar2(255 char), CORR_STATUS varchar2(255 char), FAULT_TYPE varchar2(255 char), FAULT_EXPL varchar2(255 char), CALLEE varchar2(255 char), PARTNERLINK number(19,0), PIPED_ID varchar2(255 char), SUBSCRIBER_COUNT number(10,0), INSERT_TIME timestamp, MLOCK number(10,0) not null, primary key (ID)); -create table BPEL_MEX_PROPS (MEX number(19,0) not null, VALUE long, NAME varchar2(255 char) not null, primary key (MEX, NAME)); -create table BPEL_PLINK_VAL (ID number(19,0) not null, PARTNER_LINK varchar2(100 char) not null, PARTNERROLE varchar2(100 char), MYROLE_EPR_DATA blob, PARTNERROLE_EPR_DATA blob, PROCESS number(19,0), SCOPE number(19,0), SVCNAME varchar2(255 char), MYROLE varchar2(100 char), MODELID number(10,0), MYSESSIONID varchar2(255 char), PARTNERSESSIONID varchar2(255 char), INSERT_TIME timestamp, MLOCK number(10,0) not null, primary key (ID)); -create table BPEL_PROCESS (ID number(19,0) not null, PROCID varchar2(255 char) not null unique, deployer varchar2(255 char), deploydate timestamp, type_name varchar2(255 char), type_ns varchar2(255 char), version number(19,0), ACTIVE_ number(1,0), guid varchar2(255 char), INSERT_TIME timestamp, MLOCK number(10,0) not null, primary key (ID)); -create table BPEL_SCOPE (ID number(19,0) not null, PIID number(19,0), PARENT_SCOPE_ID number(19,0), STATE varchar2(255 char) not null, NAME varchar2(255 char) not null, MODELID number(10,0), INSERT_TIME timestamp, MLOCK number(10,0) not null, primary key (ID)); -create table BPEL_SELECTORS (ID number(19,0) not null, PIID number(19,0) not null, SELGRPID varchar2(255 char) not null, IDX number(10,0) not null, CORRELATION_KEY varchar2(255 char) not null, PROC_TYPE varchar2(255 char) not null, ROUTE_POLICY varchar2(255 char), CORRELATOR number(19,0) not null, INSERT_TIME timestamp, MLOCK number(10,0) not null, primary key (ID), unique (CORRELATION_KEY, CORRELATOR)); -create table BPEL_UNMATCHED (ID number(19,0) not null, MEX number(19,0), CORRELATION_KEY varchar2(255 char), CORRELATOR number(19,0) not null, INSERT_TIME timestamp, MLOCK number(10,0) not null, primary key (ID)); -create table BPEL_XML_DATA (ID number(19,0) not null, DATA blob, NAME varchar2(255 char) not null, SCOPE_ID number(19,0), PIID number(19,0), IS_SIMPLE_TYPE number(1,0), INSERT_TIME timestamp, MLOCK number(10,0) not null, primary key (ID)); -create table VAR_PROPERTY (ID number(19,0) not null, XML_DATA_ID number(19,0), PROP_VALUE varchar2(255 char), PROP_NAME varchar2(255 char) not null, INSERT_TIME timestamp, MLOCK number(10,0) not null, primary key (ID)); -create index IDX_CORRELATOR_CID on BPEL_CORRELATOR (CID); -create index IDX_BPEL_CORRELATOR_MESSAGE_CKEY on BPEL_CORRELATOR_MESSAGE_CKEY (CKEY); -create index IDX_SELECTOR_CORRELATOR on BPEL_SELECTORS (CORRELATOR); -create index IDX_SELECTOR_CKEY on BPEL_SELECTORS (CORRELATION_KEY); -create index IDX_SELECTOR_SELGRPID on BPEL_SELECTORS (SELGRPID); -create index IDX_UNMATCHED_CKEY on BPEL_UNMATCHED (CORRELATION_KEY); -create index IDX_UNMATCHED_CORRELATOR on BPEL_UNMATCHED (CORRELATOR); -create sequence hibernate_seqhilo; ---create indexes + create table ODE_ACTIVITY_RECOVERY ( + ID number(19,0) not null, + ACTIONS varchar2(255), + ACTIVITY_ID number(19,0), + CHANNEL varchar2(255), + DATE_TIME date, + DETAILS clob, + INSTANCE_ID number(19,0), + REASON varchar2(255), + RETRIES number(10,0), + primary key (ID) + ); -create index IDX_XMLDATA_IID on BPEL_XML_DATA (PIID) ; -create index IDX_XMLDATA_SID on BPEL_XML_DATA (SCOPE_ID) ; -create index IDX_XMLDATA_NAME on BPEL_XML_DATA (NAME) ; -create index IDX_XMLDATA_NAME_SID on BPEL_XML_DATA (NAME, SCOPE_ID) ; -create index IDX_EVENT_IID on BPEL_EVENT (IID) ; -create index IDX_EVENT_PID on BPEL_EVENT (PID) ; -create index IDX_CORR_SET_NAME on BPEL_CORRELATION_SET (CORR_SET_NAME) ; -create index IDX_CORR_SET_SCOPE_ID on BPEL_CORRELATION_SET (SCOPE_ID) ; -create index IDX_BPEL_INSTANCE_PROCESS_ID on BPEL_INSTANCE (PROCESS_ID) ; -create index IDX_BPEL_INSTANCE_STATE on BPEL_INSTANCE (STATE) ; -create index IDX_BPEL_PROCESS_TYPE_NAME on BPEL_PROCESS (type_name) ; -create index IDX_BPEL_PROCESS_TYPE_NS on BPEL_PROCESS (type_ns) ; -create index IDX_BPEL_CORRELATOR_PROCESS_ID on BPEL_CORRELATOR (PROCESS_ID) ; -create index IDX_UNMATCHED_CORRELATOR_CKEY on BPEL_UNMATCHED (CORRELATOR,CORRELATION_KEY) ; -create index IDX_PLINK_VAL_PROCESS_IDX on BPEL_PLINK_VAL (PROCESS) ; -create index IDX_PLINK_VAL_SCOPE on BPEL_PLINK_VAL (SCOPE) ; -create index IDX_PLINK_VAL_MODELID on BPEL_PLINK_VAL (MODELID) ; -create index IDX_SELECTOR_INSTANCE on BPEL_SELECTORS (PIID) ; -create index IDX_VARPROP_XMLDATA on VAR_PROPERTY (XML_DATA_ID) ; -create index IDX_VARPROP_NAME on VAR_PROPERTY (PROP_NAME) ; -create index IDX_VARPROP_VALUE on VAR_PROPERTY (PROP_VALUE) ; -create index IDX_UNMATCHED_MEX on BPEL_UNMATCHED (MEX) ; + create table ODE_CORRELATION_SET ( + CORRELATION_SET_ID number(19,0) not null, + CORRELATION_KEY varchar2(255), + NAME varchar2(255), + SCOPE_ID number(19,0), + primary key (CORRELATION_SET_ID) + ); ---Indexes for instance deletion -create index IDX_MESSAGE_MEX on BPEL_MESSAGE(MEX) ; -create index IDX_MESSAGE_EXCHANGE_PIID on BPEL_MESSAGE_EXCHANGE(PIID) ; -create index IDX_SCOPE_PIID on BPEL_SCOPE(PIID) ; + create table ODE_CORRELATOR ( + CORRELATOR_ID number(19,0) not null, + CORRELATOR_KEY varchar2(255), + PROC_ID number(19,0), + primary key (CORRELATOR_ID) + ); + create table ODE_CORSET_PROP ( + ID number(19,0) not null, + CORRSET_ID number(19,0), + PROP_KEY varchar2(255), + PROP_VALUE varchar2(255), + primary key (ID) + ); + + create table ODE_EVENT ( + EVENT_ID number(19,0) not null, + DETAIL varchar2(255), + DATA blob, + SCOPE_ID number(19,0), + TSTAMP date, + TYPE varchar2(255), + INSTANCE_ID number(19,0), + PROCESS_ID number(19,0), + primary key (EVENT_ID) + ); + + create table ODE_FAULT ( + FAULT_ID number(19,0) not null, + ACTIVITY_ID number(10,0), + DATA clob, + MESSAGE varchar2(4000), + LINE_NUMBER number(10,0), + NAME varchar2(255), + primary key (FAULT_ID) + ); + + create table ODE_MESSAGE ( + MESSAGE_ID number(19,0) not null, + DATA clob, + HEADER clob, + TYPE varchar2(255), + MESSAGE_EXCHANGE_ID varchar2(255), + primary key (MESSAGE_ID) + ); + + create table ODE_MESSAGE_EXCHANGE ( + MESSAGE_EXCHANGE_ID varchar2(255) not null, + CALLEE varchar2(255), + CHANNEL varchar2(255), + CORRELATION_ID varchar2(255), + CORRELATION_KEYS varchar2(255), + CORRELATION_STATUS varchar2(255), + CREATE_TIME date, + DIRECTION char(1), + EPR clob, + FAULT varchar2(255), + FAULT_EXPLANATION varchar2(255), + OPERATION varchar2(255), + PARTNER_LINK_MODEL_ID number(10,0), + PATTERN varchar2(255), + PIPED_ID varchar2(255), + PORT_TYPE varchar2(255), + PROPAGATE_TRANS number(1,0), + STATUS varchar2(255), + SUBSCRIBER_COUNT number(10,0), + CORR_ID number(19,0), + PARTNER_LINK_ID number(19,0), + PROCESS_ID number(19,0), + PROCESS_INSTANCE_ID number(19,0), + REQUEST_MESSAGE_ID number(19,0), + RESPONSE_MESSAGE_ID number(19,0), + primary key (MESSAGE_EXCHANGE_ID) + ); + + create table ODE_MESSAGE_ROUTE ( + MESSAGE_ROUTE_ID number(19,0) not null, + CORRELATION_KEY varchar2(255), + GROUP_ID varchar2(255), + ROUTE_INDEX number(10,0), + PROCESS_INSTANCE_ID number(19,0), + ROUTE_POLICY varchar2(16), + CORR_ID number(19,0), + primary key (MESSAGE_ROUTE_ID) + ); + + create table ODE_MEX_PROP ( + ID number(19,0) not null, + MEX_ID varchar2(255), + PROP_KEY varchar2(255), + PROP_VALUE varchar2(2000), + primary key (ID) + ); + + create table ODE_PARTNER_LINK ( + PARTNER_LINK_ID number(19,0) not null, + MY_EPR clob, + MY_ROLE_NAME varchar2(255), + MY_ROLE_SERVICE_NAME varchar2(255), + MY_SESSION_ID varchar2(255), + PARTNER_EPR clob, + PARTNER_LINK_MODEL_ID number(10,0), + PARTNER_LINK_NAME varchar2(255), + PARTNER_ROLE_NAME varchar2(255), + PARTNER_SESSION_ID varchar2(255), + SCOPE_ID number(19,0), + primary key (PARTNER_LINK_ID) + ); + + create table ODE_PROCESS ( + ID number(19,0) not null, + GUID varchar2(255), + PROCESS_ID varchar2(255), + PROCESS_TYPE varchar2(255), + VERSION number(19,0), + primary key (ID) + ); + + create table ODE_PROCESS_INSTANCE ( + ID number(19,0) not null, + DATE_CREATED date, + EXECUTION_STATE blob, + FAULT_ID number(19,0), + LAST_ACTIVE_TIME date, + LAST_RECOVERY_DATE date, + PREVIOUS_STATE number(5,0), + SEQUENCE number(19,0), + INSTANCE_STATE number(5,0), + INSTANTIATING_CORRELATOR_ID number(19,0), + PROCESS_ID number(19,0), + ROOT_SCOPE_ID number(19,0), + primary key (ID) + ); + + create table ODE_SCOPE ( + SCOPE_ID number(19,0) not null, + MODEL_ID number(10,0), + SCOPE_NAME varchar2(255), + SCOPE_STATE varchar2(255), + PARENT_SCOPE_ID number(19,0), + PROCESS_INSTANCE_ID number(19,0), + primary key (SCOPE_ID) + ); + + create table ODE_XML_DATA ( + XML_DATA_ID number(19,0) not null, + DATA clob, + IS_SIMPLE_TYPE number(1,0), + NAME varchar2(255), + SCOPE_ID number(19,0), + primary key (XML_DATA_ID) + ); + + create table ODE_XML_DATA_PROP ( + ID number(19,0) not null, + XML_DATA_ID number(19,0), + PROP_KEY varchar2(255), + PROP_VALUE varchar2(255), + primary key (ID) + ); + + create table STORE_DU ( + NAME varchar2(255) not null, + DEPLOYDT date, + DEPLOYER varchar2(255), + DIR varchar2(255), + primary key (NAME) + ); + + create table STORE_PROCESS ( + PID varchar2(255) not null, + STATE varchar2(255), + TYPE varchar2(255), + VERSION number(19,0), + DU varchar2(255), + primary key (PID) + ); + + create table STORE_PROCESS_PROP ( + ID number(19,0) not null, + PROP_KEY varchar2(255), + PROP_VAL varchar2(255), + primary key (ID) + ); + + create table STORE_PROC_TO_PROP ( + STORE_PROCESS_PID varchar2(255) not null, + STORE_PROPERTY_ID number(19,0) not null, + primary key (STORE_PROCESS_PID, STORE_PROPERTY_ID), + unique (STORE_PROPERTY_ID) + ); + + create table STORE_VERSIONS ( + ID number(19,0) not null, + VERSION number(19,0), + primary key (ID) + ); + + create sequence hibernate_sequence; \ No newline at end of file Modified: trunk/runtime/engine-assembly/src/main/resources/bpel-sql/postgres.sql =================================================================== --- trunk/runtime/engine-assembly/src/main/resources/bpel-sql/postgres.sql 2010-05-31 07:27:51 UTC (rev 683) +++ trunk/runtime/engine-assembly/src/main/resources/bpel-sql/postgres.sql 2010-05-31 07:36:33 UTC (rev 684) @@ -1,5 +1,25 @@ +-- +-- 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. +-- + create table ODE_SCHEMA_VERSION(VERSION integer); -insert into ODE_SCHEMA_VERSION values (5); +insert into ODE_SCHEMA_VERSION values (6); + -- Apache ODE - SimpleScheduler Database Schema -- -- Apache Derby scripts by Maciej Szefler. @@ -12,67 +32,242 @@ nodeid char(64), scheduled int NOT NULL DEFAULT 0, transacted int NOT NULL DEFAULT 0, - details bytea, + + instanceId BIGINT, + mexId varchar(255), + processId varchar(255), + type varchar(255), + channel varchar(255), + correlatorId varchar(255), + correlationKeySet varchar(255), + retryCount int, + inMem int, + detailsExt bytea, + PRIMARY KEY(jobid)); CREATE INDEX IDX_ODE_JOB_TS ON ode_job(ts); CREATE INDEX IDX_ODE_JOB_NODEID ON ode_job(nodeid); -create table BPEL_ACTIVITY_RECOVERY (ID int8 not null, PIID int8, AID int8, CHANNEL varchar(255), REASON varchar(255), DATE_TIME timestamp, DETAILS bytea, ACTIONS varchar(255), RETRIES int4, INSERT_TIME timestamp, MLOCK int4 not null, primary key (ID)); -create table BPEL_CORRELATION_PROP (ID int8 not null, NAME varchar(255), NAMESPACE varchar(255), VALUE varchar(255), CORR_SET_ID int8, INSERT_TIME timestamp, MLOCK int4 not null, primary key (ID)); -create table BPEL_CORRELATION_SET (ID int8 not null, VALUE varchar(255), CORR_SET_NAME varchar(255), SCOPE_ID int8, PIID int8, PROCESS_ID int8, INSERT_TIME timestamp, MLOCK int4 not null, primary key (ID)); -create table BPEL_CORRELATOR (ID int8 not null, CID varchar(255), PROCESS_ID int8, INSERT_TIME timestamp, MLOCK int4 not null, primary key (ID)); -create table BPEL_CORRELATOR_MESSAGE_CKEY (ID int8 not null, CKEY varchar(255), CORRELATOR_MESSAGE_ID int8, INSERT_TIME timestamp, MLOCK int4 not null, primary key (ID)); -create table BPEL_EVENT (ID int8 not null, IID int8, PID int8, TSTAMP timestamp, TYPE varchar(255), DETAIL text, DATA bytea, SID int8, INSERT_TIME timestamp, MLOCK int4 not null, primary key (ID)); -create table BPEL_FAULT (ID int8 not null, FAULTNAME varchar(255), DATA bytea, EXPLANATION varchar(4000), LINE_NUM int4, AID int4, INSERT_TIME timestamp, MLOCK int4 not null, primary key (ID)); -create table BPEL_INSTANCE (ID int8 not null, INSTANTIATING_CORRELATOR int8, FAULT int8, JACOB_STATE_DATA bytea, PREVIOUS_STATE int2, PROCESS_ID int8, STATE int2, LAST_ACTIVE_DT timestamp, SEQUENCE int8, FAILURE_COUNT int4, FAILURE_DT timestamp, INSERT_TIME timestamp, MLOCK int4 not null, primary key (ID)); -create table BPEL_MESSAGE (ID int8 not null, MEX int8, TYPE varchar(255), MESSAGE_DATA bytea, MESSAGE_HEADER bytea, INSERT_TIME timestamp, MLOCK int4 not null, primary key (ID)); -create table BPEL_MESSAGE_EXCHANGE (ID int8 not null, PORT_TYPE varchar(255), CHANNEL_NAME varchar(255), CLIENTKEY varchar(255), ENDPOINT bytea, CALLBACK_ENDPOINT bytea, REQUEST int8, RESPONSE int8, INSERT_DT timestamp, OPERATION varchar(255), STATE varchar(255), PROCESS int8, PIID int8, DIR char(1), PLINK_MODELID int4, PATTERN varchar(255), CORR_STATUS varchar(255), FAULT_TYPE varchar(255), FAULT_EXPL varchar(255), CALLEE varchar(255), PARTNERLINK int8, PIPED_ID varchar(255), SUBSCRIBER_COUNT int4, INSERT_TIME timestamp, MLOCK int4 not null, primary key (ID)); -create table BPEL_MEX_PROPS (MEX int8 not null, VALUE varchar(8000), NAME varchar(255) not null, primary key (MEX, NAME)); -create table BPEL_PLINK_VAL (ID int8 not null, PARTNER_LINK varchar(100) not null, PARTNERROLE varchar(100), MYROLE_EPR_DATA bytea, PARTNERROLE_EPR_DATA bytea, PROCESS int8, SCOPE int8, SVCNAME varchar(255), MYROLE varchar(100), MODELID int4, MYSESSIONID varchar(255), PARTNERSESSIONID varchar(255), INSERT_TIME timestamp, MLOCK int4 not null, primary key (ID)); -create table BPEL_PROCESS (ID int8 not null, PROCID varchar(255) not null unique, deployer varchar(255), deploydate timestamp, type_name varchar(255), type_ns varchar(255), version int8, ACTIVE_ bool, guid varchar(255), INSERT_TIME timestamp, MLOCK int4 not null, primary key (ID)); -create table BPEL_SCOPE (ID int8 not null, PIID int8, PARENT_SCOPE_ID int8, STATE varchar(255) not null, NAME varchar(255) not null, MODELID int4, INSERT_TIME timestamp, MLOCK int4 not null, primary key (ID)); -create table BPEL_SELECTORS (ID int8 not null, PIID int8 not null, SELGRPID varchar(255) not null, IDX int4 not null, CORRELATION_KEY varchar(255) not null, PROC_TYPE varchar(255) not null, ROUTE_POLICY varchar(255), CORRELATOR int8 not null, INSERT_TIME timestamp, MLOCK int4 not null, primary key (ID), unique (CORRELATION_KEY, CORRELATOR)); -create table BPEL_UNMATCHED (ID int8 not null, MEX int8, CORRELATION_KEY varchar(255), CORRELATOR int8 not null, INSERT_TIME timestamp, MLOCK int4 not null, primary key (ID)); -create table BPEL_XML_DATA (ID int8 not null, DATA bytea, NAME varchar(255) not null, SCOPE_ID int8, PIID int8, IS_SIMPLE_TYPE bool, INSERT_TIME timestamp, MLOCK int4 not null, primary key (ID)); -create table VAR_PROPERTY (ID int8 not null, XML_DATA_ID int8, PROP_VALUE varchar(255), PROP_NAME varchar(255) not null, INSERT_TIME timestamp, MLOCK int4 not null, primary key (ID)); -create index IDX_CORRELATOR_CID on BPEL_CORRELATOR (CID); -create index IDX_BPEL_CORRELATOR_MESSAGE_CKEY on BPEL_CORRELATOR_MESSAGE_CKEY (CKEY); -create index IDX_SELECTOR_CORRELATOR on BPEL_SELECTORS (CORRELATOR); -create index IDX_SELECTOR_CKEY on BPEL_SELECTORS (CORRELATION_KEY); -create index IDX_SELECTOR_SELGRPID on BPEL_SELECTORS (SELGRPID); -create index IDX_UNMATCHED_CKEY on BPEL_UNMATCHED (CORRELATION_KEY); -create index IDX_UNMATCHED_CORRELATOR on BPEL_UNMATCHED (CORRELATOR); -create sequence hibernate_seqhilo; + create table ODE_ACTIVITY_RECOVERY ( + ID int8 not null, + ACTIONS varchar(255), + ACTIVITY_ID int8, + CHANNEL varchar(255), + DATE_TIME timestamp, + DETAILS text, + INSTANCE_ID int8, + REASON varchar(255), + RETRIES int4, + primary key (ID) + ); ---create indexes + create table ODE_CORRELATION_SET ( + CORRELATION_SET_ID int8 not null, + CORRELATION_KEY varchar(255), + NAME varchar(255), + SCOPE_ID int8, + primary key (CORRELATION_SET_ID) + ); -create index IDX_XMLDATA_IID on BPEL_XML_DATA (PIID) ; -create index IDX_XMLDATA_SID on BPEL_XML_DATA (SCOPE_ID) ; -create index IDX_XMLDATA_NAME on BPEL_XML_DATA (NAME) ; -create index IDX_XMLDATA_NAME_SID on BPEL_XML_DATA (NAME, SCOPE_ID) ; -create index IDX_EVENT_IID on BPEL_EVENT (IID) ; -create index IDX_EVENT_PID on BPEL_EVENT (PID) ; -create index IDX_CORR_SET_NAME on BPEL_CORRELATION_SET (CORR_SET_NAME) ; -create index IDX_CORR_SET_SCOPE_ID on BPEL_CORRELATION_SET (SCOPE_ID) ; -create index IDX_BPEL_INSTANCE_PROCESS_ID on BPEL_INSTANCE (PROCESS_ID) ; -create index IDX_BPEL_INSTANCE_STATE on BPEL_INSTANCE (STATE) ; -create index IDX_BPEL_PROCESS_TYPE_NAME on BPEL_PROCESS (type_name) ; -create index IDX_BPEL_PROCESS_TYPE_NS on BPEL_PROCESS (type_ns) ; -create index IDX_BPEL_CORRELATOR_PROCESS_ID on BPEL_CORRELATOR (PROCESS_ID) ; -create index IDX_UNMATCHED_CORRELATOR_CKEY on BPEL_UNMATCHED (CORRELATOR,CORRELATION_KEY) ; -create index IDX_PLINK_VAL_PROCESS_IDX on BPEL_PLINK_VAL (PROCESS) ; -create index IDX_PLINK_VAL_SCOPE on BPEL_PLINK_VAL (SCOPE) ; -create index IDX_PLINK_VAL_MODELID on BPEL_PLINK_VAL (MODELID) ; -create index IDX_SELECTOR_INSTANCE on BPEL_SELECTORS (PIID) ; -create index IDX_VARPROP_XMLDATA on VAR_PROPERTY (XML_DATA_ID) ; -create index IDX_VARPROP_NAME on VAR_PROPERTY (PROP_NAME) ; -create index IDX_VARPROP_VALUE on VAR_PROPERTY (PROP_VALUE) ; -create index IDX_UNMATCHED_MEX on BPEL_UNMATCHED (MEX) ; + create table ODE_CORRELATOR ( + CORRELATOR_ID int8 not null, + CORRELATOR_KEY varchar(255), + PROC_ID int8, + primary key (CORRELATOR_ID) + ); ---Indexes for instance deletion -create index IDX_MESSAGE_MEX on BPEL_MESSAGE(MEX) ; -create index IDX_MESSAGE_EXCHANGE_PIID on BPEL_MESSAGE_EXCHANGE(PIID) ; -create index IDX_SCOPE_PIID on BPEL_SCOPE(PIID) ; \ No newline at end of file + create table ODE_CORSET_PROP ( + ID int8 not null, + CORRSET_ID int8, + PROP_KEY varchar(255), + PROP_VALUE varchar(255), + primary key (ID) + ); + + create table ODE_EVENT ( + EVENT_ID int8 not null, + DETAIL varchar(255), + DATA oid, + SCOPE_ID int8, + TSTAMP timestamp, + TYPE varchar(255), + INSTANCE_ID int8, + PROCESS_ID int8, + primary key (EVENT_ID) + ); + + create table ODE_FAULT ( + FAULT_ID int8 not null, + ACTIVITY_ID int4, + DATA text, + MESSAGE varchar(4000), + LINE_NUMBER int4, + NAME varchar(255), + primary key (FAULT_ID) + ); + + create table ODE_MESSAGE ( + MESSAGE_ID int8 not null, + DATA text, + HEADER text, + TYPE varchar(255), + MESSAGE_EXCHANGE_ID varchar(255), + primary key (MESSAGE_ID) + ); + + create table ODE_MESSAGE_EXCHANGE ( + MESSAGE_EXCHANGE_ID varchar(255) not null, + CALLEE varchar(255), + CHANNEL varchar(255), + CORRELATION_ID varchar(255), + CORRELATION_KEYS varchar(255), + CORRELATION_STATUS varchar(255), + CREATE_TIME timestamp, + DIRECTION char(1), + EPR text, + FAULT varchar(255), + FAULT_EXPLANATION varchar(255), + OPERATION varchar(255), + PARTNER_LINK_MODEL_ID int4, + PATTERN varchar(255), + PIPED_ID varchar(255), + PORT_TYPE varchar(255), + PROPAGATE_TRANS bool, + STATUS varchar(255), + SUBSCRIBER_COUNT int4, + CORR_ID int8, + PARTNER_LINK_ID int8, + PROCESS_ID int8, + PROCESS_INSTANCE_ID int8, + REQUEST_MESSAGE_ID int8, + RESPONSE_MESSAGE_ID int8, + primary key (MESSAGE_EXCHANGE_ID) + ); + + create table ODE_MESSAGE_ROUTE ( + MESSAGE_ROUTE_ID int8 not null, + CORRELATION_KEY varchar(255), + GROUP_ID varchar(255), + ROUTE_INDEX int4, + PROCESS_INSTANCE_ID int8, + ROUTE_POLICY varchar(16), + CORR_ID int8, + primary key (MESSAGE_ROUTE_ID) + ); + + create table ODE_MEX_PROP ( + ID int8 not null, + MEX_ID varchar(255), + PROP_KEY varchar(255), + PROP_VALUE varchar(2000), + primary key (ID) + ); + + create table ODE_PARTNER_LINK ( + PARTNER_LINK_ID int8 not null, + MY_EPR text, + MY_ROLE_NAME varchar(255), + MY_ROLE_SERVICE_NAME varchar(255), + MY_SESSION_ID varchar(255), + PARTNER_EPR text, + PARTNER_LINK_MODEL_ID int4, + PARTNER_LINK_NAME varchar(255), + PARTNER_ROLE_NAME varchar(255), + PARTNER_SESSION_ID varchar(255), + SCOPE_ID int8, + primary key (PARTNER_LINK_ID) + ); + + create table ODE_PROCESS ( + ID int8 not null, + GUID varchar(255), + PROCESS_ID varchar(255), + PROCESS_TYPE varchar(255), + VERSION int8, + primary key (ID) + ); + + create table ODE_PROCESS_INSTANCE ( + ID int8 not null, + DATE_CREATED timestamp, + EXECUTION_STATE oid, + FAULT_ID int8, + LAST_ACTIVE_TIME timestamp, + LAST_RECOVERY_DATE timestamp, + PREVIOUS_STATE int2, + SEQUENCE int8, + INSTANCE_STATE int2, + INSTANTIATING_CORRELATOR_ID int8, + PROCESS_ID int8, + ROOT_SCOPE_ID int8, + primary key (ID) + ); + + create table ODE_SCOPE ( + SCOPE_ID int8 not null, + MODEL_ID int4, + SCOPE_NAME varchar(255), + SCOPE_STATE varchar(255), + PARENT_SCOPE_ID int8, + PROCESS_INSTANCE_ID int8, + primary key (SCOPE_ID) + ); + + create table ODE_XML_DATA ( + XML_DATA_ID int8 not null, + DATA text, + IS_SIMPLE_TYPE bool, + NAME varchar(255), + SCOPE_ID int8, + primary key (XML_DATA_ID) + ); + + create table ODE_XML_DATA_PROP ( + ID int8 not null, + XML_DATA_ID int8, + PROP_KEY varchar(255), + PROP_VALUE varchar(255), + primary key (ID) + ); + + create table STORE_DU ( + NAME varchar(255) not null, + DEPLOYDT timestamp, + DEPLOYER varchar(255), + DIR varchar(255), + primary key (NAME) + ); + + create table STORE_PROCESS ( + PID varchar(255) not null, + STATE varchar(255), + TYPE varchar(255), + VERSION int8, + DU varchar(255), + primary key (PID) + ); + + create table STORE_PROCESS_PROP ( + ID int8 not null, + PROP_KEY varchar(255), + PROP_VAL varchar(255), + primary key (ID) + ); + + create table STORE_PROC_TO_PROP ( + STORE_PROCESS_PID varchar(255) not null, + STORE_PROPERTY_ID int8 not null, + primary key (STORE_PROCESS_PID, STORE_PROPERTY_ID), + unique (STORE_PROPERTY_ID) + ); + + create table STORE_VERSIONS ( + ID int8 not null, + VERSION int8, + primary key (ID) + ); + + create sequence hibernate_sequence; \ No newline at end of file Modified: trunk/runtime/engine-assembly/src/main/resources/bpel.properties =================================================================== --- trunk/runtime/engine-assembly/src/main/resources/bpel.properties 2010-05-31 07:27:51 UTC (rev 683) +++ trunk/runtime/engine-assembly/src/main/resources/bpel.properties 2010-05-31 07:36:33 UTC (rev 684) @@ -53,7 +53,8 @@ ## DAO Connection Factory class. ## uncomment the following for hibernate. -bpel.dao.factory=org.apache.ode.daohib.bpel.BpelDAOConnectionFactoryImpl +bpel.dao.factory=org.apache.ode.dao.jpa.hibernate.BpelDAOConnectionFactoryImpl +bpel.dao.factory.store=org.apache.ode.dao.jpa.hibernate.ConfStoreDAOConnectionFactoryImpl ## Transaction Factory ## default is org.apache.ode.il.EmbeddedGeronimoFactory @@ -86,6 +87,7 @@ #bpel.extension.bundles.validation = bpel.db.mode=EXTERNAL +db.emb.create=false bpel.db.ext.dataSource=java:BPELDB # if set to true will self-register BPEL endpoints upon deployment to a UDDI. # this uses the juddi-client-3.0.0 and the uddi client config can be set in the uddi.xml