《使用游标操作数据库》
使用游标操作数据库资源，包括：执行 SQL 语句、调用存储过程、执行事
务、获取结果集操作。
1 执行 SQL 语句
连接创建后，可以使用连接的cursor 方法生成游标，然后可以使用游标执
行ＳＱＬ语句和获取结果集。
from GBaseConnector import connect, GBaseError
if name == ‘main’:
config = {‘host’:‘172.16.0.131’,
‘user’:‘root’,
‘passwd’:‘111111’,
‘port’:5258}
try:
conn = connect()
conn.connect(**config)
cur = conn.cursor()
cur.execute(“CREATE DATABASE test”)
except GBaseError.DatabaseError as err:
print err
finally:
conn.close()
2 执行多条语句
使用游标执行多条ＳＱＬ语句。
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(“CREATE TABLE IF NOT EXISTS test(id INT, name VARCHAR(20))”)
cur.execute(“INSERT INTO test VALUES(%s,%s)”, (1,‘hello’))
iters = cur.execute("UPDATE test SET id=%s,name=%s;DELETE FROM test;SELECT复制
‘result’;",
params=(2,‘world’), multi_stmt=True)
for i in iters:
try:
print i.fetchall()
except GBaseError.InterfaceError:
pass
cur.execute(“DROP TABLE IF EXISTS test”)
except GBaseError.DatabaseError, err:
print err
finally:
conn.close()
