利用python进行PostgreSQL 数据库连接

卖不甜枣  论坛元老 | 2025-3-13 04:19:13 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 1635|帖子 1635|积分 4905

利用python进行PostgreSQL 数据库连接

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

Psycopy是针对python的Postgres 数据库的适配模块，安装psycopg2可以整合python和Postgres 。利用cmd输入下令进行安装：
  1. 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.
  1. import psycopg2
  3. con = psycopg2.connect(database="postgres",
  4.                        user="fbase",
  5.                        password="123456",
  6.                        host="192.168.198.152",
  7.                        port="8432")
  8. print(con)
  9. print("Database opened successfully")
  10. cur = con.cursor()
  11. cur.execute('SELECT version()')
  12. db_version = cur.fetchone()
  13. print(db_version)
  14. con.close()
复制代码
运行结果如下：

3.2 利用设置文件

可以利用设置文件来存储所有连接参数。
database.ini文件的内容如下：
  1. [postgresql]
  2. host = 192.168.198.152
  3. database = postgres
  4. user = fbase
  5. password = 123456
  6. port = 8432
复制代码
下面的config()函数会读取database.ini文件并返回连接参数。该config()函数放置在config.py文件中：
  1. from configparser import ConfigParser
  4. def config(filename='../../resource/database.ini', section='postgresql'):
  5.     # create a parser
  6.     parser = ConfigParser()
  7.     # read config file
  8.     parser.read(filename)
  10.     # get section, default to postgresql
  11.     db = {}
  12.     if parser.has_section(section):
  13.         params = parser.items(section)
  14.         for param in params:
  15.             db[param[0]] = param[1]
  16.     else:
  17.         raise Exception('Section {0} not found in the {1} file'.format(section, filename))
  19.     return db
复制代码
下面的connect()函数连接到suppliers数据库并打印出 PostgreSQL 数据库版本。
  1. import psycopg2
  3. from demo.pgdemo.config import config
  6. def connect():
  7.     """ Connect to the PostgreSQL database server """
  8.     conn = None
  9.     try:
  10.         # read connection parameters
  11.         params = config()
  13.         # connect to the PostgreSQL server
  14.         print('Connecting to the PostgreSQL database...')
  15.         conn = psycopg2.connect(**params)
  17.         # create a cursor
  18.         cur = conn.cursor()
  20.         # execute a statement
  21.         print('PostgreSQL database version:')
  22.         cur.execute('SELECT version()')
  24.         # display the PostgreSQL database server version
  25.         db_version = cur.fetchone()
  26.         print(db_version)
  28.         # close the communication with the PostgreSQL
  29.         cur.close()
  30.     except (Exception, psycopg2.DatabaseError) as error:
  31.         print(error)
  32.     finally:
  33.         if conn is not None:
  34.             conn.close()
  35.             print('Database connection closed.')
  38. if __name__ == '__main__':
  39.     connect()
复制代码
怎么运行的。


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

4.1 创建表

利用SQL(Structured Query Language)语句CREATE TABLE添加新的表:
  1. import psycopg2
  3. # 建立数据库连接
  4. con = psycopg2.connect(database="postgres",
  5.                        user="fbase",
  6.                        password="123456",
  7.                        host="192.168.198.152",
  8.                        port="8432")
  9. print("Database opened successfully")
  10. # 调用游标对象
  11. cur = con.cursor()
  12. # 用cursor中的execute 使用DDL语句创建一个名为 STUDENT 的表,指定表的字段以及字段类型
  13. cur.execute('''
  14.        CREATE TABLE IF NOT EXISTS STUDENT
  15.       (ADMISSION INT PRIMARY KEY     NOT NULL,
  16.       NAME           TEXT            NOT NULL,
  17.       AGE            INT             NOT NULL,
  18.       COURSE        CHAR(50),
  19.       DEPARTMENT        CHAR(50));''')
  21. # 提交更改，增添或者修改数据只会必须要提交才能生效
  22. con.commit()
  23. con.close()
复制代码
结果查看：
  1. postgres=# \d
  2.         List of relations
  3. Schema |  Name   | Type  | Owner
  4. --------+---------+-------+-------
  5. public | student | table | fbase
  6. (1 row)
复制代码
4.2 表插入数据

利用INSERT INTO 在以经生成的表中插入数据
  1. import psycopg2
  3. # 建立数据库连接
  4. con = psycopg2.connect(database="postgres",
  5.                        user="fbase",
  6.                        password="123456",
  7.                        host="192.168.198.152",
  8.                        port="8432")
  9. print("Database opened successfully")
  10. # 调用游标对象
  11. cur = con.cursor()
  12. # 在表中插入一条数据
  13. cur.execute("INSERT INTO STUDENT (ADMISSION,NAME,AGE,COURSE,DEPARTMENT) "
  14.             "VALUES (3420, 'John', 18, 'Computer Science', 'ICT')")
  16. # 提交更改，增添或者修改数据只会必须要提交才能生效
  17. con.commit()
  18. con.close()
复制代码
结果查看：
  1. postgres=# select * from student ;
  2. admission | name | age |                       course                       |                     department                     
  3. -----------+------+-----+----------------------------------------------------+----------------------------------------------------
  4.       3420 | John |  18 | Computer Science                                   | ICT                                               
  5. (1 row)
复制代码
4.3 表更新数据

同样利用SQL语句更新目的字段，利用commit()更新数据库
  1. import psycopg2
  3. # 建立数据库连接
  4. con = psycopg2.connect(database="postgres",
  5.                        user="fbase",
  6.                        password="123456",
  7.                        host="192.168.198.152",
  8.                        port="8432")
  9. print("Database opened successfully")
  10. # 调用游标对象
  11. cur = con.cursor()
  12. # 更新表中的数据
  13. cur.execute("UPDATE student set name = 'joe' WHERE admission = 3420")
  15. # 提交更改，增添或者修改数据只会必须要提交才能生效
  16. con.commit()
  17. con.close()
复制代码
结果查看：
  1. postgres=# select * from student ;
  2. admission | name | age |                       course                       |                     department                     
  3. -----------+------+-----+----------------------------------------------------+----------------------------------------------------
  4.       3420 | John |  18 | Computer Science                                   | ICT                                               
  5. (1 row)
  6. postgres=# select * from student ; admission | name | age |                       course                       |                     department                     -----------+------+-----+----------------------------------------------------+----------------------------------------------------      3420 | joe  |  18 | Computer Science                                   | ICT                                        (1 row)
复制代码
4.4 表删除数据

同样利用SQL语句更新目的字段，利用commit()更新数据库
  1. import psycopg2
  3. # 建立数据库连接
  4. con = psycopg2.connect(database="postgres",
  5.                        user="fbase",
  6.                        password="123456",
  7.                        host="192.168.198.152",
  8.                        port="8432")
  9. print("Database opened successfully")
  10. # 调用游标对象
  11. cur = con.cursor()
  12. # 删除表中的数据
  13. cur.execute("DELETE FROM student WHERE admission = 3420")
  15. # 提交更改，增添或者修改数据只会必须要提交才能生效
  16. con.commit()
  17. con.close()
复制代码
结果查看：
  1. postgres=# select * from student ;
  2. admission | name | age |                       course                       |                     department                     
  3. -----------+------+-----+----------------------------------------------------+----------------------------------------------------
  4.       3420 | joe  |  18 | Computer Science                                   | ICT                                               
  5. (1 row)
  7. postgres=# select * from student ;
  8. admission | name | age | course | department
  9. -----------+------+-----+--------+------------
  10. (0 rows)
复制代码
5. DQL语句测试

5.1 查看表中的数据

同样利用SQL语句更新目的字段，利用commit()更新数据库
  1. import psycopg2
  3. # 建立数据库连接
  4. con = psycopg2.connect(database="postgres",
  5.                        user="fbase",
  6.                        password="123456",
  7.                        host="192.168.198.152",
  8.                        port="8432")
  9. print("Database opened successfully")
  10. # 调用游标对象
  11. cur = con.cursor()
  12. # 删除表中的数据
  13. cur.execute("SELECT * FROM student")
  15. rows = cur.fetchall()
  16. for row in rows:
  17.     print("ADMISSION =", row[0])
  18.     print("NAME =", row[1])
  19.     print("AGE =", row[2])
  20.     print("COURSE =", row[3])
  21.     print("DEPARTMENT =", row[4], "\n")
  23. # 提交更改，增添或者修改数据只会必须要提交才能生效
  24. con.commit()
  25. con.close()
复制代码
结果查看：
  1. D:\python3\python.exe D:/project/python/demo/demo/pgdemo/dql_select_1.py
  2. Database opened successfully
  3. ADMISSION = 3420
  4. NAME = John
  5. AGE = 18
  6. COURSE = Computer Science                                 
  7. DEPARTMENT = ICT
  8. w[3])
  9.     print("DEPARTMENT =", row[4], "\n")
  11. # 提交更改，增添或者修改数据只会必须要提交才能生效
  12. con.commit()
  13. con.close()
复制代码
结果查看：
  1. D:\python3\python.exe D:/project/python/demo/demo/pgdemo/dql_select_1.py
  2. Database opened successfully
  3. ADMISSION = 3420
  4. NAME = John
  5. AGE = 18
  6. COURSE = Computer Science                                 
  7. DEPARTMENT = ICT
复制代码
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

卖不甜枣

论坛元老
这个人很懒什么都没写!

楼主热帖

标签云

AI 运维 CIO 存储 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表