专栏首页python前行者Python之psycopg2操作PostgreSQL

Python之psycopg2操作PostgreSQL

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

cmd中运行代码:pip install psycopg2-2.6.2-cp27-none-win_amd64.whl

导入psycopg2

想要使用psycopg2,必须用import语句导入该包:

import psycopg2

connection类

connection类表示数据库连接对象。由psycopg2.connect()方法创建。

创建connection对象

psycopg2.connect()函数创建一个新的数据库会话(Session)并且返回一个连接对象。该函数的参数为:

  • dbname – 数据库名字
  • user – 数据库角色名称
  • password – 数据库角色密码
  • host – 数据库地址
  • port – 端口

connection的主要方法

connection提供了常用的数据库操作:

  • commit():提交任何未提交的事务(transaction)到数据库。
  • rollback():回滚。
  • close():关闭数据库。如果关闭数据库时仍有未提交的事务,则执行回滚操作。

cursor类

创建cursor对象

psycopg2提供了一个cursor类,用来在数据库Session里执行PostgreSQL命令。cursor对象由connection.cursor()方法创建:

cur = conn.cursor()

cursor的主要方法

  • execute(query, vars=None):执行SQL语句。
  • fetchall():获取所有查询结果,返回值为tuple列表。

有了cursor对象,就可以操作数据库了。

建立数据库连接

conn = psycopg2.connect(dbname="mydb", user="postgres",
        password="1234", host="127.0.0.1", port="5432")

创建表

cur.execute(
        'CREATE TABLE Employee ('
        'name    varchar(80),'
        'address varchar(80),'
        'age     int,'
        'date    date'
        ')'
    )

插入数据

cur.execute("INSERT INTO Employee "
        "VALUES('Gopher', 'China Beijing', 100, '2017-05-27')")

查询数据

cur.execute("SELECT * FROM Employee")
rows = cur.fetchall()
for row in rows:
    print('name=' + str(row[0]) + ' address=' + str(row[1]) + 
        ' age=' + str(row[2]) + ' date=' + str(row[3]))

更新数据

cur.execute("UPDATE Employee SET age=12 WHERE name='Gopher'")

删除数据

cur.execute("DELETE FROM Employee WHERE name='Gopher'")

完整示例

#coding=utf-8

import psycopg2

# 连接数据库
conn = psycopg2.connect(dbname="mydb", user="postgres",
        password="1234", host="127.0.0.1", port="5432")

# 创建cursor以访问数据库
cur = conn.cursor()

# 创建表
cur.execute(
        'CREATE TABLE Employee ('
        'name    varchar(80),'
        'address varchar(80),'
        'age     int,'
        'date    date'
        ')'
    )

# 插入数据
cur.execute("INSERT INTO Employee "
        "VALUES('Gopher', 'China Beijing', 100, '2017-05-27')")

# 查询数据
cur.execute("SELECT * FROM Employee")
rows = cur.fetchall()
for row in rows:
    print('name=' + str(row[0]) + ' address=' + str(row[1]) + 
        ' age=' + str(row[2]) + ' date=' + str(row[3]))

# 更新数据
cur.execute("UPDATE Employee SET age=12 WHERE name='Gopher'")

# 删除数据
cur.execute("DELETE FROM Employee WHERE name='Gopher'")

# 提交事务
conn.commit()

# 关闭连接
conn.close()

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()   这个例程获取所有查询结果(剩余)行,返回一个列表。空行时则返回空列表。

参考:https://blog.csdn.net/u011304970/article/details/72771775 https://www.cnblogs.com/yy3b2007com/p/5724427.html

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Python操作SQLite数据库

    版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。 ...

    周小董
  • [761]解决sqlite删除数据或者表后,文件大小不变的问题

    原因: sqlite采用的是变长纪录存储,当你从Sqlite删除数据后,未使用的磁盘空间被添加到一个内在的”空闲列表”中用于存储你下次插入的数据,用于提高效率...

    周小董
  • pip 安装mysqlclient报错OSError: mysql_config not found

    周小董
  • python操作sybase数据库

    db = dbName.connect("localhost","testuser","test123","TESTDB" )

    用户2398817
  • python3 下调用zabbix api 获取多个机房的IP

    根据工作的需要,需要查看监控中的所有ip,我们一共有三个机房,每个机房都部署了同样的zabbix监控 根据三个园区的 监控api的url 实现功能:不输入参数 ...

    98k
  • app后台技术

    首先应用程序框架,随你自己业务需求而定,可以选择SSH或者SSM,或者看自己业务量大小。

    公众号php_pachong
  • 微服务:如何拆分共享数据库?

    在分解单体应用程序到微服务体系架构时,重点考虑独立数据库拆分是很重要的。您需要想出一个可靠的策略,将您的数据库分割为多个与应用程序对齐的小型数据库。简而言之,您...

    程序你好
  • 数据库连接

    windows数据库管理,可以在控制面板打开odbc设置和添加数据库驱动(默认sqlserver驱动),用odbc打开数据库

    sofu456
  • Java Web技术经验总结(十一)

    阿杜
  • CSS中基本元件的属性设置

    版权声明:本文为博主原创文章,转载请注明出处。 ...

    魏晓蕾

扫码关注云+社区

领取腾讯云代金券

玩转腾讯云 有奖征文活动