1、创建用户并授予使用权限
CREATE USER gsloader WTH PASSWORD 'Gsloader14';
GRANT ALL ON FUNCTlON copy_error_log_create() TO gsloader;
GRANT ALL ON SCHEMA public To gsloader;
SELECT copy_error_log_create();
SELECT copy_summary_create();
GRANT ALL FRIVILEGES ON public.pgxc_copy_error_log To gsloader;
GRANT ALL PRIVILEGES ON public.gs_copy_summary To gsloader;


2、创建系统表和数据表
select copy_summary_create();  --gs_copy_summary记录执行结果汇总,包括成功行数,出错行数,忽略行数,空行数。

CREATE TABLE loader_tbl
(
ID NUMBER
NAME VARCHAR2(20),
CON VARCHAR2(20),
DT DATE
);



3、创建控制文件ctl
loader_tbl.ctl

Load Data
truncate INTO TABLE loader_tbl
fields terminated by ','
(
col1 integer external,
col2 integer external
)

4、数据文件
loader_tbl.csv

123456,7891011
987654,3213210

5、进行导入
gs_loader control=loader_tbl.ctl data=loader_tbl.csv db=postgres discard=doader.dis bad=loader.bad errors=5 port=30100 passwd=Gsloader14 user=gsloader


Logo

一站式 AI 云服务平台

更多推荐