summaryrefslogtreecommitdiff
path: root/src/database/dbadmin.py
diff options
context:
space:
mode:
Diffstat (limited to 'src/database/dbadmin.py')
-rw-r--r--src/database/dbadmin.py64
1 files changed, 27 insertions, 37 deletions
diff --git a/src/database/dbadmin.py b/src/database/dbadmin.py
index 7463021..7b00cd5 100644
--- a/src/database/dbadmin.py
+++ b/src/database/dbadmin.py
@@ -16,45 +16,37 @@ class DbAdmin(dbmain.DbMain):
# GESTION DES UTILISATEURS DANS L'ADMIN
# ****************************************************************************
# Récupérer toutes les infos de la table userAccount
- def get_all_users_account(self):
- reqGetAll = """
+ def get_all_users_account(self) -> list:
+ reqGetAll: str = """
SELECT
*
FROM
""" + self.TABLEUSERACCOUNT
- # https:#www.php.net/manual/fr/pdostatement.fetch.php
- # "PDO::FETCH_ASSOC: retourne un tableau indexé
- # par le nom de la colonne comme retourné dans le jeu de résultats"
self.exec_cmd(reqGetAll)
result = self.cur.fetchall()
return result
# https:#stackoverflow.com/questions/1361340/how-can-i-do-insert-if-not-exists-in-mysql
# Suppresion d'un utilisateur
- def del_user_by_userid(self, userId):
+ def del_user_by_userid(self, userId: int) -> int:
# Préparation de la requète pour voir si l'utilisateur existe
# https:#stackoverflow.com/questions/1676551/best-way-to-test-if-a-row-exists-in-a-mysql-table
- reqCheckExistId = """
+ reqCheckExistId: str = """
SELECT EXISTS(
SELECT 1 FROM
""" + self.TABLEUSERACCOUNT + """
WHERE
- userId = ?
+ userId = %s
LIMIT 1
)"""
- # Exécution de la requète, fetchall pour avoir le résultat
- # https:#www.php.net/manual/fr/pdostatement.fetch.php
- # struct par défaut req et index (fetch_both) = arr([0] => arr("req" => BOOL, [0] => BOOL])
- # PDO::FETCH_NUM : retourne un tableau indexé par le numéro de la colonne comme elle
- # est retourné dans votre jeu de résultat, commençant à 0
self.exec_cmd(reqCheckExistId, [userId])
reqResult = self.cur.fetchall()
# Si il existe
if (reqResult[0][0]):
# Préparation de la requète pour suppression
- reqDelUser = """DELETE FROM """ + self.TABLEUSERACCOUNT + """ WHERE userId = ?"""
+ reqDelUser: str = """DELETE FROM """ + self.TABLEUSERACCOUNT + """ WHERE userId = %s"""
# Exécution de la requète
- self.exec_cmd(reqDelUser, [userId])
+ self.exec_cmd(reqDelUser, [userId], True)
# Retourne 1 pour réussite
return 1
else:
@@ -66,14 +58,14 @@ class DbAdmin(dbmain.DbMain):
# GESTION DES EMPLOIS DANS L'ADMIN
# ****************************************************************************
# Ajout d'une categorie
- def register_job_category(self, jobNameEn, jobNameFr):
+ def register_job_category(self, jobNameEn: str, jobNameFr: str) -> int:
# Préparation et execution de la requète pour voir si la categorie existe en anglais
- reqCheckjobCategoryNameEn = """
+ reqCheckjobCategoryNameEn: str = """
SELECT EXISTS(
SELECT 1 FROM
""" + self.TABLEJOBCATEGORY + """
WHERE
- jobCategoryNameEn = ?
+ jobCategoryNameEn = %s
LIMIT 1
)"""
self.exec_cmd(reqCheckjobCategoryNameEn, [jobNameEn])
@@ -81,12 +73,12 @@ class DbAdmin(dbmain.DbMain):
# Si il n'existe pas en anglais
if not reqResultEn[0][0]:
# Préparation et execution de la requète pour voir si la categorie existe en Français
- reqCheckjobCategoryNameFr = """
+ reqCheckjobCategoryNameFr: str = """
SELECT EXISTS(
SELECT 1 FROM
""" + self.TABLEJOBCATEGORY + """
WHERE
- jobCategoryNameFr = ?
+ jobCategoryNameFr = %s
LIMIT 1
)"""
self.exec_cmd(reqCheckjobCategoryNameFr, [jobNameFr])
@@ -94,14 +86,14 @@ class DbAdmin(dbmain.DbMain):
# Si il n'existe pas en Français non plus
if not reqResultFr[0][0]:
# Préparation de la requète pour l'ajout
- reqjobCategoryNameAdd = """
+ reqjobCategoryNameAdd: str = """
INSERT INTO
""" + self.TABLEJOBCATEGORY + """
(jobCategoryNameEn, jobCategoryNameFr)
VALUES
- (? ,?)"""
+ (%s ,%s)"""
# Exécution de la requète
- self.exec_cmd(reqjobCategoryNameAdd, [jobNameEn, jobNameFr])
+ self.exec_cmd(reqjobCategoryNameAdd, [jobNameEn, jobNameFr], True)
# Retourne 1 pour réussite
return 1
else:
@@ -112,31 +104,29 @@ class DbAdmin(dbmain.DbMain):
return 0
# Suppresion d'un utilisateur
- def del_job_category_by_jobid(self, jobId):
+ def del_job_category_by_jobid(self, jobId: int) -> int:
# Préparation de la requète pour voir si l'utilisateur existe
- reqCheckExistId = """
+ reqCheckExistId: str = """
SELECT EXISTS(
SELECT 1 FROM
""" + self.TABLEJOBCATEGORY + """
WHERE
- jobCategoryId = ?
+ jobCategoryId = %s
LIMIT 1
)"""
# Exécution de la requète, fetchall pour avoir le résultat
- # struct par défaut req et index (fetch_both) = arr([0] => arr("req" => BOOL, [0] => BOOL])
- # fetch_num pour casser l'index "req" en chiffre, dict -> list
self.exec_cmd(reqCheckExistId, [jobId])
reqResult = self.cur.fetchall()
# Si il existe
if (reqResult[0][0]):
# Préparation de la requète pour suppression
- reqDelJobCategory = """
+ reqDelJobCategory: str = """
DELETE FROM
""" + self.TABLEJOBCATEGORY + """
WHERE
- jobCategoryId = ?"""
+ jobCategoryId = %s"""
# Exécution de la requète
- self.exec_cmd(reqDelJobCategory, [jobId])
+ self.exec_cmd(reqDelJobCategory, [jobId], True)
# Retourne 1 pour réussite
return 1
else:
@@ -147,14 +137,14 @@ class DbAdmin(dbmain.DbMain):
# GESTION DES MISSIONS DANS L'ADMIN
# ****************************************************************************
# Suppresion d'une mission
- def del_mission_by_missionid(self, missionId):
+ def del_mission_by_missionid(self, missionId: int) -> int:
# Préparation de la requète pour voir si l'utilisateur existe
- reqCheckExistId = """
+ reqCheckExistId: str = """
SELECT EXISTS(
SELECT 1 FROM
""" + self.TABLEMISSION + """
WHERE
- missionId = ?
+ missionId = %s
LIMIT 1
)"""
# Exécution de la requète
@@ -163,13 +153,13 @@ class DbAdmin(dbmain.DbMain):
# Si il existe
if (reqResult[0][0]):
# Préparation de la requète pour suppression
- reqDelMission = """
+ reqDelMission: str = """
DELETE FROM
""" + self.TABLEMISSION + """
WHERE
- missionId = ?"""
+ missionId = %s"""
# Exécution de la requète
- self.exec_cmd(reqDelMission, [missionId])
+ self.exec_cmd(reqDelMission, [missionId], True)
# Retourne 1 pour réussite
return 1
else: