65 lines
1.6 KiB
Python
Executable File
65 lines
1.6 KiB
Python
Executable File
import asyncio
|
|
|
|
from sqlor.dbpools import DBPools
|
|
|
|
dbs={
|
|
"tasks":{
|
|
"driver":"aiomysql",
|
|
"async_mode":True,
|
|
"coding":"utf8",
|
|
"dbname":"tasks",
|
|
"kwargs":{
|
|
"user":"test",
|
|
"db":"tasks",
|
|
"password":"test123",
|
|
"host":"localhost"
|
|
}
|
|
},
|
|
"aiocfae":{
|
|
"driver":"aiomysql",
|
|
"async_mode":True,
|
|
"coding":"utf8",
|
|
"dbname":"cfae",
|
|
"kwargs":{
|
|
"user":"test",
|
|
"db":"cfae",
|
|
"password":"test123",
|
|
"host":"localhost"
|
|
}
|
|
},
|
|
"cfae":{
|
|
"driver":"mysql.connector",
|
|
"coding":"utf8",
|
|
"dbname":"cfae",
|
|
"kwargs":{
|
|
"user":"test",
|
|
"db":"cfae",
|
|
"password":"test123",
|
|
"host":"localhost"
|
|
}
|
|
}
|
|
}
|
|
|
|
loop = asyncio.get_event_loop()
|
|
pool = DBPools(dbs,loop=loop)
|
|
|
|
async def testfunc():
|
|
@pool.runSQL
|
|
def sql(db,ns,callback):
|
|
return {
|
|
"sql_string":"select * from product",
|
|
}
|
|
x = await sql('cfae',{},print)
|
|
|
|
async def testfunc1():
|
|
@pool.runSQL
|
|
def sql(db,ns,callback):
|
|
return {
|
|
"sql_string":"select * from timeobjects",
|
|
}
|
|
print('testfunc1(),test tasks database select')
|
|
x = await sql('tasks',{},print)
|
|
|
|
loop.run_until_complete(testfunc())
|
|
loop.run_until_complete(testfunc1())
|