64 lines
1.7 KiB
Python
64 lines
1.7 KiB
Python
import mysql.connector
|
|
import mysql.connector.locales.eng.client_error
|
|
from sshtunnel import SSHTunnelForwarder
|
|
|
|
server = SSHTunnelForwarder(
|
|
('forward.stines.de', 2223),
|
|
ssh_username="root",
|
|
ssh_password="adm.3dfx12",
|
|
remote_bind_address=('127.0.0.1', 3306)
|
|
)
|
|
def database(query,name,user):
|
|
server.start()
|
|
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()
|
|
server.stop()
|
|
def get_ip(query,name):
|
|
print("GetIP")
|
|
user = ""
|
|
return database(query, name,user)
|
|
def get_database():
|
|
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))
|
|
|
|
def get_user(query,name,user):
|
|
try:
|
|
database(query,name,user)
|
|
return (user)
|
|
except Exception as e:
|
|
print("Ein Fehler ist aufgetreten:", str(e))
|