GBase 8a中使用LOAD命令需要借助execute()函数。
1、首先创建数据库连接:

from GBaseConnector import connect

config = {
	'host': '你的数据库IP地址',
	'user': 'username',
	'password': 'passwd',
	'port': 5258, # 默认为5258
	'db': 'test',
	'charset': 'utf-8', # 指定编码格式
	'connect_timeout': 1000, # 连接超时时间
}

conn = connect(**config)

2、创建游标

cursor = conn.cursor()

3、使用LOAD命令将文本文件中的数据加载到数据库表中

'''
此处使用的是sftp协议作为示例,同时也支持本地、ftp、https、hdfs等协议;
DATA_FORMAT指定为3表示使用文本文件进行加载,指定为4表示使用定长方式加载,
指定为5表示使用文本文件宽松模式,即数据源文件为包围符中含有换行符和包围符文本文件,或多列少列文件
TERMINATED BY用于指定字段分隔符,本示例的分隔符为空格
'''
cursor.execute("LOAD DATA INFILE 'sftp://username:passwd@ip_address//home/gbase/test.txt' INTO TABLE test.table1 DATA_FORMAT 3 FIELDS TERMINATED BY ' ';")

# 查看加载信息
print(cursor.info)

4、关闭数据库连接

cursor.close()
conn.close()
Logo

GitCode 天启AI是一款由 GitCode 团队打造的智能助手,基于先进的LLM(大语言模型)与多智能体 Agent 技术构建,致力于为用户提供高效、智能、多模态的创作与开发支持。它不仅支持自然语言对话,还具备处理文件、生成 PPT、撰写分析报告、开发 Web 应用等多项能力,真正做到“一句话,让 Al帮你完成复杂任务”。

更多推荐