Sqlite3 Как проверить существование записи?

Question

[Swek09]

Когда перезапускаешь бота с команды старт то бот вылетает,
библиотека бота(pyTelegramBotAPI)

import sqlite3
import telebot
from telebot import types


token='Токен'
bot=telebot.TeleBot(token)
conn = sqlite3.connect('db/Database.db', check_same_thread=False)
cursor = conn.cursor()




def db_table_val(User_id: int, User_name: str, User_surname: str, Username: str):
	cursor.execute('INSERT INTO Users (User_id, User_name, User_surname, Username) VALUES (?, ?, ?, ?)', (User_id, User_name, User_surname, Username))
	conn.commit()


@bot.message_handler(commands=['start'])
def button_message(message):
    us_id = message.from_user.id
    us_name = message.from_user.first_name
    us_sname = message.from_user.last_name
    username = message.from_user.username
    db_table_val(User_id=us_id, User_name=us_name, User_surname=us_sname, Username=username)
    bot.send_message(message.chat.id,'Привет',reply_markup=markup)
bot.infinity_polling(none_stop=True)

Вот так выглядит База данных:

Comments

[Алан Гибизов]

Вопрос про существование записи или про вылет бота? Если по вашему это связанные проблемы, то я из вопроса этого явно не улавливаю.
Рекомендую конкретизировать вопрос и дополнить - хотя бы traceback приведите, полный текст ошибки.

[Swek09]

Мне нужно сделать проверку на существование id в базе
Например:
Если получена команда /start то:
проверить существование данного пользователя в базе
если пользователя нет то:
Внести данные пользователя в базу данных
если пользователь существует в базе данных то:
Прислать ответ: вы уже есть в базе данных

[Vindicar]

Swek09, чем запрос SELECT не устроил? Если ты хоть что-то читал по SQL, должен про него знать.
А если не читал, то сначала почитай. Сэкономишь время в итоге.

Answer 1

[Османов Осман]

...
user = cursor.execute('SELECT * FROM users WHERE id=%d' % us_id).fetchall();
if user:
    # пользователь есть

else:
    # его нет

Comments

[Swek09]

А можешь это вставить в код?

[Османов Осман]

@bot.message_handler(commands=['start'])
def button_message(message):
    us_id = message.from_user.id
    us_name = message.from_user.first_name
    us_sname = message.from_user.last_name
    username = message.from_user.username
    user = cursor.execute('SELECT * FROM users WHERE User_id=?', us_id).fetchall();
    if user:
        bot.send_message(message.chat.id,'Не беспокойтесь. Вы существуете.')
    else:
        db_table_val(User_id=us_id, User_name=us_name, User_surname=us_sname, Username=username)
    bot.send_message(message.chat.id,'Привет',reply_markup=markup)

[Swek09]

Османов Осман, баг
user = cursor.execute('SELECT * FROM users WHERE id=?', us_id).fetchall();
sqlite3.OperationalError: no such column: id

[Османов Осман]

Swek09, поправил. Почему бы не написать просто "id" в базе данных?

[Swek09]

Османов Осман, А это как пофиксить?
user = cursor.execute('SELECT * FROM users WHERE User_id=?', us_id).fetchall();
ValueError: parameters are of unsupported type

[Османов Осман]

Swek09, удалите эту строчку и напишите print(f"type: {type(us_id)} value: {us_id}")
Скажите, что напечаталось

[Swek09]

Османов Осман, if user:
NameError: name 'user' is not defined
"

[Swek09]

Османов Осман, ой нето вот это напечатолось
type: value: 1488037388

[Османов Осман]

Swek09, мне нужно все, что вывелось в консоль

[Swek09]

Османов Осман,
type: value: 1488037388
2022-07-08 23:53:34,159 (__init__.py:574 MainThread) ERROR - TeleBot: "Infinity polling exception: name 'user' is not defined"
2022-07-08 23:53:34,164 (__init__.py:576 MainThread) ERROR - TeleBot: "Exception traceback:
Traceback (most recent call last):
File "C:\Python38-64\lib\site-packages\telebot\__init__.py", line 570, in infinity_polling
self.polling(non_stop=True, timeout=timeout, long_polling_timeout=long_polling_timeout,
File "C:\Python38-64\lib\site-packages\telebot\__init__.py", line 621, in polling
self.__threaded_polling(non_stop=non_stop, interval=interval, timeout=timeout, long_polling_timeout=long_polling_timeout,
File "C:\Python38-64\lib\site-packages\telebot\__init__.py", line 695, in __threaded_polling
raise e
File "C:\Python38-64\lib\site-packages\telebot\__init__.py", line 651, in __threaded_polling
self.worker_pool.raise_exceptions()
File "C:\Python38-64\lib\site-packages\telebot\util.py", line 147, in raise_exceptions
raise self.exception_info
File "C:\Python38-64\lib\site-packages\telebot\util.py", line 93, in run
task(*args, **kwargs)
File "C:\Users\admin\Desktop\Мой бот\241242.py", line 27, in button_message
if user:
NameError: name 'user' is not defined
"

[Османов Осман]

Swek09,

user = cursor.execute('SELECT * FROM users WHERE User_id=?', int(us_id)).fetchall();

попробуйте теперь вот этот вариант

[Swek09]

Османов Осман,
2022-07-09 00:00:35,703 (__init__.py:574 MainThread) ERROR - TeleBot: "Infinity polling exception: parameters are of unsupported type"
2022-07-09 00:00:35,745 (__init__.py:576 MainThread) ERROR - TeleBot: "Exception traceback:
Traceback (most recent call last):
File "C:\Python38-64\lib\site-packages\telebot\__init__.py", line 570, in infinity_polling
self.polling(non_stop=True, timeout=timeout, long_polling_timeout=long_polling_timeout,
File "C:\Python38-64\lib\site-packages\telebot\__init__.py", line 621, in polling
self.__threaded_polling(non_stop=non_stop, interval=interval, timeout=timeout, long_polling_timeout=long_polling_timeout,
File "C:\Python38-64\lib\site-packages\telebot\__init__.py", line 695, in __threaded_polling
raise e
File "C:\Python38-64\lib\site-packages\telebot\__init__.py", line 651, in __threaded_polling
self.worker_pool.raise_exceptions()
File "C:\Python38-64\lib\site-packages\telebot\util.py", line 147, in raise_exceptions
raise self.exception_info
File "C:\Python38-64\lib\site-packages\telebot\util.py", line 93, in run
task(*args, **kwargs)
File "C:\Users\admin\Desktop\Мой бот\241242.py", line 26, in button_message
user = cursor.execute('SELECT * FROM users WHERE User_id=?', int(us_id)).fetchall();
ValueError: parameters are of unsupported type
"

[Османов Осман]

Swek09, думаю, вот это пойдет

user = cursor.execute('SELECT * FROM users WHERE User_id=?', (int(us_id)),).fetchall();

[Swek09]

Османов Осман,

2022-07-09 00:05:10,056 (__init__.py:574 MainThread) ERROR - TeleBot: "Infinity polling exception: parameters are of unsupported type"
2022-07-09 00:05:10,105 (__init__.py:576 MainThread) ERROR - TeleBot: "Exception traceback:
Traceback (most recent call last):
  File "C:\Python38-64\lib\site-packages\telebot\__init__.py", line 570, in infinity_polling
    self.polling(non_stop=True, timeout=timeout, long_polling_timeout=long_polling_timeout,
  File "C:\Python38-64\lib\site-packages\telebot\__init__.py", line 621, in polling
    self.__threaded_polling(non_stop=non_stop, interval=interval, timeout=timeout, long_polling_timeout=long_polling_timeout,
  File "C:\Python38-64\lib\site-packages\telebot\__init__.py", line 695, in __threaded_polling
    raise e
  File "C:\Python38-64\lib\site-packages\telebot\__init__.py", line 651, in __threaded_polling
    self.worker_pool.raise_exceptions()
  File "C:\Python38-64\lib\site-packages\telebot\util.py", line 147, in raise_exceptions
    raise self.exception_info
  File "C:\Python38-64\lib\site-packages\telebot\util.py", line 93, in run
    task(*args, **kwargs)
  File "C:\Users\egris\Desktop\Мой Магазин\241242.py", line 26, in button_message
    user = cursor.execute('SELECT * FROM users WHERE User_id=?', (int(us_id)),).fetchall();
ValueError: parameters are of unsupported type
"

[Османов Осман]

user = cursor.execute('SELECT * FROM users WHERE User_id=?', (int(us_id),)).fetchall();

запятая левее должна быть

[Османов Осман]

А вообще, знаете, можно без экранизации. Ведь sql-инъекции итак исключены.

user = cursor.execute('SELECT * FROM users WHERE User_id=%d' % us_id).fetchall();

Вот рабочий вариант

[Swek09]

Османов Осман, Спасибо всё работает

Answer 2

[kwarsk]

Здрвствуйте, помогите пожалуйста, вот код:
import telebot
import sqlite3
conn = sqlite3.connect('adcadczscbd.sqlite3', check_same_thread=False)
cursor = conn.cursor()

bot = telebot.TeleBot("5739726750:AAE1ysradDAVUfAwGNRyhlObyoj6i4TR7CU")
@bot.message_handler(commands=['register'])
def get_text_messages(message):
usernam = message.from_user.username
data = cursor.execute(f"SELECT * FROM users WHERE usernames = {usernam}").fetchone()
if data is None:
username = [message.from_user.username]
cursor.execute("INSERT INTO users VALUES (?)", username)
conn.commit()
bot.reply_to(message, 'Поздравляю! Ты зарегистрировался')
else:
bot.reply_to(message, 'Ты уже зарегистрирован')

bot.infinity_polling(none_stop=True, timeout=0)

А вот вывод:
2022-11-23 09:22:02,205 (__init__.py:964 MainThread) ERROR - TeleBot: "Infinity polling exception: no such column: kwarsk"
2022-11-23 09:22:02,208 (__init__.py:966 MainThread) ERROR - TeleBot: "Exception traceback:
Traceback (most recent call last):
File "C:\Users\limba\AppData\Roaming\Python\Python310\site-packages\telebot\__init__.py", line 959, in infinity_polling
self.polling(non_stop=True, timeout=timeout, long_polling_timeout=long_polling_timeout,
File "C:\Users\limba\AppData\Roaming\Python\Python310\site-packages\telebot\__init__.py", line 1047, in polling
self.__threaded_polling(non_stop=non_stop, interval=interval, timeout=timeout, long_polling_timeout=long_polling_timeout,
File "C:\Users\limba\AppData\Roaming\Python\Python310\site-packages\telebot\__init__.py", line 1122, in __threaded_polling
raise e
File "C:\Users\limba\AppData\Roaming\Python\Python310\site-packages\telebot\__init__.py", line 1078, in __threaded_polling
self.worker_pool.raise_exceptions()
File "C:\Users\limba\AppData\Roaming\Python\Python310\site-packages\telebot\util.py", line 154, in raise_exceptions
raise self.exception_info
File "C:\Users\limba\AppData\Roaming\Python\Python310\site-packages\telebot\util.py", line 98, in run
task(*args, **kwargs)
File "C:\Users\limba\AppData\Roaming\Python\Python310\site-packages\telebot\__init__.py", line 6086, in _run_middlewares_and_handler
result = handler['function'](message)
File "E:\Bot\adcadczsc.py", line 10, in get_text_messages
data = cursor.execute(f"SELECT * FROM users WHERE usernames = {usernam}").fetchone()
sqlite3.OperationalError: no such column: