82 lines
2.2 KiB
Python
82 lines
2.2 KiB
Python
import mysql.connector.locales.eng
|
|
import mysql.connector
|
|
import os
|
|
import Controller.ssh_tunnel as ssh_tunnel
|
|
|
|
filename = os.path.basename(__file__)
|
|
def ping(host):
|
|
# Führe den Ping-Befehl aus und erfasse die Ausgabe
|
|
result = os.system("ping -c 1 " + host)
|
|
if result == 0:
|
|
hostname = "172.17.1.21", 22
|
|
else:
|
|
hostname = "forward.stines.de", 2223
|
|
return hostname
|
|
|
|
|
|
def database(query,name,user):
|
|
# server.start()
|
|
print(f"{filename}-SSH Server start Port:{ssh_tunnel.server_port()}")
|
|
|
|
mydb = mysql.connector.connect(
|
|
host="127.0.0.1",
|
|
port=ssh_tunnel.server_port(),
|
|
user="root",
|
|
password="N53yBCswuawzBzS445VNAhWVMs3N59Gb9szEsrzXRBzarDqpdETpQeyt5v5CGe",
|
|
database="" + name,
|
|
auth_plugin='mysql_native_password',
|
|
)
|
|
mydb.connect()
|
|
print(f"{filename}-SQL Server Connect")
|
|
print(f"{filename}-{query}")
|
|
cursor = mydb.cursor()
|
|
if "SELECT" in query:
|
|
if user:
|
|
cursor.execute(query, user)
|
|
return cursor.fetchone()
|
|
else:
|
|
cursor.execute(query, user)
|
|
print(f"{filename}- Inside SELECT ALL")
|
|
return cursor.fetchall()
|
|
if "SHOW" in query:
|
|
cursor.execute(query)
|
|
return cursor.fetchall()
|
|
if "INSERT" in query:
|
|
cursor.execute(query)
|
|
mydb.commit()
|
|
if "UPDATE" in query:
|
|
cursor.execute(query)
|
|
mydb.commit()
|
|
mydb.close()
|
|
# server.stop()
|
|
def get_ip(query):
|
|
print(f"{filename}-GetIP")
|
|
user = ""
|
|
name = ""
|
|
return database(query, name, user)
|
|
def get_database():
|
|
name = ""
|
|
user = ""
|
|
query = 'SHOW DATABASES'
|
|
return database(query,name,user)
|
|
def create_database(query,name):
|
|
try:
|
|
user = ""
|
|
database(query,name,user)
|
|
except Exception as e:
|
|
print(f"{filename}-Ein Fehler ist aufgetreten:", str(e))
|
|
def add_user(query,name,user):
|
|
try:
|
|
database(query, name, user)
|
|
return print(f"{filename}-User Added")
|
|
except Exception as e:
|
|
print(f"{filename}-Ein Fehler ist aufgetreten:", str(e))
|
|
|
|
def get_user(query,name,user):
|
|
return database(query,name,user)
|
|
|
|
def get_cpu(query,name,cpu):
|
|
return database(query,name,cpu)
|
|
|
|
def update_cpu(query,name):
|
|
database(query,name) |