Constant Field Values

Contents

• org.springframework.*

org.springframework.*

org.springframework.cloud.dataflow.core.BindingPropertyKeys

Modifier and Type	Constant Field	Value
public static final String	BINDING_KEY_PREFIX	"spring.cloud.stream.bindings."
public static final String	INPUT_BINDING_KEY_PREFIX	"spring.cloud.stream.bindings.input."
public static final String	INPUT_CONTENT_TYPE	"spring.cloud.stream.bindings.input.contentType"
public static final String	INPUT_DESTINATION	"spring.cloud.stream.bindings.input.destination"
public static final String	INPUT_GROUP	"spring.cloud.stream.bindings.input.group"
public static final String	INPUT_PARTITIONED	"spring.cloud.stream.bindings.input.consumer.partitioned"
public static final String	OUTPUT_BINDING_KEY_PREFIX	"spring.cloud.stream.bindings.output."
public static final String	OUTPUT_CONTENT_TYPE	"spring.cloud.stream.bindings.output.contentType"
public static final String	OUTPUT_DESTINATION	"spring.cloud.stream.bindings.output.destination"
public static final String	OUTPUT_PARTITION_COUNT	"spring.cloud.stream.bindings.output.producer.partitionCount"
public static final String	OUTPUT_PARTITION_KEY_EXPRESSION	"spring.cloud.stream.bindings.output.producer.partitionKeyExpression"
public static final String	OUTPUT_PARTITION_KEY_EXTRACTOR_CLASS	"spring.cloud.stream.bindings.output.producer.partitionKeyExtractorClass"
public static final String	OUTPUT_REQUIRED_GROUPS	"spring.cloud.stream.bindings.output.producer.requiredGroups"

org.springframework.cloud.dataflow.core.DataFlowPropertyKeys

Modifier and Type	Constant Field	Value
public static final String	PREFIX	"spring.cloud.dataflow."
public static final String	STREAM_APP_LABEL	"spring.cloud.dataflow.stream.app.label"
public static final String	STREAM_APP_TYPE	"spring.cloud.dataflow.stream.app.type"
public static final String	STREAM_NAME	"spring.cloud.dataflow.stream.name"

org.springframework.cloud.dataflow.core.StreamPropertyKeys

Modifier and Type	Constant Field	Value
public static final String	INSTANCE_COUNT	"spring.cloud.stream.instanceCount"

org.springframework.cloud.dataflow.core.StreamRuntimePropertyKeys

Modifier and Type	Constant Field	Value
public static final String	ATTRIBUTE_GUID	"guid"
public static final String	ATTRIBUTE_PORT	"port"
public static final String	ATTRIBUTE_SKIPPER_APPLICATION_NAME	"skipper.application.name"
public static final String	ATTRIBUTE_SKIPPER_RELEASE_NAME	"skipper.release.name"
public static final String	ATTRIBUTE_SKIPPER_RELEASE_VERSION	"skipper.release.version"
public static final String	ATTRIBUTE_URL	"url"

org.springframework.cloud.dataflow.core.TaskDefinition

Modifier and Type	Constant Field	Value
public static final String	SPRING_CLOUD_TASK_NAME	"spring.cloud.task.name"

org.springframework.cloud.dataflow.core.TaskPlatformFactory

Modifier and Type	Constant Field	Value
public static final String	CLOUDFOUNDRY_PLATFORM_TYPE	"Cloud Foundry"
public static final String	KUBERNETES_PLATFORM_TYPE	"Kubernetes"
public static final String	LOCAL_PLATFORM_TYPE	"Local"

org.springframework.cloud.dataflow.core.TaskPropertyKeys

Modifier and Type	Constant Field	Value
public static final String	TASK_NAME	"spring.cloud.task.name"

org.springframework.cloud.dataflow.registry.support.DockerImage

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_NAMESPACE	"library"
public static final String	DEFAULT_TAG	"latest"
public static final String	SECTION_SEPARATOR	"/"
public static final String	TAG_SEPARATOR	":"

org.springframework.cloud.dataflow.rest.SkipperStream

Modifier and Type	Constant Field	Value
public static final String	SKIPPER_DEFAULT_API_VERSION	"skipper.spring.io/v1"
public static final String	SKIPPER_DEFAULT_KIND	"SpringCloudDeployerApplication"
public static final String	SKIPPER_DEFAULT_MAINTAINER	"dataflow"
public static final String	SKIPPER_KEY_PREFIX	"spring.cloud.dataflow.skipper"
public static final String	SKIPPER_PACKAGE_NAME	"spring.cloud.dataflow.skipper.packageName"
public static final String	SKIPPER_PACKAGE_VERSION	"spring.cloud.dataflow.skipper.packageVersion"
public static final String	SKIPPER_PLATFORM_NAME	"spring.cloud.dataflow.skipper.platformName"
public static final String	SKIPPER_REPO_NAME	"spring.cloud.dataflow.skipper.repoName"
public static final String	SKIPPER_SPEC_RESOURCE	"resource"
public static final String	SKIPPER_SPEC_VERSION	"version"

org.springframework.cloud.dataflow.rest.Version

Modifier and Type	Constant Field	Value
public static final int	REVISION	14
public static final String	REVISION_KEY	"api.revision"

org.springframework.cloud.dataflow.rest.client.SchedulerTemplate

Modifier and Type	Constant Field	Value
public static final String	SCHEDULES_RELATION	"tasks/schedules"

org.springframework.cloud.dataflow.rest.client.StreamTemplate

Modifier and Type	Constant Field	Value
public static final String	DEFINITIONS_REL	"streams/definitions"

org.springframework.cloud.dataflow.rest.client.dsl.AbstractPropertiesBuilder

Modifier and Type	Constant Field	Value
protected final String	DEPLOYER_PREFIX	"deployer.%s.%s"

org.springframework.cloud.dataflow.rest.client.dsl.task.TaskSchedule

Modifier and Type	Constant Field	Value
public static final String	CRON_EXPRESSION_KEY	"deployer.cron.expression"

org.springframework.cloud.dataflow.rest.job.support.TimeUtils

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_DATAFLOW_DATE_FORMAT_PATTERN	"yyyy-MM-dd"
public static final String	DEFAULT_DATAFLOW_DATE_TIME_FORMAT_PATTERN	"yyyy-MM-dd HH:mm:ss,SSS"
public static final String	DEFAULT_DATAFLOW_DATE_TIME_PARAMETER_FORMAT_PATTERN	"yyyy-MM-dd\'T\'HH:mm:ss,SSS"
public static final String	DEFAULT_DATAFLOW_DURATION_FORMAT_PATTERN	"HH:mm:ss"
public static final String	DEFAULT_DATAFLOW_TIME_FORMAT_PATTERN	"HH:mm:ss"
public static final String	DEFAULT_DATAFLOW_TIMEZONE_ID	"UTC"

org.springframework.cloud.dataflow.rest.resource.AppStatusResource

Modifier and Type	Constant Field	Value
public static final String	NO_INSTANCES	"no-instances"

org.springframework.cloud.dataflow.rest.resource.StreamStatusResource

Modifier and Type	Constant Field	Value
public static final String	NO_APPS	"no apps"

org.springframework.cloud.dataflow.server.DockerValidatorProperties

Modifier and Type	Constant Field	Value
public static final String	DOCKER_REGISTRY_URL	"https://hub.docker.com/v2/repositories"
public static final String	DOCKER_VALIDATION_PREFIX	"spring.cloud.dataflow.docker.validation"

org.springframework.cloud.dataflow.server.config.DataflowAsyncAutoConfiguration

Modifier and Type	Constant Field	Value
public static final String	ASYNC_PROPS_PREFIX	"spring.cloud.dataflow.async"
public static final String	DATAFLOW_ASYNC_EXECUTOR	"dataflowAsyncExecutor"

org.springframework.cloud.dataflow.server.config.DataflowMetricsProperties

Modifier and Type	Constant Field	Value
public static final String	METRICS_PREFIX	"spring.cloud.dataflow.metrics"

org.springframework.cloud.dataflow.server.config.DefaultEnvironmentPostProcessor

Modifier and Type	Constant Field	Value
public static final int	ORDER	-2147482738

org.springframework.cloud.dataflow.server.config.VersionInfoProperties

Modifier and Type	Constant Field	Value
public static final String	VERSION_INFO_PREFIX	"spring.cloud.dataflow.version-info"

org.springframework.cloud.dataflow.server.config.features.FeaturesProperties

Modifier and Type	Constant Field	Value
public static final String	FEATURES_PREFIX	"spring.cloud.dataflow.features"
public static final String	SCHEDULES_ENABLED	"schedules-enabled"
public static final String	STREAMS_ENABLED	"streams-enabled"
public static final String	TASKS_ENABLED	"tasks-enabled"

org.springframework.cloud.dataflow.server.controller.UiController

Modifier and Type	Constant Field	Value
public static final String	WEB_UI_INDEX_PAGE_ROUTE	"/dashboard"

org.springframework.cloud.dataflow.server.db.migration.AbstractAggregateViewMigration

Modifier and Type	Constant Field	Value
public static final String	CREATE_AGGREGATE_JOB_EXECUTION_VIEW	"CREATE VIEW AGGREGATE_JOB_EXECUTION AS\n SELECT JOB_EXECUTION_ID, VERSION, JOB_INSTANCE_ID, CREATE_TIME, START_TIME, END_TIME, STATUS, EXIT_CODE, EXIT_MESSAGE, LAST_UPDATED, \'boot2\' AS SCHEMA_TARGET FROM BATCH_JOB_EXECUTION\nUNION ALL\n SELECT JOB_EXECUTION_ID, VERSION, JOB_INSTANCE_ID, CREATE_TIME, START_TIME, END_TIME, STATUS, EXIT_CODE, EXIT_MESSAGE, LAST_UPDATED, \'boot3\' AS SCHEMA_TARGET FROM BOOT3_BATCH_JOB_EXECUTION"
public static final String	CREATE_AGGREGATE_JOB_INSTANCE_VIEW	"CREATE VIEW AGGREGATE_JOB_INSTANCE AS\n SELECT JOB_INSTANCE_ID, VERSION, JOB_NAME, JOB_KEY, \'boot2\' AS SCHEMA_TARGET FROM BATCH_JOB_INSTANCE\nUNION ALL\n SELECT JOB_INSTANCE_ID, VERSION, JOB_NAME, JOB_KEY, \'boot3\' AS SCHEMA_TARGET FROM BOOT3_BATCH_JOB_INSTANCE"
public static final String	CREATE_AGGREGATE_STEP_EXECUTION_VIEW	"CREATE VIEW AGGREGATE_STEP_EXECUTION AS\n SELECT STEP_EXECUTION_ID, VERSION, STEP_NAME, JOB_EXECUTION_ID, START_TIME, END_TIME, STATUS, COMMIT_COUNT, READ_COUNT, FILTER_COUNT, WRITE_COUNT, READ_SKIP_COUNT, WRITE_SKIP_COUNT, PROCESS_SKIP_COUNT, ROLLBACK_COUNT, EXIT_CODE, EXIT_MESSAGE, LAST_UPDATED, \'boot2\' AS SCHEMA_TARGET FROM BATCH_STEP_EXECUTION\nUNION ALL\n SELECT STEP_EXECUTION_ID, VERSION, STEP_NAME, JOB_EXECUTION_ID, START_TIME, END_TIME, STATUS, COMMIT_COUNT, READ_COUNT, FILTER_COUNT, WRITE_COUNT, READ_SKIP_COUNT, WRITE_SKIP_COUNT, PROCESS_SKIP_COUNT, ROLLBACK_COUNT, EXIT_CODE, EXIT_MESSAGE, LAST_UPDATED, \'boot3\' AS SCHEMA_TARGET FROM BOOT3_BATCH_STEP_EXECUTION"
public static final String	CREATE_AGGREGATE_TASK_BATCH_VIEW	"CREATE VIEW AGGREGATE_TASK_BATCH AS\n SELECT TASK_EXECUTION_ID, JOB_EXECUTION_ID, \'boot2\' AS SCHEMA_TARGET FROM TASK_TASK_BATCH\nUNION ALL\n SELECT TASK_EXECUTION_ID, JOB_EXECUTION_ID, \'boot3\' AS SCHEMA_TARGET FROM BOOT3_TASK_TASK_BATCH"
public static final String	CREATE_AGGREGATE_TASK_EXECUTION_PARAMS_VIEW	"CREATE VIEW AGGREGATE_TASK_EXECUTION_PARAMS AS\n SELECT TASK_EXECUTION_ID, TASK_PARAM, \'boot2\' AS SCHEMA_TARGET FROM TASK_EXECUTION_PARAMS\nUNION ALL\n SELECT TASK_EXECUTION_ID, TASK_PARAM, \'boot3\' AS SCHEMA_TARGET FROM BOOT3_TASK_EXECUTION_PARAMS"
public static final String	CREATE_AGGREGATE_TASK_EXECUTION_VIEW	"CREATE VIEW AGGREGATE_TASK_EXECUTION AS\n SELECT TASK_EXECUTION_ID, START_TIME, END_TIME, TASK_NAME, EXIT_CODE, EXIT_MESSAGE, ERROR_MESSAGE, LAST_UPDATED, EXTERNAL_EXECUTION_ID, PARENT_EXECUTION_ID, \'boot2\' AS SCHEMA_TARGET FROM TASK_EXECUTION\nUNION ALL\n SELECT TASK_EXECUTION_ID, START_TIME, END_TIME, TASK_NAME, EXIT_CODE, EXIT_MESSAGE, ERROR_MESSAGE, LAST_UPDATED, EXTERNAL_EXECUTION_ID, PARENT_EXECUTION_ID, \'boot3\' AS SCHEMA_TARGET FROM BOOT3_TASK_EXECUTION"

org.springframework.cloud.dataflow.server.db.migration.AbstractCaseSensitiveMigration

Modifier and Type	Constant Field	Value
protected static final String	ALTER_SEQUENCE_TASK_EXECUTION_METADATA_SEQ	"select setval(TASK_EXECUTION_METADATA_SEQ, select nextval(task_execution_metadata_seq_lc), false)"
protected static final String	ALTER_SEQUENCE_TASK_EXECUTION_METADATA_SEQ_LC	"select setval(task_execution_metadata_seq_lc, select nextval(task_execution_metadata_seq), false)"
protected static final String	CREATE_SEQUENCE_TASK_EXECUTION_METADATA_SEQ	"create sequence TASK_EXECUTION_METADATA_SEQ START WITH 1 MINVALUE 1 MAXVALUE 9223372036854775806 INCREMENT BY 1 NOCACHE NOCYCLE ENGINE=InnoDB"
protected static final String	CREATE_SEQUENCE_TASK_EXECUTION_METADATA_SEQ_LC	"CREATE SEQUENCE task_execution_metadata_seq_lc"
protected static final String	DROP_SEQUENCE_TASK_EXECUTION_METADATA_SEQ	"drop sequence task_execution_metadata_seq"
protected static final String	DROP_SEQUENCE_TASK_EXECUTION_METADATA_SEQ_LC	"drop sequence task_execution_metadata_seq_lc"
protected static final String	RENAME_TASK_EXECUTION_METADATA	"alter table task_execution_metadata_lc rename to TASK_EXECUTION_METADATA"
protected static final String	RENAME_TASK_EXECUTION_METADATA_LC	"alter table task_execution_metadata rename to task_execution_metadata_lc"
protected static final String	RENAME_TASK_EXECUTION_METADATA_SEQ	"alter sequence task_execution_metadata_seq_lc rename to TASK_EXECUTION_METADATA_SEQ"
protected static final String	RENAME_TASK_EXECUTION_METADATA_SEQ_LC	"alter sequence task_execution_metadata_seq rename to task_execution_metadata_seq_lc"
protected static final String	RENAME_TASK_EXECUTION_METADATA_SEQ_LC_TBL	"alter table task_execution_metadata_seq rename to task_execution_metadata_seq_lc"
protected static final String	RENAME_TASK_EXECUTION_METADATA_SEQ_TBL	"alter table task_execution_metadata_seq_lc rename to TASK_EXECUTION_METADATA_SEQ"

org.springframework.cloud.dataflow.server.db.migration.AbstractCreateBatchIndexesMigration

Modifier and Type	Constant Field	Value
protected static final String	CREATE_BATCH_JOB_EXECUTION_START_TIME_INDEX	"create index BATCH_JOB_EXECUTION_START_TIME_IX on BATCH_JOB_EXECUTION(START_TIME)"
protected static final String	CREATE_BATCH_STEP_EXECUTION_JOB_EXECUTION_ID_INDEX	"create index BATCH_STEP_EXECUTION_JOB_EXECUTION_ID_IX on BATCH_STEP_EXECUTION(JOB_EXECUTION_ID)"
protected static final String	CREATE_BOOT3_BATCH_JOB_EXECUTION_START_TIME_INDEX	"create index BOOT3_BATCH_JOB_EXECUTION_START_TIME_IX on BOOT3_BATCH_JOB_EXECUTION(START_TIME)"
protected static final String	CREATE_BOOT3_BATCH_STEP_EXECUTION_JOB_EXECUTION_ID_INDEX	"create index BOOT3_BATCH_STEP_EXECUTION_JOB_EXECUTION_ID_IX on BOOT3_BATCH_STEP_EXECUTION(JOB_EXECUTION_ID)"
protected static final String	CREATE_BOOT3_TASK_TASK_BATCH_JOB_EXECUTION_ID_INDEX	"create index BOOT3_TASK_TASK_BATCH_JOB_EXECUTION_ID_IX on BOOT3_TASK_TASK_BATCH(JOB_EXECUTION_ID)"
protected static final String	CREATE_TASK_TASK_BATCH_JOB_EXECUTION_ID_INDEX	"create index TASK_TASK_BATCH_JOB_EXECUTION_ID_IX on TASK_TASK_BATCH(JOB_EXECUTION_ID)"

org.springframework.cloud.dataflow.server.db.migration.AbstractCreateTaskParentIndexMigration

Modifier and Type	Constant Field	Value
protected static final String	CREATE_BOOT3_TASK_PARENT_INDEX	"create index BOOT3_TASK_EXECUTION_PARENT_IX on BOOT3_TASK_EXECUTION(PARENT_EXECUTION_ID)"
protected static final String	CREATE_TASK_PARENT_INDEX	"create index TASK_EXECUTION_PARENT_IX on TASK_EXECUTION(PARENT_EXECUTION_ID)"

org.springframework.cloud.dataflow.server.db.migration.db2.Db2BeforeBaseline

Modifier and Type	Constant Field	Value
public static final String	CREATE_AUDIT_RECORDS_AUDIT_ACTION_IDX_INDEX	"create index audit_records_audit_action_idx on audit_records (audit_action)"
public static final String	CREATE_AUDIT_RECORDS_AUDIT_OPERATION_IDX_INDEX	"create index audit_records_audit_operation_idx on audit_records (audit_operation)"
public static final String	CREATE_AUDIT_RECORDS_CORRELATION_ID_IDX_INDEX	"create index audit_records_correlation_id_idx on audit_records (correlation_id)"
public static final String	CREATE_AUDIT_RECORDS_CREATED_ON_IDX_INDEX	"create index audit_records_created_on_idx on audit_records (created_on)"
public static final String	DROP_APP_REGISTRATION_TABLE	"drop table APP_REGISTRATION"
public static final String	DROP_AUDIT_RECORDS_AUDIT_ACTION_IDX_INDEX	"drop index AUDIT_RECORDS_AUDIT_ACTION_IDX"
public static final String	DROP_AUDIT_RECORDS_AUDIT_OPERATION_IDX_INDEX	"drop index AUDIT_RECORDS_AUDIT_OPERATION_IDX"
public static final String	DROP_AUDIT_RECORDS_CORRELATION_ID_IDX_INDEX	"drop index AUDIT_RECORDS_CORRELATION_ID_IDX"
public static final String	DROP_AUDIT_RECORDS_CREATED_ON_IDX_INDEX	"drop index AUDIT_RECORDS_CREATED_ON_IDX"
public static final String	DROP_AUDIT_RECORDS_TABLE	"drop table AUDIT_RECORDS"
public static final String	DROP_STREAM_DEFINITIONS_TABLE	"drop table STREAM_DEFINITIONS"
public static final String	DROP_TASK_DEFINITIONS_TABLE	"drop table TASK_DEFINITIONS"
public static final String	INSERT_APP_REGISTRATION_DATA	"insert into\n app_registration_tmp (id, object_version, default_version, metadata_uri, name, type, uri, version) \n select id, object_Version, default_Version, metadata_Uri, name, type, uri, version\n from APP_REGISTRATION"
public static final String	INSERT_AUDIT_RECORDS_DATA	"insert into\n audit_records_tmp (id, audit_action, audit_data, audit_operation, correlation_id, created_by, created_on)\n select id, audit_Action, audit_data, audit_Operation, correlation_id, created_by, created_On\n from AUDIT_RECORDS"
public static final String	INSERT_STREAM_DEFINITIONS_DATA	"insert into\n stream_definitions_tmp (definition_name, definition) \n select DEFINITION_NAME, DEFINITION\n from STREAM_DEFINITIONS"
public static final String	INSERT_TASK_DEFINITIONS_DATA	"insert into\n task_definitions_tmp (definition_name, definition) \n select DEFINITION_NAME, DEFINITION\n from TASK_DEFINITIONS"
public static final String	RENAME_APP_REGISTRATION_TMP_TABLE	"rename table app_registration_tmp to app_registration"
public static final String	RENAME_AUDIT_RECORDS_TMP_TABLE	"rename table audit_records_tmp to audit_records"
public static final String	RENAME_STREAM_DEFINITIONS_TMP_TABLE	"rename table stream_definitions_tmp to stream_definitions"
public static final String	RENAME_TASK_DEFINITIONS_TMP_TABLE	"rename table task_definitions_tmp to task_definitions"

org.springframework.cloud.dataflow.server.db.migration.db2.V1__Initial_Setup

Modifier and Type	Constant Field	Value
public static final String	CREATE_APP_REGISTRATION_TABLE	"create table app_registration (\n id bigint not null,\n object_version bigint,\n default_version smallint,\n metadata_uri clob(255),\n name varchar(255),\n type integer,\n uri clob(255),\n version varchar(255),\n primary key (id)\n)"
public static final String	CREATE_AUDIT_RECORDS_TABLE	"create table audit_records (\n id bigint not null,\n audit_action bigint,\n audit_data long varchar,\n audit_operation bigint,\n correlation_id varchar(255),\n created_by varchar(255),\n created_on timestamp,\n primary key (id)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION_CONTEXT (\n JOB_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n SHORT_CONTEXT VARCHAR(2500) NOT NULL,\n SERIALIZED_CONTEXT CLOB,\n constraint JOB_EXEC_CTX_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_PARAMS_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION_PARAMS (\n JOB_EXECUTION_ID BIGINT NOT NULL,\n TYPE_CD VARCHAR(6) NOT NULL,\n KEY_NAME VARCHAR(100) NOT NULL,\n STRING_VAL VARCHAR(250),\n DATE_VAL TIMESTAMP DEFAULT NULL,\n LONG_VAL BIGINT,\n DOUBLE_VAL DOUBLE PRECISION,\n IDENTIFYING CHAR(1) NOT NULL,\n constraint JOB_EXEC_PARAMS_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_SEQUENCE	"CREATE SEQUENCE BATCH_JOB_EXECUTION_SEQ AS BIGINT MAXVALUE 9223372036854775807 NO CYCLE"
public static final String	CREATE_BATCH_JOB_EXECUTION_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION (\n JOB_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT,\n JOB_INSTANCE_ID BIGINT NOT NULL,\n CREATE_TIME TIMESTAMP NOT NULL,\n START_TIME TIMESTAMP DEFAULT NULL,\n END_TIME TIMESTAMP DEFAULT NULL,\n STATUS VARCHAR(10),\n EXIT_CODE VARCHAR(2500),\n EXIT_MESSAGE VARCHAR(2500),\n LAST_UPDATED TIMESTAMP,\n JOB_CONFIGURATION_LOCATION VARCHAR(2500) NULL,\n constraint JOB_INST_EXEC_FK foreign key (JOB_INSTANCE_ID)\n references BATCH_JOB_INSTANCE(JOB_INSTANCE_ID)\n)"
public static final String	CREATE_BATCH_JOB_INSTANCE_TABLE	"CREATE TABLE BATCH_JOB_INSTANCE (\n JOB_INSTANCE_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT,\n JOB_NAME VARCHAR(100) NOT NULL,\n JOB_KEY VARCHAR(32) NOT NULL,\n constraint JOB_INST_UN unique (JOB_NAME, JOB_KEY)\n)"
public static final String	CREATE_BATCH_JOB_SEQUENCE	"CREATE SEQUENCE BATCH_JOB_SEQ AS BIGINT MAXVALUE 9223372036854775807 NO CYCLE"
public static final String	CREATE_BATCH_STEP_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BATCH_STEP_EXECUTION_CONTEXT (\n STEP_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n SHORT_CONTEXT VARCHAR(2500) NOT NULL,\n SERIALIZED_CONTEXT CLOB,\n constraint STEP_EXEC_CTX_FK foreign key (STEP_EXECUTION_ID)\n references BATCH_STEP_EXECUTION(STEP_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_STEP_EXECUTION_SEQUENCE	"CREATE SEQUENCE BATCH_STEP_EXECUTION_SEQ AS BIGINT MAXVALUE 9223372036854775807 NO CYCLE"
public static final String	CREATE_BATCH_STEP_EXECUTION_TABLE	"CREATE TABLE BATCH_STEP_EXECUTION (\n STEP_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT NOT NULL,\n STEP_NAME VARCHAR(100) NOT NULL,\n JOB_EXECUTION_ID BIGINT NOT NULL,\n START_TIME TIMESTAMP NOT NULL,\n END_TIME TIMESTAMP DEFAULT NULL,\n STATUS VARCHAR(10),\n COMMIT_COUNT BIGINT,\n READ_COUNT BIGINT,\n FILTER_COUNT BIGINT,\n WRITE_COUNT BIGINT,\n READ_SKIP_COUNT BIGINT,\n WRITE_SKIP_COUNT BIGINT,\n PROCESS_SKIP_COUNT BIGINT,\n ROLLBACK_COUNT BIGINT,\n EXIT_CODE VARCHAR(2500),\n EXIT_MESSAGE VARCHAR(2500),\n LAST_UPDATED TIMESTAMP,\n constraint JOB_EXEC_STEP_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_STREAM_DEFINITIONS_TABLE	"create table stream_definitions (\n definition_name varchar(255) not null,\n definition clob(255),\n primary key (definition_name)\n)"
public static final String	CREATE_TASK_DEFINITIONS_TABLE	"create table task_definitions (\n definition_name varchar(255) not null,\n definition clob(255),\n primary key (definition_name)\n)"
public static final String	CREATE_TASK_DEPLOYMENT_TABLE	"create table task_deployment (\n id bigint not null,\n object_version bigint,\n task_deployment_id varchar(255) not null,\n task_definition_name varchar(255) not null,\n platform_name varchar(255) not null,\n created_on timestamp,\n primary key (id)\n)"
public static final String	CREATE_TASK_EXECUTION_PARAMS_TABLE	"CREATE TABLE TASK_EXECUTION_PARAMS (\n TASK_EXECUTION_ID BIGINT NOT NULL,\n TASK_PARAM VARCHAR(2500),\n constraint TASK_EXEC_PARAMS_FK foreign key (TASK_EXECUTION_ID)\n references TASK_EXECUTION(TASK_EXECUTION_ID)\n)"
public static final String	CREATE_TASK_EXECUTION_TABLE	"CREATE TABLE TASK_EXECUTION (\n TASK_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n START_TIME TIMESTAMP DEFAULT NULL,\n END_TIME TIMESTAMP DEFAULT NULL,\n TASK_NAME VARCHAR(100),\n EXIT_CODE INTEGER,\n EXIT_MESSAGE VARCHAR(2500),\n ERROR_MESSAGE VARCHAR(2500),\n LAST_UPDATED TIMESTAMP,\n EXTERNAL_EXECUTION_ID VARCHAR(255),\n PARENT_EXECUTION_ID BIGINT\n)"
public static final String	CREATE_TASK_LOCK_TABLE	"CREATE TABLE TASK_LOCK (\n LOCK_KEY CHAR(36) NOT NULL,\n REGION VARCHAR(100) NOT NULL,\n CLIENT_ID CHAR(36),\n CREATED_DATE TIMESTAMP NOT NULL,\n constraint LOCK_PK primary key (LOCK_KEY, REGION)\n)"
public static final String	CREATE_TASK_TASK_BATCH	"CREATE TABLE TASK_TASK_BATCH (\n TASK_EXECUTION_ID BIGINT NOT NULL,\n JOB_EXECUTION_ID BIGINT NOT NULL,\n constraint TASK_EXEC_BATCH_FK foreign key (TASK_EXECUTION_ID)\n references TASK_EXECUTION(TASK_EXECUTION_ID)\n)"

org.springframework.cloud.dataflow.server.db.migration.db2.V2__Add_Descriptions_And_OriginalDefinition

Modifier and Type	Constant Field	Value
public static final String	ALTER_STREAM_DEFINITION_TABLE_DESC	"alter table stream_definitions add description varchar(255)"
public static final String	ALTER_STREAM_DEFINITION_TABLE_ORIG_DEF	"alter table stream_definitions add original_definition clob(255)"
public static final String	ALTER_TASK_DEFINITION_TABLE	"alter table task_definitions add description varchar(255)"
public static final String	CREATE_TASK_METADATA_SEQUENCE	"CREATE SEQUENCE task_execution_metadata_seq AS BIGINT MAXVALUE 9223372036854775807 NO CYCLE"
public static final String	CREATE_TASK_METADATA_TABLE	"CREATE TABLE task_execution_metadata (\n id BIGINT NOT NULL PRIMARY KEY,\n task_execution_id BIGINT NOT NULL,\n task_execution_manifest CLOB,\n CONSTRAINT TASK_METADATA_FK FOREIGN KEY (task_execution_id)\n REFERENCES TASK_EXECUTION(TASK_EXECUTION_ID)\n)"
public static final String	UPDATE_STREAM_DEFINITION_TABLE_ORIG_DEF	"update stream_definitions set original_definition=definition"

org.springframework.cloud.dataflow.server.db.migration.db2.V3__Add_Platform_To_AuditRecords

Modifier and Type	Constant Field	Value
public static final String	ALTER_AUDIT_RECORDS_TABLE_PLATFORM	"alter table audit_records add platform_name varchar(255)"

org.springframework.cloud.dataflow.server.db.migration.db2.V4__Add_Step_Name_Indexes

Modifier and Type	Constant Field	Value
public static final String	ADD_INDEX_TO_BATCH_STEP_EXECUTION	"create index STEP_NAME_IDX on BATCH_STEP_EXECUTION (STEP_NAME)"

org.springframework.cloud.dataflow.server.db.migration.db2.V5__Add_Task_Execution_Params_Indexes

Modifier and Type	Constant Field	Value
public static final String	ADD_INDEX_TO_STEP_EXECUTION_PARAMS	"create index TASK_EXECUTION_ID_IDX on TASK_EXECUTION_PARAMS (TASK_EXECUTION_ID)"

org.springframework.cloud.dataflow.server.db.migration.mariadb.MariadbBeforeBaseline

Modifier and Type	Constant Field	Value
public static final String	CREATE_AUDIT_RECORDS_AUDIT_ACTION_IDX_INDEX	"create index audit_records_audit_action_idx on audit_records (audit_action)"
public static final String	CREATE_AUDIT_RECORDS_AUDIT_OPERATION_IDX_INDEX	"create index audit_records_audit_operation_idx on audit_records (audit_operation)"
public static final String	CREATE_AUDIT_RECORDS_CORRELATION_ID_IDX_INDEX	"create index audit_records_correlation_id_idx on audit_records (correlation_id)"
public static final String	CREATE_AUDIT_RECORDS_CREATED_ON_IDX_INDEX	"create index audit_records_created_on_idx on audit_records (created_on)"
public static final String	DROP_APP_REGISTRATION_TABLE	"drop table APP_REGISTRATION"
public static final String	DROP_AUDIT_RECORDS_AUDIT_ACTION_IDX_INDEX	"drop index AUDIT_RECORDS_AUDIT_ACTION_IDX on AUDIT_RECORDS"
public static final String	DROP_AUDIT_RECORDS_AUDIT_OPERATION_IDX_INDEX	"drop index AUDIT_RECORDS_AUDIT_OPERATION_IDX on AUDIT_RECORDS"
public static final String	DROP_AUDIT_RECORDS_CORRELATION_ID_IDX_INDEX	"drop index AUDIT_RECORDS_CORRELATION_ID_IDX on AUDIT_RECORDS"
public static final String	DROP_AUDIT_RECORDS_CREATED_ON_IDX_INDEX	"drop index AUDIT_RECORDS_CREATED_ON_IDX on AUDIT_RECORDS"
public static final String	DROP_AUDIT_RECORDS_TABLE	"drop table AUDIT_RECORDS"
public static final String	DROP_STREAM_DEFINITIONS_TABLE	"drop table STREAM_DEFINITIONS"
public static final String	DROP_TASK_DEFINITIONS_TABLE	"drop table TASK_DEFINITIONS"
public static final String	INSERT_APP_REGISTRATION_DATA	"insert into\n app_registration_tmp (id, object_version, default_version, metadata_uri, name, type, uri, version) \n select id, object_Version, default_Version, metadata_Uri, name, type, uri, version\n from APP_REGISTRATION"
public static final String	INSERT_AUDIT_RECORDS_DATA	"insert into\n audit_records_tmp (id, audit_action, audit_data, audit_operation, correlation_id, created_by, created_on)\n select id, audit_Action, audit_data, audit_Operation, correlation_id, created_by, created_On\n from AUDIT_RECORDS"
public static final String	INSERT_STREAM_DEFINITIONS_DATA	"insert into\n stream_definitions_tmp (definition_name, definition) \n select DEFINITION_NAME, DEFINITION\n from STREAM_DEFINITIONS"
public static final String	INSERT_TASK_DEFINITIONS_DATA	"insert into\n task_definitions_tmp (definition_name, definition) \n select DEFINITION_NAME, DEFINITION\n from TASK_DEFINITIONS"
public static final String	RENAME_APP_REGISTRATION_TMP_TABLE	"alter table app_registration_tmp rename to app_registration"
public static final String	RENAME_AUDIT_RECORDS_TMP_TABLE	"alter table audit_records_tmp rename to audit_records"
public static final String	RENAME_STREAM_DEFINITIONS_TMP_TABLE	"alter table stream_definitions_tmp rename to stream_definitions"
public static final String	RENAME_TASK_DEFINITIONS_TMP_TABLE	"alter table task_definitions_tmp rename to task_definitions"

org.springframework.cloud.dataflow.server.db.migration.mariadb.V1__Initial_Setup

Modifier and Type	Constant Field	Value
public static final String	CREATE_APP_REGISTRATION_TABLE	"create table app_registration (\n id bigint not null,\n object_version bigint,\n default_version bit,\n metadata_uri longtext,\n name varchar(255),\n type integer,\n uri longtext,\n version varchar(255),\n primary key (id)\n)"
public static final String	CREATE_AUDIT_RECORDS_TABLE	"create table audit_records (\n id bigint not null,\n audit_action bigint,\n audit_data longtext,\n audit_operation bigint,\n correlation_id varchar(255),\n created_by varchar(255),\n created_on datetime,\n primary key (id)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION_CONTEXT (\n JOB_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n SHORT_CONTEXT VARCHAR(2500) NOT NULL,\n SERIALIZED_CONTEXT TEXT,\n constraint JOB_EXEC_CTX_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_PARAMS_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION_PARAMS (\n JOB_EXECUTION_ID BIGINT NOT NULL,\n TYPE_CD VARCHAR(6) NOT NULL,\n KEY_NAME VARCHAR(100) NOT NULL,\n STRING_VAL VARCHAR(250),\n DATE_VAL DATETIME DEFAULT NULL,\n LONG_VAL BIGINT,\n DOUBLE_VAL DOUBLE PRECISION,\n IDENTIFYING CHAR(1) NOT NULL,\n constraint JOB_EXEC_PARAMS_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_SEQUENCE	"CREATE TABLE BATCH_JOB_EXECUTION_SEQ (\n ID BIGINT NOT NULL,\n UNIQUE_KEY CHAR(1) NOT NULL,\n constraint UNIQUE_KEY_UN unique (UNIQUE_KEY)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION (\n JOB_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT,\n JOB_INSTANCE_ID BIGINT NOT NULL,\n CREATE_TIME DATETIME NOT NULL,\n START_TIME DATETIME DEFAULT NULL,\n END_TIME DATETIME DEFAULT NULL,\n STATUS VARCHAR(10),\n EXIT_CODE VARCHAR(2500),\n EXIT_MESSAGE VARCHAR(2500),\n LAST_UPDATED DATETIME,\n JOB_CONFIGURATION_LOCATION VARCHAR(2500) NULL,\n constraint JOB_INST_EXEC_FK foreign key (JOB_INSTANCE_ID)\n references BATCH_JOB_INSTANCE(JOB_INSTANCE_ID)\n)"
public static final String	CREATE_BATCH_JOB_INSTANCE_TABLE	"CREATE TABLE BATCH_JOB_INSTANCE (\n JOB_INSTANCE_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT,\n JOB_NAME VARCHAR(100) NOT NULL,\n JOB_KEY VARCHAR(32) NOT NULL,\n constraint JOB_INST_UN unique (JOB_NAME, JOB_KEY)\n)"
public static final String	CREATE_BATCH_JOB_SEQUENCE	"CREATE TABLE BATCH_JOB_SEQ (\n ID BIGINT NOT NULL,\n UNIQUE_KEY CHAR(1) NOT NULL,\n constraint UNIQUE_KEY_UN unique (UNIQUE_KEY)\n)"
public static final String	CREATE_BATCH_STEP_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BATCH_STEP_EXECUTION_CONTEXT (\n STEP_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n SHORT_CONTEXT VARCHAR(2500) NOT NULL,\n SERIALIZED_CONTEXT TEXT,\n constraint STEP_EXEC_CTX_FK foreign key (STEP_EXECUTION_ID)\n references BATCH_STEP_EXECUTION(STEP_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_STEP_EXECUTION_SEQUENCE	"CREATE TABLE BATCH_STEP_EXECUTION_SEQ (\n ID BIGINT NOT NULL,\n UNIQUE_KEY CHAR(1) NOT NULL,\n constraint UNIQUE_KEY_UN unique (UNIQUE_KEY)\n)"
public static final String	CREATE_BATCH_STEP_EXECUTION_TABLE	"CREATE TABLE BATCH_STEP_EXECUTION (\n STEP_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT NOT NULL,\n STEP_NAME VARCHAR(100) NOT NULL,\n JOB_EXECUTION_ID BIGINT NOT NULL,\n START_TIME DATETIME NOT NULL,\n END_TIME DATETIME DEFAULT NULL,\n STATUS VARCHAR(10),\n COMMIT_COUNT BIGINT,\n READ_COUNT BIGINT,\n FILTER_COUNT BIGINT,\n WRITE_COUNT BIGINT,\n READ_SKIP_COUNT BIGINT,\n WRITE_SKIP_COUNT BIGINT,\n PROCESS_SKIP_COUNT BIGINT,\n ROLLBACK_COUNT BIGINT,\n EXIT_CODE VARCHAR(2500),\n EXIT_MESSAGE VARCHAR(2500),\n LAST_UPDATED DATETIME,\n constraint JOB_EXEC_STEP_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_HIBERNATE_SEQUENCE	"create sequence if not exists hibernate_sequence start 1 increment 1"
public static final String	CREATE_STREAM_DEFINITIONS_TABLE	"create table stream_definitions (\n definition_name varchar(255) not null,\n definition longtext,\n primary key (definition_name)\n)"
public static final String	CREATE_TASK_DEFINITIONS_TABLE	"create table task_definitions (\n definition_name varchar(255) not null,\n definition longtext,\n primary key (definition_name)\n)"
public static final String	CREATE_TASK_DEPLOYMENT_TABLE	"create table task_deployment (\n id bigint not null,\n object_version bigint,\n task_deployment_id varchar(255) not null,\n task_definition_name varchar(255) not null,\n platform_name varchar(255) not null,\n created_on datetime,\n primary key (id)\n)"
public static final String	CREATE_TASK_EXECUTION_PARAMS_TABLE	"CREATE TABLE TASK_EXECUTION_PARAMS (\n TASK_EXECUTION_ID BIGINT NOT NULL,\n TASK_PARAM VARCHAR(2500),\n constraint TASK_EXEC_PARAMS_FK foreign key (TASK_EXECUTION_ID)\n references TASK_EXECUTION(TASK_EXECUTION_ID)\n)"
public static final String	CREATE_TASK_EXECUTION_TABLE	"CREATE TABLE TASK_EXECUTION (\n TASK_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n START_TIME DATETIME DEFAULT NULL,\n END_TIME DATETIME DEFAULT NULL,\n TASK_NAME VARCHAR(100),\n EXIT_CODE INTEGER,\n EXIT_MESSAGE VARCHAR(2500),\n ERROR_MESSAGE VARCHAR(2500),\n LAST_UPDATED TIMESTAMP,\n EXTERNAL_EXECUTION_ID VARCHAR(255),\n PARENT_EXECUTION_ID BIGINT\n)"
public static final String	CREATE_TASK_LOCK_TABLE	"CREATE TABLE TASK_LOCK (\n LOCK_KEY CHAR(36) NOT NULL,\n REGION VARCHAR(100) NOT NULL,\n CLIENT_ID CHAR(36),\n CREATED_DATE DATETIME(6) NOT NULL,\n constraint LOCK_PK primary key (LOCK_KEY, REGION)\n)"
public static final String	CREATE_TASK_TASK_BATCH	"CREATE TABLE TASK_TASK_BATCH (\n TASK_EXECUTION_ID BIGINT NOT NULL,\n JOB_EXECUTION_ID BIGINT NOT NULL,\n constraint TASK_EXEC_BATCH_FK foreign key (TASK_EXECUTION_ID)\n references TASK_EXECUTION(TASK_EXECUTION_ID)\n)"
public static final String	INSERT_BATCH_JOB_EXECUTION_SEQUENCE	"INSERT INTO BATCH_JOB_EXECUTION_SEQ (ID, UNIQUE_KEY) select * from (select 0 as ID, \'0\' as UNIQUE_KEY) as tmp where not exists(select * from BATCH_JOB_EXECUTION_SEQ)"
public static final String	INSERT_BATCH_JOB_SEQUENCE	"INSERT INTO BATCH_JOB_SEQ (ID, UNIQUE_KEY) select * from (select 0 as ID, \'0\' as UNIQUE_KEY) as tmp where not exists(select * from BATCH_JOB_SEQ)"
public static final String	INSERT_BATCH_STEP_EXECUTION_SEQUENCE	"INSERT INTO BATCH_STEP_EXECUTION_SEQ (ID, UNIQUE_KEY) select * from (select 0 as ID, \'0\' as UNIQUE_KEY) as tmp where not exists(select * from BATCH_STEP_EXECUTION_SEQ)"

org.springframework.cloud.dataflow.server.db.migration.mariadb.V2__Add_Descriptions_And_OriginalDefinition

Modifier and Type	Constant Field	Value
public static final String	ALTER_STREAM_DEFINITION_TABLE_DESC	"alter table stream_definitions add description varchar(255)"
public static final String	ALTER_STREAM_DEFINITION_TABLE_ORIG_DEF	"alter table stream_definitions add original_definition longtext"
public static final String	ALTER_TASK_DEFINITION_TABLE	"alter table task_definitions add description varchar(255)"
public static final String	CREATE_TASK_METADATA_SEQUENCE	"CREATE TABLE task_execution_metadata_seq (\n ID BIGINT NOT NULL,\n UNIQUE_KEY CHAR(1) NOT NULL,\n constraint UNIQUE_KEY_UN unique (UNIQUE_KEY)\n)"
public static final String	CREATE_TASK_METADATA_TABLE	"CREATE TABLE task_execution_metadata (\n id BIGINT NOT NULL,\n task_execution_id BIGINT NOT NULL,\n task_execution_manifest LONGTEXT,\n primary key (id),\n CONSTRAINT TASK_METADATA_FK FOREIGN KEY (task_execution_id)\n REFERENCES TASK_EXECUTION(TASK_EXECUTION_ID)\n)"
public static final String	INSERT_TASK_METADATA_SEQUENCE	"INSERT INTO task_execution_metadata_seq (ID, UNIQUE_KEY) select * from (select 0 as ID, \'0\' as UNIQUE_KEY) as tmp where not exists(select * from task_execution_metadata_seq)"
public static final String	UPDATE_STREAM_DEFINITION_TABLE_ORIG_DEF	"update stream_definitions set original_definition=definition"

org.springframework.cloud.dataflow.server.db.migration.mariadb.V3__Add_Platform_To_AuditRecords

Modifier and Type	Constant Field	Value
public static final String	ALTER_AUDIT_RECORDS_TABLE_PLATFORM	"alter table audit_records add platform_name varchar(255)"

org.springframework.cloud.dataflow.server.db.migration.mariadb.V4__Add_Step_Name_Indexes

Modifier and Type	Constant Field	Value
public static final String	ADD_INDEX_TO_BATCH_STEP_EXECUTION	"create index STEP_NAME_IDX on BATCH_STEP_EXECUTION (STEP_NAME)"

org.springframework.cloud.dataflow.server.db.migration.mariadb.V5__Add_Task_Execution_Params_Indexes

Modifier and Type	Constant Field	Value
public static final String	ADD_INDEX_TO_STEP_EXECUTION_PARAMS	"create index TASK_EXECUTION_ID_IDX on TASK_EXECUTION_PARAMS (TASK_EXECUTION_ID)"

org.springframework.cloud.dataflow.server.db.migration.mysql.MysqlBeforeBaseline

Modifier and Type	Constant Field	Value
public static final String	CREATE_AUDIT_RECORDS_AUDIT_ACTION_IDX_INDEX	"create index audit_records_audit_action_idx on audit_records (audit_action)"
public static final String	CREATE_AUDIT_RECORDS_AUDIT_OPERATION_IDX_INDEX	"create index audit_records_audit_operation_idx on audit_records (audit_operation)"
public static final String	CREATE_AUDIT_RECORDS_CORRELATION_ID_IDX_INDEX	"create index audit_records_correlation_id_idx on audit_records (correlation_id)"
public static final String	CREATE_AUDIT_RECORDS_CREATED_ON_IDX_INDEX	"create index audit_records_created_on_idx on audit_records (created_on)"
public static final String	DROP_APP_REGISTRATION_TABLE	"drop table APP_REGISTRATION"
public static final String	DROP_AUDIT_RECORDS_AUDIT_ACTION_IDX_INDEX	"drop index AUDIT_RECORDS_AUDIT_ACTION_IDX on AUDIT_RECORDS"
public static final String	DROP_AUDIT_RECORDS_AUDIT_OPERATION_IDX_INDEX	"drop index AUDIT_RECORDS_AUDIT_OPERATION_IDX on AUDIT_RECORDS"
public static final String	DROP_AUDIT_RECORDS_CORRELATION_ID_IDX_INDEX	"drop index AUDIT_RECORDS_CORRELATION_ID_IDX on AUDIT_RECORDS"
public static final String	DROP_AUDIT_RECORDS_CREATED_ON_IDX_INDEX	"drop index AUDIT_RECORDS_CREATED_ON_IDX on AUDIT_RECORDS"
public static final String	DROP_AUDIT_RECORDS_TABLE	"drop table AUDIT_RECORDS"
public static final String	DROP_STREAM_DEFINITIONS_TABLE	"drop table STREAM_DEFINITIONS"
public static final String	DROP_TASK_DEFINITIONS_TABLE	"drop table TASK_DEFINITIONS"
public static final String	INSERT_APP_REGISTRATION_DATA	"insert into\n app_registration_tmp (id, object_version, default_version, metadata_uri, name, type, uri, version) \n select id, object_Version, default_Version, metadata_Uri, name, type, uri, version\n from APP_REGISTRATION"
public static final String	INSERT_AUDIT_RECORDS_DATA	"insert into\n audit_records_tmp (id, audit_action, audit_data, audit_operation, correlation_id, created_by, created_on)\n select id, audit_Action, audit_data, audit_Operation, correlation_id, created_by, created_On\n from AUDIT_RECORDS"
public static final String	INSERT_STREAM_DEFINITIONS_DATA	"insert into\n stream_definitions_tmp (definition_name, definition) \n select DEFINITION_NAME, DEFINITION\n from STREAM_DEFINITIONS"
public static final String	INSERT_TASK_DEFINITIONS_DATA	"insert into\n task_definitions_tmp (definition_name, definition) \n select DEFINITION_NAME, DEFINITION\n from TASK_DEFINITIONS"
public static final String	RENAME_APP_REGISTRATION_TMP_TABLE	"alter table app_registration_tmp rename to app_registration"
public static final String	RENAME_AUDIT_RECORDS_TMP_TABLE	"alter table audit_records_tmp rename to audit_records"
public static final String	RENAME_STREAM_DEFINITIONS_TMP_TABLE	"alter table stream_definitions_tmp rename to stream_definitions"
public static final String	RENAME_TASK_DEFINITIONS_TMP_TABLE	"alter table task_definitions_tmp rename to task_definitions"

org.springframework.cloud.dataflow.server.db.migration.mysql.V1__Initial_Setup

Modifier and Type	Constant Field	Value
public static final String	CREATE_APP_REGISTRATION_TABLE	"create table app_registration (\n id bigint not null,\n object_version bigint,\n default_version bit,\n metadata_uri longtext,\n name varchar(255),\n type integer,\n uri longtext,\n version varchar(255),\n primary key (id)\n)"
public static final String	CREATE_AUDIT_RECORDS_TABLE	"create table audit_records (\n id bigint not null,\n audit_action bigint,\n audit_data longtext,\n audit_operation bigint,\n correlation_id varchar(255),\n created_by varchar(255),\n created_on datetime,\n primary key (id)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION_CONTEXT (\n JOB_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n SHORT_CONTEXT VARCHAR(2500) NOT NULL,\n SERIALIZED_CONTEXT TEXT,\n constraint JOB_EXEC_CTX_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_PARAMS_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION_PARAMS (\n JOB_EXECUTION_ID BIGINT NOT NULL,\n TYPE_CD VARCHAR(6) NOT NULL,\n KEY_NAME VARCHAR(100) NOT NULL,\n STRING_VAL VARCHAR(250),\n DATE_VAL DATETIME DEFAULT NULL,\n LONG_VAL BIGINT,\n DOUBLE_VAL DOUBLE PRECISION,\n IDENTIFYING CHAR(1) NOT NULL,\n constraint JOB_EXEC_PARAMS_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_SEQUENCE	"CREATE TABLE BATCH_JOB_EXECUTION_SEQ (\n ID BIGINT NOT NULL,\n UNIQUE_KEY CHAR(1) NOT NULL,\n constraint UNIQUE_KEY_UN unique (UNIQUE_KEY)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION (\n JOB_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT,\n JOB_INSTANCE_ID BIGINT NOT NULL,\n CREATE_TIME DATETIME NOT NULL,\n START_TIME DATETIME DEFAULT NULL,\n END_TIME DATETIME DEFAULT NULL,\n STATUS VARCHAR(10),\n EXIT_CODE VARCHAR(2500),\n EXIT_MESSAGE VARCHAR(2500),\n LAST_UPDATED DATETIME,\n JOB_CONFIGURATION_LOCATION VARCHAR(2500) NULL,\n constraint JOB_INST_EXEC_FK foreign key (JOB_INSTANCE_ID)\n references BATCH_JOB_INSTANCE(JOB_INSTANCE_ID)\n)"
public static final String	CREATE_BATCH_JOB_INSTANCE_TABLE	"CREATE TABLE BATCH_JOB_INSTANCE (\n JOB_INSTANCE_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT,\n JOB_NAME VARCHAR(100) NOT NULL,\n JOB_KEY VARCHAR(32) NOT NULL,\n constraint JOB_INST_UN unique (JOB_NAME, JOB_KEY)\n)"
public static final String	CREATE_BATCH_JOB_SEQUENCE	"CREATE TABLE BATCH_JOB_SEQ (\n ID BIGINT NOT NULL,\n UNIQUE_KEY CHAR(1) NOT NULL,\n constraint UNIQUE_KEY_UN unique (UNIQUE_KEY)\n)"
public static final String	CREATE_BATCH_STEP_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BATCH_STEP_EXECUTION_CONTEXT (\n STEP_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n SHORT_CONTEXT VARCHAR(2500) NOT NULL,\n SERIALIZED_CONTEXT TEXT,\n constraint STEP_EXEC_CTX_FK foreign key (STEP_EXECUTION_ID)\n references BATCH_STEP_EXECUTION(STEP_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_STEP_EXECUTION_SEQUENCE	"CREATE TABLE BATCH_STEP_EXECUTION_SEQ (\n ID BIGINT NOT NULL,\n UNIQUE_KEY CHAR(1) NOT NULL,\n constraint UNIQUE_KEY_UN unique (UNIQUE_KEY)\n)"
public static final String	CREATE_BATCH_STEP_EXECUTION_TABLE	"CREATE TABLE BATCH_STEP_EXECUTION (\n STEP_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT NOT NULL,\n STEP_NAME VARCHAR(100) NOT NULL,\n JOB_EXECUTION_ID BIGINT NOT NULL,\n START_TIME DATETIME NOT NULL,\n END_TIME DATETIME DEFAULT NULL,\n STATUS VARCHAR(10),\n COMMIT_COUNT BIGINT,\n READ_COUNT BIGINT,\n FILTER_COUNT BIGINT,\n WRITE_COUNT BIGINT,\n READ_SKIP_COUNT BIGINT,\n WRITE_SKIP_COUNT BIGINT,\n PROCESS_SKIP_COUNT BIGINT,\n ROLLBACK_COUNT BIGINT,\n EXIT_CODE VARCHAR(2500),\n EXIT_MESSAGE VARCHAR(2500),\n LAST_UPDATED DATETIME,\n constraint JOB_EXEC_STEP_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_HIBERNATE_SEQUENCE_TABLE	"create table if not exists hibernate_sequence (\n next_val bigint\n)"
public static final String	CREATE_STREAM_DEFINITIONS_TABLE	"create table stream_definitions (\n definition_name varchar(255) not null,\n definition longtext,\n primary key (definition_name)\n)"
public static final String	CREATE_TASK_DEFINITIONS_TABLE	"create table task_definitions (\n definition_name varchar(255) not null,\n definition longtext,\n primary key (definition_name)\n)"
public static final String	CREATE_TASK_DEPLOYMENT_TABLE	"create table task_deployment (\n id bigint not null,\n object_version bigint,\n task_deployment_id varchar(255) not null,\n task_definition_name varchar(255) not null,\n platform_name varchar(255) not null,\n created_on datetime,\n primary key (id)\n)"
public static final String	CREATE_TASK_EXECUTION_PARAMS_TABLE	"CREATE TABLE TASK_EXECUTION_PARAMS (\n TASK_EXECUTION_ID BIGINT NOT NULL,\n TASK_PARAM VARCHAR(2500),\n constraint TASK_EXEC_PARAMS_FK foreign key (TASK_EXECUTION_ID)\n references TASK_EXECUTION(TASK_EXECUTION_ID)\n)"
public static final String	CREATE_TASK_EXECUTION_TABLE	"CREATE TABLE TASK_EXECUTION (\n TASK_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n START_TIME DATETIME DEFAULT NULL,\n END_TIME DATETIME DEFAULT NULL,\n TASK_NAME VARCHAR(100),\n EXIT_CODE INTEGER,\n EXIT_MESSAGE VARCHAR(2500),\n ERROR_MESSAGE VARCHAR(2500),\n LAST_UPDATED TIMESTAMP,\n EXTERNAL_EXECUTION_ID VARCHAR(255),\n PARENT_EXECUTION_ID BIGINT\n)"
public static final String	CREATE_TASK_LOCK_TABLE	"CREATE TABLE TASK_LOCK (\n LOCK_KEY CHAR(36) NOT NULL,\n REGION VARCHAR(100) NOT NULL,\n CLIENT_ID CHAR(36),\n CREATED_DATE DATETIME(6) NOT NULL,\n constraint LOCK_PK primary key (LOCK_KEY, REGION)\n)"
public static final String	CREATE_TASK_TASK_BATCH	"CREATE TABLE TASK_TASK_BATCH (\n TASK_EXECUTION_ID BIGINT NOT NULL,\n JOB_EXECUTION_ID BIGINT NOT NULL,\n constraint TASK_EXEC_BATCH_FK foreign key (TASK_EXECUTION_ID)\n references TASK_EXECUTION(TASK_EXECUTION_ID)\n)"
public static final String	INSERT_BATCH_JOB_EXECUTION_SEQUENCE	"INSERT INTO BATCH_JOB_EXECUTION_SEQ (ID, UNIQUE_KEY) select * from (select 0 as ID, \'0\' as UNIQUE_KEY) as tmp where not exists(select * from BATCH_JOB_EXECUTION_SEQ)"
public static final String	INSERT_BATCH_JOB_SEQUENCE	"INSERT INTO BATCH_JOB_SEQ (ID, UNIQUE_KEY) select * from (select 0 as ID, \'0\' as UNIQUE_KEY) as tmp where not exists(select * from BATCH_JOB_SEQ)"
public static final String	INSERT_BATCH_STEP_EXECUTION_SEQUENCE	"INSERT INTO BATCH_STEP_EXECUTION_SEQ (ID, UNIQUE_KEY) select * from (select 0 as ID, \'0\' as UNIQUE_KEY) as tmp where not exists(select * from BATCH_STEP_EXECUTION_SEQ)"
public static final String	INSERT_HIBERNATE_SEQUENCE_TABLE	"insert into hibernate_sequence (next_val)\n select * from (select 1 as next_val) as temp\n where not exists(select * from hibernate_sequence)"

org.springframework.cloud.dataflow.server.db.migration.mysql.V2__Add_Descriptions_And_OriginalDefinition

Modifier and Type	Constant Field	Value
public static final String	ALTER_STREAM_DEFINITION_TABLE_DESC	"alter table stream_definitions add description varchar(255)"
public static final String	ALTER_STREAM_DEFINITION_TABLE_ORIG_DEF	"alter table stream_definitions add original_definition longtext"
public static final String	ALTER_TASK_DEFINITION_TABLE	"alter table task_definitions add description varchar(255)"
public static final String	CREATE_TASK_METADATA_SEQUENCE	"CREATE TABLE task_execution_metadata_seq (\n ID BIGINT NOT NULL,\n UNIQUE_KEY CHAR(1) NOT NULL,\n constraint UNIQUE_KEY_UN unique (UNIQUE_KEY)\n)"
public static final String	CREATE_TASK_METADATA_TABLE	"CREATE TABLE task_execution_metadata (\n id BIGINT NOT NULL,\n task_execution_id BIGINT NOT NULL,\n task_execution_manifest LONGTEXT,\n primary key (id),\n CONSTRAINT TASK_METADATA_FK FOREIGN KEY (task_execution_id)\n REFERENCES TASK_EXECUTION(TASK_EXECUTION_ID)\n)"
public static final String	INSERT_TASK_METADATA_SEQUENCE	"INSERT INTO task_execution_metadata_seq (ID, UNIQUE_KEY) select * from (select 0 as ID, \'0\' as UNIQUE_KEY) as tmp where not exists(select * from task_execution_metadata_seq)"
public static final String	UPDATE_STREAM_DEFINITION_TABLE_ORIG_DEF	"update stream_definitions set original_definition=definition"

org.springframework.cloud.dataflow.server.db.migration.mysql.V3__Add_Platform_To_AuditRecords

Modifier and Type	Constant Field	Value
public static final String	ALTER_AUDIT_RECORDS_TABLE_PLATFORM	"alter table audit_records add platform_name varchar(255)"

org.springframework.cloud.dataflow.server.db.migration.mysql.V4__Add_Step_Name_Indexes

Modifier and Type	Constant Field	Value
public static final String	ADD_INDEX_TO_BATCH_STEP_EXECUTION	"create index STEP_NAME_IDX on BATCH_STEP_EXECUTION (STEP_NAME)"

org.springframework.cloud.dataflow.server.db.migration.mysql.V5__Add_Task_Execution_Params_Indexes

Modifier and Type	Constant Field	Value
public static final String	ADD_INDEX_TO_STEP_EXECUTION_PARAMS	"create index TASK_EXECUTION_ID_IDX on TASK_EXECUTION_PARAMS (TASK_EXECUTION_ID)"

org.springframework.cloud.dataflow.server.db.migration.oracle.OracleBeforeBaseline

Modifier and Type	Constant Field	Value
public static final String	CREATE_AUDIT_RECORDS_AUDIT_ACTION_IDX_INDEX	"create index audit_records_audit_action_idx on audit_records (audit_action)"
public static final String	CREATE_AUDIT_RECORDS_AUDIT_OPERATION_IDX_INDEX	"create index audit_records_audit_operation_idx on audit_records (audit_operation)"
public static final String	CREATE_AUDIT_RECORDS_CORRELATION_ID_IDX_INDEX	"create index audit_records_correlation_id_idx on audit_records (correlation_id)"
public static final String	CREATE_AUDIT_RECORDS_CREATED_ON_IDX_INDEX	"create index audit_records_created_on_idx on audit_records (created_on)"
public static final String	DROP_APP_REGISTRATION_TABLE	"drop table APP_REGISTRATION"
public static final String	DROP_AUDIT_RECORDS_AUDIT_ACTION_IDX_INDEX	"drop index AUDIT_RECORDS_AUDIT_ACTION_IDX"
public static final String	DROP_AUDIT_RECORDS_AUDIT_OPERATION_IDX_INDEX	"drop index AUDIT_RECORDS_AUDIT_OPERATION_IDX"
public static final String	DROP_AUDIT_RECORDS_CORRELATION_ID_IDX_INDEX	"drop index AUDIT_RECORDS_CORRELATION_ID_IDX"
public static final String	DROP_AUDIT_RECORDS_CREATED_ON_IDX_INDEX	"drop index AUDIT_RECORDS_CREATED_ON_IDX"
public static final String	DROP_AUDIT_RECORDS_TABLE	"drop table AUDIT_RECORDS"
public static final String	DROP_STREAM_DEFINITIONS_TABLE	"drop table STREAM_DEFINITIONS"
public static final String	DROP_TASK_DEFINITIONS_TABLE	"drop table TASK_DEFINITIONS"
public static final String	INSERT_APP_REGISTRATION_DATA	"insert into\n app_registration_tmp (id, object_version, default_version, metadata_uri, name, type, uri, version) \n select id, object_Version, default_Version, metadata_Uri, name, type, uri, version\n from APP_REGISTRATION"
public static final String	INSERT_AUDIT_RECORDS_DATA	"insert into\n audit_records_tmp (id, audit_action, audit_data, audit_operation, correlation_id, created_by, created_on)\n select id, audit_Action, audit_data, audit_Operation, correlation_id, created_by, created_On\n from AUDIT_RECORDS"
public static final String	INSERT_STREAM_DEFINITIONS_DATA	"insert into\n stream_definitions_tmp (definition_name, definition) \n select DEFINITION_NAME, DEFINITION\n from STREAM_DEFINITIONS"
public static final String	INSERT_TASK_DEFINITIONS_DATA	"insert into\n task_definitions_tmp (definition_name, definition) \n select DEFINITION_NAME, DEFINITION\n from TASK_DEFINITIONS"
public static final String	RENAME_APP_REGISTRATION_TMP_TABLE	"alter table app_registration_tmp rename to app_registration"
public static final String	RENAME_AUDIT_RECORDS_TMP_TABLE	"alter table audit_records_tmp rename to audit_records"
public static final String	RENAME_STREAM_DEFINITIONS_TMP_TABLE	"alter table stream_definitions_tmp rename to stream_definitions"
public static final String	RENAME_TASK_DEFINITIONS_TMP_TABLE	"alter table task_definitions_tmp rename to task_definitions"

org.springframework.cloud.dataflow.server.db.migration.oracle.V1__Initial_Setup

Modifier and Type	Constant Field	Value
public static final String	CREATE_APP_REGISTRATION_TABLE	"create table app_registration (\n id number(19,0) not null,\n object_version number(19,0),\n default_version number(1,0),\n metadata_uri clob,\n name varchar2(255 char),\n type number(10,0),\n uri clob,\n version varchar2(255 char),\n primary key (id)\n)"
public static final String	CREATE_AUDIT_RECORDS_TABLE	"create table audit_records (\n id number(19,0) not null,\n audit_action number(19,0),\n audit_data long,\n audit_operation number(19,0),\n correlation_id varchar2(255 char),\n created_by varchar2(255 char),\n created_on timestamp,\n primary key (id)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION_CONTEXT (\n JOB_EXECUTION_ID NUMBER(19,0) NOT NULL PRIMARY KEY,\n SHORT_CONTEXT VARCHAR2(2500 char) NOT NULL,\n SERIALIZED_CONTEXT CLOB,\n constraint JOB_EXEC_CTX_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_PARAMS_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION_PARAMS (\n JOB_EXECUTION_ID NUMBER(19,0) NOT NULL,\n TYPE_CD VARCHAR2(6 char) NOT NULL,\n KEY_NAME VARCHAR2(100 char) NOT NULL,\n STRING_VAL VARCHAR2(250 char),\n DATE_VAL TIMESTAMP DEFAULT NULL,\n LONG_VAL NUMBER(19,0),\n DOUBLE_VAL NUMBER,\n IDENTIFYING CHAR(1) NOT NULL,\n constraint JOB_EXEC_PARAMS_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_SEQUENCE	"CREATE SEQUENCE BATCH_JOB_EXECUTION_SEQ START WITH 1 MINVALUE 1 MAXVALUE 9223372036854775807 NOCYCLE"
public static final String	CREATE_BATCH_JOB_EXECUTION_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION (\n JOB_EXECUTION_ID NUMBER(19,0) NOT NULL PRIMARY KEY,\n VERSION NUMBER(19,0),\n JOB_INSTANCE_ID NUMBER(19,0) NOT NULL,\n CREATE_TIME TIMESTAMP NOT NULL,\n START_TIME TIMESTAMP DEFAULT NULL,\n END_TIME TIMESTAMP DEFAULT NULL,\n STATUS VARCHAR2(10 char),\n EXIT_CODE VARCHAR2(2500 char),\n EXIT_MESSAGE VARCHAR2(2500 char),\n LAST_UPDATED TIMESTAMP,\n JOB_CONFIGURATION_LOCATION VARCHAR(2500 char) NULL,\n constraint JOB_INST_EXEC_FK foreign key (JOB_INSTANCE_ID)\n references BATCH_JOB_INSTANCE(JOB_INSTANCE_ID)\n)"
public static final String	CREATE_BATCH_JOB_INSTANCE_TABLE	"CREATE TABLE BATCH_JOB_INSTANCE (\n JOB_INSTANCE_ID NUMBER(19,0) NOT NULL PRIMARY KEY,\n VERSION NUMBER(19,0),\n JOB_NAME VARCHAR2(100 char) NOT NULL,\n JOB_KEY VARCHAR2(32 char) NOT NULL,\n constraint JOB_INST_UN unique (JOB_NAME, JOB_KEY)\n)"
public static final String	CREATE_BATCH_JOB_SEQUENCE	"CREATE SEQUENCE BATCH_JOB_SEQ START WITH 1 MINVALUE 1 MAXVALUE 9223372036854775807 NOCYCLE"
public static final String	CREATE_BATCH_STEP_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BATCH_STEP_EXECUTION_CONTEXT (\n STEP_EXECUTION_ID NUMBER(19,0) NOT NULL PRIMARY KEY,\n SHORT_CONTEXT VARCHAR2(2500 char) NOT NULL,\n SERIALIZED_CONTEXT CLOB,\n constraint STEP_EXEC_CTX_FK foreign key (STEP_EXECUTION_ID)\n references BATCH_STEP_EXECUTION(STEP_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_STEP_EXECUTION_SEQUENCE	"CREATE SEQUENCE BATCH_STEP_EXECUTION_SEQ START WITH 1 MINVALUE 1 MAXVALUE 9223372036854775807 NOCYCLE"
public static final String	CREATE_BATCH_STEP_EXECUTION_TABLE	"CREATE TABLE BATCH_STEP_EXECUTION (\n STEP_EXECUTION_ID NUMBER(19,0) NOT NULL PRIMARY KEY,\n VERSION NUMBER(19,0) NOT NULL,\n STEP_NAME VARCHAR2(100 char) NOT NULL,\n JOB_EXECUTION_ID NUMBER(19,0) NOT NULL,\n START_TIME TIMESTAMP NOT NULL,\n END_TIME TIMESTAMP DEFAULT NULL,\n STATUS VARCHAR2(10 char),\n COMMIT_COUNT NUMBER(19,0),\n READ_COUNT NUMBER(19,0),\n FILTER_COUNT NUMBER(19,0),\n WRITE_COUNT NUMBER(19,0),\n READ_SKIP_COUNT NUMBER(19,0),\n WRITE_SKIP_COUNT NUMBER(19,0),\n PROCESS_SKIP_COUNT NUMBER(19,0),\n ROLLBACK_COUNT NUMBER(19,0),\n EXIT_CODE VARCHAR2(2500 char),\n EXIT_MESSAGE VARCHAR2(2500 char),\n LAST_UPDATED TIMESTAMP,\n constraint JOB_EXEC_STEP_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_STREAM_DEFINITIONS_TABLE	"create table stream_definitions (\n definition_name varchar2(255 char) not null,\n definition clob,\n primary key (definition_name)\n)"
public static final String	CREATE_TASK_DEFINITIONS_TABLE	"create table task_definitions (\n definition_name varchar2(255 char) not null,\n definition clob,\n primary key (definition_name)\n)"
public static final String	CREATE_TASK_DEPLOYMENT_TABLE	"create table task_deployment (\n id number(19,0) not null,\n object_version number(19,0),\n task_deployment_id varchar2(255 char) not null,\n task_definition_name varchar2(255 char) not null,\n platform_name varchar2(255 char) not null,\n created_on timestamp,\n primary key (id)\n)"
public static final String	CREATE_TASK_EXECUTION_PARAMS_TABLE	"CREATE TABLE TASK_EXECUTION_PARAMS (\n TASK_EXECUTION_ID NUMBER NOT NULL,\n TASK_PARAM VARCHAR2(2500),\n constraint TASK_EXEC_PARAMS_FK foreign key (TASK_EXECUTION_ID)\n references TASK_EXECUTION(TASK_EXECUTION_ID)\n)"
public static final String	CREATE_TASK_EXECUTION_TABLE	"CREATE TABLE TASK_EXECUTION (\n TASK_EXECUTION_ID NUMBER NOT NULL PRIMARY KEY,\n START_TIME TIMESTAMP DEFAULT NULL,\n END_TIME TIMESTAMP DEFAULT NULL,\n TASK_NAME VARCHAR2(100),\n EXIT_CODE INTEGER,\n EXIT_MESSAGE VARCHAR2(2500),\n ERROR_MESSAGE VARCHAR2(2500),\n LAST_UPDATED TIMESTAMP,\n EXTERNAL_EXECUTION_ID VARCHAR2(255),\n PARENT_EXECUTION_ID NUMBER\n)"
public static final String	CREATE_TASK_LOCK_TABLE	"CREATE TABLE TASK_LOCK (\n LOCK_KEY CHAR(36) NOT NULL,\n REGION VARCHAR(100) NOT NULL,\n CLIENT_ID CHAR(36),\n CREATED_DATE TIMESTAMP NOT NULL,\n constraint LOCK_PK primary key (LOCK_KEY, REGION)\n)"
public static final String	CREATE_TASK_TASK_BATCH	"CREATE TABLE TASK_TASK_BATCH (\n TASK_EXECUTION_ID NUMBER NOT NULL,\n JOB_EXECUTION_ID NUMBER NOT NULL,\n constraint TASK_EXEC_BATCH_FK foreign key (TASK_EXECUTION_ID)\n references TASK_EXECUTION(TASK_EXECUTION_ID)\n)"

org.springframework.cloud.dataflow.server.db.migration.oracle.V2__Add_Descriptions_And_OriginalDefinition

Modifier and Type	Constant Field	Value
public static final String	ALTER_STREAM_DEFINITION_TABLE_DESC	"alter table stream_definitions add description varchar2(255)"
public static final String	ALTER_STREAM_DEFINITION_TABLE_ORIG_DEF	"alter table stream_definitions add original_definition clob"
public static final String	ALTER_TASK_DEFINITION_TABLE	"alter table task_definitions add description varchar2(255)"
public static final String	CREATE_TASK_METADATA_TABLE	"CREATE TABLE task_execution_metadata (\n id number(19,0) NOT NULL,\n task_execution_id number(19,0) NOT NULL,\n task_execution_manifest CLOB,\n primary key (id),\n CONSTRAINT TASK_METADATA_FK FOREIGN KEY (task_execution_id)\n REFERENCES TASK_EXECUTION(TASK_EXECUTION_ID)\n)"
public static final String	UPDATE_STREAM_DEFINITION_TABLE_ORIG_DEF	"update stream_definitions set original_definition=definition"

org.springframework.cloud.dataflow.server.db.migration.oracle.V3__Add_Platform_To_AuditRecords

Modifier and Type	Constant Field	Value
public static final String	ALTER_AUDIT_RECORDS_TABLE_PLATFORM	"alter table audit_records add platform_name varchar2(255)"

org.springframework.cloud.dataflow.server.db.migration.oracle.V4__Add_Step_Name_Indexes

Modifier and Type	Constant Field	Value
public static final String	ADD_INDEX_TO_BATCH_STEP_EXECUTION	"create index STEP_NAME_IDX on BATCH_STEP_EXECUTION (STEP_NAME)"

org.springframework.cloud.dataflow.server.db.migration.oracle.V5__Add_Task_Execution_Params_Indexes

Modifier and Type	Constant Field	Value
public static final String	ADD_INDEX_TO_STEP_EXECUTION_PARAMS	"create index TASK_EXECUTION_ID_IDX on TASK_EXECUTION_PARAMS (TASK_EXECUTION_ID)"

org.springframework.cloud.dataflow.server.db.migration.oracle.V7__Boot3_Add_Task3_Batch5_Schema

Modifier and Type	Constant Field	Value
public static final String	CREATE_BATCH_JOB_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BOOT3_BATCH_JOB_EXECUTION_CONTEXT (\nJOB_EXECUTION_ID NUMBER(19,0) NOT NULL PRIMARY KEY,\nSHORT_CONTEXT VARCHAR2(2500 char) NOT NULL,\nSERIALIZED_CONTEXT CLOB,\n constraint BOOT3_JOB_EXEC_CTX_FK foreign key (JOB_EXECUTION_ID)\n references BOOT3_BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n) SEGMENT CREATION IMMEDIATE"
public static final String	CREATE_BATCH_JOB_EXECUTION_PARAMS_TABLE	"CREATE TABLE BOOT3_BATCH_JOB_EXECUTION_PARAMS (\nJOB_EXECUTION_ID NUMBER(19,0) NOT NULL,\nTYPE_CD VARCHAR2(6 char) NOT NULL,\nKEY_NAME VARCHAR2(100 char) NOT NULL,\nSTRING_VAL VARCHAR2(250 char),\nDATE_VAL TIMESTAMP(9) DEFAULT NULL,\nLONG_VAL NUMBER(19,0),\nDOUBLE_VAL NUMBER,\nIDENTIFYING CHAR(1) NOT NULL,\n constraint BOOT3_JOB_EXEC_PARAMS_FK foreign key (JOB_EXECUTION_ID)\n references BOOT3_BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n) SEGMENT CREATION IMMEDIATE"
public static final String	CREATE_BATCH_JOB_EXECUTION_SEQUENCE	"CREATE SEQUENCE BOOT3_BATCH_JOB_EXECUTION_SEQ START WITH 1 MINVALUE 1 MAXVALUE 9223372036854775806 INCREMENT BY 1 NOCACHE NOCYCLE"
public static final String	CREATE_BATCH_JOB_EXECUTION_TABLE	"CREATE TABLE BOOT3_BATCH_JOB_EXECUTION (\nJOB_EXECUTION_ID NUMBER(19,0) NOT NULL PRIMARY KEY,\nVERSION NUMBER(19,0),\nJOB_INSTANCE_ID NUMBER(19,0) NOT NULL,\nCREATE_TIME TIMESTAMP(9) NOT NULL,\nSTART_TIME TIMESTAMP(9) DEFAULT NULL,\nEND_TIME TIMESTAMP(9) DEFAULT NULL,\nSTATUS VARCHAR2(10 char),\nEXIT_CODE VARCHAR2(2500 char),\nEXIT_MESSAGE VARCHAR2(2500 char),\nLAST_UPDATED TIMESTAMP(9),\nJOB_CONFIGURATION_LOCATION VARCHAR(2500 char) NULL,\n constraint BOOT3_JOB_INST_EXEC_FK foreign key (JOB_INSTANCE_ID)\nreferences BOOT3_BATCH_JOB_INSTANCE(JOB_INSTANCE_ID)\n) SEGMENT CREATION IMMEDIATE"
public static final String	CREATE_BATCH_JOB_INSTANCE_TABLE	"CREATE TABLE BOOT3_BATCH_JOB_INSTANCE (\nJOB_INSTANCE_ID NUMBER(19,0) NOT NULL PRIMARY KEY ,\nVERSION NUMBER(19,0) ,\nJOB_NAME VARCHAR2(100 char) NOT NULL,\nJOB_KEY VARCHAR2(32 char) NOT NULL,\n constraint BOOT3_JOB_INST_UN unique (JOB_NAME, JOB_KEY)\n) SEGMENT CREATION IMMEDIATE"
public static final String	CREATE_BATCH_JOB_SEQUENCE	"CREATE SEQUENCE BOOT3_BATCH_JOB_SEQ START WITH 1 MINVALUE 1 MAXVALUE 9223372036854775806 INCREMENT BY 1 NOCACHE NOCYCLE"
public static final String	CREATE_BATCH_STEP_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BOOT3_BATCH_STEP_EXECUTION_CONTEXT (\nSTEP_EXECUTION_ID NUMBER(19,0) NOT NULL PRIMARY KEY,\nSHORT_CONTEXT VARCHAR2(2500 char) NOT NULL,\nSERIALIZED_CONTEXT CLOB,\n constraint BOOT3_STEP_EXEC_CTX_FK foreign key (STEP_EXECUTION_ID)\n references BOOT3_BATCH_STEP_EXECUTION(STEP_EXECUTION_ID)\n) SEGMENT CREATION IMMEDIATE"
public static final String	CREATE_BATCH_STEP_EXECUTION_SEQUENCE	"CREATE SEQUENCE BOOT3_BATCH_STEP_EXECUTION_SEQ START WITH 1 MINVALUE 1 MAXVALUE 9223372036854775806 INCREMENT BY 1 NOCACHE NOCYCLE"
public static final String	CREATE_BATCH_STEP_EXECUTION_TABLE	"CREATE TABLE BOOT3_BATCH_STEP_EXECUTION (\nSTEP_EXECUTION_ID NUMBER(19,0) NOT NULL PRIMARY KEY,\nVERSION NUMBER(19,0) NOT NULL,\nSTEP_NAME VARCHAR2(100 char) NOT NULL,\nJOB_EXECUTION_ID NUMBER(19,0) NOT NULL,\nCREATE_TIME TIMESTAMP(9) NOT NULL,\nSTART_TIME TIMESTAMP(9) DEFAULT NULL,\nEND_TIME TIMESTAMP(9) DEFAULT NULL,\nSTATUS VARCHAR2(10 char),\nCOMMIT_COUNT NUMBER(19,0),\nREAD_COUNT NUMBER(19,0),\nFILTER_COUNT NUMBER(19,0),\nWRITE_COUNT NUMBER(19,0),\nREAD_SKIP_COUNT NUMBER(19,0),\nWRITE_SKIP_COUNT NUMBER(19,0),\nPROCESS_SKIP_COUNT NUMBER(19,0),\nROLLBACK_COUNT NUMBER(19,0),\nEXIT_CODE VARCHAR2(2500 char),\nEXIT_MESSAGE VARCHAR2(2500 char),\nLAST_UPDATED TIMESTAMP(9),\n constraint BOOT3_JOB_EXEC_STEP_FK foreign key (JOB_EXECUTION_ID)\n references BOOT3_BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n) SEGMENT CREATION IMMEDIATE"
public static final String	CREATE_TASK_EXECUTION_PARAMS_TABLE	"CREATE TABLE BOOT3_TASK_EXECUTION_PARAMS (\nTASK_EXECUTION_ID NUMBER NOT NULL,\nTASK_PARAM VARCHAR2(2500),\n constraint BOOT3_TASK_EXEC_PARAMS_FK foreign key (TASK_EXECUTION_ID)\n references BOOT3_TASK_EXECUTION (TASK_EXECUTION_ID)\n)SEGMENT CREATION IMMEDIATE"
public static final String	CREATE_TASK_EXECUTION_TABLE	"CREATE TABLE BOOT3_TASK_EXECUTION (\nTASK_EXECUTION_ID NUMBER NOT NULL PRIMARY KEY ,\nSTART_TIME TIMESTAMP(9) DEFAULT NULL,\nEND_TIME TIMESTAMP(9) DEFAULT NULL,\nTASK_NAME VARCHAR2(100),\nEXIT_CODE INTEGER,\nEXIT_MESSAGE VARCHAR2(2500),\nERROR_MESSAGE VARCHAR2(2500),\nLAST_UPDATED TIMESTAMP(9),\nEXTERNAL_EXECUTION_ID VARCHAR2(255),\nPARENT_EXECUTION_ID NUMBER\n)SEGMENT CREATION IMMEDIATE"
public static final String	CREATE_TASK_LOCK_TABLE	"CREATE TABLE BOOT3_TASK_LOCK (\nLOCK_KEY VARCHAR2(36) NOT NULL,\nREGION VARCHAR2(100) NOT NULL,\nCLIENT_ID VARCHAR2(36),\nCREATED_DATE TIMESTAMP(9) NOT NULL,\nconstraint BOOT3_LOCK_PK primary key (LOCK_KEY, REGION)\n)SEGMENT CREATION IMMEDIATE"
public static final String	CREATE_TASK_TASK_BATCH	"CREATE TABLE BOOT3_TASK_TASK_BATCH (\nTASK_EXECUTION_ID NUMBER NOT NULL,\nJOB_EXECUTION_ID NUMBER NOT NULL,\n constraint BOOT3_EXEC_BATCH_FK foreign key (TASK_EXECUTION_ID)\n references BOOT3_TASK_EXECUTION(TASK_EXECUTION_ID)\n) SEGMENT CREATION IMMEDIATE"

org.springframework.cloud.dataflow.server.db.migration.oracle.V9__Boot3_Batch5_Job_Execution_Params_Column_Fix

Modifier and Type	Constant Field	Value
public static final String	ADD_COLUMNS_BATCH_JOB_EXECUTION_PARAMS_TABLE	"ALTER TABLE BOOT3_BATCH_JOB_EXECUTION_PARAMS ADD (\n PARAMETER_NAME VARCHAR(100 char) NOT NULL,\n PARAMETER_TYPE VARCHAR(100 char) NOT NULL,\n PARAMETER_VALUE VARCHAR(2500 char),\n\t IDENTIFYING CHAR(1) NOT NULL\n)"
public static final String	DROP_COLUMNS_BATCH_JOB_EXECUTION_PARAMS_TABLE	"ALTER TABLE BOOT3_BATCH_JOB_EXECUTION_PARAMS DROP (TYPE_CD, KEY_NAME, STRING_VAL, DATE_VAL, LONG_VAL, DOUBLE_VAL, IDENTIFYING)"

org.springframework.cloud.dataflow.server.db.migration.postgresql.PostgresBeforeBaseline

Modifier and Type	Constant Field	Value
public static final String	CREATE_AUDIT_RECORDS_AUDIT_ACTION_IDX_INDEX	"create index if not exists audit_records_audit_action_idx on audit_records (audit_action)"
public static final String	CREATE_AUDIT_RECORDS_AUDIT_OPERATION_IDX_INDEX	"create index if not exists audit_records_audit_operation_idx on audit_records (audit_operation)"
public static final String	CREATE_AUDIT_RECORDS_CORRELATION_ID_IDX_INDEX	"create index if not exists audit_records_correlation_id_idx on audit_records (correlation_id)"
public static final String	CREATE_AUDIT_RECORDS_CREATED_ON_IDX_INDEX	"create index if not exists audit_records_created_on_idx on audit_records (created_on)"
public static final String	DROP_APP_REGISTRATION_TABLE	"drop table APP_REGISTRATION"
public static final String	DROP_AUDIT_RECORDS_AUDIT_ACTION_IDX_INDEX	"drop index if exists AUDIT_RECORDS_AUDIT_ACTION_IDX"
public static final String	DROP_AUDIT_RECORDS_AUDIT_OPERATION_IDX_INDEX	"drop index if exists AUDIT_RECORDS_AUDIT_OPERATION_IDX"
public static final String	DROP_AUDIT_RECORDS_CORRELATION_ID_IDX_INDEX	"drop index if exists AUDIT_RECORDS_CORRELATION_ID_IDX"
public static final String	DROP_AUDIT_RECORDS_CREATED_ON_IDX_INDEX	"drop index if exists AUDIT_RECORDS_CREATED_ON_IDX"
public static final String	DROP_AUDIT_RECORDS_TABLE	"drop table AUDIT_RECORDS"
public static final String	DROP_STREAM_DEFINITIONS_TABLE	"drop table STREAM_DEFINITIONS"
public static final String	DROP_TASK_DEFINITIONS_TABLE	"drop table TASK_DEFINITIONS"
public static final String	INSERT_APP_REGISTRATION_DATA	"insert into\n app_registration_tmp (id, object_version, default_version, metadata_uri, name, type, uri, version) \n select id, object_Version, default_Version, metadata_Uri, name, type, uri, version\n from APP_REGISTRATION"
public static final String	INSERT_AUDIT_RECORDS_DATA	"insert into\n audit_records_tmp (id, audit_action, audit_data, audit_operation, correlation_id, created_by, created_on)\n select id, audit_Action, audit_data, audit_Operation, correlation_id, created_by, created_On\n from AUDIT_RECORDS"
public static final String	RENAME_APP_REGISTRATION_TMP_TABLE	"alter table app_registration_tmp rename to app_registration"
public static final String	RENAME_AUDIT_RECORDS_TMP_TABLE	"alter table audit_records_tmp rename to audit_records"
public static final String	RENAME_STREAM_DEFINITIONS_TMP_TABLE	"alter table stream_definitions_tmp rename to stream_definitions"
public static final String	RENAME_TASK_DEFINITIONS_TMP_TABLE	"alter table task_definitions_tmp rename to task_definitions"

org.springframework.cloud.dataflow.server.db.migration.postgresql.V1__Initial_Setup

Modifier and Type	Constant Field	Value
public static final String	CREATE_APP_REGISTRATION_TABLE	"create table app_registration (\n id int8 not null,\n object_version int8,\n default_version boolean,\n metadata_uri text,\n name varchar(255),\n type int4,\n uri text,\n version varchar(255),\n primary key (id)\n)"
public static final String	CREATE_AUDIT_RECORDS_TABLE	"create table audit_records (\n id int8 not null,\n audit_action int8,\n audit_data text,\n audit_operation int8,\n correlation_id varchar(255),\n created_by varchar(255),\n created_on timestamp,\n primary key (id)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION_CONTEXT (\n JOB_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n SHORT_CONTEXT VARCHAR(2500) NOT NULL,\n SERIALIZED_CONTEXT TEXT,\n constraint JOB_EXEC_CTX_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_PARAMS_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION_PARAMS (\n JOB_EXECUTION_ID BIGINT NOT NULL,\n TYPE_CD VARCHAR(6) NOT NULL,\n KEY_NAME VARCHAR(100) NOT NULL,\n STRING_VAL VARCHAR(250),\n DATE_VAL TIMESTAMP DEFAULT NULL,\n LONG_VAL BIGINT,\n DOUBLE_VAL DOUBLE PRECISION,\n IDENTIFYING CHAR(1) NOT NULL,\n constraint JOB_EXEC_PARAMS_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_SEQUENCE	"CREATE SEQUENCE BATCH_JOB_EXECUTION_SEQ MAXVALUE 9223372036854775807 NO CYCLE"
public static final String	CREATE_BATCH_JOB_EXECUTION_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION (\n JOB_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT,\n JOB_INSTANCE_ID BIGINT NOT NULL,\n CREATE_TIME TIMESTAMP NOT NULL,\n START_TIME TIMESTAMP DEFAULT NULL,\n END_TIME TIMESTAMP DEFAULT NULL,\n STATUS VARCHAR(10),\n EXIT_CODE VARCHAR(2500),\n EXIT_MESSAGE VARCHAR(2500),\n LAST_UPDATED TIMESTAMP,\n JOB_CONFIGURATION_LOCATION VARCHAR(2500) NULL,\n constraint JOB_INST_EXEC_FK foreign key (JOB_INSTANCE_ID)\n references BATCH_JOB_INSTANCE(JOB_INSTANCE_ID)\n)"
public static final String	CREATE_BATCH_JOB_INSTANCE_TABLE	"CREATE TABLE BATCH_JOB_INSTANCE (\n JOB_INSTANCE_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT,\n JOB_NAME VARCHAR(100) NOT NULL,\n JOB_KEY VARCHAR(32) NOT NULL,\n constraint JOB_INST_UN unique (JOB_NAME, JOB_KEY)\n)"
public static final String	CREATE_BATCH_JOB_SEQUENCE	"CREATE SEQUENCE BATCH_JOB_SEQ MAXVALUE 9223372036854775807 NO CYCLE"
public static final String	CREATE_BATCH_STEP_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BATCH_STEP_EXECUTION_CONTEXT (\n STEP_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n SHORT_CONTEXT VARCHAR(2500) NOT NULL,\n SERIALIZED_CONTEXT TEXT,\n constraint STEP_EXEC_CTX_FK foreign key (STEP_EXECUTION_ID)\n references BATCH_STEP_EXECUTION(STEP_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_STEP_EXECUTION_SEQUENCE	"CREATE SEQUENCE BATCH_STEP_EXECUTION_SEQ MAXVALUE 9223372036854775807 NO CYCLE"
public static final String	CREATE_BATCH_STEP_EXECUTION_TABLE	"CREATE TABLE BATCH_STEP_EXECUTION (\n STEP_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT NOT NULL,\n STEP_NAME VARCHAR(100) NOT NULL,\n JOB_EXECUTION_ID BIGINT NOT NULL,\n START_TIME TIMESTAMP NOT NULL,\n END_TIME TIMESTAMP DEFAULT NULL,\n STATUS VARCHAR(10),\n COMMIT_COUNT BIGINT,\n READ_COUNT BIGINT,\n FILTER_COUNT BIGINT,\n WRITE_COUNT BIGINT,\n READ_SKIP_COUNT BIGINT,\n WRITE_SKIP_COUNT BIGINT,\n PROCESS_SKIP_COUNT BIGINT,\n ROLLBACK_COUNT BIGINT,\n EXIT_CODE VARCHAR(2500),\n EXIT_MESSAGE VARCHAR(2500),\n LAST_UPDATED TIMESTAMP,\n constraint JOB_EXEC_STEP_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_STREAM_DEFINITIONS_TABLE	"create table stream_definitions (\n definition_name varchar(255) not null,\n definition text,\n primary key (definition_name)\n)"
public static final String	CREATE_TASK_DEFINITIONS_TABLE	"create table task_definitions (\n definition_name varchar(255) not null,\n definition text,\n primary key (definition_name)\n)"
public static final String	CREATE_TASK_DEPLOYMENT_TABLE	"create table task_deployment (\n id int8 not null,\n object_version int8,\n task_deployment_id varchar(255) not null,\n task_definition_name varchar(255) not null,\n platform_name varchar(255) not null,\n created_on timestamp,\n primary key (id)\n)"
public static final String	CREATE_TASK_EXECUTION_PARAMS_TABLE	"CREATE TABLE TASK_EXECUTION_PARAMS (\n TASK_EXECUTION_ID BIGINT NOT NULL,\n TASK_PARAM VARCHAR(2500),\n constraint TASK_EXEC_PARAMS_FK foreign key (TASK_EXECUTION_ID)\n references TASK_EXECUTION(TASK_EXECUTION_ID)\n)"
public static final String	CREATE_TASK_EXECUTION_TABLE	"CREATE TABLE TASK_EXECUTION (\n TASK_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n START_TIME TIMESTAMP DEFAULT NULL,\n END_TIME TIMESTAMP DEFAULT NULL,\n TASK_NAME VARCHAR(100),\n EXIT_CODE INTEGER,\n EXIT_MESSAGE VARCHAR(2500),\n ERROR_MESSAGE VARCHAR(2500),\n LAST_UPDATED TIMESTAMP,\n EXTERNAL_EXECUTION_ID VARCHAR(255),\n PARENT_EXECUTION_ID BIGINT\n)"
public static final String	CREATE_TASK_LOCK_TABLE	"CREATE TABLE TASK_LOCK (\n LOCK_KEY CHAR(36) NOT NULL,\n REGION VARCHAR(100) NOT NULL,\n CLIENT_ID CHAR(36),\n CREATED_DATE TIMESTAMP NOT NULL,\n constraint LOCK_PK primary key (LOCK_KEY, REGION)\n)"
public static final String	CREATE_TASK_TASK_BATCH	"CREATE TABLE TASK_TASK_BATCH (\n TASK_EXECUTION_ID BIGINT NOT NULL,\n JOB_EXECUTION_ID BIGINT NOT NULL,\n constraint TASK_EXEC_BATCH_FK foreign key (TASK_EXECUTION_ID)\n references TASK_EXECUTION(TASK_EXECUTION_ID)\n)"

org.springframework.cloud.dataflow.server.db.migration.postgresql.V2__Add_Descriptions_OriginalDefinition

Modifier and Type	Constant Field	Value
public static final String	ALTER_STREAM_DEFINITION_TABLE_DESC	"alter table stream_definitions add column description varchar(255)"
public static final String	ALTER_STREAM_DEFINITION_TABLE_ORIG_DEF	"alter table stream_definitions add column original_definition text"
public static final String	ALTER_TASK_DEFINITION_TABLE	"alter table task_definitions add column description varchar(255)"
public static final String	CREATE_TASK_METADATA_TABLE	"CREATE TABLE task_execution_metadata (\n id int8 NOT NULL,\n task_execution_id int8 NOT NULL,\n task_execution_manifest TEXT,\n primary key (id),\n CONSTRAINT TASK_METADATA_FK FOREIGN KEY (task_execution_id)\n REFERENCES TASK_EXECUTION(TASK_EXECUTION_ID)\n)"
public static final String	UPDATE_STREAM_DEFINITION_TABLE_ORIG_DEF	"update stream_definitions set original_definition=definition"

org.springframework.cloud.dataflow.server.db.migration.postgresql.V3__Add_Platform_To_AuditRecords

Modifier and Type	Constant Field	Value
public static final String	ALTER_AUDIT_RECORDS_TABLE_PLATFORM	"alter table audit_records add platform_name varchar(255)"

org.springframework.cloud.dataflow.server.db.migration.postgresql.V4__Add_Step_Name_Indexes

Modifier and Type	Constant Field	Value
public static final String	ADD_INDEX_TO_BATCH_STEP_EXECUTION	"create index STEP_NAME_IDX on BATCH_STEP_EXECUTION (STEP_NAME)"

org.springframework.cloud.dataflow.server.db.migration.postgresql.V5__Add_Task_Execution_Params_Indexes

Modifier and Type	Constant Field	Value
public static final String	ADD_INDEX_TO_STEP_EXECUTION_PARAMS	"create index TASK_EXECUTION_ID_IDX on TASK_EXECUTION_PARAMS (TASK_EXECUTION_ID)"

org.springframework.cloud.dataflow.server.db.migration.postgresql.V7__Boot3_Add_Task3_Batch5_Schema

Modifier and Type	Constant Field	Value
public static final String	CREATE_BATCH_JOB_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BOOT3_BATCH_JOB_EXECUTION_CONTEXT (\n JOB_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n SHORT_CONTEXT VARCHAR(2500) NOT NULL,\n SERIALIZED_CONTEXT TEXT,\n constraint BOOT3_JOB_EXEC_CTX_FK foreign key (JOB_EXECUTION_ID)\n references BOOT3_BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_PARAMS_TABLE	"CREATE TABLE BOOT3_BATCH_JOB_EXECUTION_PARAMS (\n JOB_EXECUTION_ID BIGINT NOT NULL,\n PARAMETER_NAME VARCHAR(100) NOT NULL,\n PARAMETER_TYPE VARCHAR(100) NOT NULL,\n PARAMETER_VALUE VARCHAR(2500),\n IDENTIFYING CHAR(1) NOT NULL,\n constraint BOOT3_JOB_EXEC_PARAMS_FK foreign key (JOB_EXECUTION_ID)\n references BOOT3_BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_SEQUENCE	"CREATE SEQUENCE BOOT3_BATCH_JOB_EXECUTION_SEQ MAXVALUE 9223372036854775807 NO CYCLE"
public static final String	CREATE_BATCH_JOB_EXECUTION_TABLE	"CREATE TABLE BOOT3_BATCH_JOB_EXECUTION (\n JOB_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT,\n JOB_INSTANCE_ID BIGINT NOT NULL,\n CREATE_TIME TIMESTAMP NOT NULL,\n START_TIME TIMESTAMP DEFAULT NULL,\n END_TIME TIMESTAMP DEFAULT NULL,\n STATUS VARCHAR(10),\n EXIT_CODE VARCHAR(2500),\n EXIT_MESSAGE VARCHAR(2500),\n LAST_UPDATED TIMESTAMP,\n JOB_CONFIGURATION_LOCATION VARCHAR(2500) NULL,\n constraint BOOT3_JOB_INST_EXEC_FK foreign key (JOB_INSTANCE_ID)\n references BOOT3_BATCH_JOB_INSTANCE(JOB_INSTANCE_ID)\n)"
public static final String	CREATE_BATCH_JOB_INSTANCE_TABLE	"CREATE TABLE BOOT3_BATCH_JOB_INSTANCE (\n JOB_INSTANCE_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT,\n JOB_NAME VARCHAR(100) NOT NULL,\n JOB_KEY VARCHAR(32) NOT NULL,\n constraint BOOT3_JOB_INST_UN unique (JOB_NAME, JOB_KEY)\n)"
public static final String	CREATE_BATCH_JOB_SEQUENCE	"CREATE SEQUENCE BOOT3_BATCH_JOB_SEQ MAXVALUE 9223372036854775807 NO CYCLE"
public static final String	CREATE_BATCH_STEP_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BOOT3_BATCH_STEP_EXECUTION_CONTEXT (\n STEP_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n SHORT_CONTEXT VARCHAR(2500) NOT NULL,\n SERIALIZED_CONTEXT TEXT,\n constraint BOOT3_STEP_EXEC_CTX_FK foreign key (STEP_EXECUTION_ID)\n references BOOT3_BATCH_STEP_EXECUTION(STEP_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_STEP_EXECUTION_SEQUENCE	"CREATE SEQUENCE BOOT3_BATCH_STEP_EXECUTION_SEQ MAXVALUE 9223372036854775807 NO CYCLE"
public static final String	CREATE_BATCH_STEP_EXECUTION_TABLE	"CREATE TABLE BOOT3_BATCH_STEP_EXECUTION (\n STEP_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT NOT NULL,\n STEP_NAME VARCHAR(100) NOT NULL,\n JOB_EXECUTION_ID BIGINT NOT NULL,\n CREATE_TIME TIMESTAMP NOT NULL,\n START_TIME TIMESTAMP DEFAULT NULL,\n END_TIME TIMESTAMP DEFAULT NULL,\n STATUS VARCHAR(10),\n COMMIT_COUNT BIGINT,\n READ_COUNT BIGINT,\n FILTER_COUNT BIGINT,\n WRITE_COUNT BIGINT,\n READ_SKIP_COUNT BIGINT,\n WRITE_SKIP_COUNT BIGINT,\n PROCESS_SKIP_COUNT BIGINT,\n ROLLBACK_COUNT BIGINT,\n EXIT_CODE VARCHAR(2500),\n EXIT_MESSAGE VARCHAR(2500),\n LAST_UPDATED TIMESTAMP,\n constraint BOOT3_JOB_EXEC_STEP_FK foreign key (JOB_EXECUTION_ID)\n references BOOT3_BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_TASK_EXECUTION_PARAMS_TABLE	"CREATE TABLE BOOT3_TASK_EXECUTION_PARAMS (\n TASK_EXECUTION_ID BIGINT NOT NULL,\n TASK_PARAM VARCHAR(2500),\n constraint BOOT3_TASK_EXEC_PARAMS_FK foreign key (TASK_EXECUTION_ID)\n references BOOT3_TASK_EXECUTION(TASK_EXECUTION_ID)\n)"
public static final String	CREATE_TASK_EXECUTION_TABLE	"CREATE TABLE BOOT3_TASK_EXECUTION (\n TASK_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n START_TIME TIMESTAMP DEFAULT NULL,\n END_TIME TIMESTAMP DEFAULT NULL,\n TASK_NAME VARCHAR(100),\n EXIT_CODE INTEGER,\n EXIT_MESSAGE VARCHAR(2500),\n ERROR_MESSAGE VARCHAR(2500),\n LAST_UPDATED TIMESTAMP,\n EXTERNAL_EXECUTION_ID VARCHAR(255),\n PARENT_EXECUTION_ID BIGINT\n)"
public static final String	CREATE_TASK_LOCK_TABLE	"CREATE TABLE BOOT3_TASK_LOCK (\n LOCK_KEY CHAR(36) NOT NULL,\n REGION VARCHAR(100) NOT NULL,\n CLIENT_ID CHAR(36),\n CREATED_DATE TIMESTAMP NOT NULL,\n constraint BOOT3_LOCK_PK primary key (LOCK_KEY, REGION)\n)"
public static final String	CREATE_TASK_TASK_BATCH	"CREATE TABLE BOOT3_TASK_TASK_BATCH (\n TASK_EXECUTION_ID BIGINT NOT NULL,\n JOB_EXECUTION_ID BIGINT NOT NULL,\n constraint BOOT3_EXEC_BATCH_FK foreign key (TASK_EXECUTION_ID)\n references BOOT3_TASK_EXECUTION(TASK_EXECUTION_ID)\n)"

org.springframework.cloud.dataflow.server.db.migration.sqlserver.MsSqlBeforeBaseline

Modifier and Type	Constant Field	Value
public static final String	CREATE_AUDIT_RECORDS_AUDIT_ACTION_IDX_INDEX	"create index audit_records_audit_action_idx on audit_records (audit_action)"
public static final String	CREATE_AUDIT_RECORDS_AUDIT_OPERATION_IDX_INDEX	"create index audit_records_audit_operation_idx on audit_records (audit_operation)"
public static final String	CREATE_AUDIT_RECORDS_CORRELATION_ID_IDX_INDEX	"create index audit_records_correlation_id_idx on audit_records (correlation_id)"
public static final String	CREATE_AUDIT_RECORDS_CREATED_ON_IDX_INDEX	"create index audit_records_created_on_idx on audit_records (created_on)"
public static final String	DROP_APP_REGISTRATION_TABLE	"drop table APP_REGISTRATION"
public static final String	DROP_AUDIT_RECORDS_AUDIT_ACTION_IDX_INDEX	"drop index if exists AUDIT_RECORDS_AUDIT_ACTION_IDX on audit_records"
public static final String	DROP_AUDIT_RECORDS_AUDIT_OPERATION_IDX_INDEX	"drop index if exists AUDIT_RECORDS_AUDIT_OPERATION_IDX on audit_records"
public static final String	DROP_AUDIT_RECORDS_CORRELATION_ID_IDX_INDEX	"drop index if exists AUDIT_RECORDS_CORRELATION_ID_IDX on audit_records"
public static final String	DROP_AUDIT_RECORDS_CREATED_ON_IDX_INDEX	"drop index if exists AUDIT_RECORDS_CREATED_ON_IDX on audit_records"
public static final String	DROP_AUDIT_RECORDS_TABLE	"drop table AUDIT_RECORDS"
public static final String	DROP_STREAM_DEFINITIONS_TABLE	"drop table STREAM_DEFINITIONS"
public static final String	DROP_TASK_DEFINITIONS_TABLE	"drop table TASK_DEFINITIONS"
public static final String	INSERT_APP_REGISTRATION_DATA	"insert into\n app_registration_tmp (id, object_version, default_version, metadata_uri, name, type, uri, version) \n select id, object_Version, default_Version, metadata_Uri, name, type, uri, version\n from APP_REGISTRATION"
public static final String	INSERT_AUDIT_RECORDS_DATA	"insert into\n audit_records_tmp (id, audit_action, audit_data, audit_operation, correlation_id, created_by, created_on)\n select id, audit_Action, audit_data, audit_Operation, correlation_id, created_by, created_On\n from AUDIT_RECORDS"
public static final String	INSERT_STREAM_DEFINITIONS_DATA	"insert into\n stream_definitions_tmp (definition_name, definition) \n select DEFINITION_NAME, DEFINITION\n from STREAM_DEFINITIONS"
public static final String	INSERT_TASK_DEFINITIONS_DATA	"insert into\n task_definitions_tmp (definition_name, definition) \n select DEFINITION_NAME, DEFINITION\n from TASK_DEFINITIONS"
public static final String	RENAME_APP_REGISTRATION_TMP_TABLE	"sp_rename \'app_registration_tmp\', \'app_registration\'"
public static final String	RENAME_AUDIT_RECORDS_TMP_TABLE	"sp_rename \'audit_records_tmp\', \'audit_records\'"
public static final String	RENAME_STREAM_DEFINITIONS_TMP_TABLE	"sp_rename \'stream_definitions_tmp\', \'stream_definitions\'"
public static final String	RENAME_TASK_DEFINITIONS_TMP_TABLE	"sp_rename \'task_definitions_tmp\', \'task_definitions\'"

org.springframework.cloud.dataflow.server.db.migration.sqlserver.V1__Initial_Setup

Modifier and Type	Constant Field	Value
public static final String	CREATE_APP_REGISTRATION_TABLE	"create table app_registration (\n id bigint not null,\n object_version bigint,\n default_version bit,\n metadata_uri varchar(MAX),\n name varchar(255),\n type int,\n uri varchar(MAX),\n version varchar(255),\n primary key (id)\n)"
public static final String	CREATE_AUDIT_RECORDS_TABLE	"create table audit_records (\n id bigint not null,\n audit_action bigint,\n audit_data varchar(MAX),\n audit_operation bigint,\n correlation_id varchar(255),\n created_by varchar(255),\n created_on datetime2,\n primary key (id)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION_CONTEXT (\n JOB_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n SHORT_CONTEXT VARCHAR(2500) NOT NULL,\n SERIALIZED_CONTEXT TEXT NULL,\n constraint JOB_EXEC_CTX_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_PARAMS_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION_PARAMS (\n JOB_EXECUTION_ID BIGINT NOT NULL,\n TYPE_CD VARCHAR(6) NOT NULL,\n KEY_NAME VARCHAR(100) NOT NULL,\n STRING_VAL VARCHAR(250) NULL,\n DATE_VAL DATETIME DEFAULT NULL,\n LONG_VAL BIGINT NULL,\n DOUBLE_VAL DOUBLE PRECISION NULL,\n IDENTIFYING CHAR(1) NOT NULL ,\n constraint JOB_EXEC_PARAMS_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_SEQUENCE	"CREATE TABLE BATCH_JOB_EXECUTION_SEQ (ID BIGINT IDENTITY)"
public static final String	CREATE_BATCH_JOB_EXECUTION_TABLE	"CREATE TABLE BATCH_JOB_EXECUTION (\n JOB_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT NULL,\n JOB_INSTANCE_ID BIGINT NOT NULL,\n CREATE_TIME DATETIME NOT NULL,\n START_TIME DATETIME DEFAULT NULL,\n END_TIME DATETIME DEFAULT NULL,\n STATUS VARCHAR(10) NULL,\n EXIT_CODE VARCHAR(2500) NULL,\n EXIT_MESSAGE VARCHAR(2500) NULL,\n LAST_UPDATED DATETIME NULL,\n JOB_CONFIGURATION_LOCATION VARCHAR(2500) NULL,\n constraint JOB_INST_EXEC_FK foreign key (JOB_INSTANCE_ID)\n references BATCH_JOB_INSTANCE(JOB_INSTANCE_ID)\n)"
public static final String	CREATE_BATCH_JOB_INSTANCE_TABLE	"CREATE TABLE BATCH_JOB_INSTANCE (\n JOB_INSTANCE_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT NULL,\n JOB_NAME VARCHAR(100) NOT NULL,\n JOB_KEY VARCHAR(32) NOT NULL,\n constraint JOB_INST_UN unique (JOB_NAME, JOB_KEY)\n)"
public static final String	CREATE_BATCH_JOB_SEQUENCE	"CREATE TABLE BATCH_JOB_SEQ (ID BIGINT IDENTITY)"
public static final String	CREATE_BATCH_STEP_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BATCH_STEP_EXECUTION_CONTEXT (\n STEP_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n SHORT_CONTEXT VARCHAR(2500) NOT NULL,\n SERIALIZED_CONTEXT TEXT NULL,\n constraint STEP_EXEC_CTX_FK foreign key (STEP_EXECUTION_ID)\n references BATCH_STEP_EXECUTION(STEP_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_STEP_EXECUTION_SEQUENCE	"CREATE TABLE BATCH_STEP_EXECUTION_SEQ (ID BIGINT IDENTITY)"
public static final String	CREATE_BATCH_STEP_EXECUTION_TABLE	"CREATE TABLE BATCH_STEP_EXECUTION (\n STEP_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT NOT NULL,\n STEP_NAME VARCHAR(100) NOT NULL,\n JOB_EXECUTION_ID BIGINT NOT NULL,\n START_TIME DATETIME NOT NULL,\n END_TIME DATETIME DEFAULT NULL,\n STATUS VARCHAR(10) NULL,\n COMMIT_COUNT BIGINT NULL,\n READ_COUNT BIGINT NULL,\n FILTER_COUNT BIGINT NULL,\n WRITE_COUNT BIGINT NULL,\n READ_SKIP_COUNT BIGINT NULL,\n WRITE_SKIP_COUNT BIGINT NULL,\n PROCESS_SKIP_COUNT BIGINT NULL,\n ROLLBACK_COUNT BIGINT NULL,\n EXIT_CODE VARCHAR(2500) NULL,\n EXIT_MESSAGE VARCHAR(2500) NULL,\n LAST_UPDATED DATETIME NULL,\n constraint JOB_EXEC_STEP_FK foreign key (JOB_EXECUTION_ID)\n references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_STREAM_DEFINITIONS_TABLE	"create table stream_definitions (\n definition_name varchar(255) not null,\n definition varchar(MAX),\n primary key (definition_name)\n)"
public static final String	CREATE_TASK_DEFINITIONS_TABLE	"create table task_definitions (\n definition_name varchar(255) not null,\n definition varchar(MAX),\n primary key (definition_name)\n)"
public static final String	CREATE_TASK_DEPLOYMENT_TABLE	"create table task_deployment (\n id bigint not null,\n object_version bigint,\n task_deployment_id varchar(255) not null,\n task_definition_name varchar(255) not null,\n platform_name varchar(255) not null,\n created_on datetime2,\n primary key (id)\n)"
public static final String	CREATE_TASK_EXECUTION_PARAMS_TABLE	"CREATE TABLE TASK_EXECUTION_PARAMS (\n TASK_EXECUTION_ID BIGINT NOT NULL,\n TASK_PARAM VARCHAR(2500),\n constraint TASK_EXEC_PARAMS_FK foreign key (TASK_EXECUTION_ID)\n references TASK_EXECUTION(TASK_EXECUTION_ID)\n)"
public static final String	CREATE_TASK_EXECUTION_TABLE	"CREATE TABLE TASK_EXECUTION (\n TASK_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n START_TIME DATETIME DEFAULT NULL,\n END_TIME DATETIME DEFAULT NULL,\n TASK_NAME VARCHAR(100),\n EXIT_CODE INTEGER,\n EXIT_MESSAGE VARCHAR(2500),\n ERROR_MESSAGE VARCHAR(2500),\n LAST_UPDATED DATETIME,\n EXTERNAL_EXECUTION_ID VARCHAR(255),\n PARENT_EXECUTION_ID BIGINT\n)"
public static final String	CREATE_TASK_LOCK_TABLE	"CREATE TABLE TASK_LOCK (\n LOCK_KEY CHAR(36) NOT NULL,\n REGION VARCHAR(100) NOT NULL,\n CLIENT_ID CHAR(36),\n CREATED_DATE DATETIME NOT NULL,\n constraint LOCK_PK primary key (LOCK_KEY, REGION)\n)"
public static final String	CREATE_TASK_TASK_BATCH	"CREATE TABLE TASK_TASK_BATCH (\n TASK_EXECUTION_ID BIGINT NOT NULL,\n JOB_EXECUTION_ID BIGINT NOT NULL,\n constraint TASK_EXEC_BATCH_FK foreign key (TASK_EXECUTION_ID)\n references TASK_EXECUTION(TASK_EXECUTION_ID)\n)"

org.springframework.cloud.dataflow.server.db.migration.sqlserver.V2__Add_Descriptions_And_OriginalDefinition

Modifier and Type	Constant Field	Value
public static final String	ALTER_STREAM_DEFINITION_TABLE_DESC	"alter table stream_definitions add description varchar(255)"
public static final String	ALTER_STREAM_DEFINITION_TABLE_ORIG_DEF	"alter table stream_definitions add original_definition varchar(MAX)"
public static final String	ALTER_TASK_DEFINITION_TABLE	"alter table task_definitions add description varchar(255)"
public static final String	CREATE_TASK_METADATA_SEQUENCE	"CREATE TABLE task_execution_metadata_seq (\n ID BIGINT IDENTITY)"
public static final String	CREATE_TASK_METADATA_TABLE	"CREATE TABLE task_execution_metadata (\n id BIGINT NOT NULL PRIMARY KEY,\n task_execution_id BIGINT NOT NULL,\n task_execution_manifest text,\n CONSTRAINT TASK_METADATA_FK FOREIGN KEY (task_execution_id)\n REFERENCES TASK_EXECUTION(TASK_EXECUTION_ID)\n)"
public static final String	UPDATE_STREAM_DEFINITION_TABLE_ORIG_DEF	"update stream_definitions set original_definition=definition"

org.springframework.cloud.dataflow.server.db.migration.sqlserver.V3__Add_Platform_To_AuditRecords

Modifier and Type	Constant Field	Value
public static final String	ALTER_AUDIT_RECORDS_TABLE_PLATFORM	"alter table audit_records add platform_name varchar(255)"

org.springframework.cloud.dataflow.server.db.migration.sqlserver.V4__Add_Step_Name_Indexes

Modifier and Type	Constant Field	Value
public static final String	ADD_INDEX_TO_BATCH_STEP_EXECUTION	"create index STEP_NAME_IDX on BATCH_STEP_EXECUTION (STEP_NAME)"

org.springframework.cloud.dataflow.server.db.migration.sqlserver.V5__Add_Task_Execution_Params_Indexes

Modifier and Type	Constant Field	Value
public static final String	ADD_INDEX_TO_STEP_EXECUTION_PARAMS	"create index TASK_EXECUTION_ID_IDX on TASK_EXECUTION_PARAMS (TASK_EXECUTION_ID)"

org.springframework.cloud.dataflow.server.db.migration.sqlserver.V7__Boot3_Add_Task3_Batch5_Schema

Modifier and Type	Constant Field	Value
public static final String	CREATE_BATCH_JOB_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BOOT3_BATCH_JOB_EXECUTION_CONTEXT (\n JOB_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n SHORT_CONTEXT VARCHAR(2500) NOT NULL,\n SERIALIZED_CONTEXT TEXT,\n constraint BOOT3_JOB_EXEC_CTX_FK foreign key (JOB_EXECUTION_ID)\n references BOOT3_BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_PARAMS_TABLE	"CREATE TABLE BOOT3_BATCH_JOB_EXECUTION_PARAMS (\n JOB_EXECUTION_ID BIGINT NOT NULL,\n PARAMETER_NAME VARCHAR(100) NOT NULL,\n PARAMETER_TYPE VARCHAR(100) NOT NULL,\n PARAMETER_VALUE VARCHAR(2500),\n IDENTIFYING CHAR(1) NOT NULL,\n constraint BOOT3_JOB_EXEC_PARAMS_FK foreign key (JOB_EXECUTION_ID)\n references BOOT3_BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_JOB_EXECUTION_SEQUENCE	"CREATE SEQUENCE BOOT3_BATCH_JOB_EXECUTION_SEQ START WITH 1 MINVALUE 1 MAXVALUE 9223372036854775807 NO CACHE NO CYCLE"
public static final String	CREATE_BATCH_JOB_EXECUTION_TABLE	"CREATE TABLE BOOT3_BATCH_JOB_EXECUTION (\n JOB_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT,\n JOB_INSTANCE_ID BIGINT NOT NULL,\n CREATE_TIME DATETIME2 NOT NULL,\n START_TIME DATETIME2 DEFAULT NULL,\n END_TIME DATETIME2 DEFAULT NULL,\n STATUS VARCHAR(10),\n EXIT_CODE VARCHAR(2500),\n EXIT_MESSAGE VARCHAR(2500),\n LAST_UPDATED DATETIME2,\n JOB_CONFIGURATION_LOCATION VARCHAR(2500) NULL,\n constraint BOOT3_JOB_INST_EXEC_FK foreign key (JOB_INSTANCE_ID)\n references BOOT3_BATCH_JOB_INSTANCE(JOB_INSTANCE_ID)\n)"
public static final String	CREATE_BATCH_JOB_INSTANCE_TABLE	"CREATE TABLE BOOT3_BATCH_JOB_INSTANCE (\n JOB_INSTANCE_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT,\n JOB_NAME VARCHAR(100) NOT NULL,\n JOB_KEY VARCHAR(32) NOT NULL,\n constraint BOOT3_JOB_INST_UN unique (JOB_NAME, JOB_KEY)\n)"
public static final String	CREATE_BATCH_JOB_SEQUENCE	"CREATE SEQUENCE BOOT3_BATCH_JOB_SEQ START WITH 1 MINVALUE 1 MAXVALUE 9223372036854775807 NO CACHE NO CYCLE"
public static final String	CREATE_BATCH_STEP_EXECUTION_CONTEXT_TABLE	"CREATE TABLE BOOT3_BATCH_STEP_EXECUTION_CONTEXT (\n STEP_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n SHORT_CONTEXT VARCHAR(2500) NOT NULL,\n SERIALIZED_CONTEXT TEXT,\n constraint BOOT3_STEP_EXEC_CTX_FK foreign key (STEP_EXECUTION_ID)\n references BOOT3_BATCH_STEP_EXECUTION(STEP_EXECUTION_ID)\n)"
public static final String	CREATE_BATCH_STEP_EXECUTION_SEQUENCE	"CREATE SEQUENCE BOOT3_BATCH_STEP_EXECUTION_SEQ START WITH 1 MINVALUE 1 MAXVALUE 9223372036854775807 NO CACHE NO CYCLE"
public static final String	CREATE_BATCH_STEP_EXECUTION_TABLE	"CREATE TABLE BOOT3_BATCH_STEP_EXECUTION (\n STEP_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n VERSION BIGINT NOT NULL,\n STEP_NAME VARCHAR(100) NOT NULL,\n JOB_EXECUTION_ID BIGINT NOT NULL,\n CREATE_TIME DATETIME2 NOT NULL,\n START_TIME DATETIME2 NOT NULL,\n END_TIME DATETIME2 DEFAULT NULL,\n STATUS VARCHAR(10),\n COMMIT_COUNT BIGINT,\n READ_COUNT BIGINT,\n FILTER_COUNT BIGINT,\n WRITE_COUNT BIGINT,\n READ_SKIP_COUNT BIGINT,\n WRITE_SKIP_COUNT BIGINT,\n PROCESS_SKIP_COUNT BIGINT,\n ROLLBACK_COUNT BIGINT,\n EXIT_CODE VARCHAR(2500),\n EXIT_MESSAGE VARCHAR(2500),\n LAST_UPDATED DATETIME2,\n constraint BOOT3_JOB_EXEC_STEP_FK foreign key (JOB_EXECUTION_ID)\n references BOOT3_BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)\n)"
public static final String	CREATE_TASK_EXECUTION_METADATA_SEQ	"CREATE SEQUENCE BOOT3_TASK_EXECUTION_METADATA_SEQ START WITH 1 MINVALUE 1 MAXVALUE 9223372036854775807 NO CACHE NO CYCLE"
public static final String	CREATE_TASK_EXECUTION_METADATA_TABLE	"CREATE TABLE BOOT3_TASK_EXECUTION_METADATA (\n ID BIGINT NOT NULL,\n TASK_EXECUTION_ID BIGINT NOT NULL,\n TASK_EXECUTION_MANIFEST VARCHAR(MAX) NULL,\n primary key (ID),\n CONSTRAINT BOOT3_TASK_METADATA_FK FOREIGN KEY (TASK_EXECUTION_ID) REFERENCES BOOT3_TASK_EXECUTION (TASK_EXECUTION_ID)\n)"
public static final String	CREATE_TASK_EXECUTION_PARAMS_TABLE	"CREATE TABLE BOOT3_TASK_EXECUTION_PARAMS (\n TASK_EXECUTION_ID BIGINT NOT NULL,\n TASK_PARAM VARCHAR(2500),\n constraint BOOT3_TASK_EXEC_PARAMS_FK foreign key (TASK_EXECUTION_ID)\n references BOOT3_TASK_EXECUTION(TASK_EXECUTION_ID)\n)"
public static final String	CREATE_TASK_EXECUTION_TABLE	"CREATE TABLE BOOT3_TASK_EXECUTION (\n TASK_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY,\n START_TIME DATETIME2 DEFAULT NULL,\n END_TIME DATETIME2 DEFAULT NULL,\n TASK_NAME VARCHAR(100),\n EXIT_CODE INTEGER,\n EXIT_MESSAGE VARCHAR(2500),\n ERROR_MESSAGE VARCHAR(2500),\n LAST_UPDATED DATETIME2,\n EXTERNAL_EXECUTION_ID VARCHAR(255),\n PARENT_EXECUTION_ID BIGINT\n)"
public static final String	CREATE_TASK_LOCK_TABLE	"CREATE TABLE BOOT3_TASK_LOCK (\n LOCK_KEY CHAR(36) NOT NULL,\n REGION VARCHAR(100) NOT NULL,\n CLIENT_ID CHAR(36),\n CREATED_DATE DATETIME2 NOT NULL,\n constraint BOOT3_LOCK_PK primary key (LOCK_KEY, REGION)\n)"
public static final String	CREATE_TASK_TASK_BATCH	"CREATE TABLE BOOT3_TASK_TASK_BATCH (\n TASK_EXECUTION_ID BIGINT NOT NULL,\n JOB_EXECUTION_ID BIGINT NOT NULL,\n constraint BOOT3_EXEC_BATCH_FK foreign key (TASK_EXECUTION_ID)\n references BOOT3_TASK_EXECUTION(TASK_EXECUTION_ID)\n)"

org.springframework.cloud.dataflow.server.service.SchedulerServiceProperties

Modifier and Type	Constant Field	Value
public static final int	SCHEDULER_MAX_RETURNED_NUMBER	10000
public static final String	SCHEDULER_SERVICE_PREFIX	"spring.cloud.dataflow.scheduler.service"

org.springframework.cloud.dataflow.server.service.impl.DefaultStreamService

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_SKIPPER_PACKAGE_VERSION	"1.0.0"

org.springframework.cloud.dataflow.server.service.impl.DefaultTaskExecutionService

Modifier and Type	Constant Field	Value
public static final String	COMMAND_LINE_ARGS	"commandLineArgs"
public static final String	TASK_DEFINITION_DSL_TEXT	"taskDefinitionDslText"
public static final String	TASK_DEPLOYMENT_PROPERTIES	"taskDeploymentProperties"
public static final String	TASK_PLATFORM_NAME	"spring.cloud.dataflow.task.platformName"

org.springframework.cloud.dataflow.server.service.impl.TaskConfigurationProperties

Modifier and Type	Constant Field	Value
public static final String	COMPOSED_TASK_RUNNER_NAME	"composed-task-runner"
public static final String	TASK_PREFIX	"spring.cloud.dataflow.task"

org.springframework.cloud.dataflow.server.task.impl.DefaultDataFlowTaskExecutionQueryDao

Modifier and Type	Constant Field	Value
public static final String	FROM_CLAUSE	"TASK_EXECUTION"
public static final String	SELECT_CLAUSE	"TASK_EXECUTION_ID, START_TIME, END_TIME, TASK_NAME, EXIT_CODE, EXIT_MESSAGE, ERROR_MESSAGE, LAST_UPDATED, EXTERNAL_EXECUTION_ID, PARENT_EXECUTION_ID"

org.springframework.cloud.dataflow.shell.Target

Modifier and Type	Constant Field	Value
public static final String	DEFAULT_CLIENT_REGISTRATION_ID	"dataflow-shell"
public static final String	DEFAULT_CREDENTIALS_PROVIDER_COMMAND	""
public static final String	DEFAULT_HOST	"localhost"
public static final String	DEFAULT_PASSWORD	""
public static final int	DEFAULT_PORT	9393
public static final String	DEFAULT_PROXY_PASSWORD	""
public static final String	DEFAULT_PROXY_URI	""
public static final String	DEFAULT_PROXY_USERNAME	""
public static final String	DEFAULT_SCHEME	"http"
public static final String	DEFAULT_SKIP_SSL_VALIDATION	"true"
public static final String	DEFAULT_TARGET	"http://localhost:9393/"
public static final String	DEFAULT_USERNAME	""

org.springframework.cloud.dataflow.shell.converter.NumberFormatConverter

Modifier and Type	Constant Field	Value
public static final String	DEFAULT	"<use platform locale>"