CopyManager类

用于Vastbase拷贝批量数据传输的API。

copyDual

功能描述

获取一个CopyDual对象。

语法格式

public CopyDual copyDual(String sql)         
throws SQLException

参数说明

sql：字符串类型的sql语句。

返回值

返回一个CopyDual对象。

copyIn(String sql)

功能描述

获取一个CopyIn对象。

语法格式

public CopyIn copyIn(String sql)       
throws SQLException

参数说明

sql：字符串类型的sql语句。

返回值

返回一个CopyIn对象。

copyIn(String sql, Reader from, int bufferSize)

功能描述

使用COPY FROM STDIN快速地从Reader复制到数据库表中。

语法格式

public long copyIn(String sql,          
Reader from,          
int bufferSize)      
throws SQLException,          
IOException

参数说明

sql：COPY FROM STDIN 语句。

from：一个CSV文件或类似的文件。

buffersize：要缓冲的字节数，同时通过网络推送到服务器。

返回值

返回已更新的行数。

copyIn(String sql, Reader from)

功能描述

使用COPY FROM STDIN快速地从Reader复制到数据库表中。

语法格式

public long copyIn(String sql,          
Reader from)      
throws SQLException,          
IOException

参数说明

sql：COPY FROM STDIN 语句。

from：一个CSV文件或类似的文件。

返回值

返回已更新的行数。

copyIn(String sql, InputStream from, int bufferSize)

功能描述

使用COPY FROM STDIN快速地从InputStream复制到数据库表中。

语法格式

public long copyIn(String sql,          
InputStream from,int bufferSize)      
throws SQLException,          
IOException

参数说明

sql：COPY FROM STDIN 语句。

from：一个CSV文件或类似的文件。

buffersize：要缓冲的字节数，同时通过网络推送到服务器。

返回值

返回已更新的行数。

copyIn(String sql, InputStream from)

功能描述

使用COPY FROM STDIN快速地从InputStream复制到数据库表中。

方法原型

public long copyIn(String sql,          
InputStream from)      
throws SQLException,          
IOException

参数说明

sql：COPY FROM STDIN 语句。

from：一个CSV文件或类似的文件。

返回值

返回已更新的行数。

copyOut(String sql)

功能描述

获取一个CopyOut对象。

语法格式

public CopyOut copyOut(String sql)        
throws SQLException

参数说明

sql：字符串类型的sql语句。

返回值

返回一个CopyOut对象。

copyOut(String sql, Writer to)

功能描述

将COPY TO STDOUT查询的结果从数据库传递给Writer。

语法格式

public long copyOut(String sql,          
Writer to)       
throws SQLException,          
IOException

参数说明

sql：COPY TO STDOUT 语句。

to：写入器将结果逐行写入，在复制输出操作结束时，写入器没有关闭。

返回值

返回已更新的行数。

copyOut(String sql, OutputStream to)

功能描述

将COPY TO STDOUT查询的结果从数据库传递到OutputStream。

语法格式

public long copyOut(String sql,          
OutputStream to)       
throws SQLException,          
IOException

参数说明

sql：COPY TO STDOUT 语句。

to：将结果逐行写入的流在操作结束时不会关闭流。这是有意为之，以便调用者可以继续写入输出流。

返回值

返回已更新的行数。

copyOut(String sql)

功能描述

获取一个CopyOut对象。

语法格式

public CopyOut copyOut(String sql)        
throws SQLException

参数说明

sql：字符串类型的sql语句。

返回值

返回一个CopyOut对象。