diff options
Diffstat (limited to 'sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache')
14 files changed, 931 insertions, 0 deletions
diff --git a/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementation.java b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementation.java new file mode 100644 index 0000000000..c1ed6b4e58 --- /dev/null +++ b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementation.java @@ -0,0 +1,36 @@ +/* + * 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/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementationFactory.java b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementationFactory.java new file mode 100644 index 0000000000..a5812b26e4 --- /dev/null +++ b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementationFactory.java @@ -0,0 +1,24 @@ +/* + * 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/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementationProcessor.java b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementationProcessor.java new file mode 100644 index 0000000000..7ddd30047a --- /dev/null +++ b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/JPAImplementationProcessor.java @@ -0,0 +1,99 @@ +/* + * 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.jpa"); + 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/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/PersistenceUnitInfoImplProcessor.java b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/PersistenceUnitInfoImplProcessor.java new file mode 100644 index 0000000000..d6e8276f25 --- /dev/null +++ b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/PersistenceUnitInfoImplProcessor.java @@ -0,0 +1,109 @@ +/* + * 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/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyBrokerFactory.java b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyBrokerFactory.java new file mode 100644 index 0000000000..c4b14a1a90 --- /dev/null +++ b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyBrokerFactory.java @@ -0,0 +1,100 @@ +/* + * 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/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyBrokerImpl.java b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyBrokerImpl.java new file mode 100644 index 0000000000..f5972142de --- /dev/null +++ b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyBrokerImpl.java @@ -0,0 +1,37 @@ +/* + * 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/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyJDBCConfigurationImpl.java b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyJDBCConfigurationImpl.java new file mode 100644 index 0000000000..820121824a --- /dev/null +++ b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyJDBCConfigurationImpl.java @@ -0,0 +1,59 @@ +/* + * 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.jdbc.conf.JDBCConfigurationImpl; +import org.apache.openjpa.jdbc.sql.DBDictionary; +import org.apache.openjpa.jdbc.sql.DerbyDictionary; +import org.apache.openjpa.kernel.BrokerImpl; +import org.apache.openjpa.lib.conf.Configurations; +import javax.sql.*; +import org.apache.openjpa.ee.*; +import org.apache.openjpa.kernel.*; + +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/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyManagerRuntime.java b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyManagerRuntime.java new file mode 100644 index 0000000000..2fb35f83a1 --- /dev/null +++ b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyManagerRuntime.java @@ -0,0 +1,51 @@ +/* + * 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/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyStoreManager.java b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyStoreManager.java new file mode 100644 index 0000000000..441ba666d7 --- /dev/null +++ b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/TuscanyStoreManager.java @@ -0,0 +1,49 @@ +/* + * 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/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/impl/JPAImplementationFactoryImpl.java b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/impl/JPAImplementationFactoryImpl.java new file mode 100644 index 0000000000..2a7d1abd70 --- /dev/null +++ b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/impl/JPAImplementationFactoryImpl.java @@ -0,0 +1,39 @@ +/* + * 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/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/impl/JPAImplementationImpl.java b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/impl/JPAImplementationImpl.java new file mode 100644 index 0000000000..055ecd4a4d --- /dev/null +++ b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/impl/JPAImplementationImpl.java @@ -0,0 +1,119 @@ +/* + * 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/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAImplementationProvider.java b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAImplementationProvider.java new file mode 100644 index 0000000000..fbff09341c --- /dev/null +++ b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAImplementationProvider.java @@ -0,0 +1,101 @@ +/* + * 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); + try { + // tm.begin(); + } catch (Exception ex) { + ex.printStackTrace(); + } + 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/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAImplementationProviderFactory.java b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAImplementationProviderFactory.java new file mode 100644 index 0000000000..11a92c5064 --- /dev/null +++ b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAImplementationProviderFactory.java @@ -0,0 +1,45 @@ +/* + * 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 eP; + + public JPAImplementationProviderFactory(ExtensionPointRegistry extensionPoints) { + eP = extensionPoints; + } + + public ImplementationProvider createImplementationProvider(RuntimeComponent component, + JPAImplementation implementation) { + return new JPAImplementationProvider(component, implementation, eP); + } + + public Class<JPAImplementation> getModelType() { + // TODO Auto-generated method stub + return null; + } + +} diff --git a/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAInvoker.java b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAInvoker.java new file mode 100644 index 0000000000..8b74209d3e --- /dev/null +++ b/sandbox/sebastien/java/sca-node/modules/implementation-openjpa/src/main/java/org/apache/tuscany/sca/implementation/openjpa/provider/JPAInvoker.java @@ -0,0 +1,63 @@ +/* + * 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); + + } + } + +} |