Paso 3: Prueba de concepto de la conexión a SQL con pyodbc
Esta prueba de concepto de ejemplo usa pyodbc
para conectarse a una base de datos SQL. En este ejemplo se supone que usa la base de datos de ejemplo AdventureWorksLT.
Nota:
Este ejemplo solo debe considerarse una prueba de concepto. El código de ejemplo se simplifica para mayor claridad y no representa necesariamente los procedimientos recomendados por Microsoft.
Requisitos previos
- Python 3
- Si aún no tiene Python, instale el administrador de paquetes de Python runtime y el Índice de paquetes de Python (PyPI) desde python.org.
- ¿Prefiere no usar su propio entorno? Abra como un devcontainer mediante GitHub Codespaces.
pyodbc
paquete de PyPI.- Instala Microsoft ODBC Driver 18 para SQL Server
- Una base de datos SQL y credenciales.
Conexión y consulta de datos
Conéctese a una base de datos con sus credenciales.
Cree un nuevo archivo llamado app.py.
Agregue una docstring de módulo.
""" Connects to a SQL database using pyodbc """
Importe el paquete
pyodbc
.import pyodbc
Cree variables para las credenciales de conexión.
SERVER = '<server-address>' DATABASE = '<database-name>' USERNAME = '<username>' PASSWORD = '<password>'
Cree una variable de cadena de conexión mediante la interpolación de cadenas.
connectionString = f'DRIVER={{ODBC Driver 18 for SQL Server}};SERVER={SERVER};DATABASE={DATABASE};UID={USERNAME};PWD={PASSWORD}'
Use la
pyodbc.connect
función para conectarse a una base de datos SQL.conn = pyodbc.connect(connectionString)
Ejecutar una consulta
Use una cadena de consulta SQL para ejecutar una consulta y analizar los resultados.
Cree una variable para la cadena de consulta SQL.
SQL_QUERY = """ SELECT TOP 5 c.CustomerID, c.CompanyName, COUNT(soh.SalesOrderID) AS OrderCount FROM SalesLT.Customer AS c LEFT OUTER JOIN SalesLT.SalesOrderHeader AS soh ON c.CustomerID = soh.CustomerID GROUP BY c.CustomerID, c.CompanyName ORDER BY OrderCount DESC; """
Use
cursor.execute
para recuperar un conjunto de resultados de una consulta en la base de datos.cursor = conn.cursor() cursor.execute(SQL_QUERY)
Nota:
Esta función acepta cualquier consulta y devuelve un conjunto de resultados que se puede iterar mediante el uso de cursor.fetchone().
Use
cursor.fetchall
con un loopforeach
para obtener todos los registros de la base de datos. A continuación, imprima los registros.records = cursor.fetchall() for r in records: print(f"{r.CustomerID}\t{r.OrderCount}\t{r.CompanyName}")
Guarde el archivo app.py.
Abra un terminal y pruebe la aplicación.
python app.py
29485 1 Professional Sales and Service 29531 1 Remarkable Bike Store 29546 1 Bulk Discount Store 29568 1 Coalition Bike Company 29584 1 Futuristic Bikes
Inserte una fila como transacción
En este ejemplo, se ejecuta una sentencia INSERT
de forma segura y se pasan parámetros. El paso de parámetros como valores protege la aplicación del ataque por inyección de código SQL.
Importe
randrange
desde la bibliotecarandom
.from random import randrange
Genere un número de producto aleatorio.
productNumber = randrange(1000)
Sugerencia
La generación de un número de producto aleatorio aquí garantiza que puede ejecutar este ejemplo varias veces.
Cree una cadena de instrucción SQL.
SQL_STATEMENT = """ INSERT SalesLT.Product ( Name, ProductNumber, StandardCost, ListPrice, SellStartDate ) OUTPUT INSERTED.ProductID VALUES (?, ?, ?, ?, CURRENT_TIMESTAMP) """
Ejecute la instrucción mediante
cursor.execute
.cursor.execute( SQL_STATEMENT, f'Example Product {productNumber}', f'EXAMPLE-{productNumber}', 100, 200 )
Capture la primera columna del único resultado mediante
cursor.fetchval
, imprima el identificador único del resultado y, a continuación, confirme la operación como una transacción medianteconnection.commit
.resultId = cursor.fetchval() print(f"Inserted Product ID : {resultId}") conn.commit()
Sugerencia
Opcionalmente, puede usar
connection.rollback
para revertir la transacción.Cierre el cursor y la conexión mediante
cursor.close
yconnection.close
.cursor.close() conn.close()
Guarde el archivo app.py y vuelva a probar la aplicación.
python app.py
Inserted Product ID : 1001