Как исправить «pymysql.err.ProgrammingError: Cursor closed»?

Question

[Артём Смирнов]

from aiomysql import Pool, DictCursor
from basa.db import db_pool

class dbsql():
    pool: Pool = db_pool

    async def register(self):
        async with self.pool.acquire() as conn:
            async with conn.cursor() as cur:
                result = await cur.execute("SELECT * FROM profile WHERE uid")
                row = await cur.fetchall()
            if result == 0:
                await cur.execute(f'INSERT INTO profile(uid) VALUES(uid)')
            else:
                return await row


main = dbsql()

Ошибка:

raise ProgrammingError("Cursor closed")
pymysql.err.ProgrammingError: Cursor closed

Answer 1

[Vindicar]

async with conn.cursor() as cur:
По выходу из with курсор будет гарантированно закрыт, независимо от способа выхода. А у тебя дальше идёт

await cur.execute(f'INSERT INTO profile(uid) VALUES(uid)')

Либо внеси эту операцию внутрь with, либо создай под неё новый курсор.

Comments

[Артём Смирнов]

Спасибо

[Артём Смирнов]

А как тогда написать так, что бы пользователь добовлялся в бд?

[Артём Смирнов]

@Cog.listener()
    async def on_message_new(self, message):
        user = await self.bot.get_user(message.from_id)
        reg = await basa.register.main.register()
        if reg is None:
            print(user.id)
            reg = await basa.register.main.register()
            await message.send(format(user.first_name) + ", добро пожаловать")

[Артём Смирнов]

и uid, везде и у всех 0, хотя это user_id

[Vindicar]

Artem4442, проверь запросы.
1. Ты не забыл указать первичный ключ в таблице пользователей?
2. Где ты подставляешь значение id для пользователя? В приведённом тобой запросе вообще подстановки нет.

[Артём Смирнов]

Vindicar, Я уже всё сделал, спасибо за помощь, я SQL запросы подучил ещё

Answer 2

[alexbprofit]

from aiomysql import Pool, DictCursor
from basa.db import db_pool

class dbsql():
    pool: Pool = db_pool

    async def register(self):
        async with self.pool.acquire() as conn:
            async with conn.cursor() as cur:
                result = await cur.execute("SELECT * FROM profile WHERE uid")
                row = await cur.fetchall()
                if result == 0:
                    await cur.execute(f'INSERT INTO profile(uid) VALUES(uid)')
                else:
                    return await row


main = dbsql()

Comments

[Артём Смирнов]

И что изменилось?

[alexbprofit]

Изменилось то что теперь вы делая запрос в бд работаете с незакрытым курсором

[alexbprofit]

просто нужно было код с условиями сдвинуть на один таб вправо

[Артём Смирнов]

alexbprofit, Спасибо, а можете подсказать почему uid у всех 0?, user_id не смог в бд передать потому что выходит ошибка с атриботом, и 1 и того же пользователя заносят в бд несколько раз

[alexbprofit]

Artem4442, вы неправильно использовали f строки

[Артём Смирнов]

alexbprofit, Я их убрал из кода полностью
Можешь подсказать?

async def chekc_bank(self, user):
        async with self.pool.acquire() as conn:
            async with conn.cursor() as cur:
                result = await cur.execute("SELECT * FROM profile WHERE uid=%s", user.id)
                row = await cur.fetchall()
                if result == 1:

                    return row['bank']

Что бы при использовании команды определённой, то ему показывалось сколько денег в банке

Answer 3

[Александр Нестеров]

Почитайте как работают контекстные менеджеры.
При использовании таковых работать с cur можно только в блоке with

async with conn.cursor() as cur:
                result = await cur.execute("SELECT * FROM profile WHERE uid")
                row = await cur.fetchall()

Comments

[Артём Смирнов]

Спасибо

[Артём Смирнов]

А как тогда написать так, что бы пользователь добовлялся в бд?

[Александр Нестеров]

Artem4442, в ответе выше уже сказали - второй запрос нужно поместить внутрь блока with

async with conn.cursor() as cur:
                result = await cur.execute("SELECT * FROM profile WHERE uid")
                row = await cur.fetchall()
                if result == 0:
                    await cur.execute(f'INSERT INTO profile(uid) VALUES(uid)')
                else:
                    return await row

[Артём Смирнов]

Александр Нестеров, Я это сделал, но пользователя несколько раз заносит в бд и uid у всех о нулям, параметр user_id не смог передать иза ошибки атрибута

[Александр Нестеров]

Artem4442, но это уже отдельный вопрос, касающийся структуры таблицы и запроса. Который, к слову, лучше опубликовать отдельно, приложив структуру базы (желательно в виде sql-кода, с помощью которого вы создавали ее. Если его нет - посмотрите, как вывести ее для вашей субд), пример запроса, который вы пытаетесь выполнить и какую ошибку выдает.

[Артём Смирнов]

Александр Нестеров, Уже опубликовал