使用Python进行PostgreSQL数据库连接的流程步骤

更新时间：2026年04月03日 09:17:39 作者：2601_94981616

本文介绍了使用Python连接PostgreSQL数据库的方法,包括使用psycopg2安装、图形化连接和代码连接,还详细介绍了DML（数据操作语言）和DQL（数据查询语言）语句的测试,涵盖创建表、插入数据、更新数据、删除数据和查询数据的操作,需要的朋友可以参考下

使用python进行PostgreSQL 数据库连接

PostgreSQL 数据库是最常用的关系型数据库之一，最吸引人的一点是它作为开源数据库且具有可拓展性，能够提供丰富的应用。运用python可以很简单的建立PostgreSQL 数据库连接，其中最受欢迎的就是psycopg。

1. 安装psycopg2

Psycopy是针对python的Postgres 数据库的适配模块，安装psycopg2可以整合python和Postgres 。使用cmd输入命令进行安装：

pip install psycopg2

也可以在pycharm中查找psycopg2安装包：

2. 图形化连接数据库

在pycharm中选择Database，点击左上角的+添加数据库，选择postgresql:
创建数据库连接后点击apply，数据库会显示在右侧窗格中。

3. 代码连接数据库

3.1 不使用配置文件

下面使用 psycopy2.connect()方法连接到postgresql数据库。通过调用cursor类中的execute()方法对数据库进行操作。在execute()中用SQL语句创建表。使用commit()将数据发送到数据库服务器，最后使用close()关闭数据库。commit()能够对数据库进行改变，且不可逆。

connect() 方法的参数一般包括:

database: 要连接的数据库名称
user:连接数据库的用户名
password: 连接数据库的密码
host: 数据库端口的地址，一般为 “localhost”,或者主机的IP地址
port: 门户默认为5432.

import psycopg2
con = psycopg2.connect(database=“postgres”,
user=“fbase”,
password=“123456”,
host=“192.168.198.152”,
port=“8432”)
print(con)
print(“Database opened successfully”)
cur = con.cursor()
cur.execute(‘SELECT version()')
db_version = cur.fetchone()
print(db_version)
con.close()

运行结果如下：

3.2 使用配置文件

可以使用配置文件来存储所有连接参数。

database.ini文件的内容如下：

[postgresql]
host = 192.168.198.152
database = postgres
user = fbase
password = 123456
port = 8432

下面的config()函数会读取database.ini文件并返回连接参数。该config()函数放置在config.py文件中：

from configparser import ConfigParser


def config(filename='../../resource/database.ini', section='postgresql'):
    # create a parser
    parser = ConfigParser()
    # read config file
    parser.read(filename)

    # get section, default to postgresql
    db = {}
    if parser.has_section(section):
        params = parser.items(section)
        for param in params:
            db[param[0]] = param[1]
    else:
        raise Exception('Section {0} not found in the {1} file'.format(section, filename))

    return db

下面的connect()函数连接到suppliers数据库并打印出 PostgreSQL 数据库版本。

import psycopg2

from demo.pgdemo.config import config


def connect():
    """ Connect to the PostgreSQL database server """
    conn = None
    try:
        # read connection parameters
        params = config()

        # connect to the PostgreSQL server
        print('Connecting to the PostgreSQL database...')
        conn = psycopg2.connect(**params)

        # create a cursor
        cur = conn.cursor()

        # execute a statement
        print('PostgreSQL database version:')
        cur.execute('SELECT version()')

        # display the PostgreSQL database server version
        db_version = cur.fetchone()
        print(db_version)

        # close the communication with the PostgreSQL
        cur.close()
    except (Exception, psycopg2.DatabaseError) as error:
        print(error)
    finally:
        if conn is not None:
            conn.close()
            print('Database connection closed.')


if __name__ == '__main__':
    connect()

怎么运行的。

首先，从database.ini文件中读取数据库连接参数。
接下来，通过调用connect()函数创建一个新的数据库连接。
然后，新建一个cursor并执行SQL语句来获取 PostgreSQL 数据库版本。
之后，通过调用游标对象的 fetchone()方法读取结果集。
最后，通过调用cursor和connection对象的close()方法关闭与数据库服务器的通信。

4. DML语句测试

4.1 创建表

使用SQL(Structured Query Language)语句CREATE TABLE添加新的表:

import psycopg2

# 建立数据库连接
con = psycopg2.connect(database="postgres",
                       user="fbase",
                       password="123456",
                       host="192.168.198.152",
                       port="8432")
print("Database opened successfully")
# 调用游标对象
cur = con.cursor()
# 用cursor中的execute 使用DDL语句创建一个名为 STUDENT 的表,指定表的字段以及字段类型
cur.execute('''
       CREATE TABLE IF NOT EXISTS STUDENT
      (ADMISSION INT PRIMARY KEY     NOT NULL,
      NAME           TEXT            NOT NULL,
      AGE            INT             NOT NULL,
      COURSE        CHAR(50),
      DEPARTMENT        CHAR(50));''')

# 提交更改，增添或者修改数据只会必须要提交才能生效
con.commit()
con.close()

结果查看：

postgres=# d
        List of relations
 Schema |  Name   | Type  | Owner 
--------+---------+-------+-------
 public | student | table | fbase
(1 row)

4.2 表插入数据

使用INSERT INTO 在以经生成的表中插入数据

import psycopg2

# 建立数据库连接
con = psycopg2.connect(database="postgres",
                       user="fbase",
                       password="123456",
                       host="192.168.198.152",
                       port="8432")
print("Database opened successfully")
# 调用游标对象
cur = con.cursor()
# 在表中插入一条数据
cur.execute("INSERT INTO STUDENT (ADMISSION,NAME,AGE,COURSE,DEPARTMENT) "
            "VALUES (3420, 'John', 18, 'Computer Science', 'ICT')")

# 提交更改，增添或者修改数据只会必须要提交才能生效
con.commit()
con.close()

结果查看：

postgres=# select * from student ;
 admission | name | age |                       course                       |                     department                     
-----------+------+-----+----------------------------------------------------+----------------------------------------------------
      3420 | John |  18 | Computer Science                                   | ICT                                               
(1 row)

4.3 表更新数据

同样使用SQL语句更新目标字段，使用commit()更新数据库

import psycopg2

# 建立数据库连接
con = psycopg2.connect(database="postgres",
                       user="fbase",
                       password="123456",
                       host="192.168.198.152",
                       port="8432")
print("Database opened successfully")
# 调用游标对象
cur = con.cursor()
# 更新表中的数据
cur.execute("UPDATE student set name = 'joe' WHERE admission = 3420")

# 提交更改，增添或者修改数据只会必须要提交才能生效
con.commit()
con.close()

结果查看：

postgres=# select * from student ;
 admission | name | age |                       course                       |                     department                     
-----------+------+-----+----------------------------------------------------+----------------------------------------------------
      3420 | John |  18 | Computer Science                                   | ICT                                               
(1 row)
postgres=# select * from student ;
 admission | name | age |                       course                       |                     department                     
-----------+------+-----+----------------------------------------------------+----------------------------------------------------
      3420 | joe  |  18 | Computer Science                                   | ICT                                        
(1 row)

4.4 表删除数据

同样使用SQL语句更新目标字段，使用commit()更新数据库

import psycopg2

# 建立数据库连接
con = psycopg2.connect(database="postgres",
                       user="fbase",
                       password="123456",
                       host="192.168.198.152",
                       port="8432")
print("Database opened successfully")
# 调用游标对象
cur = con.cursor()
# 删除表中的数据
cur.execute("DELETE FROM student WHERE admission = 3420")

# 提交更改，增添或者修改数据只会必须要提交才能生效
con.commit()
con.close()

结果查看：

postgres=# select * from student ;
 admission | name | age |                       course                       |                     department                     
-----------+------+-----+----------------------------------------------------+----------------------------------------------------
      3420 | joe  |  18 | Computer Science                                   | ICT                                               
(1 row)
postgres=# select * from student ;
 admission | name | age | course | department 
-----------+------+-----+--------+------------
(0 rows)

5. DQL语句测试

5.1 查看表中的数据

同样使用SQL语句更新目标字段，使用commit()更新数据库

import psycopg2

# 建立数据库连接
con = psycopg2.connect(database="postgres",
                       user="fbase",
                       password="123456",
                       host="192.168.198.152",
                       port="8432")
print("Database opened successfully")
# 调用游标对象
cur = con.cursor()
# 删除表中的数据
cur.execute("SELECT * FROM student")

rows = cur.fetchall()
for row in rows:
    print("ADMISSION =", row[0])
    print("NAME =", row[1])
    print("AGE =", row[2])
    print("COURSE =", row[3])
    print("DEPARTMENT =", row[4], "
")

# 提交更改，增添或者修改数据只会必须要提交才能生效
con.commit()
con.close()

结果查看：

D:python3python.exe D:/project/python/demo/demo/pgdemo/dql_select_1.py
Database opened successfully
ADMISSION = 3420
NAME = John
AGE = 18
COURSE = Computer Science                                  
DEPARTMENT = ICT
w[3])
    print("DEPARTMENT =", row[4], "
")

# 提交更改，增添或者修改数据只会必须要提交才能生效
con.commit()
con.close()

结果查看：

D:python3python.exe D:/project/python/demo/demo/pgdemo/dql_select_1.py
Database opened successfully
ADMISSION = 3420
NAME = John
AGE = 18
COURSE = Computer Science                                  
DEPARTMENT = ICT

以上就是使用Python进行PostgreSQL数据库连接的流程步骤的详细内容，更多关于Python连接PostgreSQL数据库的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

如何利用Python+OpenCV实现简易图像边缘轮廓检测(零基础)
轮廓是形状分析和物体检测和识别的有用工具,下面这篇文章主要给大家介绍了关于如何利用Python+OpenCV实现简易图像边缘轮廓检测(零基础)的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
2022-05-05
python无限生成不重复(字母,数字,字符)组合的方法
今天小编就为大家分享一篇python无限生成不重复(字母,数字,字符)组合的方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2018-12-12
Python Pygame实战之超级炸弹人游戏的实现
如今的玩家们在无聊的时候会玩些什么游戏呢？王者还是吃鸡是最多的选择。但在80、90年代的时候多是一些很简单的游戏：《超级玛丽》、《魂斗罗》等。本文将利用Pygame制作另一个经典游戏—炸弹人，感兴趣的可以了解一下
2022-03-03
Python 进程池ProcessPoolExecutor全面使用教程(推荐)
进程池（ProcessPoolExecutor）是Python中用于并行执行任务的强大工具,尤其适合CPU密集型操作,与传统的多进程编程相比,它提供了更简单、更高级的接口,本文通过实例代码介绍Python 进程池ProcessPoolExecutor全面使用,感兴趣的朋友一起看看吧
2025-09-09
python扩展库numpy入门教程
这篇文章主要为大家介绍了python扩展库numpy入门教程详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2021-11-11
8种用Python实现线性回归的方法对比详解
这篇文章主要介绍了8种用Python实现线性回归的方法对比详解，说到如何用Python执行线性回归，大部分人会立刻想到用sklearn的linear_model，但事实是，Python至少有8种执行线性回归的方法，sklearn并不是最高效的,需要的朋友可以参考下
2019-07-07
使用Python获取JS加载的数据的多种实现方法
在当今的互联网时代,网页数据的动态加载已经成为一种常见的技术手段,许多现代网站通过JavaScript（JS）动态加载内容,这使得传统的静态网页爬取方法难以奏效,所以本文将详细介绍如何使用Python来爬取JavaScript加载的数据,需要的朋友可以参考下
2025-05-05
Python工具脚本调用外层模块的操作方法
今天有同学问我,这种情况应该怎么调用,才能让remove_outdated_data.py正确导入models里面的模块,下面通过本文介绍下Python工具脚本调用外层模块的方法,感兴趣的朋友一起看看吧
2024-02-02
Python readline()和readlines()函数实现按行读取文件
本文主要介绍了Python readline()和readlines()函数实现按行读取文件，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2023-02-02
Python求出0~100以内的所有素数
质数又称素数。一个大于1的自然数，除了1和它自身外，不能被其他自然数整除的数叫做质数；否则称为合数。下面小编给大家带来了Python求出0~100以内的所有素数实例代码，需要的朋友参考下
2018-01-01