Introducción
Contenido
Para cualquier aplicación implementable completamente funcional, la persistencia de los datos es indispensable. Una forma trivial de almacenar datos sería escribirlos en un archivo en el disco duro, pero uno preferiría escribir los datos específicos de la aplicación en una base de datos por razones obvias. Python proporciona soporte de lenguaje para escribir datos en una amplia gama de bases de datos.
API de Python DB
En el corazón del soporte de Python para la programación de bases de datos se encuentra la API Python DB (PEP – 249) que no depende de ningún motor de base de datos específico. Dependiendo de la base de datos que usemos en la capa de persistencia, se debe importar y usar en nuestro programa una implementación apropiada de Python DB API. En este tutorial, demostraremos cómo usar Python para conectarse a la base de datos MySQL y realizar transacciones con ella. Para esto, usaremos el MySQLdb Paquete de Python.
Antes de continuar con la conexión a la base de datos usando Python, necesitamos instalar el conector MySQL para Python. Esto se puede hacer de dos formas:
- Una forma es descargar el instalador apropiado para el sistema operativo y la versión de bits directamente desde el Sitio oficial de MySQL.
- Otra forma es usar pip para instalarlo.
$ pip install mysql-connector-python
Si hay una versión específica de MySQL instalada en la máquina local, entonces es posible que necesite una versión específica del conector MySQL para que no surjan problemas de compatibilidad, que podemos obtener usando el siguiente comando:
$ pip install mysql-connector-python==<insert_version_number_here>
Finalmente, necesitamos instalar el módulo de cliente MySQL que nos permitirá conectarnos a bases de datos MySQL desde nuestra aplicación Python, que actúa como cliente:
$ pip install mysqlclient
Conectarse a la base de datos
Una vez que tenemos el conector instalado en su lugar, el import MySQLdb La declaración no debería arrojar ningún error al ejecutar el archivo Python.
Prerrequisitos
Nota: Se asume que los lectores tienen un conocimiento básico de las bases de datos en general y de la base de datos MySQL en específico, junto con el conocimiento del lenguaje estructurado de consultas (SQL). Sin embargo, el proceso básico para crear una base de datos y un usuario se ha explicado en esta sección. Sigue estos pasos:
- Asegúrese de que su servidor MySQL se esté ejecutando. Esto se puede verificar a través de MySQL WorkBench -> Estado del servidor.
- Abra MySQL WorkBench o MySQL CLI. Crea una nueva base de datos. Vamos a llamarlo
pythondb.
CREATE DATABASE pythondb;
USE pythondb;
- Crea un nuevo usuario
pythonusercon contraseñapythonpwd123y otorgar acceso apythondb
CREATE USER 'pythonuser'@'localhost' IDENTIFIED BY 'pythonpwd123'
GRANT ALL PRIVILEGES ON pythondb.* To 'pythonuser'@'localhost'
FLUSH PRIVILEGES
Comprobando su conexión a pythondb
Aquí hay un script simple que se puede usar para probar mediante programación la conexión a la base de datos recién creada:
#!/usr/bin/python
import MySQLdb
dbconnect = MySQLdb.connect("localhost", "pythonuser", "pythonpwd123", "pythondb")
cursor = dbconnect.cursor()
cursor.execute("SELECT VERSION()")
data = cursor.fetchone()
if data:
print('Version retrieved: ', data)
else:
print('Version not retrieved.')
dbconnect.close()
Salida
Version retrieved: 5.7.19
El número de versión que se muestra arriba es solo un número ficticio. Debe coincidir con la versión del servidor MySQL instalado.
Echemos un vistazo más de cerca al programa de muestra anterior para aprender cómo funciona. Antes que nada, import MySQLdb se usa para importar el módulo de Python requerido.
MySQLdb.connect() El método toma el nombre de host, el nombre de usuario, la contraseña y el nombre del esquema de la base de datos para crear una conexión a la base de datos. Al conectarse correctamente con la base de datos, devolverá un objeto de conexión (que se conoce como dbconnect Aquí).
Usando el objeto de conexión, podemos ejecutar consultas, confirmar transacciones y revertir transacciones antes de cerrar la conexión.
Una vez que obtenemos el objeto de conexión, necesitamos obtener un MySQLCursor objeto para ejecutar consultas utilizando execute método. El conjunto de resultados de la transacción se puede recuperar utilizando el fetchall, fetchoneo fetchmany métodos, que se discutirán más adelante en este tutorial.
Hay tres métodos importantes relacionados con las transacciones de la base de datos además del método de ejecución. Ahora aprenderemos brevemente sobre estos métodos.
los dbconnect.commit() El método informa a la base de datos que los cambios ejecutados antes de llamar a esta función se finalizarán y no hay margen para volver al estado anterior si la transacción es exitosa.
A veces, si ocurre una falla en la transacción, tendremos que cambiar la base de datos al estado anterior antes de que ocurriera la falla para que los datos no se pierdan ni se corrompan. En tal caso, necesitaremos revertir la base de datos al estado anterior usando dbconnect.rollback().
Finalmente, el dbconnect.close() El método se utiliza para cerrar la conexión a la base de datos. Para realizar más transacciones, necesitamos crear una nueva conexión.
Crear una nueva tabla
Una vez que la conexión con pythondb se establece con éxito, estamos listos para pasar al siguiente paso. Creemos una nueva tabla en ella:
import MySQLdb
dbconnect = MySQLdb.connect("localhost","pythonuser","pythonpwd123","pythondb" )
cursor = dbconnect.cursor()
cursor.execute("DROP TABLE IF EXISTS MOVIE")
query = "CREATE TABLE MOVIE(
id int(11) NOT NULL,
name varchar(20),
year int(11),
director varchar(20),
genre varchar(20),
PRIMARY KEY (id))"
cursor.execute(query)
dbconnect.close()
Después de ejecutar el script anterior, debería poder ver una nueva tabla movie creado para el esquema pythondb. Esto se puede ver usando MySQL WorkBench.
Realización de operaciones CRUD
Ahora realizaremos algunas operaciones de inserción, lectura, modificación y eliminación en la tabla de base de datos recién creada a través del script de Python.
Crear un nuevo registro
El siguiente script demuestra cómo insertar un nuevo registro en la base de datos MySQL usando un script de Python:
#!/usr/bin/python
import MySQLdb
dbconnect = MySQLdb.connect("localhost", "pythonuser", "pythonpwd123", "pythondb")
cursor = dbconnect.cursor()
query = 'insert into movie(id, name, year, director, genre)
values (1, "Bruce Almighty", 2003, "Tom Shaydac", "Comedy")'
try:
cursor.execute(query)
dbconnect.commit()
except:
dbconnect.rollback()
finally:
dbconnect.close()
Leer filas de una tabla
Una vez que se inserta una nueva fila en la base de datos, puede obtener los datos de tres formas usando el objeto cursor:
cursor.fetchall()– se puede usar para obtener todas las filascursor.fetchmany()– se puede usar para obtener un número seleccionado de filascursor.fetchone()– se puede usar para obtener solo la primera fila del conjunto de resultados
Para simplificar, usaremos la consulta SQL «seleccionar todo» y usaremos un bucle for sobre el conjunto de resultados del fetchall método para imprimir registros individuales.
#!/usr/bin/python
import MySQLdb
dbconnect = MySQLdb.connect("localhost", "pythonuser", "pythonpwd123", "pythondb")
cursor = dbconnect.cursor()
query = "SELECT * FROM movie"
try:
cursor.execute(query)
resultList = cursor.fetchall()
for row in resultList:
print ("Movie ID =", row[0])
print ("Name =", row[1])
print ("Year =", row[2])
print ("Director = ", row[3])
print ('Genre=", row[4])
except:
print ("Encountered error while retrieving data from database")
finally:
dbconnect.close()
Salida:
Movie ID = 1
Name = Bruce Almighty
Year = 2003
Director = Tom Shaydac
Genre = Comedy
Actualizar una fila
Actualicemos ahora el género de «Bruce Almighty» de comedia a sátira:
import MySQLdb
dbconnect = MySQLdb.connect("localhost", "pythonuser", "pythonpwd123", "pythondb")
# The cursor object obtained below allows SQL queries to be executed in the database session.
cursor = dbconnect.cursor()
updatequery = "update movie set genre = "Satire' where id = 1"
cursor.execute(updatequery)
dbconnect.commit()
print(cursor.rowcount, "record(s) affected")
Salida:
1 record(s) affected
Eliminar un registro
Aquí hay una secuencia de comandos de Python que demuestra cómo eliminar una fila de la base de datos:
import MySQLdb
dbconnect = MySQLdb.connect("localhost", "pythonuser", "pythonpwd123", "pythondb")
# The cursor object obtained below allows SQL queries to be executed in the database session.
cursor = dbconnect.cursor()
updatequery = "DELETE FROM movie WHERE id = 1"
cursor.execute(updatequery)
dbconnect.commit()
print(cursor.rowcount, "record(s) deleted")
Después de ejecutar el script anterior, debería poder ver el siguiente resultado si todo va bien.
Salida
1 record(s) deleted
Conclusión
En este artículo, aprendimos cómo usar la API de Python DB para conectarse a una base de datos. Específicamente, vimos cómo se puede establecer una conexión a una base de datos MySQL usando la implementación MySQLdb de la API Python DB. También aprendimos cómo realizar transacciones con la base de datos.
