diff --git a/Python/Semana 10/conexion.py b/Python/Semana 10/conexion.py index e7016e9..0de6b5f 100644 --- a/Python/Semana 10/conexion.py +++ b/Python/Semana 10/conexion.py @@ -3,6 +3,7 @@ from logger_base import log import sys + class Conexion: _DATABASE = 'test_bd' _USERNAME = 'postgres' @@ -11,8 +12,7 @@ class Conexion: _HOST = '127.0.0.1' _MIN_CON = 1 _MAX_CON = 5 - _Pool = None - + _pool = None @classmethod def obtenerConexion(cls): @@ -20,7 +20,6 @@ def obtenerConexion(cls): log.debug(f'Conexion obtenida del pool: {conexion}') return conexion - @classmethod def obtenerCursor(cls): pass @@ -29,13 +28,13 @@ def obtenerCursor(cls): def obtenerPool(cls): if cls._pool is None: try: - cls._pool = pool._simpleConnectionPool(cls._MIN_CON, - cls._MAX_CON, - host=cls._HOST, - User=cls._USERNAME, - password=cls._PASSWORD, - port=cls._BD_PORT, - database=cls._DATABASE) + cls._pool = pool.SimpleConnectionPool(cls._MIN_CON, + cls._MAX_CON, + host=cls._HOST, + user=cls._USERNAME, + password=cls._PASSWORD, + port=cls._BD_PORT, + database=cls._DATABASE) log.debug(f'creacion del pool exitosa: {cls._pool}') return cls._pool except Exception as e: @@ -45,12 +44,9 @@ def obtenerPool(cls): return cls._pool - if __name__ == ' __main__ ': conexion1 = Conexion.obtenerConexion() conexion2 = Conexion.obtenerConexion() conexion3 = Conexion.obtenerConexion() conexion4 = Conexion.obtenerConexion() - conexion5 = Conexion.obtenerConexion() - - + conexion5 = Conexion.obtenerConexion() \ No newline at end of file diff --git a/Python/Semana 10/persona_dao.py b/Python/Semana 10/persona_dao.py index 245e9bc..3206283 100644 --- a/Python/Semana 10/persona_dao.py +++ b/Python/Semana 10/persona_dao.py @@ -1,5 +1,5 @@ -from Persona import Persona -from conexion import Conexion +from Persona import * +from conexion import * from logger_base import log @@ -12,8 +12,8 @@ class personaDAO: Update ->Actualizar Delete -> Eliminar """ - _SELECCIONAR = 'SELECT * FROM persona ORDER BY id_Personar' - _INSERTAR = 'INSERT INTO persona(nombre, apellido, email) VALUES (%s, %s, %S)' + _SELECCIONAR = 'SELECT * FROM persona ORDER BY id_persona' + _INSERTAR = 'INSERT INTO persona(nombre, apellido, email) VALUES (%s, %s, %s)' _ACTUALIZAR = 'UPDATE persona SET nombre=%s, apellido=%s, email=%s WHERE id_persona=%s' _ELIMINAR = 'DELETE FROM persona WHERE id_persona=%s' @@ -60,18 +60,18 @@ def eliminar(cls, persona): if __name__ == '__main__': # Eliminar un registro - persona1 = Persona(id_persona=8) + # persona1 = Persona(id_persona=8) # Actualizar un registro -# persona1 = Persona(1, 'Juan jose', 'pena', 'jjpena@mail.com') -# personas_actualizadas = personaDAO.actualizar(persona1) -# log.debug(f'Personas actualizadas: {personas_actualizadas}') + # persona1 = Persona(1, 'Juan jose', 'pena', 'jjpena@mail.com') + # personas_actualizadas = personaDAO.actualizar(persona1) + # log.debug(f'Personas actualizadas: {personas_actualizadas}') -# Insertar un registro -# persona1 = Persona(nombre = 'Omero', apellido= 'Ramos',email= 'omeror@mail.com') -# personas_insertadas = personaDAO.insertar(persona1) -# log.debug(f'Personas insertadas: {personas_insertadas}') + # Insertar un registro + # persona1 = Persona(nombre = 'Omero', apellido= 'Ramos',email= 'omeror@mail.com') + # personas_insertadas = personaDAO.insertar(persona1) + # log.debug(f'Personas insertadas: {personas_insertadas}') # Seleccionamos objetos -personas = personaDAO.seleccionar() -for persona in personas: - log.debug(persona) + personas = personaDAO.seleccionar() + for persona in personas: + log.debug(persona) diff --git a/Python/Semana 9/__pycache__/logger_base.cpython-310.pyc b/Python/Semana 9/__pycache__/logger_base.cpython-310.pyc new file mode 100644 index 0000000..9dcdba1 Binary files /dev/null and b/Python/Semana 9/__pycache__/logger_base.cpython-310.pyc differ diff --git a/Python/Semana 9/conexion.py b/Python/Semana 9/conexion.py index 8d0277a..940f476 100644 --- a/Python/Semana 9/conexion.py +++ b/Python/Semana 9/conexion.py @@ -3,6 +3,7 @@ from logger_base import log import sys + class Conexion: _DATABASE = 'test_bd' _USERNAME = 'postgres' @@ -16,11 +17,11 @@ class Conexion: def obtenerConexion(cls): if cls._conexion is None: try: - cls._conexion = bd.connect(host=cls._HOST, - user=cls._USERNAME, - password=cls._PASSWORD, - port=cls._BD_PORT, - database=cls._DATABASE) + cls._conexion = bd.connect(host=cls._HOST, + user=cls._USERNAME, + password=cls._PASSWORD, + port=cls._BD_PORT, + database=cls._DATABASE) log.debug(f'Conexion Exitosa: {cls._conexion}') return cls._conexion except Exception as e: @@ -29,8 +30,6 @@ def obtenerConexion(cls): else: return cls._conexion - - @classmethod def obtenerCursor(cls): if cls._cursor is None: @@ -42,7 +41,8 @@ def obtenerCursor(cls): log.error(f'Ocurrio un error: {e}') sys.exit() else: - return cls._cursor + return cls._cursor + if __name__ == ' __main__ ': Conexion.obtenerConexion() diff --git a/Python/Semana 9/persona_dao.py b/Python/Semana 9/persona_dao.py index 245e9bc..df2c5fd 100644 --- a/Python/Semana 9/persona_dao.py +++ b/Python/Semana 9/persona_dao.py @@ -2,7 +2,6 @@ from conexion import Conexion from logger_base import log - class personaDAO: """" DAO significa: Data Access Object @@ -75,3 +74,4 @@ def eliminar(cls, persona): personas = personaDAO.seleccionar() for persona in personas: log.debug(persona) + \ No newline at end of file