--- title: "数据迁移概览 - OceanBase 最佳实践 | OceanBase 文档中心" description: 数据迁移概览 本文档面向需要将数据从本地或其他云环境迁移到 OceanBase 数据库的人员，介绍了数据库迁移的概念、方法和工具。在本文档中，下游目标环境为 OceanBase 数据库。 应用场景 数据迁移是数据库运维常见的操作，主要有如下的应用场景： 调整集群负载和机房搬迁。 数据库替换。 数据库逻辑复制，包括读写… image: https://mdn.alipayobjects.com/huamei_22khvb/afts/img/A*OSPzQ6GUQF4AAAAAQHAAAAgAeiGDAQ/original --- 切换语言 - 中文站 - 简体中文 - International - English - 日本站 - 日本語 # 数据迁移概览 更新时间：2026-07-28 [编辑](https://github.com/oceanbase/best-practices-doc/edit/master/zh-CN/300.migrations/200.migration-intro.md) 适用产品： OceanBase 数据库 适用场景： 数据迁移及导入 本文档面向需要将数据从本地或其他云环境迁移到 OceanBase 数据库的人员，介绍了数据库迁移的概念、方法和工具。在本文档中，下游目标环境为 OceanBase 数据库。 ## 应用场景 数据迁移是数据库运维常见的操作，主要有如下的应用场景： - 调整集群负载和机房搬迁。 - 数据库替换。 - 数据库逻辑复制，包括读写分离、数据库容灾、业务多活等。 - 数据复制。 ## 迁移类型 本文档定义了以下主要的迁移类型： - 数据库到数据库的迁移。 - 数据文件到数据库的迁移。 ### 数据库到数据库的迁移 如果您希望从数据库迁移数据到 OceanBase 数据库，推荐使用 OMS。OMS 支持如下数据源： - MySQL - Oracle - DB2 LUW - TiDB - PostgreSQL 如果 OMS 不支持您使用的数据库，请采用其他迁移方式。您可以把上游数据 Dump 出来，生成数据文件，再参考数据文件到数据库的迁移。 ### 数据文件到数据库的迁移 如果您的数据文件是 CSV 文件，采用以下方式导入： - MySQL 租户的 LOAD DATA 命令 - DataX 或 DataX Web 版 - OBLOADER 如果您的数据文件是 SQL 文件，采用以下方式导入： - OBLOADER - MySQL 或 obclient 命令 - Subtopic - 数据库客户端导入 如果您的数据文件是 Parquet 文件，采用以下方式导入： - OBLOADER - LOAD DATA 如果您的数据文件是 ORC 文件，采用 OBLOADER 导入。 ## 迁移工具 OceanBase 数据库提供丰富的数据迁移方法，包括： - OceanBase 官方方案 - OceanBase 提供的数据迁移服务 OMS，专门大规模数据迁移设计。 - OceanBase 提供的导入数据工具 OBLOADER，专门为从数据文件导入设计。 - 命令行工具 - 标准 SQL 命令 LOAD DATA 和 INSERT SQL，便于操作，适合小规模数据导入。 - CREATE EXTERNAL TABLE 实现外部数据文件的直接查询，增加分析灵活性。 - CREATE TABLE AS SELECT。 - 第三方集成工具 Flink OceanBase Connector、DataX OceanBase Writer Plugin、Kafka 和 Canal 等。 ### OMS **基本特性：** OMS 特性如下： - 在线不停服迁移，业务应用无感知。 - 高性能的数据迁移，安全可靠。 - 一站式交互。 **适用场景：** - 数据迁移适合大规模数据库到数据库的迁移。 **使用参考：** - 关于 OMS 的详细介绍，参见 [OMS 使用文档](https://www.oceanbase.com/docs/oms-doc-cn)。 ### OBLOADER **基本特性：** OBLOADER 特性如下： - 支持从本地磁盘、NAS、HDFS、OSS、COS、OBS、Apache Hadoop、Aliyun OSS 和 AWS S3 导入数据库对象定义和表数据。 - 支持导入 mysqldump 导出的 INSERT SQL 格式的文件。 - 支持导入标准的 CSV、Insert SQL、Apache ORC 和 Apache Parquet 等格式的数据文件。 - 支持配置数据预处理的控制规则以及文件与表之间的字段映射关系。 - 支持导入限速、防导爆、断点恢复和错误自动重试。 - 支持指定自定义的日志目录，导入时可以保存坏数据和冲突数据。 - 支持导入工具自动对大文件进行切分且不占用额外的存储空间，无需人工切分文件。 - 支持对命令行中指定的敏感参数进行加密。包括：数据库的账号密码，云存储的账号密钥。 **适用场景：** - OBLOADER 适合较大规模数据导入。 **使用参考：** - 关于 OBLOADER 的详细介绍，参见 [OBLOADER 使用文档](https://www.oceanbase.com/docs/oceanbase-dumper-loader)。 ### LOAD DATA #### LOAD DATA LOCAL **基本特性：** LOAD DATA LOCAL 特性如下： - 适用于本地文件导入 OB Cloud 云数据库。将本地文件以网络流的方式传输到 OB Cloud 云数据库并插入。 - 适用于小数据量场景。 - 仅支持一次传输一个文件。 - 目前支持 CSV、SQL 和 Parquet 文件单导入。 **适用场景：** - LOAD DATA LOCAL 适合小规模数据导入。 **使用参考：** - 关于 LOAD DATA LOCAL 的使用方法，参见 [使用 LOAD DATA 语句导入数据](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000001049863)。 #### LOAD DATA FROM OSS **基本特性：** LOAD DATA FROM OSS 特性如下： - 将 OSS 文件直接导入到 OB Cloud 云数据库中。 - 可支持一次导入多个 OSS 文件。 - 目前仅支持 CSV 文件导入。 **适用场景：** - LOAD DATA FROM OSS 适合大规模数据导入。 **使用参考：** - 关于 LOAD DATA FROM OSS 的操作指导，参见 [LOAD DATA（Oracle 模式）](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000001054301) 和 [LOAD DATA（MySQL 模式）](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000001053471)。 ### INSERT SQL **适用场景：** - INSERT INTO VALUES 适合向内部表写入少量数据。 - INSERT INTO SELECT FROM 适合向目标表写入另外一张表（内部表或外部表）的查询结果，即表与表之间的迁移。 - INSERT /*+ [APPEND |direct(need_sort,max_error,'full')] enable_parallel_dml parallel(N)*/ INTO table_name select_sentence 旁路导入适合全量和增量旁路导入。 **使用参考：** - 关于 INSERT SQL 的使用指导，参见 [INSERT（Oracle 模式）](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000001054301) 和 [INSERT（MySQL 模式）](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000001053471)。 ### CREATE EXTERNAL TABLE **适用场景：** - 外表是数据库管理系统中的一项关键功能，通常数据库中的表存放于数据库的存储空间中，而外表的数据存储于外部存储服务中。 **使用参考：** - 关于外表的使用指导，参见 [外表（Oracle 模式）](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000001053129)和 [外表（MySQL 模式）](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000001053137)。 ### Flink **适用场景：** - Flink OceanBase Connector 适合从 Flink 实时导入数据。 **使用参考：** - [通过 Flink 同步数据](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000001049848) ### Canal **适用场景：** - 适合从 Canal 实时导入数据。 **使用参考：** - [通过 Canal 同步数据](https://www.oceanbase.com/[../800.integration/200.canal.md](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000001049845)) ### Kafka **适用场景：** - 适合从 MySQL、Oracle 和 PostgreSQL 等数据库向 OceanBase 数据库迁移或同步数据。 **使用参考：** - [OceanBase 数据库与 Kafka 集成最佳实践](https://www.oceanbase.com/docs/common-oceanbase-cloud-1000000001039437) ## 迁移方案选择 本节概述了各种常见数据源的迁移方案，旨在帮助您根据实际需求快速选择最适合的迁移策略。我们将按照数据源类型来分类介绍不同的迁移方案。 ### 对象存储 将云厂商的对象存储中的数据导入到 OB Cloud 云数据库的方案见下表。 | **数据源** | **支持的导入方案** | | --- | --- | | Alibaba Cloud OSS | - DataX（[参考文档](https://github.com/alibaba/DataX)） - LOAD DATA INFILE（[参考文档](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000000821997#7-title-%E4%BB%8E%20OSS%20%E6%96%87%E4%BB%B6%E5%AF%BC%E5%85%A5%E6%95%B0%E6%8D%AE)） - 将数据下载到本地或者可访问的服务器上，再使用 MySQL 命令行工具或 SQL 管理工具导入到 OceanBase 数据库，或者编写脚本，使用 MySQL 的连接库执行 SQL 语句并执行批量插入。 | | Tencent Cloud COS | - LOAD DATA INFILE（[参考文档](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000000821997#7-title-%E4%BB%8E%20OSS%20%E6%96%87%E4%BB%B6%E5%AF%BC%E5%85%A5%E6%95%B0%E6%8D%AE)） - 将数据下载到本地或者可访问的服务器上，再使用 MySQL 命令行工具或 SQL 管理工具导入到 OceanBase 数据库，或者编写脚本，使用 MySQL 的连接库执行 SQL 语句并执行批量插入。 | | Huawei Cloud OBS | - LOAD DATA INFILE（[参考文档](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000000821997#7-title-%E4%BB%8E%20OSS%20%E6%96%87%E4%BB%B6%E5%AF%BC%E5%85%A5%E6%95%B0%E6%8D%AE)） - 将数据下载到本地或者可访问的服务器上，再使用 MySQL 命令行工具或 SQL 管理工具导入到 OceanBase 数据库，或者编写脚本，使用 MySQL 的连接库执行 SQL 语句并执行批量插入。 - Flink 对接 OBS（[参考文档](https://nightlies.apache.org/flink/flink-docs-release-1.16/zh/docs/deployment/filesystems/overview/)） | | Amazon S3 | - 将数据下载到本地或者可访问的服务器上，再使用 MySQL 命令行工具或 SQL 管理工具导入到 OceanBase 数据库，或者编写脚本，使用 MySQL 的连接库执行 SQL 语句并执行批量插入。 | | Azure Blob Storage | 将数据下载到本地或者可访问的服务器上，再使用 MySQL 命令行工具或 SQL 管理工具导入到 OceanBase 数据库，或者编写脚本，使用 MySQL 的连接库执行 SQL 语句并执行批量插入。 | | Google Cloud GCS | 将数据下载到本地或者可访问的服务器上，再使用 MySQL 命令行工具或 SQL 管理工具导入到 OceanBase 数据库，或者编写脚本，使用 MySQL 的连接库执行 SQL 语句并执行批量插入。 | ### 文件系统 将本地文件系统及分布式文件系统中的数据导入到 OceanBase 数据库的方案见下表。 | **数据源** | **支持的导入方案** | | --- | --- | | Local File System (包括 NFS 和 NAS) | - 如果数据是 CSV，您可以使用 OBLOADER（[参考文档](https://www.oceanbase.com/docs/common-oceanbase-dumper-loader-1000000000775418#9-title-%E5%AF%BC%E5%85%A5%20CSV%20%E6%95%B0%E6%8D%AE%E6%96%87%E4%BB%B6)）。 - 如果数据是 SQL，您可以使用 LOAD DATA INFILE（[参考文档](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000000821997#7-title-%E4%BB%8E%20OSS%20%E6%96%87%E4%BB%B6%E5%AF%BC%E5%85%A5%E6%95%B0%E6%8D%AE)）。 - 编写脚本，使用 MySQL 的连接库执行 SQL 语句并执行批量插入。 | | 分布式文件系统 HDFS | - 将数据导入至 TXT 文件，再使用 OBLOADER 导入（[参考文档](https://www.oceanbase.com/docs/common-oceanbase-dumper-loader-1000000000775418#14-title-%E4%BB%8E%20Aliyun%20OSS%20%E5%AF%BC%E5%85%A5%E6%95%B0%E6%8D%AE%E6%96%87%E4%BB%B6%E5%88%B0%20OceanBase%20%E6%95%B0%E6%8D%AE%E5%BA%93)）。 - 编写自定义 ETL 脚本，使用 HDFS API 读取 HDFS 中的数据，然后使用 MySQL 的客户端库（例如 JDBC、Python 的 mysql-connector-python 等）将数据转换和导入到 OceanBase 数据库。 | ### 流式系统 将流式系统中的数据导入到 OceanBase 数据库的方案见下表。 | **数据源** | **支持的导入方案** | | --- | --- | | Flink | - MySQL CDC Connector（[参考文档](https://nightlies.apache.org/flink/flink-cdc-docs-release-3.1/docs/connectors/flink-sources/mysql-cdc/)） - Flink JDBC SQL Connector（[参考文档](https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/jdbc/)） - Flink OceanBase Connector（[参考文档](https://nightlies.apache.org/flink/flink-cdc-docs-release-3.0/docs/connectors/flink-sources/oceanbase-cdc/)） | | Canal | - Canal Server（[参考文档](https://github.com/alibaba/canal)） - Canal Adapter（[参考文档](https://github.com/alibaba/canal)） | | Spark | 使用 JDBC 接口连接到 OB Cloud 云数据库（[参考文档](https://spark.apache.org/docs/latest/sql-data-sources-jdbc.html)） | ### 数据库 将数据库中的数据导入到 OceanBase 数据库的方案见下表。 | **数据源** | **支持的导入方案** | | --- | --- | | MySQL | - 使用 OMS 从数据库到数据库。 - DataX。 - 把 MySQL 中的数据 dump 出来，再使用 obloader 或者 LOAD DATA。方案类似文件系统迁移。 | | Oracle | - 在线迁移，使用 OMS 从数据库到数据库。 - DataX。 - 把 Oracle 中的数据 dump 出来，再使用 obloader 或者 LOAD DATA。 | | PostgreSQL | - 使用 OMS 从数据库到数据库。 - 把 PostgreSQL 中的数据 dump 出来，再使用 obloader 或者 LOAD DATA。 | | TiDB | - 使用 OMS 从数据库到数据库。 - 把 TiDB 中的数据 dump 出来，再使用 obloader 或者 LOAD DATA。 | | SQLServer | - DataX。 - 把 SQLServer 中的数据 dump 出来，再使用 obloader 或者 LOAD DATA。 | | StarRocks | 把 StarRocks 中的数据 dump 出来，再使用 obloader 或者 LOAD DATA。 | | Doris | 把 Doris 中的数据 dump 出来，再使用 obloader 或者 LOAD DATA。 | | HBase | - DataX。 - 把 HBase 中的数据 dump 出来，再使用 obloader 或者 LOAD DATA。 | | MaxCompute | - Dataworks - 把 MaxCompute 中的数据 dump 出来，再使用 obloader 或者 LOAD DATA。 | | Hologres | - Dataworks - 把 Hologres 中的数据 dump 出来，再使用 obloader 或者 LOAD DATA。 | 上一篇 下一篇 ![有帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*y6ocSqN8cqsAAAAAAAAAAAAAARQnAQ)![无帮助](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*BG9IQJyLHF8AAAAAAAAAAAAAARQnAQ)![反馈](https://gw.alipayobjects.com/mdn/ob_asset/afts/img/A*eTWdQKCRKHwAAAAAAAAAAAAAARQnAQ)[AI](https://www.oceanbase.com/obi) 咨询热线