psycopg查询
#coding:utf-8 import psycopg2 conn=psycopg2.connect(host='127.0.0.1',port=5432,user='postgres',password='1',database='postgis') print "opened db successfully" cursor=conn.cursor() cursor.execute("select name,type,state from wy") rows=cursor.fetchall() for row in rows: print "name:",row[0] print "type:",row[1] print "state:",row[2] print "*****" print "Records select successfully"; conn.close()
psycopg插入
#coding:utf-8 import psycopg2 conn=psycopg2.connect(host='127.0.0.1',port=5432,user='postgres',password='1‘’,database='postgis') print "opened db successfully" cursor=conn.cursor() cursor.execute("insert into wy(mid,name,psw,type,state,creat_time) \ values('7762cc64-5de1-11e6-ba75-000c2923b59f','admin2','1','测试组','1',CURRENT_TIMESTAMP)") conn.commit() print "Records created successfully"; conn.close()
psycopg修改
#coding:utf-8 import psycopg2 conn=psycopg2.connect(host='127.0.0.1',port=5432,user='postgres',password='1',database='postgis') print "opened db successfully" cursor=conn.cursor() cursor.execute("update wy set type='UI组' where name='admin2'") conn.commit() print "Total number of rows updated:",cursor.rowcount cursor.execute("select name,type,state from wy") rows=cursor.fetchall() for row in rows: print "name:",row[0] print "type:",row[1] print "state:",row[2] print "*******" print "done"; conn.close()
psycopg删除
#coding:utf-8 import psycopg2 conn=psycopg2.connect(host='127。0.0.1',port=5432,user='postgres',password='1',database='postgis') print "opened db successfully" cursor=conn.cursor() cursor.execute("delete from wy where name='admin2'") conn.commit() print "Total number of rows updated:",cursor.rowcount cursor.execute("select name,type,state from wy") rows=cursor.fetchall() for row in rows: print "name:",row[0] print "type:",row[1] print "state:",row[2] print "*******" print "done"; conn.close()