Oracle通过LogMiner实现数据同步迁移

下面我将就「Oracle通过LogMiner实现数据同步迁移」提供完整攻略。

概述

Oracle数据库中提供了一个LogMiner工具，可以监听数据库中的redo日志进行解析，从而在当前数据库中进行数据库同步迁移操作，类似于MySQL中的binlog。LogMiner实时解析redo日志，然后生成SQL语句以便可以通过Database Link将数据迁移到目标数据库中。

实现步骤

首先，我们需要在目标数据库中创建一个Database Link，以便连接源数据库。

sql CREATE DATABASE LINK link_name CONNECT TO username IDENTIFIED BY password USING 'tns_alias';

link_name：上述链接名字，连接源数据库和目标数据库时要用到。
username：连接源数据库的账号。
password：连接源数据库的密码。
tns_alias：TNS服务别名，该别名指向源数据库的实例。

示例如下：

sql CREATE DATABASE LINK orcl_link CONNECT TO scott IDENTIFIED BY tiger USING 'orcl';

在目标数据库中创建一个LogMiner对象，该对象将用于实时解析redo日志。

sql EXECUTE DBMS_LOGMNR_D.BUILD(OPTIONS => DBMS_LOGMNR_D.STORE_IN_REDO_LOGS);

开启LogMiner对象监听来源数据库中的redo日志。

sql EXECUTE DBMS_LOGMNR.START_LOGMNR(STARTTIME => SYSDATE, ENDTIME => SYSDATE + 10/1440, OPTIONS => DBMS_LOGMNR.DICT_FROM_ONLINE_CATALOG + DBMS_LOGMNR.CONTINUOUS_MINE);

STARTTIME：指定LogMiner从什么时候开始监听，此处指定为系统当前时间。
ENDTIME：指定LogMiner监听结束时间，此处指定为系统当前时间10分钟后。
OPTIONS：
- DBMS_LOGMNR.DICT_FROM_ONLINE_CATALOG：从在线目录中提取字典信息。
- DBMS_LOGMNR.CONTINUOUS_MINE：持续监听日志，实时更新。
使用LogMiner对象查询指定时间范围内修改的表，获取修改的SQL语句。

sql SELECT SQL_REDO FROM V$logmnr_contents WHERE SEG_OWNER = 'SCOTT' AND SEG_NAME = 'TEST' AND OPERATION = 'UPDATE';

SEG_OWNER：修改表的用户名，此处指定为SCOTT用户。
SEG_NAME：修改的表名，此处指定为TEST表。
OPERATION：操作类型，此处指定为UPDATE。

示例如下：

```sql
SELECT SQL_REDO FROM V$logmnr_contents WHERE SEG_OWNER = 'SCOTT' AND SEG_NAME = 'TEST' AND OPERATION = 'UPDATE';

SQL_REDO

update "SCOTT"."TEST" set "NAME" = 'test2' where ROWID = 'AAAEjwAABAAAAHmAAQ';

```

使用查询出来的SQL语句连接Database Link进行同步操作：

sql INSERT INTO scott.test@orcl_link SELECT * FROM scott.test WHERE ROWID='AAAEjwAABAAAAHmAAQ';

scott.test@orcl_link：指定通过orcl_link连接远程的scott下的test表，达到迁移同步的目的。
WHERE ROWID='AAAEjwAABAAAAHmAAQ'：是指定同步的行，此处使用前面查询出来的SQL语句。

示例如下：

sql INSERT INTO scott.test@orcl_link SELECT * FROM scott.test WHERE ROWID='AAAEjwAABAAAAHmAAQ';

示例

给出两个示例：

源数据库用户为scott，密码为tiger；目标数据库用户为test，密码为test，中间使用链接名为orcl_link的链接进行相关操作

```sql
CREATE DATABASE LINK orcl_link CONNECT TO scott IDENTIFIED BY tiger USING 'orcl';

EXECUTE DBMS_LOGMNR_D.BUILD(OPTIONS => DBMS_LOGMNR_D.STORE_IN_REDO_LOGS);

EXECUTE DBMS_LOGMNR.START_LOGMNR(STARTTIME => SYSDATE, ENDTIME => SYSDATE + 10/1440, OPTIONS => DBMS_LOGMNR.DICT_FROM_ONLINE_CATALOG + DBMS_LOGMNR.CONTINUOUS_MINE);

SELECT SQL_REDO FROM V$logmnr_contents WHERE SEG_OWNER = 'SCOTT' AND SEG_NAME = 'TEST' AND OPERATION = 'UPDATE';

INSERT INTO test.test@orcl_link SELECT * FROM scott.test WHERE ROWID='AAAEjwAABAAAAHmAAQ';
```

源数据库名为source_db，实例名为orcl；目标数据库名为target_db，实例名为orcl，中间使用链接名为orcl_link的链接进行相关操作

```sql
CREATE DATABASE LINK orcl_link CONNECT TO source_user IDENTIFIED BY source_pwd USING 'source_db_orcl';

EXECUTE DBMS_LOGMNR_D.BUILD(OPTIONS => DBMS_LOGMNR_D.STORE_IN_REDO_LOGS);

EXECUTE DBMS_LOGMNR.START_LOGMNR(STARTTIME => SYSDATE, ENDTIME => SYSDATE + 10/1440, OPTIONS => DBMS_LOGMNR.DICT_FROM_ONLINE_CATALOG + DBMS_LOGMNR.CONTINUOUS_MINE);

SELECT SQL_REDO FROM V$logmnr_contents WHERE SEG_OWNER = 'SCOTT' AND SEG_NAME = 'TEST' AND OPERATION = 'UPDATE';

INSERT INTO test.test@orcl_link SELECT * FROM source_db.scott.test WHERE ROWID='AAAEjwAABAAAAHmAAQ';
```