Pool DB package
Project description
PoolDB
python数据库连接池管理,支持并发获取sql数据,自动管理数据库连接,支持with语句,支持sql字典访问形式获取数据等
- 原生sql获取数据
db_url = 'postgresql+psycopg2://postgres:pgpasswd@172.16.1.64:5433/dw_jinan?utf-8'
pool = PoolDB(db_url=db_url)
conn = pool.connect()
result = conn.execute("select * from manage.substation limit 5")
while 1:
try:
r = next(result)
print(r)
print(r.pid)
except:
break
pool.close(conn)
- 并发获取数据库数据
db_url = 'postgresql+psycopg2://postgres:pgpasswd@172.16.1.64:5433/dw_jinan?utf-8'
pool = PoolDB(db_url=db_url)
gv = pool.multi_data(sql=sqls) # 多条数据并发获取,
for v in gv:
print(v)
- 字典形式访问获取数据库数据, key为sql或sql列表
db_url = 'postgresql+psycopg2://postgres:pgpasswd@172.16.1.64:5433/dw_jinan?utf-8'
pool = PoolDB(db_url=db_url)
r = pool["select * from manage.substation limit 5"]
print(r)
sqls = ["select * from manage.substation limit 5", "select * from manage.substation limit 4"]
r_list = pool[sqls]
print(r_list)
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distributions
No source distribution files available for this release.See tutorial on generating distribution archives.
Built Distribution
PoolDB-0.0.1-py3-none-any.whl
(5.6 kB
view hashes)