EMPIREDB-227 Spring JDBC Template contributed by Ivan Nemeth Project: http://git-wip-us.apache.org/repos/asf/empire-db/repo Commit: http://git-wip-us.apache.org/repos/asf/empire-db/commit/20ecbae8 Tree: http://git-wip-us.apache.org/repos/asf/empire-db/tree/20ecbae8 Diff: http://git-wip-us.apache.org/repos/asf/empire-db/diff/20ecbae8
Branch: refs/heads/master Commit: 20ecbae8b347846cc9ba6c26324ecfac339af35c Parents: cedc978 Author: Rainer Döbele <[email protected]> Authored: Fri Sep 25 12:25:31 2015 +0200 Committer: Rainer Döbele <[email protected]> Committed: Fri Sep 25 12:25:31 2015 +0200 ---------------------------------------------------------------------- empire-db-spring/pom.xml | 47 +++ .../empire/spring/DbDatabaseFactoryBean.java | 137 ++++++++ .../apache/empire/spring/EmpireDaoSupport.java | 91 +++++ .../apache/empire/spring/EmpireDataReader.java | 27 ++ .../empire/spring/EmpireDriverFactory.java | 101 ++++++ .../empire/spring/EmpireIntegerValueReader.java | 39 +++ .../empire/spring/EmpireLongValueReader.java | 39 +++ .../org/apache/empire/spring/EmpireReader.java | 104 ++++++ .../empire/spring/EmpireReaderExtractor.java | 27 ++ .../org/apache/empire/spring/EmpireRecord.java | 68 ++++ .../empire/spring/EmpireRecordWriter.java | 28 ++ .../empire/spring/EmpireRowCallbackHandler.java | 27 ++ .../empire/spring/EmpireStringValueReader.java | 37 ++ .../apache/empire/spring/EmpireTemplate.java | 301 +++++++++++++++++ .../apache/empire/spring/EmpireValueReader.java | 37 ++ .../empire/spring/example1/EmpireApp.java | 47 +++ .../empire/spring/example1/EmpireAppImpl.java | 337 +++++++++++++++++++ .../empire/spring/example1/SampleBean.java | 126 +++++++ .../apache/empire/spring/example1/SampleDB.java | 148 ++++++++ .../empire/spring/example1/SampleSpringApp.java | 86 +++++ .../empire/spring/example2/Department.java | 90 +++++ .../apache/empire/spring/example2/Employee.java | 140 ++++++++ .../empire/spring/example2/EmployeeDao.java | 45 +++ .../empire/spring/example2/EmployeeDaoImpl.java | 225 +++++++++++++ .../spring/example2/EmployeeSpringApp.java | 220 ++++++++++++ .../resources/example1/applicationContext.xml | 83 +++++ .../example2/applicationContext-employee.xml | 85 +++++ .../src/main/resources/log4j.properties | 21 ++ .../src/main/resources/settings.properties | 44 +++ pom.xml | 1 + 30 files changed, 2808 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/pom.xml ---------------------------------------------------------------------- diff --git a/empire-db-spring/pom.xml b/empire-db-spring/pom.xml new file mode 100644 index 0000000..815d675 --- /dev/null +++ b/empire-db-spring/pom.xml @@ -0,0 +1,47 @@ +<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";> + <modelVersion>4.0.0</modelVersion> + <parent> + <artifactId>empire-db-parent</artifactId> + <groupId>org.apache.empire-db</groupId> + <version>2.4.5-SNAPSHOT</version> + </parent> + <artifactId>empire-db-spring</artifactId> + <name>Apache Empire-db Spring JDBC Template</name> + <description>Implementation of Spring JDBC Template with Empire-db.</description> + + <properties> + <spring.version>4.2.1.RELEASE</spring.version> + </properties> + + <dependencies> + + <dependency> + <groupId>org.apache.empire-db</groupId> + <artifactId>empire-db</artifactId> + </dependency> + <dependency> + <groupId>hsqldb</groupId> + <artifactId>hsqldb</artifactId> + </dependency> + + <dependency> + <groupId>org.springframework</groupId> + <artifactId>spring-context</artifactId> + <version>${spring.version}</version> + </dependency> + + <dependency> + <groupId>org.springframework</groupId> + <artifactId>spring-jdbc</artifactId> + <version>${spring.version}</version> + </dependency> + + <dependency> + <groupId>commons-dbcp</groupId> + <artifactId>commons-dbcp</artifactId> + <version>1.2.2</version> + </dependency> + + </dependencies> +</project> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/DbDatabaseFactoryBean.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/DbDatabaseFactoryBean.java b/empire-db-spring/src/main/java/org/apache/empire/spring/DbDatabaseFactoryBean.java new file mode 100644 index 0000000..6bb5648 --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/DbDatabaseFactoryBean.java @@ -0,0 +1,137 @@ +/* + * 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.empire.spring; + +import org.apache.empire.db.DBDatabase; +import org.apache.empire.db.DBDatabaseDriver; +import org.springframework.beans.factory.FactoryBean; +import org.springframework.beans.factory.InitializingBean; + +public class DbDatabaseFactoryBean implements FactoryBean<DBDatabase>, + InitializingBean { + + private boolean singleton = true; + + private DBDatabase singletonInstance; + private String schema; + private String linkName; + private DBDatabaseDriver driver; + private boolean preparedStatementsEnabled = true; + private Class<? extends DBDatabase> databaseClass = null; + private boolean earlyOpen = true; + + private Class<DBDatabaseDriver> driverClass; + + public final void setSingleton(boolean singleton) { + this.singleton = singleton; + } + + public void setDatabaseClass(Class<? extends DBDatabase> databaseClass) { + this.databaseClass = databaseClass; + } + + public void setEarlyOpen(boolean earlyOpen) { + this.earlyOpen = earlyOpen; + } + + public void setSchema(String schema) { + this.schema = schema; + } + + public void setLinkName(String linkName) { + this.linkName = linkName; + } + + public void setDriver(DBDatabaseDriver driver) { + this.driver = driver; + } + + public void setDriverClass(Class<DBDatabaseDriver> driverClass) { + this.driverClass = driverClass; + } + + + public void setPreparedStatementsEnabled(boolean preparedStatementsEnabled) { + this.preparedStatementsEnabled = preparedStatementsEnabled; + } + + public DBDatabase getObject() throws Exception { + if (this.singleton) { + return this.singletonInstance; + } else { + return createInstance(); + } + } + + public Class<?> getObjectType() { + return DBDatabase.class; + } + + public boolean isSingleton() { + return false; + } + + public void afterPropertiesSet() throws Exception { + if (driver == null && driverClass == null){ + throw new RuntimeException("driver or driverClass must be set"); + } + + if (driver == null){ + driver = (DBDatabaseDriver) driverClass.newInstance(); + } + + if (this.singleton) { + this.singletonInstance = createInstance(); + } + } + + protected DBDatabase createInstance() { + DBDatabase database = null; + if (this.databaseClass == null) { + database = new DefaultDb(); + } else { + try { + database = this.databaseClass.newInstance(); + } catch (Exception e) { + throw new RuntimeException("Failed to create database: " + + this.databaseClass, e); + } + } + if (this.schema != null && this.schema.trim().length() > 0){ + database.setSchema(schema); + } + if (this.linkName != null && this.linkName.trim().length() > 0){ + database.setLinkName(linkName); + } + + + database.setPreparedStatementsEnabled(preparedStatementsEnabled); + if (earlyOpen) { + database.open(driver, null); + } + return database; + } + + public static class DefaultDb extends DBDatabase { + + private static final long serialVersionUID = 1L; + + } + +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireDaoSupport.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireDaoSupport.java b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireDaoSupport.java new file mode 100644 index 0000000..387d004 --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireDaoSupport.java @@ -0,0 +1,91 @@ +/* + * 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.empire.spring; + +import java.sql.Connection; +import java.sql.SQLException; + +import org.apache.empire.db.DBDatabase; +import org.apache.empire.db.DBDatabaseDriver; +import org.springframework.dao.DataAccessException; +import org.springframework.jdbc.core.ConnectionCallback; +import org.springframework.jdbc.core.support.JdbcDaoSupport; +import org.springframework.util.Assert; + +public abstract class EmpireDaoSupport extends JdbcDaoSupport { + + private EmpireTemplate empireTemplate; + private DBDatabase database; + private DBDatabaseDriver driver; + + + + public void setDriver(DBDatabaseDriver driver) { + this.driver = driver; + } + + protected EmpireTemplate getEmpireTemplate() { + if (this.empireTemplate == null) { + this.empireTemplate = new EmpireTemplate(); + this.empireTemplate.setJdbcTemplate(getJdbcTemplate()); + } + return this.empireTemplate; + } + + public void setEmpireTemplate(EmpireTemplate empireTemplate) { + this.empireTemplate = empireTemplate; + } + + protected void initEmpireDao(){ + } + + @Override + protected final void initDao() throws Exception { + super.initDao(); + if (!this.database.isOpen() && this.driver == null){ + throw new RuntimeException("Database isn't open and no driver set."); + } + this.initEmpireDao(); + + } + + public void setDatabase(DBDatabase database){ + if (this.database != null){ + Assert.isTrue(this.database == database, "setting different database not allowed"); + } + this.database = database; + } + + @SuppressWarnings("unchecked") + public <T extends DBDatabase> T getDatabase(){ + if (!this.database.isOpen()){ + getJdbcTemplate().execute(new ConnectionCallback<Object>() { + + public Object doInConnection(Connection con) + throws SQLException, DataAccessException { + EmpireDaoSupport.this.database.open(driver, getConnection()); + return null; + } + }); + + } + return (T) this.database; + } + +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireDataReader.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireDataReader.java b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireDataReader.java new file mode 100644 index 0000000..b0b2f76 --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireDataReader.java @@ -0,0 +1,27 @@ +/* + * 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.empire.spring; + +import org.apache.empire.db.DBRecordData; + +public interface EmpireDataReader<K> { + + public abstract K read(DBRecordData record); + +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireDriverFactory.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireDriverFactory.java b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireDriverFactory.java new file mode 100644 index 0000000..4548482 --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireDriverFactory.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.empire.spring; + +import java.sql.Connection; + +import org.apache.empire.db.DBDatabaseDriver; +import org.apache.empire.db.derby.DBDatabaseDriverDerby; +import org.apache.empire.db.h2.DBDatabaseDriverH2; +import org.apache.empire.db.hsql.DBDatabaseDriverHSql; +import org.apache.empire.db.mysql.DBDatabaseDriverMySQL; +import org.apache.empire.db.oracle.DBDatabaseDriverOracle; +import org.apache.empire.db.postgresql.DBDatabaseDriverPostgreSQL; +import org.apache.empire.db.sqlserver.DBDatabaseDriverMSSQL; +import org.springframework.jdbc.core.support.JdbcDaoSupport; + +/** + * Creates the Empire-DB Drivers. Extends JdbcDaoSupport because it needs a Connection + */ +public class EmpireDriverFactory extends JdbcDaoSupport { + + // copy&paste from the SampleApp + + public DBDatabaseDriver createDriver(String driverclass, String schema) { + if (isClass(DBDatabaseDriverMySQL.class, driverclass)) + { + DBDatabaseDriverMySQL driver = new DBDatabaseDriverMySQL(); + // Set Driver specific properties (if any) + driver.setDatabaseName(schema); + return driver; + } + else if (isClass(DBDatabaseDriverOracle.class, driverclass)) + { + DBDatabaseDriverOracle driver = new DBDatabaseDriverOracle(); + // Set Driver specific properties (if any) + return driver; + } + else if (isClass(DBDatabaseDriverMSSQL.class, driverclass)) + { + DBDatabaseDriverMSSQL driver = new DBDatabaseDriverMSSQL(); + // Set Driver specific properties (if any) + driver.setDatabaseName(schema); + return driver; + } + else if (isClass(DBDatabaseDriverHSql.class, driverclass)) + { + DBDatabaseDriverHSql driver = new DBDatabaseDriverHSql(); + // Set Driver specific properties (if any) + return driver; + } + else if (isClass(DBDatabaseDriverPostgreSQL.class, driverclass)) + { + DBDatabaseDriverPostgreSQL driver = new DBDatabaseDriverPostgreSQL(); + // Set Driver specific properties (if any) + driver.setDatabaseName(schema); + // Create the reverse function that is needed by this sample + Connection conn = getConnection(); + driver.createReverseFunction(conn); + releaseConnection(conn); + return driver; + } + else if (isClass(DBDatabaseDriverH2.class, driverclass)) + { + DBDatabaseDriverH2 driver = new DBDatabaseDriverH2(); + // Set Driver specific properties (if any) + driver.setDatabaseName(schema); + return driver; + } + else if (isClass(DBDatabaseDriverDerby.class, driverclass)) + { + DBDatabaseDriverDerby driver = new DBDatabaseDriverDerby(); + // Set Driver specific properties (if any) + driver.setDatabaseName(schema); + return driver; + } + else + { // Unknown Provider + throw new RuntimeException("Unknown Database Driver " + driverclass); + } + } + + private boolean isClass(Class<? extends DBDatabaseDriver> clazz, String name) { + return name.equals(clazz.getName()); + } +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireIntegerValueReader.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireIntegerValueReader.java b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireIntegerValueReader.java new file mode 100644 index 0000000..f707a8c --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireIntegerValueReader.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.empire.spring; + +import org.apache.empire.db.DBColumnExpr; +import org.apache.empire.db.DBRecordData; + +public class EmpireIntegerValueReader implements EmpireDataReader<Integer> { + + DBColumnExpr column; + Integer defaultValue = null; + + public EmpireIntegerValueReader(DBColumnExpr column, Integer defaultValue) { + super(); + this.column = column; + this.defaultValue = defaultValue; + } + + public Integer read(DBRecordData record) { + return record.isNull(column) ? defaultValue : record.getInt(column); + } + +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireLongValueReader.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireLongValueReader.java b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireLongValueReader.java new file mode 100644 index 0000000..7e68f22 --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireLongValueReader.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.empire.spring; + +import org.apache.empire.db.DBColumnExpr; +import org.apache.empire.db.DBRecordData; + +public class EmpireLongValueReader implements EmpireDataReader<Long> { + + DBColumnExpr column; + private Long defaultValue; + + public EmpireLongValueReader(DBColumnExpr column, Long defaultValue) { + super(); + this.column = column; + this.defaultValue = defaultValue; + } + + public Long read(DBRecordData record) { + return record.isNull(column) ? defaultValue : record.getLong(column); + } + +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireReader.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireReader.java b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireReader.java new file mode 100644 index 0000000..cfac81a --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireReader.java @@ -0,0 +1,104 @@ +/* + * 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.empire.spring; + +import java.beans.PropertyDescriptor; +import java.lang.reflect.InvocationTargetException; + +import org.apache.commons.beanutils.BeanUtils; +import org.apache.commons.beanutils.BeanUtilsBean; +import org.apache.commons.beanutils.PropertyUtils; +import org.apache.empire.commons.ObjectUtils; +import org.apache.empire.commons.StringUtils; +import org.apache.empire.db.DBReader; +import org.apache.empire.exceptions.BeanPropertySetException; +import org.apache.empire.exceptions.InvalidArgumentException; +import org.apache.empire.exceptions.ItemNotFoundException; + +public class EmpireReader extends DBReader +{ + private static final long serialVersionUID = 1L; + + @Override + protected void getBeanProperty(Object bean, String property, Object value) + { + try + { + if (bean == null) + throw new InvalidArgumentException("bean", bean); + if (StringUtils.isEmpty(property)) + throw new InvalidArgumentException("property", property); + + // Get descriptor + PropertyDescriptor descriptor = BeanUtilsBean.getInstance().getPropertyUtils().getPropertyDescriptor(bean, property); + if (descriptor == null) + { + return; // Skip this property setter + } + // Check enum + Class<?> type = descriptor.getPropertyType(); + if (type.isEnum()) + { + // Enum<?> ev = Enum.valueOf(type, value); + boolean found = false; + Enum<?>[] items = (Enum[]) type.getEnumConstants(); + for (int i = 0; i < items.length; i++) + { + Enum<?> item = items[i]; + if (ObjectUtils.compareEqual(item.name(), value)) + { + value = item; + found = true; + break; + } + } + // Enumeration value not found + if (!found) + throw new ItemNotFoundException(value); + } + + // Set Property Value + if (value != null) + { // Bean utils will convert if necessary + BeanUtils.setProperty(bean, property, value); + } + else + { // Don't convert, just set + PropertyUtils.setProperty(bean, property, null); + } + } + catch (IllegalAccessException e) + { log.error(bean.getClass().getName() + ": unable to set property '" + property + "'"); + throw new BeanPropertySetException(bean, property, e); + } + catch (InvocationTargetException e) + { log.error(bean.getClass().getName() + ": unable to set property '" + property + "'"); + throw new BeanPropertySetException(bean, property, e); + } + catch (NoSuchMethodException e) + { log.error(bean.getClass().getName() + ": unable to set property '" + property + "'"); + throw new BeanPropertySetException(bean, property, e); + } + catch (NullPointerException e) + { log.error(bean.getClass().getName() + ": unable to set property '" + property + "'"); + throw new BeanPropertySetException(bean, property, e); + } + } + +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireReaderExtractor.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireReaderExtractor.java b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireReaderExtractor.java new file mode 100644 index 0000000..81255d7 --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireReaderExtractor.java @@ -0,0 +1,27 @@ +/* + * 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.empire.spring; + +import org.apache.empire.db.DBReader; + +public interface EmpireReaderExtractor<K> { + + K process(DBReader reader); + +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireRecord.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireRecord.java b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireRecord.java new file mode 100644 index 0000000..e3efca1 --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireRecord.java @@ -0,0 +1,68 @@ +/* + * 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.empire.spring; + +import java.beans.PropertyDescriptor; +import java.lang.reflect.InvocationTargetException; + +import org.apache.commons.beanutils.BeanUtilsBean; +import org.apache.commons.beanutils.PropertyUtilsBean; +import org.apache.empire.data.Column; +import org.apache.empire.db.DBRecord; +import org.apache.empire.exceptions.BeanPropertyGetException; + +public class EmpireRecord extends DBRecord +{ + private static final long serialVersionUID = 1L; + + @Override + protected void setBeanValue(Object bean, String property, Column column) + { + try + { + // Get descriptor + Object value; + PropertyUtilsBean pub = BeanUtilsBean.getInstance().getPropertyUtils(); + PropertyDescriptor descriptor = pub.getPropertyDescriptor(bean, property); + if (descriptor == null) { + return; // Skip this property setter + } + + // Get Property Value + value = pub.getSimpleProperty(bean, property); + + // Check enum + if (value instanceof Enum<?>) + value = ((Enum<?>)value).name(); + + // Set the record value + setValue( column, value ); + + } catch (IllegalAccessException e) + { log.error(bean.getClass().getName() + ": unable to get property '" + property + "'"); + throw new BeanPropertyGetException(bean, property, e); + } catch (NoSuchMethodException e) + { log.error(bean.getClass().getName() + ": unable to get property '" + property + "'"); + throw new BeanPropertyGetException(bean, property, e); + } catch (InvocationTargetException e) + { log.error(bean.getClass().getName() + ": unable to get property '" + property + "'"); + throw new BeanPropertyGetException(bean, property, e); + } + } +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireRecordWriter.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireRecordWriter.java b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireRecordWriter.java new file mode 100644 index 0000000..2ecea4d --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireRecordWriter.java @@ -0,0 +1,28 @@ +/* + * 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.empire.spring; + +import org.apache.empire.db.DBRecord; + + +public interface EmpireRecordWriter<K> { + + public abstract void write(DBRecord record, K entity); + +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireRowCallbackHandler.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireRowCallbackHandler.java b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireRowCallbackHandler.java new file mode 100644 index 0000000..9a24bce --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireRowCallbackHandler.java @@ -0,0 +1,27 @@ +/* + * 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.empire.spring; + +import org.apache.empire.db.DBRecordData; + +public interface EmpireRowCallbackHandler { + + void processRow(DBRecordData record); + +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireStringValueReader.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireStringValueReader.java b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireStringValueReader.java new file mode 100644 index 0000000..9f16a6c --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireStringValueReader.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.empire.spring; + +import org.apache.empire.db.DBColumnExpr; +import org.apache.empire.db.DBRecordData; + +public class EmpireStringValueReader implements EmpireDataReader<String> { + + DBColumnExpr column; + + public EmpireStringValueReader(DBColumnExpr column) { + super(); + this.column = column; + } + + public String read(DBRecordData record) { + return record.getString(column); + } + +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireTemplate.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireTemplate.java b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireTemplate.java new file mode 100644 index 0000000..9202bbc --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireTemplate.java @@ -0,0 +1,301 @@ +/* + * 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.empire.spring; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.List; + +import javax.sql.DataSource; + +import org.apache.empire.db.DBColumnExpr; +import org.apache.empire.db.DBCommand; +import org.apache.empire.db.DBReader; +import org.apache.empire.db.DBRecord; +import org.apache.empire.db.DBRowSet; +import org.apache.empire.db.DBTable; +import org.apache.empire.db.exceptions.RecordNotFoundException; +import org.springframework.beans.factory.InitializingBean; +import org.springframework.dao.DataAccessException; +import org.springframework.dao.support.DataAccessUtils; +import org.springframework.jdbc.core.ConnectionCallback; +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.util.Assert; + +public class EmpireTemplate implements InitializingBean { + + private JdbcTemplate jdbcTemplate; + + public void setJdbcTemplate(JdbcTemplate jdbcTemplate) { + this.jdbcTemplate = jdbcTemplate; + } + + public JdbcTemplate getJdbcTemplate() { + return this.jdbcTemplate; + } + + public final void setDataSource(DataSource dataSource) { + if (this.jdbcTemplate == null || dataSource != this.jdbcTemplate.getDataSource()) { + this.jdbcTemplate = new JdbcTemplate(dataSource); + this.jdbcTemplate.afterPropertiesSet(); + } + } + + public void afterPropertiesSet() throws Exception { + if (getJdbcTemplate() == null) { + throw new IllegalArgumentException("Property 'jdbcTemplate' is required"); + } + + } + + public <K> List<K> query(final DBCommand cmd, final EmpireDataReader<K> dataReader) { + return query(cmd, new EmpireDataReaderExtractor<K>(dataReader)); + + } + + public List<Object> queryForList(final DBCommand cmd, final DBColumnExpr col) { + return query(cmd, new EmpireValueReader(col)); + + } + + public Long queryForLong(final DBCommand cmd, final DBColumnExpr col, Long defaultValue) { + return DataAccessUtils.uniqueResult(queryForLongList(cmd, col, defaultValue)); + } + + public List<Long> queryForLongList(final DBCommand cmd, final DBColumnExpr col, final Long defaultValue) { + return query(cmd, new EmpireLongValueReader(col, defaultValue)); + + } + + public Integer queryForInteger(final DBCommand cmd, final DBColumnExpr col, Integer defaultValue) { + return DataAccessUtils.uniqueResult(queryForIntegerList(cmd, col, defaultValue)); + } + + public List<Integer> queryForIntegerList(final DBCommand cmd, final DBColumnExpr col, final Integer defaultValue) { + return query(cmd, new EmpireIntegerValueReader(col, defaultValue)); + } + + public String queryForString(final DBCommand cmd, final DBColumnExpr col) { + return DataAccessUtils.uniqueResult(queryForStringList(cmd, col)); + } + + public List<String> queryForStringList(final DBCommand cmd, final DBColumnExpr col) { + return query(cmd, new EmpireStringValueReader(col)); + } + + public <K> K query(final DBCommand cmd, final EmpireReaderExtractor<K> readerHandler) { + + class QueryCallback implements ConnectionCallback<K> { + public K doInConnection(Connection connection) throws SQLException, DataAccessException { + return query(connection, cmd, readerHandler); + } + } + return getJdbcTemplate().execute(new QueryCallback()); + + } + + public void query(final DBCommand cmd, final EmpireRowCallbackHandler rowCallbackHandler) { + query(cmd, new EmpireRowCallbackHandlerExtractor(rowCallbackHandler)); + } + + public <K> K queryForObject(final DBCommand cmd, final EmpireDataReader<K> dataReader) { + + return DataAccessUtils.uniqueResult(query(cmd, dataReader)); + + } + + public void deleteRecord(final DBRecord record) { + + class DeleteRecordCallback implements ConnectionCallback<Object> { + public Object doInConnection(Connection connection) throws SQLException, DataAccessException { + record.delete(connection); + return null; + } + } + getJdbcTemplate().execute(new DeleteRecordCallback()); + + } + + public void deleteRecord(final DBTable table, final Object key) { + deleteRecord(table, new Object[] { key }); + } + + public void deleteRecord(final DBTable table, final Object[] keys) { + + class DeleteRecordCallback implements ConnectionCallback<Object> { + public Object doInConnection(Connection connection) throws SQLException, DataAccessException { + DBRecord record = new EmpireRecord(); + record.read(table, keys, connection); + record.delete(connection); + return null; + } + } + getJdbcTemplate().execute(new DeleteRecordCallback()); + + } + + public DBRecord updateRecord(final DBRecord record) { + + class UpdateRecordCallback implements ConnectionCallback<DBRecord> { + public DBRecord doInConnection(Connection connection) throws SQLException, DataAccessException { + record.update(connection); + return record; + } + } + + return getJdbcTemplate().execute(new UpdateRecordCallback()); + + } + + public int executeUpdate(final DBCommand cmd) { + + class UpdateRecordCallback implements ConnectionCallback<Integer> { + public Integer doInConnection(Connection connection) throws SQLException, DataAccessException { + return cmd.getDatabase().executeUpdate(cmd, connection); + } + } + + return getJdbcTemplate().execute(new UpdateRecordCallback()); + + } + + public int executeDelete(final DBTable table, final DBCommand cmd) { + + class DeleteRecordCallback implements ConnectionCallback<Integer> { + public Integer doInConnection(Connection connection) throws SQLException, DataAccessException { + return cmd.getDatabase().executeDelete(table, cmd, connection); + } + } + + return getJdbcTemplate().execute(new DeleteRecordCallback()); + + } + + public int executeInsert(final DBCommand cmd) { + + class InsertRecordCallback implements ConnectionCallback<Integer> { + public Integer doInConnection(Connection connection) throws SQLException, DataAccessException { + return cmd.getDatabase().executeInsert(cmd, connection); + } + } + + return getJdbcTemplate().execute(new InsertRecordCallback()); + + } + + public DBRecord newRecord(final DBRowSet table) { + DBRecord record = new EmpireRecord(); + record.create(table); + return record; + } + + public DBRecord openRecord(final DBRowSet table, final Object key) { + return openRecord(table, new Object[] { key }); + } + + public DBRecord openRecord(final DBRowSet table, final Object[] keys) { + + class ReadRecordCallback implements ConnectionCallback<DBRecord> { + public DBRecord doInConnection(Connection connection) throws SQLException, DataAccessException { + DBRecord record = new EmpireRecord(); + try { + record.read(table, keys, connection); + } catch (RecordNotFoundException e) { + return null; + } + return record; + } + } + + return getJdbcTemplate().execute(new ReadRecordCallback()); + + } + + public <K> K execute(ConnectionCallback<K> connectionCallback) { + return getJdbcTemplate().execute(connectionCallback); + } + + private <K> K query(Connection connection, DBCommand command, EmpireReaderExtractor<K> callback) { + DBReader reader = newDBReader(); + try { + reader.open(command, connection); + + return callback.process(reader); + + } finally { + reader.close(); + } + } + + private DBReader newDBReader() { + return new EmpireReader(); + } + + public static class EmpireRowCallbackHandlerExtractor implements EmpireReaderExtractor<Object> { + + private final EmpireRowCallbackHandler rowCallbackHandler; + + public EmpireRowCallbackHandlerExtractor(EmpireRowCallbackHandler rowCallbackHandler) { + Assert.notNull(rowCallbackHandler, "RowCallbackHandler is required"); + this.rowCallbackHandler = rowCallbackHandler; + } + +// @Override + public Object process(DBReader reader) { + try { + while (reader.moveNext()) { + this.rowCallbackHandler.processRow(reader); + } + return null; + } finally { + reader.close(); + } + } + + } + + public static class EmpireDataReaderExtractor<K> implements EmpireReaderExtractor<List<K>> { + + private final EmpireDataReader<K> dataReader; + + public EmpireDataReaderExtractor(EmpireDataReader<K> rowMapper) { + Assert.notNull(rowMapper, "DataReader is required"); + this.dataReader = rowMapper; + } + +// @Override + public List<K> process(DBReader reader) { + try { + List<K> results = new ArrayList<K>(); + + while (reader.moveNext()) { + results.add(this.dataReader.read(reader)); + } + + return results; + + } finally { + reader.close(); + } + } + + } + +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireValueReader.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireValueReader.java b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireValueReader.java new file mode 100644 index 0000000..95e1b9b --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/EmpireValueReader.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.empire.spring; + +import org.apache.empire.db.DBColumnExpr; +import org.apache.empire.db.DBRecordData; + +public class EmpireValueReader implements EmpireDataReader<Object> { + + DBColumnExpr column; + + public EmpireValueReader(DBColumnExpr column) { + super(); + this.column = column; + } + + public Object read(DBRecordData record) { + return record.getValue(column); + } + +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/example1/EmpireApp.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/example1/EmpireApp.java b/empire-db-spring/src/main/java/org/apache/empire/spring/example1/EmpireApp.java new file mode 100644 index 0000000..ddf809f --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/example1/EmpireApp.java @@ -0,0 +1,47 @@ +/* + * 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.empire.spring.example1; + + +/** + * This is the interface to the application. It is usually some high level interface; for this basic + * example this is the dao object. + * + */ +public interface EmpireApp { + + void clearDatabase(); + + void setupDatabase(); + + Integer insertDepartment(String departmentName, String businessUnit); + + Integer insertEmployee(String firstName, String lastName, String gender, int departmentId); + + void updateEmployee(int idPers, String phoneNumber); + + void doQuery(QueryType type); + + public enum QueryType + { + Reader, + BeanList, + XmlDocument + } +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/example1/EmpireAppImpl.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/example1/EmpireAppImpl.java b/empire-db-spring/src/main/java/org/apache/empire/spring/example1/EmpireAppImpl.java new file mode 100644 index 0000000..41fcd52 --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/example1/EmpireAppImpl.java @@ -0,0 +1,337 @@ +/* + * 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.empire.spring.example1; + +import java.sql.Connection; +import java.sql.SQLException; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +import org.apache.empire.db.DBColumn; +import org.apache.empire.db.DBColumnExpr; +import org.apache.empire.db.DBCommand; +import org.apache.empire.db.DBDatabase; +import org.apache.empire.db.DBDatabaseDriver; +import org.apache.empire.db.DBReader; +import org.apache.empire.db.DBRecord; +import org.apache.empire.db.DBRecordData; +import org.apache.empire.db.DBSQLScript; +import org.apache.empire.db.DBTable; +import org.apache.empire.db.derby.DBDatabaseDriverDerby; +import org.apache.empire.db.h2.DBDatabaseDriverH2; +import org.apache.empire.db.hsql.DBDatabaseDriverHSql; +import org.apache.empire.db.postgresql.DBDatabaseDriverPostgreSQL; +import org.apache.empire.spring.EmpireDaoSupport; +import org.apache.empire.spring.EmpireDataReader; +import org.apache.empire.spring.EmpireReaderExtractor; +import org.apache.empire.spring.EmpireRecord; +import org.apache.empire.spring.EmpireRowCallbackHandler; +import org.apache.empire.xml.XMLWriter; +import org.springframework.dao.DataAccessException; +import org.springframework.jdbc.core.ConnectionCallback; +import org.springframework.transaction.annotation.Transactional; +import org.w3c.dom.Document; + +/** + * + */ +public class EmpireAppImpl extends EmpireDaoSupport implements EmpireApp { + + @Transactional + public void clearDatabase() { + SampleDB db = getDatabase(); + + DBCommand cmd = db.createCommand(); + // Delete all Employees (no constraints) + getEmpireTemplate().executeDelete(db.EMPLOYEES, cmd); + // Delete all Departments (no constraints) + getEmpireTemplate().executeDelete(db.DEPARTMENTS, cmd); + } + + + @Transactional + public Integer insertDepartment(String departmentName, String businessUnit) { + SampleDB db = getDatabase(); + + DBRecord rec = new EmpireRecord(); + rec.create(db.DEPARTMENTS); + rec.setValue(db.DEPARTMENTS.NAME, departmentName); + rec.setValue(db.DEPARTMENTS.BUSINESS_UNIT, businessUnit); + + getEmpireTemplate().updateRecord(rec); + // Return Department ID + return rec.getInt(db.DEPARTMENTS.DEPARTMENT_ID); + } + + @Transactional + public Integer insertEmployee(String firstName, String lastName, + String gender, int departmentId) { + SampleDB db = getDatabase(); + + DBRecord rec = new EmpireRecord(); + rec.create(db.EMPLOYEES); + rec.setValue(db.EMPLOYEES.FIRSTNAME, firstName); + rec.setValue(db.EMPLOYEES.LASTNAME, lastName); + rec.setValue(db.EMPLOYEES.GENDER, gender); + rec.setValue(db.EMPLOYEES.DEPARTMENT_ID, departmentId); + getEmpireTemplate().updateRecord(rec); + // Return Employee ID + return rec.getInt(db.EMPLOYEES.EMPLOYEE_ID); + } + + @Transactional + public void updateEmployee(int idPers, String phoneNumber) { + if (getEmployee(idPers) == null) { + // if you like more verbose exceptions for the app + throw new IllegalArgumentException( + "The specified employee does not exist."); + } + + SampleDB db = getDatabase(); + + DBRecord rec = getEmpireTemplate().openRecord(db.EMPLOYEES, idPers); + // Set + rec.setValue(db.EMPLOYEES.PHONE_NUMBER, phoneNumber); + getEmpireTemplate().updateRecord(rec); + } + + @Transactional(readOnly = true) + public void doQuery(QueryType type) { + SampleDB db = getDatabase(); + + // Define the query + DBCommand cmd = db.createCommand(); + // Define shortcuts for tables used - not necessary but convenient + final SampleDB.Employees EMP = db.EMPLOYEES; + final SampleDB.Departments DEP = db.DEPARTMENTS; + + // The following expression concats lastname + ', ' + firstname + final DBColumnExpr EMPLOYEE_FULLNAME = EMP.LASTNAME.append(", ") + .append(EMP.FIRSTNAME).as("FULL_NAME"); + + // The following expression extracts the extension number from the phone + // field + // e.g. substr(PHONE_NUMBER, + // length(PHONE_NUMBER)-instr(reverse(PHONE_NUMBER), '-')+2) AS + // PHONE_EXTENSION + // Hint: Since the reverse() function is not supported by HSQLDB there + // is special treatment for HSQL + final DBColumnExpr PHONE_LAST_DASH; + if (db.getDriver() instanceof DBDatabaseDriverHSql + || db.getDriver() instanceof DBDatabaseDriverDerby + || db.getDriver() instanceof DBDatabaseDriverH2) + PHONE_LAST_DASH = EMP.PHONE_NUMBER.indexOf("-", + EMP.PHONE_NUMBER.indexOf("-").plus(1)).plus(1); // HSQLDB + // only + else + PHONE_LAST_DASH = EMP.PHONE_NUMBER.length() + .minus(EMP.PHONE_NUMBER.reverse().indexOf("-")).plus(2); + final DBColumnExpr PHONE_EXT_NUMBER = EMP.PHONE_NUMBER.substring( + PHONE_LAST_DASH).as("PHONE_EXTENSION"); + + // DBColumnExpr genderExpr = + // cmd.select(EMP.GENDER.decode(EMP.GENDER.getOptions()).as(EMP.GENDER.getName())); + // Select required columns + cmd.select(EMP.EMPLOYEE_ID, EMPLOYEE_FULLNAME); + if (db.getDriver() instanceof DBDatabaseDriverPostgreSQL) { + // postgres does not support the substring expression + cmd.select(EMP.GENDER, EMP.PHONE_NUMBER); + } else { + cmd.select(EMP.GENDER, EMP.PHONE_NUMBER, PHONE_EXT_NUMBER); + + } + cmd.select(DEP.NAME.as("DEPARTMENT")); + cmd.select(DEP.BUSINESS_UNIT); + cmd.join(EMP.DEPARTMENT_ID, DEP.DEPARTMENT_ID); + // Set constraints and order + cmd.where(EMP.LASTNAME.length().isGreaterThan(0)); + cmd.orderBy(EMP.LASTNAME, EMP.FIRSTNAME); + + // Query Records and print output + try { + // Open Reader + System.out.println("Running Query:"); + System.out.println(cmd.getSelect()); + // Print output + System.out.println("---------------------------------"); + switch (type) { + case BeanList: + // Text-Output by iterating through all records. + EmpireRowCallbackHandler readerImpl = new EmpireRowCallbackHandler() { + + public void processRow(DBRecordData reader) { + System.out.println(reader.getString(EMP.EMPLOYEE_ID) + + "\t" + + reader.getString(EMPLOYEE_FULLNAME) + + "\t" + + EMP.GENDER.getOptions().get( + reader.getString(EMP.GENDER)) + "\t" + + reader.getString(PHONE_EXT_NUMBER) + "\t" + + reader.getString(DEP.NAME)); + + } + }; + getEmpireTemplate().query(cmd, readerImpl); + break; + case Reader: + // Text-Output using a list of Java Beans supplied by the + // DBReader + EmpireReaderExtractor<List<SampleBean>> beanListImpl = new EmpireReaderExtractor<List<SampleBean>>() { + + public List<SampleBean> process(DBReader reader) { + return reader.getBeanList(SampleBean.class); + } + }; + List<SampleBean> beanList = getEmpireTemplate().query(cmd, + beanListImpl); + System.out.println(String.valueOf(beanList.size()) + + " SampleBeans returned from Query."); + for (SampleBean b : beanList) { + System.out.println(b.toString()); + } + break; + case XmlDocument: + // XML Output + XmlDocumentExtractor xmlImpl = new XmlDocumentExtractor(); + Document doc = getEmpireTemplate().query(cmd, xmlImpl); + // Print XML Document to System.out + XMLWriter.debug(doc); + break; + } + + } finally { + + // always close Reader + + // reader is closed in EmpireTemplate's methods + + // reader.close(); + } + } + + public Map<Object, Object> getDepartment(int id) { + SampleDB db = getDatabase(); + return get(db.DEPARTMENTS, id); + } + + public Map<Object, Object> getEmployee(int id) { + SampleDB db = getDatabase(); + return get(db.EMPLOYEES, id); + } + + private Map<Object, Object> get(DBTable table, int pk) { + + SampleDB db = getDatabase(); + + DBCommand cmd = db.createCommand(); + cmd.select(table.getColumns()); + cmd.where(table.getPrimaryKey().getColumns()[0].is(pk)); // i know there + // is just + // one + // pk-column + // ;-) + Map<Object, Object> dep = getEmpireTemplate().queryForObject(cmd, + new RowToObjectMapDataMapper(table)); + + return dep; + } + + public static class XmlDocumentExtractor implements + EmpireReaderExtractor<Document> { + + public Document process(DBReader reader) { + return reader.getXmlDocument(); + } + + } + + public static class RowToObjectMapDataMapper implements + EmpireDataReader<Map<Object, Object>> { + + DBTable table; + + public RowToObjectMapDataMapper(DBTable table) { + super(); + this.table = table; + } + + public Map<Object, Object> read(DBRecordData record) { + Map<Object, Object> dep = new HashMap<Object, Object>(); + for (DBColumn col : table.getColumns()) { + dep.put(col.getName(), record.getValue(col)); + } + return dep; + } + + } + + public boolean databaseExists() { + Connection conn = getConnection(); + try { + DBDatabase db = getDatabase(); + if (db.getTables() == null || db.getTables().isEmpty()) { + throw new AssertionError( + "There are no tables in this database!"); + } + DBCommand cmd = db.createCommand(); + if (cmd == null) { + throw new AssertionError("The DBCommand object is null."); + } + DBTable t = db.getTables().get(0); + cmd.select(t.count()); + return (db.querySingleInt(cmd, -1, conn) >= 0); + } catch (Exception e) { + return false; + } + } + + public void initializeDatabase() { + if (!databaseExists()) { + createDatabase(); + } + } + + @Transactional + public void setupDatabase() { + initializeDatabase(); + } + + public void createDatabase() { + + // create DLL for Database Definition + final DBSQLScript script = new DBSQLScript(); + final DBDatabaseDriver driver = getDatabase().getDriver(); + getDatabase().getCreateDDLScript(driver, script); + + // Show DLL Statement + System.out.println(script.toString()); + // Execute Script + getEmpireTemplate().execute(new ConnectionCallback<Object>() { + + public Object doInConnection(Connection con) throws SQLException, + DataAccessException { + script.executeAll(driver, con, false); + return null; + } + }); + + } + +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/example1/SampleBean.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/example1/SampleBean.java b/empire-db-spring/src/main/java/org/apache/empire/spring/example1/SampleBean.java new file mode 100644 index 0000000..efe89b1 --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/example1/SampleBean.java @@ -0,0 +1,126 @@ +/* + * 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.empire.spring.example1; + + +/** + * The SampleBean class is used to demonstrate JavaBean support for SQL-Queries. + * The SampleBean is used in the SampleApp's queryRecords function. + */ +public class SampleBean +{ + private int employeeId; + private String fullName; + private String gender; + private String phoneNumber; + private String department; + private String businessUnit; + + /* + * Uncomment this if you want to use constructor instead of setters + * However, number of arguments and data types must match query! + * + public SampleBean(int employeeId, String fullName, String gender, String phoneNumber, String department, String businessUnit) + { + this.employeeId = employeeId; + this.fullName = fullName; + this.gender = gender; + this.phoneNumber = phoneNumber; + this.department = department; + this.businessUnit = businessUnit; + } + */ + + public int getEmployeeId() + { + return employeeId; + } + + public void setEmployeeId(int employeeId) + { + this.employeeId = employeeId; + } + + public String getFullName() + { + return fullName; + } + + public void setFullName(String fullName) + { + this.fullName = fullName; + } + + public String getGender() + { + return gender; + } + + public void setGender(String gender) + { + this.gender = gender; + } + + public String getPhoneNumber() + { + return phoneNumber; + } + + public void setPhoneNumber(String phoneNumber) + { + this.phoneNumber = phoneNumber; + } + + public String getDepartment() + { + return department; + } + + public void setDepartment(String department) + { + this.department = department; + } + + public String getBusinessUnit() + { + return businessUnit; + } + + public void setBusinessUnit(String businessUnit) + { + this.businessUnit = businessUnit; + } + + @Override + public String toString() + { + StringBuffer buf = new StringBuffer(); + buf.append(employeeId); + buf.append("\t"); + buf.append(fullName); + buf.append("\t"); + buf.append(gender); + buf.append("\t"); + buf.append(department); + buf.append("\t"); + buf.append(businessUnit); + return buf.toString(); + } + +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/example1/SampleDB.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/example1/SampleDB.java b/empire-db-spring/src/main/java/org/apache/empire/spring/example1/SampleDB.java new file mode 100644 index 0000000..c8f3284 --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/example1/SampleDB.java @@ -0,0 +1,148 @@ +/* + * 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.empire.spring.example1; + +import org.apache.empire.commons.Options; +import org.apache.empire.data.DataType; +import org.apache.empire.data.DataMode; +import org.apache.empire.db.DBColumn; +import org.apache.empire.db.DBDatabase; +import org.apache.empire.db.DBTable; +import org.apache.empire.db.DBTableColumn; + +/** + * <PRE> + * This file contains the definition of the data model in Java. + * The SampleDB data model consists of two tables and a foreign key relation. + * The tables are defined as nested classes here, but you may put the in separate files if you want. + * + * PLEASE NOTE THE NAMING CONVENTION: + * Since all tables, views and columns are declared as "final" constants they are all in upper case. + * We recommend using a prefix of T_ for tables and C_ for columns in order to keep them together + * when listed in your IDE's code completion. + * There is no need to stick to this convention but it makes life just another little bit easier. + * + * You may declare other database tables or views in the same way. + * </PRE> + */ +public class SampleDB extends DBDatabase +{ + private final static long serialVersionUID = 1L; + + /** + * This class represents the definition of the Departments table. + */ + public static class Departments extends DBTable + { + + private final static long serialVersionUID = 1L; + + public final DBTableColumn DEPARTMENT_ID; + public final DBTableColumn NAME; + public final DBTableColumn HEAD; + public final DBTableColumn BUSINESS_UNIT; + public final DBTableColumn UPDATE_TIMESTAMP; + + public Departments(DBDatabase db) + { + super("DEPARTMENTS", db); + // ID + DEPARTMENT_ID = addColumn("DEPARTMENT_ID", DataType.AUTOINC, 0, true, "DEP_ID_SEQUENCE"); + NAME = addColumn("NAME", DataType.TEXT, 80, true); + HEAD = addColumn("HEAD", DataType.TEXT, 80, false); + BUSINESS_UNIT = addColumn("BUSINESS_UNIT", DataType.TEXT, 4, true, "ITTK"); + UPDATE_TIMESTAMP= addColumn("UPDATE_TIMESTAMP", DataType.DATETIME, 0, true); + + // Primary Key + setPrimaryKey(DEPARTMENT_ID); + // Set other Indexes + addIndex("DEARTMENT_NAME_IDX", true, new DBColumn[] { NAME }); + // Set timestamp column for save updates + setTimestampColumn(UPDATE_TIMESTAMP); + } + } + + /** + * This class represents the definition of the Employees table. + */ + public static class Employees extends DBTable + { + private final static long serialVersionUID = 1L; + + public final DBTableColumn EMPLOYEE_ID; + public final DBTableColumn SALUTATION; + public final DBTableColumn FIRSTNAME; + public final DBTableColumn LASTNAME; + public final DBTableColumn DATE_OF_BIRTH; + public final DBTableColumn DEPARTMENT_ID; + public final DBTableColumn GENDER; + public final DBTableColumn PHONE_NUMBER; + public final DBTableColumn EMAIL; + public final DBTableColumn SALARY; + public final DBTableColumn RETIRED; + public final DBTableColumn UPDATE_TIMESTAMP; + + public Employees(DBDatabase db) + { + super("EMPLOYEES", db); + // ID + EMPLOYEE_ID = addColumn("EMPLOYEE_ID", DataType.AUTOINC, 0, true, "EMPLOYEE_ID_SEQUENCE"); + SALUTATION = addColumn("SALUTATION", DataType.TEXT, 20, false); + FIRSTNAME = addColumn("FIRST_NAME", DataType.TEXT, 40, true); + LASTNAME = addColumn("LAST_NAME", DataType.TEXT, 40, true); + DATE_OF_BIRTH = addColumn("DATE_OF_BIRTH", DataType.DATE, 0, false); + DEPARTMENT_ID = addColumn("DEPARTMENT_ID", DataType.INTEGER, 0, true); + GENDER = addColumn("GENDER", DataType.TEXT, 1, false); + PHONE_NUMBER = addColumn("PHONE_NUMBER", DataType.TEXT, 40, false); + EMAIL = addColumn("EMAIL", DataType.TEXT, 80, false); + SALARY = addColumn("SALARY", DataType.DECIMAL, 10.2, false); + RETIRED = addColumn("RETIRED", DataType.BOOL, 0, true, false); + UPDATE_TIMESTAMP= addColumn("UPDATE_TIMESTAMP", DataType.DATETIME, 0, true); + + // Primary Key + setPrimaryKey(EMPLOYEE_ID); + // Set other Indexes + addIndex("EMPLOYEE_NAME_IDX", true, new DBColumn[] { FIRSTNAME, LASTNAME, DATE_OF_BIRTH }); + // Set timestamp column for save updates + setTimestampColumn(UPDATE_TIMESTAMP); + + // Create Options for GENDER column + Options genders = new Options(); + genders.set("M", "Male"); + genders.set("F", "Female"); + GENDER.setOptions(genders); + } + } + + // Declare all Tables and Views here + public final Departments DEPARTMENTS = new Departments(this); + public final Employees EMPLOYEES = new Employees(this); + + /** + * Constructor of the SampleDB data model description + * + * Put all foreign key relations here. + */ + public SampleDB() + { + // Define Foreign-Key Relations + addRelation( EMPLOYEES.DEPARTMENT_ID.referenceOn( DEPARTMENTS.DEPARTMENT_ID )); + } + +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/example1/SampleSpringApp.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/example1/SampleSpringApp.java b/empire-db-spring/src/main/java/org/apache/empire/spring/example1/SampleSpringApp.java new file mode 100644 index 0000000..3ff0230 --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/example1/SampleSpringApp.java @@ -0,0 +1,86 @@ +/* + * 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.empire.spring.example1; + +import java.util.logging.Logger; + +import org.springframework.beans.factory.xml.XmlBeanDefinitionReader; +import org.springframework.context.ApplicationContext; +import org.springframework.context.support.GenericApplicationContext; +import org.springframework.core.io.ClassPathResource; + +/** + * + */ +public class SampleSpringApp { + private static final Logger log = Logger.getLogger(SampleSpringApp.class.getName()); + + //creates the application context + //this is usually in some bootstrapping code; so your application will + //just have one at runtime. + static ApplicationContext ctx = getContext(); + + //get the service that is the entry point into the application + //normally this is injected by spring into classes that need it + static EmpireApp appBean = ctx.getBean("empireApp", EmpireApp.class); + + public static void main(String[] args) throws Exception { + + System.out.println("Running Spring Example..."); + + appBean.setupDatabase(); + appBean.clearDatabase(); + + System.out.println("*** Step 6: insertDepartment() & insertEmployee() ***"); + int idDevDep = appBean.insertDepartment("Development", "ITTK"); + int idSalDep = appBean.insertDepartment("Sales", "ITTK"); + + int idPers1 = appBean.insertEmployee("Peter", "Sharp", "M", idDevDep); + int idPers2 = appBean.insertEmployee("Fred", "Bloggs", "M", idDevDep); + int idPers3 = appBean.insertEmployee("Emma", "White", "F", idSalDep); + + System.out.println("*** Step 7: updateEmployee() ***"); + appBean.updateEmployee(idPers1, "+49-7531-457160"); + appBean.updateEmployee(idPers2, "+49-5555-505050"); + appBean.updateEmployee(idPers3, "+49-040-125486"); + + System.out.println("*** Step 8 Option 1: queryRecords() / Tab-Output ***"); + appBean.doQuery(EmpireApp.QueryType.Reader); + + System.out.println("*** Step 8 Option 2: queryRecords() / Bean-List-Output ***"); + appBean.doQuery(EmpireApp.QueryType.BeanList); + + System.out.println("*** Step 8 Option 3: queryRecords() / XML-Output ***"); + appBean.doQuery(EmpireApp.QueryType.XmlDocument); + + + } + + + + static GenericApplicationContext getContext() { + log.info("Creating Spring Application Context ..."); + GenericApplicationContext ctx = new GenericApplicationContext(); + XmlBeanDefinitionReader reader = new XmlBeanDefinitionReader(ctx); + reader.loadBeanDefinitions(new ClassPathResource("/example1/applicationContext.xml")); + + ctx.refresh(); + return ctx; + } +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/example2/Department.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/example2/Department.java b/empire-db-spring/src/main/java/org/apache/empire/spring/example2/Department.java new file mode 100644 index 0000000..e56953c --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/example2/Department.java @@ -0,0 +1,90 @@ +/* + * 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.empire.spring.example2; + +public class Department { + + private Integer departmentId; + private String name; + private String businessUnit; + private String head; + + public Integer getDepartmentId() { + return departmentId; + } + + public void setDepartmentId(Integer departmentId) { + this.departmentId = departmentId; + } + + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } + + public String getBusinessUnit() { + return businessUnit; + } + + public void setBusinessUnit(String businessUnit) { + this.businessUnit = businessUnit; + } + + public String getHead() { + return head; + } + + public void setHead(String head) { + this.head = head; + } + + @Override + public String toString() { + return this.name; + } + + @Override + public boolean equals(Object obj) { + if (this == obj) { + return true; + } + if (obj == null) { + return false; + } + + if (obj.getClass().equals(this.getClass())) { + Department other = (Department) obj; + if (other.departmentId == null || this.departmentId == null) { + return false; + } + return this.departmentId.equals(other.departmentId); + } + + return super.equals(obj); + } + + @Override + public int hashCode() { + return 1; + } + +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/example2/Employee.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/example2/Employee.java b/empire-db-spring/src/main/java/org/apache/empire/spring/example2/Employee.java new file mode 100644 index 0000000..5a07ce9 --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/example2/Employee.java @@ -0,0 +1,140 @@ +/* + * 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.empire.spring.example2; + +public class Employee { + + public static enum Gender { + + M("Male"), F("Female"); + + private String label; + + private Gender(String label) { + this.label = label; + } + + @Override + public String toString() { + return this.label; + } + } + + private Integer employeeId; + private String firstName; + private String lastName; + private Gender gender; + private String phoneNumber; + + private Department department; + + public Integer getEmployeeId() { + return employeeId; + } + + public void setEmployeeId(Integer employeeId) { + this.employeeId = employeeId; + } + + 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 Gender getGender() { + return gender; + } + + public void setGender(Gender gender) { + this.gender = gender; + } + + public String getPhoneNumber() { + return phoneNumber; + } + + public void setPhoneNumber(String phoneNumber) { + this.phoneNumber = phoneNumber; + } + + public Department getDepartment() { + return department; + } + + public void setDepartment(Department department) { + this.department = department; + } + + @Override + public String toString() { + StringBuffer buf = new StringBuffer(); + buf.append(employeeId); + buf.append("\t"); + buf.append(firstName); + buf.append(" "); + buf.append(lastName); + buf.append("\t"); + buf.append(gender); + + if (department != null){ + buf.append("\t"); + buf.append(department.getName()); + buf.append("\t"); + buf.append(department.getBusinessUnit()); + } + return buf.toString(); + } + + @Override + public boolean equals(Object obj) { + if (this == obj) { + return true; + } + if (obj == null) { + return false; + } + + if (obj.getClass().equals(this.getClass())) { + Employee other = (Employee) obj; + if (other.employeeId == null || this.employeeId == null) { + return false; + } + return this.employeeId.equals(other.employeeId); + } + + return super.equals(obj); + } + + @Override + public int hashCode() { + return 1; + } + +} http://git-wip-us.apache.org/repos/asf/empire-db/blob/20ecbae8/empire-db-spring/src/main/java/org/apache/empire/spring/example2/EmployeeDao.java ---------------------------------------------------------------------- diff --git a/empire-db-spring/src/main/java/org/apache/empire/spring/example2/EmployeeDao.java b/empire-db-spring/src/main/java/org/apache/empire/spring/example2/EmployeeDao.java new file mode 100644 index 0000000..ad02b46 --- /dev/null +++ b/empire-db-spring/src/main/java/org/apache/empire/spring/example2/EmployeeDao.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.empire.spring.example2; + +import java.util.List; + +public interface EmployeeDao { + + public List<Employee> getEmployees(); + + public Integer createEmployee(Employee employee); + + public void updateEmployee(Employee employee); + + public Employee openEmployee(Integer id); + + public Employee findEmployee(String firstName, String lastName); + + public Department openDepartment(Integer id); + + public Department findDepartment(String name); + + public Integer createDepartment(Department department); + + public void updateDepartment(Department department); + + public void renameDepartment(Integer id, String name); + +}
