-
Notifications
You must be signed in to change notification settings - Fork 1
/
Database.py
59 lines (44 loc) · 1.49 KB
/
Database.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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
import psycopg2
conn = psycopg2.connect(host=##, database=##, user=##, password=##)
c = conn.cursor()
# c.execute("""CREATE TABLE activegps (
# groupid int
# )""")
# conn.commit()
#
# conn.close()
def getactivegaps():
with conn:
c.execute("SELECT groupid FROM aliag_db.taggergps")
return c.fetchall()
def activegap(chat_id):
chat_id = int(chat_id)
with conn:
c.execute(f"SELECT groupid FROM aliag_db.taggergps WHERE groupid = {chat_id}")
isthere = len(c.fetchall())
if isthere == 0:
with conn:
c.execute(f"INSERT INTO aliag_db.taggergps VALUES ({chat_id})")
return "Group added to database seccesfully🟢"
else:
return "Group has been activated before!"
def deactivegap(chat_id):
chat_id = int(chat_id)
with conn:
c.execute(f"SELECT groupid FROM aliag_db.taggergps WHERE groupid = {chat_id}")
isthere = len(c.fetchall())
if isthere != 0:
with conn:
c.execute(f"DELETE FROM aliag_db.taggergps WHERE groupid = {chat_id}")
return "Group remove from database seccesfully🔴"
else:
return "Group isn\'t active!"
def isactive(chat_id):
chat_id = int(chat_id)
with conn:
c.execute(f"SELECT groupid FROM aliag_db.taggergps WHERE groupid = {chat_id}")
isthere = len(c.fetchall())
if isthere == 0:
return False
else:
return True