1
- import pymysql , datetime , socket
1
+ import pymysql , psycopg2 , datetime , socket
2
2
3
3
host_ = socket .gethostbyname (socket .gethostname ())
4
4
port_ = 80 # Default XAMPP Apache server port.
7
7
db_ = None
8
8
creds_ = ""
9
9
cursor_ = "DEFAULT"
10
+ mode_ = "MySQL"
10
11
11
12
# Make this differently, for the love of god!
12
- def bake (host = host_ , port = port_ , user = user_ , pasw = pasw_ , db = db_ , creds = creds_ , cursor = cursor_ ):
13
- global host_ , port_ , user_ , pasw_ , db_ , creds_ , cursor_
13
+ def bake (host = host_ , port = port_ , user = user_ , pasw = pasw_ , db = db_ , creds = creds_ , cursor = cursor_ , mode = mode_ ):
14
+ global host_ , port_ , user_ , pasw_ , db_ , creds_ , cursor_ , mode_
14
15
if host != "" : host_ = host
15
16
if port != "" : port_ = port
16
17
if user != "" : user_ = user
17
18
if pasw != "" : pasw_ = pasw
18
19
if db != "" : db_ = db
19
20
if creds != "" : creds_ = creds
20
21
if cursor != "" : cursor_ = cursor
22
+ if mode != "" : mode_ = mode
21
23
22
24
# A query.
23
25
def query (query ):
24
- conn = pymysql .connect (host = host_ , port = port_ , user = user_ , passwd = pasw_ , db = db_ )
26
+ if (mode_ == "MySQL" ):
27
+ conn = pymysql .connect (host = host_ , port = port_ , user = user_ , passwd = pasw_ , db = db_ )
28
+ elif (mode_ == "PostgreSQL" ):
29
+ conn = psycopg2 .connect (host = host_ , port = port_ , user = user_ , password = pasw_ , database = db_ )
25
30
conn_object = conn .cursor (pymysql .cursors .DictCursor ) if cursor_ == "DICTIONARY" else conn .cursor ()
26
31
conn_object .execute (query )
27
32
response = conn_object .fetchall ()
@@ -30,6 +35,18 @@ def query(query):
30
35
conn .close ()
31
36
return response
32
37
38
+ # Test your connection with your database.
39
+ def test ():
40
+ try :
41
+ if (mode_ == "MySQL" ):
42
+ conn = pymysql .connect (host = host_ , port = port_ , user = user_ , passwd = pasw_ , db = db_ )
43
+ elif (mode_ == "PostgreSQL" ):
44
+ conn = psycopg2 .connect (host = host_ , port = port_ , user = user_ , password = pasw_ , database = db_ )
45
+ print (f"Successful connection at: { host_ } " )
46
+ except Exception as ex :
47
+ print (f"Connection error at: { host_ } " )
48
+ print (ex )
49
+
33
50
# Call a stored procedure.
34
51
def call (func , * args ):
35
52
call = "CALL " + func + "("
0 commit comments