OceanBase

Target DataSource：

MySQL

Connection

Basic Functions

Function	Description
Schema Migration	If the target schema does not exist, BladePipe will automatically generate and execute CREATE statements based on the source metadata and the mapping rule.
Full Data Migration	Migrate data by sequentially scanning data in tables and writing it in batches to the target database.
Incremental Data Sync	Sync of common DML like INSERT, UPDATE, DELETE is supported. UPDATE and DELETE for tables without primary keys are not synced by default (manual selection required).
Data Verification and Correction	Verify all existing data. Optionally, you can correct the inconsistent data based on verification results. Scheduled DataTasks are supported. For more information, see Create Verification and Correction DataJob.
Subscription Modification	Add, delete, or modify the subscribed tables with support for historical data migration. For more information, see Modify Subscription.
Position Resetting	Reset positions by timestamp or file position to consume the OceanBase data in a past period again.
Table Name Mapping	Support the mapping rules, namely, keeping the name the same as that in Source, converting the text to lowercase, converting the text to uppercase, truncating the name by "_digit" suffix.
DDL Sync	ALTER TABLE ADD COLUMN, DROP COLUMN, MODIFY COLUMN, CHANGE COLUMN ADD INDEX RENAME TABLE Other compatible DDL operations.

Advanced Functions

Function	Description
CDC-based Incremental Data Sync	Support incremental data synchronization based on OceanBase LogProxy.
Binlog-based Incremental Data Sync	Support incremental data synchronization based on OceanBase Binlog service. This method is limited to OceanBase for MySQL.
Tenant-specific Data Migration and Sync	Allow specifying a tenant to parse relevant information from ObLogProxy events.
Removal of Target Data before Full Data Migration	Remove the existing data in the Target before running the Full Data Migration, applicable for DataJobs reruning and scheduled Full Data migrations.
Recreating Target Table	Recreate target tables before running the Full Data Migration, applicable for DataJobs reruning and scheduled Full Data migrations.
Incremental Data Write Conflict Resolution Rule	IGNORE: Ignore primary key conflicts (skip writing), REPLACE: Replace the entire row in case of primary key conflicts.
Handling of Zero Value for Time	Allow setting zero value for time to different data types to prevent errors when writing to the Target.
Custom Code	For more information, see Custom Code Processing, Debug Custom Code and Logging in Custom Code.
Data Filtering Conditions	Support data filtering using WHERE conditions, with SQL-92 as the SQL language. For more information, see Data Filtering.
Setting Target Primary Key	Change the primary key to another field to facilitate data aggregation and other operations.

---

Source

Prerequisites

Prerequisite	Description
Permissions for Account	Permissions for all tables in the SYS tenant databases and SELECT permission for databases and tables to be synced.
Port Preparation	Allow the migration and sync node (Worker) to connect to the OceanBase ports (e.g., 2881) and LogProxy ports (if available, e.g., 2983).

Parameters

Parameter	Description
needJsonEscape	Escape special characters in JSON to be written to the target database.
fullDataSqlConditionEnabled	Add filtering conditions in SQL during source data scanning. It only works in Full Data migration.
eventStoreSize	Cache size for parsed incremental events.
obIncreMode	Incremental mode, including LogProxy and Binlog options.
clusterUrl	OceanBase cluster URL (similar to a name server).
obLogProxyHost	LogProxy service address, typically in the format ip:2983. Required for LogProxy incremental mode.
rpcPortList	RPC ports for OceanBase server nodes. If the host parameter is ip1;ip2, this parameter should be port1;port2. Common port is 2882. Required for LogProxy incremental mode.
syncAccount	Account for LogProxy to connect to OceanBase server (optional).
syncPwd	Password for LogProxy to connect to OceanBase server (optional).
tenant	The tenant where the subscribed tables reside.
workingMode	Libobcdc parameter that LogProxy depends on. The default value is storage.

Tips: To modify the general parameters, see General Parameters and Functions.

---

Target

Prerequisites

Prerequisite	Description
Permissions for Account	See Permissions Required for MySQL/MariaDB.
Port Preparation	Allow the migration and sync node (Worker) to connect to the MySQL/MariaDB port (e.g., 3306).

Parameters

Parameter	Description
keyConflictStrategy	Strategy for handling primary key conflicts during write in Incremental DataTask: IGNORE: Ignore conflicts (default) REPLACE: Replace conflicts (optional)
dstWholeReplace	Convert INSERT and UPDATE operations into full row replacement in the Target.
deCycle	Enable filtering in bidirectional sync to filter DML/DDL with specific markers.
specialSqlMode	Set a specific SQL mode when initializing the connection between databases.
defaultGisSRID	Set the SRID for GIS data types.
dstTimeZone	Target time zone, e.g., +08:00, Asia/Shanghai, America/New_York, etc.
increParallelApplyStrategy	Parallel write strategy for relational databases in the Target: KEY: Parallel writing to partitions separated based on primary keys. TABLE: Parallel writing to partitions separated based on tables. KEY_UPGRADE_TABLE: Parallel writing to partitions separated based on primary keys. Upgrade the partition to a table if there is an update to the unique key.

Tips: To modify the general parameters, see General Parameters and Functions.

Connection

Basic Functions

Advanced Functions

Limits

Example

FAQ

Source

Prerequisites

Parameters

Target

Prerequisites

Parameters