import sqlite3 from aiogram import Bot, Dispatcher, executor conn = sqlite3.connect("db.db") c = conn.cursor() c.execute('''CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY AUTOINCREMENT, user_id INTEGER)''') conn.commit() conn.close() class SQLither: def __init__(self, database): self.conn = sqlite3.connect(database) self.c = self.conn.cursor() def exists_user(self, user_id): """Проверка существования пользователя в БД""" return bool(self.c.execute("SELECT * FROM users WHERE user_id=?", (user_id,)).fetchone()) def add_to_db(self, user_id): """Добавление пользователя в БД""" self.c.execute("INSERT INTO users ('user_id') VALUES(?)", (user_id,)) self.conn.commit() bot = Bot(token="") dp = Dispatcher(bot) db = SQLither("db.db") @dp.message_handler(content_types=["text"]) async def message_handler(message): user_id = message.chat.id if not db.exists_user(user_id): db.add_to_db(user_id) if __name__ == "__main__": executor.start_polling(dp, skip_updates=True) Python import sqlite3 from aiogram import Bot, Dispatcher, executor conn = sqlite3.connect("db.db") c = conn.cursor() c.execute('''CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY AUTOINCREMENT, user_id INTEGER)''') conn.commit() conn.close() class SQLither: def __init__(self, database): self.conn = sqlite3.connect(database) self.c = self.conn.cursor() def exists_user(self, user_id): """Проверка существования пользователя в БД""" return bool(self.c.execute("SELECT * FROM users WHERE user_id=?", (user_id,)).fetchone()) def add_to_db(self, user_id): """Добавление пользователя в БД""" self.c.execute("INSERT INTO users ('user_id') VALUES(?)", (user_id,)) self.conn.commit() bot = Bot(token="") dp = Dispatcher(bot) db = SQLither("db.db") @dp.message_handler(content_types=["text"]) async def message_handler(message): user_id = message.chat.id if not db.exists_user(user_id): db.add_to_db(user_id) if __name__ == "__main__": executor.start_polling(dp, skip_updates=True)