У меня есть телеграм бот написанный через aiogram. Есть класс, которые отвечает за подключение к базе данных SQLite и имеет в себе методы для чтения/записи данных (около 15 методов).
class DatabaseBot:
def __init__(self, db_file):
"""Подключение к БД SQLite"""
try:
self.connection = sqlite3.connect(db_file)
self.cursor = self.connection.cursor()
except Exception as e:
logging.error('Ошибка подключения к БД:' + str(e))
def check_user(self, telegram_id: int):
"""Проверка наличия пользователя в БД"""
user_exist = self.cursor.execute("SELECT telegram_id FROM users WHERE telegram_id = ?", (telegram_id,))
return bool(len(user_exist.fetchall()))
def add_user(self, telegram_id: int):
"""Добавление пользователя в БД в таблицу users"""
self.cursor.execute("INSERT into users ('telegram_id') VALUES (?)", (telegram_id,))
return self.connection.commit()
def get_number_of_requests(self, telegram_id: int):
"""Вывод количества запросов пользователя, которые он может отправить боту"""
num_of_requests = self.cursor.execute("SELECT num_requests FROM users WHERE telegram_id = ?", (telegram_id,))
return num_of_requests.fetchone()[0]
и т.д.
Однако, столкнулся с необходимостью переписать код под асинхронный формат с использованием aiosqlite, т.к. в асинхронном боте использовать блокирующие функции не имеет смысла. Прошу подсказать, как будет правильнее написать асинхронный код с использованием класса для работы с базой данных sqlite. И можно ли в данном случае использовать def __init__
? Я читал что есть какие-то обходные пути с использованием def __init__
, но я их не до конца понимаю.
Так же хотелось бы избежать вот такого варианта:
async def user_exists(user_id):
"""Есть ли такой пользователь (по id)"""
async with aiosqlite.connect("db/filedb.db") as db:
async with db.execute("SELECT EXISTS(SELECT 1 "
"FROM users "
"WHERE user_id = ?)", (user_id,)) as cursor:
result1 = await cursor.fetchone()
result = bool(result1[0])
return result
Потому что, как мне кажется, если у нас в классе 15 таких методов и для каждого метода делать отдельное подключение будет не целесообразным. Поправьте меня, если я ошибаюсь, буду рад любым идеям!