BladePipe 1.7.0: Stronger alerts, Broader DB support, Faster KingbaseES scanning.
Skip to main content

Oracle to Tunnel

BladePipe supports data replication from Oracle to Tunnel. View supported migration, sync, verification, and connector capabilities.

Target DataSource：
Tunnel

Connection

Basic Functions

FunctionDescription
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).

Position Resetting

Reset the position by timestamp or Scn to consume Oracle Redo Log 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 Synchronization
  • ALTER TABLE ADD, MODIFY, DROP COLUMN
  • TRUNCATE TABLE
  • ALTER TABLE RENAME TO
  • CREATE TABLE (whole database sync)
  • DROP TABLE (whole database sync)

Advanced Functions

FunctionDescription
Automatic Dictionary Creation

When using offline dictionaries to parse Oracle Redo files, the dictionary is automatically created during DataJob creation.

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.

Limits

LimitDescription
Incremental Data Sync Performance

Due to LogMiner performance limits and BladePipe's lack of parallel analysis, the performance benchmark is set at 3000 records per second.

Data Types

Do not support BLOB and derived types.

Examples

TitleDetails
Cross-Internet Data Synchronization

See Cross-Internet Data Synchronization

Source

Prerequisites

PrerequisiteDescription
Permissions for Account

See Permissions Required for Oracle.

Incremental Data Sync Preparation

See Preparation for Oracle LogMiner.

Port Preparation

Allow the migration and sync node (Worker) to connect to the Oracle port (e.g., 1521).

Parameters

ParameterDescription
fullFetchSize

Fetch size for scaning full data.

eventStoreSize

Cache size for parsed incremental events.

logminerUser

User name for connection to Oracle to execute LogMiner SQL.

logminerPasswd

Password for connection to Oracle to execute LogMiner SQL.

logminerConnectType

Way to connect to Oracle (PDB) to execute LogMiner SQL, including ORACLE_SID and ORACLE_SERVICE options.

logminerSidOrService

SID or service name for connection to Oracle (PDB) to execute LogMiner SQL.

parseRedoSqlParallel

Number of threads for parallel parsing of LogMiner data.

parseRedoSqlBufferSize

Size of the circular buffer for parsing LogMiner data.

redoFetchSize

Number of rows of LogMiner analyzed data to fetch each time.

redoOfferTransMaxSize

Maximum number of unconsumed but committed transactions in cache.

oraMiningSessionPauseSec

Interval between LogMiner sessions, in seconds.

maxEventCountPerTxInMem

Maximum number of events per transaction in memory.

logMiningScnStep

Analysis range specified when Oracle LogMiner analyzes redo logs.

abandonUnCommitTxTimeoutSec

Automatically abandon transactions that have not been committed for longer than the specified timeout.

restartTxWithDataTimeoutSec

Automatically restart DataJobs for transactions with data changes that have not been committed for longer than the specified timeout.

oraUseOnlineDic

Whether to use online logs; false means using offline logs, which may put more stress on Oracle.

oraReleaseIntervalSec

Interval for recreating connection for analysis to release Oracle server resources.

oraMiningSessionPauseSec

Interval between execution of LogMiner commands for analysis.

fallBackScnStep

Distance to keep from the latest Redo log data; 0 means to keep right behind the latest Redo log data.

sqlCaseConversionEnabled

Whether to enable DDL case conversion (according to the default case rules of the current database).

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

Target

Prerequisites

PrerequisiteDescription
Port Preparation

For BladePipe (Docker version), modify the docker-compose.yml port mappings before installing/upgrading after extraction, and open relevant ECS security group ports for remote connection.

Parameters

ParameterDescription
writeParallel

Concurrency level for writing on the other end, significantly impacts migration or synchronization performance.

batchWriteSize

The maximum data size of a single message.

deCycle

Prevent circular data replication.

deCycleFlag

Default marker to prevent circular data replication.

protocol

Protocol for data transfer in Tunnel. Support HTTP currently.

uriPrefix

URI prefix for Tunnel data sources.

contentCompressType

Data compression form for Tunnel data sources. Support DeInflater / GZIP currently.

dbs

Definition of the data source schema.

printDataInLog

Enable to print key data to logs for troubleshooting. Enabling this feature may impact performance and data security.

schemaFormat

Type of Value Schema.

printCustomCodeDebugLog

Print custom code DEBUG logs (Note that it will print data before and after processing, which may increase disk usage and impact sync performance). This parameter takes effect dynamically and DataJob restart is not required.

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