-
-
ssh_tunnel
+
+
sshtunnel
SourceModule
@@ -12820,7 +12908,6 @@ imports:
imported by:
adcontroller_export
•
exchange_export
- •
main.py
•
os
•
paramiko.proxy
•
platform
@@ -12913,7 +13000,9 @@ imported by:
•
shlex
•
shutil
•
socket
+ •
socketserver
•
sre_compile
+ •
sshtunnel
•
ssl
•
subprocess
•
tarfile
@@ -13075,6 +13164,8 @@ imported by:
•
queue
•
requests.auth
•
requests.cookies
+ •
socketserver
+ •
sshtunnel
•
subprocess
•
urllib3._collections
•
zipfile
@@ -13125,6 +13216,7 @@ imported by:
•
requests.auth
•
requests.cookies
•
requests.sessions
+ •
socketserver
•
ssl
•
subprocess
•
tarfile
@@ -13199,6 +13291,7 @@ imported by:
•
main.py
•
paramiko.util
•
py_compile
+ •
socketserver
•
threading
•
warnings
@@ -14559,6 +14652,7 @@ imported by:
•
requests.utils
•
shlex
•
sre_parse
+ •
sshtunnel
•
ssl
•
subprocess
•
tempfile
diff --git a/dist/main.exe b/dist/main.exe
index 4e90102..0d9decf 100644
Binary files a/dist/main.exe and b/dist/main.exe differ
diff --git a/main.py b/main.py
index 3e4d15b..aaa0e91 100644
--- a/main.py
+++ b/main.py
@@ -78,8 +78,8 @@ def gucamole(ip,servername):
# query = "SELECT * FROM `Stines-GmbH`.`Kunden-Server` WHERE `IP-Adresse` = ""'{}'""".format(get_local_ip())
query = "SELECT * FROM `Stines-GmbH`.`Kunden-Server` WHERE `IP-Adresse` = ""'{}'""".format("172.18.1.3")
-
-list = mysql_connect.get_ip(query)
+name = "Stines-GmbH"
+list = mysql_connect.get_ip(query,name)
# Ergebnisse durchlaufen und ausgeben
for row in list:
diff --git a/mysql_connect.py b/mysql_connect.py
index d3ac935..a5ec5f9 100644
--- a/mysql_connect.py
+++ b/mysql_connect.py
@@ -10,36 +10,47 @@ server = SSHTunnelForwarder(
)
server.start()
print(server.local_bind_port)
-mydb = mysql.connector.connect(
- host="127.0.0.1",
- port=server.local_bind_port,
- user="root",
- password="N53yBCswuawzBzS445VNAhWVMs3N59Gb9szEsrzXRBzarDqpdETpQeyt5v5CGe",
- database="Stines-GmbH"
-)
-def get_ip(query):
+def database(query,name,user):
+ mydb = mysql.connector.connect(
+ host="127.0.0.1",
+ port=server.local_bind_port,
+ user="root",
+ password="N53yBCswuawzBzS445VNAhWVMs3N59Gb9szEsrzXRBzarDqpdETpQeyt5v5CGe",
+ database="" + name
+ )
+ mydb.connect()
+ cursor = mydb.cursor()
+ if user:
+ cursor.execute(query,user)
+ else:
+ cursor.execute(query)
+ if "INSERT" in query:
+ mydb.commit()
+ if "SELECT" in query:
+ return cursor.fetchall()
+ if "SHOW" in query :
+ return cursor.fetchall()
+ # mydb.close()
+def get_ip(query,name):
print("GetIP")
- mydb.connect()
- cursor = mydb.cursor()
- cursor.execute(query)
- mydb.close()
- return cursor.fetchall()
+ user = ""
+ return database(query, name,user)
def get_database():
- cursor = mydb.cursor()
- cursor.execute('SHOW DATABASES')
- return cursor.fetchall()
-def create_database(query):
- print(query)
- cursor = mydb.cursor()
- cursor.execute(query)
- mydb.commit()
- mydb.close()
- return ("Database Created")
-def add_user(query, user):
- print("add_user")
- mydb.connect()
- cursor = mydb.cursor()
- cursor.execute(query, user)
- mydb.commit()
- mydb.close()
- return ("user Addet")
\ No newline at end of file
+ name = ""
+ user = ""
+ query = 'SHOW DATABASES'
+ print(database(query,name,user))
+ return database(query,name,user)
+def create_database(query,name):
+ try:
+ user = ""
+ database(query,name,user)
+ return ("Database Created")
+ except Exception as e:
+ print("Ein Fehler ist aufgetreten:", str(e))
+def add_user(query,name,user):
+ try:
+ database(query,name,user)
+ return ("user Addet")
+ except Exception as e:
+ print("Ein Fehler ist aufgetreten:", str(e))
\ No newline at end of file
diff --git a/rds_export.py b/rds_export.py
index 91fa539..a3c70bb 100644
--- a/rds_export.py
+++ b/rds_export.py
@@ -17,7 +17,8 @@ def rds (ip,name):
create_table_query += f"`{field}` TEXT, "
create_table_query = create_table_query.rstrip(", ") + ")"
create_table_query += " ROW_FORMAT=DYNAMIC"
- mysql_connect.create_database(create_table_query)
+ user = ""
+ mysql_connect.create_database(create_table_query,name)
for line in output_lines:
parts = line.split()
@@ -31,4 +32,4 @@ def rds (ip,name):
unix_time = int(datetime.now().timestamp())
user = [unix_time] + user
insert_query = f"INSERT INTO `{table_name}` (importdate, `{'`, `'.join(fieldname)}`) VALUES (%s, {', '.join(['%s'] * len(fieldname))})"
- mysql_connect.add_user(insert_query, user)
\ No newline at end of file
+ mysql_connect.add_user(insert_query,name, user)
\ No newline at end of file