---
title: "通过 DBLink 修改远端数据库中的数据 - OceanBase 数据库 V4.5.0 | OceanBase 文档中心"
description: 通过 DBLink 修改远端数据库中的数据 创建 DBLink 后，可以使用 DBLink 修改远端数据库中的数据。当前支持通过 DBLink 向 OceanBase 数据库中 Oracle 模式的数据库和 Oracle 数据库中写入数据。 使用限制 使用 DBLink 写功能时，如果远端数据库为 OceanBase…
---
切换语言

- 中文站 - 简体中文
- International - English
- 日本站 - 日本語

文档反馈![](https://mdn.alipayobjects.com/huamei_22khvb/afts/img/A*P8CuR4UJ_FkAAAAAAAAAAAAADiGDAQ/original) OceanBase 数据库分布式版 - V 4.5.0

# 通过 DBLink 修改远端数据库中的数据

更新时间：2026-02-09 19:40:10

[编辑](https://github.com/oceanbase/oceanbase-doc/edit/V4.5.0/zh-CN/700.reference/300.database-object-management/200.manage-object-of-oracle-mode/1000.manage-dblink-of-oracle-mode/400.update-data-in-remote-database-by-a-dblink-of-oracle-mode.md)  

创建 DBLink 后，可以使用 DBLink 修改远端数据库中的数据。当前支持通过 DBLink 向 OceanBase 数据库中 Oracle 模式的数据库和 Oracle 数据库中写入数据。

## 使用限制

- 使用 DBLink 写功能时，如果远端数据库为 OceanBase 数据库，则要求远端 OceanBase 数据库的版本必须是 V4.1.0 及以上版本；如果远端数据库为 Oracle 数据库，建议使用 Oracle 11g 及以上版本。
 - DBLink 写数据功能中有一个反向 Link 特性，反向 Link 特性主要用于远端数据库访问本地数据库的对象，对象包括表、视图和同义词等。如果在使用 DBLink 写数据功能时需要使用反向 Link 特性，则需要在创建 DBLink 时提供本地数据库的 `ip`、`port`、`user_name`、`tenant_name`、`pass_word` 等信息，具体操作及详细说明信息，参见 [创建 DBLink](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004476651)。
 - 当前反向 Link 特性仅支持 OceanBase 数据库的 Oracle 模式到 OceanBase 数据库的 Oracle 模式之间的访问，暂不支持 OceanBase 数据库的 Oracle 模式到 Oracle 数据库之间的访问。

## 前提条件

- 已创建 DBLink，创建 DBLink 的详细操作，参见 [创建 DBLink](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004476651)。
 - 对于 OceanBase V4.2.1 及以上版本，使用 DBLink 功能访问远端 Oracle 数据库时，需要在集群的所有 OBServer 节点上安装并配置 OCI-12.2。此外，对于 OceanBase V4.2.1 以下版本升级到 V4.2.1 及以上版本的场景，也需要您将原来配置的 OCI-11.2 重新配置为 OCI-12.2。

  安装和配置 OCI-12.2 的详细操作，请参见 [安装和配置 OCI](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004476656)。

## 注意事项

- 通过 DBLink 向远端数据库中写入数据时，OceanBase 数据库会自动开启本地和远端的 XA 事务，无需用户手动开启。

  有关 XA 事务的详细说明，参见 [XA 事务](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004476813)。
 - 通过 DBLink 向远端数据库写入数据的操作完成后，需要手动使用 `COMMIT` 或者 `ROLLBACK` 语句提交回滚本地和远端的 XA 事务。

  更多事务控制语句的详细说明信息，参见 [事务管理概述](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004476145)。
 - 通过 DBLink 向远端数据库写入数据时，暂不支持通过设置 `autocommit = True` 来开启事务的自动提交，并且通过 DBLink 写入数据的操作一旦开启 XA 事务，系统就会将本 Session 的 `autocommit` 值强制置为 `False`，直到 XA 事务提交或者回滚后，才会恢复 `autocommit` 原本的值。

  系统变量 `autocommit` 用于设置是否开启自动提交事务，默认值为 `True`，更多系统变量 `autocommit` 的说明信息，参见 [autocommit](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004478723)。
 - 如果预期 XA 事务耗时较长，为了防止 XA 事务超时出现非预期的错误，可以使用 `set ob_trx_timeout = 1000000000;` 语句提前调大事务的超时时间。

  系统变量 `ob_trx_timeout` 用于设置事务的超时时间，默认值为 `86400000000`，单位为微秒。更多系统变量 `ob_trx_timeout` 相关的信息，参见 [ob_trx_timeout](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004478716)。
 - 通过 DBLink 调用远程 UDF（用户自定义函数）后，在 SQL 中需要显示使用 `COMMIT` 语句提交本地和远端的 XA 事务。暂不支持通过设置 `autocommit = True` 来开启事务的自动提交。在 PL 中，可以通过设置 `autocommit = True` 来开启事务的自动提交。

## 修改远端数据库中的数据

通过 DBLink 修改远端数据库中数据的操作包括插入数据、更新数据、替换数据和删除数据等操作，主要通过 `INSERT`、`UPDATE`、`MERGE INTO` 和 `DELETE` 四种 DML 语句来实现。

### 插入数据

通过 DBLink 向表中插入数据的基本语法如下：

```sql
obclient> INSERT INTO table_name@dblink_name (list_of_columns) VALUES (list_of_values);

```

相关参数说明如下：

- `table_name@dblink_name`：`table_name` 表示待修改的远端数据库的表名；`dblink_name` 表示 DBLink 名。
 - `list_of_columns`：指定表中需要插入数据的列。
 - `list_of_values`：`ist_of_columns` 中指定的列的对应值，必须一一对应。

通过 DBLink 向远端数据库的表 `t1` 中插入一行数据 `(11,11)` 的示例如下：

```sql
obclient> SELECT * FROM t1@ob_dblink;
+------+------+
| C1   | C2   |
+------+------+
|    1 |    1 |
+------+------+
1 row in set

obclient> INSERT INTO t1@ob_dblink VALUES (11,11);
Query OK, 1 row affected

obclient> SELECT * FROM t1@ob_dblink;
+------+------+
| C1   | C2   |
+------+------+
|    1 |    1 |
|   11 |   11 |
+------+------+
2 rows in set

```

通过 DBLink 向远端数据库的表中插入数据的操作与直接向表中插入数据的操作类似，只需要在语句中待操作的表名后添加 `@dblink_name` 后缀即可，有关向表中插入数据的详细操作，请参见 [插入数据](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004476122)。

更多 `INSERT` 语句的详细使用及说明，请参见 [INSERT](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004480988)。

#### 将本地表数据插入远端表

通过 DBLink 将本地表数据写入远端表的基本语法如下：

```sql
INSERT INTO table_name@dblink_name[(list_of_columns)] SELECT * FROM table_name_list [WHERE query_condition];

table_name_list:
    table_name_local [, table_name_local ...] [, table_name_dblink@dblink_name_select ...]

```

相关参数说明如下：

- `table_name@dblink_name`：目标表的名称和 DBLink 的名称。

     - `table_name`：表示需要插入数据的远端表的名称。
     - `dblink_name`：表示在本地数据库创建的指向远端数据库的数据库链接（DBLink）的名称。
 - `list_of_columns`：可选项，指定目标表中需要插入数据的列的列表。如果省略，SQL 语句将源表的列顺序和目标表的列匹配，并且包括目标表中 `SELECT` 子句选中的所有列。
 - `table_name_local`：表示本地数据库中的源表名称。
 - `table_name_dblink@dblink_name`：通过 DBLink 在远端数据库中选取的源表。

     - `table_name_dblink`：表示远端源表的名称。
     - `dblink_name_select`：表示用来访问远端源表的 DBLink 的名称。
 - `WHERE query_condition`：可选项，表示 SELECT 语句的条件部分。`query_condition` 指定了哪些行应该从源表被选取来执行插入操作。

**示例如下：**

1. 查看本地表 `tbl1` 的数据。

   ```shell
   obclient [SYS]> SELECT * FROM tbl1;

   ```

   返回结果如下：

   ```shell
   +------+------+
   | COL1 | COL2 |
   +------+------+
   |    1 | AAA  |
   |    2 | BBB  |
   |    3 | CCC  |
   +------+------+
   3 rows in set

   ```
 2. 查看远端数据库 A 中表 `a_tbl1` 的数据。

   ```shell
   obclient [SYS]> SELECT * FROM a_tbl1@ob_dblink_a;

   ```

   返回结果如下：

   ```shell
   Empty set

   ```
 3. 查看远端数据库 B 中表 `b_tbl1` 的数据。

   ```shell
   obclient [SYS]> SELECT * FROM b_tbl1@ob_dblink_b;

   ```

   返回结果如下：

   ```shell
   +------+------+
   | COL1 | COL2 |
   +------+------+
   |    1 | AA   |
   |    2 | BBB  |
   |    3 | CC   |
   +------+------+
   3 rows in set

   ```
 4. 通过数据库链接 `ob_dblink_b` 访问远程数据库表 `b_tbl1`，并从本地表 `tbl1` 选取与 `b_tbl1` 的 `col1` 和 `col2` 列匹配的记录，然后将这些选中的 `col1` 和 `col2` 值通过另一个数据库链接 `ob_dblink_a` 插入到远程数据库的表 `a_tbl1` 中。

   ```shell
   obclient [SYS]> INSERT INTO a_tbl1@ob_dblink_a
     SELECT t1.col1, t1.col2 FROM tbl1 t1, b_tbl1@ob_dblink_b t2
     WHERE t1.col1 = t2.col1
     AND t1.col2 = t2.col2;

   ```

   返回结果如下：

   ```shell
   Query OK, 1 row affected

   ```
 5. 再次查看远端数据库 A 中表 `a_tbl1` 的数据。

   ```

   返回结果如下：

   ```shell
   +------+------+
   | COL1 | COL2 |
   +------+------+
   |    2 | BBB  |
   +------+------+
   1 row in set

   ```

### 更新数据

通过 DBLink 更新表数据的基本语法如下：

```sql
obclient> UPDATE table_name@dblink_name
SET column_name = value [, column_name = value]...
[WHERE condition];

```

相关参数说明如下：

- `table_name@dblink_name`：`table_name` 表示待修改的远端数据库的表名；`dblink_name` 表示 DBLink 名。
 - `column_name = value [, column_name = value]`：指定需要更新的列，等号（=）后面的 `value` 为更新的目标值。
 - `WHERE condition`：条件子句指定要更新的行记录必须满足的条件。如果没有则表示更新表对应列的所有记录。

通过 DBLink 将远端数据库表 `t2` 中 `C1` 列的值修改为 `3` 的示例如下：

```sql
obclient> SET ob_trx_timeout = 1000000000;
Query OK, 0 rows affected

obclient> SELECT * FROM t2@ob_dblink;
+------+------+
| C1   | C2   |
+------+------+
|    2 |    2 |
+------+------+
1 row in set

obclient> UPDATE t2@ob_dblink SET C1 = 3;
Query OK, 1 row affected

obclient> SELECT * FROM t2@ob_dblink;
+------+------+
| C1   | C2   |
+------+------+
|    3 |    2 |
+------+------+
1 rows in set

```

通过 DBLink 更新远端数据库中表数据的操作与直接更新表数据的操作类似，只需要在语句中待操作的表名后添加 `@dblink_name` 后缀即可，有关更新表数据的详细操作，可参见 [更新数据](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004476124)。

更多 `UPDATE` 语句的详细使用及说明，请参见 [UPDATE](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004480986)。

#### 将本地表数据更新至远端表

**示例如下：**

   ```

   返回结果如下：

   ```
 2. 查看远端数据库 B 中表 `b_tbl1` 的数据。

   ```

   返回结果如下：

   ```
 3. 通过 DBLink `ob_dblink_b` 更新远程表 `b_tbl1`，将其 `col2` 列的值更改为与本地表 `tbl1` 中 `col1` 列值匹配的行的 `col2` 值，但是只更新那些在 `tbl1` 中存在匹配 `col1` 值的 `b_tbl1` 的行。

   ```shell
   UPDATE b_tbl1@ob_dblink_b t1
       SET t1.col2 = (SELECT t2.col2
                     FROM tbl1 t2
                     WHERE t2.col1 = t1.col1)
       WHERE EXISTS (SELECT 1
                     FROM tbl1 t2
                     WHERE t2.col1 = t1.col1);

   ```

   返回结果如下：

   ```shell
   Query OK, 3 rows affected
   Rows matched: 0  Changed: 0  Warnings: 0

   ```
 4. 再次查看远端数据库 B 中表 `b_tbl1` 的数据。

   ```

   返回结果如下：

   ```

### 替换数据

通过 DBLink 替换表数据的基本语法如下：

```sql
obclient> MERGE INTO table_name@dblink_name alias1
USING (table|view|sub_query) alias2
ON (join condition)
WHEN MATCHED THEN
    UPDATE table_name
    SET col1 = col1_val,
        col2 = col2_val
WHEN NOT MATCHED THEN
    INSERT (column_list) VALUES (column_values);

```

相关参数说明如下：

- `MERGE INTO table_name@dblink_name alias1`：指定待修改的远端数据库的表名和别名。`dblink_name` 表示 DBLink 名。
 - `USING (table|view|sub_query) alias2`：指定源表（视图、子查询）和别名。
 - `ON (join condition)`：指定判断条件。
 - `WHEN MATCHED THEN UPDATE table_name SET col1 = col_val1 , col2 = col2_val` ：当条件匹配时，执行 `UPDATE` 语句。
 - `WHEN NOT MATCHED THEN INSERT (column_list) VALUES (column_values);`：当条件不匹配时，执行 `INSERT` 语句。

使用 `MERGE INTO` 语句替换数据时，如果源表中的记录在目标表中不存在，则向目标表中插入数据；如果源表中的记录在目标表中存在，则更新记录。

通过 DBLink 替换远端数据库表 `t3` 中的数据的示例如下：

```sql
obclient> SELECT * FROM t3@orcl_dblink;
+------+------+
| C1   | C2   |
+------+------+
|    3 |    3 |
|    4 |    4 |
+------+------+
2 row in set

obclient> SELECT * FROM t4;
+------+------+
| C1   | C2   |
+------+------+
|    5 |    5 |
|    6 |    6 |
+------+------+
2 row in set

obclient> MERGE INTO t3@orcl_dblink a
 USING (SELECT C1,C2 FROM t4 ) b
 ON (a.C1 = b.C1)
 WHEN MATCHED THEN
     UPDATE SET a.C2 = b.C2
 WHEN NOT MATCHED THEN
     INSERT (a.C1,a.C2) VALUES(b.C1, b.C2);
Query OK, 2 rows affected

obclient> SELECT * FROM t3@orcl_dblink;
+------+------+
| C1   | C2   |
+------+------+
|    3 |    3 |
|    4 |    4 |
|    5 |    5 |
|    6 |    6 |
+------+------+
4 row in set

```

通过 DBLink 替换远端数据库中表数据的操作与直接替换数据的操作类似，只需要在语句中待操作的表名后添加 `@dblink_name` 后缀即可，有关替换表数据的详细操作，可参见 [替换数据](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004476123)。

更多 `MERGE INTO` 语句的详细使用及说明，请参见 [MERGE](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004480984)。

#### 使用本地表数据替换远端表数据

**示例如下：**

   ```

   返回结果如下：

   ```

   返回结果如下：

   ```shell
   +------+------+
   | COL1 | COL2 |
   +------+------+
   |    1 | AAA  |
   |    2 | B2   |
   |    5 | E5   |
   +------+------+
   3 rows in set

   ```
 3. 通过 DBLink `ob_dblink_b` 更新远程表 `b_tbl1`，将其 `col2` 列的值更改为与本地表（源表） `tbl1` 中 `col1` 列值匹配的行的 `col2` 值，但是只更新那些在 `tbl1` 中存在匹配 `col1` 值的 `b_tbl1` 的行。如果源表 `tbl1` 有行在目标表 `b_tbl1` 中没有匹配的行（基于 `col1` 值），则执行 `INSERT` 操作，插入新的行到目标表 `b_tbl1` 中，其 `col1` 和 `col2` 的值来源于源表 `tbl1` 的对应列。

   ```shell
   MERGE INTO b_tbl1@ob_dblink_b t1
       USING tbl1 t2
           ON (t2.col1 = t1.col1)
       WHEN MATCHED THEN UPDATE SET t1.col2 = t2.col2
       WHEN NOT MATCHED THEN INSERT (t1.col1, t1.col2) VALUES(t2.col1, t2.col2);

   ```

   返回结果如下：

   ```shell
   Query OK, 3 rows affected

   ```

   返回结果如下：

   ```shell
   +------+------+
   | COL1 | COL2 |
   +------+------+
   |    1 | AAA  |
   |    2 | BBB  |
   |    5 | E5   |
   |    3 | CCC  |
   +------+------+
   4 rows in set

   ```

### 删除数据

通过 DBLink 删除表数据的基本语法如下：

```sql
obclient> DELETE FROM table_name@dblink_name [WHERE condition];

```

相关参数说明如下：

- `table_name@dblink_name`：`table_name` 表示待修改的远端数据库的表名；`dblink_name` 表示 DBLink 名。
 - `WHERE condition`：条件子句指定要删除的数据必须满足的条件，如果没有则表示执行全表删除。

通过 DBLink 删除远端数据库表 `t5` 中 `C2 = 7` 的数据行的示例如下：

obclient> SELECT * FROM t5@orcl_dblink;
+------+------+
| C1   | C2   |
+------+------+
|    7 |    7 |
|    8 |    8 |
+------+------+
2 row in set

obclient> DELETE FROM t5@orcl_dblink WHERE C2 = 7;
Query OK, 1 row affected

obclient> SELECT * FROM t5@orcl_dblink;
+------+------+
| C1   | C2   |
+------+------+
|    8 |    8 |
+------+------+
1 row in set

```

通过 DBLink 删除远端数据库的表数据的操作与直接删除表数据的操作类似，只需要在语句中待操作的表名后添加 `@dblink_name` 后缀即可，有关删除表数据的详细操作，可参见 [删除数据](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004476126)。

更多 `DELETE` 语句的详细使用及说明，请参见 [DELETE](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004480989)。

#### 根据本地表数据删除远端表数据

**示例如下：**

   ```

   返回结果如下：

   ```

   返回结果如下：

   ```shell
   +------+------+
   | COL1 | COL2 |
   +------+------+
   |    2 | BBB  |
   |    1 | AA1  |
   |    2 | BB2  |
   |    3 | CC3  |
   +------+------+
   4 rows in set

   ```
 3. 删除远程表 `a_tbl1` 中所有在本地表 `tbl1` 中找到匹配 `col1` 和 `col2` 列值的行。

   ```shell
   DELETE FROM a_tbl1@ob_dblink_a t1
       WHERE EXISTS (SELECT 1
                     FROM tbl1 t2
                     WHERE t2.col1 = t1.col1
                     AND t2.col2 = t1.col2
                   );

   ```

   返回结果如下：

   ```
 4. 再次查看远端数据库 A 中表 `a_tbl1` 的数据。

   ```

   返回结果如下：

   ```shell
   +------+------+
   | COL1 | COL2 |
   +------+------+
   |    1 | AA1  |
   |    2 | BB2  |
   |    3 | CC3  |
   +------+------+
   3 rows in set

   ```

### DBLink 写支持 SAVEPOINT 功能

#### 说明

DBLink 写支持 `SAVEPOINT` 功能，允许执行事务回滚到指定的保存点。

**示例如下：**

远端数据库中有空表 `tbl1`，现通过以下 SQL 语句展示 DBLink 执行事务回滚到指定的保存点。

1. 向远程表 `tbl1` 中插入行 1。

   ```sql
   INSERT INTO tbl1@dblink_o2 VALUES(1);

   ```
 2. 创建名为 `sp1` 的 Savepoint。

   ```sql
   SAVEPOINT sp1;

   ```
 3. 向远程表 `tbl1` 中插入行 2。

   ```sql
   INSERT INTO tbl1@dblink_o2 VALUES(2);

   ```
 4. 创建名为 `sp2` 的 Savepoint。

   ```sql
   SAVEPOINT sp2;

   ```
 5. 将修改回滚到 `sp1`。

   ```sql
   ROLLBACK TO sp1;

   ```
 6. 向远程表 `tbl1` 中插入行 3。

   ```sql
   INSERT INTO tbl1@dblink_o2 VALUES(3);

   ```
 7. 提交事务。

   ```sql
   COMMIT;

   ```
 8. 查询表 `tbl1` 的数据。

   ```sql
   obclient [SYS]> SELECT * FROM tbl1@dblink_o2;

   ```

   返回结果如下：

   ```shell
   +------+
   | C1   |
   +------+
   |    1 |
   |    3 |
   +------+
   2 rows in set

   ```

## 相关文档

更多 DBLink 相关的操作，请参见以下信息：

- [创建 DBLink](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004476651)
 - [查看 DBLink](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004476654)
 - [通过 DBLink 访问远端数据库的数据](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004476650)
 - [删除 DBLink](https://www.oceanbase.com/docs/common-oceanbase-database-cn-1000000004476652)

 上一篇 下一篇 ![有帮助](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) 咨询热线