From adc86c02cc32bf487503940c2bce65157e82472d Mon Sep 17 00:00:00 2001 From: sgoudham Date: Sun, 26 Jul 2020 17:48:07 +0100 Subject: [PATCH] Reverting back to inefficient blocking connections --- main.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/main.py b/main.py index eef9a8d0..12e8f210 100644 --- a/main.py +++ b/main.py @@ -157,14 +157,14 @@ async def _help(ctx, *, command: Optional[str] = None): async def reload_db(ctx): pool = await db.connection2(db.loop) - async with pool.acquire() as conn: - async with conn.cursor() as cursor: + with db.connection() as conn: + with closing(conn.cursor()) as cursor: # Define the insert statement that will insert the user's information - insert = """INSERT IGNORE INTO members (guildID, discordID) VALUES""" + ", ".join( + insert = "INSERT IGNORE INTO members (guildID, discordID) VALUES " + ", ".join( map(lambda m: f"({ctx.guild.id}, {m.id})", ctx.guild.members)) try: # Execute the query - await cursor.execute(insert) + cursor.execute(insert) except Exception as e: print(e) print(cursor.rowcount, f"Record(s) inserted successfully into Members from {ctx.guild.name}") @@ -214,7 +214,7 @@ async def on_guild_join(guild): print(cursor.rowcount, f"Record inserted successfully into Guilds from {guild.name}") # Define the insert statement that will insert the user's information - insert = "INSERT IGNORE INTO members (guildID, discordID) VALUES" + ", ".join( + insert = "INSERT INTO members (guildID, discordID) VALUES" + ", ".join( map(lambda m: f"({guild.id}, {m.id})", guild.members)) with closing(conn.cursor()) as cursor: # Execute the query @@ -269,7 +269,7 @@ async def on_member_join(member): with db.connection() as conn: # Define the insert statement that will insert the user's information - insert_query = """INSERT INTO members (guildID, discordID) VALUES (?, ?, ?)""" + insert_query = """INSERT INTO members (guildID, discordID) VALUES (?, ?)""" vals = member.guild.id, member.id, with closing(conn.cursor()) as cursor: # Execute the SQL Query