Spring/spring-batch
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

BATCH-328: applied patch for samples

Browse Source
This commit is contained in:
dsyer
2008-07-01 06:47:35 +00:00
parent 56564c73b8
commit e72825d761
29 changed files with 913 additions and 578 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
pom.xml
View File

@@ -686,6 +686,16 @@
<name>ObjectStyle.org Repository</name>
<url>http://objectstyle.org/maven2/</url>
</repository>
<repository>
<id>com.springsource.repository.bundles.release</id>
<name>SpringSource Enterprise Bundle Repository - SpringSource Bundle Releases</name>
<url>http://repository.springsource.com/maven/bundles/release</url>
</repository>
<repository>
<id>com.springsource.repository.bundles.external</id>
<name>SpringSource Enterprise Bundle Repository - External Bundle Releases</name>
<url>http://repository.springsource.com/maven/bundles/external</url>
</repository>
</repositories>
<pluginRepositories>
<pluginRepository>

40
spring-batch-samples/pom.xml
View File

@@ -189,6 +189,18 @@
<version>10.2.1.6</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>net.sourceforge.jtds</groupId>
<artifactId>jtds</artifactId>
<version>1.2.2</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.oracle.jdbc</groupId>
<artifactId>com.springsource.oracle.jdbc</artifactId>
<version>10.2.0.2</version>
<scope>test</scope>
</dependency>
<!-- Spring Dependencies -->
<dependency>
<groupId>org.springframework</groupId>
@@ -343,6 +355,34 @@
<fileset dir="${basedir}/src/main/sql" includes="business-schema.sql.vpp" />
<mapper type="glob" from="*.sql.vpp" to="*-mysql.sql" />
</vppcopy>
<!-- Reference script for MS SQLServer - N.B. not under source control, but packaged in jar. -->
<vppcopy todir="${basedir}/target/generated-resources" overwrite="true">
<config>
<context>
<property key="includes" value="src/main/sql" />
<property file="${basedir}/src/main/sql/sqlserver.properties" />
</context>
<engine>
<property key="velocimacro.library" value="src/main/sql/sqlserver.vpp" />
</engine>
</config>
<fileset dir="${basedir}/src/main/sql" includes="business-schema.sql.vpp" />
<mapper type="glob" from="*.sql.vpp" to="*-sqlserver.sql" />
</vppcopy>
<!-- Reference script for Sybase - N.B. not under source control, but packaged in jar. -->
<vppcopy todir="${basedir}/target/generated-resources" overwrite="true">
<config>
<context>
<property key="includes" value="src/main/sql" />
<property file="${basedir}/src/main/sql/sybase.properties" />
</context>
<engine>
<property key="velocimacro.library" value="src/main/sql/sybase.vpp" />
</engine>
</config>
<fileset dir="${basedir}/src/main/sql" includes="business-schema.sql.vpp" />
<mapper type="glob" from="*.sql.vpp" to="*-sybase.sql" />
</vppcopy>
</tasks>
</configuration>
<goals>

15
spring-batch-samples/src/main/resources/batch-oracle.properties Normal file
View File

@@ -0,0 +1,15 @@
# Placeholders batch.*
# for MS SQLServer:
batch.jdbc.driver=oracle.jdbc.OracleDriver
batch.jdbc.url=jdbc:oracle:thin:@//dbhost:1521/xe
batch.jdbc.user=spring
batch.jdbc.password=spring
batch.schema=
batch.jndi.name=
batch.naming.factory.initial=
batch.naming.provider.url=
batch.schema.script=schema-oracle10g.sql
batch.business.schema.script=business-schema-oracle10g.sql
batch.database.incrementer.class=org.springframework.jdbc.support.incrementer.OracleSequenceMaxValueIncrementer
batch.lob.handler.class=org.springframework.jdbc.support.lob.DefaultLobHandler

18
spring-batch-samples/src/main/resources/batch-sqlserver.properties Normal file
View File

@@ -0,0 +1,18 @@
# Placeholders batch.*
# for MS SQLServer:
batch.jdbc.driver=net.sourceforge.jtds.jdbc.Driver
batch.jdbc.url=jdbc:jtds:sqlserver://dbhost:1433;databaseName=test
batch.jdbc.user=spring
batch.jdbc.password=spring
batch.schema=
batch.jndi.name=
batch.naming.factory.initial=
batch.naming.provider.url=
batch.schema.script=schema-sqlserver.sql
batch.business.schema.script=business-schema-sqlserver.sql
batch.database.incrementer.class=org.springframework.jdbc.support.incrementer.SqlServerMaxValueIncrementer
batch.lob.handler.class=org.springframework.jdbc.support.lob.DefaultLobHandler
# Bean Properties for override
# when not using sequences:
incrementerParent.columnName=ID

18
spring-batch-samples/src/main/resources/batch-sybase.properties Normal file
View File

@@ -0,0 +1,18 @@
# Placeholders batch.*
# for MySQL:
batch.jdbc.driver=net.sourceforge.jtds.jdbc.Driver
batch.jdbc.url=jdbc:jtds:sybase://dbhost:5000;databaseName=test
batch.jdbc.user=spring
batch.jdbc.password=spring
batch.schema=
batch.jndi.name=
batch.naming.factory.initial=
batch.naming.provider.url=
batch.schema.script=schema-sybase.sql
batch.business.schema.script=business-schema-sybase.sql
batch.database.incrementer.class=org.springframework.jdbc.support.incrementer.SybaseMaxValueIncrementer
batch.lob.handler.class=org.springframework.jdbc.support.lob.DefaultLobHandler
# Bean Properties for override
# when not using sequences:
incrementerParent.columnName=ID

170
spring-batch-samples/src/main/resources/business-schema-db2.sql
View File

@@ -1,86 +1,86 @@
-- Autogenerated: do not edit this file
DROP SEQUENCE BATCH_STAGING_SEQ ;
DROP SEQUENCE TRADE_SEQ ;
DROP SEQUENCE CUSTOMER_SEQ ;
DROP TABLE BATCH_STAGING ;
DROP TABLE TRADE ;
DROP TABLE CUSTOMER ;
DROP TABLE PLAYERS ;
DROP TABLE GAMES ;
DROP TABLE PLAYER_SUMMARY ;
-- Autogenerated: do not edit this file
CREATE SEQUENCE CUSTOMER_SEQ;
CREATE SEQUENCE BATCH_STAGING_SEQ;
CREATE SEQUENCE TRADE_SEQ;
CREATE TABLE BATCH_STAGING (
ID BIGINT PRIMARY KEY ,
JOB_ID BIGINT NOT NULL,
VALUE BLOB NOT NULL,
PROCESSED CHAR(1) NOT NULL
);
CREATE TABLE TRADE (
ID BIGINT PRIMARY KEY ,
VERSION BIGINT,
ISIN VARCHAR(45) NOT NULL,
QUANTITY BIGINT,
PRICE DOUBLE,
CUSTOMER VARCHAR(45)
);
CREATE TABLE CUSTOMER (
ID BIGINT PRIMARY KEY ,
VERSION BIGINT,
NAME VARCHAR(45),
CREDIT DOUBLE
);
INSERT INTO customer (id, version, name, credit) VALUES (1, 0, 'customer1', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (2, 0, 'customer2', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (3, 0, 'customer3', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (4, 0, 'customer4', 100000);
CREATE TABLE PLAYERS (
PLAYER_ID char(8) NOT NULL PRIMARY KEY,
LAST_NAME varchar(35) not null,
FIRST_NAME varchar(25) not null,
POS varchar(10),
YEAR_OF_BIRTH BIGINT not null,
YEAR_DRAFTED BIGINT not null
);
CREATE TABLE GAMES (
PLAYER_ID char(8) not null,
YEAR_NO BIGINT not null,
TEAM char(3) not null,
WEEK BIGINT not null,
OPPONENT char(3),
COMPLETES BIGINT,
ATTEMPTS BIGINT,
PASSING_YARDS BIGINT,
PASSING_TD BIGINT,
INTERCEPTIONS BIGINT,
RUSHES BIGINT,
RUSH_YARDS BIGINT,
RECEPTIONS BIGINT,
RECEPTIONS_YARDS BIGINT,
TOTAL_TD BIGINT
);
CREATE TABLE PLAYER_SUMMARY (
ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
COMPLETES BIGINT NOT NULL ,
ATTEMPTS BIGINT NOT NULL ,
PASSING_YARDS BIGINT NOT NULL ,
PASSING_TD BIGINT NOT NULL ,
INTERCEPTIONS BIGINT NOT NULL ,
RUSHES BIGINT NOT NULL ,
RUSH_YARDS BIGINT NOT NULL ,
RECEPTIONS BIGINT NOT NULL ,
RECEPTIONS_YARDS BIGINT NOT NULL ,
TOTAL_TD BIGINT NOT NULL
-- Autogenerated: do not edit this file
DROP SEQUENCE BATCH_STAGING_SEQ ;
DROP SEQUENCE TRADE_SEQ ;
DROP SEQUENCE CUSTOMER_SEQ ;
DROP TABLE BATCH_STAGING ;
DROP TABLE TRADE ;
DROP TABLE CUSTOMER ;
DROP TABLE PLAYERS ;
DROP TABLE GAMES ;
DROP TABLE PLAYER_SUMMARY ;
-- Autogenerated: do not edit this file
CREATE SEQUENCE CUSTOMER_SEQ;
CREATE SEQUENCE BATCH_STAGING_SEQ;
CREATE SEQUENCE TRADE_SEQ;
CREATE TABLE BATCH_STAGING (
ID BIGINT NOT NULL PRIMARY KEY ,
JOB_ID BIGINT NOT NULL,
VALUE BLOB NOT NULL,
PROCESSED CHAR(1) NOT NULL
);
CREATE TABLE TRADE (
ID BIGINT NOT NULL PRIMARY KEY ,
VERSION BIGINT ,
ISIN VARCHAR(45) NOT NULL,
QUANTITY BIGINT ,
PRICE DOUBLE PRECISION ,
CUSTOMER VARCHAR(45)
);
CREATE TABLE CUSTOMER (
ID BIGINT NOT NULL PRIMARY KEY ,
VERSION BIGINT ,
NAME VARCHAR(45) ,
CREDIT DOUBLE PRECISION
);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (1, 0, 'customer1', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (2, 0, 'customer2', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (3, 0, 'customer3', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (4, 0, 'customer4', 100000);
CREATE TABLE PLAYERS (
PLAYER_ID CHAR(8) NOT NULL PRIMARY KEY,
LAST_NAME VARCHAR(35) NOT NULL,
FIRST_NAME VARCHAR(25) NOT NULL,
POS VARCHAR(10) ,
YEAR_OF_BIRTH BIGINT NOT NULL,
YEAR_DRAFTED BIGINT NOT NULL
);
CREATE TABLE GAMES (
PLAYER_ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
TEAM CHAR(3) NOT NULL,
WEEK BIGINT NOT NULL,
OPPONENT CHAR(3) ,
COMPLETES BIGINT ,
ATTEMPTS BIGINT ,
PASSING_YARDS BIGINT ,
PASSING_TD BIGINT ,
INTERCEPTIONS BIGINT ,
RUSHES BIGINT ,
RUSH_YARDS BIGINT ,
RECEPTIONS BIGINT ,
RECEPTIONS_YARDS BIGINT ,
TOTAL_TD BIGINT
);
CREATE TABLE PLAYER_SUMMARY (
ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
COMPLETES BIGINT NOT NULL ,
ATTEMPTS BIGINT NOT NULL ,
PASSING_YARDS BIGINT NOT NULL ,
PASSING_TD BIGINT NOT NULL ,
INTERCEPTIONS BIGINT NOT NULL ,
RUSHES BIGINT NOT NULL ,
RUSH_YARDS BIGINT NOT NULL ,
RECEPTIONS BIGINT NOT NULL ,
RECEPTIONS_YARDS BIGINT NOT NULL ,
TOTAL_TD BIGINT NOT NULL
);

170
spring-batch-samples/src/main/resources/business-schema-derby.sql
View File

@@ -1,86 +1,86 @@
-- Autogenerated: do not edit this file
DROP TABLE BATCH_STAGING_SEQ ;
DROP TABLE TRADE_SEQ ;
DROP TABLE CUSTOMER_SEQ ;
DROP TABLE BATCH_STAGING ;
DROP TABLE TRADE ;
DROP TABLE CUSTOMER ;
DROP TABLE PLAYERS ;
DROP TABLE GAMES ;
DROP TABLE PLAYER_SUMMARY ;
-- Autogenerated: do not edit this file
CREATE TABLE CUSTOMER_SEQ (ID BIGINT PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY, DUMMY VARCHAR(1));
CREATE TABLE BATCH_STAGING_SEQ (ID BIGINT PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY, DUMMY VARCHAR(1));
CREATE TABLE TRADE_SEQ (ID BIGINT PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY, DUMMY VARCHAR(1));
CREATE TABLE BATCH_STAGING (
ID BIGINT PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY,
JOB_ID BIGINT NOT NULL,
VALUE BLOB NOT NULL,
PROCESSED CHAR(1) NOT NULL
);
CREATE TABLE TRADE (
ID BIGINT PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY,
VERSION BIGINT,
ISIN VARCHAR(45) NOT NULL,
QUANTITY BIGINT,
PRICE DOUBLE,
CUSTOMER VARCHAR(45)
);
CREATE TABLE CUSTOMER (
ID BIGINT PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY,
VERSION BIGINT,
NAME VARCHAR(45),
CREDIT DOUBLE
);
INSERT INTO customer (id, version, name, credit) VALUES (1, 0, 'customer1', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (2, 0, 'customer2', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (3, 0, 'customer3', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (4, 0, 'customer4', 100000);
CREATE TABLE PLAYERS (
PLAYER_ID char(8) NOT NULL PRIMARY KEY,
LAST_NAME varchar(35) not null,
FIRST_NAME varchar(25) not null,
POS varchar(10),
YEAR_OF_BIRTH BIGINT not null,
YEAR_DRAFTED BIGINT not null
);
CREATE TABLE GAMES (
PLAYER_ID char(8) not null,
YEAR_NO BIGINT not null,
TEAM char(3) not null,
WEEK BIGINT not null,
OPPONENT char(3),
COMPLETES BIGINT,
ATTEMPTS BIGINT,
PASSING_YARDS BIGINT,
PASSING_TD BIGINT,
INTERCEPTIONS BIGINT,
RUSHES BIGINT,
RUSH_YARDS BIGINT,
RECEPTIONS BIGINT,
RECEPTIONS_YARDS BIGINT,
TOTAL_TD BIGINT
);
CREATE TABLE PLAYER_SUMMARY (
ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
COMPLETES BIGINT NOT NULL ,
ATTEMPTS BIGINT NOT NULL ,
PASSING_YARDS BIGINT NOT NULL ,
PASSING_TD BIGINT NOT NULL ,
INTERCEPTIONS BIGINT NOT NULL ,
RUSHES BIGINT NOT NULL ,
RUSH_YARDS BIGINT NOT NULL ,
RECEPTIONS BIGINT NOT NULL ,
RECEPTIONS_YARDS BIGINT NOT NULL ,
TOTAL_TD BIGINT NOT NULL
-- Autogenerated: do not edit this file
DROP TABLE BATCH_STAGING_SEQ ;
DROP TABLE TRADE_SEQ ;
DROP TABLE CUSTOMER_SEQ ;
DROP TABLE BATCH_STAGING ;
DROP TABLE TRADE ;
DROP TABLE CUSTOMER ;
DROP TABLE PLAYERS ;
DROP TABLE GAMES ;
DROP TABLE PLAYER_SUMMARY ;
-- Autogenerated: do not edit this file
CREATE TABLE CUSTOMER_SEQ (ID BIGINT PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY, DUMMY VARCHAR(1));
CREATE TABLE BATCH_STAGING_SEQ (ID BIGINT PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY, DUMMY VARCHAR(1));
CREATE TABLE TRADE_SEQ (ID BIGINT PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY, DUMMY VARCHAR(1));
CREATE TABLE BATCH_STAGING (
ID BIGINT NOT NULL PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY,
JOB_ID BIGINT NOT NULL,
VALUE BLOB NOT NULL,
PROCESSED CHAR(1) NOT NULL
);
CREATE TABLE TRADE (
ID BIGINT NOT NULL PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY,
VERSION BIGINT ,
ISIN VARCHAR(45) NOT NULL,
QUANTITY BIGINT ,
PRICE DOUBLE PRECISION ,
CUSTOMER VARCHAR(45)
);
CREATE TABLE CUSTOMER (
ID BIGINT NOT NULL PRIMARY KEY GENERATED BY DEFAULT AS IDENTITY,
VERSION BIGINT ,
NAME VARCHAR(45) ,
CREDIT DOUBLE PRECISION
);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (1, 0, 'customer1', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (2, 0, 'customer2', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (3, 0, 'customer3', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (4, 0, 'customer4', 100000);
CREATE TABLE PLAYERS (
PLAYER_ID CHAR(8) NOT NULL PRIMARY KEY,
LAST_NAME VARCHAR(35) NOT NULL,
FIRST_NAME VARCHAR(25) NOT NULL,
POS VARCHAR(10) ,
YEAR_OF_BIRTH BIGINT NOT NULL,
YEAR_DRAFTED BIGINT NOT NULL
);
CREATE TABLE GAMES (
PLAYER_ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
TEAM CHAR(3) NOT NULL,
WEEK BIGINT NOT NULL,
OPPONENT CHAR(3) ,
COMPLETES BIGINT ,
ATTEMPTS BIGINT ,
PASSING_YARDS BIGINT ,
PASSING_TD BIGINT ,
INTERCEPTIONS BIGINT ,
RUSHES BIGINT ,
RUSH_YARDS BIGINT ,
RECEPTIONS BIGINT ,
RECEPTIONS_YARDS BIGINT ,
TOTAL_TD BIGINT
);
CREATE TABLE PLAYER_SUMMARY (
ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
COMPLETES BIGINT NOT NULL ,
ATTEMPTS BIGINT NOT NULL ,
PASSING_YARDS BIGINT NOT NULL ,
PASSING_TD BIGINT NOT NULL ,
INTERCEPTIONS BIGINT NOT NULL ,
RUSHES BIGINT NOT NULL ,
RUSH_YARDS BIGINT NOT NULL ,
RECEPTIONS BIGINT NOT NULL ,
RECEPTIONS_YARDS BIGINT NOT NULL ,
TOTAL_TD BIGINT NOT NULL
);

182
spring-batch-samples/src/main/resources/business-schema-hsqldb.sql
View File

@@ -1,92 +1,92 @@
-- Autogenerated: do not edit this file
DROP TABLE BATCH_STAGING_SEQ IF EXISTS;
DROP TABLE TRADE_SEQ IF EXISTS;
DROP TABLE CUSTOMER_SEQ IF EXISTS;
DROP TABLE BATCH_STAGING IF EXISTS;
DROP TABLE TRADE IF EXISTS;
DROP TABLE CUSTOMER IF EXISTS;
DROP TABLE PLAYERS IF EXISTS;
DROP TABLE GAMES IF EXISTS;
DROP TABLE PLAYER_SUMMARY IF EXISTS;
-- Autogenerated: do not edit this file
CREATE TABLE CUSTOMER_SEQ (
ID BIGINT IDENTITY
);
CREATE TABLE BATCH_STAGING_SEQ (
ID BIGINT IDENTITY
);
CREATE TABLE TRADE_SEQ (
ID BIGINT IDENTITY
);
CREATE TABLE BATCH_STAGING (
ID BIGINT IDENTITY PRIMARY KEY ,
JOB_ID BIGINT NOT NULL,
VALUE LONGVARBINARY NOT NULL,
PROCESSED CHAR(1) NOT NULL
);
CREATE TABLE TRADE (
ID BIGINT IDENTITY PRIMARY KEY ,
VERSION BIGINT,
ISIN VARCHAR(45) NOT NULL,
QUANTITY BIGINT,
PRICE DOUBLE,
CUSTOMER VARCHAR(45)
);
CREATE TABLE CUSTOMER (
ID BIGINT IDENTITY PRIMARY KEY ,
VERSION BIGINT,
NAME VARCHAR(45),
CREDIT DOUBLE
);
INSERT INTO customer (id, version, name, credit) VALUES (1, 0, 'customer1', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (2, 0, 'customer2', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (3, 0, 'customer3', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (4, 0, 'customer4', 100000);
CREATE TABLE PLAYERS (
PLAYER_ID char(8) NOT NULL PRIMARY KEY,
LAST_NAME varchar(35) not null,
FIRST_NAME varchar(25) not null,
POS varchar(10),
YEAR_OF_BIRTH BIGINT not null,
YEAR_DRAFTED BIGINT not null
);
CREATE TABLE GAMES (
PLAYER_ID char(8) not null,
YEAR_NO BIGINT not null,
TEAM char(3) not null,
WEEK BIGINT not null,
OPPONENT char(3),
COMPLETES BIGINT,
ATTEMPTS BIGINT,
PASSING_YARDS BIGINT,
PASSING_TD BIGINT,
INTERCEPTIONS BIGINT,
RUSHES BIGINT,
RUSH_YARDS BIGINT,
RECEPTIONS BIGINT,
RECEPTIONS_YARDS BIGINT,
TOTAL_TD BIGINT
);
CREATE TABLE PLAYER_SUMMARY (
ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
COMPLETES BIGINT NOT NULL ,
ATTEMPTS BIGINT NOT NULL ,
PASSING_YARDS BIGINT NOT NULL ,
PASSING_TD BIGINT NOT NULL ,
INTERCEPTIONS BIGINT NOT NULL ,
RUSHES BIGINT NOT NULL ,
RUSH_YARDS BIGINT NOT NULL ,
RECEPTIONS BIGINT NOT NULL ,
RECEPTIONS_YARDS BIGINT NOT NULL ,
TOTAL_TD BIGINT NOT NULL
-- Autogenerated: do not edit this file
DROP TABLE BATCH_STAGING_SEQ IF EXISTS;
DROP TABLE TRADE_SEQ IF EXISTS;
DROP TABLE CUSTOMER_SEQ IF EXISTS;
DROP TABLE BATCH_STAGING IF EXISTS;
DROP TABLE TRADE IF EXISTS;
DROP TABLE CUSTOMER IF EXISTS;
DROP TABLE PLAYERS IF EXISTS;
DROP TABLE GAMES IF EXISTS;
DROP TABLE PLAYER_SUMMARY IF EXISTS;
-- Autogenerated: do not edit this file
CREATE TABLE CUSTOMER_SEQ (
ID BIGINT IDENTITY
);
CREATE TABLE BATCH_STAGING_SEQ (
ID BIGINT IDENTITY
);
CREATE TABLE TRADE_SEQ (
ID BIGINT IDENTITY
);
CREATE TABLE BATCH_STAGING (
ID BIGINT IDENTITY NOT NULL PRIMARY KEY ,
JOB_ID BIGINT NOT NULL,
VALUE LONGVARBINARY NOT NULL,
PROCESSED CHAR(1) NOT NULL
);
CREATE TABLE TRADE (
ID BIGINT IDENTITY NOT NULL PRIMARY KEY ,
VERSION BIGINT ,
ISIN VARCHAR(45) NOT NULL,
QUANTITY BIGINT ,
PRICE DOUBLE PRECISION ,
CUSTOMER VARCHAR(45)
);
CREATE TABLE CUSTOMER (
ID BIGINT IDENTITY NOT NULL PRIMARY KEY ,
VERSION BIGINT ,
NAME VARCHAR(45) ,
CREDIT DOUBLE PRECISION
);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (1, 0, 'customer1', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (2, 0, 'customer2', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (3, 0, 'customer3', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (4, 0, 'customer4', 100000);
CREATE TABLE PLAYERS (
PLAYER_ID CHAR(8) NOT NULL PRIMARY KEY,
LAST_NAME VARCHAR(35) NOT NULL,
FIRST_NAME VARCHAR(25) NOT NULL,
POS VARCHAR(10) ,
YEAR_OF_BIRTH BIGINT NOT NULL,
YEAR_DRAFTED BIGINT NOT NULL
);
CREATE TABLE GAMES (
PLAYER_ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
TEAM CHAR(3) NOT NULL,
WEEK BIGINT NOT NULL,
OPPONENT CHAR(3) ,
COMPLETES BIGINT ,
ATTEMPTS BIGINT ,
PASSING_YARDS BIGINT ,
PASSING_TD BIGINT ,
INTERCEPTIONS BIGINT ,
RUSHES BIGINT ,
RUSH_YARDS BIGINT ,
RECEPTIONS BIGINT ,
RECEPTIONS_YARDS BIGINT ,
TOTAL_TD BIGINT
);
CREATE TABLE PLAYER_SUMMARY (
ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
COMPLETES BIGINT NOT NULL ,
ATTEMPTS BIGINT NOT NULL ,
PASSING_YARDS BIGINT NOT NULL ,
PASSING_TD BIGINT NOT NULL ,
INTERCEPTIONS BIGINT NOT NULL ,
RUSHES BIGINT NOT NULL ,
RUSH_YARDS BIGINT NOT NULL ,
RECEPTIONS BIGINT NOT NULL ,
RECEPTIONS_YARDS BIGINT NOT NULL ,
TOTAL_TD BIGINT NOT NULL
);

176
spring-batch-samples/src/main/resources/business-schema-mysql.sql
View File

@@ -1,89 +1,89 @@
-- Autogenerated: do not edit this file
DROP TABLE IF EXISTS BATCH_STAGING_SEQ ;
DROP TABLE IF EXISTS TRADE_SEQ ;
DROP TABLE IF EXISTS CUSTOMER_SEQ ;
DROP TABLE IF EXISTS BATCH_STAGING ;
DROP TABLE IF EXISTS TRADE ;
DROP TABLE IF EXISTS CUSTOMER ;
DROP TABLE IF EXISTS PLAYERS ;
DROP TABLE IF EXISTS GAMES ;
DROP TABLE IF EXISTS PLAYER_SUMMARY ;
-- Autogenerated: do not edit this file
CREATE TABLE CUSTOMER_SEQ (ID BIGINT NOT NULL) type=MYISAM;
INSERT INTO CUSTOMER_SEQ values(0);
CREATE TABLE BATCH_STAGING_SEQ (ID BIGINT NOT NULL) type=MYISAM;
INSERT INTO BATCH_STAGING_SEQ values(0);
CREATE TABLE TRADE_SEQ (ID BIGINT NOT NULL) type=MYISAM;
INSERT INTO TRADE_SEQ values(0);
CREATE TABLE BATCH_STAGING (
ID BIGINT unsigned PRIMARY KEY ,
JOB_ID BIGINT NOT NULL,
VALUE BLOB NOT NULL,
PROCESSED CHAR(1) NOT NULL
);
CREATE TABLE TRADE (
ID BIGINT unsigned PRIMARY KEY ,
VERSION BIGINT,
ISIN VARCHAR(45) NOT NULL,
QUANTITY BIGINT,
PRICE DOUBLE,
CUSTOMER VARCHAR(45)
);
CREATE TABLE CUSTOMER (
ID BIGINT unsigned PRIMARY KEY ,
VERSION BIGINT,
NAME VARCHAR(45),
CREDIT DOUBLE
);
INSERT INTO customer (id, version, name, credit) VALUES (1, 0, 'customer1', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (2, 0, 'customer2', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (3, 0, 'customer3', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (4, 0, 'customer4', 100000);
CREATE TABLE PLAYERS (
PLAYER_ID char(8) NOT NULL PRIMARY KEY,
LAST_NAME varchar(35) not null,
FIRST_NAME varchar(25) not null,
POS varchar(10),
YEAR_OF_BIRTH BIGINT not null,
YEAR_DRAFTED BIGINT not null
);
CREATE TABLE GAMES (
PLAYER_ID char(8) not null,
YEAR_NO BIGINT not null,
TEAM char(3) not null,
WEEK BIGINT not null,
OPPONENT char(3),
COMPLETES BIGINT,
ATTEMPTS BIGINT,
PASSING_YARDS BIGINT,
PASSING_TD BIGINT,
INTERCEPTIONS BIGINT,
RUSHES BIGINT,
RUSH_YARDS BIGINT,
RECEPTIONS BIGINT,
RECEPTIONS_YARDS BIGINT,
TOTAL_TD BIGINT
);
CREATE TABLE PLAYER_SUMMARY (
ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
COMPLETES BIGINT NOT NULL ,
ATTEMPTS BIGINT NOT NULL ,
PASSING_YARDS BIGINT NOT NULL ,
PASSING_TD BIGINT NOT NULL ,
INTERCEPTIONS BIGINT NOT NULL ,
RUSHES BIGINT NOT NULL ,
RUSH_YARDS BIGINT NOT NULL ,
RECEPTIONS BIGINT NOT NULL ,
RECEPTIONS_YARDS BIGINT NOT NULL ,
TOTAL_TD BIGINT NOT NULL
-- Autogenerated: do not edit this file
DROP TABLE IF EXISTS BATCH_STAGING_SEQ ;
DROP TABLE IF EXISTS TRADE_SEQ ;
DROP TABLE IF EXISTS CUSTOMER_SEQ ;
DROP TABLE IF EXISTS BATCH_STAGING ;
DROP TABLE IF EXISTS TRADE ;
DROP TABLE IF EXISTS CUSTOMER ;
DROP TABLE IF EXISTS PLAYERS ;
DROP TABLE IF EXISTS GAMES ;
DROP TABLE IF EXISTS PLAYER_SUMMARY ;
-- Autogenerated: do not edit this file
CREATE TABLE CUSTOMER_SEQ (ID BIGINT NOT NULL) type=MYISAM;
INSERT INTO CUSTOMER_SEQ values(0);
CREATE TABLE BATCH_STAGING_SEQ (ID BIGINT NOT NULL) type=MYISAM;
INSERT INTO BATCH_STAGING_SEQ values(0);
CREATE TABLE TRADE_SEQ (ID BIGINT NOT NULL) type=MYISAM;
INSERT INTO TRADE_SEQ values(0);
CREATE TABLE BATCH_STAGING (
ID BIGINT NOT NULL PRIMARY KEY ,
JOB_ID BIGINT NOT NULL,
VALUE BLOB NOT NULL,
PROCESSED CHAR(1) NOT NULL
);
CREATE TABLE TRADE (
ID BIGINT NOT NULL PRIMARY KEY ,
VERSION BIGINT ,
ISIN VARCHAR(45) NOT NULL,
QUANTITY BIGINT ,
PRICE DOUBLE PRECISION ,
CUSTOMER VARCHAR(45)
);
CREATE TABLE CUSTOMER (
ID BIGINT NOT NULL PRIMARY KEY ,
VERSION BIGINT ,
NAME VARCHAR(45) ,
CREDIT DOUBLE PRECISION
);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (1, 0, 'customer1', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (2, 0, 'customer2', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (3, 0, 'customer3', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (4, 0, 'customer4', 100000);
CREATE TABLE PLAYERS (
PLAYER_ID CHAR(8) NOT NULL PRIMARY KEY,
LAST_NAME VARCHAR(35) NOT NULL,
FIRST_NAME VARCHAR(25) NOT NULL,
POS VARCHAR(10) ,
YEAR_OF_BIRTH BIGINT NOT NULL,
YEAR_DRAFTED BIGINT NOT NULL
);
CREATE TABLE GAMES (
PLAYER_ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
TEAM CHAR(3) NOT NULL,
WEEK BIGINT NOT NULL,
OPPONENT CHAR(3) ,
COMPLETES BIGINT ,
ATTEMPTS BIGINT ,
PASSING_YARDS BIGINT ,
PASSING_TD BIGINT ,
INTERCEPTIONS BIGINT ,
RUSHES BIGINT ,
RUSH_YARDS BIGINT ,
RECEPTIONS BIGINT ,
RECEPTIONS_YARDS BIGINT ,
TOTAL_TD BIGINT
);
CREATE TABLE PLAYER_SUMMARY (
ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
COMPLETES BIGINT NOT NULL ,
ATTEMPTS BIGINT NOT NULL ,
PASSING_YARDS BIGINT NOT NULL ,
PASSING_TD BIGINT NOT NULL ,
INTERCEPTIONS BIGINT NOT NULL ,
RUSHES BIGINT NOT NULL ,
RUSH_YARDS BIGINT NOT NULL ,
RECEPTIONS BIGINT NOT NULL ,
RECEPTIONS_YARDS BIGINT NOT NULL ,
TOTAL_TD BIGINT NOT NULL
);

170
spring-batch-samples/src/main/resources/business-schema-oracle10g.sql
View File

@@ -1,86 +1,86 @@
-- Autogenerated: do not edit this file
DROP SEQUENCE BATCH_STAGING_SEQ ;
DROP SEQUENCE TRADE_SEQ ;
DROP SEQUENCE CUSTOMER_SEQ ;
DROP TABLE BATCH_STAGING ;
DROP TABLE TRADE ;
DROP TABLE CUSTOMER ;
DROP TABLE PLAYERS ;
DROP TABLE GAMES ;
DROP TABLE PLAYER_SUMMARY ;
-- Autogenerated: do not edit this file
CREATE SEQUENCE CUSTOMER_SEQ;
CREATE SEQUENCE BATCH_STAGING_SEQ;
CREATE SEQUENCE TRADE_SEQ;
CREATE TABLE BATCH_STAGING (
ID NUMBER(38) PRIMARY KEY ,
JOB_ID NUMBER(38) NOT NULL,
VALUE BLOB NOT NULL,
PROCESSED CHAR(1) NOT NULL
);
CREATE TABLE TRADE (
ID NUMBER(38) PRIMARY KEY ,
VERSION NUMBER(38),
ISIN VARCHAR(45) NOT NULL,
QUANTITY NUMBER(38),
PRICE DOUBLE,
CUSTOMER VARCHAR(45)
);
CREATE TABLE CUSTOMER (
ID NUMBER(38) PRIMARY KEY ,
VERSION NUMBER(38),
NAME VARCHAR(45),
CREDIT DOUBLE
);
INSERT INTO customer (id, version, name, credit) VALUES (1, 0, 'customer1', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (2, 0, 'customer2', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (3, 0, 'customer3', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (4, 0, 'customer4', 100000);
CREATE TABLE PLAYERS (
PLAYER_ID char(8) NOT NULL PRIMARY KEY,
LAST_NAME varchar(35) not null,
FIRST_NAME varchar(25) not null,
POS varchar(10),
YEAR_OF_BIRTH NUMBER(38) not null,
YEAR_DRAFTED NUMBER(38) not null
);
CREATE TABLE GAMES (
PLAYER_ID char(8) not null,
YEAR_NO NUMBER(38) not null,
TEAM char(3) not null,
WEEK NUMBER(38) not null,
OPPONENT char(3),
COMPLETES NUMBER(38),
ATTEMPTS NUMBER(38),
PASSING_YARDS NUMBER(38),
PASSING_TD NUMBER(38),
INTERCEPTIONS NUMBER(38),
RUSHES NUMBER(38),
RUSH_YARDS NUMBER(38),
RECEPTIONS NUMBER(38),
RECEPTIONS_YARDS NUMBER(38),
TOTAL_TD NUMBER(38)
);
CREATE TABLE PLAYER_SUMMARY (
ID CHAR(8) NOT NULL,
YEAR_NO NUMBER(38) NOT NULL,
COMPLETES NUMBER(38) NOT NULL ,
ATTEMPTS NUMBER(38) NOT NULL ,
PASSING_YARDS NUMBER(38) NOT NULL ,
PASSING_TD NUMBER(38) NOT NULL ,
INTERCEPTIONS NUMBER(38) NOT NULL ,
RUSHES NUMBER(38) NOT NULL ,
RUSH_YARDS NUMBER(38) NOT NULL ,
RECEPTIONS NUMBER(38) NOT NULL ,
RECEPTIONS_YARDS NUMBER(38) NOT NULL ,
TOTAL_TD NUMBER(38) NOT NULL
-- Autogenerated: do not edit this file
DROP SEQUENCE BATCH_STAGING_SEQ ;
DROP SEQUENCE TRADE_SEQ ;
DROP SEQUENCE CUSTOMER_SEQ ;
DROP TABLE BATCH_STAGING ;
DROP TABLE TRADE ;
DROP TABLE CUSTOMER ;
DROP TABLE PLAYERS ;
DROP TABLE GAMES ;
DROP TABLE PLAYER_SUMMARY ;
-- Autogenerated: do not edit this file
CREATE SEQUENCE CUSTOMER_SEQ;
CREATE SEQUENCE BATCH_STAGING_SEQ;
CREATE SEQUENCE TRADE_SEQ;
CREATE TABLE BATCH_STAGING (
ID NUMBER(38) NOT NULL PRIMARY KEY ,
JOB_ID NUMBER(38) NOT NULL,
VALUE BLOB NOT NULL,
PROCESSED CHAR(1) NOT NULL
);
CREATE TABLE TRADE (
ID NUMBER(38) NOT NULL PRIMARY KEY ,
VERSION NUMBER(38) ,
ISIN VARCHAR(45) NOT NULL,
QUANTITY NUMBER(38) ,
PRICE NUMBER ,
CUSTOMER VARCHAR2(45)
);
CREATE TABLE CUSTOMER (
ID NUMBER(38) NOT NULL PRIMARY KEY ,
VERSION NUMBER(38) ,
NAME VARCHAR2(45) ,
CREDIT NUMBER
);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (1, 0, 'customer1', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (2, 0, 'customer2', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (3, 0, 'customer3', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (4, 0, 'customer4', 100000);
CREATE TABLE PLAYERS (
PLAYER_ID CHAR(8) NOT NULL PRIMARY KEY,
LAST_NAME VARCHAR2(35) NOT NULL,
FIRST_NAME VARCHAR2(25) NOT NULL,
POS VARCHAR2(10) ,
YEAR_OF_BIRTH NUMBER(38) NOT NULL,
YEAR_DRAFTED NUMBER(38) NOT NULL
);
CREATE TABLE GAMES (
PLAYER_ID CHAR(8) NOT NULL,
YEAR_NO NUMBER(38) NOT NULL,
TEAM CHAR(3) NOT NULL,
WEEK NUMBER(38) NOT NULL,
OPPONENT CHAR(3) ,
COMPLETES NUMBER(38) ,
ATTEMPTS NUMBER(38) ,
PASSING_YARDS NUMBER(38) ,
PASSING_TD NUMBER(38) ,
INTERCEPTIONS NUMBER(38) ,
RUSHES NUMBER(38) ,
RUSH_YARDS NUMBER(38) ,
RECEPTIONS NUMBER(38) ,
RECEPTIONS_YARDS NUMBER(38) ,
TOTAL_TD NUMBER(38)
);
CREATE TABLE PLAYER_SUMMARY (
ID CHAR(8) NOT NULL,
YEAR_NO NUMBER(38) NOT NULL,
COMPLETES NUMBER(38) NOT NULL ,
ATTEMPTS NUMBER(38) NOT NULL ,
PASSING_YARDS NUMBER(38) NOT NULL ,
PASSING_TD NUMBER(38) NOT NULL ,
INTERCEPTIONS NUMBER(38) NOT NULL ,
RUSHES NUMBER(38) NOT NULL ,
RUSH_YARDS NUMBER(38) NOT NULL ,
RECEPTIONS NUMBER(38) NOT NULL ,
RECEPTIONS_YARDS NUMBER(38) NOT NULL ,
TOTAL_TD NUMBER(38) NOT NULL
);

170
spring-batch-samples/src/main/resources/business-schema-postgresql.sql
View File

@@ -1,86 +1,86 @@
-- Autogenerated: do not edit this file
DROP SEQUENCE BATCH_STAGING_SEQ ;
DROP SEQUENCE TRADE_SEQ ;
DROP SEQUENCE CUSTOMER_SEQ ;
DROP TABLE BATCH_STAGING ;
DROP TABLE TRADE ;
DROP TABLE CUSTOMER ;
DROP TABLE PLAYERS ;
DROP TABLE GAMES ;
DROP TABLE PLAYER_SUMMARY ;
-- Autogenerated: do not edit this file
CREATE SEQUENCE CUSTOMER_SEQ;
CREATE SEQUENCE BATCH_STAGING_SEQ;
CREATE SEQUENCE TRADE_SEQ;
CREATE TABLE BATCH_STAGING (
ID BIGINT PRIMARY KEY ,
JOB_ID BIGINT NOT NULL,
VALUE BYTEA NOT NULL,
PROCESSED CHAR(1) NOT NULL
);
CREATE TABLE TRADE (
ID BIGINT PRIMARY KEY ,
VERSION BIGINT,
ISIN VARCHAR(45) NOT NULL,
QUANTITY BIGINT,
PRICE DOUBLE,
CUSTOMER VARCHAR(45)
);
CREATE TABLE CUSTOMER (
ID BIGINT PRIMARY KEY ,
VERSION BIGINT,
NAME VARCHAR(45),
CREDIT DOUBLE
);
INSERT INTO customer (id, version, name, credit) VALUES (1, 0, 'customer1', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (2, 0, 'customer2', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (3, 0, 'customer3', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (4, 0, 'customer4', 100000);
CREATE TABLE PLAYERS (
PLAYER_ID char(8) NOT NULL PRIMARY KEY,
LAST_NAME varchar(35) not null,
FIRST_NAME varchar(25) not null,
POS varchar(10),
YEAR_OF_BIRTH BIGINT not null,
YEAR_DRAFTED BIGINT not null
);
CREATE TABLE GAMES (
PLAYER_ID char(8) not null,
YEAR_NO BIGINT not null,
TEAM char(3) not null,
WEEK BIGINT not null,
OPPONENT char(3),
COMPLETES BIGINT,
ATTEMPTS BIGINT,
PASSING_YARDS BIGINT,
PASSING_TD BIGINT,
INTERCEPTIONS BIGINT,
RUSHES BIGINT,
RUSH_YARDS BIGINT,
RECEPTIONS BIGINT,
RECEPTIONS_YARDS BIGINT,
TOTAL_TD BIGINT
);
CREATE TABLE PLAYER_SUMMARY (
ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
COMPLETES BIGINT NOT NULL ,
ATTEMPTS BIGINT NOT NULL ,
PASSING_YARDS BIGINT NOT NULL ,
PASSING_TD BIGINT NOT NULL ,
INTERCEPTIONS BIGINT NOT NULL ,
RUSHES BIGINT NOT NULL ,
RUSH_YARDS BIGINT NOT NULL ,
RECEPTIONS BIGINT NOT NULL ,
RECEPTIONS_YARDS BIGINT NOT NULL ,
TOTAL_TD BIGINT NOT NULL
-- Autogenerated: do not edit this file
DROP SEQUENCE BATCH_STAGING_SEQ ;
DROP SEQUENCE TRADE_SEQ ;
DROP SEQUENCE CUSTOMER_SEQ ;
DROP TABLE BATCH_STAGING ;
DROP TABLE TRADE ;
DROP TABLE CUSTOMER ;
DROP TABLE PLAYERS ;
DROP TABLE GAMES ;
DROP TABLE PLAYER_SUMMARY ;
-- Autogenerated: do not edit this file
CREATE SEQUENCE CUSTOMER_SEQ;
CREATE SEQUENCE BATCH_STAGING_SEQ;
CREATE SEQUENCE TRADE_SEQ;
CREATE TABLE BATCH_STAGING (
ID BIGINT NOT NULL PRIMARY KEY ,
JOB_ID BIGINT NOT NULL,
VALUE BYTEA NOT NULL,
PROCESSED CHAR(1) NOT NULL
);
CREATE TABLE TRADE (
ID BIGINT NOT NULL PRIMARY KEY ,
VERSION BIGINT ,
ISIN VARCHAR(45) NOT NULL,
QUANTITY BIGINT ,
PRICE DOUBLE PRECISION ,
CUSTOMER VARCHAR(45)
);
CREATE TABLE CUSTOMER (
ID BIGINT NOT NULL PRIMARY KEY ,
VERSION BIGINT ,
NAME VARCHAR(45) ,
CREDIT DOUBLE PRECISION
);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (1, 0, 'customer1', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (2, 0, 'customer2', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (3, 0, 'customer3', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (4, 0, 'customer4', 100000);
CREATE TABLE PLAYERS (
PLAYER_ID CHAR(8) NOT NULL PRIMARY KEY,
LAST_NAME VARCHAR(35) NOT NULL,
FIRST_NAME VARCHAR(25) NOT NULL,
POS VARCHAR(10) ,
YEAR_OF_BIRTH BIGINT NOT NULL,
YEAR_DRAFTED BIGINT NOT NULL
);
CREATE TABLE GAMES (
PLAYER_ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
TEAM CHAR(3) NOT NULL,
WEEK BIGINT NOT NULL,
OPPONENT CHAR(3) ,
COMPLETES BIGINT ,
ATTEMPTS BIGINT ,
PASSING_YARDS BIGINT ,
PASSING_TD BIGINT ,
INTERCEPTIONS BIGINT ,
RUSHES BIGINT ,
RUSH_YARDS BIGINT ,
RECEPTIONS BIGINT ,
RECEPTIONS_YARDS BIGINT ,
TOTAL_TD BIGINT
);
CREATE TABLE PLAYER_SUMMARY (
ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
COMPLETES BIGINT NOT NULL ,
ATTEMPTS BIGINT NOT NULL ,
PASSING_YARDS BIGINT NOT NULL ,
PASSING_TD BIGINT NOT NULL ,
INTERCEPTIONS BIGINT NOT NULL ,
RUSHES BIGINT NOT NULL ,
RUSH_YARDS BIGINT NOT NULL ,
RECEPTIONS BIGINT NOT NULL ,
RECEPTIONS_YARDS BIGINT NOT NULL ,
TOTAL_TD BIGINT NOT NULL
);

86
spring-batch-samples/src/main/resources/business-schema-sqlserver.sql Normal file
View File

@@ -0,0 +1,86 @@
-- Autogenerated: do not edit this file
DROP TABLE BATCH_STAGING_SEQ ;
DROP TABLE TRADE_SEQ ;
DROP TABLE CUSTOMER_SEQ ;
DROP TABLE BATCH_STAGING ;
DROP TABLE TRADE ;
DROP TABLE CUSTOMER ;
DROP TABLE PLAYERS ;
DROP TABLE GAMES ;
DROP TABLE PLAYER_SUMMARY ;
-- Autogenerated: do not edit this file
CREATE TABLE CUSTOMER_SEQ (ID BIGINT IDENTITY);
CREATE TABLE BATCH_STAGING_SEQ (ID BIGINT IDENTITY);
CREATE TABLE TRADE_SEQ (ID BIGINT IDENTITY);
CREATE TABLE BATCH_STAGING (
ID BIGINT NOT NULL PRIMARY KEY ,
JOB_ID BIGINT NOT NULL,
VALUE IMAGE NOT NULL,
PROCESSED CHAR(1) NOT NULL
);
CREATE TABLE TRADE (
ID BIGINT NOT NULL PRIMARY KEY ,
VERSION BIGINT ,
ISIN VARCHAR(45) NOT NULL,
QUANTITY BIGINT ,
PRICE DOUBLE PRECISION ,
CUSTOMER VARCHAR(45)
);
CREATE TABLE CUSTOMER (
ID BIGINT NOT NULL PRIMARY KEY ,
VERSION BIGINT ,
NAME VARCHAR(45) ,
CREDIT DOUBLE PRECISION
);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (1, 0, 'customer1', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (2, 0, 'customer2', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (3, 0, 'customer3', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (4, 0, 'customer4', 100000);
CREATE TABLE PLAYERS (
PLAYER_ID CHAR(8) NOT NULL PRIMARY KEY,
LAST_NAME VARCHAR(35) NOT NULL,
FIRST_NAME VARCHAR(25) NOT NULL,
POS VARCHAR(10) ,
YEAR_OF_BIRTH BIGINT NOT NULL,
YEAR_DRAFTED BIGINT NOT NULL
);
CREATE TABLE GAMES (
PLAYER_ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
TEAM CHAR(3) NOT NULL,
WEEK BIGINT NOT NULL,
OPPONENT CHAR(3) ,
COMPLETES BIGINT ,
ATTEMPTS BIGINT ,
PASSING_YARDS BIGINT ,
PASSING_TD BIGINT ,
INTERCEPTIONS BIGINT ,
RUSHES BIGINT ,
RUSH_YARDS BIGINT ,
RECEPTIONS BIGINT ,
RECEPTIONS_YARDS BIGINT ,
TOTAL_TD BIGINT
);
CREATE TABLE PLAYER_SUMMARY (
ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
COMPLETES BIGINT NOT NULL ,
ATTEMPTS BIGINT NOT NULL ,
PASSING_YARDS BIGINT NOT NULL ,
PASSING_TD BIGINT NOT NULL ,
INTERCEPTIONS BIGINT NOT NULL ,
RUSHES BIGINT NOT NULL ,
RUSH_YARDS BIGINT NOT NULL ,
RECEPTIONS BIGINT NOT NULL ,
RECEPTIONS_YARDS BIGINT NOT NULL ,
TOTAL_TD BIGINT NOT NULL
);

86
spring-batch-samples/src/main/resources/business-schema-sybase.sql Normal file
View File

@@ -0,0 +1,86 @@
-- Autogenerated: do not edit this file
DROP TABLE BATCH_STAGING_SEQ ;
DROP TABLE TRADE_SEQ ;
DROP TABLE CUSTOMER_SEQ ;
DROP TABLE BATCH_STAGING ;
DROP TABLE TRADE ;
DROP TABLE CUSTOMER ;
DROP TABLE PLAYERS ;
DROP TABLE GAMES ;
DROP TABLE PLAYER_SUMMARY ;
-- Autogenerated: do not edit this file
CREATE TABLE CUSTOMER_SEQ (ID BIGINT IDENTITY);
CREATE TABLE BATCH_STAGING_SEQ (ID BIGINT IDENTITY);
CREATE TABLE TRADE_SEQ (ID BIGINT IDENTITY);
CREATE TABLE BATCH_STAGING (
ID BIGINT NOT NULL PRIMARY KEY ,
JOB_ID BIGINT NOT NULL,
VALUE IMAGE NOT NULL,
PROCESSED CHAR(1) NOT NULL
);
CREATE TABLE TRADE (
ID BIGINT NOT NULL PRIMARY KEY ,
VERSION BIGINT NULL,
ISIN VARCHAR(45) NOT NULL,
QUANTITY BIGINT NULL,
PRICE DOUBLE PRECISION NULL,
CUSTOMER VARCHAR(45) NULL
);
CREATE TABLE CUSTOMER (
ID BIGINT NOT NULL PRIMARY KEY ,
VERSION BIGINT NULL,
NAME VARCHAR(45) NULL,
CREDIT DOUBLE PRECISION NULL
);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (1, 0, 'customer1', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (2, 0, 'customer2', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (3, 0, 'customer3', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (4, 0, 'customer4', 100000);
CREATE TABLE PLAYERS (
PLAYER_ID CHAR(8) NOT NULL PRIMARY KEY,
LAST_NAME VARCHAR(35) NOT NULL,
FIRST_NAME VARCHAR(25) NOT NULL,
POS VARCHAR(10) NULL,
YEAR_OF_BIRTH BIGINT NOT NULL,
YEAR_DRAFTED BIGINT NOT NULL
);
CREATE TABLE GAMES (
PLAYER_ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
TEAM CHAR(3) NOT NULL,
WEEK BIGINT NOT NULL,
OPPONENT CHAR(3) NULL,
COMPLETES BIGINT NULL,
ATTEMPTS BIGINT NULL,
PASSING_YARDS BIGINT NULL,
PASSING_TD BIGINT NULL,
INTERCEPTIONS BIGINT NULL,
RUSHES BIGINT NULL,
RUSH_YARDS BIGINT NULL,
RECEPTIONS BIGINT NULL,
RECEPTIONS_YARDS BIGINT NULL,
TOTAL_TD BIGINT NULL
);
CREATE TABLE PLAYER_SUMMARY (
ID CHAR(8) NOT NULL,
YEAR_NO BIGINT NOT NULL,
COMPLETES BIGINT NOT NULL ,
ATTEMPTS BIGINT NOT NULL ,
PASSING_YARDS BIGINT NOT NULL ,
PASSING_TD BIGINT NOT NULL ,
INTERCEPTIONS BIGINT NOT NULL ,
RUSHES BIGINT NOT NULL ,
RUSH_YARDS BIGINT NOT NULL ,
RECEPTIONS BIGINT NOT NULL ,
RECEPTIONS_YARDS BIGINT NOT NULL ,
TOTAL_TD BIGINT NOT NULL
);

5
spring-batch-samples/src/main/sql/db2.properties
View File

@@ -1,7 +1,10 @@
platform=db2
# SQL language oddities
BIGINT = BIGINT
IDENTITY =
IDENTITY =
DOUBLE = DOUBLE PRECISION
BLOB = BLOB
TIMESTAMP = TIMESTAMP
VARCHAR = VARCHAR
# for generating drop statements...
SEQUENCE = SEQUENCE

5
spring-batch-samples/src/main/sql/derby.properties
View File

@@ -2,7 +2,10 @@ platform=db2
# SQL language oddities
BIGINT = BIGINT
IDENTITY =
GENERATED = GENERATED BY DEFAULT AS IDENTITY
GENERATED = GENERATED BY DEFAULT AS IDENTITY
DOUBLE = DOUBLE PRECISION
BLOB = BLOB
TIMESTAMP = TIMESTAMP
VARCHAR = VARCHAR
# for generating drop statements...
SEQUENCE = TABLE

3
spring-batch-samples/src/main/sql/hsqldb.properties
View File

@@ -3,6 +3,9 @@ platform=hsqldb
BIGINT = BIGINT
IDENTITY = IDENTITY
IFEXISTS = IF EXISTS
DOUBLE = DOUBLE PRECISION
BLOB = LONGVARBINARY
TIMESTAMP = TIMESTAMP
VARCHAR = VARCHAR
# for generating drop statements...
SEQUENCE = TABLE

70
spring-batch-samples/src/main/sql/init.sql.vpp
View File

@@ -5,58 +5,58 @@
#sequence( "TRADE_SEQ" )
CREATE TABLE BATCH_STAGING (
ID ${BIGINT} $!{IDENTITY} PRIMARY KEY $!{GENERATED},
ID ${BIGINT} $!{IDENTITY} NOT NULL PRIMARY KEY $!{GENERATED},
JOB_ID ${BIGINT} NOT NULL,
VALUE ${BLOB} NOT NULL,
PROCESSED CHAR(1) NOT NULL
);
CREATE TABLE TRADE (
ID ${BIGINT} $!{IDENTITY} PRIMARY KEY $!{GENERATED},
VERSION ${BIGINT},
ID ${BIGINT} $!{IDENTITY} NOT NULL PRIMARY KEY $!{GENERATED},
VERSION ${BIGINT} $!{NULL},
ISIN VARCHAR(45) NOT NULL,
QUANTITY ${BIGINT},
PRICE DOUBLE,
CUSTOMER VARCHAR(45)
QUANTITY ${BIGINT} $!{NULL},
PRICE ${DOUBLE} $!{NULL},
CUSTOMER ${VARCHAR}(45) $!{NULL}
);
CREATE TABLE CUSTOMER (
ID ${BIGINT} $!{IDENTITY} PRIMARY KEY $!{GENERATED},
VERSION ${BIGINT},
NAME VARCHAR(45),
CREDIT DOUBLE
ID ${BIGINT} $!{IDENTITY} NOT NULL PRIMARY KEY $!{GENERATED},
VERSION ${BIGINT} $!{NULL},
NAME ${VARCHAR}(45) $!{NULL},
CREDIT ${DOUBLE} $!{NULL}
);
INSERT INTO customer (id, version, name, credit) VALUES (1, 0, 'customer1', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (2, 0, 'customer2', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (3, 0, 'customer3', 100000);
INSERT INTO customer (id, version, name, credit) VALUES (4, 0, 'customer4', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (1, 0, 'customer1', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (2, 0, 'customer2', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (3, 0, 'customer3', 100000);
INSERT INTO CUSTOMER (ID, VERSION, NAME, CREDIT) VALUES (4, 0, 'customer4', 100000);
CREATE TABLE PLAYERS (
PLAYER_ID char(8) NOT NULL PRIMARY KEY,
LAST_NAME varchar(35) not null,
FIRST_NAME varchar(25) not null,
POS varchar(10),
YEAR_OF_BIRTH ${BIGINT} not null,
YEAR_DRAFTED ${BIGINT} not null
PLAYER_ID CHAR(8) NOT NULL PRIMARY KEY,
LAST_NAME ${VARCHAR}(35) NOT NULL,
FIRST_NAME ${VARCHAR}(25) NOT NULL,
POS ${VARCHAR}(10) $!{NULL},
YEAR_OF_BIRTH ${BIGINT} NOT NULL,
YEAR_DRAFTED ${BIGINT} NOT NULL
);
CREATE TABLE GAMES (
PLAYER_ID char(8) not null,
YEAR_NO ${BIGINT} not null,
TEAM char(3) not null,
WEEK ${BIGINT} not null,
OPPONENT char(3),
COMPLETES ${BIGINT},
ATTEMPTS ${BIGINT},
PASSING_YARDS ${BIGINT},
PASSING_TD ${BIGINT},
INTERCEPTIONS ${BIGINT},
RUSHES ${BIGINT},
RUSH_YARDS ${BIGINT},
RECEPTIONS ${BIGINT},
RECEPTIONS_YARDS ${BIGINT},
TOTAL_TD ${BIGINT}
PLAYER_ID CHAR(8) NOT NULL,
YEAR_NO ${BIGINT} NOT NULL,
TEAM CHAR(3) NOT NULL,
WEEK ${BIGINT} NOT NULL,
OPPONENT CHAR(3) $!{NULL},
COMPLETES ${BIGINT} $!{NULL},
ATTEMPTS ${BIGINT} $!{NULL},
PASSING_YARDS ${BIGINT} $!{NULL},
PASSING_TD ${BIGINT} $!{NULL},
INTERCEPTIONS ${BIGINT} $!{NULL},
RUSHES ${BIGINT} $!{NULL},
RUSH_YARDS ${BIGINT} $!{NULL},
RECEPTIONS ${BIGINT} $!{NULL},
RECEPTIONS_YARDS ${BIGINT} $!{NULL},
TOTAL_TD ${BIGINT} $!{NULL}
);
CREATE TABLE PLAYER_SUMMARY (

6
spring-batch-samples/src/main/sql/mysql.properties
View File

@@ -1,9 +1,13 @@
platform=oracle10g
# SQL language oddities
BIGINT = BIGINT
IDENTITY = unsigned
IDENTITY =
GENERATED =
VOODOO = type=InnoDB
IFEXISTSBEFORE = IF EXISTS
DOUBLE = DOUBLE PRECISION
BLOB = BLOB
TIMESTAMP = DATETIME
VARCHAR = VARCHAR
# for generating drop statements...
SEQUENCE = TABLE

3
spring-batch-samples/src/main/sql/oracle10g.properties
View File

@@ -3,6 +3,9 @@ platform=oracle10g
BIGINT = NUMBER(38)
IDENTITY =
GENERATED =
DOUBLE = NUMBER
BLOB = BLOB
TIMESTAMP = TIMESTAMP
VARCHAR = VARCHAR2
# for generating drop statements...
SEQUENCE = SEQUENCE

5
spring-batch-samples/src/main/sql/postgresql.properties
View File

@@ -3,6 +3,9 @@ platform=postgresql
BIGINT = BIGINT
IDENTITY =
GENERATED =
BLOB = BYTEA
DOUBLE = DOUBLE PRECISION
BLOB = BYTEA
TIMESTAMP = TIMESTAMP
VARCHAR = VARCHAR
# for generating drop statements...
SEQUENCE = SEQUENCE

10
spring-batch-samples/src/main/sql/sqlserver.properties Normal file
View File

@@ -0,0 +1,10 @@
# SQL language oddities
BIGINT = BIGINT
IDENTITY =
GENERATED =
DOUBLE = DOUBLE PRECISION
BLOB = IMAGE
TIMESTAMP = DATETIME
VARCHAR = VARCHAR
# for generating drop statements...
SEQUENCE = TABLE

3
spring-batch-samples/src/main/sql/sqlserver.vpp Normal file
View File

@@ -0,0 +1,3 @@
#macro (sequence $name)CREATE TABLE ${name} (ID BIGINT IDENTITY);
#end
#macro (notnull $name $type)ALTER COLUMN ${name} ${type} NOT NULL#end

11
spring-batch-samples/src/main/sql/sybase.properties Normal file
View File

@@ -0,0 +1,11 @@
# SQL language oddities
BIGINT = BIGINT
IDENTITY =
GENERATED =
DOUBLE = DOUBLE PRECISION
BLOB = IMAGE
TIMESTAMP = DATETIME
VARCHAR = VARCHAR
NULL = NULL
# for generating drop statements...
SEQUENCE = TABLE

3
spring-batch-samples/src/main/sql/sybase.vpp Normal file
View File

@@ -0,0 +1,3 @@
#macro (sequence $name)CREATE TABLE ${name} (ID BIGINT IDENTITY);
#end
#macro (notnull $name $type)ALTER COLUMN ${name} ${type} NOT NULL#end

13
src/.project
View File

@@ -1,7 +1,18 @@
<?xml version="1.0" encoding="UTF-8"?>
<projectDescription>
<name>src</name>
<name>spring-batch</name>
<comment></comment>
<projects>
</projects>
<buildSpec>
</buildSpec>
<natures>
</natures>
<linkedResources>
<link>
<name>pom.xml</name>
<type>1</type>
<locationURI>SPRING_BATCH/pom.xml</locationURI>
</link>
</linkedResources>
</projectDescription>

10
src/site/apt/articles.apt
View File

@@ -16,3 +16,13 @@ Spring Batch In the Media
* http://blog.decaresystems.ie/index.php/2007/04/12/spring-batch/
* http://www.itweek.co.uk/itweek/news/2189502/accenture-launches-batch
* http://www.theserverside.com/tt/articles/article.tss?l=SpringBatchOverview
* http://www.springframework.org/node/698
* http://www.infoq.com/interviews/johnson-spring-portfolio
* http://www.infoq.com/news/2008/06/spring-batch
* http://blog.springsource.com/main/2008/05/30/running-a-spring-batch-job-in-the-springsource-aplication-platform

5
src/site/apt/building.apt
View File

@@ -70,9 +70,8 @@ $ mvn test -DforkMode=never -Dtest=FootballJobFunctionalTests -Dplayer.file.name
and feeds changes into other projects in your workspace. It is not
recommended to use the Maven Eclipse plugin (<<<mvn
eclipse:eclipse>>>) because it cannot track dependencies across the
Eclipse workspace. It will also create conflicting Eclipse
meta-data every time you run it, which will interfere with the meta
data under source control.
Eclipse workspace. It will also create Eclipse meta-data every time
you run it, conflicting with the version under source control.
* Dependencies

3
src/site/apt/cases/index.apt
View File

@@ -29,7 +29,8 @@ Use Cases for Spring Batch
* {{{parallel.html}Massively Parallel Batch Processing}}. Spring
Batch 1.0 does not contain any implementations of this use case,
but it is quite feasible to implement them using the framework as
a starting point.
a starting point. 1.1 has some prototype code under the Integration
module.
* {{{restart.html}Manual Restart After Failure}}

25
src/site/apt/cases/parallel.apt
View File

@@ -149,7 +149,7 @@ Use Case: Massively Parallel Batch Processing
Consider two examples: a file input source and a JDBC (SQL query)
based input source. Each provides its own challenges.
*** File Data Source Partitioning
*** File Data Source
* If each node reads the whole file there could be a performance
issue. They would all need to have instructions about which lines
@@ -163,16 +163,15 @@ Use Case: Massively Parallel Batch Processing
* But if each input record can span a variable number of lines (not
that unlikely in practice), then we can't use line numbers
* Maybe the best solution is to have a single process parsing the
file and sending it to a message queue, either formally using a
messaging infrastructure or informally using some sort of
roll-your-own approach. The integration pattern could then be a
* Maybe the best solution is to use middleware anyway. A single
process parses the file and sends it to a message queue, item by
item (or chunk by chunk). The integration pattern could then be a
simple Eager Consumer, assuming that all records are processed
independently. The messaging semantics would simply have to ensure
that a consumer can roll back and return the input records to a
queue for another consumer to retry.
For large batches a real messaging infrastructure (JMS etc.) with
* For large batches a real messaging infrastructure (JMS etc.) with
guaranteed delivery would be a benefit, but might be seen as
overkill for a system that didn't otherwise require it. In this
case we could imagine the partitioning process being one of simply
@@ -182,19 +181,15 @@ Use Case: Massively Parallel Batch Processing
* What would parallel processing look like to the client? We can
make it completely transparent if we assume that the client only
ever implements <<<ItemProvider>>> and <<<ItemProcessor>>>. The
client code is unaware of the partitioning of its data source:
+---
batchTemplate.iterate(new ItemProviderRepeatCallback(provider, processor));
+---
ever implements <<<ItemReader>>> and <<<ItemWriter>>>. The
client code is unaware of the partitioning of its data source.
* Parallelisation could also take place at the level of the
<<<ItemProvider>>> - we could proxy the data provider and wrap it in
<<<ItemReader>>> - we could proxy the data provider and wrap it in
a partitioning proxy:
+---
<bean id="itemProvider"
<bean id="itemReader"
class="org.springframework.aop.framework.ProxyFactoryBean">
<property name="target">
@@ -260,7 +255,7 @@ batchTemplate.iterate(new ItemProviderRepeatCallback(provider, processor));
+---
<bean id="inputSource"
class="test.input.SqlInputDataProvider">
class="test.input.SqlInputItemReader">
<property name="query">
<value>SELECT * from T_INPUT</value>