Paso 3: Prueba de concepto de la conexión a SQL con pymssql

Artículo
08/30/2023

Esta prueba de concepto de ejemplo usa pymssql 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.
  - .
pymssql paquete de PyPI.
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 pymssql
"""

Importe el paquete pymssql.
```
import pymssql
```

Use la pymssql.connect función para conectarse a una base de datos SQL.

conn = pymssql.connect(
    server='<server-address>',
    user='<username>',
    password='<password>',
    database='<database-name>',
    as_dict=True
)

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 loop foreach 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 biblioteca random.
```
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 (%s, %s, %s, %s, CURRENT_TIMESTAMP)
"""

Ejecute la instrucción mediante cursor.execute.

cursor.execute(
    SQL_STATEMENT,
    (
        f'Example Product {productNumber}', 
        f'EXAMPLE-{productNumber}', 
        100,
        200
    )
)

Capture el único resultado mediante cursor.fetchone, imprima el identificador único del resultado y, a continuación, confirme la operación como una transacción mediante connection.commit.
```
result = cursor.fetchone()
print(f"Inserted Product ID : {result['ProductID']}")
conn.commit()
```
Sugerencia

Opcionalmente, puede usar connection.rollback para revertir la transacción.
Cierre el cursor y la conexión mediante cursor.close y connection.close.
```
cursor.close()
conn.close()
```
Guarde el archivo app.py y vuelva a probar la aplicación.
```
python app.py
```
```
Inserted Product ID : 1001
```

Pasos siguientes

Centro para desarrolladores de Python

Compartir a través de