Python中用psycopg2模块操作PostgreSQL方法
其实在Python中可以用来连接PostgreSQL的模块很多,这里比较推荐psycopg2。psycopg2安装起来非常的简单(pip install psycopg2),这里主要重点介绍下如何使用。
安装psycopg2模块:
怎么验证是否已经安装过psycopy2?
编写上面代码,运行看是否抛出缺少psycopg2模块。
安装方法1:
1)使用psycopg2-2.4.2.win-amd64-py2.7-pg9.0.4-release.exe安装,下载地址:http://vdisk.weibo.com/s/Cd8pPaw56Ozys
直接运行exe,不出错误,运行上边代码验证代码无错误,基本算是安装完成了。
2)怎么卸载?
2.1)找到安装目录:C:\Python27,发现下边包含文件:Removepsycopg2.exe,运行,来删除;
2.2)如果运行失败的话,进入目录:C:\Python27\Lib\site-packages下,找到psycopg2文件夹和psycopg2-2.4.2-py2.7.egg-info文件,右键删除。
2.3)运行上边的代码,确认是否删除成功。
安装方法2:
使用.whl安装,下载地址:https://pypi.python.org/pypi/psycopg2/
下载文件:psycopg2-2.6.2-cp27-none-win_amd64.whl
我这里把psycopg2-2.6.2-cp27-none-win_amd64.whl拷贝到安装目录下Scripts文件夹中。
cmd中运行代码:pip install C:\Python27\Scripts\psycopg2-2.6.2-cp27-none-win_amd64.whl
运行上边的代码,确认是否删除成功。
通过psycopg2操作数据库:
使用账户postgres,创建测试数据库testdb。
参考yiibai.comAPI:
S.N. API & 描述
1 psycopg2.connect(database="testdb", user="postgres", password="cohondob", host="127.0.0.1", port="5432")
这个API打开一个连接到PostgreSQL数据库。如果成功打开数据库时,它返回一个连接对象。
2 connection.cursor()
该程序创建一个光标将用于整个数据库使用Python编程。
3 cursor.execute(sql [, optional parameters])
此例程执行SQL语句。可被参数化的SQL语句(即占位符,而不是SQL文字)。 psycopg2的模块支持占位符用%s标志
例如:cursor.execute("insert into people values (%s, %s)", (who, age))
4 curosr.executemany(sql, seq_of_parameters)
该程序执行SQL命令对所有参数序列或序列中的sql映射。
5 curosr.callproc(procname[, parameters])
这个程序执行的存储数据库程序给定的名称。该程序预计为每一个参数,参数的顺序必须包含一个条目。
6 cursor.rowcount
这个只读属性,它返回数据库中的行的总数已修改,插入或删除最后 execute*().
7 connection.commit()
此方法提交当前事务。如果不调用这个方法,无论做了什么修改,自从上次调用commit()是不可见的,从其他的数据库连接。
8 connection.rollback()
此方法会回滚任何更改数据库自上次调用commit()方法。
9 connection.close()
此方法关闭数据库连接。请注意,这并不自动调用commit()。如果你只是关闭数据库连接而不调用commit()方法首先,那么所有更改将会丢失!
10 cursor.fetchone()
这种方法提取的查询结果集的下一行,返回一个序列,或者无当没有更多的数据是可用的。
11 cursor.fetchmany([size=cursor.arraysize])
这个例程中取出下一个组的查询结果的行数,返回一个列表。当没有找到记录,返回空列表。该方法试图获取尽可能多的行所显示的大小参数。
12 cursor.fetchall()
这个例程获取所有查询结果(剩余)行,返回一个列表。空行时则返回空列表。
打开数据库连接:
import os import sys import psycopg2 def connectPostgreSQL(): conn = psycopg2.connect(database="testdb", user="postgres", password="new.1234", host="127.0.0.1", port="5432") print 'connect successful!' if __name__=='__main__': connectPostgreSQL()
创建表操作:
import os import sys import psycopg2 def connectPostgreSQL(): conn = psycopg2.connect(database="testdb", user="postgres", password="new.1234", host="127.0.0.1", port="5432") print 'connect successful!' cursor=conn.cursor() cursor.execute('''create table public.member( id integer not null primary key, name varchar(32) not null, password varchar(32) not null, singal varchar(128) )''') conn.commit() conn.close() print 'table public.member is created!' if __name__=='__main__': connectPostgreSQL()
Insert 操作:
import os import sys import psycopg2 def connectPostgreSQL(): conn = psycopg2.connect(database="testdb", user="postgres", password="new.1234", host="127.0.0.1", port="5432") print 'connect successful!' cursor=conn.cursor() cursor.execute('''create table public.member( id integer not null primary key, name varchar(32) not null, password varchar(32) not null, singal varchar(128) )''') conn.commit() conn.close() print 'table public.member is created!' def insertOperate(): conn = psycopg2.connect(database="testdb", user="postgres", password="new.1234", host="127.0.0.1", port="5432") cursor=conn.cursor() cursor.execute("insert into public.member(id,name,password,singal)\ values(1,'member0','password0','signal0')") cursor.execute("insert into public.member(id,name,password,singal)\ values(2,'member1','password1','signal1')") cursor.execute("insert into public.member(id,name,password,singal)\ values(3,'member2','password2','signal2')") cursor.execute("insert into public.member(id,name,password,singal)\ values(4,'member3','password3','signal3')") conn.commit() conn.close() print 'insert records into public.memmber successfully' if __name__=='__main__': #connectPostgreSQL() insertOperate()
Select 操作:
import os import sys import psycopg2 def connectPostgreSQL(): conn = psycopg2.connect(database="testdb", user="postgres", password="new.1234", host="127.0.0.1", port="5432") print 'connect successful!' cursor=conn.cursor() cursor.execute('''create table public.member( id integer not null primary key, name varchar(32) not null, password varchar(32) not null, singal varchar(128) )''') conn.commit() conn.close() print 'table public.member is created!' def insertOperate(): conn = psycopg2.connect(database="testdb", user="postgres", password="new.1234", host="127.0.0.1", port="5432") cursor=conn.cursor() cursor.execute("insert into public.member(id,name,password,singal)\ values(1,'member0','password0','signal0')") cursor.execute("insert into public.member(id,name,password,singal)\ values(2,'member1','password1','signal1')") cursor.execute("insert into public.member(id,name,password,singal)\ values(3,'member2','password2','signal2')") cursor.execute("insert into public.member(id,name,password,singal)\ values(4,'member3','password3','signal3')") conn.commit() conn.close() print 'insert records into public.memmber successfully' def selectOperate(): conn = psycopg2.connect(database="testdb", user="postgres", password="new.1234", host="127.0.0.1", port="5432") cursor=conn.cursor() cursor.execute("select id,name,password,singal from public.member where id>2") rows=cursor.fetchall() for row in rows: print 'id=',row[0], ',name=',row[1],',pwd=',row[2],',singal=',row[3],'\n' conn.close() if __name__=='__main__': #connectPostgreSQL() #insertOperate() selectOperate()
结果:
Python 2.7.12 (v2.7.12:d33e0cf91556, Jun 27 2016, 15:24:40) [MSC v.1500 64 bit (AMD64)] on win32 Type "copyright", "credits" or "license()" for more information. >>> ========== RESTART: C:\Users\Administrator\Desktop\mutilpleTest.py ========== id= 3 ,name= member2 ,pwd= password2 ,singal= signal2 id= 4 ,name= member3 ,pwd= password3 ,singal= signal3 >>>
update操作:
import os import sys import psycopg2 def connectPostgreSQL(): conn = psycopg2.connect(database="testdb", user="postgres", password="new.1234", host="127.0.0.1", port="5432") print 'connect successful!' cursor=conn.cursor() cursor.execute('''create table public.member( id integer not null primary key, name varchar(32) not null, password varchar(32) not null, singal varchar(128) )''') conn.commit() conn.close() print 'table public.member is created!' def insertOperate(): conn = psycopg2.connect(database="testdb", user="postgres", password="new.1234", host="127.0.0.1", port="5432") cursor=conn.cursor() cursor.execute("insert into public.member(id,name,password,singal)\ values(1,'member0','password0','signal0')") cursor.execute("insert into public.member(id,name,password,singal)\ values(2,'member1','password1','signal1')") cursor.execute("insert into public.member(id,name,password,singal)\ values(3,'member2','password2','signal2')") cursor.execute("insert into public.member(id,name,password,singal)\ values(4,'member3','password3','signal3')") conn.commit() conn.close() print 'insert records into public.memmber successfully' def selectOperate(): conn = psycopg2.connect(database="testdb", user="postgres", password="new.1234", host="127.0.0.1", port="5432") cursor=conn.cursor() cursor.execute("select id,name,password,singal from public.member where id>2") rows=cursor.fetchall() for row in rows: print 'id=',row[0], ',name=',row[1],',pwd=',row[2],',singal=',row[3],'\n' conn.close() def updateOperate(): conn = psycopg2.connect(database="testdb", user="postgres", password="new.1234", host="127.0.0.1", port="5432") cursor=conn.cursor() cursor.execute("update public.member set name='update ...' where id=2") conn.commit() print "Total number of rows updated :", cursor.rowcount cursor.execute("select id,name,password,singal from public.member") rows=cursor.fetchall() for row in rows: print 'id=',row[0], ',name=',row[1],',pwd=',row[2],',singal=',row[3],'\n' conn.close() if __name__=='__main__': #connectPostgreSQL() #insertOperate() #selectOperate() updateOperate()
结果:
Python 2.7.12 (v2.7.12:d33e0cf91556, Jun 27 2016, 15:24:40) [MSC v.1500 64 bit (AMD64)] on win32 Type "copyright", "credits" or "license()" for more information. >>> ========== RESTART: C:\Users\Administrator\Desktop\mutilpleTest.py ========== Total number of rows updated : 1 id= 1 ,name= member0 ,pwd= password0 ,singal= signal0 id= 3 ,name= member2 ,pwd= password2 ,singal= signal2 id= 4 ,name= member3 ,pwd= password3 ,singal= signal3 id= 2 ,name= update ... ,pwd= password1 ,singal= signal1 >>>
Delete操作:
import os import sys import psycopg2 def connectPostgreSQL(): conn = psycopg2.connect(database="testdb", user="postgres", password="new.1234", host="127.0.0.1", port="5432") print 'connect successful!' cursor=conn.cursor() cursor.execute('''create table public.member( id integer not null primary key, name varchar(32) not null, password varchar(32) not null, singal varchar(128) )''') conn.commit() conn.close() print 'table public.member is created!' def insertOperate(): conn = psycopg2.connect(database="testdb", user="postgres", password="new.1234", host="127.0.0.1", port="5432") cursor=conn.cursor() cursor.execute("insert into public.member(id,name,password,singal)\ values(1,'member0','password0','signal0')") cursor.execute("insert into public.member(id,name,password,singal)\ values(2,'member1','password1','signal1')") cursor.execute("insert into public.member(id,name,password,singal)\ values(3,'member2','password2','signal2')") cursor.execute("insert into public.member(id,name,password,singal)\ values(4,'member3','password3','signal3')") conn.commit() conn.close() print 'insert records into public.memmber successfully' def selectOperate(): conn = psycopg2.connect(database="testdb", user="postgres", password="new.1234", host="127.0.0.1", port="5432") cursor=conn.cursor() cursor.execute("select id,name,password,singal from public.member where id>2") rows=cursor.fetchall() for row in rows: print 'id=',row[0], ',name=',row[1],',pwd=',row[2],',singal=',row[3],'\n' conn.close() def updateOperate(): conn = psycopg2.connect(database="testdb", user="postgres", password="new.1234", host="127.0.0.1", port="5432") cursor=conn.cursor() cursor.execute("update public.member set name='update ...' where id=2") conn.commit() print "Total number of rows updated :", cursor.rowcount cursor.execute("select id,name,password,singal from public.member") rows=cursor.fetchall() for row in rows: print 'id=',row[0], ',name=',row[1],',pwd=',row[2],',singal=',row[3],'\n' conn.close() def deleteOperate(): conn = psycopg2.connect(database="testdb", user="postgres", password="new.1234", host="127.0.0.1", port="5432") cursor=conn.cursor() cursor.execute("select id,name,password,singal from public.member") rows=cursor.fetchall() for row in rows: print 'id=',row[0], ',name=',row[1],',pwd=',row[2],',singal=',row[3],'\n' print 'begin delete' cursor.execute("delete from public.member where id=2") conn.commit() print 'end delete' print "Total number of rows deleted :", cursor.rowcount cursor.execute("select id,name,password,singal from public.member") rows=cursor.fetchall() for row in rows: print 'id=',row[0], ',name=',row[1],',pwd=',row[2],',singal=',row[3],'\n' conn.close() if __name__=='__main__': #connectPostgreSQL() #insertOperate() #selectOperate() #updateOperate() deleteOperate()
结果:
Python 2.7.12 (v2.7.12:d33e0cf91556, Jun 27 2016, 15:24:40) [MSC v.1500 64 bit (AMD64)] on win32 Type "copyright", "credits" or "license()" for more information. >>> ========== RESTART: C:\Users\Administrator\Desktop\mutilpleTest.py ========== id= 1 ,name= member0 ,pwd= password0 ,singal= signal0 id= 3 ,name= member2 ,pwd= password2 ,singal= signal2 id= 4 ,name= member3 ,pwd= password3 ,singal= signal3 id= 2 ,name= update ... ,pwd= password1 ,singal= signal1 begin delete end delete Total number of rows deleted : 1 id= 1 ,name= member0 ,pwd= password0 ,singal= signal0 id= 3 ,name= member2 ,pwd= password2 ,singal= signal2 id= 4 ,name= member3 ,pwd= password3 ,singal= signal3 >>>
- Pandas Series笔记
- Asp.Net4.0/VS2010新变化(6):内置的图表控件
- Asp.Net4.0/VS2010新变化(5):可扩展的(分布式)缓存
- Pandas对行情数据的预处理
- 上市公司*ST华泽官网打不开,域名已被挂出售卖
- Asp.Net4.0/VS2010新变化(4):SEO的改进
- Pandas DataFrame笔记
- 让控件填满整个页面
- 用多个类别来进行微调
- Asp.Net4.0/VS2010新变化(2):网站自动预热
- Asp.Net4.0/VS2010新变化(1):web.config与publish
- 任天堂将推出Nintendo Labo 域名保护意识墙
- 表格效果
- ROR学习笔记(2):Asp.Net开发者看ROR
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 猿蜕变系列7——也说说springMVC上传姿势
- 猿蜕变系列8——一文搞懂Interceptor操纵姿势
- 猿蜕变9——一文搞定SpringMVC的RESTFul套路
- 猿蜕变10——一文学会ORM的正确打开姿势
- 猿蜕变11——一文掌握mybatis全局玩儿法
- 猿蜕变12——一文搞定mybatis花式玩法
- 猿蜕变13——一文搞懂mybatis规范和标签
- 猿蜕变14——一文搞懂AOP的套路
- 猿蜕变15——一文搞懂Spring AOP的正确姿势
- 猿蜕变16——一文搞懂Spring事务花式玩法
- 猿蜕变17——一文掌握SSM框架搭建姿势
- 猿蜕变18——一文掌控SSM玩耍方式
- 猿蜕变19——一文掌握代码自动生成
- 基于Java的俄罗斯方块游戏的设计与实现
- Docker中部署RabbitMQ并使用Python3.x操作全书(Python操作RabbitMQ看这一篇就够了)