57 lines
3.1 KiB
Python
57 lines
3.1 KiB
Python
import mysql.connector
|
|
|
|
from loguru import logger
|
|
|
|
class Database:
|
|
def __init__(self, host, user, password, db):
|
|
self.con = mysql.connector.connect(
|
|
host=host,
|
|
user=user,
|
|
password=password,
|
|
database=db,
|
|
)
|
|
|
|
def init_test_database(self):
|
|
self.con.reconnect()
|
|
cursor = self.con.cursor()
|
|
try:
|
|
cursor.execute("CREATE TABLE discord_link ( admin_id int(10) UNSIGNED NOT NULL, discord_id bigint(20) UNSIGNED NOT NULL, steamid varchar(65) COLLATE utf8mb4_unicode_ci NOT NULL);")
|
|
cursor.execute("CREATE TABLE sm_admins ( id int(10) UNSIGNED NOT NULL, authtype enum('steam', 'name', 'ip') COLLATE utf8mb4_unicode_ci NOT NULL, identity varchar(65) COLLATE utf8mb4_unicode_ci NOT NULL, password varchar(65) COLLATE utf8mb4_unicode_ci DEFAULT NULL, flags varchar(30) COLLATE utf8mb4_unicode_ci NOT NULL, name varchar(65) COLLATE utf8mb4_unicode_ci NOT NULL, immunity int(10) UNSIGNED NOT NULL);")
|
|
cursor.execute("ALTER TABLE discord_link ADD PRIMARY KEY (admin_id), ADD UNIQUE KEY admin_id (admin_id), ADD UNIQUE KEY discord_id (discord_id), ADD UNIQUE KEY steamid (steamid);")
|
|
cursor.execute("ALTER TABLE sm_admins ADD PRIMARY KEY (id), ADD UNIQUE KEY identity (identity), ADD UNIQUE KEY id (id);")
|
|
cursor.execute("ALTER TABLE sm_admins MODIFY id int(10) UNSIGNED NOT NULL AUTO_INCREMENT;")
|
|
cursor.execute("ALTER TABLE discord_link ADD CONSTRAINT discord_link_ibfk_1 FOREIGN KEY (admin_id) REFERENCES sm_admins (id);")
|
|
except mysql.connector.InterfaceError:
|
|
logger.info(f"Connection to mysql got interrupted, trying to reconnect...")
|
|
self.con.reconnect()
|
|
self.init_test_database()
|
|
except Exception as err:
|
|
logger.error(f"Database interrupted: {err}")
|
|
raise Exception("Error while trying to connect to database.")
|
|
|
|
def create_reserved_slot(self, discord_user, steam_id):
|
|
self.con.reconnect()
|
|
cursor = self.con.cursor()
|
|
|
|
try:
|
|
sql_sm = "INSERT INTO sm_admins (authtype, identity, password, flags, name, immunity) VALUES (%s, %s, %s, %s, %s, %s)"
|
|
val_sm = ("steam", steam_id, "", "a", discord_user.username, "5")
|
|
cursor.execute(sql_sm, val_sm)
|
|
self.con.commit()
|
|
|
|
id = cursor.lastrowid
|
|
|
|
sql_discord = "INSERT INTO discord_link (admin_id, discord_id, steamid) VALUES (%s, %s, %s)"
|
|
val_discord = (id, str(discord_user.id), steam_id)
|
|
cursor.execute(sql_discord, val_discord)
|
|
self.con.commit()
|
|
except mysql.connector.InterfaceError:
|
|
logger.info(f"Connection to mysql got interrupted, trying to reconnect...")
|
|
self.con.reconnect()
|
|
self.create_reserved_slot(discord_user, steam_id)
|
|
except mysql.connector.IntegrityError:
|
|
raise Exception("Duplicate entrys")
|
|
except Exception as err:
|
|
logger.error(f"Database interrupted: {err}")
|
|
raise Exception("Error while trying to connect to database.")
|