返回首页

gbase数据、南大通用产品文档:GBase8a

更新日期:2024年09月11日

获取多个结果集数据
当有多个结果集时,可使用如下方法获取多个结果集的数据。
from GBaseConnector import connect, GBaseError
if __name__ == '__main__':
config = {'host':'172.16.0.131',
'user':'root',
'passwd':'111111',
'port':5258,
'db':'test'}
try:
conn = connect()
conn.connect(**config)
cur = conn.cursor()
cur.execute("DROP TABLE IF EXISTS test")
cur.execute("CREATE TABLE test (COL1 INT, COL2 VARCHAR(20))")
opfmt = "INSERT INTO test(COL1, COL2) VALUES(%s, %s)"
rows = []



GBase Python 接口开发手册
南大通用数据技术股份有限公司

- 11 -
for i in xrange(0, 100):
rows.append((i, "row" + str(i)))
cur.executemany(opfmt, rows)
iters
=
cur.execute("SELECT
*
FROM
test
limit
5;SELECT
*
FROM
TEST
LIMIT
10, 5", multi_stmt= True)
for ter in iters:
print ter.fetchall()

cur.execute("DROP TABLE IF EXISTS test")
except GBaseError.DatabaseError, err:
print err
finally:
conn.close()

安装监控网站...................................... 6

功能
当该值不为0 时,若小表拉表的数据行数大于该值,进行HASH 重分布JOIN。
该参数的默认值是0。