使用Python第三方库PyGreSQL连接集群 在Linux环境使用PyGreSQL第三方库连接集群 1.以root用户登录Linux环境。 2.执行以下命令创建pythondws.py文件。 vi pythondws.py 请复制粘贴以下内容放入pythondws.py文件中: !/usr/bin/env python3 encoding:utf8 from future import printfunction import pg def createtable(connection): print("Begin to create table") try: connection.query("drop table if exists test;" "create table test(id int, name text);") except pg.InternalError as e: print(e) else: print("Table created successfully") def insertdata(connection): print("Begin to insert data") try: connection.query("insert into test values(1,'number1');") connection.query("insert into test values(2,'number2');") connection.query("insert into test values(3,'number3');") except pg.InternalError as e: print(e) else: print("Insert data successfully") def updatedata(connection): print("Begin to update data") try: result connection.query("update test set name 'numberupdated' where id1;") print("Total number of rows updated :", result) result connection.query("select from test order by 1;") rows result.getresult() for row in rows: print("id ", row[0]) print("name ", row[1], "n") except pg.InternalError as e: print(e) else: print("After Update, Operation done successfully") def deletedata(connection): print("Begin to delete data") try: result connection.query("delete from test where id3;") print("Total number of rows deleted :", result) result connection.query("select from test order by 1;") rows result.getresult() for row in rows: print("id ", row[0]) print("name ", row[1], "n") except pg.InternalError as e: print(e) else: print("After Delete,Operation done successfully") def selectdata(connection): print("Begin to select data") try: result connection.query("select from test order by 1;") rows result.getresult() for row in rows: print("id ", row[0]) print("name ", row[1]) except pg.InternalError as e: print(e) print("select failed") else: print("Operation done successfully") if name 'main': try: conn pg.DB(host'10.154.70.231', port8000, dbname'gaussdb',
来自: