fix: modify database connection way

modify parallelDatabase as Database

Bug: 2042812
Change-Id: I33f282e69e7383a51c3e69b4c8e9273609fb988d
This commit is contained in:
iauhsnaiq 2023-11-10 09:55:01 +08:00
parent 1cedd57d6a
commit 99f557e19c

View File

@ -16,7 +16,7 @@ from __future__ import annotations
from contextvars import ContextVar
from databases import Database, DatabaseURL, core
from databases import Database, DatabaseURL
from skyline_apiserver.config import CONF
@ -24,16 +24,11 @@ DATABASE = None
DB: ContextVar = ContextVar("skyline_db")
class ParallelDatabase(Database):
def connection(self) -> core.Connection:
return core.Connection(self._backend)
async def setup():
db_url = DatabaseURL(CONF.default.database_url)
global DATABASE
if db_url.scheme == "mysql":
DATABASE = ParallelDatabase(
DATABASE = Database(
db_url,
minsize=1,
maxsize=100,
@ -42,7 +37,7 @@ async def setup():
client_flag=0,
)
elif db_url.scheme == "sqlite":
DATABASE = ParallelDatabase(db_url)
DATABASE = Database(db_url)
else:
raise ValueError("Unsupported database backend")
await DATABASE.connect()