feat: DB切断部分を修正
This commit is contained in:
parent
83152fd1ec
commit
5d5ef88339
@ -114,14 +114,6 @@ class DatabaseClient:
|
||||
raise DBException('DBに接続していません')
|
||||
return self.__session
|
||||
|
||||
def connect(self):
|
||||
# FIXME: 未使用。後ほど削除
|
||||
...
|
||||
|
||||
def disconnect(self):
|
||||
# FIXME: エラーにしないための仮実装。後で消す
|
||||
...
|
||||
|
||||
def execute_select(self, select_query: str, parameters=None) -> list[dict]:
|
||||
"""SELECTクエリを実行します。
|
||||
|
||||
@ -190,11 +182,10 @@ class DatabaseClient:
|
||||
if self.session.in_transaction():
|
||||
self.session.rollback()
|
||||
|
||||
# def disconnect(self):
|
||||
# """DB接続を切断します。"""
|
||||
# if self.session is not None:
|
||||
# self.session.close()
|
||||
# self.__session = None
|
||||
def disconnect(self):
|
||||
"""DB接続を切断します。"""
|
||||
self.session.close()
|
||||
self.__session = None
|
||||
|
||||
def to_jst(self):
|
||||
self.execute('SET time_zone = "+9:00"')
|
||||
|
||||
@ -11,5 +11,3 @@ def get_database(request: Request) -> DatabaseClient:
|
||||
yield database
|
||||
finally:
|
||||
database.disconnect()
|
||||
# FIXME; リポジトリを直し終えたら消す
|
||||
session.close()
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user