为什么用户的响应没有记录在数据库中？

Question

大家下午好。

我有一个电报机器人，我希望该机器人注册用户并将他们的答案输入数据库。但问题是它注册了用户 ID，但没有用其他用户响应（姓名、电子邮件、phone）更新数据库中的记录。

顺便说一下，我使用 aiogram 库来创建电报机器人。

这是主要鳕鱼：

class FSMRegistration (StatesGroup):
    cl_name= State()
    cl_phone=State()
    cl_email=State()
db = THEPARALLEL_DB('35thparallelClientBase.db')
@dp.callback_query_handler(text='reg')
@dp.callback_query_handler(text='cansel_1')
async def registration(query: types.CallbackQuery):
    answ_data = query.data
    if answ_data == 'reg':
        if (not db.client_exists(query.from_user.id)):
            await bot.send_message(query.from_user.id, text=f'Lest do it! Write: next')
@dp.message_handler(Text(equals='next', ignore_case=True), state=None)
async def reg_start(message: types.Message):
    await FSMRegistration.cl_name.set()
    await message.reply('Write your First and Last name')
    if (len(message.text) > 20):
        await message.reply(
            ('The first and last name must not exceed more than 20 characters'))
    elif '@' in message.text or '/' in message.text or '?' in message.text or '#' in message.text or '$' in message.text or '%' in message.text:
        await message.reply(message.from_user.id, "You have entered a forbidden symbol.")
    else:
        db.add_client(message.from_user.id)
        pass

@dp.message_handler(state="*", commands='cansel')
@dp.message_handler(Text(equals='отмена', ignore_case=True), state="*")
async def cansel_handler(message: types.Message, state: FSMContext, current_state=None):
    current_state * await state.get_state()
    if current_state is None:
        return
    await state.finish()
    await message.reply('Ok!')
@dp.message_handler(state=FSMRegistration.cl_name)
async def set_cl_name(message: types.Message, state:FSMContext):
    async with state.proxy() as data:
        db.set_client_name(message.from_user.id, message.text)
        data['cl_name']=message.text
        await FSMRegistration.next()
        await message.reply("Great! Please write your phone:")

@dp.message_handler(state=FSMRegistration.cl_phone)
async def set_cl_phone(message: types.Message, state: FSMContext):
    async with state.proxy() as data:
        if (len(message.text) > 12):
            await message.reply(('There are too many symbols in your message'))
        elif int(message.text):
            data['cl_phone'] = message.text
            db.set_client_phone(message.from_user.id, message.text)
            await FSMRegistration.next()
            await message.reply("Great, one more step behind! Your email:")

@dp.message_handler(state=FSMRegistration.cl_email)
async def set_cl_email(message: types.Message, state: FSMContext):
    async with state.proxy() as data:
        if '@' not in message.text and '.' not in message.text:
            await message.reply(
            ('Error! You have lost this symbol (@)'))
        else:
            data['cl_email'] = message.text
            db.set_client_email(message.from_user.id, message.text)
            await message.reply("Succses, Thank You!")

            await state.finish()

我将 sqllite3 用于数据库：

class THEPARALLEL_DB():
def __init__(self, database_file):
    self.connection = sqlite3.connect(database_file)
    self.cursor=self.connection.cursor()

def client_exists(self, user_id):
    with self.connection:
        result = self.cursor.execute("SELECT * FROM 'clients' WHERE 'user_id' = ?", (user_id,)).fetchall()
        return bool(len(result))

def get_user_id (self, user_id):
    result = self.cursor.execute("SELECT 'id' FROM 'clients' WHERE 'user_id'= ?", (user_id,))
    return result.fetchall()[0]

def add_client(self, user_id):
    with self.connection:
        return self.cursor.execute("INSERT INTO 'clients' ('user_id') VALUES (?)", (user_id,))

def set_client_name(self, user_id, client_name):
    with self.connection:
        return self.cursor.execute("UPDATE 'clients' SET 'client_name' = ? WHERE 'user_id' = ?",
                                   (client_name, user_id,))

def set_client_phone(self, user_id, cl_phone):
    with self.connection:
        return self.cursor.execute("UPDATE 'clients' SET 'Phone' = ?  WHERE 'user_id' = ?", (user_id, cl_phone,))

def set_client_email(self, user_id, cl_email):
    with self.connection:
        return self.cursor.execute("UPDATE 'clients' SET 'Email' = ? WHERE 'user_id' = ?", (user_id, cl_email,))

Answer 1

您在上下文管理器中使用了错误的光标。正确的是：

with self.connection:
    self.connection.execute("INSERT INTO 'clients' ('user_id') VALUES (?)", (user_id,))

您还可以在查询上打开一个新游标：

with contextlib.closing(self.connection.cursor()) as cursor:
    cursor.execute(...)

为什么用户的响应没有记录在数据库中？

Why is the response from the user not recorded in the database?

python

sqlite

telegram

telegram-bot

aiogram