跳到主要内容

PostgreSQL 迁移同步到 MySQL

NineData 数据复制支持 PostgreSQL 到 MySQL 数据源之间的数据同步。

功能介绍​

NineData 数据复制支持数据源之间的结构、全量数据、增量数据的高性能复制，对于部分数据源，还提供双向复制功能，实现快捷构建异地多活业务架构。

  • 结构：支持同构及异构数据源之间的对象结构复制，很大程度上降低了两个数据源之间的数据复制门槛。
  • 全量数据：通过智能数据分片实现行级并发批量复制能力，有效保障复制性能。自主研发的新型断点续传技术，保证无主键表的数据准确性。
  • 增量数据：支持全对象类型的 DML|DDL 增量数据复制，结合行级并发、热点合并等技术，提供强劲复制性能。
  • 双向数据实时复制：直接多个节点之间的数据双向复制，保证所有节点的数据均保持最新状态。

通过以上功能，可以轻松高效地实现全量|增量数据复制、全量|增量数据迁移、全量|增量数据同步、数据集成、不停机无缝迁移等场景，为企业提供灵活和可靠的数据复制解决方案。

前提条件​

  • 已将源数据源和目标数据源添加至 NineData。如何添加，请参见添加数据源。

  • 源数据源为 PostgreSQL。

  • 目标数据源为 MySQL。

  • 您必须拥有源数据源和目标数据源的如下权限：

    复制类型
    		源数据源目标数据源
    结构复制CONNECT、SELECTDDL
    全量复制CONNECT、SELECTTABLE的相关权限（ALTER、DROP、SELECT、INSERT、UPDATE、DELETE)
    增量复制SUPERUSERTABLE的相关权限（ALTER、DROP、SELECT、INSERT、UPDATE、DELETE)

  • 如需增量复制，请打开 postgresql.conf 文件配置如下参数，如果找不到该文件的位置，可以在 psql 客户端中执行 SHOW config_file; SQL 命令查看。

    • 源数据源的 wal_level 参数必须为 logical，如需确认当前值，可以直接在客户端中执行 SHOW wal_level 查看。
    • 源数据源的 wal_sender_timeout 参数设置为 0。此参数用于中断处于停滞状态超过指定毫秒数的复制连接，默认值为 60000 毫秒。设置为 0 将将禁用超时机制。如需确认当前值，可以直接在客户端中执行 SHOW wal_sender_timeout 查看。
    • 源数据源的 max_replication_slots 参数必须大于 1。此参数指定服务器可以支持的最大复制槽数。默认值为10。
    • 源数据源的 max_wal_senders 参数必须大于 1。此参数指定最大的并发连接数。默认值为10。如需确认当前值，可以直接在客户端中执行 SHOW max_wal_senders 查看。

使用限制​

  • 执行数据同步前需评估源数据源和目标数据源的性能，同时建议业务低峰期执行数据同步。否则全量数据初始化时将占用源数据源和目标数据源一定的读写资源，导致数据库负载上升。
  • 需要确保同步对象中的每张表都有主键或唯一约束、列名具有唯一性，否则可能会重复同步相同数据。

操作步骤​

  1. 登录 NineData 控制台。

  2. 在左侧导航栏单击数据复制 > 数据复制。

  3. 在数据复制页面，单击右上角的创建复制。

  4. 在数据源与目标页签，按照下表进行配置，并单击下一步。

    参数
    		说明
    任务名称输入数据同步任务的名称，为了方便后续查找和管理，请尽量使用有意义的名称。最多支持 64 个字符。
    源数据源同步对象所在的数据源。
    目标数据源接收同步对象的数据源。
    目标数据库选择将数据同步到目标的哪个数据库。
    目标对象命名规则选择对象名称从源端迁移到目标端后的大小写转换规则。
    • 全部转小写：无论源端的命名规则如何，目标端的命名规则全部为小写。
    • 保持与源一致：沿用源端的命名规则。
    • 全部转大写：无论源端的命名规则如何，目标端的命名规则全部为大写。
    复制类型选择复制类型。
    • 结构复制：只同步源数据源的库表结构，不同步数据。
    • 全量复制：同步源数据源的所有对象和数据，即全量数据复制。右侧的开关为周期性全量复制的开关，更多信息，请参见周期性全量复制。
    • 增量复制：在全量同步完成后，基于源数据源的日志进行增量同步。setting图标为增量操作类型配置，可以根据需求取消勾选某一些操作类型，取消勾选后，这些操作会在增量同步中被忽略。
    增量开始时间复制类型仅为增量复制时需要选择。
    • 从启动时间开始：以当前复制任务开始时间为基准，进行增量复制。
    • 自定义时间：选择增量复制开始的时间点，您可以根据您的业务所在地域按需选择时区。如果将时间点配置为当前复制任务开始前，则如果该时间段内有 DDL 操作，复制任务将失败。
    复制规格复制任务的规格，规格越大复制的速率越高，将鼠标悬浮于details图标上即可查看每个规格对应的速率和配置信息。如果先配置数据复制任务再购买资源，可以在此选择需要的规格；如果先购买资源再配置任务，系统会选中购买资源时指定的规格，且无法在任务配置中变更。
    目标库同名对象处理策略（选中结构复制时需要选择）
    • 预检查报错并停止任务：预检查阶段检测到同名表时，停止任务。
    • 跳过并继续任务：预检查阶段检测到同名表时，发送提示并继续任务。 结构复制时，忽略该同名表。如果您同时进行了数据复制，则数据会在同名表中追加，而不会覆盖原有数据。
    • 删除对象并重建：预检查阶段检测到同名表时，发送提示并继续任务。结构复制时，删除目标库同名表，并基于源库重新复制表结构。如果您同时进行了数据复制，则数据会在表结构复制完成后写入。
    目标表存量数据处理策略（选中全量复制时需要选择）
    • 预检查报错并停止任务：预检查阶段检测到目标表中存在数据时，停止任务。
    • 忽略目标存量数据，追加写入：预检查阶段检测到目标表中存在数据时，忽略该部分数据，追加写入其他数据。
    • 清空目标存量数据，重新写入：预检查阶段检测到目标表中存在数据时，删除该部分数据，重新写入。
    目标表增量数据冲突处理策略（选中增量复制时需要选择）
    • 运行时报错：增量复制过程中遇到目标数据已存在则报错，等待人工介入处理。
    • 不更新目标数据：增量复制过程中遇到目标数据已存在则不写入，并继续后续任务。
    • 更新目标数据：增量复制过程中遇到目标数据已存在则覆盖写入目标数据。

  5. 在选择复制对象页签，配置下列参数，然后单击下一步。

    参数
    		说明
    复制对象选择需要复制的内容，您可以选择全部实例复制源库所有内容，也可以选择自定义对象，在源对象列表中选中需要复制的内容，单击>添加到右侧目标对象列表。

    如果您需要创建多条相同复制对象的复制链路，可以创建一个配置文件，在新建任务的时候导入即可。单击右上角的导入配置，再单击下载模板，将配置文件模版下载到本地，编辑完成后单击上传文件上传该配置文件即可实现批量导入。字段和示例请参见导入复制对象配置模板。配置文件说明：

    参数
    		说明示例
    source_table_name需同步的源表名。填写源数据源中实际存在的表名。example_tbl_name
    target_table_name接收同步对象的目标表名。example_tbl_name
    source_database_name需同步的对象所在的源库名。test_db
    target_database_name接收同步对象的目标库名。test_db_bak
    column_list需要同步的字段列表。["col1", "clo2", "col3"]
    extra_configuration额外配置的 JSON 字符串。column_rules 用于配置字段映射与取值规则，其中 column_name 为源列名，target_column_name 为目标列名，target_column_type 为目标列类型，column_value 为字段值；filter_condition 用于配置行级过滤条件。{"extra_config": {"column_rules": [...]}}
    提示

    以下 JSON 表示下载的 Excel 模板中的两行示例数据。实际上传时，请保留 Excel 模板的列名，并将 extra_configuration 单元格填写为 JSON 字符串；以下代码块不是可直接上传的 JSON 文件。

    [
      {
        "source_table_name": "example_tbl_name",
        "target_table_name": "example_tbl_name",
        "source_database_name": "test_db",
        "target_database_name": "test_db_bak",
        "column_list": ["col1", "clo2", "col3"],
        "extra_configuration": {
          "extra_config": {
            "column_rules": [
              {
                "column_name": "example_column_name",
                "target_column_name": "example_target_column_name",
                "target_column_type": "int",
                "column_value": "current_timestamp()"
              },
              {
                "column_name": "example_column_name",
                "target_column_name": "example_target_column_name",
                "target_column_type": "int"
              }
            ],
            "filter_condition": "example_condition_expression"
          }
        }
      },
      {
        "source_table_name": "example_order_tbl",
        "target_table_name": "example_order_tbl",
        "source_database_name": "test_db",
        "target_database_name": "test_db_bak",
        "column_list": ["col1", "clo2", "col3"],
        "extra_configuration": {
          "extra_config": {
            "column_rules": [
              {
                "column_name": "example_column_name",
                "target_column_name": "example_target_column_name",
                "target_column_type": "int",
                "column_value": "current_timestamp()"
              },
              {
                "column_name": "example_column_name",
                "target_column_name": "example_target_column_name",
                "target_column_type": "int"
              }
            ],
            "filter_condition": "example_condition_expression"
          }
        }
      }
    ]

  6. 在配置映射页签，根据所选的复制类型选择不同操作，然后单击保存并预检查。如果在配置映射阶段，源和目标数据源中有更新，可以单击页面右上角的刷新元数据按钮，重新获取源和目标数据源的信息。

    • 包含结构复制：配置目标表同步到目标数据源之后的表名。

    • 不包含结构复制：系统默认选择目标数据源中的同名数据库，如果不存在，则需要手动选择目标库。目标库中的表名、列名需要和同步对象一致。如果不一致，您也可以手动进行表名和列名的映射。

    您还可以进行如下操作：

    • 单击页面右侧的映射与过滤，自定义列名同步到目标数据源之后的名称。
    • 在映射与过滤页面，在数据过滤条件下方的文本框中输入比较表达式作为过滤条件，仅符合过滤条件的数据会同步到目标数据源。例如，将过滤条件设置为 emp_no>=10005，则 emp_no 列中小于 10005 的数据均不会同步到目标数据源。
    • 单击"目标表名"右侧的replace_tablename图标，可搜索表名，并替换成目标名称。
    • 在右上角的搜索表文本框中输入表名以快速定位到目标表。
    • 单击右上角的批量配置，可以批量定义通用规则（如表名、字段名大小写转换、前后缀添加、替换等），实现对大量表和字段的统一映射配置。

  1. 在预检查页签等待系统完成预检查。预检查通过后，在复制任务列表中打开已保存任务的详情页并启动任务。

    • 您可以勾选开启数据一致性对比。在同步任务完成后，自动开启基于源数据源的数据一致性对比，保证两端数据一致。根据您选择的复制类型，开启数据一致性对比的启动时机如下：

      • 结构复制：结构复制完成后启动。
      • 结构复制+全量复制：全量复制完成后启动。
      • 全量复制：全量复制完成后启动。
      • 结构复制+全量复制+增量复制、增量复制：当增量数据首次和源数据源一致且延迟为 0 秒时启动。您可以单击查看详情，在复制详情页面中查看同步延迟。sync_delay

    • 如果预检查未通过，需要单击目标检查项右侧操作列的详情，排查失败的原因，手动修复后单击重新检查重新执行预检查，直到通过。

    • 检查结果为警告的检查项，可视具体情况修复或忽略。

  2. 复制任务启动后，您可以进行以下操作：

    • 单击查看详情查看同步任务各个阶段的执行情况。

      • 单击返回列表可以返回数据复制任务列表页面。

修改增量同步位点​

对于复制类型中包含增量复制且任务详情提供位点管理的任务，可以查看并修改同步位点。可用的位点类型和输入格式由当前数据源及复制链路决定，以页面显示为准；如果位点显示为 - 或位点类型没有可选项，则当前任务没有可供修改的位点。

该功能用于特定运维场景：重新指定增量任务的日志读取位置或同步写入位置。读取位点控制任务从源端哪个位置继续读取，写入位点控制任务从哪个位置继续处理同步写入；提交后任务会暂停并重新启动，使新的位点生效。

  1. 在复制任务列表中，单击目标任务的任务 ID，进入任务详情。

  2. 单击增量复制页签，然后单击同步位点管理，查看当前的读取位点和写入位点。

  3. 单击修改位点。在位点类型中选择要调整的读取位点或写入位点，再根据页面显示的位点类型填写调整位点。

  4. 确认值和影响范围后，单击验证并提交。任务会进入暂停和重新启动过程；任务恢复运行后，再次打开同步位点管理确认位点已更新。

危险

修改同步位点，将会调整日志读取或同步写入的点位，可能导致数据丢失，谨慎操作！ 修改任一位点都可能导致数据丢失或源端与目标端数据不一致。请仅在已授权的测试环境，或已完成备份并具备回滚方案的维护窗口执行。已完成增量复制的任务不能重置位点。

查看同步结果​

  1. 登录 NineData 控制台。

  2. 在左侧导航栏单击数据复制 > 数据复制。

  3. 在数据复制页面单击目标同步任务的任务 ID，页面说明如下。

    result

    序号
    		功能
    		说明
    1同步延迟源数据源和目标数据源之间的数据同步延迟，0 秒表示两端之间没有延迟，此时您可以选择将业务切换到目标数据源，实现平滑迁移。
    2配置告警配置告警后，系统会在任务失败时通过您选择的方式通知您。
    3更多
    • 暂停：暂停任务，仅状态为运行中的任务可选。
    • 类似创建：创建一个和当前任务配置相同的新复制任务。
    • 终止：结束未完成或监听中（即增量同步中）的任务，终止任务后无法重启任务，请谨慎操作。如果复制对象中包含触发器或事件，系统会显示相应对象的终止行为选项：
      • 进行触发器迁移后终止或进行事件迁移后终止：先将相应对象迁移至目标数据源，再终止任务。
      • 不迁移触发器，立即终止或不迁移事件，立即终止：不迁移相应对象，立即终止任务。
    • 删除：删除任务，任务删除后无法恢复，请谨慎操作。
    4结构复制（包含结构复制的场景下显示）展示结构复制的进度和详细信息。
    • 单击页面右侧的日志：查看结构复制的执行日志。
    • 单击页面右侧的refresh：查看最新的信息。
    • 单击列表中目标对象右侧操作列的查看 DDL：可以查看 SQL 回放。
    5全量复制（包含全量复制的场景下显示）展示全量复制的进度和详细信息。
    • 单击页面右侧的监控：查看全量复制过程中的各监控指标。全量复制过程中，还可以单击监控指标页面右侧的限流设置，限制每秒写入到目标数据源的速率。单位为行/秒。
    • 单击页面右侧的日志：查看全量复制的执行日志。
    • 单击页面右侧的refresh：查看最新的信息。
    6增量复制（包含增量复制的场景下显示）展示增量复制的各项监控指标。
    • 单击页面右侧的查看线程：查看当前复制任务正在执行中的操作，包含：
      • 线程号：复制任务分多个线程执行复制操作，展示当前进行中的线程号。
      • 执行 SQL：当前线程正在执行中的 SQL 语句详情。
      • 提交响应时间：当前线程的响应时间，如果该数值变大，则代表当前线程可能由于某些原因卡住。
      • 事件时间：当前线程开启的时间戳。
      • 状态：当前线程的状态。
    • 单击页面右侧的限流设置：限制每秒写入到目标数据源的速率。单位为行/秒。
    • 单击页面右侧的日志：查看增量复制的执行日志。
    • 单击页面右侧的refresh：查看最新的信息。
    7修改对象展示同步对象的修改记录。
    • 单击页面右侧的修改同步对象，可对同步对象进行配置。
    • 单击页面右侧的refresh：查看最新的信息。
    8数据对比展示源数据源和目标数据源之间对比的结果。如果您未开启数据对比，请单击页面中的开启数据对比。
    • 单击页面右侧的重新对比：对当前源和目标两端数据重新发起对比。
    • 单击页面右侧的停止：对比任务开始后，可单击该按钮立即停止对比任务。
    • 单击页面右侧的日志：查看一致性对比的执行日志。
    • 单击页面右侧的监控（仅数据对比显示）：查看对比 RPS（每秒对比的记录数）的走势图。单击详情可以查看更早之前的记录。
    • 在对比列表右侧操作列单击details（数据页签下只在不一致情况下显示）：查看源端和目标端的对比详情。
    • 在对比列表右侧操作列单击sql（不一致情况下显示)：生成用于修正不一致的 SQL。该 SQL 可能修改目标端数据。执行前，请人工审查语句、目标对象和影响范围，并确认目标端备份或适用的回滚方案。按审查后的执行顺序运行；不要未经审查批量执行。
    9展开展示当前复制任务的详细信息。常用选项：
    • 导出表配置：导出当前任务的库表配置，可在新建复制任务时快速导入，以快速创建多条相同复制对象的复制链路。
    • 告警规则：配置当前任务的告警策略。

附录一：数据类型映射表​

以下映射仅适用于 PostgreSQL 15.2 到 MySQL 8.0.28。源类型依据 PostgreSQL 15 官方数据类型、数组、范围类型、数值及 serial 声明和伪类型资料，并与实际源列定义核对。表中的目标类型及长度、精度和标度来自结构与全量复制完成后读取的 MySQL INFORMATION_SCHEMA.COLUMNS。伪类型不能用作列类型，因此不列入映射。自定义类型行仅适用于本次实测的类型定义，不代表所有自定义类型。

非数组类型​

PostgreSQL 源类型MySQL COLUMN_TYPE目标列元数据
"char"（内部单字节字符类型）varchar(255)CHARACTER_MAXIMUM_LENGTH=255
aclitemvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
bigintbigintNUMERIC_PRECISION=19，NUMERIC_SCALE=0
bit varying(8)varchar(255)CHARACTER_MAXIMUM_LENGTH=255
bit(4)bit(4)NUMERIC_PRECISION=4
booleantinyint(1)NUMERIC_PRECISION=3，NUMERIC_SCALE=0
boxvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
bpchar（未指定长度）longtextCHARACTER_MAXIMUM_LENGTH=4294967295
bytealongblobCHARACTER_MAXIMUM_LENGTH=4294967295
character varying(20)varchar(20)CHARACTER_MAXIMUM_LENGTH=20
character(3)char(3)CHARACTER_MAXIMUM_LENGTH=3
cidvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
cidrvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
circlevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
datedate未返回其他长度或精度
datemultirangevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
daterangevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
double precisiondoubleNUMERIC_PRECISION=22
gtsvectorvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
inetvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
int2vectorlongtextCHARACTER_MAXIMUM_LENGTH=4294967295
int4multirangevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
int4rangevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
int8multirangevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
int8rangevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
integerintNUMERIC_PRECISION=10，NUMERIC_SCALE=0
interval day to second(3)varchar(255)CHARACTER_MAXIMUM_LENGTH=255
interval year to monthvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
interval(3)varchar(255)CHARACTER_MAXIMUM_LENGTH=255
jsonjson未返回其他长度或精度
jsonbjson未返回其他长度或精度
jsonpathvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
linevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
lsegvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
macaddrvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
macaddr8varchar(255)CHARACTER_MAXIMUM_LENGTH=255
moneydecimal(19,2)NUMERIC_PRECISION=19，NUMERIC_SCALE=2
namevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
用户定义的复合类型（本次实测定义）varchar(255)CHARACTER_MAXIMUM_LENGTH=255
用户定义的域类型（以 integer 为基类型，本次实测定义）intNUMERIC_PRECISION=10，NUMERIC_SCALE=0
用户定义的枚举类型（本次实测定义）varchar(255)CHARACTER_MAXIMUM_LENGTH=255
用户定义的多重范围类型（以 int4range 为基类型，本次实测定义）varchar(255)CHARACTER_MAXIMUM_LENGTH=255
用户定义的范围类型（以 int4range 为基类型，本次实测定义）varchar(255)CHARACTER_MAXIMUM_LENGTH=255
numericdecimal(65,0)NUMERIC_PRECISION=65，NUMERIC_SCALE=0
numeric(12,4)decimal(12,4)NUMERIC_PRECISION=12，NUMERIC_SCALE=4
nummultirangevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
numrangevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
oidvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
oidvectorlongtextCHARACTER_MAXIMUM_LENGTH=4294967295
pathvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
pg_brin_bloom_summaryvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
pg_brin_minmax_multi_summaryvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
pg_dependenciesvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
pg_lsnvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
pg_mcv_listvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
pg_ndistinctvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
pg_node_treevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
pg_snapshotvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
pointpoint未返回其他长度或精度
polygonpolygon未返回其他长度或精度
realdoubleNUMERIC_PRECISION=22
refcursorvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
regclassvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
regcollationvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
regconfigvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
regdictionaryvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
regnamespacevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
regopervarchar(255)CHARACTER_MAXIMUM_LENGTH=255
regoperatorvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
regprocvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
regprocedurevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
regrolevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
regtypevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
smallintsmallintNUMERIC_PRECISION=5，NUMERIC_SCALE=0
textlongtextCHARACTER_MAXIMUM_LENGTH=4294967295
tidvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
time(3) with time zonetime(3)DATETIME_PRECISION=3
time(3) without time zonetime(3)DATETIME_PRECISION=3
timestamp(3) with time zonetimestamp(3)DATETIME_PRECISION=3
timestamp(3) without time zonedatetime(3)DATETIME_PRECISION=3
tsmultirangevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
tsqueryvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
tsrangevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
tstzmultirangevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
tstzrangevarchar(255)CHARACTER_MAXIMUM_LENGTH=255
tsvectorvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
txid_snapshotvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
uuidvarchar(36)CHARACTER_MAXIMUM_LENGTH=36
xidvarchar(255)CHARACTER_MAXIMUM_LENGTH=255
xid8varchar(255)CHARACTER_MAXIMUM_LENGTH=255
xmllongtextCHARACTER_MAXIMUM_LENGTH=4294967295

serial 声明形式​

PostgreSQL 的 serial 声明会创建对应的整数列；下表列出实际以这些声明形式建列并复制后读回的目标物理类型。

PostgreSQL 源 DDL 声明PostgreSQL 源物理类型MySQL COLUMN_TYPE目标数值精度/标度
smallserialsmallintsmallintNUMERIC_PRECISION=5，NUMERIC_SCALE=0
serial2smallintsmallintNUMERIC_PRECISION=5，NUMERIC_SCALE=0
serialintegerintNUMERIC_PRECISION=10，NUMERIC_SCALE=0
serial4integerintNUMERIC_PRECISION=10，NUMERIC_SCALE=0
bigserialbigintbigintNUMERIC_PRECISION=19，NUMERIC_SCALE=0
serial8bigintbigintNUMERIC_PRECISION=19，NUMERIC_SCALE=0

数组类型​

以下每一种数组列的目标 COLUMN_TYPE 均为 longtext，CHARACTER_MAXIMUM_LENGTH 均为 4294967295。

PostgreSQL 源数组类型MySQL COLUMN_TYPE
"char"[]longtext
aclitem[]longtext
bigint[]longtext
bit varying[]longtext
bit(1)[]longtext
boolean[]longtext
box[]longtext
bytea[]longtext
character varying[]longtext
character(1)[]longtext
cid[]longtext
cidr[]longtext
circle[]longtext
date[]longtext
datemultirange[]longtext
daterange[]longtext
double precision[]longtext
gtsvector[]longtext
inet[]longtext
int2vector[]longtext
int4multirange[]longtext
int4range[]longtext
int8multirange[]longtext
int8range[]longtext
integer[]longtext
interval[]longtext
json[]longtext
jsonb[]longtext
jsonpath[]longtext
line[]longtext
lseg[]longtext
macaddr[]longtext
macaddr8[]longtext
money[]longtext
name[]longtext
用户定义的复合类型数组（本次实测定义）longtext
用户定义的域类型数组（以 integer 为基类型，本次实测定义）longtext
用户定义的枚举类型数组（本次实测定义）longtext
用户定义的多重范围类型数组（以 int4range 为基类型，本次实测定义）longtext
用户定义的范围类型数组（以 int4range 为基类型，本次实测定义）longtext
numeric[]longtext
nummultirange[]longtext
numrange[]longtext
oid[]longtext
oidvector[]longtext
path[]longtext
pg_lsn[]longtext
pg_snapshot[]longtext
point[]longtext
polygon[]longtext
real[]longtext
refcursor[]longtext
regclass[]longtext
regcollation[]longtext
regconfig[]longtext
regdictionary[]longtext
regnamespace[]longtext
regoper[]longtext
regoperator[]longtext
regproc[]longtext
regprocedure[]longtext
regrole[]longtext
regtype[]longtext
smallint[]longtext
text[]longtext
tid[]longtext
time with time zone[]longtext
time without time zone[]longtext
timestamp with time zone[]longtext
timestamp without time zone[]longtext
tsmultirange[]longtext
tsquery[]longtext
tsrange[]longtext
tstzmultirange[]longtext
tstzrange[]longtext
tsvector[]longtext
txid_snapshot[]longtext
uuid[]longtext
xid[]longtext
xid8[]longtext
xml[]longtext

本表仅记录目标列类型和元数据，不代表所有类型的非空值都已验证保真。数组 fixture 的数组值均为 NULL；point 和 polygon 的非空值保真未确认。不要据此推断其他 PostgreSQL 或 MySQL 版本、自定义类型定义或其他复制链路的映射行为。

附录二：预检查项一览表​

检查项检查内容
源数据源连接检查检查源数据源网关状态、实例是否可达、用户名及密码准确性
目标数据源连接检查检查目标数据源网关状态、实例是否可达、用户名及密码准确性
源库权限检查检查源数据库的账号权限是否满足要求
目标库权限检查检查目标数据库的账号权限是否满足要求
目标数据源触发器检查检测目标数据库的触发器是否存在
目标库数据存在性检查检查待复制对象在目标数据库中是否已存在数据
目标库同名对象存在性检查检查待复制对象在目标数据库中是否已存在
循环链路检查检查环路是否存在
检查 wal_level检查源数据源的 wal_level 是否为 logical
检查 max_wal_senders检查 max_wal_senders 是否满足复制连接数要求
检查 max_replication_slots检查 max_replication_slots 是否满足复制槽数量要求
源库无主键表存在性校验检查待复制对象是否不存在主键或唯一键
校验源端数据库实例是否处于只读模式校验源端数据库实例是否处于只读模式
校验目标端数据库实例是否处于只读模式校验目标端数据库实例是否处于只读模式
源端联邦表可用性校验检查源端联邦表可用性

相关文档​

数据复制简介