gbase 8a使用python api执行load示例

#!/bin/env python

from GBaseConnector import connect, GBaseError

connStr = {'host':'172.16.3.58','port':5258, 'user':'gbase','passwd':'gbase20110531', 'database':'guo', 'connection_timeout':9999999, 'charset':'utf8'} 
conn = connect (**connStr) 
cursor = conn.cursor() 
cursor.execute("LOAD DATA INFILE 'sftp://gbase:gbase@172.16.3.58//home/gbase/t1.txt' into table test.t1 fields terminated by '|';") 
print cursor.info
print cursor.rowcount
cursor.close() 
conn.close()