python3連接postgresql


利用連接池連接postgresql,這里要注意的是,如果fetchall報錯的話有可能是字符編碼,需要設置字符編碼如下:

import psycopg2.pool
from time import time

t = time()
n = 10000
simple_conn_pool = psycopg2.pool.SimpleConnectionPool(5, 200, host=HOST,user=USERNAME, password=PASSWORD, dbname=DB,port=PORT)
conn = simple_conn_pool.getconn()
conn.set_client_encoding('utf-8')
cur = conn.cursor()
cur.execute(SQL)
res = cur.fetchall()
print(res)
print(time() - t)
simple_conn_pool.closeall()

直連

import psycopg2
from time import time

t = time()
n = 10000
conn = psycopg2.connect(dbname=DB, user=USERNAME, password=PASSWORD, host=HOST,port=PORT)
conn.set_client_encoding('utf-8')
cur = conn.cursor()
cur.execute(SQL)
for i in cur:
    print(i)
print(time() - t)

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM