psycopg2中连接池pool的使用

原创
2017/03/13 11:40
阅读数 1.6K

在百度上搜了并没有这东西,自己看着文档摸索了半天终于略知一二了,官网文档http://initd.org/psycopg/docs/pool.html。

下面是可以跨线程的连接池使用

import psycopg2

from psycopg2.pool import ThreadedConnectionPool

pool = ThreadedConnectionPool(5,100,"dbname=你的数据库名 user=用户名 password=密码 host=主机名 port=端口号") #创建连接池连接

conn= pool.getconn(key) #key可以为空

cursor=conn.cursor()

sql_str=""

cursor.execute(sql_str)

 

关闭连接也很简单

pool.putconn(conn, key=None, close=False)# 这里close设置为true则会从连接池中关闭conn对象的连接

pool.closeall()会关闭连接池内所有的连接

 

展开阅读全文
打赏
0
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部