@dp.message_handler(text='Пн')
async def send_text(message: types.Message):
connect = sqlite3.connect('main.db')
cursor = connect.cursor()
cursor.execute('SELECT grup FROM Users')
row = cursor.fetchall()
for i in row:
for j in i:
if j == '1':
await message.answer('текст1')
elif j == '2':
await message.answer('текст2')
connect.close()
cursor.execute('SELECT grup FROM Users WHERE user_id = ?', (message.from_user.id, ))
row = cursor.fetchone()
if row:
grup = row[0]
# в grup будет значение поля из таблицы по данному пользователю
else:
# пользователь не найден в базе