Working on examples for Oracle

Author: Thomas Risberg

oracle/src/main/java/com/oreilly/springdata/jdbc/domain/AbstractEntity.java

@@ -0,0 +1,62 @@
+/*
+ * Copyright 2012 the original author or authors.
+ *
+ * Licensed 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 com.oreilly.springdata.jdbc.domain;
+
+/**
+ * @author Oliver Gierke
+ * @author Thomas Risberg
+ */
+public class AbstractEntity {
+
+	private Long id;
+
+	public Long getId() {
+		return id;
+	}
+
+	public void setId(Long id) {
+		this.id = id;
+	}
+
+	/* 
+	 * (non-Javadoc)
+	 * @see java.lang.Object#equals(java.lang.Object)
+	 */
+	@Override
+	public boolean equals(Object obj) {
+
+		if (this == obj) {
+			return true;
+		}
+
+		if (this.id == null || obj == null || !(this.getClass().equals(obj.getClass()))) {
+			return false;
+		}
+
+		AbstractEntity that = (AbstractEntity) obj;
+
+		return this.id.equals(that.getId());
+	}
+
+	/* 
+	 * (non-Javadoc)
+	 * @see java.lang.Object#hashCode()
+	 */
+	@Override
+	public int hashCode() {
+		return id == null ? 0 : id.hashCode();
+	}
+}

oracle/src/main/java/com/oreilly/springdata/jdbc/domain/Address.java

@@ -0,0 +1,45 @@
+package com.oreilly.springdata.jdbc.domain;
+
+/**
+ */
+public class Address extends AbstractEntity {
+	private String street, city, country;
+
+	public Address() {
+	}
+
+	public Address(String street, String city, String country) {
+		this.street = street;
+		this.city = city;
+		this.country = country;
+	}
+
+	public String getCountry() {
+		return country;
+	}
+
+	public void setCountry(String country) {
+		this.country = country;
+	}
+
+	public String getStreet() {
+		return street;
+	}
+
+	public void setStreet(String street) {
+		this.street = street;
+	}
+
+	public String getCity() {
+		return city;
+	}
+
+	public void setCity(String city) {
+		this.city = city;
+	}
+
+	@Override
+	public String toString() {
+		return street + ", " + city + " " + country ;
+	}
+}

oracle/src/main/java/com/oreilly/springdata/jdbc/domain/Customer.java

@@ -0,0 +1,56 @@
+package com.oreilly.springdata.jdbc.domain;
+
+import java.util.Collections;
+import java.util.HashSet;
+import java.util.Set;
+
+/**
+ */
+public class Customer extends AbstractEntity {
+
+	private String firstName;
+	private String lastName;
+	private EmailAddress emailAddress;
+	private Set<Address> addresses = new HashSet<Address>();
+
+	public String getFirstName() {
+		return firstName;
+	}
+
+	public void setFirstName(String firstName) {
+		this.firstName = firstName;
+	}
+
+	public String getLastName() {
+		return lastName;
+	}
+
+	public void setLastName(String lastName) {
+		this.lastName = lastName;
+	}
+
+	public EmailAddress getEmailAddress() {
+		return emailAddress;
+	}
+
+	public void setEmailAddress(EmailAddress emailAddress) {
+		this.emailAddress = emailAddress;
+	}
+
+	public Set<Address> getAddresses() {
+		return Collections.unmodifiableSet(addresses);
+	}
+
+	public void addAddress(Address address) {
+		this.addresses.add(address);
+	}
+
+	public void clearAddresses() {
+		this.addresses.clear();
+	}
+
+	@Override
+	public String toString() {
+		return "Customer: [" + getId() + "] " + firstName + " " + lastName + " " + emailAddress + " " + addresses;
+	}
+}

oracle/src/main/java/com/oreilly/springdata/jdbc/domain/EmailAddress.java

@@ -0,0 +1,49 @@
+package com.oreilly.springdata.jdbc.domain;
+
+import org.springframework.util.Assert;
+
+import java.util.regex.Pattern;
+
+/**
+ */
+public class EmailAddress {
+
+	private static final String EMAIL_REGEX = "^[_A-Za-z0-9-]+(\\.[_A-Za-z0-9-]+)*@[A-Za-z0-9]+(\\.[A-Za-z0-9]+)*(\\.[A-Za-z]{2,})$";
+	private static final Pattern PATTERN = Pattern.compile(EMAIL_REGEX);
+
+	private String value;
+
+	protected EmailAddress() {
+	}
+
+	public EmailAddress(String emailAddress) {
+		Assert.isTrue(isValid(emailAddress), "Invalid email address!");
+		this.value = emailAddress;
+	}
+
+	public static boolean isValid(String source) {
+		return PATTERN.matcher(source).matches();
+	}
+
+	@Override
+	public boolean equals(Object o) {
+		if (this == o) return true;
+		if (o == null || getClass() != o.getClass()) return false;
+
+		EmailAddress that = (EmailAddress) o;
+
+		if (value != null ? !value.equals(that.value) : that.value != null) return false;
+
+		return true;
+	}
+
+	@Override
+	public int hashCode() {
+		return value != null ? value.hashCode() : 0;
+	}
+
+	@Override
+	public String toString() {
+		return value;
+	}
+}

oracle/src/main/java/com/oreilly/springdata/jdbc/oracle/CustomerRepository.java

@@ -0,0 +1,22 @@
+package com.oreilly.springdata.jdbc.oracle;
+
+import com.oreilly.springdata.jdbc.domain.Customer;
+import com.oreilly.springdata.jdbc.domain.EmailAddress;
+
+import java.util.List;
+
+/**
+ * @author Thomas Risberg
+ */
+public interface CustomerRepository {
+
+	Customer findById(Long id);
+
+	List<Customer> findAll();
+
+	void save(Customer customer);
+
+	void delete(Customer customer);
+
+	Customer findByEmailAddress(EmailAddress emailAddress);
+}

oracle/src/main/java/com/oreilly/springdata/jdbc/oracle/StructCustomerRepository.java

@@ -0,0 +1,65 @@
+package com.oreilly.springdata.jdbc.oracle;
+
+import com.oreilly.springdata.jdbc.domain.Customer;
+import com.oreilly.springdata.jdbc.domain.EmailAddress;
+import oracle.jdbc.OracleTypes;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.jdbc.support.oracle.SqlReturnStruct;
+import org.springframework.data.jdbc.support.oracle.SqlStructValue;
+import org.springframework.jdbc.core.SqlOutParameter;
+import org.springframework.jdbc.core.SqlParameter;
+import org.springframework.jdbc.core.simple.SimpleJdbcCall;
+
+import javax.sql.DataSource;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class StructCustomerRepository implements CustomerRepository {
+
+	private SimpleJdbcCall getCustomerCall;
+
+	private SimpleJdbcCall saveCustomerCall;
+
+
+	@Autowired
+	public void setDataSource(DataSource dataSource) {
+
+		this.getCustomerCall = new SimpleJdbcCall(dataSource).withProcedureName("get_customer")
+				.declareParameters(new SqlOutParameter("out_customer",
+						OracleTypes.STRUCT, "CUSTOMER_TYPE",
+						new SqlReturnStruct(Customer.class)));
+
+		this.saveCustomerCall = new SimpleJdbcCall(dataSource).withProcedureName("save_customer")
+				.declareParameters(new SqlParameter("in_customer", OracleTypes.STRUCT, "CUSTOMER_TYPE"));
+	}
+
+	@Override
+	public Customer findById(Long id) {
+		Map<String, Object> in = new HashMap<String, Object>();
+		in.put("in_customer_id", id);
+		return getCustomerCall.executeObject(Customer.class, in);
+	}
+
+	@Override
+	public List<Customer> findAll() {
+		return null;
+	}
+
+	@Override
+	public void save(Customer customer) {
+		Map<String, Object> in = new HashMap<String, Object>();
+	 	in.put("in_customer", new SqlStructValue(customer));
+     	saveCustomerCall.execute(in);
+	}
+
+	@Override
+	public void delete(Customer customer) {
+
+	}
+
+	@Override
+	public Customer findByEmailAddress(EmailAddress emailAddress) {
+		return null;
+	}
+}

oracle/src/main/resources/META-INF/spring/application-context-oracle.xml

@@ -15,4 +15,6 @@
 
     <bean class="com.oreilly.springdata.jdbc.oracle.HelloOracle"/>
 
+    <bean id="structCustomerRepository" class="com.oreilly.springdata.jdbc.oracle.StructCustomerRepository"/>
+
 </beans>

oracle/src/main/sql/oracle-struct.sql

@@ -0,0 +1,50 @@
+CREATE TABLE customer (
+  id NUMBER(10),
+  first_name VARCHAR(255),
+  last_name VARCHAR(255),
+  email_address VARCHAR(255),
+  PRIMARY KEY (id));
+/
+CREATE OR REPLACE TYPE customer_type
+  AS OBJECT (id NUMBER(10), first_name VARCHAR(255), last_name VARCHAR(255), email_address VARCHAR(255));
+/
+CREATE OR REPLACE TYPE customer_tab_type AS TABLE OF customer_type;
+/
+CREATE OR REPLACE PROCEDURE add_customer (in_customer IN customer_type)
+AS
+BEGIN
+  INSERT into customer (id, first_name, last_name, email_address) VALUES(in_customer.id, in_customer.first_name, in_customer.last_name , in_customer.email_address);
+END;
+/
+CREATE OR REPLACE PROCEDURE save_customer (in_customer IN customer_type)
+AS
+  m_exists NUMBER;
+BEGIN
+  SELECT count(*) INTO m_exists FROM customer WHERE id = in_customer.id;
+  IF m_exists > 0 THEN
+    UPDATE customer SET first_name = in_customer.first_name, last_name = in_customer.last_name, email_address = in_customer.email_address WHERE id = in_customer.id;
+  ELSE
+    INSERT into customer (id, first_name, last_name, email_address) VALUES(in_customer.id, in_customer.first_name, in_customer.last_name , in_customer.email_address);
+  END IF;
+END;
+/
+CREATE OR REPLACE PROCEDURE get_customer (in_customer_id IN NUMBER, out_customer OUT customer_type)
+AS
+BEGIN
+  SELECT customer_type(id, first_name, last_name, email_address) INTO out_customer FROM customer WHERE id = in_customer_id;
+END;
+/
+CREATE OR REPLACE FUNCTION get_all_customer_types RETURN customer_tab_type
+AS
+  m_customer_tab customer_tab_type;
+  cursor c_customer is
+    select id, first_name, last_name, email_address from customer a;
+BEGIN
+  m_customer_tab := customer_tab_type();
+  FOR r_customer IN c_customer loop
+    m_customer_tab.extend;
+    m_customer_tab(m_customer_tab.count) := customer_type(r_customer.id, r_customer.first_name, r_customer.last_name, r_customer.email_address);
+  END LOOP;
+  RETURN m_customer_tab;
+END;
+/