当前位置： 首页 > news >正文

使用python进行PostgreSQL 数据库连接

news 2025/11/17 5:59:25

使用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 ConfigParserdef config(filename='../../resource/database.ini', section='postgresql'):# create a parserparser = ConfigParser()# read config fileparser.read(filename)# get section, default to postgresqldb = {}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 psycopg2from demo.pgdemo.config import configdef connect():""" Connect to the PostgreSQL database server """conn = Nonetry:# read connection parametersparams = config()# connect to the PostgreSQL serverprint('Connecting to the PostgreSQL database...')conn = psycopg2.connect(**params)# create a cursorcur = conn.cursor()# execute a statementprint('PostgreSQL database version:')cur.execute('SELECT version()')# display the PostgreSQL database server versiondb_version = cur.fetchone()print(db_version)# close the communication with the PostgreSQLcur.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=# dList of relationsSchema |  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
http://www.dtcms.com/a/617589.html

相关文章：

  • 天线类型和指标介绍
  • Netty编写Echo服务器
  • 沙雕图片视频制作软件。制图内都是搞笔图制作模板，表白墙，节日祝福制作
  • 开源项目分享 图像深度学习Demo项目
  • 性能优化方向
  • 2.socket套接字
  • 旧网站如何优化设计制作实践活动有哪些
  • HTML 实例详解
  • 【监控】Spring Boot+Prometheus+Grafana实现可视化监控
  • 【深度学习新浪潮】大模型在图像质量评价方面的研发进展一览
  • **MATLAB R2025a** 环境下，基于 **双向时间卷积网络（BITCN）+ 双向长短期记忆网络（BiLSTM）** 的多特征分类预测完整实现
  • 在21世纪的我用C语言探寻世界本质——字符函数和字符串函数(2)
  • 《基于机器学习的脑电认知负荷识别研究与应用》论文笔记
  • 数据结构：双向链表（2）
  • Java EE - 常见的死锁和解决方法
  • transformer 教程(一) qkv矩阵介绍以及为什么除以根号d推导
  • 网络网站开发江苏电信网站备案
  • 树莓派 5 上 Ubuntu 24.04 LTS 自带 RDP 远程桌面重启密码就变
  • 算法---贪心算法（Greedy Algorithm）
  • TDengine 字符串函数 REGEXP_IN_SET 用户手册
  • 佛山市外贸网站建设公司因网站开发需要
  • 神经网络组植物分类学习规划与本周进展综述15
  • 做律师事务所网站牡丹江住房和城乡建设厅网站
  • 上海崇明林业建设有限公司 网站建设 市民中心网站
  • 在UEC++中使用什么方式返回像 FTransform 这种类型的值
  • GPT‑OSS‑20B MoE 在昇腾 NPU 上的部署与性能实测：开发者视角的多精度推理优化实践
  • 后端服务弹性伸缩实践实践：让系统更高效、稳定
  • 网站的比较做网站哪家便宜
  • 寻找昆明网站建设手机网站 跳转
  • 建站网址大全56做视频网站