Sqlite3.OperationalError: table stats has no column named user_id?

Question

[Вова Ефанов]

class SQLighter:
	def __init__(self, database):
	    self.connection = sqlite3.connect(database, check_same_thread = False)
	    self.cursor = self.connection.cursor()
	    self.cursor.execute("CREATE TABLE IF NOT EXISTS stats (user_id INT, user_name TEXT, survived INT, infected INT)")
	def add_user(self, id, name, survived, infected): 
	    with self.connection:
	        return self.cursor.execute("""INSERT INTO `stats` (user_id, user_name, survived, infected) VALUES (?,?,?,?)""", (id, name, survived, infected))
	def get_nick(self, id):
	    with self.connection:
	        return self.cursor.execute("SELECT user_id FROM stats WHERE id = ?", (id, )).fetchall()
	def set_fast(self, id):
	    with self.connection:
	        return self.cursor.execute("UPDATE stats SET infected=X WHERE id=?", (id))

sql_lighter.get_nick(754651730)
sql_lighter.get_nick(982543922)

Пишет ошибку в названии темы

Answer 1

[Yupiter7575]

Вы ищете по колонке id которую не создавали. Вопросы?

Answer 2

[MichaelMih]

def __init__(self, database):
      self.connection = sqlite3.connect(database, check_same_thread = False)
      self.cursor = self.connection.cursor()
      self.cursor.execute("CREATE TABLE IF NOT EXISTS stats (user_id INT, user_name TEXT, survived INT, infected INT)")
      self.connection.commit()

Comments

[Вова Ефанов]

sqlite3.OperationalError: no such column: id теперь эта ошибка

def get_nick(self, id):
	    with self.connection:
	        return self.cursor.execute("SELECT user_id FROM stats WHERE id = ?", (id, )).fetchall()

[MichaelMih]

Моя библиотека, для работы с базой

import sqlite3
from threading import Lock

lock = Lock()


def dict_factory(cursor, row):
    d = {}
    for idx, col in enumerate(cursor.description):
        d[col[0]] = row[idx]
    return d


class DataBase:

    def __init__(self, _db):
        self._db = _db
        self.conn = sqlite3.connect(_db, check_same_thread=False)
        self.conn.row_factory = dict_factory
        self.cur = self.conn.cursor()

    def add_row(self, table, **params):
        item = []
        p = []
        values=[]

        for key, value in params.items():
            item.append(str(key))
            values.append(str(value))
            p.append("?")

        item = ",".join(item)
        p = ",".join(p)
        with lock:
            self.cur.execute(f"insert into {table} ({item}) values ({p})", values)
            self.conn.commit()

    def update_row(self, table, check=None, **params):
        item, values = "", []

        for key, value in params.items():
            if item == "":
                item = item + f"{key}=?"
            else:
                item = item + f",{key}=?"
            values.append(value)
        with lock:
            if check is None:
                self.cur.execute(f"update {table} SET {item}", values)
            else:
                self.cur.execute(f"update {table} SET {item} WHERE {check}", values)
            self.conn.commit()

    def get_row(self, table, row='*', check=None):
        if check is None:
            with lock:
                respone = self.cur.execute(f"SELECT {row} FROM {table}")
                return respone.fetchall()
        else:
            with lock:
                respone = self.cur.execute(f"SELECT {row} FROM {table} WHERE {check}")
                return respone.fetchall()

    def get_lat_row(self, table):
        with lock:
            sql = f"SELECT * FROM {table} ORDER BY id DESC LIMIT 1"
            rsp = self.cur.execute(sql)
            return rsp.fetchone()


if __name__ == "__main__":
    db = DataBase("base.db")

Пример использования

db.add_row("users", user_id=432, text="fdsfsd") # добавить запись
db.update_row("users", check="user_id=432", text="f")# обновляем запись с нужным узерид
db.get_row("users",  check="user_id=432") #получаем запись с нужным юзерид

[MichaelMih]

NoPressF,

def add_user(self, id, name, survived, infected): 
      with self.connection:
          obj = self.cursor.execute("""INSERT INTO `stats` (user_id, user_name, survived, infected) VALUES (?,?,?,?)""", (id, name, survived, infected))
          self.commit()
          return obj

[MichaelMih]

NoPressF, WHERE user_id = ?

[Вова Ефанов]

MichaelMih, Что мне это даст?
Я туповат и не пойму этого мне нужно исправить мою ошибку, а не давать пример (не ругаюсь)

[Вова Ефанов]

MichaelMih, NameError: name 'survived' is not defined

[Вова Ефанов]

Ничего не изменилось

[MichaelMih]

NoPressF, после запросов к базе, в которых вы добавляете какую-либо информацию, нужно писать
connection.commit(), если мы берем информацию из базы данных, пишем fetchall или fetchone

Добавим запись:

conn = sqlite3.connect("db.db", check_same_thread=False)
cur = conn.cursor()
cur.execute("insert into users values ('name')"])
conn.commit

[MichaelMih]

NoPressF,
ошибка NameError: name 'survived' is not defined указывает на то, что survived нет в таблице

[Вова Ефанов]

MichaelMih, Traceback (most recent call last):
File "zombiebot.py", line 164, in
bot.polling(none_stop=True, interval=0)
File "C:\Users\Vova\AppData\Local\Programs\Python\Python37\lib\site-packages\telebot\__init__.py", line 496, in polling
self.__threaded_polling(none_stop, interval, timeout, long_polling_timeout)
File "C:\Users\Vova\AppData\Local\Programs\Python\Python37\lib\site-packages\telebot\__init__.py", line 555, in __threaded_polling
raise e
File "C:\Users\Vova\AppData\Local\Programs\Python\Python37\lib\site-packages\telebot\__init__.py", line 518, in __threaded_polling
self.worker_pool.raise_exceptions()
File "C:\Users\Vova\AppData\Local\Programs\Python\Python37\lib\site-packages\telebot\util.py", line 117, in raise_exceptions
raise self.exception_info
File "C:\Users\Vova\AppData\Local\Programs\Python\Python37\lib\site-packages\telebot\util.py", line 69, in run
task(*args, **kwargs)
File "zombiebot.py", line 96, in reactMessage
bot.send_message(message.chat.id, f"Мой профиль\nМой ID: [{message.from_user.id}]\nМой Псевдоним: [{message.from_user.username}]\nМоё Ф.И: [{message.from_user.first_name} {message.from_user.last_name}]\nКоличество побед за выжившего: [{survived}]\nКоличество заражений за заражённого: [{infected}]\nВерсия помощника бота: [V0.3]\nВерсия игры зомби: [V0.9]")
NameError: name 'survived' is not defined

[Вова Ефанов]

NoPressF,

class SQLighter:
	def __init__(self, database):
	    self.connection = sqlite3.connect(database, check_same_thread = False)
	    self.cursor = self.connection.cursor()
	    self.cursor.execute("CREATE TABLE IF NOT EXISTS stats (user_id INT, user_name TEXT, survived INT, infected INT)")
	    self.connection.commit()
	def add_user(self, id, name, survived, infected): 
	    with self.connection:
	        return self.cursor.execute("INSERT INTO `stats` (user_id, user_name, survived, infected) VALUES (?,?,?,?)", (id, name, survived, infected))
	def get_nick(self, id):
	    with self.connection:
	        self.cursor.execute("SELECT user_id FROM stats WHERE user_id = ?", (id, )).fetchall()
	        self.connection.commit()
	def set_fast(self, id, survived, infected):
	    with self.connection:
	        self.cursor.execute("UPDATE stats SET infected = ?, survived = ? WHERE user_id = ?", (infected, survived, id))
	       	self.connection.commit()
	

sql_lighter = SQLighter("database.db")
sql_lighter.add_user(982543922, "Вова", 1, 1)
sql_lighter.add_user(754651730, "Андрей", 2, 2)
sql_lighter.set_fast(982543922, 1, 1)
sql_lighter.set_fast(754651730, 2, 2)
sql_lighter.get_nick(754651730)
sql_lighter.get_nick(982543922)

[Yupiter7575]

MichaelMih, Браво! У нас теперь NameError имеет прямое отношение к БД

[Вова Ефанов]

MichaelMih, вроде сделал всё правильно а такая фигня

[Вова Ефанов]

NoPressF, пол дня потратил в пустую...

[Yupiter7575]

NoPressF, Покажите весь код, вместе с принтом

[Вова Ефанов]

Yupiter7575, Хорошо вот:

class SQLighter:
	def __init__(self, database):
	    self.connection = sqlite3.connect(database, check_same_thread = False)
	    self.cursor = self.connection.cursor()
	    self.cursor.execute("CREATE TABLE IF NOT EXISTS stats (user_id INT, user_name TEXT, survived INT, infected INT)")
	    self.connection.commit()
	def add_user(self, id, name, survived, infected): 
	    with self.connection:
	        return self.cursor.execute("INSERT INTO `stats` (user_id, user_name, survived, infected) VALUES (?,?,?,?)", (id, name, survived, infected))
	def get_nick(self, id):
	    with self.connection:
	        self.cursor.execute("SELECT user_id FROM stats WHERE user_id = ?", (id, )).fetchall()
	        self.connection.commit()
	def set_fast(self, id, survived, infected):
	    with self.connection:
	        self.cursor.execute("UPDATE stats SET infected = ?, survived = ? WHERE user_id = ?", (infected, survived, id))
	       	self.connection.commit()
	

sql_lighter = SQLighter("database.db")
sql_lighter.add_user(982543922, "Вова", 1, 1)
sql_lighter.add_user(754651730, "Андрей", 2, 2)
sql_lighter.set_fast(982543922, 1, 1)
sql_lighter.set_fast(754651730, 2, 2)
sql_lighter.get_nick(754651730)
sql_lighter.get_nick(982543922)


if message.text.lower() == ' мой профиль':
		bot.send_message(message.chat.id, f"Мой профиль\nМой ID: [{message.from_user.id}]\nМой Псевдоним: [{message.from_user.username}]\nМоё Ф.И: [{message.from_user.first_name} {message.from_user.last_name}]\nКоличество побед за выжившего: [{survived}]\nКоличество заражений за заражённого: [{infected}]\nВерсия помощника бота: [V0.3]\nВерсия игры зомби: [V0.9]")

[MichaelMih]

NoPressF,

import sqlite3


class SQLighter:
    def __init__(self, database):
        self.connection = sqlite3.connect(database, check_same_thread=False)
        self.cursor = self.connection.cursor()
        self.cursor.execute(
            "CREATE TABLE IF NOT EXISTS stats (user_id INT, user_name TEXT, survived INT, infected INT)")
        self.connection.commit()

    def add_user(self, id, name, survived, infected):
        with self.connection:
            obj = self.cursor.execute("INSERT INTO `stats` (user_id, user_name, survived, infected) VALUES (?,?,?,?)",
                                       (id, name, survived, infected))
            self.connection.commit()
            return obj

    def get_nick(self, id):
        with self.connection:
            self.cursor.execute("SELECT user_id FROM stats WHERE user_id = ?", (id,)).fetchall()

    def set_fast(self, id, survived, infected):
        with self.connection:
            self.cursor.execute("UPDATE stats SET infected = ?, survived = ? WHERE user_id = ?",
                                (infected, survived, id))
            self.connection.commit()

    def delete_table(self, table):
        with self.connection:
            self.cursor.execute(f"DROP TABLE {table}")
            self.connection.commit()

    def create_table(self):
        self.cursor.execute(
            "CREATE TABLE IF NOT EXISTS stats (user_id INT, user_name TEXT, survived INT, infected INT)")
        self.connection.commit()


sql_lighter = SQLighter("database.db")
sql_lighter.delete_table("stats")
sql_lighter.create_table()
sql_lighter.add_user(982543922, "Вова", 1, 1)
sql_lighter.add_user(754651730, "Андрей", 2, 2)
sql_lighter.set_fast(982543922, 1, 1)
sql_lighter.set_fast(754651730, 2, 2)
sql_lighter.get_nick(754651730)
sql_lighter.get_nick(982543922)

[Yupiter7575]

NoPressF,

выжившего: [{survived}]\nКоличество заражений за заражённого: [{infected}]\nВерсия помощника бота: [V0.3]\nВерсия игры зомби: [V0.9]")

У вас нигде не обозначается переменная survived и infected, вот и ругается интерпретатор

[Вова Ефанов]

MichaelMih, Таже самая ошибка

[MichaelMih]

MichaelMih, после выполнения этого кода, уберите
sql_lighter.delete_table("stats")
sql_lighter.create_table()
Так же уберите эти 2 функции из класса

[Yupiter7575]

MichaelMih, Не позорьтесь. Я выше отписал причину ошибки.

[Вова Ефанов]

Yupiter7575, и как это исправить?

[Yupiter7575]

NoPressF, Обозначьте переменную infected и survived. Вы их не создаете но используете - это так не работает

[Вова Ефанов]

Yupiter7575, сделать типо так в глобал ?

infected = 0
survived = 0

[Yupiter7575]

NoPressF, Разве у вас не должно это значение быть в базе данных? От туда и берите. Если я не прав то да ваш пример верный

[Вова Ефанов]

Yupiter7575, всмысле их брать, как ? infected = infected? в функции get_nick?

[Вова Ефанов]

Yupiter7575, Если сделать по моему способу через глобал то выдаёт везде 0

[Yupiter7575]

NoPressF,

def get_infect_and_survived(self, id):
    return self.cursor.execute(f'SELECT infected, survived FROM stats WHERE user_id={id}')

[Yupiter7575]

NoPressF, Вам же нужно брать значения из БД.
Потом в коде:

arr = sql_lighter.get_infect_and_survived(id) #здесь будет id

И вы получаете массив с infected и survived. Если выдаст ошибку попробуйте через fetch all его прокатить

[Вова Ефанов]

Yupiter7575,

class SQLighter:
	def __init__(self, database):
	    self.connection = sqlite3.connect(database, check_same_thread = False)
	    self.cursor = self.connection.cursor()
	    self.cursor.execute("CREATE TABLE IF NOT EXISTS stats (user_id INT, user_name TEXT, survived INT, infected INT)")
	    self.connection.commit()
	def add_user(self, id, name, survived, infected): 
	    with self.connection:
	        return self.cursor.execute("INSERT INTO `stats` (user_id, user_name, survived, infected) VALUES (?,?,?,?)", (id, name, survived, infected))
	def get_nick(self, id):
	    with self.connection:
	        return self.cursor.execute("SELECT user_id FROM stats WHERE user_id = ?", (id, )).fetchall()
	def set_fast(self, id, survived, infected):
	    with self.connection:
	        return self.cursor.execute("UPDATE stats SET infected = ?, survived = ? WHERE user_id=?", (infected, survived, id))
	def get_infected_and_survived(self, id):
		return self.cursor.execute(f'SELECT infected, survived FROM stats WHERE user_id={id}')
 

sql_lighter = SQLighter("database.db")
sql_lighter.add_user(982543922, "Вова", 1, 1)
sql_lighter.add_user(754651730, "Андрей", 2, 2)
sql_lighter.get_infected_and_survived(754651730)
sql_lighter.get_infected_and_survived(982543922)
infected = 0
survived = 0

Вывод всё равно 0

[Yupiter7575]

NoPressF,

sql_lighter.get_infected_and_survived(982543922)

Ну вам нужно это в переменную записать. Я выше отписал как и что

[Вова Ефанов]

Yupiter7575, оличество побед за выжившего: [sqlite3.Cursor object at 0x000000000384CAB0]
Количество заражений за заражённого: [sqlite3.Cursor object at 0x000000000384CAB0]
Вот что выдал бот
sqlite3.Cursor object at 0x000000000384CAB0

[Yupiter7575]

NoPressF, Слушайте, тут разбираться надо.
Продебажте код, на выходе сделайте print(arr) посмотрите как устроен этот словарь.

[Вова Ефанов]

Yupiter7575, Вы можете мне конкретнее объяснить, всё таки 0:16 на улице мозг не варит уже

[Yupiter7575]

NoPressF,

def get_infected_and_survived(self, id):
    for row in  self.cursor.execute(f'SELECT infected, survived FROM stats WHERE user_id={id}'):
        return row

Так попробуйте.
Вообще почитать бы вам документацию

[Yupiter7575]

Yupiter7575, Ммм я кажется понял вашу проблему. Код выше выведет последнюю запись, т.к. у вас не уникального ключа, и после каждого запуска программы у вас заново создается одна и та же запись.

[Вова Ефанов]

Yupiter7575, а вот у меня есть survived и infected переменные я им присваиваю get_infected_and_survived(729194740)
А как мне написать для каждого пользователя отдельное значение?

[Yupiter7575]

NoPressF, Ну берете id пользователя в телеграмме и с ним работаете