Python讀取postgresql數據庫詳情
一、讀取postgresql數據庫
(1)首先,我們需要安裝 psycopg 驅動。通過 pip 安裝最新的 psycopg
pip install psycopg2 -i https://pypi.tuna.tsinghua.edu.cn/simple

(2) 創(chuàng)建一個數據庫連接的配置文件 dbconfig.ini,添加以下內容:
[postgresql] host = [ip地址] port = 5432 database = xxx user = xxx password = xxx
配置文件中存儲了數據庫的連接信息:主機、端口、數據庫、用戶以及密碼;我們需要按照自己的環(huán)境進行配置。
(3)然后,新建一個測試數據庫連接的 Python 文件 postgresql_connection.py,
文件目錄結構為:

postgresql_connection.py的完整代碼為:
# 導入 psycopg2 模塊和 Error 對象
import psycopg2
from psycopg2 import DatabaseError
from configparser import ConfigParser
def read_db_config(filename='dbconfig.ini', section='postgresql'):
""" 讀取數據庫配置文件,返回一個字典對象"""
# 創(chuàng)建解析器,讀取配置文件
parser = ConfigParser()
parser.read(filename)
# 獲取 postgresql 部分的配置
db = {}
if parser.has_section(section):
items = parser.items(section)
for item in items:
db[item[0]] = item[1]
else:
raise Exception('文件 {1} 中未找到 {0} 配置信息!'.format(section, filename))
return db
if __name__ == '__main__':
db_config = read_db_config()
connection = None
try:
# 使用 psycopg2.connect 方法連接 PostgreSQL 數據庫
connection = psycopg2.connect(**db_config)
cur = connection.cursor() # 創(chuàng)建一個游標
cur.execute('SELECT version()') # 獲取 PostgreSQL 版本號
db_version = cur.fetchone()
print("連接成功,PostgreSQL 服務器版本:", db_version) # 輸出 PostgreSQL 版本
# `在這里插入代碼片`
cur.close() # 關閉游標
except (Exception, DatabaseError) as e:
print("連接 PostgreSQL 失?。?, e)
finally:
if connection is not None: # 釋放數據庫連接
connection.close()
print("PostgreSQL 數據庫連接已關閉。")(4)運行程序,
- 首先,我們導入了 psycopg2 驅動和解析配置文件的 configparser 模塊;
- 然后,創(chuàng)建一個讀取配置文件的 read_db_config 函數;
- 接下來調用 psycopg2.connect 函數創(chuàng)建一個新的數據庫連接;
- 然后通過連接對象的 cursor 函數創(chuàng)建一個新的游標,并且執(zhí)行查詢語句返回數據庫的版本;
- 在此之后,調用游標對象的 fetchone() 方法獲取返回結果并打印信息;
- 最后,調用 close() 方法關閉游標資源和數據庫連接對象。
執(zhí)行以上腳本,返回的信息如下:
連接成功,PostgreSQL 服務器版本: ('PostgreSQL 12.3 on x86_64-pc-linux-gnu, compiled by gcc (GCC) 4.8.5 20150623 (Red Hat 4.8.5-39), 64-bit',)
PostgreSQL 數據庫連接已關閉。

二、查詢數據
游標對象提供了三種獲取返回結果的方法:fetchone() 獲取下一行數據,fetchmany(size=cursor.arraysize) 獲取下一組數據行,fetchall() 返回全部數據行。
(1)我們創(chuàng)建一個新的文件 postgresql_query.py:
# 導入 psycopg2 模塊和 Error 對象
import psycopg2
from psycopg2 import DatabaseError
from configparser import ConfigParser
def read_db_config(filename='dbconfig.ini', section='postgresql'):
""" 讀取數據庫配置文件,返回一個字典對象
"""
# 創(chuàng)建解析器,讀取配置文件
parser = ConfigParser()
parser.read(filename)
# 獲取 postgresql 部分的配置
db = {}
if parser.has_section(section):
items = parser.items(section)
for item in items:
db[item[0]] = item[1]
else:
raise Exception('文件 {1} 中未找到 {0} 配置信息!'.format(section, filename))
return db
if __name__ == '__main__':
db_config = read_db_config()
connection = None
try:
connection = psycopg2.connect(**db_config) # 使用 psycopg2.connect 方法連接 PostgreSQL 數據庫
cur = connection.cursor() # 創(chuàng)建一個游標
# 定義 SQL 語句
sql = """ select id, name, age from users"""
cur.execute(sql) # 執(zhí)行 SQL 命令
print("用戶數量:", cur.rowcount)
# 獲取結果
user = cur.fetchone()
while user is not None:
print(user)
user = cur.fetchone()
cur.close() # 關閉游標
except (Exception, DatabaseError) as e:
print("操作失?。?, e)
finally:
if connection is not None: # 釋放數據庫連接
connection.close()(2)游標對象的 rowcount 屬性代表了返回的數據行數,fetchone() 方法返回一行數據或者 None,while 循環(huán)用于遍歷和打印查詢結果。由于 users 表中目前只有一行數據,
執(zhí)行以上文件的結果如下:
用戶數量: 2 (1, 'lane', False) (2, 'lane_dynamic', False)

到此這篇關于Python讀取postgresql數據庫詳情的文章就介紹到這了,更多相關Python讀取postgresql內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
mac下給python3安裝requests庫和scrapy庫的實例
今天小編就為大家分享一篇mac下給python3安裝requests庫和scrapy庫的實例,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2018-06-06
使用Python的Twisted框架實現(xiàn)一個簡單的服務器
這篇文章主要介紹了使用Python的Twisted框架實現(xiàn)一個簡單的服務器,翻譯自Twisted的文檔,需要的朋友可以參考下2015-04-04
Python實現(xiàn)微信自動回復信息的功能(根據不同信息回復對應的信息)
這篇文章主要介紹了Python實現(xiàn)微信自動回復信息的功能(根據不同信息回復對應的信息),我們使用的第三方包是UIAutomation,結合示例代碼給大家介紹的非常詳細,需要的朋友可以參考下2023-09-09
Python flask框架實現(xiàn)瀏覽器點擊自定義跳轉頁面
這篇文章主要介紹了Python flask框架實現(xiàn)瀏覽器點擊自定義跳轉頁面,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-06-06

