48 lines
1.6 KiB
Python
48 lines
1.6 KiB
Python
|
# -*- coding: utf-8 -*-
|
||
|
|
|
||
|
|
|
||
|
|
# =============================================================================
|
||
|
|
# Contiene las clases necesarias para conectar con la Base de Datos mysql.
|
||
|
|
#
|
||
|
|
# =============================================================================
|
||
|
|
|
||
|
|
import mysql.connector
|
||
|
|
|
||
|
|
|
||
|
|
class DatabaseInstance():
|
||
|
|
|
||
|
|
|
||
|
|
def __init__(self, connection_parameters):
|
||
|
|
self.host = connection_parameters['host']
|
||
|
|
self.database = connection_parameters['database']
|
||
|
|
self.user = connection_parameters['user']
|
||
|
|
self.password = connection_parameters['password']
|
||
|
|
|
||
|
|
self.connection = None
|
||
|
|
|
||
|
|
def connect(self):
|
||
|
|
try:
|
||
|
|
self.connection = mysql.connector.connect(host = self.host,
|
||
|
|
database = self.database,
|
||
|
|
user = self.user,
|
||
|
|
password = self.password)
|
||
|
|
except Error as e:
|
||
|
|
print("Could not connect to the database.")
|
||
|
|
print(e)
|
||
|
|
|
||
|
|
def disconnect(self):
|
||
|
|
if self.connection.is_connected():
|
||
|
|
self.connection.disconnect()
|
||
|
|
else:
|
||
|
|
print("Connection was not active.")
|
||
|
|
|
||
|
|
def ping(self):
|
||
|
|
self.connect()
|
||
|
|
self.disconnect()
|
||
|
|
|
||
|
|
def query(self, query, parameters):
|
||
|
|
self.connect()
|
||
|
|
if self.connection.is_connected():
|
||
|
|
cursor = self.connection.cursor()
|
||
|
|
cursor.execute()
|
||
|
|
#SEGUIR AQUIIIIIIIIIIIIIIIIIIIIIIIIIIIIIIIIIIIIIIII
|