Update Akeno/utils/base_sqlite.py
Browse files
Akeno/utils/base_sqlite.py
CHANGED
@@ -23,12 +23,14 @@ async def set_prefix_in_db(user_id: int, prefix: str):
|
|
23 |
conn.commit()
|
24 |
|
25 |
async def get_prefix(user_id: int):
|
|
|
|
|
|
|
|
|
|
|
|
|
26 |
cursor.execute('SELECT prefix FROM prefixes WHERE user_id=?', (user_id,))
|
27 |
result = cursor.fetchone()
|
28 |
-
|
29 |
-
if result:
|
30 |
-
return result[0]
|
31 |
-
else:
|
32 |
-
return None
|
33 |
|
34 |
conn.close()
|
|
|
23 |
conn.commit()
|
24 |
|
25 |
async def get_prefix(user_id: int):
|
26 |
+
loop = asyncio.get_running_loop()
|
27 |
+
result = await loop.run_in_executor(None, fetch_prefix_from_db, user_id)
|
28 |
+
return result
|
29 |
+
|
30 |
+
def fetch_prefix_from_db(user_id: int):
|
31 |
+
cursor = conn.cursor()
|
32 |
cursor.execute('SELECT prefix FROM prefixes WHERE user_id=?', (user_id,))
|
33 |
result = cursor.fetchone()
|
34 |
+
return result[0] if result else None
|
|
|
|
|
|
|
|
|
35 |
|
36 |
conn.close()
|