Python PostgreSQL 教程

原文： http://zetcode.com/python/psycopg2/

带有psycopg2模块的 Python PostgreSQL 教程展示了如何使用psycopg2模块在 Python 中编程 PostgreSQL 数据库。

PostgreSQL

PostgreSQL 是一个功能强大的开源对象关系数据库系统。它是一个多用户数据库管理系统。它可以在包括 Linux，FreeBSD，Solaris，Microsoft Windows 和 Mac OS X 在内的多个平台上运行。PostgreSQL 由 PostgreSQL 全球开发小组开发。

`psycopg2`模块

PostgreSQL 有几个 Python 库。语言。在本教程中，我们使用psycopg2模块。它是用于 Python 编程语言的 PostgreSQL 数据库适配器。它主要在 C 中作为libpq包装器实现。

$ pip install psycopg2

我们安装psycopg2模块。

Python psycopg2 版本示例

在第一个代码示例中，我们获得 PostgreSQL 数据库的版本。

version.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2
import sys

con = None

try:

    con = psycopg2.connect(database='testdb', user='postgres',
        password='s$cret')

    cur = con.cursor()
    cur.execute('SELECT version()')

    version = cur.fetchone()[0]
    print(version)

except psycopg2.DatabaseError as e:

    print(f'Error {e}')
    sys.exit(1)

finally:

    if con:
        con.close()

在程序中，我们连接到先前创建的testdb数据库。我们执行一条 SQL 语句，该语句返回 PostgreSQL 数据库的版本。

import psycopg2

psycopg2是一个 Python 模块，用于与 PostgreSQL 数据库一起使用。

con = None

我们将con变量初始化为None。如果无法创建与数据库的连接（例如磁盘已满），则不会定义连接变量。这将导致finally子句中的错误。

con = psycopg2.connect(database='testdb', user='postgres',
    password='s$cret')

connect()方法创建一个新的数据库会话并返回一个连接对象。用户创建时没有密码。在 localhost 上，我们可以省略password选项。否则，必须指定它。

cur = con.cursor()
cur.execute('SELECT version()')

从连接中，我们得到游标对象。游标用于遍历结果集中的记录。我们调用游标的execute()方法并执行 SQL 语句。

version = cur.fetchone()[0]

我们获取数据。由于只检索一条记录，因此我们称为fetchone()方法。

print(version)

我们将检索到的数据打印到控制台。

except psycopg2.DatabaseError as e:

    print(f'Error {e}')
    sys.exit(1)

如果发生异常，我们将输出一条错误消息并以错误代码 1 退出程序。

finally:

    if con:
        con.close())

在最后一步，我们释放资源。

$ version.py
PostgreSQL 11.1, compiled by Visual C++ build 1914, 64-bit

这是输出。

在第二个示例中，我们再次获得 PostgreSQL 数据库的版本。这次我们使用with关键字。

version2.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2

con = psycopg2.connect(database='testdb', user='postgres',
    password='s$cret')

with con:

    cur = con.cursor()
    cur.execute('SELECT version()')

    version = cur.fetchone()[0]
    print(version)

程序返回 PostgreSQL 数据库的当前版本。与with关键字一起使用。代码更紧凑。

with con:

使用with关键字，Python 自动释放资源。它还提供错误处理。

Python psycopg2 `execute`

我们创建cars表并在其中插入几行。 execute()执行数据库操作（查询或命令）。

create_table.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2

con = psycopg2.connect(database='testdb', user='postgres',
                       password='s$cret')

with con:

    cur = con.cursor()

    cur.execute("DROP TABLE IF EXISTS cars")
    cur.execute("CREATE TABLE cars(id SERIAL PRIMARY KEY, name VARCHAR(255), price INT)")
    cur.execute("INSERT INTO cars(name, price) VALUES('Audi', 52642)")
    cur.execute("INSERT INTO cars(name, price) VALUES('Mercedes', 57127)")
    cur.execute("INSERT INTO cars(name, price) VALUES('Skoda', 9000)")
    cur.execute("INSERT INTO cars(name, price) VALUES('Volvo', 29000)")
    cur.execute("INSERT INTO cars(name, price) VALUES('Bentley', 350000)")
    cur.execute("INSERT INTO cars(name, price) VALUES('Citroen', 21000)")
    cur.execute("INSERT INTO cars(name, price) VALUES('Hummer', 41400)")
    cur.execute("INSERT INTO cars(name, price) VALUES('Volkswagen', 21600)")

该程序将创建cars表，并将八行插入到该表中。

cur.execute("CREATE TABLE cars(id SERIAL PRIMARY KEY, name VARCHAR(20), price INT)")

该 SQL 语句创建一个新的cars表。该表有三列。

cur.execute("INSERT INTO cars(name, price) VALUES('Audi', 52642)")
cur.execute("INSERT INTO cars(name, price) VALUES('Mercedes', 57127)")

这两行将两辆车插入表。

$ psql -U postgres testdb
psql (11.1)
Type "help" for help.

testdb=# SELECT * FROM cars;
    id |    name    | price
----+------------+--------
    1 | Audi       |  52642
    2 | Mercedes   |  57127
    3 | Skoda      |   9000
    4 | Volvo      |  29000
    5 | Bentley    | 350000
    6 | Citroen    |  21000
    7 | Hummer     |  41400
    8 | Volkswagen |  21600
(8 rows)

我们使用psql工具验证写入的数据。

Python Psycopg2 `executemany`

executemany()方法是一种方便的方法，用于针对在提供的序列中找到的所有参数元组或映射启动数据库操作（查询或命令）。该函数对更新数据库的命令最有用：查询返回的任何结果集都将被丢弃。

execute_many.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2

cars = (
    (1, 'Audi', 52642),
    (2, 'Mercedes', 57127),
    (3, 'Skoda', 9000),
    (4, 'Volvo', 29000),
    (5, 'Bentley', 350000),
    (6, 'Citroen', 21000),
    (7, 'Hummer', 41400),
    (8, 'Volkswagen', 21600)
)

con = psycopg2.connect(database='testdb', user='postgres',
                    password='s$cret')

with con:

    cur = con.cursor()

    cur.execute("DROP TABLE IF EXISTS cars")
    cur.execute("CREATE TABLE cars(id SERIAL PRIMARY KEY, name VARCHAR(255), price INT)")

    query = "INSERT INTO cars (id, name, price) VALUES (%s, %s, %s)"
    cur.executemany(query, cars)

    con.commit()

本示例删除cars表（如果存在）并（重新）创建它。

cur.execute("DROP TABLE IF EXISTS cars")
cur.execute("CREATE TABLE cars(id SERIAL PRIMARY KEY, name VARCHAR(255), price INT)")

第一个 SQL 语句删除cars表（如果存在）。第二条 SQL 语句创建cars表。

query = "INSERT INTO cars (id, name, price) VALUES (%s, %s, %s)"

这是我们使用的查询。

cur.executemany(query, cars)

我们使用便捷的executemany()方法将八行插入到表中。此方法的第一个参数是参数化的 SQL 语句。第二个参数是数据，以元组的形式显示。

Python `psycopg2`最后插入的行 ID

psycopg2不支持lastrowid属性。要返回最后插入的行的 ID，我们必须使用 PostgreSQL 的RETURNING id子句。

lastrowid.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2

con = psycopg2.connect(database='testdb', user='postgres',
                       password='s$cret')

with con:

    cur = con.cursor()

    cur.execute("DROP TABLE IF EXISTS words")
    cur.execute("CREATE TABLE words(id SERIAL PRIMARY KEY, word VARCHAR(255))")
    cur.execute("INSERT INTO words(word) VALUES('forest') RETURNING id")
    cur.execute("INSERT INTO words(word) VALUES('cloud') RETURNING id")
    cur.execute("INSERT INTO words(word) VALUES('valley') RETURNING id")

    last_row_id = cur.fetchone()[0]

    print(f"The last Id of the inserted row is {last_row_id}")

该程序将创建一个新的words表并打印最后插入的行的 ID。

$ lastrowid.py
The last Id of the inserted row is 3

这是输出。

Python Psycopg2 `fetchall`

fetchall()获取查询结果的所有（剩余）行，并将它们作为元组列表返回。如果没有更多记录可获取，则返回一个空列表。

fetch_all.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2

con = psycopg2.connect(database='testdb', user='postgres',
                    password='s$cret')

with con:

    cur = con.cursor()
    cur.execute("SELECT * FROM cars")

    rows = cur.fetchall()

    for row in rows:
        print(f"{row[0]} {row[1]} {row[2]}")

在此示例中，我们从cars表中检索所有数据。

cur.execute("SELECT * FROM cars")

该 SQL 语句从cars表中选择所有数据。

rows = cur.fetchall()

fetchall()方法获取所有记录。它返回一个结果集。从技术上讲，它是一个元组的元组。每个内部元组代表表中的一行。

for row in rows:
    print(f"{row[0]} {row[1]} {row[2]}")

我们将数据逐行打印到控制台。

$ fetch_all.py
1 Audi 52642
2 Mercedes 57127
3 Skoda 9000
4 Volvo 29000
5 Bentley 350000
6 Citroen 21000
7 Hummer 41400
8 Volkswagen 21600

这是示例的输出。

Python Psycopg2 `fetchone`

fetchone()返回查询结果集的下一行，返回单个元组，或者在没有更多数据可用时返回None。

fetchone.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2

con = psycopg2.connect(database='testdb', user='postgres',
                    password='s$cret')

with con:

    cur = con.cursor()
    cur.execute("SELECT * FROM cars")

    while True:

        row = cur.fetchone()

        if row == None:
            break

        print(f"{row[0]} {row[1]} {row[2]}")

在此示例中，我们连接到数据库并一张一张地获取cars表的行。

while True:

我们从while循环访问数据。当我们读取最后一行时，循环终止。

row = cur.fetchone()

if row == None:
    break

fetchone()方法返回表的下一行。如果没有剩余数据，则返回None。在这种情况下，我们打破了循环。

print(f"{row[0]} {row[1]} {row[2]}")

数据以元组的形式返回。在这里，我们从元组中选择记录。第一个是 ID，第二个是汽车名称，第三个是汽车的价格。

Python `psycopg2`字典游标

默认游标检索元组中的数据。使用字典游标，数据以 Python 字典的形式发送。然后，我们可以通过列名称来引用数据。

dictionary_cursor

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2
import psycopg2.extras

con = psycopg2.connect(database='testdb', user='postgres',
                    password='s$cret')

with con:

    cursor = con.cursor(cursor_factory=psycopg2.extras.DictCursor)
    cursor.execute("SELECT * FROM cars")

    rows = cursor.fetchall()

    for row in rows:
        print(f"{row['id']} {row['name']} {row['price']}")

在此示例中，我们使用字典游标打印cars表的内容。

import psycopg2.extras

字典游标位于extras模块中。

cursor = con.cursor(cursor_factory=psycopg2.extras.DictCursor)

我们创建一个DictCursor。

for row in rows:
    print(f"{row['id']} {row['name']} {row['price']}")

通过列名访问数据。列名在 PostgreSQL 中（除非加引号）被折叠成小写并且区分大小写。因此，我们必须以小写形式提供列名称。

Python `psycopg2`参数化查询

当使用参数化查询时，我们使用占位符，而不是直接将值写入语句。参数化查询可提高安全性和性能。

Python psycopg2模块支持两种类型的占位符：ANSI C printf格式和 Python 扩展格式。

parameterized_query.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2

con = psycopg2.connect(database='testdb', user='postgres',
                    password='s$cret')

uId = 1
uPrice = 62300

con = psycopg2.connect(database='testdb', user='postgres',
                    password='s$cret')

with con:

    cur = con.cursor()
    cur.execute("UPDATE cars SET price=%s WHERE id=%s", (uPrice, uId))

    print(f"Number of rows updated: {cur.rowcount}")

我们更新了一辆车的价格。在此代码示例中，我们使用问号占位符。

cur.execute("UPDATE cars SET price=%s WHERE id=%s", (uPrice, uId))

字符（%s）是值的占位符。这些值将添加到占位符。

print(f"Number of rows updated: {cur.rowcount}")

rowcount属性返回更新的行数。在我们的情况下，一行已更新。

$ parameterized_query.py
Number of rows updated: 1

testdb=> SELECT * FROM cars WHERE id=1;
 id | name | price
----+------+-------
  1 | Audi | 62300
(1 row)

汽车的价格已更新。我们使用psql工具检查更改。

第二个示例使用 Python 扩展格式的参数化语句。

parameterized_query2.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2

uid = 3

con = psycopg2.connect(database='testdb', user='postgres',
                    password='s$cret')

with con:

    cur = con.cursor()

    cur.execute("SELECT * FROM cars WHERE id=%(id)s", {'id': uid } )

    row = cur.fetchone()

    print(f'{row[0]} {row[1]} {row[2]}')

我们使用pyformat参数化语句选择汽车的名称和价格。

cur.execute("SELECT * FROM cars WHERE id=%(id)s", {'id': uid } )

命名的占位符以冒号开头。

$ parameterized_query2.py
3 Skoda 9000

这是输出。

Python `psycopg2`迁移

mogrify是 Python DB API 的psycopg2扩展，在参数绑定后返回查询字符串。返回的字符串恰好是将发送到运行execute()方法或类似方法的数据库的字符串。

mogrify.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2

con = psycopg2.connect(database='testdb', user='postgres',
                    password='s$cret')
cur = None

with con:

    cur = con.cursor()     

    print(cur.mogrify("SELECT name, price FROM cars WHERE id=%s", (2,)))

    # cur.execute("SELECT name, price FROM cars WHERE id=%s", (2,) )
    # row = cur.fetchone()
    # print(f"{row[0]} {row[1]}")

在将参数与mogrify()绑定后，程序显示SELECT查询字符串。

$ mogrify.py
b'SELECT name, price FROM cars WHERE id=2'

这是输出。

Python `psycopg2`插入图像

在本节中，我们将图像插入 PostgreSQL 数据库。

testdb=> CREATE TABLE images(id SERIAL PRIMARY KEY, data BYTEA);

对于此示例，我们创建一个名为images的新表。对于图像，我们使用BYTEA数据类型。它允许存储二进制字符串。

insert_image.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2
import sys

def readImage():

    fin = None

    try:
        fin = open("sid.jpg", "rb")
        img = fin.read()
        return img

    except IOError as e:

        print(f'Error {e.args[0]}, {e.args[1]}')
        sys.exit(1)

    finally:

        if fin:
            fin.close()

con = None

try:
    con = psycopg2.connect(database='testdb', user='postgres',
                    password='s$cret')

    cur = con.cursor()
    data = readImage()
    binary = psycopg2.Binary(data)
    cur.execute("INSERT INTO images(data) VALUES (%s)", (binary,))

    con.commit()

except psycopg2.DatabaseError as e:

    if con:
        con.rollback()

    print(f'Error {e}')
    sys.exit(1)

finally:

    if con:
        con.close()

在程序中，我们从当前工作目录中读取图像，并将其写入 PostgreSQL testdb数据库的images表中。

try:
    fin = open("sid.jpg", "rb")
    img = fin.read()
    return img

我们从文件系统读取二进制数据。我们有一个名为sid.jpg的 JPEG 图像。

binary = psycopg2.Binary(data)

使用psycopg2 Binary对象对数据进行编码。

cur.execute("INSERT INTO images(data) VALUES (%s)", (binary,))

该 SQL 语句用于将映像插入数据库。

Python `psycopg2`读取图像

在本节中，我们将执行相反的操作。我们从数据库表中读取图像。

read_image.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2
import sys

def writeImage(data):

    fout = None

    try:
        fout = open('sid2.jpg', 'wb')
        fout.write(data)

    except IOError as e:

        print(f"Error {0}")
        sys.exit(1)

    finally:

        if fout:
            fout.close()

try:
    con = psycopg2.connect(database='testdb', user='postgres',
                    password='s$cret')

    cur = con.cursor()
    cur.execute("SELECT data FROM images LIMIT 1")
    data = cur.fetchone()[0]

    writeImage(data)

except psycopg2.DatabaseError as e:

    print(f'Error {e}')
    sys.exit(1)

finally:

    if con:
        con.close()

我们从图像表中读取图像数据并将其写入另一个文件，我们称为sid2.jpg。

try:
    fout = open('sid2.jpg', 'wb')
    fout.write(data)

我们以写入模式打开一个二进制文件。来自数据库的数据被写入文件。

cur.execute("SELECT data FROM images LIMIT 1")
data = cur.fetchone()[0]

这两行从images表中选择并获取数据。我们从第一行获取二进制数据。

Python PostgreSQL 元数据

元数据是有关数据库中数据的信息。 PostgreSQL 数据库中的元数据包含有关表和列的信息，我们在其中存储数据。受 SQL 语句影响的行数是元数据。结果集中返回的行数和列数也属于元数据。

可以使用游标对象的description属性或information_schema表获取 PostgreSQL 中的元数据。

接下来，我们打印cars表中的所有行及其列名。

column_names.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2

con = psycopg2.connect(database='testdb', user='postgres',
                       password='s$cret')

with con:

    cur = con.cursor()

    cur.execute('SELECT * FROM cars')

    col_names = [cn[0] for cn in cur.description]
    rows = cur.fetchall()

    print(f'{col_names[0]} {col_names[1]} {col_names[2]}')

我们将cars表的内容打印到控制台。现在，我们也包括列的名称。

col_names = [cn[0] for cn in cur.description]

我们从游标对象的description属性获得列名。

print(f'{col_names[0]} {col_names[1]} {col_names[2]}')

此行打印cars表的三个列名。

我们使用for循环打印行。数据与列名对齐。

$ column_names.py
id name price

这是输出。

在下面的示例中，我们列出了testdb数据库中的所有表。

list_tables.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2

con = psycopg2.connect(database='testdb', user='postgres',
                    password='s$cret')

with con:

    cur = con.cursor()
    cur.execute("""SELECT table_name FROM information_schema.tables
        WHERE table_schema = 'public'""")

    rows = cur.fetchall()

    for row in rows:
        print(row[0])

该代码示例将当前数据库中的所有可用表打印到终端。

cur.execute("""SELECT table_name FROM information_schema.tables
    WHERE table_schema = 'public'""")

表名存储在系统information_schema表中。

$ list_tables.py
cars
countries
projects
employees
users
tasks
images

这些是我们系统上的表。

Python `psycopg2`导出和导入数据

我们可以使用copy_to()和copy_from()导出和导入数据。

copy_to.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2
import sys

con = None
fout = None

try:

    con = psycopg2.connect(database='testdb', user='postgres',
                    password='s$cret')

    cur = con.cursor()
    fout = open('cars.csv', 'w')
    cur.copy_to(fout, 'cars', sep="|")

except psycopg2.DatabaseError as e:

    print(f'Error {e}')
    sys.exit(1)

except IOError as e:

    print(f'Error {e}')
    sys.exit(1)

finally:

    if con:
        con.close()

    if fout:
        fout.close()

该代码示例将数据从cars表复制到cars.csv文件中。

fout = open('cars.csv', 'w')

我们打开一个文件，在其中写入cars表中的数据。

cur.copy_to(fout, 'cars', sep="|")

copy_to方法将数据从cars表复制到打开的文件。这些列用|字符分隔。

$ cat cars.csv
2|Mercedes|57127
3|Skoda|9000
4|Volvo|29000
5|Bentley|350000
6|Citroen|21000
7|Hummer|41400
8|Volkswagen|21600
1|Audi|62300

这些是cars文件的内容。

现在，我们将执行反向操作。我们将转储的表重新导入数据库表。

testdb=> DELETE FROM cars;
DELETE 8

我们从cars表中删除数据。

copy_from.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2
import sys

con = None
f = None

try:

    con = psycopg2.connect(database='testdb', user='postgres',
                    password='s$cret')

    cur = con.cursor()
    f = open('cars.csv', 'r')

    cur.copy_from(f, 'cars', sep="|")
    con.commit()

except psycopg2.DatabaseError as e:

    if con:
        con.rollback()

    print(f'Error {e}')
    sys.exit(1)

except IOError as e:

    if con:
        con.rollback()

    print(f'Error {e}')
    sys.exit(1)

finally:

    if con:
        con.close()

    if f:
        f.close()

在程序中，我们读取cars文件的内容，并将其复制回cars表。

f = open('cars.csv', 'r')
cur.copy_from(f, 'cars', sep="|")
con.commit()

我们打开cars.csv文件进行读取，然后将内容复制到cars表中。所做的更改已提交。

SELECT * FROM cars;
 id |    name    | price
----+------------+--------
  2 | Mercedes   |  57127
  3 | Skoda      |   9000
  4 | Volvo      |  29000
  5 | Bentley    | 350000
  6 | Citroen    |  21000
  7 | Hummer     |  41400
  8 | Volkswagen |  21600
  1 | Audi       |  62300
(8 rows)

输出显示我们已经成功地重新创建了已保存的cars表。

Python `psycopg2`事务

事务是针对一个或多个数据库中数据的数据库操作的基本单位。事务中所有 SQL 语句的影响可以全部提交给数据库，也可以全部回滚。

在psycopg2模块中，事务由连接类处理。连接游标的第一个命令启动事务。（我们不需要用BEGIN和END语句来封装 SQL 命令来创建事务。这将由psycopg2自动处理。）以下命令在此新事务的上下文中执行。发生错误时，事务将中止，并且直到rollback()方法都不再执行其他命令。

psycopg2模块的文档说，该连接负责终止其事务，并调用commit()或rollback()方法。提交的更改将立即持久化到数据库中。使用close()方法关闭连接或破坏连接对象（使用del或使其超出范围）将导致隐式的rollback()调用。

psycopg2模块还支持自动提交模式，其中对表的所有更改均立即生效。为了在自动提交模式下运行，我们将连接对象的autocommit属性设置为True。

no_commit.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2
import sys

con = None

try:

    con = psycopg2.connect(database='testdb', user='postgres',
                    password='s$cret')

    cur = con.cursor()

    cur.execute("DROP TABLE IF EXISTS friends")
    cur.execute("CREATE TABLE friends(id SERIAL PRIMARY KEY, name VARCHAR(255))")
    cur.execute("INSERT INTO friends(name) VALUES ('Tom')")
    cur.execute("INSERT INTO friends(name) VALUES ('Rebecca')")
    cur.execute("INSERT INTO friends(name) VALUES ('Jim')")
    cur.execute("INSERT INTO friends(name) VALUES ('Robert')")

    con.commit()

except psycopg2.DatabaseError as e:

    if con:
        con.rollback()

    print('Error {e}')
    sys.exit(1)

finally:

    if con:
        con.close()

我们创建friends表，并尝试用数据填充它。但是，正如我们将看到的，数据不会被提交。

#con.commit()

注释commit()方法。如果我们取消注释该行，则数据将被写入表中。

finally:

    if con:
        con.close()

finally块始终执行。如果我们尚未提交更改，并且没有发生错误（会回滚更改），则该事务仍将打开。使用close()方法关闭连接，并通过隐式调用rollback()方法终止事务。

testdb=# \dt
        List of relations
Schema |   Name    | Type  |  Owner
--------+-----------+-------+----------
public | cars      | table | postgres
public | countries | table | postgres
public | employees | table | postgres
public | images    | table | postgres
public | projects  | table | postgres
public | tasks     | table | postgres
public | users     | table | postgres
(7 rows)

仅在取消注释该行之后，才创建friends表。

Python `psycopg2`自动提交

在自动提交模式下，将立即执行一条 SQL 语句。

autocommit.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import psycopg2
import sys

con = None

try:

    con = psycopg2.connect(database='testdb', user='postgres',
                    password='s$cret')

    con.autocommit = True

    cur = con.cursor()

    cur.execute("DROP TABLE IF EXISTS friends")
    cur.execute("CREATE TABLE friends(id serial PRIMARY KEY, name VARCHAR(10))")
    cur.execute("INSERT INTO friends(name) VALUES ('Jane')")
    cur.execute("INSERT INTO friends(name) VALUES ('Tom')")
    cur.execute("INSERT INTO friends(name) VALUES ('Rebecca')")
    cur.execute("INSERT INTO friends(name) VALUES ('Jim')")
    cur.execute("INSERT INTO friends(name) VALUES ('Robert')")
    cur.execute("INSERT INTO friends(name) VALUES ('Patrick')")

except psycopg2.DatabaseError as e:

    print(f'Error {e}')
    sys.exit(1)

finally:

    if con:
        con.close()

在此示例中，我们以自动提交模式连接到数据库。我们既不调用commit()，也不调用rollback()方法。

con.autocommit = True

我们将连接设置为自动提交模式。

$ autocommit.py

testdb=# select * from friends;
 id |  name
----+---------
  1 | Jane
  2 | Tom
  3 | Rebecca
  4 | Jim
  5 | Robert
  6 | Patrick
(6 rows)

数据已成功提交到friends表。

这是 PostgreSQL Python 教程。您可能也对 SQLite Python 教程和 MySQL Python 教程感兴趣

我们一直在努力

apachecn/AiLearning

Python PostgreSQL 教程

PostgreSQL

psycopg2模块

Python psycopg2 版本示例

Python psycopg2 execute

Python Psycopg2 executemany

Python psycopg2最后插入的行 ID

Python Psycopg2 fetchall

Python Psycopg2 fetchone

Python psycopg2字典游标

Python psycopg2参数化查询

Python psycopg2迁移

Python psycopg2插入图像

Python psycopg2读取图像

Python PostgreSQL 元数据

Python psycopg2导出和导入数据

Python psycopg2事务

Python psycopg2自动提交

`psycopg2`模块

Python psycopg2 `execute`

Python Psycopg2 `executemany`

Python `psycopg2`最后插入的行 ID

Python Psycopg2 `fetchall`

Python Psycopg2 `fetchone`

Python `psycopg2`字典游标

Python `psycopg2`参数化查询

Python `psycopg2`迁移

Python `psycopg2`插入图像

Python `psycopg2`读取图像

Python `psycopg2`导出和导入数据

Python `psycopg2`事务

Python `psycopg2`自动提交