元数据架构

附录 A:元数据架构

概述

Spring Batch Metadata 表与在 Java。例如JobInstance,JobExecution,JobParametersStepExecution映射到BATCH_JOB_INSTANCE,BATCH_JOB_EXECUTION,BATCH_JOB_EXECUTION_PARAMSBATCH_STEP_EXECUTION分别。ExecutionContext映射到两者BATCH_JOB_EXECUTION_CONTEXTBATCH_STEP_EXECUTION_CONTEXT.这JobRepository是 负责将每个 Java 对象保存并存储到其正确的表中。本附录 详细描述了元数据表,以及许多设计决策 是在创建它们时制作的。查看所描述的各种表创建语句时 在本附录的后面部分,请注意,使用的数据类型尽可能通用。Spring Batch 提供了许多架构作为示例。它们都有不同的数据类型,因为 各个数据库提供商处理数据类型的方式的变化。下图 显示了所有六个表及其相互关系的 ERD 模型:spring-doc.cadn.net.cn

Spring Batch 元数据 ERD
图 1.Spring Batch 元数据 ERD

DDL 脚本示例

Spring Batch Core JAR 文件包含用于创建关系表的示例脚本 对于许多数据库平台(这些平台又由作业自动检测到 存储库工厂 bean 或命名空间等效项)。这些脚本可以按原样使用,或者 根据需要使用其他索引和约束进行修改。文件名位于 形式schema-*.sql,其中是目标数据库平台的简称。 脚本在包中*org.springframework.batch.core.spring-doc.cadn.net.cn

迁移 DDL 脚本

Spring Batch 提供了升级版本时需要执行的迁移 DDL 脚本。 这些脚本可以在 Core Jar 文件中的org/springframework/batch/core/migration. 迁移脚本组织到与引入它们的版本号相对应的文件夹中:spring-doc.cadn.net.cn

版本

本附录中讨论的许多数据库表都包含版本列。这 列很重要,因为 Spring Batch 在 处理数据库的更新。这意味着每次“触摸”记录时 (已更新),则版本列中的值将递增 1。当存储库离开时 返回保存值,如果版本号已更改,则会抛出OptimisticLockingFailureException,表示 concurrent 出现错误 访问。此检查是必要的,因为即使可能正在运行不同的批处理作业 在不同的机器上,它们都使用相同的数据库表。spring-doc.cadn.net.cn

身份

BATCH_JOB_INSTANCE,BATCH_JOB_EXECUTIONBATCH_STEP_EXECUTION每个包含 以_ID.这些字段充当各自表的主键。 但是,它们不是数据库生成的密钥。相反,它们是由单独的 序列。这是必要的,因为在将其中一个域对象插入到 数据库,需要在实际对象上设置给定的键,以便它们可以 在 Java 中唯一标识。较新的数据库驱动程序(JDBC 3.0 及更高版本)支持此功能 具有数据库生成键的功能。但是,与其要求该功能, 序列。架构的每个变体都包含以下某种形式 语句:spring-doc.cadn.net.cn

CREATE SEQUENCE BATCH_STEP_EXECUTION_SEQ;
CREATE SEQUENCE BATCH_JOB_EXECUTION_SEQ;
CREATE SEQUENCE BATCH_JOB_SEQ;

许多数据库提供商不支持序列。在这些情况下,使用解决方法 比如MySQL的以下语句:spring-doc.cadn.net.cn

CREATE TABLE BATCH_STEP_EXECUTION_SEQ (ID BIGINT NOT NULL) type=InnoDB;
INSERT INTO BATCH_STEP_EXECUTION_SEQ values(0);
CREATE TABLE BATCH_JOB_EXECUTION_SEQ (ID BIGINT NOT NULL) type=InnoDB;
INSERT INTO BATCH_JOB_EXECUTION_SEQ values(0);
CREATE TABLE BATCH_JOB_SEQ (ID BIGINT NOT NULL) type=InnoDB;
INSERT INTO BATCH_JOB_SEQ values(0);

在前面的案例中,使用表代替每个序列。Spring 核心类MySQLMaxValueIncrementer,然后将此序列中的一列递增为 提供类似的功能。spring-doc.cadn.net.cn

BATCH_JOB_INSTANCE桌子

BATCH_JOB_INSTANCE表包含与JobInstance和 作为整体层次结构的顶端。使用以下通用 DDL 语句 要创建它:spring-doc.cadn.net.cn

CREATE TABLE BATCH_JOB_INSTANCE  (
  JOB_INSTANCE_ID BIGINT  PRIMARY KEY ,
  VERSION BIGINT,
  JOB_NAME VARCHAR(100) NOT NULL ,
  JOB_KEY VARCHAR(32) NOT NULL
);

以下列表描述了表中的每一列:spring-doc.cadn.net.cn

  • JOB_INSTANCE_ID:标识实例的唯一 ID。它也是主要的 钥匙。此列的值应该可以通过调用getId方法JobInstance.spring-doc.cadn.net.cn

  • VERSION:请参阅版本spring-doc.cadn.net.cn

  • JOB_NAME:从Job对象。因为它需要 标识实例,它不得为 null。spring-doc.cadn.net.cn

  • JOB_KEY:序列化JobParameters唯一标识单独的 同一作业的实例。(JobInstances必须具有相同作业名称 有不同的JobParameters因此,不同JOB_KEY值)。spring-doc.cadn.net.cn

BATCH_JOB_EXECUTION_PARAMS桌子

BATCH_JOB_EXECUTION_PARAMS表包含与JobParameters对象。它包含 0 个或多个传递给Job和 用作运行作业时使用的参数的记录。对于每个参数,该 有助于生成作业的标识,IDENTIFYING标志设置为 true。 请注意,该表已非规范化。而不是为每个 type 时,有一个表有一个列指示类型,如下所示 列表显示:spring-doc.cadn.net.cn

CREATE TABLE BATCH_JOB_EXECUTION_PARAMS  (
	JOB_EXECUTION_ID BIGINT NOT NULL ,
	PARAMETER_NAME VARCHAR(100) NOT NULL ,
	PARAMETER_TYPE VARCHAR(100) NOT NULL ,
	PARAMETER_VALUE VARCHAR(2500) ,
	IDENTIFYING CHAR(1) NOT NULL ,
	constraint JOB_EXEC_PARAMS_FK foreign key (JOB_EXECUTION_ID)
	references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)
);

以下列表描述了每列:spring-doc.cadn.net.cn

请注意,此表没有主键。这是因为框架没有 用于一个,因此不需要它。如果需要,您可以添加主键 使用数据库生成的密钥,而不会对框架本身造成任何问题。spring-doc.cadn.net.cn

BATCH_JOB_EXECUTION桌子

BATCH_JOB_EXECUTION表包含与JobExecution对象。每次Job运行时,总会有一个新的叫JobExecution并在 这个表。以下列表显示了BATCH_JOB_EXECUTION桌子:spring-doc.cadn.net.cn

CREATE TABLE BATCH_JOB_EXECUTION  (
  JOB_EXECUTION_ID BIGINT  PRIMARY KEY ,
  VERSION BIGINT,
  JOB_INSTANCE_ID BIGINT NOT NULL,
  CREATE_TIME TIMESTAMP NOT NULL,
  START_TIME TIMESTAMP DEFAULT NULL,
  END_TIME TIMESTAMP DEFAULT NULL,
  STATUS VARCHAR(10),
  EXIT_CODE VARCHAR(20),
  EXIT_MESSAGE VARCHAR(2500),
  LAST_UPDATED TIMESTAMP,
  constraint JOB_INSTANCE_EXECUTION_FK foreign key (JOB_INSTANCE_ID)
  references BATCH_JOB_INSTANCE(JOB_INSTANCE_ID)
) ;

以下列表描述了每列:spring-doc.cadn.net.cn

  • JOB_EXECUTION_ID:唯一标识此执行的主键。的值 可以通过调用getId方法JobExecution对象。spring-doc.cadn.net.cn

  • VERSION:请参阅版本spring-doc.cadn.net.cn

  • JOB_INSTANCE_ID:来自BATCH_JOB_INSTANCE桌子。它表示 此执行所属的实例。每个执行可能有多个 实例。spring-doc.cadn.net.cn

  • CREATE_TIME:表示创建执行的时间戳。spring-doc.cadn.net.cn

  • START_TIME:表示执行开始时间的时间戳。spring-doc.cadn.net.cn

  • END_TIME:表示执行完成时间的时间戳,无论 成功或失败。当作业当前未运行时,此列中的空值 表示存在某种类型的错误,并且框架无法执行 失败前的最后一次保存。spring-doc.cadn.net.cn

  • STATUS:表示执行状态的字符串。这可能是COMPLETED,STARTED,等。此列的对象表示是BatchStatus列举。spring-doc.cadn.net.cn

  • EXIT_CODE:表示执行的退出代码的字符串。在这种情况下 命令行作业的,这可以转换为数字。spring-doc.cadn.net.cn

  • EXIT_MESSAGE:字符串,表示如何 作业退出。在失败的情况下,这可能包括尽可能多的堆栈跟踪 可能。spring-doc.cadn.net.cn

  • LAST_UPDATED:表示上次持久化此执行的时间戳。spring-doc.cadn.net.cn

BATCH_STEP_EXECUTION桌子

BATCH_STEP_EXECUTION表包含与StepExecution对象。此表在许多方面与BATCH_JOB_EXECUTION表,然后那里 始终每个至少有一个条目Step对于每个JobExecution创建。以下内容 列表中显示了BATCH_STEP_EXECUTION桌子:spring-doc.cadn.net.cn

CREATE TABLE BATCH_STEP_EXECUTION  (
  STEP_EXECUTION_ID BIGINT NOT NULL PRIMARY KEY ,
  VERSION BIGINT NOT NULL,
  STEP_NAME VARCHAR(100) NOT NULL,
  JOB_EXECUTION_ID BIGINT NOT NULL,
  CREATE_TIME TIMESTAMP NOT NULL,
  START_TIME TIMESTAMP DEFAULT NULL ,
  END_TIME TIMESTAMP DEFAULT NULL,
  STATUS VARCHAR(10),
  COMMIT_COUNT BIGINT ,
  READ_COUNT BIGINT ,
  FILTER_COUNT BIGINT ,
  WRITE_COUNT BIGINT ,
  READ_SKIP_COUNT BIGINT ,
  WRITE_SKIP_COUNT BIGINT ,
  PROCESS_SKIP_COUNT BIGINT ,
  ROLLBACK_COUNT BIGINT ,
  EXIT_CODE VARCHAR(20) ,
  EXIT_MESSAGE VARCHAR(2500) ,
  LAST_UPDATED TIMESTAMP,
  constraint JOB_EXECUTION_STEP_FK foreign key (JOB_EXECUTION_ID)
  references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)
) ;

以下列表描述了每列:spring-doc.cadn.net.cn

  • STEP_EXECUTION_ID:唯一标识此执行的主键。的值 该列应通过调用getId方法StepExecution对象。spring-doc.cadn.net.cn

  • VERSION:请参阅版本spring-doc.cadn.net.cn

  • STEP_NAME:此执行所属的步骤的名称。spring-doc.cadn.net.cn

  • JOB_EXECUTION_ID:来自BATCH_JOB_EXECUTION桌子。它表示JobExecutionStepExecution是。可能只有一个StepExecution给定JobExecution给定Step名字。spring-doc.cadn.net.cn

  • START_TIME:表示执行开始时间的时间戳。spring-doc.cadn.net.cn

  • END_TIME:表示执行完成时间的时间戳,无论 成功或失败。此列中的空值,即使作业不是 当前正在运行,表示存在某种类型的错误,并且框架是 无法在失败之前执行最后一次保存。spring-doc.cadn.net.cn

  • STATUS:表示执行状态的字符串。这可能是COMPLETED,STARTED,等。此列的对象表示是BatchStatus列举。spring-doc.cadn.net.cn

  • COMMIT_COUNT:步骤提交事务的次数 在此执行期间。spring-doc.cadn.net.cn

  • READ_COUNT:在此执行期间读取的项目数。spring-doc.cadn.net.cn

  • FILTER_COUNT:从此执行中筛选出的项目数。spring-doc.cadn.net.cn

  • WRITE_COUNT:在此执行期间写入和提交的项目数。spring-doc.cadn.net.cn

  • READ_SKIP_COUNT:在此执行期间读取时跳过的项目数。spring-doc.cadn.net.cn

  • WRITE_SKIP_COUNT:在此执行期间在写入时跳过的项目数。spring-doc.cadn.net.cn

  • PROCESS_SKIP_COUNT:在此期间处理过程中跳过的项目数 执行。spring-doc.cadn.net.cn

  • ROLLBACK_COUNT:此执行期间的回滚次数。请注意,此计数 包括每次发生回滚的时间,包括重试回滚和跳过 恢复程序。spring-doc.cadn.net.cn

  • EXIT_CODE:表示执行的退出代码的字符串。在这种情况下 命令行作业的,这可以转换为数字。spring-doc.cadn.net.cn

  • EXIT_MESSAGE:字符串,表示如何 作业退出。在失败的情况下,这可能包括尽可能多的堆栈跟踪 可能。spring-doc.cadn.net.cn

  • LAST_UPDATED:表示上次持久化此执行的时间戳。spring-doc.cadn.net.cn

BATCH_JOB_EXECUTION_CONTEXT桌子

BATCH_JOB_EXECUTION_CONTEXT表包含与ExecutionContextJob.正好有一个Job ExecutionContext对于每个JobExecution,并且它包含特定 作业执行。此数据通常表示在 失败,以便JobInstance可以“从上次中断的地方开始”。以下内容 列表中显示了BATCH_JOB_EXECUTION_CONTEXT桌子:spring-doc.cadn.net.cn

CREATE TABLE BATCH_JOB_EXECUTION_CONTEXT  (
  JOB_EXECUTION_ID BIGINT PRIMARY KEY,
  SHORT_CONTEXT VARCHAR(2500) NOT NULL,
  SERIALIZED_CONTEXT CLOB,
  constraint JOB_EXEC_CTX_FK foreign key (JOB_EXECUTION_ID)
  references BATCH_JOB_EXECUTION(JOB_EXECUTION_ID)
) ;

以下列表描述了每列:spring-doc.cadn.net.cn

BATCH_STEP_EXECUTION_CONTEXT桌子

BATCH_STEP_EXECUTION_CONTEXT表包含与ExecutionContextStep.正好有一个ExecutionContextStepExecution,并且它包含所有数据 需要为特定步骤执行持久化。此数据通常表示 状态,以便在失败后检索JobInstance可以“启动 从它离开的地方“。以下列表显示了BATCH_STEP_EXECUTION_CONTEXT桌子:spring-doc.cadn.net.cn

CREATE TABLE BATCH_STEP_EXECUTION_CONTEXT  (
  STEP_EXECUTION_ID BIGINT PRIMARY KEY,
  SHORT_CONTEXT VARCHAR(2500) NOT NULL,
  SERIALIZED_CONTEXT CLOB,
  constraint STEP_EXEC_CTX_FK foreign key (STEP_EXECUTION_ID)
  references BATCH_STEP_EXECUTION(STEP_EXECUTION_ID)
) ;

以下列表描述了每列:spring-doc.cadn.net.cn

归档

因为每次运行批处理作业时都会在多个表中出现条目,所以通常为元数据表创建存档策略。表本身被设计为以显示过去发生的事情的记录,并且通常不会影响任何作业的运行,但有一些与重新启动有关的显着例外:spring-doc.cadn.net.cn

  • 该框架使用元数据表来确定特定的JobInstance之前已经运行过。如果它已经运行并且作业不可重新启动,则会抛出异常。spring-doc.cadn.net.cn

  • 如果JobInstance在未成功完成的情况下被删除,则框架认为该作业是新的,而不是重新启动。spring-doc.cadn.net.cn

  • 如果重新启动作业,框架将使用已持久化到ExecutionContext要恢复Job’s州。因此,从 此表表示尚未成功完成的作业可防止它们从 如果再次运行,则为正确的点。spring-doc.cadn.net.cn

国际字符和多字节字符

如果您在业务中使用多字节字符集(例如中文或西里尔字母) processing,这些字符可能需要保留在 Spring Batch 模式中。 许多用户发现,只需更改模式即可将VARCHAR列就足够了。其他人更喜欢使用max-varchar-length一半 的值VARCHAR列长。一些用户还报告说,他们使用NVARCHAR代替VARCHAR在他们的模式定义中。最好的结果取决于 数据库平台以及数据库服务器在本地的配置方式。spring-doc.cadn.net.cn

为元数据表编制索引的建议

Spring Batch 为核心 jar 文件中的元数据表提供 DDL 示例,用于 几个常见的数据库平台。索引声明不包含在该 DDL 中, 因为用户可能希望编制索引的方式有太多变化,具体取决于他们的 精确的平台、当地惯例以及工作方式的业务需求 操作。下表提供了有关哪些列将要执行的一些指示 用于WHERESpring Batch 提供的 DAO 实现的子句以及如何 通常,它们可能会被使用,以便各个项目可以自己做出决定 关于索引:spring-doc.cadn.net.cn

表 1.SQL 语句中的 Where 子句(不包括主键)及其大致使用频率。

默认表名称spring-doc.cadn.net.cn

Where 子句spring-doc.cadn.net.cn

频率spring-doc.cadn.net.cn

BATCH_JOB_INSTANCEspring-doc.cadn.net.cn

JOB_NAME = ? and JOB_KEY = ?spring-doc.cadn.net.cn

每次启动作业时spring-doc.cadn.net.cn

BATCH_JOB_EXECUTIONspring-doc.cadn.net.cn

JOB_INSTANCE_ID = ?spring-doc.cadn.net.cn

每次重新启动作业时spring-doc.cadn.net.cn

BATCH_STEP_EXECUTIONspring-doc.cadn.net.cn

VERSION = ?spring-doc.cadn.net.cn

在提交间隔上,又名块(以及 步骤)spring-doc.cadn.net.cn

BATCH_STEP_EXECUTIONspring-doc.cadn.net.cn

STEP_NAME = ? and JOB_EXECUTION_ID = ?spring-doc.cadn.net.cn

在执行每个步骤之前spring-doc.cadn.net.cn