summaryrefslogtreecommitdiffstats
path: root/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java
diff options
context:
space:
mode:
Diffstat (limited to 'sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java')
-rw-r--r--sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/Customer.java93
-rw-r--r--sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/CustomerCollection.java26
-rw-r--r--sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/CustomerCollectionImpl.java101
-rw-r--r--sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/CustomerService.java31
-rw-r--r--sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/CustomerServiceImpl.java117
-rw-r--r--sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/launch/Launch.java35
6 files changed, 403 insertions, 0 deletions
diff --git a/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/Customer.java b/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/Customer.java
new file mode 100644
index 0000000000..6d207ea2ef
--- /dev/null
+++ b/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/Customer.java
@@ -0,0 +1,93 @@
+/*
+ * 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 customer;
+
+import javax.persistence.Basic;
+import javax.persistence.Entity;
+import javax.persistence.Id;
+
+@Entity
+public class Customer {
+
+ @Id protected int id;
+ @Basic protected String name;
+ @Basic protected String phone;
+ @Basic protected String address;
+ @Basic protected String city;
+ @Basic protected String state;
+ @Basic protected String zip;
+
+ public int getId() {
+ return id;
+ }
+
+ public void setId(int id) {
+ this.id = id;
+ }
+
+ public String getName() {
+ return name;
+ }
+
+ public void setName(String name) {
+ this.name = name;
+ }
+
+ public String getPhone() {
+ return phone;
+ }
+
+ public void setPhone(String phone) {
+ this.phone = phone;
+ }
+
+ public String getAddress() {
+ return address;
+ }
+
+ public void setAddress(String address) {
+ this.address = address;
+ }
+
+ public String getCity() {
+ return city;
+ }
+
+ public void setCity(String city) {
+ this.city = city;
+ }
+
+ public String getState() {
+ return state;
+ }
+
+ public void setState(String state) {
+ this.state = state;
+ }
+
+ public String getZip() {
+ return zip;
+ }
+
+ public void setZip(String zip) {
+ this.zip = zip;
+ }
+
+}
diff --git a/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/CustomerCollection.java b/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/CustomerCollection.java
new file mode 100644
index 0000000000..5ad39aad5c
--- /dev/null
+++ b/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/CustomerCollection.java
@@ -0,0 +1,26 @@
+/*
+ * 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 customer;
+
+import org.apache.tuscany.sca.data.collection.Collection;
+
+
+public interface CustomerCollection extends Collection<String, Customer> {
+
+}
diff --git a/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/CustomerCollectionImpl.java b/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/CustomerCollectionImpl.java
new file mode 100644
index 0000000000..c0a2f25f15
--- /dev/null
+++ b/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/CustomerCollectionImpl.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 customer;
+
+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.data.collection.Entry;
+import org.apache.tuscany.sca.data.collection.NotFoundException;
+
+
+public class CustomerCollectionImpl implements CustomerCollection {
+ EntityManagerFactory emf = null;
+ EntityManager em = null;
+
+ public CustomerCollectionImpl() {
+ System.out.println(">>>");
+ try {
+ emf = Persistence.createEntityManagerFactory("customer-openJPA");
+ em = emf.createEntityManager();
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+ public void delete(String arg0) throws NotFoundException {
+ // TODO Auto-generated method stub
+
+ }
+
+ public Customer get(String arg0) throws NotFoundException {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ public Entry<String, Customer>[] getAll() {
+ EntityTransaction tx = em.getTransaction();
+ try {
+ tx.begin();
+
+ Query q = em.createQuery("SELECT c FROM customer c");
+ List results = q.getResultList();
+ Iterator iter = results.iterator();
+ while (iter.hasNext()) {
+ Customer customer = (Customer)iter.next();
+
+ System.out.println(customer);
+ }
+
+ tx.commit();
+ } catch(Exception e) {
+ e.printStackTrace();
+ } finally {
+ if (tx.isActive()) {
+ tx.rollback();
+ }
+
+ em.close();
+ }
+
+ return null;
+ }
+
+ public String post(String arg0, Customer arg1) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+ public void put(String arg0, Customer arg1) throws NotFoundException {
+ // TODO Auto-generated method stub
+
+ }
+
+ public Entry<String, Customer>[] query(String arg0) {
+ // TODO Auto-generated method stub
+ return null;
+ }
+
+}
diff --git a/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/CustomerService.java b/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/CustomerService.java
new file mode 100644
index 0000000000..7915cc6e77
--- /dev/null
+++ b/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/CustomerService.java
@@ -0,0 +1,31 @@
+/*
+ * 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 customer;
+
+import org.osoa.sca.annotations.Remotable;
+
+@Remotable
+public interface CustomerService {
+
+ Customer[] get();
+
+ Customer findCustomerByName(String name);
+
+}
diff --git a/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/CustomerServiceImpl.java b/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/CustomerServiceImpl.java
new file mode 100644
index 0000000000..0cba7d8bc1
--- /dev/null
+++ b/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/customer/CustomerServiceImpl.java
@@ -0,0 +1,117 @@
+/*
+ * 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 customer;
+
+import java.util.ArrayList;
+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.osoa.sca.annotations.Destroy;
+import org.osoa.sca.annotations.Init;
+
+public class CustomerServiceImpl implements CustomerService {
+ EntityManagerFactory emf = null;
+ EntityManager em = null;
+
+ public CustomerServiceImpl() {
+
+ }
+
+ @Init
+ public void init() {
+ System.out.println(">>> Initializing JPA");
+ try {
+ emf = Persistence.createEntityManagerFactory("customer-openJPA");
+ em = emf.createEntityManager();
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+ @Destroy
+ public void destroy() {
+ emf.close();
+ }
+
+ public Customer[] get() {
+ EntityTransaction tx = em.getTransaction();
+ List<Customer> customers = new ArrayList<Customer>();
+ try {
+ tx.begin();
+
+ Query q = em.createQuery("SELECT c FROM customer c");
+ List results = q.getResultList();
+ Iterator iter = results.iterator();
+ while (iter.hasNext()) {
+ Customer customer = (Customer)iter.next();
+ customers.add(customer);
+ }
+
+ tx.commit();
+ } catch (Exception e) {
+ e.printStackTrace();
+ } finally {
+ if (tx.isActive()) {
+ tx.rollback();
+ }
+
+ em.close();
+ }
+
+ Customer[] customerArray = new Customer[customers.size()];
+ customers.toArray(customerArray);
+ return customerArray;
+ }
+
+ public Customer findCustomerByName(String name) {
+ EntityTransaction tx = em.getTransaction();
+ Customer customer = null;
+
+ try {
+ tx.begin();
+
+ Query q = em.createQuery("SELECT c FROM customer c WHERE c.name = '" + name + "'");
+ List results = q.getResultList();
+ Iterator iter = results.iterator();
+ while (iter.hasNext()) {
+ customer = (Customer)iter.next();
+ }
+
+ tx.commit();
+ } catch (Exception e) {
+ e.printStackTrace();
+ } finally {
+ if (tx.isActive()) {
+ tx.rollback();
+ }
+
+ em.close();
+ }
+
+ return customer;
+ }
+
+}
diff --git a/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/launch/Launch.java b/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/launch/Launch.java
new file mode 100644
index 0000000000..a51ab605bc
--- /dev/null
+++ b/sca-java-2.x/branches/sca-equinox/samples/customer-dojo/src/main/java/launch/Launch.java
@@ -0,0 +1,35 @@
+/*
+ * 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 launch;
+
+import org.apache.tuscany.sca.host.embedded.SCADomain;
+
+public class Launch {
+ public static void main(String[] args) throws Exception {
+ System.out.println("Starting ...");
+ SCADomain scaDomain = SCADomain.newInstance("customer.composite");
+ System.out.println("customer.composite ready for big business !!!");
+ System.out.println("url : http://localhost:8080/customer.html");
+ System.in.read();
+ System.out.println("Stopping ...");
+ scaDomain.close();
+ System.out.println();
+ }
+}