一、问题描述

二、控制文件模板

lang=java(
  列名 字节偏移位置(可选) "预处理函数" 映射定义(可选),
  列名 字节偏移位置(可选) "预处理函数" 映射定义(可选),
  列名 字节偏移位置(可选) "预处理函数" 映射定义(可选)
);

简单示例：

lang=java
server=mysql/oracle
(
    c1 "nvl(c1,'not null')" map(field_position),
    c2 "none" map(field_position)
);

• field_position 为导入的数据文件中预处理数据的列位置。

• 控制文件的命名规范：table_name.ctl ，大小写与数据库中保持一致。
• 控制文件的内容要求列名的顺序与表中定义的列顺序保持一致，且列名大小写与表中的列名大小写保持一致。

三、使用案例

3.1、测试数据：

cat /data/test/TABLE/test.dat
1@##oceanbase@##2023-01-12 15:00:00.0@##1@##ob@##1@##ob
2@##oceanbase@##2023-01-12 15:00:00.0@##2@##ob@##2@##ob
3@##oceanbase@##2023-01-12 15:00:00.0@##3@##ob@##3@##ob

create table test01 (
id int(10) not null primary key,
name varchar(10),
time timestamp not null default '1971-01-01 01:01:01',
blank varchar(255) null
);

create table test02 (
id int(10) not null primary key,
name varchar(10) not null,
time timestamp not null,
bar varchar(255) default null,
blank varchar(255) default null,
line varchar(255) default null,
mark  varchar(255) default null,
test  varchar(255) not null
);

3.2、案例1：

控制文件：

vi /data/test01.ctl
lang=java(
id "none" map(1),
name "none" map(2),
time "none" map(3),
blank "none" map(5)
);

导入语句：

./obloader -h 10.186.60.94 -P 2883 -u root -p rootroot \
-c ywob -t mysql_yw_tent -D ywdb --table test01 --cut \
-f /data/test/TABLE/test.dat --log-path /data/ --external-data \
--replace-data --column-splitter '@##' --ctl-path /data/test01.ctl

输出结果：

All Dump Tasks Finished:
---------------------------------------------------------------------------------------------------
         No.#      |        Type       |        Name       |       Count       |       Status
---------------------------------------------------------------------------------------------------
          1        |       TABLE       |      test01       |         3         |      SUCCESS
---------------------------------------------------------------------------------------------------

3.3、案例2：

控制文件：

vi /data/test01.ctl
lang=java(
id "none" map(1)
);

导入数据，可以看到报错信息：

Error:"Field 'id' doesn't have a default value"

修改控制文件：

vi /data/test01.ctl
lang=java(
id "none" map(1),
name "none" map(2)
);

说明：

• 插入部分列时，需要为插入的每列，在参数文件中指定对应的文本列。

• not null 列必须有对应的插入数据，或者是有缺省值。

3.4、案例3：

控制文件：

vi /data/test02.ctl
lang=java(
id "none" map(1),
name "none" map(2),
time "none" map(3),
bar "none" map(4),
blank "none" map(5),
line "none" map(6),
mark "none" map(7)
);

导入语句：

./obloader -h 10.186.60.94 -P 2883 -u root -p rootroot \
-c ywce -t mysql_yw_tent -D ywdb --table test02 --cut \
-f /data/test/TABLE/test.dat --log-path /data/ --external-data \
--replace-data --column-splitter '@##' --ctl-path /data/test02.ctl

输出结果：

All Dump Tasks Finished:
----------------------------------------------------------------------------------------------------
         No.#      |        Type       |        Name       |       Count       |       Status
----------------------------------------------------------------------------------------------------
          1        |       TABLE       |      test02       |         3         |      SUCCESS
----------------------------------------------------------------------------------------------------

可以看到是成功的。但是今天在另一个同版本的 OB 环境下意外的发现了一个怪事，竟然报错了：

Error: Column count doesn't match value count at row 1

方式1：修改控制文件：

vi /data/test02.ctl
lang=java(
id "none" map(1),
name "none" map(2),
time "none" map(3),
bar "none" map(4),
blank "none" map(5),
line "none" map(6),
mark "none" map(7),
test "none" map(1)
);

3.5、在使用“obdumper+控制文件”导出数据时，也有可能会出现该报错信息：

Error: Column count doesn't match value count at row 1

补充：

示例：

SUBSTR('abc',0,3)