sebastian.serfling
/
REPORTS
1
0
Fork 0
Code Issues 2 Pull Requests Packages Projects 1 Releases Wiki Activity

ADD mysql_connect.py

main
Sebastian Serfling 2023-07-24 16:42:11 +02:00
parent 90c1bb4f04
commit 56ad8924e0
1 changed files with 10 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
main.py
View File

@ -7,7 +7,8 @@ import adcontroller_export
import exchange_export import exchange_export
import smtp_export import smtp_export
import rds_export import rds_export
import ssh_tunnel
import mysql_connect
def get_local_ip(): def get_local_ip():
try: try:
# Socket erstellen, um die lokale IP-Adresse zu ermitteln # Socket erstellen, um die lokale IP-Adresse zu ermitteln
@ -80,29 +81,22 @@ def gucamole(ip,servername):
print("" + ip + servername) print("" + ip + servername)
# Verbindung zur Datenbank herstellen # Verbindung zur Datenbank herstellen
mydb = mysql.connector.connect( # SSH Tunnel aufbauen
host="172.17.1.21", ssh_tunnel.create_ssh_tunnel()
user="root",
password="N53yBCswuawzBzS445VNAhWVMs3N59Gb9szEsrzXRBzarDqpdETpQeyt5v5CGe",
database="Stines-GmbH"
)
cursor = mydb.cursor() query = "SELECT * FROM `Stines-GmbH`.`Kunden-Server` WHERE `IP-Adresse` = ""'{}'""".format(get_local_ip())
list = mysql_connect.get_ip(query)
print(get_local_ip())
query = "SELECT * FROM `Stines-GmbH`.`Kunden-Server` WHERE `IP-Adresse` = %s"
cursor.execute(query, (get_local_ip(),))
results = cursor.fetchall()
# Ergebnisse durchlaufen und ausgeben # Ergebnisse durchlaufen und ausgeben
for row in results: for row in list:
name = row[1] name = row[1]
ipadress = row[3] ipadress = row[3]
lastchange = row[5] lastchange = row[5]
funktion = row[6] funktion = row[6]
token = row[7] token = row[7]
print(name)
cursor.execute("SHOW DATABASES") cursor = mysql_connect.get_database()
# Überprüfen, ob die Datenbank bereits existiert # Überprüfen, ob die Datenbank bereits existiert
database_exists = False database_exists = False
@ -128,4 +122,4 @@ for row in results:
print("Die Funktion existiert nicht.") print("Die Funktion existiert nicht.")
# Verbindung schließen # Verbindung schließen
mydb.close() ssh_tunnel.close_ssh_tunnel()