pg8000线程池创建代码
时间: 2024-03-20 20:38:05 浏览: 13
pg8000是一个Python的PostgreSQL数据库驱动程序,它提供了与PostgreSQL数据库的交互功能。下面是使用pg8000创建线程池的代码示例:
```python
import pg8000
from pg8000.pool import ThreadedConnectionPool
# 创建数据库连接池
pool = ThreadedConnectionPool(
minconn=1, # 最小连接数
maxconn=10, # 最大连接数
host='localhost', # 数据库主机地址
port=5432, # 数据库端口号
user='username', # 数据库用户名
password='password', # 数据库密码
database='database_name' # 数据库名称
)
# 从连接池获取数据库连接
conn = pool.getconn()
# 执行SQL查询
cursor = conn.cursor()
cursor.execute("SELECT * FROM table_name")
result = cursor.fetchall()
# 处理查询结果
for row in result:
print(row)
# 将连接放回连接池
pool.putconn(conn)
```
以上代码中,我们首先导入了`pg8000`和`ThreadedConnectionPool`类。然后,通过创建`ThreadedConnectionPool`对象来设置连接池的参数,包括最小连接数、最大连接数、数据库主机地址、端口号、用户名、密码和数据库名称。
接下来,我们可以使用`pool.getconn()`方法从连接池中获取一个数据库连接对象。然后,我们可以使用该连接对象创建游标,并执行SQL查询。最后,我们将连接对象放回连接池,以便其他线程可以重复使用。