南大通用GBase 8a MPP Python接口技术（五）

《获取多个结果集数据》
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 = []
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()