new insert query

Author: tslashd

sql.py

@@ -37,6 +37,24 @@ def insertQuery(query):
         database=db["DB"]
     )
 
+    mycursor = mydb.cursor()
+    mycursor.execute(query)
+
+    mydb.commit()
+
+    return mycursor.rowcount
+
+def insert_escaped_query(query):
+    """Executes `INSERT` query `mycursor.execute("", (query))` provided and returns `mycursor.rowcount`\n
+    Connects to a predefined `Database` from `config.json`"""
+    db = config["DATABASE"]
+    mydb = mysql.connector.connect(
+        host=db["HOST"],
+        user=db["USERNAME"],
+        password=db["PASSWORD"],
+        database=db["DB"]
+    )
+
     mycursor = mydb.cursor()
     mycursor.execute("", (query))
 

surftimer/ck_playerrank.py

@@ -1,6 +1,6 @@
 from fastapi import APIRouter, Request, Response, status
 from fastapi.responses import JSONResponse
-from sql import selectQuery, insertQuery
+from sql import selectQuery, insertQuery, insert_escaped_query
 from globals import get_cache, set_cache
 from pydantic import BaseModel
 import time, json
@@ -128,7 +128,7 @@ async def updatePlayerRankPoints(
         data.style,
     )
 
-    xquery = insertQuery(sql)
+    xquery = insert_escaped_query(sql)
 
     content_data = {"updated": xquery, "xtime": time.perf_counter() - tic}
     if xquery < 1:
@@ -184,7 +184,7 @@ async def updatePlayerRankPoints2(
         data.steamid32,
         data.style,
     )
-    xquery = insertQuery(sql)
+    xquery = insert_escaped_query(sql)
 
     content_data = {"updated": xquery, "xtime": time.perf_counter() - tic}
     if xquery < 1: