Как обновить данные в mysql?

Question

[Maxwell012]

Пишу бота для тг, мне нужно обновить некоторые данные в mysql, ошибки никакой не выдает, все выполняет, но данные не обновляются в таблице. Код:

async def record_participate(id, number):
    connection.connect
    cursor.execute(f"UPDATE `user` SET `participate`={number} WHERE `id` = {id}")
    connection.commit()
    print('Добавил бро')

Вообще не понимаю чего так происходит, код для mysql проверял в mysql все работало, также сохраняю изменения после выполнения действий в бд, ошибок не выдает, но не добавляет данные.

Comments

[Ипатьев]

А где вы брали код для этого примера?

[Maxwell012]

Ипатьев, Сам писал

[Ипатьев]

Ну вы же все эти команды не брали из головы? Вы же из какого-то примера их брали?
нельзя же из головы выдумать connection.commit() к примеру?

[Maxwell012]

Ипатьев, Да я смотрел видео на ютубе по разным бд и потом остановился на этой, ну, а так как я посмотрел достаточно много видео, я уже интуитивно понимал как они работают и начал писать код

Answer 1

[Ипатьев]

Кто ж вас учил так с БД работать?
Во-первых, данные всегда должны всегда передаваться в запрос отдельно.
Во-вторых, код соединения совсем непонятный.
Если используется mysql.connector, то надо как-то так

import mysql.connector
conn = mysql.connector.connect(host='127.0.0.1', database='test', user='user', password='')
cursor = conn.cursor()
sql = "UPDATE `user` SET `participate`=%s WHERE `id` = %s"
cursor.execute(sql, [number, id])
conn.commit()

Comments

[Maxwell012]

Учусь сам, сорри если так больно смотреть на код, я только начал в бд вникать. Вот код подключения (библиотека pymysql):

def db_start():
    try:
        global connection, cursor
        connection = pymysql.connect(
            host=host,
            port=3306,
            user=user,
            password=password,
            database=db_name,
            cursorclass=pymysql.cursors.DictCursor
        )
        cursor = connection.cursor()
    except Exception as ex:
        print("Connection refused...")
        print(ex)

Изменил запрос как вы показали:

async def record_participate(id, number):
    connection.connect
    sql = "UPDATE `user` SET `participate`=%s WHERE `id` = %s"
    cursor.execute(sql, [number,id])
    connection.commit()

Но в базе данных ничего не меняется, возможно надо сказать что у меня по умолчанию в этой колонке стоит значение NULL, хотя навряд ли оно влияет на это

[Ипатьев]

ну вот у вас есть функция db_start
а где вы её вызываете?

[Maxwell012]

Ипатьев, она вызывается в основном файле проекта, точнее она вызывается сразу при старте бота. Проблема не в том что я не подключился это точно, так как у меня в проекте имеются еще 3 функции по внесению данных в бд и получение данных, но там все работает полностью корректно, я не могу понять почему здесь такое происходит

[Ипатьев]

я тоже не могу
у меня этот код работает

начать наверное надо с вывода number и id для отладки

[Maxwell012]

Нашел ошибку, такая глупая, эта функция вызывалась когда пользователь отвечал нажимая на инлайн кнопку и я не заметил что я получаю message не пользователя, а бота и соответственно отправлял его айди, исправил, теперь отправляю айди чата. В программировании никогда не знаешь где и какую ошибку допустишь. Спасибо вам за помощь и улучшение моей структуры кода