-
Notifications
You must be signed in to change notification settings - Fork 0
/
delete_member.py
34 lines (27 loc) · 1.01 KB
/
delete_member.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
import pymysql
import redis
from mysqlcursor import cur, con
# Initialize Redis client
redis_client = redis.Redis(host='localhost', port=6379, db=0)
def option_9():
"This is to delete a Player from a Clan from the database"
'''take the following as input
Player_ID\n
Clan_ID\n
'''
try:
Player_ID = input("Enter Player ID: ")
Clan_ID = input("Enter Clan ID: ")
# Check if player-clan relationship exists in Redis cache
player_clan_key = f"player_clan:{Player_ID}:{Clan_ID}"
if redis_client.exists(player_clan_key):
redis_client.delete(player_clan_key)
print("Player-Clan relationship removed from Redis cache")
query = "DELETE FROM MemberOf WHERE Player_ID = %s AND Clan_ID = %s"
cur.execute(query, (Player_ID, Clan_ID))
con.commit()
print("Deleted from database")
except Exception as e:
con.rollback()
print("Failed to delete from database")
print(">>>>>>>>>>>>>", e)