使用PEP 249标准接口执行查询并获取结果集

前提条件

• Fabric SQL服务正常运行。
• 用户提供有效的IAM认证凭据。
• 用户已开通Fabric SQL服务并拥有访问OBS服务权限。

示例代码

from fabricsql.SQLConnector import FabricSQLConnector
from fabricsql.SQLRequests import SessionRequest
# 本示例程序演示支持PEP 249标准接口使用FabricSQLConnector

ak = 'xxxxxxxxxxxx'
sk = 'xxxxxxxxxxxx'
fabric_endpoint = 'xxxxxxxxxx'
endpoint_id = 'xxxxxxxxxxx'
workspace_id = 'xxxxxxxxxxxx'
instance_id = 'xxxxxxxxxxxxx'
catalog = 'xxxxxxxxxx'

# 填入创建Session信息
session = SessionRequest()
session.endpoint_id = endpoint_id
session.instance_id = instance_id
session.catalog = catalog
# 创建连接，内部会创建一个Session
conn = FabricSQLConnector.connect(endpoint_id, workspace_id, session, ak, sk)
# 打开一个游标
cursor = conn.cursor()
# 执行SQL语句，多个语句请使用分号隔开
cursor.execute("select * from pg_class;select * from pg_type")
# 获取查询表列信息
cols = cursor.description
# 获取一行数据
cursor.fetchone()
# 获取剩余所有数据
cursor.fetchall()
# 获取下一个语句结果集
cursor.nextset()
# 关闭游标
cursor.close()
# 关闭连接conn.close()