COPY
功能描述
通过COPY命令实现在表和文件之间复制数据。
COPY FROM从一个文件复制数据到一个表,COPY TO把一个表的数据复制到一个文件。
注意事项
- 当参数enable_copy_server_files关闭时,只允许初始用户执行COPY FROM FILENAME或COPY TO FILENAME命令,当参数enable_copy_server_files打开时,允许具有SYSADMIN权限的用户或继承了内置角色gs_role_copy_files权限的用户执行,但默认禁止对数据库配置文件,密钥文件,证书文件和审计日志执行COPY FROM FILENAME或COPY TO FILENAME,以防止用户越权查看或修改敏感文件。同时enable_copy_server_files打开时,管理员可以通过guc参数safe_data_path设置普通用户可以导入导出的路径必须为设置路径的子路径,未设置此guc参数时候(默认情况),不对普通用户使用的路径进行拦截。该参数会对copy使用路径中的相对路径进行报错处理。
- COPY只能用于表,不能用于视图。
- COPY TO需要读取的表的SELECT权限,COPY FROM需要插入的表的INSERT权限。
- 如果声明了一个字段列表,COPY将只在文件和表之间复制已声明字段的数据。如果表中有任何不在字段列表里的字段,COPY FROM将为那些字段插入缺省值。
- 如果声明了数据源文件,服务器必须可以访问该文件;如果指定了STDIN,数据将在客户前端和服务器之间流动,输入时,表的列与列之间使用TAB键分隔,在新的一行中以反斜杠和句点(\.)表示输入结束。
- 如果数据文件的任意行包含比预期多或者少的字段,COPY FROM将抛出一个错误。
- 数据的结束可以用一个只包含反斜杠和句点(\.)的行表示。如果从文件中读取数据,数据结束的标记是不必要的;如果在客户端应用之间复制数据,必须要有结束标记。
- COPY FROM中\N为空字符串,如果要输入实际数据值\N ,使用\\N。
- COPY FROM 支持通过列表达式对数据做预处理,但是列表达式中不支持子查询这类能力。
- COPY FROM在遇到数据格式错误时会回滚事务,但没有足够的错误信息,不方便用户从大量的原始数据中定位错误数据。
- COPY FROM/TO适合低并发,本地小数据量导入导出。
- COPY使用二进制格式时,不支持分布式下转码。
- COPY是服务端命令,执行环境和数据库服务端进程保持一致;\COPY是客户端元命令,执行环境和客户端gsql保持一致。需要注意的是,当在沙箱环境中使用数据库和gsql时,COPY命令和\COPY命令都使用沙箱内的路径;当在沙箱环境中使用数据库,在沙箱外使用gsql时,COPY命令使用沙箱内的路径,\COPY命令则使用沙箱外的路径。
- 在对建有全局二级索引的基表执行COPY数据导入时,需要开启enable_stream_operator参数,以达到最优数据导入性能。
- 在COPY TO导出的过程中,如果关闭GUC参数support_zero_character,表内字段数据存在'\0'字符,则字段数据在导出时会发生截断,字段中只有'\0'之前的数据会被导出。打开参数后,'\0'字符也会被导出,性能损耗与'\0'字符数量正相关。
- pgxc_copy_error_log表的模式从public变更为pg_catalog后,原public模式下的表废弃。由于public下的表可能与用户表同名,因此需要用户进行识别,确认不是用户表后,将数据迁移到pg_catalog模式下相应的表里之后,删除原public模式下废弃的表。由于pg_catalog模式下存在同名表,GSQL元命令\d(+)优先匹配pg_catalog.pgxc_copy_error_log,而因为是系统表的缘故不显示,因此列表中找不到pgxc_copy_error_log,但是实际public模式下存在这张表。可以直接通过public.pgxc_copy_error_log引用。
- 在导出float4/float8类型的数据时,推荐将extra_float_digits设为3,避免有效位数丢失造成导出导入前后数据不一致。
语法格式
- 从一个文件复制数据到一个表。
1 2 3 4 5 6 7 8 9 10 11 12 13
COPY table_name [ ( column_name [, ...] ) ] FROM { 'filename' | STDIN } [ [ USING ] DELIMITERS 'delimiters' ] [ WITHOUT ESCAPING ] [ LOG ERRORS ] [ LOG ERRORS DATA ] [ REJECT LIMIT 'limit' ] [ [ WITH ] ( option [, ...] ) | ( copy_option [, ...] ) | [ TRANSFORM ( { column_name [ data_type ] [ AS transform_expr ] } [, ...] ) ] | [ FIXED FORMATTER ( { column_name( offset, length ) } [, ...] ) ] ];
上述语法中fixed formatter与copy_option语法兼容、与option语法不兼容;copy_option与option语法不兼容;transform与copy_option、fixed formatter语法兼容。
- 把一个表的数据复制到一个文件。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
COPY table_name [ ( column_name [, ...] ) ] TO { 'filename' | STDOUT } [ [ USING ] DELIMITERS 'delimiters' ] [ WITHOUT ESCAPING ] [ [ WITH ] ( option [, ...] ) | ( copy_option [, ...] ) | [ FIXED FORMATTER ( { column_name( offset, length ) } [, ...] ) ] ]; COPY query {(SELECT) | (VALUES)} TO { 'filename' | STDOUT } [ WITHOUT ESCAPING ] [ [ WITH ] ( option [, ...] ) | ( copy_option [, ...] ) | [ FIXED FORMATTER ( { column_name( offset, length ) } [, ...] ) ] ];
其中可选参数option子句语法为:1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23
FORMAT 'format_name' | FORMAT binary | OIDS [ boolean ] | DELIMITER 'delimiter_character' | NULL 'null_string' | HEADER [ boolean ] | USEEOF [ boolean ] | FILEHEADER 'header_file_string' | FREEZE [ boolean ] | QUOTE 'quote_character' | ESCAPE 'escape_character' | EOL 'newline_character' | NOESCAPING [ boolean ] | FORCE_QUOTE { ( column_name [, ...] ) | * } | FORCE_NOT_NULL ( column_name [, ...] ) | ENCODING 'encoding_name' | IGNORE_EXTRA_DATA [ boolean ] | FILL_MISSING_FIELDS [ boolean ] | COMPATIBLE_ILLEGAL_CHARS [ boolean ] | DATE_FORMAT 'date_format_string' | TIME_FORMAT 'time_format_string' | TIMESTAMP_FORMAT 'timestamp_format_string' | SMALLDATETIME_FORMAT 'smalldatetime_format_string'
其中可选参数copy_option子句语法为:1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
OIDS | NULL 'null_string' | HEADER | USEEOF | FILEHEADER 'header_file_string' | FREEZE | FORCE_NOT_NULL column_name [, ...] | FORCE_QUOTE { column_name [, ...] | * } | BINARY | CSV | QUOTE [ AS ] 'quote_character' | ESCAPE [ AS ] 'escape_character' | EOL 'newline_character' | ENCODING 'encoding_name' | IGNORE_EXTRA_DATA | FILL_MISSING_FIELDS | COMPATIBLE_ILLEGAL_CHARS | DATE_FORMAT 'date_format_string' | TIME_FORMAT 'time_format_string' | TIMESTAMP_FORMAT 'timestamp_format_string' | SMALLDATETIME_FORMAT 'smalldatetime_format_string'
参数说明
- query
其结果将被复制。
取值范围:仅支持一个SELECT或VALUES命令,命令结尾不需要分号。
- table_name
表的名称(可以有模式修饰)。
取值范围:已存在的表名。
- column_name
可选的待复制字段列表。
取值范围:如果没有声明字段列表,将使用所有字段。
- STDIN
声明输入是来自标准输入。输入时,表的列与列之间使用TAB键分隔,在新的一行中以反斜杠和句点(\.)表示输入结束。
- STDOUT
声明输出打印到标准输出。
- FIXED
打开字段固定长度模式。在字段固定长度模式下,不能声明DELIMITER,NULL,CSV选项。指定FIXED类型后,不能再通过option或copy_option指定BINARY、CSV、TEXT等类型。定长模式下无法正确处理数据列中的换行符。
定长格式定义如下:
- 每条记录的每个字段长度相同。
- 长度不足的字段以空格填充,数字类型字段左对齐,字符字段右对齐。
- 字段和字段之间没有分隔符。
- [USING] DELIMITERS 'delimiters'
在文件中分隔各个字段的字符串,分隔符最大长度不超过10个字节。
取值范围:文本模式不允许包含\.abcdefghijklmnopqrstuvwxyz0123456789中的任何一个字符,csv格式无此限制。
缺省值:在文本模式下,缺省是水平制表符,在CSV模式下是一个逗号。
出于历史原因,DELIMITER和DELIMITERS都可以指定分隔符,但是DELIMITERS后面可以直接跟括号语法,DELIMITER不可以直接跟括号,会语法报错。
- WITHOUT ESCAPING
在TEXT格式中,不对'\'和后面的字符进行转义。
取值范围:仅支持TEXT格式。
- LOG ERRORS
若指定,则开启对于COPY FROM语句中数据类型错误的容错机制,相关错误行的错误记录会记录到此库中pg_catalog.pgxc_copy_error_log表中,备后续查阅。
取值范围:仅支持导入(即COPY FROM)时指定。
此容错选项的使用限制如下:
- 此容错机制仅捕捉COPY FROM过程中CN节点上数据解析过程中相关的数据类型错误(DATA_EXCEPTION),诸如CN与DN之间的网络交互错误或者是DN上的表达式转换错误等CN数据解析逻辑之外的过程无法涵盖在内。
- COPY已有的容错选项(如IGNORE_EXTRA_DATA)开启时,对应类型的错误会按照已有的方式处理而不会报出异常,因此错误表也不会有相应数据。
- 此容错机制的覆盖范围与GDS Foreign Table的容错范围相同。推荐用户通过表名列以及COPY FROM语句开始时间戳对查询结果进行过滤。错误数据处理请联系管理员处理。
- LOG ERRORS DATA
LOG ERRORS DATA和LOG ERRORS的区别:
- LOG ERRORS DATA会填充容错表的rawrecord字段。
- 只有super权限的用户才能使用LOG ERRORS DATA参数选项。
- 使用“LOG ERRORS DATA”时,若错误内容过于复杂可能存在写入容错表失败的风险,导致任务失败。
- 对于以某种编码无法读起来的错误,对应ERRCODE_CHARACTER_NOT_IN_REPERTOIRE和ERRCODE_UNTRANSLATABLE_CHARACTER两种错误码,不记录rawrecord字段。
- 不支持BINARY格式的文件。
- REJECT LIMIT 'limit'
与LOG ERROR选项共同使用,对COPY FROM的容错机制设置数值上限,一旦此COPY FROM语句错误数据超过选项指定条数,则会按照原有机制报错。
取值范围:正整数(1-2147483647),'unlimited'(无最大值限制)
缺省值:若未指定LOG ERRORS,则会报错;若指定LOG ERRORS,则默认为0。
如上述LOG ERRORS中描述的容错机制,REJECT LIMIT的计数也是按照执行COPY FROM的CN上遇到的解析错误数量计算,而不是每个DN上的错误数量,这点请与GDS容错机制区别开。
- FORMATTER
在固定长度模式中,定义每一个字段在数据文件中的位置。按照column(offset,length)格式定义每一列在数据文件中的位置。
取值范围:
- offset取值不能小于0,以字节为单位。
- length取值不能小于0,以字节为单位。
所有列的总长度和不能大于1GB。
文件中没有出现的列默认以空值代替。
- OPTION { option_name ' value ' }
用于指定兼容外表的各类参数。
- FORMAT
取值范围:CSV、TEXT、FIXED、BINARY。
- CSV格式的文件,可以有效处理数据列中的换行符,但对一些特殊字符处理有欠缺。
- TEXT格式的文件,可以有效处理一些特殊字符,但无法正确处理数据列中的换行符。
- FIXED格式的文件,适用于每条数据的数据列都比较固定的数据,长度不足的列会添加空格补齐,过长的列则会自动截断。无法正确处理数据列中的换行符。
- BINARY形式的选项会使得所有的数据被存储/读作二进制格式而不是文本。 这比TEXT和CSV格式的要快一些,但是一个BINARY格式文件可移植性比较差。
缺省值:TEXT
- OIDS
在处理包含OID的表(通常是系统表)时,指定是否对OID隐藏列进行导入导出。
取值范围:true/on、false/off。
缺省值:false
- DELIMITER
指定数据文件行数据的字段分隔符。
- 分隔符不能是\r和\n。
- 分隔符不能和null参数相同,CSV格式数据的分隔符不能和quote参数相同。
- TEXT格式数据的分隔符不能包含: 小写字母、数字和特殊字符.\。
- 数据文件中单行数据长度需<1GB,如果分隔符较长且数据列较多的情况下,会影响导出有效数据的长度。
- 分隔符推荐使用多字符和不可见字符。多字符例如'$^&';不可见字符例如0x07,0x08,0x1b等。
- 如使用TAB制表符进行CSV文件分隔,使用E'\t'。
取值范围:支持多字符分隔符,但分隔符不能超过10个字节。
缺省值:
- TEXT格式的默认分隔符是水平制表符(tab)。
- CSV格式的默认分隔符为“,”。
- FIXED格式没有分隔符。
- NULL
取值范围:
- null值不能是\r和\n,最大为100个字符。
- null值不能和分隔符、quote参数相同。
缺省值:
- CSV格式下默认值是一个没有引号的空字符串。
- 在TEXT格式下默认值是\N。
- HEADER
指定导出数据文件是否包含标题行,标题行一般用来描述表中每个字段的信息。header只能用于CSV,FIXED格式的文件中。
在导入数据时,如果header选项为on,则数据文本第一行会被识别为标题行,会忽略此行。如果header为off,而数据文件中第一行会被识别为数据。
在导出数据时,如果header选项为on,则需要指定fileheader。如果header为off,则导出数据文件不包含标题行。
取值范围:true/on,false/off。
缺省值:false
- USEEOF
取值范围:true/on,false/off。
缺省值:false
- QUOTE
缺省值:双引号 '"'
- quote参数不能和分隔符、null参数相同。
- quote参数只能是单字节的字符。
- 推荐不可见字符作为quote,例如0x07,0x08,0x1b等。
- ESCAPE
CSV格式下,用来指定逃逸字符,逃逸字符只能指定为单字节字符。
缺省值:双引号 '"'。当与quote值相同时,会被替换为'\0'。
- EOL 'newline_character'
取值范围:支持多字符换行符,但换行符不能超过10个字节。常见的换行符,如\r、\n、\r\n(设成0x0D、0x0A、0x0D0A效果是相同的),其他字符或字符串,如$、#。
- EOL参数只能用于TEXT格式的导入导出,不支持CSV格式和FIXED格式导入。为了兼容原有EOL参数,仍然支持导出CSV格式和FIXED格式时指定EOL参数为0x0D或0x0D0A。
- EOL参数不能和分隔符、null参数相同。
- EOL参数不能包含:.abcdefghijklmnopqrstuvwxyz0123456789。
- FORCE_QUOTE { ( column_name [, ...] ) | * }
在CSV COPY TO模式下,强制在每个声明的字段周围对所有非NULL值都使用引号包围。*代表所有字段,NULL输出不会被引号包围。
取值范围:已存在的字段。
- FORCE_NOT_NULL ( column_name [, ...] )
在CSV COPY FROM模式下,指定的字段输入不能为空。
取值范围:已存在的字段。
- ENCODING
- IGNORE_EXTRA_DATA
若数据源文件比外表定义列数多,是否会忽略对多出的列。该参数只在数据导入过程中使用。
取值范围:true/on、false/off。
- 参数为true/on,若数据源文件比外表定义列数多,则忽略行尾多出来的列。
- 参数为false/off,若数据源文件比外表定义列数多,会显示如下错误信息。
1
extra data after last expected column
缺省值:false。
如果行尾换行符丢失,使两行变成一行时,设置此参数为true将导致后一行数据被忽略掉。
- COMPATIBLE_ILLEGAL_CHARS
取值范围:true/on,false/off。
- 参数为true/on,则导入时遇到非法字符进行容错处理,非法字符转换后入库,不报错,不中断导入。导出时对非法字符进行转换后导出,不报错,不中断导出。
- 参数为false/off,导入时遇到非法字符进行报错,中断导入。导出时遇到非法字符进行报错,中断导出。
缺省值:false/off
导入非法字符容错规则如下:
- 对于'\0',容错后转换为空格。当support_zero_char打开时则会按照原格式进行导入。
- 对于其他非法字符,容错后转换为guc参数convert_illegal_char_mode设置的字符,默认为'?'。
- 若compatible_illegal_chars为true/on标识导入时对于非法字符进行容错处理,若NULL、DELIMITER、QUOTE、ESCAPE设置为空格或问号,则会通过如"illegal chars conversion may confuse COPY escape 0x20"等报错信息提示用户修改可能引起混淆的参数以避免导入错误。
- compatible_illegal_chars为true/on时,不支持对binary格式的数据进行导入。
- 如果设置了GUC参数copy_special_character_version='no_error',则会在导入的过程中屏蔽非法字符编码的校验,将非法编码字符按原样导入,查询时以乱码显示。在了解后果的情况下,请谨慎选择开启此参数。
- copy_special_character_version='no_error'时优先级会高于compatible_illegal_chars=true,即非法编码字符会按原样导入。
- 对于设置了copy_special_character_version='no_error'或compatible_illegal_chars=true的场景,每识别到一行包含非法编码的数据,都会向数据库运行日志中写入一条记录,写日志的行为会占用少量磁盘带宽。如果想要消除此部分的影响,可以配置guc参数enable_log_copy_illegal_chars为off,即不向数据库运行日志中写入记录。除有性能需要,否则不推荐修改此配置。
导出非法字符容错规则如下:
导出时分为需要转码的场景(数据库服务端编码与客户端编码不一致)和不需要转码的场景(数据库服务端编码与客户端编码保持一致),不同场景下导出的表现不同。可以通过show server_encoding;语句查询数据库服务端编码。通过show client_encoding;语句查询数据库客户端编码。
- 需要转码场景:
- 对于'\0',容错后转换为空格。当support_zero_char打开时则会按照原格式进行导出。
- 对于其他非法字符,容错后转换为guc参数convert_illegal_char_mode设置的字符,默认为'?'。
- 若compatible_illegal_chars为true/on标识导出时对于非法字符进行容错处理,若NULL、DELIMITER、QUOTE、ESCAPE设置为空格或问号,则会通过如"illegal chars conversion may confuse COPY escape 0x20"等报错信息提示用户修改可能引起混淆的参数,以避免导出错误。
- compatible_illegal_chars为true/on时,不支持对binary格式的数据进行导出。
- 对于设置了compatible_illegal_chars=true的场景,每识别到一行包含非法编码的数据,都会向数据库运行日志中写入一条记录,写日志的行为会占用少量磁盘带宽。如果想要消除此部分的影响,可以配置guc参数enable_log_copy_illegal_chars为off,即不向数据库运行日志中写入记录。除有性能需要,否则不推荐修改此配置。
- 不需要转码场景:
- 对于不需要转码的场景,数据会按照数据库内原样进行导出,即使数据中存在非法字符并设置compatible_illegal_chars=true。
- compatible_illegal_chars为true/on时,不支持对binary格式的数据进行导出。
- FILL_MISSING_FIELDS
当数据加载时,若数据源文件中一行的最后一个字段缺失的处理方式。
取值范围:true/on,false/off。
缺省值:false/off
- DATE_FORMAT
导入对于DATE类型指定格式。此参数不支持BINARY格式,会报“cannot specify bulkload compatibility options in BINARY mode”错误信息。此参数仅对COPY FROM导入有效。
取值范围:合法DATE格式。可参考时间和日期处理函数和操作符。
对于指定为ORACLE兼容类型的数据库,则DATE类型内建为TIMESTAMP类型。在导入的时候,若需指定格式,可以参考下面的timestamp_format参数。
- TIME_FORMAT
导入对于TIME类型指定格式。此参数不支持BINARY格式,会报“cannot specify bulkload compatibility options in BINARY mode”错误信息。此参数仅对COPY FROM导入有效。
取值范围:合法TIME格式,不支持时区。可参考时间和日期处理函数和操作符。
- TIMESTAMP_FORMAT
导入对于TIMESTAMP类型指定格式。此参数不支持BINARY格式,会报“cannot specify bulkload compatibility options in BINARY mode”错误信息。此参数仅对COPY FROM导入有效。
取值范围:合法TIMESTAMP格式,不支持时区。可参考时间和日期处理函数和操作符。
- SMALLDATETIME_FORMAT
导入对于SMALLDATETIME类型指定格式。此参数不支持BINARY格式,会报“cannot specify bulkload compatibility options in BINARY mode”错误信息。此参数仅对COPY FROM导入有效。
取值范围:合法SMALLDATETIME格式。可参考时间和日期处理函数和操作符。
- FORMAT
- COPY_OPTION { option_name ' value ' }
用于指定COPY原生的各类参数。
- OIDS
在处理包含OID的表(通常是系统表)是,指定是否对OID隐藏列进行导入导出。
取值范围:true/on、false/off。
缺省值:false
- NULL null_string
取值范围:
- null值不能是\r和\n,最大为100个字符。
- null值不能和分隔符、quote参数相同。
缺省值:
- 在TEXT格式下默认值是\N。
- CSV格式下默认值是一个没有引号的空字符串。
- HEADER
指定导出数据文件是否包含标题行,标题行一般用来描述表中每个字段的信息。header只能用于CSV,FIXED格式的文件中。
在导入数据时,如果header选项为on,则数据文本第一行会被识别为标题行,会忽略此行。如果header为off,而数据文件中第一行会被识别为数据。
在导出数据时,如果header选项为on,则需要指定fileheader。如果header为off,则导出数据文件不包含标题行。
- USEEOF
- FILEHEADER
导出数据时用于定义标题行的文件,一般用来描述每一列的数据信息。
- 仅在header为on或true的情况下有效。
- fileheader指定的是绝对路径。
- 该文件只能包含一行标题信息,并以换行符结尾,多余的行将被丢弃(标题信息不能包含换行符)。
- 该文件包括换行符在内长度不超过1M。
- FREEZE
将COPY加载的数据行设置为已经被frozen,就像这些数据行执行过VACUUM FREEZE。
这是一个初始数据加载的性能选项。仅当以下三个条件同时满足时,数据行会被frozen:
- 在同一事务中create或truncate这张表之后执行COPY。
- 当前事务中没有打开的游标。
- 当前事务中没有原有的快照。
COPY完成后,所有其他会话将会立刻看到这些数据。但是这违反了MVCC可见性的一般原则,用户应当了解这样会导致潜在的风险。
- FORCE NOT NULL column_name [, ...]
在CSV COPY FROM模式下,指定的字段输入不能为空。
取值范围:已存在的字段。
- FORCE QUOTE { column_name [, ...] | * }
在CSV COPY TO模式下,强制在每个声明的字段周围对所有非NULL值都使用引号包围。*代表所有字段,NULL输出不会被引号包围。
取值范围:已存在的字段。
- BINARY
- 在二进制模式下,不能声明DELIMITER、NULL、CSV选项。
- 指定BINARY类型后,不能再通过option或copy_option指定CSV、FIXED、TEXT等类型。
- 如果设置了GUC参数copy_special_character_version='no_error',则会在导入的过程中屏蔽非法字符编码的校验,将非法编码字符按原样导入,查询时以乱码显示。要求数据库服务端编码与客户端编码保持一致。在了解后果的情况下,请谨慎选择开启此参数。
- 二进制模式下copy_special_character_version='no_error',仅对TEXT、CHAR、VARCHAR、NVARCHAR2、CLOB类型的字段生效。
- CSV
打开逗号分隔变量(CSV)模式。指定CSV类型后,不能再通过option或copy_option指定BINARY、FIXED、TEXT等类型。
- QUOTE [AS] 'quote_character'
缺省值:双引号 '"'。
- quote参数不能和分隔符、null参数相同。
- quote参数只能是单字节的字符。
- 推荐不可见字符作为quote,例如0x07,0x08,0x1b等。
- ESCAPE [AS] 'escape_character'
CSV格式下,用来指定逃逸字符,逃逸字符只能指定为单字节字符。
默认值为双引号 '"'。当与quote值相同时,会被替换为'\0'。
- EOL 'newline_character'
取值范围:支持多字符换行符,但换行符不能超过10个字节。常见的换行符,如\r、\n、\r\n(设成0x0D、0x0A、0x0D0A效果是相同的),其他字符或字符串,如$、#。
- EOL参数只能用于TEXT格式的导入导出,不支持CSV格式和FIXED格式。为了兼容原有EOL参数,仍然支持导出CSV格式和FIXED格式时指定EOL参数为0x0D或0x0D0A。
- EOL参数不能和分隔符、null参数相同。
- EOL参数不能包含:.abcdefghijklmnopqrstuvwxyz0123456789。
- ENCODING 'encoding_name'
取值范围:有效的编码格式。
缺省值:当前编码格式。
- IGNORE_EXTRA_DATA
指定当数据源文件比外表定义列数多时,忽略行尾多出来的列。该参数只在数据导入过程中使用。
若不使用该参数,在数据源文件比外表定义列数多,会显示如下错误信息。1
extra data after last expected column
- COMPATIBLE_ILLEGAL_CHARS
取值范围:true/on,false/off。
- 参数为true/on,则导入时遇到非法字符进行容错处理,非法字符转换后入库,不报错,不中断导入。导出时对非法字符进行转换后导出,不报错,不中断导出。
- 参数为false/off,导入时遇到非法字符进行报错,中断导入。导出时遇到非法字符进行报错,中断导出。
缺省值:false/off
导入非法字符容错规则如下:
- 对于'\0',容错后转换为空格。当support_zero_char打开时则会按照原格式进行导入。
- 对于其他非法字符,容错后转换为guc参数convert_illegal_char_mode设置的字符,默认为'?'。
- 若compatible_illegal_chars为true/on标识,导入时对于非法字符进行容错处理,若NULL、DELIMITER、QUOTE、ESCAPE设置为空格或问号,则会通过如"illegal chars conversion may confuse COPY escape 0x20"等报错信息提示用户修改可能引起混淆的参数以避免导入错误。
- compatible_illegal_chars为true/on时,不支持对binary格式的数据进行导入,会报“cannot specify bulkload compatibility options in BINARY mode”错误信息。
- 如果设置了GUC参数copy_special_character_version='no_error',则会在导入的过程中屏蔽非法字符编码的校验,将非法编码字符按原样导入,查询时以乱码显示。在了解后果的情况下,请谨慎选择开启此参数。
- copy_special_character_version='no_error'时优先级会高于compatible_illegal_chars=true,即非法编码字符会按原样导入。
- 对于设置了copy_special_character_version='no_error'或compatible_illegal_chars=true的场景,每识别到一行包含非法编码的数据,都会向数据库运行日志中写入一条记录,写日志的行为会占用少量磁盘带宽。如果想要消除此部分的影响,可以配置guc参数enable_log_copy_illegal_chars为off,即不向数据库运行日志中写入记录。除有性能需要,否则不推荐修改此配置。
导出非法字符容错规则如下:
导出时分为需要转码的场景(数据库服务端编码与客户端编码不一致)和不需要转码的场景(数据库服务端编码与客户端编码保持一致),不同场景下导出的表现不同。可以通过show server_encoding;语句查询数据库服务端编码。通过show client_encoding;语句查询数据库客户端编码。
- 需要转码的场景:
- 对于'\0',容错后转换为空格。当support_zero_char打开时则会按照原格式进行导出。
- 对于其他非法字符,容错后转换为guc参数convert_illegal_char_mode设置的字符,默认为'?'。
- 若compatible_illegal_chars为true/on标识导出时对于非法字符进行容错处理,若NULL、DELIMITER、QUOTE、ESCAPE设置为空格或问号,则会通过如"illegal chars conversion may confuse COPY escape 0x20"等报错信息提示用户修改可能引起混淆的参数,以避免导出错误。
- compatible_illegal_chars为true/on时,不支持对binary格式的数据进行导出。
- 对于设置了compatible_illegal_chars=true的场景,每识别到一行包含非法编码的数据,都会向数据库运行日志中写入一条记录,写日志的行为会占用少量磁盘带宽。如果想要消除此部分的影响,可以配置guc参数enable_log_copy_illegal_chars为off,即不向数据库运行日志中写入记录。除有性能需要,否则不推荐修改此配置。
- 不需要转码的场景:
- 对于不需要转码的场景,数据会按照数据库内原样进行导出,即使数据中存在非法字符并设置compatible_illegal_chars=true。
- compatible_illegal_chars为true/on时,不支持对binary格式的数据进行导出。
- FILL_MISSING_FIELDS
当数据加载时,若数据源文件中一行的最后一个字段缺失的处理方式。
取值范围:true/on,false/off。
缺省值:false/off。
目前COPY指定此Option实际不会生效,即不会有相应的容错处理效果(不生效)。需要额外注意的是,打开此选项会导致解析器在CN数据解析阶段(即COPY错误表容错的涵盖范围)忽略此数据问题,而到DN重新报错,从而使得COPY错误表(打开LOG ERRORS REJECT LIMIT)在此选项打开的情况下无法成功捕获这类少列的数据异常。因此请不要指定此选项。
- DATE_FORMAT 'date_format_string'
导入对于DATE类型指定格式。此参数不支持BINARY格式,会报“cannot specify bulkload compatibility options in BINARY mode”错误信息。此参数仅对COPY FROM导入有效。
取值范围:合法DATE格式。可参考时间和日期处理函数和操作符
对于指定为ORACLE兼容类型的数据库,则DATE类型内建为TIMESTAMP类型。在导入的时候,若需指定格式,可以参考下面的timestamp_format参数。
- TIME_FORMAT 'time_format_string'
导入对于TIME类型指定格式。此参数不支持BINARY格式,会报“cannot specify bulkload compatibility options in BINARY mode”错误信息。此参数仅对COPY FROM导入有效。
取值范围:合法TIME格式,不支持时区。可参考时间和日期处理函数和操作符。
- TIMESTAMP_FORMAT 'timestamp_format_string'
导入对于TIMESTAMP类型指定格式。此参数不支持BINARY格式,会报“cannot specify bulkload compatibility options in BINARY mode”错误信息。此参数仅对COPY FROM导入有效。
取值范围:合法TIMESTAMP格式,不支持时区。可参考时间和日期处理函数和操作符。
- SMALLDATETIME_FORMAT 'smalldatetime_format_string'
导入对于SMALLDATETIME类型指定格式。此参数不支持BINARY格式,会报“cannot specify bulkload compatibility options in BINARY mode”错误信息。此参数仅对COPY FROM导入有效。
取值范围:合法SMALLDATETIME格式。可参考时间和日期处理函数和操作符。
- OIDS
- TRANSFORM ( { column_name [ data_type ] [ AS transform_expr ] } [, ...] )
指定表中各个列的转换表达式;其中data_type指定该列在表达式参数中的数据类型;transform_expr为目标表达式,返回与表中目标列数据类型一致的结果值,表达式可参考表达式。
COPY FROM目前不支持对分布列指定表达式转换。
COPY FROM能够识别的特殊反斜杠序列如下所示。- \b:反斜杠 (ASCII 8)
- \f:换页(ASCII 12)
- \n:换行符 (ASCII 10)
- \r:回车符 (ASCII 13)
- \t:水平制表符 (ASCII 9)
- \v:垂直制表符 (ASCII 11)
- \digits:反斜杠后面跟着一到三个八进制数,表示ASCII值为该数的字符。
- \xdigits:反斜杠x后面跟着一个或两个十六进制位声明指定数值编码的字符。
权限控制示例
gaussdb=> copy t1 from '/home/xy/t1.csv'; ERROR: COPY to or from a file is prohibited for security concerns HINT: Anyone can COPY to stdout or from stdin. gsql's \copy command also works for anyone. gaussdb=> grant gs_role_copy_files to xxx;
此错误为非初始用户没有使用copy的权限示例,解决方式为打开enable_copy_server_files参数,则管理员可以使用copy功能,普通用户需要在此基础上加入gs_role_copy_files群组。
示例
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 |
--创建SCHEMA。 gaussdb=# CREATE SCHEMA tpcds; --创建tpcds.ship_mode表。 gaussdb=# CREATE TABLE tpcds.ship_mode ( SM_SHIP_MODE_SK INTEGER NOT NULL, SM_SHIP_MODE_ID CHAR(16) NOT NULL, SM_TYPE CHAR(30) , SM_CODE CHAR(10) , SM_CARRIER CHAR(20) , SM_CONTRACT CHAR(20) ) DISTRIBUTE BY HASH(SM_SHIP_MODE_SK); --向tpcds.ship_mode表插入一条数据。 gaussdb=# INSERT INTO tpcds.ship_mode VALUES (1,'a','b','c','d','e'); --将tpcds.ship_mode中的数据复制到/home/omm/ds_ship_mode.dat文件中。 gaussdb=# COPY tpcds.ship_mode TO '/home/omm/ds_ship_mode.dat'; --将tpcds.ship_mode 输出到STDOUT。 gaussdb=# COPY tpcds.ship_mode TO STDOUT; --将tpcds.ship_mode 的数据输出到STDOUT,使用参数如下:分隔符为','(delimiter ','),编码格式为UTF8(encoding 'utf8')。 gaussdb=# COPY tpcds.ship_mode TO STDOUT WITH (delimiter ',', encoding 'utf8'); --将tpcds.ship_mode 的数据输出到STDOUT,使用参数如下:导入格式为CSV(format 'CSV'),引号包围SM_SHIP_MODE_SK字段的导出内容(force_quote(SM_SHIP_MODE_SK))。 gaussdb=# COPY tpcds.ship_mode TO STDOUT WITH (format 'CSV', force_quote(SM_SHIP_MODE_SK)); --创建tpcds.ship_mode_t1表。 gaussdb=# CREATE TABLE tpcds.ship_mode_t1 ( SM_SHIP_MODE_SK INTEGER NOT NULL, SM_SHIP_MODE_ID CHAR(16) NOT NULL, SM_TYPE CHAR(30) , SM_CODE CHAR(10) , SM_CARRIER CHAR(20) , SM_CONTRACT CHAR(20) ) DISTRIBUTE BY HASH(SM_SHIP_MODE_SK ); --从STDIN复制数据到表tpcds.ship_mode_t1。 gaussdb=# COPY tpcds.ship_mode_t1 FROM STDIN; --输入一行数据示例 --gaussdb=# COPY tpcds.ship_mode_t1 FROM STDIN; --Enter data to be copied followed by a newline. --End with a backslash and a period on a line by itself. -->> 1 a a a a a -->> \. -- 备注:数据与数据之间输入tab --从/home/omm/ds_ship_mode.dat文件复制数据到表tpcds.ship_mode_t1。 gaussdb=# COPY tpcds.ship_mode_t1 FROM '/home/omm/ds_ship_mode.dat'; --从/home/omm/ds_ship_mode.dat文件复制数据到表tpcds.ship_mode_t1,应用TRANSFORM表达式转换,取SM_TYPE列左边10个字符插入到表中。 gaussdb=# COPY tpcds.ship_mode_t1 FROM '/home/omm/ds_ship_mode.dat' TRANSFORM (SM_TYPE AS LEFT(SM_TYPE, 10)); --从/home/omm/ds_ship_mode.dat文件复制数据到表tpcds.ship_mode_t1,使用参数如下:导入格式为TEXT(format 'text'),分隔符为'\t'(delimiter E'\t'),忽略多余列(ignore_extra_data 'true'),不指定转义(noescaping 'true')。 gaussdb=# COPY tpcds.ship_mode_t1 FROM '/home/omm/ds_ship_mode.dat' WITH(format 'text', delimiter E'\t', ignore_extra_data 'true', noescaping 'true'); --从/home/omm/ds_ship_mode_fixed.dat文件复制数据到表tpcds.ship_mode_t1,使用参数如下:导入格式为FIXED(FIXED),指定定长格式(FORMATTER(SM_SHIP_MODE_SK(0, 2), SM_SHIP_MODE_ID(2,16), SM_TYPE(18,30), SM_CODE(50,10), SM_CARRIER(61,20), SM_CONTRACT(82,20))),忽略多余列(ignore_extra_data),有数据头(header)。 gaussdb=# COPY tpcds.ship_mode TO '/home/omm/ds_ship_mode_fixed.dat' FIXED FORMATTER(SM_SHIP_MODE_SK(0, 2), SM_SHIP_MODE_ID(2,16), SM_TYPE(18,30), SM_CODE(50,10), SM_CARRIER(61,20), SM_CONTRACT(82,20)) header; gaussdb=# COPY tpcds.ship_mode_t1 FROM '/home/omm/ds_ship_mode_fixed.dat' FIXED FORMATTER(SM_SHIP_MODE_SK(0, 2), SM_SHIP_MODE_ID(2,16), SM_TYPE(18,30), SM_CODE(50,10), SM_CARRIER(61,20), SM_CONTRACT(82,20)) header ignore_extra_data; --删除表和SCHEMA。 gaussdb=# DROP TABLE tpcds.ship_mode; gaussdb=# DROP TABLE tpcds.ship_mode_t1; gaussdb=# DROP SCHEMA tpcds; |