Vasanko/sanic
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Merge pull request #527 from r0fls/asyncpg-example

Browse Source 
update asyncpg example
This commit is contained in:
Raphael Deem 2017-03-07 19:34:10 -08:00 committed by GitHub
commit b3b27cab34
1 changed files with 16 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
examples/sanic_asyncpg_example.py
View File

@ -5,14 +5,14 @@ import os
import asyncio
import uvloop
from asyncpg import create_pool
from asyncpg import connect
from sanic import Sanic
from sanic.response import json
DB_CONFIG = {
'host': '<host>',
'user': '<username>',
'user': '<user>',
'password': '<password>',
'port': '<port>',
'database': '<database>'
@ -22,8 +22,7 @@ def jsonify(records):
"""
Parse asyncpg record response into JSON format
"""
return [{key: value for key, value in
zip(r.keys(), r.values())} for r in records]
return [dict(r.items()) for r in records]
app = Sanic(__name__)
@ -32,27 +31,23 @@ async def create_db(app, loop):
"""
Create some table and add some data
"""
async with create_pool(**DB_CONFIG) as pool:
async with pool.acquire() as connection:
async with connection.transaction():
await connection.execute('DROP TABLE IF EXISTS sanic_post')
await connection.execute("""CREATE TABLE sanic_post (
id serial primary key,
content varchar(50),
post_date timestamp
);""")
for i in range(0, 100):
await connection.execute(f"""INSERT INTO sanic_post
(id, content, post_date) VALUES ({i}, {i}, now())""")
conn = await connect(**DB_CONFIG)
await conn.execute('DROP TABLE IF EXISTS sanic_post')
await conn.execute("""CREATE TABLE sanic_post (
id serial primary key,
content varchar(50),
post_date timestamp);"""
)
for i in range(0, 100):
await conn.execute(f"""INSERT INTO sanic_post
(id, content, post_date) VALUES ({i}, {i}, now())""")
@app.route("/")
async def handler(request):
async with create_pool(**DB_CONFIG) as pool:
async with pool.acquire() as connection:
async with connection.transaction():
results = await connection.fetch('SELECT * FROM sanic_post')
return json({'posts': jsonify(results)})
conn = await connect(**DB_CONFIG)
results = await conn.fetch('SELECT * FROM sanic_post')
return json({'posts': jsonify(results)})
if __name__ == '__main__':