You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by mr...@apache.org on 2006/12/14 03:05:35 UTC
svn commit: r486927 -
/incubator/ode/trunk/bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java
Author: mriou
Date: Wed Dec 13 18:05:35 2006
New Revision: 486927
URL: http://svn.apache.org/viewvc?view=rev&rev=486927
Log:
Passing a dialect to the store as some drivers don't support dialect detection.
Modified:
incubator/ode/trunk/bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java
Modified: incubator/ode/trunk/bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java
URL: http://svn.apache.org/viewvc/incubator/ode/trunk/bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java?view=diff&rev=486927&r1=486926&r2=486927
==============================================================================
--- incubator/ode/trunk/bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java (original)
+++ incubator/ode/trunk/bpel-store/src/main/java/org/apache/ode/store/ProcessStoreImpl.java Wed Dec 13 18:05:35 2006
@@ -80,12 +80,12 @@
private DataSource _inMemDs;
public ProcessStoreImpl() {
- this(null);
+ this(null, null);
}
- public ProcessStoreImpl(DataSource ds) {
+ public ProcessStoreImpl(DataSource ds, String dbName) {
if (ds != null) {
- _cf = new DbConfStoreConnectionFactory(ds, false);
+ _cf = new DbConfStoreConnectionFactory(ds, false, dbName);
} else {
// If the datasource is not provided, then we create a HSQL-based in-memory
@@ -94,7 +94,7 @@
hsqlds.setDatabase("jdbc:hsqldb:mem:" + _guid);
hsqlds.setUser("sa");
hsqlds.setPassword("");
- _cf = new DbConfStoreConnectionFactory(hsqlds, true);
+ _cf = new DbConfStoreConnectionFactory(hsqlds, true, null);
_inMemDs = hsqlds;
}
@@ -533,7 +533,7 @@
_deploymentUnits.put(dud.getName(),dud);
for (ProcessConfDAO p : dudao.getProcesses()) {
- Process pinfo = dud.getProcessDeployInfo(p.getPID());
+ TDeployment.Process pinfo = dud.getProcessDeployInfo(p.getPID());
if (pinfo == null) {
__log.warn("Cannot load " + p.getPID() + "; cannot find descriptor.");
continue;
@@ -592,4 +592,5 @@
abstract V call(ConfStoreConnection conn);
}
+
}