diff options
Diffstat (limited to 'sandbox/lresende/sca/modules/implementation-data-pojo/src')
25 files changed, 0 insertions, 1399 deletions
diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementation.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementation.java deleted file mode 100644 index c1ed6b4e58..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementation.java +++ /dev/null @@ -1,36 +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 java.util.Properties; - -import org.apache.openjpa.persistence.PersistenceUnitInfoImpl; -import org.apache.tuscany.sca.assembly.Implementation; - -public interface JPAImplementation extends Implementation { - - void setPersistenceUnitInfoImpl(PersistenceUnitInfoImpl buii); - - PersistenceUnitInfoImpl getPersistenceUnitInfoImpl(); - - void setDataSourceMeta(Properties p); - - Properties getDataSourceMeta(); -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementationFactory.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementationFactory.java deleted file mode 100644 index a5812b26e4..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementationFactory.java +++ /dev/null @@ -1,24 +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; - -public interface JPAImplementationFactory { - JPAImplementation createOpenJpaImplementation(); -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementationProcessor.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementationProcessor.java deleted file mode 100644 index 8ea83e7bfb..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementationProcessor.java +++ /dev/null @@ -1,99 +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 java.util.Properties; - -import javax.xml.namespace.QName; -import javax.xml.stream.XMLStreamConstants; -import javax.xml.stream.XMLStreamException; -import javax.xml.stream.XMLStreamReader; -import javax.xml.stream.XMLStreamWriter; - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.openjpa.persistence.PersistenceUnitInfoImpl; -import org.apache.tuscany.sca.assembly.AssemblyFactory; -import org.apache.tuscany.sca.assembly.xml.Constants; -import org.apache.tuscany.sca.contribution.ModelFactoryExtensionPoint; -import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor; -import org.apache.tuscany.sca.contribution.resolver.ModelResolver; -import org.apache.tuscany.sca.contribution.service.ContributionReadException; -import org.apache.tuscany.sca.contribution.service.ContributionResolveException; -import org.apache.tuscany.sca.contribution.service.ContributionWriteException; -import org.apache.tuscany.sca.implementation.openjpa.impl.JPAImplementationFactoryImpl; -import org.apache.tuscany.sca.interfacedef.java.JavaInterfaceFactory; - -public class JPAImplementationProcessor implements StAXArtifactProcessor<JPAImplementation> { - private final QName QNAME = new QName(Constants.SCA10_TUSCANY_NS, "implementation.data.pojo"); - private QName DS = new QName(Constants.SCA10_TUSCANY_NS, "datasource"); - - private JPAImplementationFactory jpaFactory; - private Log log = LogFactory.getLog(this.getClass()); - private StAXArtifactProcessor<PersistenceUnitInfoImpl> puiiProcessor; - - public JPAImplementationProcessor(ModelFactoryExtensionPoint modelFactories) { - AssemblyFactory assemblyFactory = modelFactories.getFactory(AssemblyFactory.class); - JavaInterfaceFactory javaFactory = modelFactories.getFactory(JavaInterfaceFactory.class); - - this.jpaFactory = new JPAImplementationFactoryImpl(assemblyFactory, javaFactory); - this.puiiProcessor = new PersistenceUnitInfoImplProcessor(modelFactories); - } - - public Class<JPAImplementation> getModelType() { - return JPAImplementation.class; - } - - public QName getArtifactType() { - return QNAME; - } - - public JPAImplementation read(XMLStreamReader reader) throws ContributionReadException, XMLStreamException { - assert QNAME.equals(reader.getName()); - JPAImplementation implementation = jpaFactory.createOpenJpaImplementation(); - - implementation.setPersistenceUnitInfoImpl(puiiProcessor.read(reader)); - Properties dsmeta = new Properties(); - do { - int event = reader.next(); - if (event == XMLStreamConstants.START_ELEMENT) { - if (!reader.getName().equals(DS)) { - dsmeta.setProperty(reader.getName().getLocalPart(), reader.getElementText()); - } - } else if (event == XMLStreamConstants.END_ELEMENT && reader.getName().equals(DS)) { - implementation.setDataSourceMeta(dsmeta); - break; - } - } while (true); - - return implementation; - - } - - public void write(JPAImplementation model, XMLStreamWriter writer) throws ContributionWriteException, XMLStreamException { - // TODO Auto-generated method stub - - } - - public void resolve(JPAImplementation model, ModelResolver resolver) throws ContributionResolveException { - - } - -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/PersistenceUnitInfoImplProcessor.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/PersistenceUnitInfoImplProcessor.java deleted file mode 100644 index d6e8276f25..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/PersistenceUnitInfoImplProcessor.java +++ /dev/null @@ -1,109 +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.xml.namespace.QName; -import javax.xml.stream.XMLStreamConstants; -import javax.xml.stream.XMLStreamException; -import javax.xml.stream.XMLStreamReader; -import javax.xml.stream.XMLStreamWriter; - -import org.apache.openjpa.persistence.PersistenceUnitInfoImpl; -import org.apache.tuscany.sca.assembly.xml.Constants; -import org.apache.tuscany.sca.contribution.ModelFactoryExtensionPoint; -import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor; -import org.apache.tuscany.sca.contribution.resolver.ModelResolver; -import org.apache.tuscany.sca.contribution.service.ContributionReadException; -import org.apache.tuscany.sca.contribution.service.ContributionResolveException; -import org.apache.tuscany.sca.contribution.service.ContributionWriteException; - -public class PersistenceUnitInfoImplProcessor implements StAXArtifactProcessor<PersistenceUnitInfoImpl> { - private QName P_U = new QName(Constants.SCA10_TUSCANY_NS, "persistence-unit"); - private QName BrokerFactory = new QName(Constants.SCA10_TUSCANY_NS, "jpa.BrokerFactory"); - private QName CLASS = new QName(Constants.SCA10_TUSCANY_NS, "class"); - private QName TRAN_MD = new QName(Constants.SCA10_TUSCANY_NS, "jpa.TransactionMode"); - private QName LOG = new QName(Constants.SCA10_TUSCANY_NS, "jpa.Log"); - private QName SYNCHRON = new QName(Constants.SCA10_TUSCANY_NS, "jpa.jdbc.SynchronizeMappings"); - - public PersistenceUnitInfoImplProcessor(ModelFactoryExtensionPoint modelFactories) { - - } - - public QName getArtifactType() { - // TODO Auto-generated method stub - return null; - } - - - public PersistenceUnitInfoImpl read(XMLStreamReader reader) throws ContributionReadException, XMLStreamException { - - PersistenceUnitInfoImpl _info = new PersistenceUnitInfoImpl(); - - while (true) { - int event = reader.next(); - switch (event) { - - case XMLStreamConstants.START_ELEMENT: - QName qn = reader.getName(); - /* - * if (qn.equals(BrokerFactory)) { - * _info.setProperty("openjpa.BrokerFactory", reader - * .getElementText()); } - */ - if (qn.equals(CLASS)) { - _info.addManagedClassName(reader.getElementText()); - - } else if (qn.equals(P_U)) { - _info.setPersistenceUnitName(reader.getAttributeValue(null, "name")); - } else { - _info.setProperty(qn.getLocalPart(), reader.getElementText()); - } /* - * else if (qn.equals(LOG)) { - * _info.setProperty("openjpa.Log", - * reader.getElementText()); } else if - * (qn.equals(SYNCHRON)) { - * _info.setProperty("openjpa.jdbc.SynchronizeMappings", - * reader.getElementText()); } - */ - break; - case XMLStreamConstants.END_ELEMENT: - if (reader.getName().equals(P_U)) - return _info; - } - } - } - - public void write(PersistenceUnitInfoImpl model, XMLStreamWriter writer) throws ContributionWriteException, - XMLStreamException { - // TODO Auto-generated method stub - - } - - public Class<PersistenceUnitInfoImpl> getModelType() { - // TODO Auto-generated method stub - return null; - } - - public void resolve(PersistenceUnitInfoImpl model, ModelResolver resolver) throws ContributionResolveException { - // TODO Auto-generated method stub - - } - -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyBrokerFactory.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyBrokerFactory.java deleted file mode 100644 index c4b14a1a90..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/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); - } -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyBrokerImpl.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyBrokerImpl.java deleted file mode 100644 index f5972142de..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyBrokerImpl.java +++ /dev/null @@ -1,37 +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.transaction.TransactionManager; - -import org.apache.openjpa.ee.ManagedRuntime; -import org.apache.openjpa.kernel.BrokerImpl; - -public class TuscanyBrokerImpl extends BrokerImpl { - private TransactionManager tm; - - public TuscanyBrokerImpl(TransactionManager tm) { - this.tm = tm; - } - - public ManagedRuntime getManagedRuntime() { - return new TuscanyManagerRuntime(tm); - } -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyJDBCConfigurationImpl.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyJDBCConfigurationImpl.java deleted file mode 100644 index 78de14cc1c..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyJDBCConfigurationImpl.java +++ /dev/null @@ -1,58 +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.DataSource; -import javax.transaction.TransactionManager; - -import org.apache.openjpa.ee.ManagedRuntime; -import org.apache.openjpa.jdbc.conf.JDBCConfigurationImpl; -import org.apache.openjpa.jdbc.sql.DBDictionary; -import org.apache.openjpa.jdbc.sql.DerbyDictionary; -import org.apache.openjpa.kernel.StoreContext; -import org.apache.openjpa.lib.conf.Configurations; - -public class TuscanyJDBCConfigurationImpl extends JDBCConfigurationImpl { - private TransactionManager tm; - - public TuscanyJDBCConfigurationImpl(TransactionManager tm,DataSource _ds) { - this.tm = tm; - ds2 = _ds; - } - public ManagedRuntime getManagedRuntimeInstance() { - return new TuscanyManagerRuntime(tm); - } - - public Object getConnectionFactory() { - return null; - } - - public DBDictionary getDBDictionaryInstance() { - DerbyDictionary dd = new DerbyDictionary(); - Configurations.configureInstance(dd, this, "", ""); - return dd; - } - private DataSource ds2; - @Override - public DataSource getDataSource2(StoreContext ctx) { - - return ds2; - } -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyManagerRuntime.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyManagerRuntime.java deleted file mode 100644 index 2fb35f83a1..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyManagerRuntime.java +++ /dev/null @@ -1,51 +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.transaction.SystemException; -import javax.transaction.TransactionManager; - -import org.apache.openjpa.ee.ManagedRuntime; - -public class TuscanyManagerRuntime implements ManagedRuntime{ - public TuscanyManagerRuntime(TransactionManager tm){ - this.tm = tm; - } - public Throwable getRollbackCause() throws Exception { - // TODO Auto-generated method stub - return null; - } - - public Object getTransactionKey() throws Exception, SystemException { - // TODO Auto-generated method stub - return "Geng"; - } - private TransactionManager tm; - public TransactionManager getTransactionManager() throws Exception { - - - return tm; - } - - public void setRollbackOnly(Throwable cause) throws Exception { - // TODO Auto-generated method stub - - } - -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyStoreManager.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyStoreManager.java deleted file mode 100644 index 441ba666d7..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyStoreManager.java +++ /dev/null @@ -1,49 +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 java.sql.Connection; -import java.sql.SQLException; - -import javax.sql.XAConnection; - -import org.apache.openjpa.jdbc.kernel.JDBCStoreManager; - -public class TuscanyStoreManager extends JDBCStoreManager { - private XAConnection xaconn; - - public TuscanyStoreManager(XAConnection xaconn) { - this.xaconn = xaconn; - } - - protected _RefCountConnection connectInternal() throws SQLException { - Connection conn = xaconn.getConnection(); - // conn.setAutoCommit(false); - _RefCountConnection rc = new _RefCountConnection(conn); - return rc; - } - - class _RefCountConnection extends RefCountConnection { - public _RefCountConnection(Connection conn) { - - super(conn); - } - } -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/impl/JPAImplementationFactoryImpl.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/impl/JPAImplementationFactoryImpl.java deleted file mode 100644 index 2a7d1abd70..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/impl/JPAImplementationFactoryImpl.java +++ /dev/null @@ -1,39 +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.impl; - -import org.apache.tuscany.sca.assembly.AssemblyFactory; -import org.apache.tuscany.sca.implementation.openjpa.*; -import org.apache.tuscany.sca.interfacedef.java.JavaInterfaceFactory; - -public class JPAImplementationFactoryImpl implements JPAImplementationFactory { - private AssemblyFactory assemblyFactory; - private JavaInterfaceFactory javaFactory; - - public JPAImplementationFactoryImpl(AssemblyFactory aF, JavaInterfaceFactory javaIF) { - this.assemblyFactory = aF; - this.javaFactory = javaIF; - } - - public JPAImplementation createOpenJpaImplementation() { - return new JPAImplementationImpl(assemblyFactory, javaFactory); - } - -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/impl/JPAImplementationImpl.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/impl/JPAImplementationImpl.java deleted file mode 100644 index 055ecd4a4d..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/impl/JPAImplementationImpl.java +++ /dev/null @@ -1,119 +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.impl; - -import java.util.Collections; -import java.util.List; -import java.util.Properties; - -import javax.persistence.EntityManager; - -import org.apache.openjpa.persistence.PersistenceUnitInfoImpl; -import org.apache.tuscany.sca.assembly.AssemblyFactory; -import org.apache.tuscany.sca.assembly.ConstrainingType; -import org.apache.tuscany.sca.assembly.Property; -import org.apache.tuscany.sca.assembly.Reference; -import org.apache.tuscany.sca.assembly.Service; -import org.apache.tuscany.sca.implementation.openjpa.JPAImplementation; -import org.apache.tuscany.sca.interfacedef.InvalidInterfaceException; -import org.apache.tuscany.sca.interfacedef.java.JavaInterface; -import org.apache.tuscany.sca.interfacedef.java.JavaInterfaceContract; -import org.apache.tuscany.sca.interfacedef.java.JavaInterfaceFactory; - -public class JPAImplementationImpl implements JPAImplementation { - private Service jpaService; - private PersistenceUnitInfoImpl puii; - private Properties dsmeta; - - public void setPersistenceUnitInfoImpl(PersistenceUnitInfoImpl puii) { - this.puii = puii; - } - - public PersistenceUnitInfoImpl getPersistenceUnitInfoImpl() { - return this.puii; - } - - public void setDataSourceMeta(Properties p) { - dsmeta = p; - } - - public Properties getDataSourceMeta() { - return dsmeta; - } - - JPAImplementationImpl(AssemblyFactory assemblyFactory, JavaInterfaceFactory javaFactory) { - - jpaService = assemblyFactory.createService(); - jpaService.setName("EntityManager"); - JavaInterface javaInterface; - try { - javaInterface = javaFactory.createJavaInterface(EntityManager.class); - } catch (InvalidInterfaceException e) { - throw new IllegalArgumentException(e); - } - JavaInterfaceContract interfaceContract = javaFactory.createJavaInterfaceContract(); - interfaceContract.setInterface(javaInterface); - jpaService.setInterfaceContract(interfaceContract); - } - - public boolean isUnresolved() { - // TODO Auto-generated method stub - return false; - } - - public void setUnresolved(boolean unresolved) { - // TODO Auto-generated method stub - - } - - public ConstrainingType getConstrainingType() { - // TODO Auto-generated method stub - return null; - } - - public List<Property> getProperties() { - // TODO Auto-generated method stub - return Collections.emptyList(); - } - - public List<Reference> getReferences() { - return Collections.emptyList(); - } - - public List<Service> getServices() { - return Collections.singletonList(jpaService); - } - - public String getURI() { - // TODO Auto-generated method stub - return null; - } - - public void setConstrainingType(ConstrainingType constrainingType) { - // TODO Auto-generated method stub - - } - - public void setURI(String uri) { - // TODO Auto-generated method stub - - } - -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAImplementationProvider.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAImplementationProvider.java deleted file mode 100644 index 5a863a8ae7..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAImplementationProvider.java +++ /dev/null @@ -1,96 +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.provider; - -import java.util.HashMap; -import java.util.Map; - -import javax.persistence.EntityManagerFactory; -import javax.transaction.TransactionManager; - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.openjpa.kernel.Bootstrap; -import org.apache.openjpa.kernel.BrokerFactory; -import org.apache.openjpa.persistence.JPAFacadeHelper; -import org.apache.openjpa.persistence.PersistenceUnitInfoImpl; -import org.apache.openjpa.persistence.PersistenceProductDerivation.ConfigurationProviderImpl; -import org.apache.tuscany.sca.core.ExtensionPointRegistry; -import org.apache.tuscany.sca.implementation.openjpa.JPAImplementation; -import org.apache.tuscany.sca.interfacedef.Operation; -import org.apache.tuscany.sca.invocation.Invoker; -import org.apache.tuscany.sca.provider.ImplementationProvider; -import org.apache.tuscany.sca.runtime.RuntimeComponent; -import org.apache.tuscany.sca.runtime.RuntimeComponentService; - -public class JPAImplementationProvider implements ImplementationProvider { - private RuntimeComponent component; - private JPAImplementation implementation; - private EntityManagerFactory emf; - private TransactionManager tm; - - public JPAImplementationProvider(RuntimeComponent component, - JPAImplementation implementation, - ExtensionPointRegistry extensionPoints) { - this.component = component; - this.implementation = implementation; - tm = (TransactionManager)extensionPoints.getExtensionPoint(org.apache.geronimo.transaction.manager.XAWork.class); - - initEntityManager(); - } - - private void initEntityManager() { - Map map = new HashMap(); - map.put("TransactionManager", tm); - PersistenceUnitInfoImpl _info = implementation.getPersistenceUnitInfoImpl(); - _info.fromUserProperties(map); - ConfigurationProviderImpl cp = new ConfigurationProviderImpl(); - cp.addProperties(_info.toOpenJPAProperties()); - cp.addProperties(implementation.getDataSourceMeta()); - - BrokerFactory factory = Bootstrap.newBrokerFactory(cp, null); - - emf = JPAFacadeHelper.toEntityManagerFactory(factory); - - } - - private Log log = LogFactory.getLog(this.getClass()); - - public Invoker createInvoker(RuntimeComponentService service, Operation operation) { - - return new JPAInvoker(operation, emf, tm); - } - - public void start() { - // TODO Auto-generated method stub - - } - - public void stop() { - // TODO Auto-generated method stub - - } - - public boolean supportsOneWayInvocation() { - // TODO Auto-generated method stub - return false; - } - -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAImplementationProviderFactory.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAImplementationProviderFactory.java deleted file mode 100644 index e1e821113c..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAImplementationProviderFactory.java +++ /dev/null @@ -1,44 +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.provider; - -import org.apache.tuscany.sca.core.ExtensionPointRegistry; -import org.apache.tuscany.sca.implementation.openjpa.JPAImplementation; -import org.apache.tuscany.sca.provider.ImplementationProvider; -import org.apache.tuscany.sca.provider.ImplementationProviderFactory; -import org.apache.tuscany.sca.runtime.RuntimeComponent; - -public class JPAImplementationProviderFactory implements ImplementationProviderFactory<JPAImplementation> { - private ExtensionPointRegistry extensionPointRegistry; - - public JPAImplementationProviderFactory(ExtensionPointRegistry extensionPoints) { - extensionPointRegistry = extensionPoints; - } - - public ImplementationProvider createImplementationProvider(RuntimeComponent component, - JPAImplementation implementation) { - return new JPAImplementationProvider(component, implementation, extensionPointRegistry); - } - - public Class<JPAImplementation> getModelType() { - return JPAImplementation.class; - } - -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAInvoker.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAInvoker.java deleted file mode 100644 index 8b74209d3e..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAInvoker.java +++ /dev/null @@ -1,63 +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.provider; - -import java.lang.reflect.Method; - -import javax.persistence.EntityManager; -import javax.persistence.EntityManagerFactory; -import javax.transaction.TransactionManager; - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; -import org.apache.tuscany.sca.interfacedef.Operation; -import org.apache.tuscany.sca.interfacedef.java.impl.JavaInterfaceUtil; -import org.apache.tuscany.sca.invocation.Invoker; -import org.apache.tuscany.sca.invocation.Message; - -public class JPAInvoker implements Invoker { - private Operation operation; - private TransactionManager tm; - - public JPAInvoker(Operation operation, EntityManagerFactory emf, TransactionManager tm) { - this.operation = operation; - this.tm = tm; - this.emf = emf; - } - - private Log log = LogFactory.getLog(this.getClass()); - private EntityManagerFactory emf; - - public Message invoke(Message msg) { - try { - tm.begin(); - Method method = JavaInterfaceUtil.findMethod(EntityManager.class, operation); - Object r = method.invoke(emf.createEntityManager(), (Object[])msg.getBody()); - tm.commit(); - log.info(method); - msg.setBody(r); - return msg; - } catch (Exception ex) { - throw new RuntimeException(ex); - - } - } - -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor b/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor deleted file mode 100644 index 8c82832e01..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor +++ /dev/null @@ -1,19 +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. - -# Implementation class for the artifact processor extension -org.apache.tuscany.sca.implementation.openjpa.JPAImplementationProcessor;qname=http://tuscany.apache.org/xmlns/sca/1.0#implementation.data.pojo,model=org.apache.tuscany.sca.implementation.openjpa.JPAImplementation
\ No newline at end of file diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/resources/META-INF/services/org.apache.tuscany.sca.implementation.openjpa.OpenJpaImplementationFactory b/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/resources/META-INF/services/org.apache.tuscany.sca.implementation.openjpa.OpenJpaImplementationFactory deleted file mode 100644 index 13067543c9..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/resources/META-INF/services/org.apache.tuscany.sca.implementation.openjpa.OpenJpaImplementationFactory +++ /dev/null @@ -1,18 +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.
-
-org.apache.tuscany.sca.implementation.openjpa.impl.JPAImplementationFactoryImpl
\ No newline at end of file diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/resources/META-INF/services/org.apache.tuscany.sca.provider.ImplementationProviderFactory b/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/resources/META-INF/services/org.apache.tuscany.sca.provider.ImplementationProviderFactory deleted file mode 100644 index fb62ff853b..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/main/resources/META-INF/services/org.apache.tuscany.sca.provider.ImplementationProviderFactory +++ /dev/null @@ -1,19 +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.
-
-# Implementation class for the implementation extension
-org.apache.tuscany.sca.implementation.openjpa.provider.JPAImplementationProviderFactory;model=org.apache.tuscany.sca.implementation.openjpa.JPAImplementation
\ No newline at end of file diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/java/company/Company.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/java/company/Company.java deleted file mode 100644 index 3ea6e65c0d..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/java/company/Company.java +++ /dev/null @@ -1,47 +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 company; - -import javax.persistence.*; - -@Entity -public class Company { - @Id private int id; - @Basic private String name; - - public int getId() { - return id; - } - - public void setId(int i) { - id = i; - } - - public String getName() { - return this.name; - } - - public void setName(String name) { - this.name = name; - } - - public String toString() { - return "Company (" + getId() + ") is is " + getName(); - } -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/java/company/CompanyCollection.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/java/company/CompanyCollection.java deleted file mode 100644 index b74f53aa8b..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/java/company/CompanyCollection.java +++ /dev/null @@ -1,25 +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 company; - -import org.apache.tuscany.sca.implementation.data.collection.Collection; - -public interface CompanyCollection extends Collection<String, Company> { - -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/java/company/CompanyCollectionImpl.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/java/company/CompanyCollectionImpl.java deleted file mode 100644 index 385defeb0b..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/java/company/CompanyCollectionImpl.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 company; - -import java.util.Iterator; -import java.util.List; - -import javax.persistence.EntityManager; -import javax.persistence.EntityManagerFactory; -import javax.persistence.EntityTransaction; -import javax.persistence.Persistence; -import javax.persistence.Query; - -import org.apache.tuscany.sca.implementation.data.collection.Entry; -import org.apache.tuscany.sca.implementation.data.collection.NotFoundException; - -public class CompanyCollectionImpl implements CompanyCollection { - EntityManagerFactory emf = null; - EntityManager em = null; - - public CompanyCollectionImpl() { - System.out.println(">>>"); - try { - emf = Persistence.createEntityManagerFactory("company-openJPA"); - em = emf.createEntityManager(); - } catch (Exception e) { - e.printStackTrace(); - } - } - - public void delete(String arg0) throws NotFoundException { - // TODO Auto-generated method stub - - } - - public Company get(String arg0) throws NotFoundException { - // TODO Auto-generated method stub - return null; - } - - public Entry<String, Company>[] getAll() { - EntityTransaction tx = em.getTransaction(); - try { - tx.begin(); - - Query q = em.createQuery("SELECT c FROM company c"); - List results = q.getResultList(); - Iterator iter = results.iterator(); - while (iter.hasNext()) { - Company company = (Company)iter.next(); - - System.out.println(company); - } - - tx.commit(); - } catch(Exception e) { - e.printStackTrace(); - } finally { - if (tx.isActive()) { - tx.rollback(); - } - - em.close(); - } - - return null; - } - - public String post(String arg0, Company arg1) { - // TODO Auto-generated method stub - return null; - } - - public void put(String arg0, Company arg1) throws NotFoundException { - // TODO Auto-generated method stub - - } - - public Entry<String, Company>[] query(String arg0) { - // TODO Auto-generated method stub - return null; - } - -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/java/org/apache/tuscany/sca/implementation/openjpa/CompanyCollectionTestCase.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/java/org/apache/tuscany/sca/implementation/openjpa/CompanyCollectionTestCase.java deleted file mode 100644 index bc9fbb3543..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/java/org/apache/tuscany/sca/implementation/openjpa/CompanyCollectionTestCase.java +++ /dev/null @@ -1,44 +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 junit.framework.TestCase; - -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; - -import company.CompanyCollection; -import company.CompanyCollectionImpl; - -public class CompanyCollectionTestCase extends TestCase { - private Log log = LogFactory.getLog(this.getClass()); - private CompanyCollection collection = null; - - public void setUp() { - collection = new CompanyCollectionImpl(); - } - - public void testGetAll() { - collection.getAll(); - } - - public void tearDown() { - - } -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/java/org/apache/tuscany/sca/implementation/openjpa/CompanyTestCase.java b/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/java/org/apache/tuscany/sca/implementation/openjpa/CompanyTestCase.java deleted file mode 100644 index 1c4d6fb254..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/java/org/apache/tuscany/sca/implementation/openjpa/CompanyTestCase.java +++ /dev/null @@ -1,80 +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 junit.framework.*; -import org.apache.tuscany.sca.host.embedded.*; -import org.apache.commons.logging.*; - -import company.*; - -import javax.persistence.*; -import java.util.*; - -public class CompanyTestCase extends TestCase { - private EntityManager em; - private Log log = LogFactory.getLog(this.getClass()); - private SCADomain domain; - - public void setUp() { - domain = SCADomain.newInstance("openjpa.composite"); - em = domain.getService(EntityManager.class, "CompanyServiceComponent"); - - } - - public void testAccess() { - Company company = new Company(); - int id = new Random().nextInt(); - - company.setId(id); - company.setName("Company " + id); - - em.persist(company); - log.info(em.find(Company.class, id)); - - Query q = em.createQuery("select company from Company company"); - q.setMaxResults(5); - log.info("There are " + q.getResultList().size() + " Company in the database now"); - } - - public void testRollback() { - try { - Company company1 = new Company(); - Company company2 = new Company(); - - int id = new Random().nextInt(); - - company1.setId(id); - company1.setName("Company " + id); - em.persist(company1); - - company2.setId(id); - company2.setName("Company " + id); - em.persist(company2); - - } catch (RuntimeException ex) { - log.info("An expected exception occured, Tuscany is rolling back..."); - } - } - - public void tearDown() { - em.close(); - domain.close(); - } -} diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/resources/META-INF/orm.xml b/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/resources/META-INF/orm.xml deleted file mode 100644 index 75e329964f..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/resources/META-INF/orm.xml +++ /dev/null @@ -1,36 +0,0 @@ -<?xml version="1.0" encoding="UTF-8" ?> -<!-- - * 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. ---> - -<entity-mappings xmlns="http://java.sun.com/xml/ns/persistence/orm" - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" - xsi:schemaLocation="http://java.sun.com/xml/ns/persistence/orm http://java.sun.com/xml/ns/persistence/orm_1_0.xsd" - version="1.0"> - <entity class="company.Company" name="company"> - <table name="COMPANY"/> - <attributes> - <id name="id"> - <generated-value strategy="TABLE"/> - </id> - <basic name="name"> - <column name="NAME" length="30"/> - </basic> - </attributes> - </entity> -</entity-mappings>
\ No newline at end of file diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/resources/META-INF/persistence.xml b/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/resources/META-INF/persistence.xml deleted file mode 100644 index 302fbfe845..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/resources/META-INF/persistence.xml +++ /dev/null @@ -1,40 +0,0 @@ -<?xml version="1.0" encoding="UTF-8" ?> -<!-- - * 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. ---> - -<persistence xmlns="http://java.sun.com/xml/ns/persistence" - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" - xsi:schemaLocation="http://java.sun.com/xml/ns/persistence - http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd" version="1.0"> - - <persistence-unit name="company-openJPA"> - <!--mapping-file>orm.xml</mapping-file--> - <class>company.Company</class> - - <properties> - <property name="openjpa.ConnectionDriverName" value="org.apache.derby.jdbc.EmbeddedDriver"/> - <property name="openjpa.ConnectionURL" value="jdbc:derby:target/test-classes/company"/> - <property name="openjpa.ConnectionUserName" value=""/> - <property name="openjpa.ConnectionPassword" value=""/> - - <property name="openjpa.Log" value="DefaultLevel=TRACE, Tool=TRACE"/> - </properties> - </persistence-unit> - -</persistence>
\ No newline at end of file diff --git a/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/resources/company.composite b/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/resources/company.composite deleted file mode 100755 index fd164d2519..0000000000 --- a/sandbox/lresende/sca/modules/implementation-data-pojo/src/test/resources/company.composite +++ /dev/null @@ -1,47 +0,0 @@ -<?xml version="1.0" encoding="ASCII"?> -<!-- - * 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. ---> - -<composite xmlns="http://www.osoa.org/xmlns/sca/1.0" - xmlns:tuscany="http://tuscany.apache.org/xmlns/sca/1.0" - targetNamespace="http://sample/openjpa" - name="company"> - - <component name="CompanyServiceComponent"> - <tuscany:implementation.data.pojo> - - <tuscany:persistence-unit name="company"> - <tuscany:openjpa.BrokerFactory>org.apache.tuscany.sca.implementation.openjpa.TuscanyBrokerFactory</tuscany:openjpa.BrokerFactory> - <tuscany:openjpa.TransactionMode>managed</tuscany:openjpa.TransactionMode> - <tuscany:openjpa.Log>DefaultLevel=WARN,SQL=TRACE</tuscany:openjpa.Log> - <tuscany:openjpa.jdbc.SynchronizeMappings>buildSchema</tuscany:openjpa.jdbc.SynchronizeMappings> - - <tuscany:class>company.Company</tuscany:class> - </tuscany:persistence-unit> - - <tuscany:connectionInfo> - <tuscany:connectionProperties - driverClass="org.apache.derby.jdbc.EmbeddedDriver" - databaseURL="jdbc:derby:target/test-classes/company; create = true" - loginTimeout="600000"/> - </tuscany:connectionInfo> - </tuscany:implementation.data.pojo> - </component> - -</composite> |