附录2：调用示例
import os
import sys
import psycopg2
#数据库操作
def connectVastbase():
#连接数据库
conn = psycopg2.connect(database="postgres", user="vastbase2", password="Aa@123456", host="127.0.0.1", port="25432")
print('connect successful!')
cursor = conn.cursor()
#创建表
cursor.execute("create table tb_test(id integer not null primary key, name text)")
print('create table successful!')
#插入数据
cursor.execute("insert into tb_test(id, name) values(1, 'Anna')")
cursor.execute("insert into tb_test(id, name) values(%s, '%s')" %(2, 'Jack'))
conn.commit()
print('insert successful!')
#查询数据
cursor.execute("select * from tb_test")
#fetchall
records = cursor.fetchall()
for record in records:
print('fetchall: id = ' + str(record[0]) + ', name = ' + str(record[1]))
#fetchone
cursor.execute("select * from tb_test")
record = cursor.fetchone()
print('fetchone: id = ' + str(record[0]) + ', name = ' + str(record[1]))
#fetchmany
cursor.execute("select * from tb_test")
records = cursor.fetchmany(10)
for record in records:
print('fetchmany: id = ' + str(record[0]) + ', name = ' + str(record[1]))
#rollback
cursor.execute("insert into tb_test(id, name) values(3, 'Mike')")
conn.rollback()
cursor.execute("select * from tb_test")
records = cursor.fetchall()
for record in records:
print('atfer rollback: id = ' + str(record[0]) + ', name = ' + str(record[1]))
#更新数据
cursor.execute("update tb_test set name = '%s' where id = 1" %('Elsa'))
print('update successful!')
cursor.execute("select * from tb_test")
records = cursor.fetchall()
for record in records:
print('after update: id = ' + str(record[0]) + ', name = ' + str(record[1]))
#删除数据
cursor.execute("delete from tb_test where id = 2")
conn.commit()
cursor.execute("select * from tb_test")
records = cursor.fetchall()
for record in records:
print('after delete: id = ' + str(record[0]) + ', name = ' + str(record[1]))
cursor.close()
conn.close()
if __name__=='__main__':
connectVastbase()
