Rövid útmutató: Csatlakozás a Python pymssql-illesztőprogramjával

Ebben a rövid útmutatóban egy Python-szkriptet csatlakoztat egy adatbázishoz, amelyet ön hozott létre és töltött be mintaadatokkal. A Python illesztőprogramját pymssql használva csatlakozhat az adatbázishoz, és alapvető műveleteket hajthat végre, például az adatok olvasását és írását.

a pymssql dokumentációja | pymssql-forráskód | Csomag (PyPi)

Előfeltételek

Python 3
- Ha még nem rendelkezik Pythonnal, telepítse a Python futtatókörnyezetet és a Python-csomagindexet (PyPI) csomagkezelőtpython.org.
- Nem szeretné a saját környezetét használni? Nyissa meg devcontainerként a GitHub Codespaces használatával.
pymssql csomag a PyPI-ból.
Sql Serveren, Azure SQL Database-en vagy SQL Database-adatbázison a Fabricben a AdventureWorks2025 mintasémával és egy érvényes kapcsolati sztringgel.

Előkészítés

Ezeket a lépéseket követve konfigurálhatja a fejlesztési környezetet egy alkalmazás Python-illesztőprogram használatával pymssql történő fejlesztéséhez.

Megjegyzés:

Ez az illesztőprogram a Tabular Data Stream (TDS) protokollt használja, amely alapértelmezés szerint engedélyezve van az SQL Serverben, az SQL Database-ben a Fabricben és az Azure SQL Database-ben. Nincs szükség további konfigurációra.

A pymssql-csomag telepítése

Szerezze be a pymssql csomagot a PyPI-ból.

Nyisson meg egy parancssort egy üres könyvtárban.
Telepítse az pymssql csomagot.
```
pip install pymssql
```

Python-dotenv-csomag telepítése

Szerezze be a python-dotenv a PyPI-ról.

Ugyanabban a könyvtárban telepítse a python-dotenv csomagot.
```
pip install python-dotenv
```

Telepített csomagok ellenőrzése

A PyPI parancssori eszközével ellenőrizheti, hogy a tervezett csomagok telepítve vannak-e.

Ellenőrizze a telepített csomagok listáját a következővel pip list: .
```
pip list
```

SQL-adatbázis létrehozása

Ehhez a gyorsindítási útmutatóhoz az AdventureWorks2025 Lightweight sémára van szükség a Microsoft SQL Serveren, a Fabric SQL-adatbázisban vagy az Azure SQL Database-ben.

SQL-adatbázis létrehozása percek alatt az Azure Portal használatával

Új fájl létrehozása

Hozzon létre egy app.pynevű új fájlt.

Modul-dokumentáció hozzáadása.

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

Csomagok importálása, beleértve a pymssql.

from os import getenv
from dotenv import load_dotenv
from pymssql import connect

Használja a pymssql.connect függvényt, hogy csatlakozzon egy SQL-adatbázishoz.

load_dotenv()
conn = connect(getenv("SQL_SERVER"),getenv("SQL_USER"),getenv("SQL_PASSWORD"),getenv("SQL_DATABASE"))

Az aktuális könyvtárban hozzon létre egy új fájlt..env
A .env fájlon belül adja hozzá az alábbi nevű kapcsolati sztring értékek bejegyzéseit: SQL_SERVER, SQL_USER, SQL_PASSWORD, SQL_DATABASE. Cserélje le a helyőrzőket a tényleges kapcsolati sztringértékekre.
```
SQL_SERVER="<server_name>"
SQL_USER="<sql_user_name>"
SQL_PASSWORD="<sql_user_password>"
SQL_DATABASE="<sql_database>"
```
Jótanács

Az itt használt kapcsolati sztring nagyban függ attól, hogy milyen TÍPUSÚ SQL-adatbázishoz csatlakozik. A kapcsolati sztringekről és azok szintaxisáról további információt a FreeTDS kapcsolati attribútumai című témakörben talál.

Lekérdezés végrehajtása

Sql-lekérdezési sztring használatával hajthat végre egy lekérdezést, és elemezheti az eredményeket.

Hozzon létre egy változót az SQL-lekérdezési sztringhez.

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;
"""

Az cursor.execute segítségével egy eredményhalmazt kérhetünk le a lekérdezésből az adatbázison.
```
cursor = conn.cursor(as_dict=True)
cursor.execute(SQL_QUERY)
```
Megjegyzés:

Ez a függvény lényegében minden lekérdezést elfogad, és eredményhalmazt ad vissza, amely a cursor.fetchone() használatával iterálható át.
foreach Az adatbázis összes rekordjának lekéréséhez használjon hurkot. Ezután nyomtassa ki a rekordokat.
```
for r in cursor:
    print(f"{r['CustomerID']}\t{r['OrderCount']}\t{r['CompanyName']}")
```
Mentse a app.py fájlt.

Nyisson meg egy terminált, és tesztelje az alkalmazást.

python app.py

Itt a várt kimenet.

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

Sor beszúrása tranzakcióként

Biztonságosan hajthat végre egy INSERT utasítást, és paramétereket adhat át. A paraméterek értékként való átadása megvédi az alkalmazást az SQL-injektálási támadásoktól.

Importálás hozzáadása a randrange számára a random könyvtárból a app.py elejére.
```
from random import randrange
```
A app.py végén adjon hozzá kódot egy véletlenszerű termékszám generálásához.
```
productNumber = randrange(1000)
```
Jótanács

Ha véletlenszerű termékszámot hoz létre, az biztosítja, hogy ezt a mintát többször is futtathatja.

SQL utasításszöveg létrehozása.

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

Hajtsa végre az utasítást a következővel cursor.execute: .

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

Az egyetlen eredményt olvasd be cursor.fetchone, nyomtasd ki az eredmény egyedi azonosítóját, majd véglegesítsd a műveletet tranzakcióként connection.commit.
```
result = cursor.fetchone()
print(f"Inserted Product ID : {result['ProductID']}")
conn.commit()
```
Jótanács

connection.rollback Lehetőség van a tranzakció visszaállítására is.
Zárja be a kurzort és a kapcsolatot a cursor.close és connection.close segítségével.
```
cursor.close()
conn.close()
```
Mentse a app.py fájlt, és tesztelje újra az alkalmazást.
```
python app.py
```
Itt a várt kimenet.
```
Inserted Product ID : 1001
```

Következő lépés

Látogasson el az pymssql illesztőprogram GitHub-adattárába további példákért, ötletek megosztásához, vagy problémák jelentéséhez.

pymssql-illesztő a GitHubon

Visszajelzés

Hasznosnak találta ezt az oldalt?

Last updated on 2025-11-29