Etapa 3: Prova de conceito da conexão ao SQL usando pymssql

Artigo
08/28/2023

Este exemplo de prova de conceito é usado pymssql para se conectar a um banco de dados SQL. Este exemplo pressupõe que você esteja usando o banco de dados de exemplo AdventureWorksLT.

Observação

Este exemplo só deve ser considerado como uma prova de conceito. O código de exemplo está simplificado para fins de clareza e não necessariamente representa as melhores práticas recomendadas pela Microsoft.

Pré-requisitos

Python 3
- Se você ainda não possui o Python, instale o runtime do Python e o gerenciador de pacotes Índice de Pacotes do Python (PyPI) de python.org.
- Prefere não usar seu próprio ambiente? Abra como um devcontainer usando o GitHub Codespaces.
  - .
Pacote pymssql do PyPI.
Um banco de dados SQL e credenciais.

Conectar e pesquisar dados

Conecte-se a um banco de dados usando suas credenciais.

Crie um novo arquivo chamado app.py.

Adicione um módulo docstring.

"""
Connects to a SQL database using pymssql
"""

Importar o pacote pymssql.
```
import pymssql
```

Use a pymssql.connect função para se conectar a um banco de dados SQL.

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

Executar uma consulta

Use uma cadeia de caracteres de consulta SQL para executar uma consulta e analisar os resultados.

Crie uma variável para a cadeia de caracteres 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 um conjunto de resultados de uma consulta em relação ao banco de dados.
```
cursor = conn.cursor()
cursor.execute(SQL_QUERY)
```
Observação

Essencialmente, essa função aceita qualquer consulta e retorna um conjunto de resultados que pode ser iterado com o uso de cursor.fetchone().

Use cursor.fetchall com um loop foreach para obter todos os registros do banco de dados. Em seguida, imprima os registros.

records = cursor.fetchall()
for r in records:
    print(f"{r['CustomerID']}\t{r['OrderCount']}\t{r['CompanyName']}")

Salve o arquivo app.py.

Abra um terminal e teste o aplicativo.

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

Inserir uma linha como uma transação

Neste exemplo, você verá como executar uma instrução INSERT com segurança e passar parâmetros. Passar parâmetros como valores protege seu aplicativo contra ataques de injeção de SQL.

Importe randrange da biblioteca random.
```
from random import randrange
```
Gere um número de produto aleatório.
```
productNumber = randrange(1000)
```
Dica

Gerar um número de produto aleatório aqui garante que você possa executar essa amostra várias vezes.

Crie uma cadeia de caracteres de instrução SQL.

SQL_STATEMENT = """
INSERT SalesLT.Product (
Name, 
ProductNumber, 
StandardCost, 
ListPrice, 
SellStartDate
) OUTPUT INSERTED.ProductID 
VALUES (%s, %s, %s, %s, CURRENT_TIMESTAMP)
"""

Execute a instrução usando cursor.execute.

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

Busque o resultado único usando cursor.fetchone, imprima o identificador exclusivo do resultado e confirme a operação como uma transação usando connection.commit.
```
result = cursor.fetchone()
print(f"Inserted Product ID : {result['ProductID']}")
conn.commit()
```
Dica

Opcionalmente, você pode usar connection.rollback para reverter a transação.
Feche o cursor e a conexão usando cursor.close e connection.close.
```
cursor.close()
conn.close()
```
Salve o arquivo app.py e teste o aplicativo novamente
```
python app.py
```
```
Inserted Product ID : 1001
```

Próximas etapas

Centro de desenvolvedores do Python.

Partilhar via