BulkloadManager类

用于Vastbase导入大批量数据传输的API。

BulkloadManager(BaseConnection connection, String bulkloadCtlFile)

功能描述

BulkloadManager构造方法，获取BulkloadManager对象。

语法格式

public BulkloadManager(BaseConnection connection,
          String bulkloadCtlFile)
       throws SQLException

参数说明

connection：数据库连接对象。

bulkloadCtlFile：bulkload控制文件路径。

返回值

返回BulkloadManager对象。

生命周期

自V2.2版本启用。

bulkloadIn(String sql)

功能描述

获取一个BulkloadIn对象。

语法格式

public BulkloadIn bulkloadIn(String sql)
       throws SQLException

参数说明

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

返回值

返回导入结果集BulkloadIn对象。

生命周期

自V2.2版本启用。

bulkloadIn()

功能描述

调用pg_bulkload接口，快速导入数据。

语法格式

public ResultSet bulkloadIn()
       throws SQLException

参数说明

无。

返回值

返回导入结果集ResultSet对象。

生命周期

自V2.2版本启用。

bulkloadIn(InputStream from)

功能描述

调用pg_bulkload接口，快速地从InputStream复制到数据库表中。

语法格式

public ResultSet bIn(InputStream from)
      throws SQLException,
          IOException

参数说明

from：一个CSV文件或二进制的文件。

返回值

返回导入结果集ResultSet对象。

生命周期

自V2.2版本启用。

bulkloadIn(InputStream from, int bufferSize)

功能描述

调用pg_bulkload接口，快速地从InputStream复制到数据库表中。

语法格式

public ResultSet bulkloadIn(InputStream from,int bufferSize)      throws SQLException,          IOException

参数说明

from：一个CSV文件或二级制的文件。

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

返回值

返回导入结果集ResultSet对象。

生命周期

自V2.2版本启用。

bulkloadIn(File[] files)

功能描述

调用pg_bulkload接口，快速地从File[] files 多个文件中复制数据到数据库表中。

语法格式

public ResultSet bulkloadIn(File[] files)      
throws SQLException,          
IOException

参数说明

files：一个或多个CSV文件或二级制的文件的数组。

返回值

返回导入结果集ResultSet对象。

生命周期

自V2.2版本启用。

bulkloadIn(File[] files, int bufferSize)

功能描述

调用pg_bulkload接口，快速地从File[] files 多个文件中复制数据到数据库表中。

语法格式

public ResultSet bulkloadIn( File[] files,          
int bufferSize)      
throws SQLException,          
IOException

参数说明

files：一个或多个CSV文件或二级制的文件的数组。

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

返回值

返回导入结果集ResultSet对象。

生命周期

自V2.2版本启用。

bulkloadIn(String folderPath, Pattern fileNamePattern)

功能描述

调用pg_bulkload接口，从指定folderPath路径获取fileNamePattern指定文件名的文件中复制数据到数据库表中。

方法原型

public ResultSet bulkoadIn(String folderPath, Pattern fileNamePattern) throws SQLException, IOException

参数说明

返回值

返回导入结果集ResultSet对象。

生命周期

自V2.2版本启用。

bulkloadIn(String folderPath, Pattern fileNamePattern, int bufferSize)

功能描述

调用pg_bulkload接口，从指定folderPath路径获取fileNamePattern指定文件名的文件中复制数据到数据库表中。

语法格式

public ResultSet bulkloadIn(String folderPath,
          Pattern fileNamePattern,
          int bufferSize)
       throws SQLException,
          IOException

参数说明

folderPath：目录路径。

fileNamePattern：文件名的正则表达式。

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

返回值

返回导入结果集ResultSet对象。

生命周期

自V2.2版本启用。

escapeDoubleQuotesAndSlash(String str)

功能描述

将字符串中的双引号和和斜杠进行转义。

语法格式

public StringBuffer escapeDoubleQuotesAndSlash(String str)

参数说明

str：任意字符串。

返回值

返回转义处理后的StringBuffer对象。

生命周期

自V2.2版本启用。

getBulkloadInfo()

功能描述

获取bulkload控制参数。

语法格式

public BulkloadProperties getBulkloadInfo()

参数说明

无。

返回值

返回bulkload控制参数的BulkloadProperties对象。

生命周期

自V2.2版本启用。

escapeDoubleQuotesAndSlash(String str)

功能描述

将字符串中的双引号和和斜杠进行转义。

语法格式

public StringBuffer escapeDoubleQuotesAndSlash(String str)

参数说明

str：任意字符串。

返回值

返回转义处理后的StringBuffer对象。

生命周期

自V2.2版本启用。

getBulkloadStartSQL()

功能描述

生成bulkload的执行语句。

方法原型

public String getBulkloadStartSQL()

参数说明

无。

返回值

返回bulkload的执行语句。

生命周期

自V2.2版本启用。

getBulkloadStartSQL(String schemaName, String functionName)

功能描述

生成bulkload的执行语句。

方法原型

public String getBulkloadStartSQL(String schemaName, String functionName)

参数说明

schemaName：bulkload函数所在的schema名称。

functionName： bulkload函数名称。

返回值

返回bulkload的执行语句。

生命周期

自V2.2版本启用。

addBatch()

功能描述

将数据添加至缓存。

方法原型

public void addBatch()

参数说明

无。

返回值

无。

生命周期

自V2.2版本启用。

executeBatch()

功能描述

将缓存数据发送至数据库。

语法格式

public ResultSet executeBatch()      
throws SQLException,          
IOException

参数说明

无。

返回值

返回导入结果集ResultSet对象。

生命周期

自V2.2版本启用。

setBulkloadInfo(BulkloadProperties bulkloadInfo)

功能描述

设置bulkload控制参数。

方法原型

public void setBulkloadInfo(BulkloadProperties bulkloadInfo)

参数说明

bulkloadInfo：bulkload控制参数。

返回值

无。

生命周期

自V2.2版本启用。

setBoolean(int parameterIndex, Boolean value)

功能描述

设置指定列的布尔值。

方法原型

public void setBoolean(int parameterIndex, Boolean value)      
throws SQLException

参数说明

parameterIndex：列下标，从1开始。

value：布尔值

返回值

无。

生命周期

自V2.2版本启用。

setChar(int parameterIndex, Character value)

功能描述

设置指定列的char值。

方法原型

public void setChar(int parameterIndex, Character value)      
throws SQLException

参数说明

parameterIndex：列下标，从1开始。

value： char字符。

返回值

无。

生命周期

自V2.2版本启用。

setClob(int parameterIndex, Clob value)

功能描述

设置指定列的Clob数据。

方法原型

public void setClob(int parameterIndex, Clob value)      
throws SQLException

参数说明

parameterIndex：列下标，从1开始。

value： Clob数据。

返回值

无。

生命周期

自V2.2版本启用。

setDate(int parameterIndex, Date value)

功能描述

设置指定列的日期数据。

方法原型

public void setDate(int parameterIndex, Date value)      
throws SQLException

参数说明

parameterIndex：列下标，从1开始。

value： 日期数据。

返回值

无。

生命周期

自V2.2版本启用。

setInt(int parameterIndex, Integer value)

功能描述

设置指定列的整型数据。

语法格式

public void setInt(int parameterIndex, Integer value)      
throws SQLException 

参数说明

parameterIndex：列下标，从1开始。

value：整型数据。

返回值

无。

生命周期

自V2.2版本启用。

setNumber(int parameterIndex, Number value)

功能描述

设置指定列的Number数据。

语法格式

public void setNumber(int parameterIndex, Number value)      
throws SQLException

参数说明

parameterIndex：列下标，从1开始。

value：Number数据。

返回值

无。

生命周期

自V2.2版本启用。

setString(int parameterIndex, String value)

功能描述

设置指定列的字符串数据。

方法原型

public void setString(int parameterIndex, String value)      
throws SQLException

参数说明

parameterIndex：列下标，从1开始。

value：字符串数据。

返回值

无。

生命周期

自V2.2版本启用。