Почему не записывает MySQL?

Question

[Old_TyT]

У меня есть код:

from mysql.connector import MySQLConnection, Error

class mysqlighter:
    def __init__(self, db_conf):
        self.conn = MySQLConnection(**db_conf)
        self.cursor = self.conn.cursor()
    
    def add_coin(self, coinsID, coins_symbol, coins_name):
        """Добавляем список коинов"""
        with self.conn:
            query = """INSERT INTO coinTables(id,symbol,name)
                VALUES(%s,%s,%s)"""
            args = (coinsID, coins_symbol, coins_name)
            print(self)
            print(self.cursor)
            try:
                self.cursor.execute(query, args)
            except Error as error:
                print(error)
        
    def coin_Tables(self):
        with self.conn:
            self.cursor.execute("DROP TABLE coinTables")
            create_table = """
            CREATE TABLE coinTables (
            id VARCHAR(255) NULL,
            symbol VARCHAR(255) NULL,
            name VARCHAR(255) NULL);
            """
            self.cursor.execute(create_table)

Функция coin_Tables отрабатывает хорошо, а вот функция add_coin вызывает ошибку

2055: Lost connection to MySQL server at 'localhost:3306', system error: 9 Bad file descriptor

С чем связано и как чинить?

Comments

[Dimonchik]

хороший код

а что он делает?

[Old_TyT]

Dimonchik, удаляет таблицу, потом создает и заполняет ее, ну должен, а пока ток ошибку выдает

[galaxy]

Old_TyT, попробуйте подумать, зачем вам эти строки:
with self.conn:

[Old_TyT]

galaxy, что бы подключаться в бд 1 раз, или я не прав?

[galaxy]

Old_TyT, подключение уже состоялось в __init__()

[Old_TyT]

galaxy, что бы брать данные курсора наверное?(Могу ошибиться, не до конца разобрался в коде)
Я делал по примеру, в нем все работало:

import sqlite3

class SQLighter:

    def __init__(self, database):
        """Подключаемся к БД и сохраняем курсор соединения"""
        self.connection = sqlite3.connect(database)
        self.cursor = self.connection.cursor()
    def subscriber_exists(self, user_id):
        """Проверяем, есть ли уже юзер в базе"""
        with self.connection:
            result = self.cursor.execute('SELECT * FROM `users` WHERE `user_id` = ?', (user_id,)).fetchall()
            return bool(len(result))

[galaxy]

Old_TyT, где вы берете эти дурацкие примеры, извините? Ваш пример, кстати, про sqlite.

Писатели этих примеров за каким-то лешим используют context wrapper (конструкцию with). Ее поведение в Python DBAPI не определено. Разработчики драйверов конкретных СУБД делают как бог на душу положит.

Например, sqlite3 драйвер при выходе из with блока делает commit или rollback. А драйвер mysql по выходе закрывает соединение.

Вывод: не используйте with всуе (а если используете, читайте внимательно документацию).

[Old_TyT]

galaxy, Окей, а как тогда поступить?

[galaxy]

Old_TyT, да уберите эти with и все

[Old_TyT]

galaxy, воу, спасибо большое!