Данные из кода Python не сохраняются в Sqlite3?

Question

[Dj3ck]

Код выполняется . ошибок в Терминале нет . Но данные которые он должен собирать не вносятся в БД .И он изначально не хотел создавать автоматически БД ,поэтому указал Путь к папке.

import discord
from discord.ext import commands
import sqlite3

bot = commands.Bot(command_prefix=settings['prefix'])

# Создаем таблицу, если ее нет
conn = sqlite3.connect(r'C:\Users\Djeck\Desktop\Bot\discord_users.db')
c = conn.cursor()
c.execute('''CREATE TABLE IF NOT EXISTS users
             (id TEXT, name TEXT, is_active INTEGER, servers TEXT, discord_id TEXT)''')

@bot.command()
async def hello(ctx):
    author = ctx.message.author
    await ctx.send(f'доброе утро хозяин, {author.mention}!')

@bot.event
async def on_ready():
    print(f'{bot.user.name} has connected to Discord!')
    print(f'Pong! Latency: {round(bot.latency * 1000)}ms')
    await add_all_users()

async def add_all_users():
    await bot.wait_until_ready()
    members = [m for g in bot.guilds for m in g.members]
    for member in members:
        add_user(member.id)

    conn.commit()

def add_user(member_id):
    member = bot.get_user(member_id)
    if not isinstance(member, discord.Member):
        return

    # Получаем информацию о пользователе
    name = member.display_name
    is_active = 1 if member.status == discord.Status.online else 0
    servers = [str(guild.id) for guild in bot.guilds if member in guild.members]
    discord_id = member.id

    try:
        # Проверяем, есть ли пользователь с таким же ID в базе данных
        c.execute('SELECT * FROM users WHERE id = ?', (member_id,))
        user = c.fetchone()
        if user:
            # Обновляем информацию о пользователе
            c.execute('''UPDATE users SET 
                         name = ?, 
                         is_active = ?, 
                         servers = ?, 
                         discord_id = ?
                         WHERE id = ?''',
                      (name, is_active, str(servers), discord_id, member_id))
        else:
            # Добавляем нового пользователя в базу данных
            c.execute('INSERT INTO users VALUES (?, ?, ?, ?, ?)',
                      (member_id, name, is_active, str(servers), discord_id))

    except sqlite3.Error as e:
        print(f'Ошибка при работе с базой данных: {e}')

if __name__ == '__main__':
    bot.run(settings['token'])
    conn.close()

Comments

[Модератор]

Не надо ставить как можно больше тэгов. Лучше оставить один, но конкретный, с которым проблема.
См.п.3.1 Регламента. Также обратите внимание на п.3.6

[Dj3ck]

Модератор, Я много и не ставил, они все связанны с тематикой вопроса . Но спасибо за ссылки .Буду учитывать в дальнейшем .

[mayton2019]

По этому condition

if user:
у тебя работает по линии true или false?

[Dj3ck]

mayton2019, true

[Модератор]

Dj3ck, просто внимательно прочтите п.3.1 и выполняйте неукоснительно.

[mayton2019]

Dj3ck,

1) где ты делаешь commit? Или где у тебя включен auto-commit?
2) команда update обычно возвращает количество строк которые были обновлены. Проверь сколько обновилось.

[Dj3ck]

mayton2019,

async def add_all_users():
    await bot.wait_until_ready()
    members = [m for g in bot.guilds for m in g.members]
    for member in members:
        add_user(member.id)

    conn.commit()

Про auto-commit ,ещё не встречал такую функцию . Про update Нечего не обновилось ,у меня вообще данные не появляются в БД ,есть столбцы а данных по операциям нет .

[mayton2019]

Dj3ck, значит вот это условие у тебя не срабатывает.

WHERE id = ?

проверяй.

[Dj3ck]

Крч упростил код исправил пару данных и он мне заполнил БД записями но причину точную так и не выяснил =_=
Вот исправленный-упрощенный код.

import discord
from discord.ext import commands
import sqlite3
import os

print(os.getcwd())

settings = {
    'token': '',
    'bot': '',
    'id': '',
    'prefix': '+'
}

intents = discord.Intents.default()
intents.members = True
bot = commands.Bot(command_prefix=settings['prefix'], intents=intents)

# Подключение к базе данных
conn = sqlite3.connect('discord_users.db')
c = conn.cursor()

# Создание таблицы пользователей, если ее нет
c.execute('''CREATE TABLE IF NOT EXISTS users
             (id TEXT, name TEXT)''')

# Обработчик события "Бот готов"
@bot.event
async def on_ready():
    print(f'{bot.user.name} has connected to Discord!')
    print(f'Pong! Latency: {round(bot.latency * 1000)}ms')
    await add_all_users()

# Функция для добавления всех пользователей в базу данных
async def add_all_users():
    await bot.wait_until_ready()
    members = [m for g in bot.guilds for m in g.members]
    for member in members:
        add_user(member.id, member.display_name)
    conn.commit()

# Функция для добавления пользователя в базу данных
def add_user(member_id, member_name):
    try:
        c.execute('SELECT * FROM users WHERE id = ?', (int(member_id),))
        user = c.fetchone()
        if user:
            c.execute('''UPDATE users SET 
                            name = ?
                            WHERE id = ?''', (member_name, member_id))
            if c.rowcount > 0:
                print(f'{c.rowcount} строк было обновлено.')
            else:
                print(f'Строки для обновления не найдены.')
        else:
            c.execute('INSERT INTO users VALUES (?, ?)',
                      (member_id, member_name))
    except sqlite3.Error as e:
        print(f'Ошибка при работе c базой данных: {e}')

# Команда для вывода списка ID и ников пользователей на сервере
@bot.command()
async def list_users(ctx):
    guild = ctx.guild
    members = [(member.id, member.display_name) for member in guild.members if not member.bot]
    await ctx.send(f'Список пользователей на сервере: {members}')

# Запуск бота
if __name__ == '__main__':
    bot.run(settings['token'])
    conn.close()