Class JavaBatchSchemaGenerator
- java.lang.Object
-
- org.linuxforhealth.fhir.schema.control.JavaBatchSchemaGenerator
-
public class JavaBatchSchemaGenerator extends java.lang.Object
Encapsulates the generation of the Liberty Java Batch schema artifacts. This sql is generated using the Open Liberty tool ddlGenwlp/bin/ddlGen generate fhir-server
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
AMCNAME
static java.lang.String
BATCH_GROUP
static java.lang.String
BATCH_SCHEMANAME
static java.lang.String
BATCHSTATUS
static java.lang.String
CHECKPOINTDATA
static java.lang.String
CREATETIME
static java.lang.String
ENDTIME
static java.lang.String
EXECNUM
static java.lang.String
EXITSTATUS
static java.lang.String
FK_JOBEXECID
static java.lang.String
FK_JOBEXECUTIONID
static java.lang.String
FK_JOBINSTANCEID
static java.lang.String
FK_LATEST_STEPEXECID
static java.lang.String
FK_STEPEXECUTIONID
static java.lang.String
FK_TOPLVL_STEPEXECID
static java.lang.String
GROUPASSOCIATION_TABLE
static java.lang.String
GROUPNAMES
static java.lang.String
INSTANCESTATE
static java.lang.String
INTERNALSTATE
static java.lang.String
INTERNALSTATUS
static java.lang.String
ISPARTITIONEDSTEP
static java.lang.String
JOBEXECID
static java.lang.String
JOBEXECUTION_TABLE
static java.lang.String
JOBINSTANCE_TABLE
static java.lang.String
JOBINSTANCEID
static java.lang.String
JOBNAME
static java.lang.String
JOBPARAMETER_TABLE
static java.lang.String
JOBPARAMETERS
static java.lang.String
JOBXML
static java.lang.String
JOBXMLNAME
static java.lang.String
JP_FKJOBEXECID_IX
static java.lang.String
LASTUPDATED
static java.lang.String
LOGPATH
static java.lang.String
M_COMMIT
static java.lang.String
M_FILTER
static java.lang.String
M_PROCESSSKIP
static java.lang.String
M_READ
static java.lang.String
M_READSKIP
static java.lang.String
M_ROLLBACK
static java.lang.String
M_WRITE
static java.lang.String
M_WRITESKIP
static java.lang.String
NAME
static java.lang.Boolean
NOT_NULL
static java.lang.Boolean
NULL
static java.lang.String
NUMEXECS
static java.lang.String
PARTITIONED
static java.lang.String
PARTITIONPLANSIZE
static java.lang.String
PARTNUM
static java.lang.String
REMOTABLEPARTITION_TABLE
static java.lang.String
RESTARTON
static java.lang.String
RESTURL
static java.lang.String
SERVERID
static java.lang.String
STARTCOUNT
static java.lang.String
STARTTIME
static java.lang.String
STEPEXECID
static java.lang.String
STEPNAME
static java.lang.String
STEPTHREADEXECUTION_TABLE
static java.lang.String
STEPTHREADINSTANCE_TABLE
static java.lang.String
SUBMITTER
static java.lang.String
THREADTYPE
static java.lang.String
UPDATETIME
static java.lang.String
USERDATA
static java.lang.String
VALUE
-
Constructor Summary
Constructors Constructor Description JavaBatchSchemaGenerator(java.lang.String schemaName)
Configures the destination schema for JavaBatch
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addGroupAssociationTable(PhysicalDataModel model)
Adds the group association table with the following values:CREATE TABLE FHIR_BATCH.GROUPASSOCIATION ( FK_JOBINSTANCEID BIGINT, GROUPNAMES VARCHAR(255)) CREATE INDEX FHIR_BATCH.GA_FKINSTANCEID_IX ON FHIR_BATCH.GROUPASSOCIATION (FK_JOBINSTANCEID) ALTER TABLE FHIR_BATCH.GROUPASSOCIATION ADD CONSTRAINT GRPSSCTNFKJBNSTNCD FOREIGN KEY (FK_JOBINSTANCEID) REFERENCES FHIR_BATCH.JOBINSTANCE (JOBINSTANCEID)
void
addJobExecutionTable(PhysicalDataModel model)
Adds the Job Execution table with the following values:CREATE TABLE FHIR_BATCH.JOBEXECUTION( JOBEXECID BIGINT GENERATED BY DEFAULT AS IDENTITY, BATCHSTATUS INT NOT NULL, CREATETIME TIMESTAMP NOT NULL, ENDTIME TIMESTAMP, EXECNUM INT NOT NULL, EXITSTATUS VARCHAR(2048 OCTETS) NOT NULL, JOBPARAMETERS BLOB(2147483647) INLINE LENGTH 10240, UPDATETIME TIMESTAMP, LOGPATH VARCHAR(512 OCTETS), RESTURL VARCHAR(512 OCTETS), SERVERID VARCHAR(256 OCTETS), STARTTIME TIMESTAMP, FK_JOBINSTANCEID BIGINT NOT NULL, CONSTRAINT PK_JOBEXECUTION PRIMARY KEY (JOBEXECID)) CREATE INDEX FHIR_BATCH.JE_FKINSTANCEID_IX ON FHIR_BATCH.JOBEXECUTION (FK_JOBINSTANCEID) ALTER TABLE FHIR_BATCH.JOBEXECUTION ADD CONSTRAINT JBXCTNFKJBNSTNCEID FOREIGN KEY (FK_JOBINSTANCEID) REFERENCES FHIR_BATCH.JOBINSTANCE (JOBINSTANCEID)
void
addJobInstanceTable(PhysicalDataModel model)
Adds the Job Instance table with the following values:CREATE TABLE FHIR_BATCH.JOBINSTANCE( JOBINSTANCEID BIGINT GENERATED BY DEFAULT AS IDENTITY, AMCNAME VARCHAR(512 OCTETS), BATCHSTATUS INT NOT NULL, CREATETIME TIMESTAMP NOT NULL, EXITSTATUS VARCHAR(2048 OCTETS), INSTANCESTATE INT NOT NULL, JOBNAME VARCHAR(256 OCTETS), JOBXMLNAME VARCHAR(128 OCTETS), JOBXML BLOB(2147483647) INLINE LENGTH 10240, NUMEXECS INT NOT NULL, RESTARTON VARCHAR(128 OCTETS), SUBMITTER VARCHAR(256 OCTETS), UPDATETIME TIMESTAMP, CONSTRAINT PK_JOBINSTANCEID PRIMARY KEY (JOBINSTANCEID) )
void
addJobParameterTable(PhysicalDataModel model)
Adds the job table with the following values:CREATE TABLE FHIR_BATCH.JOBPARAMETER ( NAME VARCHAR(255), VALUE VARCHAR(255), FK_JOBEXECID BIGINT) CREATE INDEX FHIR_BATCH.JP_FKJOBEXECID_IX ON FHIR_BATCH.JOBPARAMETER (FK_JOBEXECID) ALTER TABLE FHIR_BATCH.JOBPARAMETER ADD CONSTRAINT JBPRMETERFKJBXECID FOREIGN KEY (FK_JOBEXECID) REFERENCES FHIR_BATCH.JOBEXECUTION (JOBEXECID)
void
addRemotablePartitionTable(PhysicalDataModel model)
Adds the Remotable Partition table with the following values:CREATE TABLE FHIR_BATCH.REMOTABLEPARTITION ( PARTNUM INTEGER NOT NULL, STEPNAME VARCHAR(255) NOT NULL, INTERNALSTATE INTEGER, LASTUPDATED TIMESTAMP, LOGPATH VARCHAR(512), RESTURL VARCHAR(512), SERVERID VARCHAR(256), FK_JOBEXECUTIONID BIGINT NOT NULL, FK_STEPEXECUTIONID BIGINT, PRIMARY KEY (PARTNUM, STEPNAME, FK_JOBEXECUTIONID)) ALTER TABLE FHIR_BATCH.REMOTABLEPARTITION ADD CONSTRAINT RMOTABLEPARTITION0 UNIQUE (FK_JOBEXECUTIONID, STEPNAME, PARTNUM) ALTER TABLE FHIR_BATCH.REMOTABLEPARTITION ADD CONSTRAINT RMTBLPRTFKSTPXCTND FOREIGN KEY (FK_STEPEXECUTIONID) REFERENCES FHIR_BATCH.STEPTHREADEXECUTION (STEPEXECID) ALTER TABLE FHIR_BATCH.REMOTABLEPARTITION ADD CONSTRAINT RMTBLPRTTFKJBXCTND FOREIGN KEY (FK_JOBEXECUTIONID) REFERENCES FHIR_BATCH.JOBEXECUTION (JOBEXECID)
void
addStepThreadExecutionTable(PhysicalDataModel model)
Adds the Step Thread Execution table with the following values:CREATE TABLE FHIR_BATCH.STEPTHREADEXECUTION( STEPEXECID BIGINT GENERATED BY DEFAULT AS IDENTITY, THREADTYPE VARCHAR(31 OCTETS), BATCHSTATUS INT NOT NULL, M_COMMIT BIGINT NOT NULL, ENDTIME TIMESTAMP, EXITSTATUS VARCHAR(512 OCTETS), M_FILTER BIGINT NOT NULL, INTERNAL_STATUS INT NOT NULL, PARTNUM INT NOT NULL, USERDATA BLOB(2147483647) INLINE LENGTH 10240 NOT NULL, M_PROCESSSKIP BIGINT NOT NULL, M_READ BIGINT NOT NULL, M_READSKIP BIGINT NOT NULL, M_ROLLBACK BIGINT NOT NULL, STARTTIME TIMESTAMP, STEPNAME VARCHAR(128 OCTETS) NOT NULL, M_WRITE BIGINT NOT NULL, M_WRITESKIP BIGINT NOT NULL, FK_JOBEXECID BIGINT NOT NULL, FK_TOPLVL_STEPEXECID BIGINT NOT NULL, ISPARTITIONEDSTEP SMALLINT, CONSTRAINT PK_STEPTHREADEXECUTION PRIMARY KEY (STEPEXECID)) CREATE INDEX FHIR_BATCH.STE_FKJOBEXECID_IX ON FHIR_BATCH.STEPTHREADEXECUTION (FK_JOBEXECID) CREATE INDEX FHIR_BATCH.STE_FKTLSTEPEID_IX ON FHIR_BATCH.STEPTHREADEXECUTION (FK_TOPLVL_STEPEXECID) ALTER TABLE FHIR_BATCH.STEPTHREADEXECUTION ADD CONSTRAINT STPTHRADEXECUTION0 UNIQUE (FK_JOBEXECID, STEPNAME, PARTNUM) ALTER TABLE FHIR_BATCH.STEPTHREADEXECUTION ADD CONSTRAINT STPTHFKTPLVLSTPXCD FOREIGN KEY (FK_TOPLVL_STEPEXECID) REFERENCES FHIR_BATCH.STEPTHREADEXECUTION (STEPEXECID) ALTER TABLE FHIR_BATCH.STEPTHREADEXECUTION ADD CONSTRAINT STPTHRDXCTNFKJBXCD FOREIGN KEY (FK_JOBEXECID) REFERENCES FHIR_BATCH.JOBEXECUTION (JOBEXECID)
void
addStepThreadInstanceTable(PhysicalDataModel model)
Adds the Step Thread Instance table with the following values:CREATE TABLE FHIR_BATCH.STEPTHREADINSTANCE( PARTNUM BIGINT NOT NULL, STEPNAME VARCHAR(128 OCTETS) NOT NULL, THREADTYPE VARCHAR(31 OCTETS), CHECKPOINTDATA BLOB(2147483647) INLINE LENGTH 10240, FK_JOBINSTANCEID BIGINT NOT NULL, FK_LATEST_STEPEXECID BIGINT NOT NULL, PARTITIONED SMALLINT NOT NULL, PARTITIONPLANSIZE INT, STARTCOUNT INT, CONSTRAINT PK_STEPTHREADINSTANCE PRIMARY KEY (PARTNUM, STEPNAME, FK_JOBINSTANCEID)) CREATE INDEX FHIR_BATCH.STI_FKINSTANCEID_IX ON FHIR_BATCH.STEPTHREADINSTANCE (FK_JOBINSTANCEID) CREATE INDEX FHIR_BATCH.STI_FKLATEST_SEI_IX ON FHIR_BATCH.STEPTHREADINSTANCE (FK_LATEST_STEPEXECID) ALTER TABLE FHIR_BATCH.STEPTHREADINSTANCE ADD CONSTRAINT STPTHRFKLTSTSTPXCD FOREIGN KEY (FK_LATEST_STEPEXECID) REFERENCES FHIR_BATCH.STEPTHREADEXECUTION (STEPEXECID) ALTER TABLE FHIR_BATCH.STEPTHREADINSTANCE ADD CONSTRAINT STPTHRDNFKJBNSTNCD FOREIGN KEY (FK_JOBINSTANCEID) REFERENCES FHIR_BATCH.JOBINSTANCE (JOBINSTANCEID)
void
buildJavaBatchSchema(PhysicalDataModel model)
Create the tables needed by the Liberty JBatch databaseStoreprotected java.util.List<GroupPrivilege>
generateGroupPrivilege()
-
-
-
Field Detail
-
BATCH_GROUP
public static final java.lang.String BATCH_GROUP
- See Also:
- Constant Field Values
-
BATCH_SCHEMANAME
public static final java.lang.String BATCH_SCHEMANAME
- See Also:
- Constant Field Values
-
NOT_NULL
public static final java.lang.Boolean NOT_NULL
-
NULL
public static final java.lang.Boolean NULL
-
JOBPARAMETER_TABLE
public static final java.lang.String JOBPARAMETER_TABLE
- See Also:
- Constant Field Values
-
NAME
public static final java.lang.String NAME
- See Also:
- Constant Field Values
-
VALUE
public static final java.lang.String VALUE
- See Also:
- Constant Field Values
-
FK_JOBEXECID
public static final java.lang.String FK_JOBEXECID
- See Also:
- Constant Field Values
-
JP_FKJOBEXECID_IX
public static final java.lang.String JP_FKJOBEXECID_IX
- See Also:
- Constant Field Values
-
JOBEXECUTION_TABLE
public static final java.lang.String JOBEXECUTION_TABLE
- See Also:
- Constant Field Values
-
JOBEXECID
public static final java.lang.String JOBEXECID
- See Also:
- Constant Field Values
-
ENDTIME
public static final java.lang.String ENDTIME
- See Also:
- Constant Field Values
-
EXECNUM
public static final java.lang.String EXECNUM
- See Also:
- Constant Field Values
-
JOBPARAMETERS
public static final java.lang.String JOBPARAMETERS
- See Also:
- Constant Field Values
-
LOGPATH
public static final java.lang.String LOGPATH
- See Also:
- Constant Field Values
-
RESTURL
public static final java.lang.String RESTURL
- See Also:
- Constant Field Values
-
SERVERID
public static final java.lang.String SERVERID
- See Also:
- Constant Field Values
-
STARTTIME
public static final java.lang.String STARTTIME
- See Also:
- Constant Field Values
-
GROUPASSOCIATION_TABLE
public static final java.lang.String GROUPASSOCIATION_TABLE
- See Also:
- Constant Field Values
-
FK_JOBINSTANCEID
public static final java.lang.String FK_JOBINSTANCEID
- See Also:
- Constant Field Values
-
GROUPNAMES
public static final java.lang.String GROUPNAMES
- See Also:
- Constant Field Values
-
JOBINSTANCE_TABLE
public static final java.lang.String JOBINSTANCE_TABLE
- See Also:
- Constant Field Values
-
JOBINSTANCEID
public static final java.lang.String JOBINSTANCEID
- See Also:
- Constant Field Values
-
AMCNAME
public static final java.lang.String AMCNAME
- See Also:
- Constant Field Values
-
BATCHSTATUS
public static final java.lang.String BATCHSTATUS
- See Also:
- Constant Field Values
-
CREATETIME
public static final java.lang.String CREATETIME
- See Also:
- Constant Field Values
-
EXITSTATUS
public static final java.lang.String EXITSTATUS
- See Also:
- Constant Field Values
-
INSTANCESTATE
public static final java.lang.String INSTANCESTATE
- See Also:
- Constant Field Values
-
JOBNAME
public static final java.lang.String JOBNAME
- See Also:
- Constant Field Values
-
JOBXMLNAME
public static final java.lang.String JOBXMLNAME
- See Also:
- Constant Field Values
-
JOBXML
public static final java.lang.String JOBXML
- See Also:
- Constant Field Values
-
NUMEXECS
public static final java.lang.String NUMEXECS
- See Also:
- Constant Field Values
-
RESTARTON
public static final java.lang.String RESTARTON
- See Also:
- Constant Field Values
-
SUBMITTER
public static final java.lang.String SUBMITTER
- See Also:
- Constant Field Values
-
UPDATETIME
public static final java.lang.String UPDATETIME
- See Also:
- Constant Field Values
-
STEPTHREADINSTANCE_TABLE
public static final java.lang.String STEPTHREADINSTANCE_TABLE
- See Also:
- Constant Field Values
-
PARTNUM
public static final java.lang.String PARTNUM
- See Also:
- Constant Field Values
-
STEPNAME
public static final java.lang.String STEPNAME
- See Also:
- Constant Field Values
-
THREADTYPE
public static final java.lang.String THREADTYPE
- See Also:
- Constant Field Values
-
CHECKPOINTDATA
public static final java.lang.String CHECKPOINTDATA
- See Also:
- Constant Field Values
-
PARTITIONED
public static final java.lang.String PARTITIONED
- See Also:
- Constant Field Values
-
PARTITIONPLANSIZE
public static final java.lang.String PARTITIONPLANSIZE
- See Also:
- Constant Field Values
-
STARTCOUNT
public static final java.lang.String STARTCOUNT
- See Also:
- Constant Field Values
-
FK_LATEST_STEPEXECID
public static final java.lang.String FK_LATEST_STEPEXECID
- See Also:
- Constant Field Values
-
STEPTHREADEXECUTION_TABLE
public static final java.lang.String STEPTHREADEXECUTION_TABLE
- See Also:
- Constant Field Values
-
STEPEXECID
public static final java.lang.String STEPEXECID
- See Also:
- Constant Field Values
-
REMOTABLEPARTITION_TABLE
public static final java.lang.String REMOTABLEPARTITION_TABLE
- See Also:
- Constant Field Values
-
INTERNALSTATE
public static final java.lang.String INTERNALSTATE
- See Also:
- Constant Field Values
-
LASTUPDATED
public static final java.lang.String LASTUPDATED
- See Also:
- Constant Field Values
-
FK_JOBEXECUTIONID
public static final java.lang.String FK_JOBEXECUTIONID
- See Also:
- Constant Field Values
-
FK_STEPEXECUTIONID
public static final java.lang.String FK_STEPEXECUTIONID
- See Also:
- Constant Field Values
-
M_COMMIT
public static final java.lang.String M_COMMIT
- See Also:
- Constant Field Values
-
M_FILTER
public static final java.lang.String M_FILTER
- See Also:
- Constant Field Values
-
INTERNALSTATUS
public static final java.lang.String INTERNALSTATUS
- See Also:
- Constant Field Values
-
USERDATA
public static final java.lang.String USERDATA
- See Also:
- Constant Field Values
-
M_PROCESSSKIP
public static final java.lang.String M_PROCESSSKIP
- See Also:
- Constant Field Values
-
M_READ
public static final java.lang.String M_READ
- See Also:
- Constant Field Values
-
M_READSKIP
public static final java.lang.String M_READSKIP
- See Also:
- Constant Field Values
-
M_ROLLBACK
public static final java.lang.String M_ROLLBACK
- See Also:
- Constant Field Values
-
M_WRITE
public static final java.lang.String M_WRITE
- See Also:
- Constant Field Values
-
M_WRITESKIP
public static final java.lang.String M_WRITESKIP
- See Also:
- Constant Field Values
-
ISPARTITIONEDSTEP
public static final java.lang.String ISPARTITIONEDSTEP
- See Also:
- Constant Field Values
-
FK_TOPLVL_STEPEXECID
public static final java.lang.String FK_TOPLVL_STEPEXECID
- See Also:
- Constant Field Values
-
-
Method Detail
-
buildJavaBatchSchema
public void buildJavaBatchSchema(PhysicalDataModel model)
Create the tables needed by the Liberty JBatch databaseStore- Parameters:
model
-
-
generateGroupPrivilege
protected java.util.List<GroupPrivilege> generateGroupPrivilege()
-
addJobParameterTable
public void addJobParameterTable(PhysicalDataModel model)
Adds the job table with the following values:CREATE TABLE FHIR_BATCH.JOBPARAMETER ( NAME VARCHAR(255), VALUE VARCHAR(255), FK_JOBEXECID BIGINT) CREATE INDEX FHIR_BATCH.JP_FKJOBEXECID_IX ON FHIR_BATCH.JOBPARAMETER (FK_JOBEXECID) ALTER TABLE FHIR_BATCH.JOBPARAMETER ADD CONSTRAINT JBPRMETERFKJBXECID FOREIGN KEY (FK_JOBEXECID) REFERENCES FHIR_BATCH.JOBEXECUTION (JOBEXECID)
- Parameters:
model
-
-
addGroupAssociationTable
public void addGroupAssociationTable(PhysicalDataModel model)
Adds the group association table with the following values:CREATE TABLE FHIR_BATCH.GROUPASSOCIATION ( FK_JOBINSTANCEID BIGINT, GROUPNAMES VARCHAR(255)) CREATE INDEX FHIR_BATCH.GA_FKINSTANCEID_IX ON FHIR_BATCH.GROUPASSOCIATION (FK_JOBINSTANCEID) ALTER TABLE FHIR_BATCH.GROUPASSOCIATION ADD CONSTRAINT GRPSSCTNFKJBNSTNCD FOREIGN KEY (FK_JOBINSTANCEID) REFERENCES FHIR_BATCH.JOBINSTANCE (JOBINSTANCEID)
- Parameters:
model
-
-
addStepThreadExecutionTable
public void addStepThreadExecutionTable(PhysicalDataModel model)
Adds the Step Thread Execution table with the following values:CREATE TABLE FHIR_BATCH.STEPTHREADEXECUTION( STEPEXECID BIGINT GENERATED BY DEFAULT AS IDENTITY, THREADTYPE VARCHAR(31 OCTETS), BATCHSTATUS INT NOT NULL, M_COMMIT BIGINT NOT NULL, ENDTIME TIMESTAMP, EXITSTATUS VARCHAR(512 OCTETS), M_FILTER BIGINT NOT NULL, INTERNAL_STATUS INT NOT NULL, PARTNUM INT NOT NULL, USERDATA BLOB(2147483647) INLINE LENGTH 10240 NOT NULL, M_PROCESSSKIP BIGINT NOT NULL, M_READ BIGINT NOT NULL, M_READSKIP BIGINT NOT NULL, M_ROLLBACK BIGINT NOT NULL, STARTTIME TIMESTAMP, STEPNAME VARCHAR(128 OCTETS) NOT NULL, M_WRITE BIGINT NOT NULL, M_WRITESKIP BIGINT NOT NULL, FK_JOBEXECID BIGINT NOT NULL, FK_TOPLVL_STEPEXECID BIGINT NOT NULL, ISPARTITIONEDSTEP SMALLINT, CONSTRAINT PK_STEPTHREADEXECUTION PRIMARY KEY (STEPEXECID)) CREATE INDEX FHIR_BATCH.STE_FKJOBEXECID_IX ON FHIR_BATCH.STEPTHREADEXECUTION (FK_JOBEXECID) CREATE INDEX FHIR_BATCH.STE_FKTLSTEPEID_IX ON FHIR_BATCH.STEPTHREADEXECUTION (FK_TOPLVL_STEPEXECID) ALTER TABLE FHIR_BATCH.STEPTHREADEXECUTION ADD CONSTRAINT STPTHRADEXECUTION0 UNIQUE (FK_JOBEXECID, STEPNAME, PARTNUM) ALTER TABLE FHIR_BATCH.STEPTHREADEXECUTION ADD CONSTRAINT STPTHFKTPLVLSTPXCD FOREIGN KEY (FK_TOPLVL_STEPEXECID) REFERENCES FHIR_BATCH.STEPTHREADEXECUTION (STEPEXECID) ALTER TABLE FHIR_BATCH.STEPTHREADEXECUTION ADD CONSTRAINT STPTHRDXCTNFKJBXCD FOREIGN KEY (FK_JOBEXECID) REFERENCES FHIR_BATCH.JOBEXECUTION (JOBEXECID)
- Parameters:
model
-
-
addRemotablePartitionTable
public void addRemotablePartitionTable(PhysicalDataModel model)
Adds the Remotable Partition table with the following values:CREATE TABLE FHIR_BATCH.REMOTABLEPARTITION ( PARTNUM INTEGER NOT NULL, STEPNAME VARCHAR(255) NOT NULL, INTERNALSTATE INTEGER, LASTUPDATED TIMESTAMP, LOGPATH VARCHAR(512), RESTURL VARCHAR(512), SERVERID VARCHAR(256), FK_JOBEXECUTIONID BIGINT NOT NULL, FK_STEPEXECUTIONID BIGINT, PRIMARY KEY (PARTNUM, STEPNAME, FK_JOBEXECUTIONID)) ALTER TABLE FHIR_BATCH.REMOTABLEPARTITION ADD CONSTRAINT RMOTABLEPARTITION0 UNIQUE (FK_JOBEXECUTIONID, STEPNAME, PARTNUM) ALTER TABLE FHIR_BATCH.REMOTABLEPARTITION ADD CONSTRAINT RMTBLPRTFKSTPXCTND FOREIGN KEY (FK_STEPEXECUTIONID) REFERENCES FHIR_BATCH.STEPTHREADEXECUTION (STEPEXECID) ALTER TABLE FHIR_BATCH.REMOTABLEPARTITION ADD CONSTRAINT RMTBLPRTTFKJBXCTND FOREIGN KEY (FK_JOBEXECUTIONID) REFERENCES FHIR_BATCH.JOBEXECUTION (JOBEXECID)
- Parameters:
model
-
-
addJobExecutionTable
public void addJobExecutionTable(PhysicalDataModel model)
Adds the Job Execution table with the following values:CREATE TABLE FHIR_BATCH.JOBEXECUTION( JOBEXECID BIGINT GENERATED BY DEFAULT AS IDENTITY, BATCHSTATUS INT NOT NULL, CREATETIME TIMESTAMP NOT NULL, ENDTIME TIMESTAMP, EXECNUM INT NOT NULL, EXITSTATUS VARCHAR(2048 OCTETS) NOT NULL, JOBPARAMETERS BLOB(2147483647) INLINE LENGTH 10240, UPDATETIME TIMESTAMP, LOGPATH VARCHAR(512 OCTETS), RESTURL VARCHAR(512 OCTETS), SERVERID VARCHAR(256 OCTETS), STARTTIME TIMESTAMP, FK_JOBINSTANCEID BIGINT NOT NULL, CONSTRAINT PK_JOBEXECUTION PRIMARY KEY (JOBEXECID)) CREATE INDEX FHIR_BATCH.JE_FKINSTANCEID_IX ON FHIR_BATCH.JOBEXECUTION (FK_JOBINSTANCEID) ALTER TABLE FHIR_BATCH.JOBEXECUTION ADD CONSTRAINT JBXCTNFKJBNSTNCEID FOREIGN KEY (FK_JOBINSTANCEID) REFERENCES FHIR_BATCH.JOBINSTANCE (JOBINSTANCEID)
- Parameters:
model
-
-
addStepThreadInstanceTable
public void addStepThreadInstanceTable(PhysicalDataModel model)
Adds the Step Thread Instance table with the following values:CREATE TABLE FHIR_BATCH.STEPTHREADINSTANCE( PARTNUM BIGINT NOT NULL, STEPNAME VARCHAR(128 OCTETS) NOT NULL, THREADTYPE VARCHAR(31 OCTETS), CHECKPOINTDATA BLOB(2147483647) INLINE LENGTH 10240, FK_JOBINSTANCEID BIGINT NOT NULL, FK_LATEST_STEPEXECID BIGINT NOT NULL, PARTITIONED SMALLINT NOT NULL, PARTITIONPLANSIZE INT, STARTCOUNT INT, CONSTRAINT PK_STEPTHREADINSTANCE PRIMARY KEY (PARTNUM, STEPNAME, FK_JOBINSTANCEID)) CREATE INDEX FHIR_BATCH.STI_FKINSTANCEID_IX ON FHIR_BATCH.STEPTHREADINSTANCE (FK_JOBINSTANCEID) CREATE INDEX FHIR_BATCH.STI_FKLATEST_SEI_IX ON FHIR_BATCH.STEPTHREADINSTANCE (FK_LATEST_STEPEXECID) ALTER TABLE FHIR_BATCH.STEPTHREADINSTANCE ADD CONSTRAINT STPTHRFKLTSTSTPXCD FOREIGN KEY (FK_LATEST_STEPEXECID) REFERENCES FHIR_BATCH.STEPTHREADEXECUTION (STEPEXECID) ALTER TABLE FHIR_BATCH.STEPTHREADINSTANCE ADD CONSTRAINT STPTHRDNFKJBNSTNCD FOREIGN KEY (FK_JOBINSTANCEID) REFERENCES FHIR_BATCH.JOBINSTANCE (JOBINSTANCEID)
- Parameters:
model
-
-
addJobInstanceTable
public void addJobInstanceTable(PhysicalDataModel model)
Adds the Job Instance table with the following values:CREATE TABLE FHIR_BATCH.JOBINSTANCE( JOBINSTANCEID BIGINT GENERATED BY DEFAULT AS IDENTITY, AMCNAME VARCHAR(512 OCTETS), BATCHSTATUS INT NOT NULL, CREATETIME TIMESTAMP NOT NULL, EXITSTATUS VARCHAR(2048 OCTETS), INSTANCESTATE INT NOT NULL, JOBNAME VARCHAR(256 OCTETS), JOBXMLNAME VARCHAR(128 OCTETS), JOBXML BLOB(2147483647) INLINE LENGTH 10240, NUMEXECS INT NOT NULL, RESTARTON VARCHAR(128 OCTETS), SUBMITTER VARCHAR(256 OCTETS), UPDATETIME TIMESTAMP, CONSTRAINT PK_JOBINSTANCEID PRIMARY KEY (JOBINSTANCEID) )
- Parameters:
model
-
-
-