summaryrefslogtreecommitdiffstats
path: root/sandbox/event/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyBrokerFactory.java
diff options
context:
space:
mode:
Diffstat (limited to 'sandbox/event/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyBrokerFactory.java')
-rw-r--r--sandbox/event/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyBrokerFactory.java100
1 files changed, 0 insertions, 100 deletions
diff --git a/sandbox/event/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyBrokerFactory.java b/sandbox/event/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyBrokerFactory.java
deleted file mode 100644
index c4b14a1a90..0000000000
--- a/sandbox/event/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyBrokerFactory.java
+++ /dev/null
@@ -1,100 +0,0 @@
-/*
- * 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.
- */
-
-package org.apache.tuscany.sca.implementation.openjpa;
-
-import javax.sql.XAConnection;
-import javax.transaction.TransactionManager;
-
-import org.apache.derby.jdbc.*;
-import org.apache.openjpa.conf.OpenJPAConfiguration;
-import org.apache.openjpa.kernel.AbstractBrokerFactory;
-import org.apache.openjpa.kernel.StoreManager;
-import org.apache.openjpa.lib.conf.ConfigurationProvider;
-import java.util.*;
-import org.apache.commons.logging.*;
-import org.apache.openjpa.jdbc.meta.MappingTool;
-import org.apache.openjpa.jdbc.conf.*;
-import org.apache.openjpa.meta.*;
-
-public class TuscanyBrokerFactory extends AbstractBrokerFactory {
- private Log log = LogFactory.getLog(this.getClass());
- protected TuscanyBrokerFactory(OpenJPAConfiguration conf) {
- super(conf);
- if (buildSchema != null && buildSchema.equals("buildSchema")) {
- MappingTool tool = new MappingTool((JDBCConfiguration) conf,
- (String) buildSchema, false);
- Collection classes = meta.loadPersistentTypes(false, this
- .getClass().getClassLoader());
- for (Iterator itr = classes.iterator(); itr.hasNext();) {
- tool.run((Class) itr.next());
- }
- log
- .info("creating database and tables accroding to class mappings...");
- tool.record();
- }
- }
-
- private XAConnection xaconn;
-
- @Override
- protected StoreManager newStoreManager() {
- try {
- if (xaconn == null) {
- if (cp.getProperties().get("dbtype").equals("Derby")) {
- EmbeddedXADataSource xads = new EmbeddedXADataSource();
- xads.setDatabaseName((String)cp.getProperties().get("dbname"));
-
- xaconn = xads.getXAConnection();
- }
-
- System.out.println("------------TuscanyBrokerFactory.newStoreManager....");
-
- }
- return new TuscanyStoreManager(xaconn);
-
- } catch (Exception ex) {
- ex.printStackTrace();
- throw new RuntimeException(ex);
- }
- }
-
- private static TransactionManager tm;
- private static ConfigurationProvider cp;
- private static Object buildSchema;
- private static MetaDataRepository meta;
-
- public static TuscanyBrokerFactory newInstance(ConfigurationProvider _cp) {
- tm = (TransactionManager)_cp.getProperties().get("TransactionManager");
- EmbeddedDataSource ds2 = null;
- if (_cp.getProperties().get("dbtype").equals("Derby")) {
- ds2 = new EmbeddedDataSource();
- ds2.setDatabaseName((String) _cp.getProperties().get("dbname"));
- ds2.setCreateDatabase((String) _cp.getProperties().get("dbcreate"));
- }
- TuscanyJDBCConfigurationImpl conf = new TuscanyJDBCConfigurationImpl(tm, ds2);
- _cp.setInto(conf);
- buildSchema = _cp.getProperties().get(
- "openjpa.jdbc.SynchronizeMappings");
-
- meta = conf.getMetaDataRepositoryInstance();
- cp = _cp;
- return new TuscanyBrokerFactory(conf);
- }
-}