思享工具箱

PostgreSQL连接python，postgresql在python 连接，创建表，创建表内容，插入操作，选择操作，更新操作，删除操作。

摘要：
安装PostgreSQL可以用Pythonpsycopg2模块集成。sycopg2是Python编程语言的PostgreSQL数据库的适配器。Pythonpsycopg2模块APIs以下是psycopg2的重要的的模块例程可以满足Python程序与PostgreSQL数据库的工作。如果寻找一个更复杂的应用程序，那么可以看看Pythonpsycopg2的模块的官方文档。2connection.cursor()该程序创建一个光标将用于整个数据库使用Python编程。3cursor.execute此例程执行SQL语句。9connection.close()此方法关闭数据库连接。

安装

PostgreSQL可以用Python psycopg2模块集成。 sycopg2是Python编程语言的PostgreSQL数据库的适配器。 其程序代码少，速度快，稳定。不需要单独安装这个模块，因为它默认情况下被运往随着Python版本在2.5.x一起的。如果不把它安装在机器上，然后可以使用yum命令安装它，如下所示：

$yum install python-psycopg2

要使用psycopg2的模块，首先必须创建一个Connection对象，它表示数据库然后再可以选择创建游标对象，这将帮助执行的所有SQL语句。

Python psycopg2 模块APIs

以下是psycopg2的重要的的模块例程可以满足Python程序与PostgreSQL数据库的工作。如果寻找一个更复杂的应用程序，那么可以看看Python psycopg2的模块的官方文档。

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()

这个例程获取所有查询结果（剩余）行，返回一个列表。空行时则返回空列表。

创建表

以下Python程序将使用以前创建的数据库中创建一个表：

#!/usr/bin/python
importpsycopg2
conn = psycopg2.connect(database="testdb", user="postgres", password="pass123", host="127.0.0.1", port="5432")
print "Opened database successfully"
cur =conn.cursor()
cur.execute('''CREATE TABLE COMPANY
       (ID INT PRIMARY KEY     NOT NULL,
       NAME           TEXT    NOT NULL,
       AGE            INT     NOT NULL,
       ADDRESS        CHAR(50),
       SALARY         REAL);''')
print "Table created successfully"
conn.commit()
conn.close()

上述程序执行时，它会创建表COMPANY 在数据库test.db中，它会显示以下消息：

Opened database successfully
Table created successfully

INSERT 操作

Python程序显示了我们如何创建表COMPANY 在上面的例子中创建表中的记录：

#!/usr/bin/python
importpsycopg2
conn = psycopg2.connect(database="testdb", user="postgres", password="pass123", host="127.0.0.1", port="5432")
print "Opened database successfully"
cur =conn.cursor()
cur.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) 
      VALUES (1, 'Paul', 32, 'California', 20000.00 )");
cur.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) 
      VALUES (2, 'Allen', 25, 'Texas', 15000.00 )");
cur.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) 
      VALUES (3, 'Teddy', 23, 'Norway', 20000.00 )");
cur.execute("INSERT INTO COMPANY (ID,NAME,AGE,ADDRESS,SALARY) 
      VALUES (4, 'Mark', 25, 'Rich-Mond ', 65000.00 )");
conn.commit()
print "Records created successfully";
conn.close() yiibai.com

上述程序执行时，它会创建COMPANY表中的记录，并显示以下两行：

Opened database successfully
Records created successfully

SELECT 操作

Python程序，显示如何获取并显示COMPANY 表在上面的例子中创建的记录：

#!/usr/bin/python
importpsycopg2
conn = psycopg2.connect(database="testdb", user="postgres", password="pass123", host="127.0.0.1", port="5432")
print "Opened database successfully"
cur =conn.cursor()
cur.execute("SELECT id, name, address, salary  from COMPANY")
rows =cur.fetchall()
for row inrows:
   print "ID = ", row[0]
   print "NAME = ", row[1]
   print "ADDRESS = ", row[2]
   print "SALARY = ", row[3], ""
print "Operation done successfully";
conn.close()

当上述程序执行时，它会产生以下结果：

Opened database successfully
ID =  1
NAME =Paul
ADDRESS =California
SALARY =  20000.0
ID =  2
NAME =Allen
ADDRESS =Texas
SALARY =  15000.0
ID =  3
NAME =Teddy
ADDRESS =Norway
SALARY =  20000.0
ID =  4
NAME =Mark
ADDRESS =  Rich-Mond
SALARY =  65000.0
Operation done successfully

UPDATE 操作

Python代码显示如何，我们可以使用UPDATE语句来更新记录，然后从COMPANY表获取并显示更新的记录：

#!/usr/bin/python
importpsycopg2
conn = psycopg2.connect(database="testdb", user="postgres", password="pass123", host="127.0.0.1", port="5432")
print "Opened database successfully"
cur =conn.cursor()
cur.execute("UPDATE COMPANY set SALARY = 25000.00 where ID=1")
conn.commit
print "Total number of rows updated :", cur.rowcount
cur.execute("SELECT id, name, address, salary  from COMPANY")
rows =cur.fetchall()
for row inrows:
   print "ID = ", row[0]
   print "NAME = ", row[1]
   print "ADDRESS = ", row[2]
   print "SALARY = ", row[3], ""
print "Operation done successfully";
conn.close()

当上述程序执行时，它会产生以下结果：

Opened database successfully
Total number of rows updated : 1
ID =  1
NAME =Paul
ADDRESS =California
SALARY =  25000.0
ID =  2
NAME =Allen
ADDRESS =Texas
SALARY =  15000.0
ID =  3
NAME =Teddy
ADDRESS =Norway
SALARY =  20000.0
ID =  4
NAME =Mark
ADDRESS =  Rich-Mond
SALARY =  65000.0
Operation done successfully

DELETE 操作

Python代码显示了如何我们可以使用DELETE语句删除记录，然后获取并显示COMPANY表剩余的记录：

#!/usr/bin/python
importpsycopg2
conn = psycopg2.connect(database="testdb", user="postgres", password="pass123", host="127.0.0.1", port="5432")
print "Opened database successfully"
cur =conn.cursor()
cur.execute("DELETE from COMPANY where ID=2;")
conn.commit
print "Total number of rows deleted :", cur.rowcount
cur.execute("SELECT id, name, address, salary  from COMPANY")
rows =cur.fetchall()
for row inrows:
   print "ID = ", row[0]
   print "NAME = ", row[1]
   print "ADDRESS = ", row[2]
   print "SALARY = ", row[3], ""
print "Operation done successfully";
conn.close()  
当上述程序执行时，它会产生以下结果：
Opened database successfully
Total number of rows deleted : 1
ID =  1
NAME =Paul
ADDRESS =California
SALARY =  20000.0
ID =  3
NAME =Teddy
ADDRESS =Norway
SALARY =  20000.0
ID =  4
NAME =Mark
ADDRESS =  Rich-Mond
SALARY =  65000.0
Operation done successfully

标签：#python#postgresql | 浏览：111 | 发布日期：

免责声明：文章转载自《PostgreSQL连接python，postgresql在python 连接，创建表，创建表内容，插入操作，选择操作，更新操作，删除操作。》仅用于学习参考。如对内容有疑问，请及时联系本站处理。

上篇Jmeter连接mysql数据库实现参数化CString下篇

宿迁高防，2C2G15M，22元/月；香港BGP，2C5G5M，25元/月 雨云优惠码：MjYwNzM=

相关文章

Misc工具合集

目录 工具安装教程 配置清华源 图片类 F5隐写 outguess stegdetect steghide lsb zsteg bpg BlindWaterMark （盲水印）频域盲水印 gaps montage合并图片 gaps拼图 stegpy 压缩包类crc32.py pyc文件 uncompyle6（pyc文件反编译）...

python之fabric(二)：执行模式（转）

执行模式 执行模式可以让你在多个主机上执行多个任务。 执行策略： 默认fabric是单个有序地执行方法，其行为如下：       1. 创建一系列任务，通过fab任务执行要执行的任务；       2. 根据主机列表定义，去执行每一个任务；       3. 没有主机定义的任务，将在本地执行一次。 如： from fabric.api import run...

DataFrame和python中数据结构互相转换

楔子 有时候DataFrame，我们不一定要保存成文件、或者入数据库，而是希望保存成其它的格式，比如字典、列表、json等等。当然，读取DataFrame也不一定非要从文件、或者数据库，根据现有的数据生成DataFrame也是可以的，那么该怎么做呢？我们来看一下 DataFrame转成python中的数据格式 转成json DataFrame转成json，...

python 30 进程之间的相互独立、进程之间的时间差

# import time# import os# from multiprocessing import Process## def func1():# time.sleep(3)# print('我是func1')## def func2():# time.sleep(3)# print('我是func2')#...

python 行转列

#encoding=utf-8 print '中国' #二维阵列变换 行转化成列，列转化成行 lista=[[1,2,3],[4,5,6],[7,8,9],[10,11,12]] #使用列表推导 listb=[[r[col] for r in lista] for col in range(len(li...

PyQt（Python+Qt）学习随笔：QTreeWidgetItem项下子项的指示符展示原则childIndicatorPolicy

老猿Python博文目录 专栏：使用PyQt开发图形界面Python应用 老猿Python博客地址 树型部件QTreeWidget中的QTreeWidgetItem项下可以有子项，如果存在子项，则父项的节点是否显示展开或折叠子项的提示符由属性childIndicatorPolicy控制。 childIndicatorPolicy属性的类型为枚举类型QT...

最新文章

随机推荐

思享工具箱导航