Adatok lekérdezése mssql-python segítségével

Az mssql-python illesztőprogram több behozási módszert, sorhozzáférési mintákat és kurzornavigációs funkciót kínál a lekérdezési eredmények lekéréséhez.

Lekérési módszerek

A SELECT lekérdezés végrehajtása után használj fetch metódusokat az eredmények lekérésére.

fetchone()

Egyetlen sort ad vissza, vagy None ha nincs több sor elérhető:

cursor.execute("SELECT ProductID, Name, ListPrice FROM Production.Product")

row = cursor.fetchone()
while row:
    print(f"{row.ProductID}: {row.Name} - ${row.ListPrice}")
    row = cursor.fetchone()

fetchmany()

Visszaad egy sorlistát. cursor.arraysize A alapértelmezett batch méretet (alapértelmezett: 1) szabályozza:

cursor.execute("SELECT * FROM Production.Product")
cursor.arraysize = 100  # Fetch 100 rows at a time

while True:
    rows = cursor.fetchmany()
    if not rows:
        break
    for row in rows:
        print(row.Name)

A méretet közvetlenül is megadhatod:

rows = cursor.fetchmany(50)  # Fetch up to 50 rows

fetchall()

Minden megmaradt sort listaként adja vissza:

cursor.execute("SELECT * FROM Production.Product WHERE Color = 'Black'")
rows = cursor.fetchall()

print(f"Found {len(rows)} products")
for row in rows:
    print(row.Name)

fetchval()

Az első sor első oszlopát adja vissza, ami hasznos skaláris lekérdezésekhez.

count = cursor.execute("SELECT COUNT(*) FROM Production.Product").fetchval()
print(f"Total products: {count}")

max_price = cursor.execute("SELECT MAX(ListPrice) FROM Production.Product").fetchval()
print(f"Highest price: ${max_price}")

Sorelérési minták

Az Row osztály több hozzáférési mintát támogat.

Index-hozzáférés

Az oszlopok elérése pozíció szerint (nullától indexelve):

cursor.execute("SELECT ProductID, Name, ListPrice FROM Production.Product WHERE ProductID < 5")
row = cursor.fetchone()

product_id = row[0]
name = row[1]
price = row[2]

Attribútum elérése

Oszlopok elérése név alapján:

cursor.execute("SELECT ProductID, Name, ListPrice FROM Production.Product WHERE ProductID < 5")
row = cursor.fetchone()

product_id = row.ProductID
name = row.Name
price = row.ListPrice

Kisbetűs oszlopnevek

Engedélyezd a kisbetűs attribútumneveket globálisan:

import mssql_python

settings = mssql_python.get_settings()
settings.lowercase = True

cursor.execute("SELECT ProductID, Name FROM Production.Product WHERE ProductID < 5")
row = cursor.fetchone()
print(row.productid, row.name)  # Lowercase access
settings.lowercase = False  # Restore default

Iteration

A sorok támogatják az értékek feletti iterációt:

cursor.execute("SELECT ProductID, Name, ListPrice FROM Production.Product WHERE ProductID < 5")
row = cursor.fetchone()

for value in row:
    print(value)

Kurzor iteráció

Iterálj közvetlenül a kurzoron a sorok feldolgozásához:

cursor.execute("SELECT * FROM Production.Product")

for row in cursor:
    print(row.Name)

Ez a minta egyenértékű azzal, ha ismételten hívnánk fetchone() .

Oszlop metaadatok

Az oszlop adatai a(z) cursor.description segítségével érhetők el:

cursor.execute("SELECT ProductID, Name, ListPrice FROM Production.Product WHERE ProductID < 5")

for col in cursor.description:
    name, type_code, display_size, internal_size, precision, scale, null_ok = col
    print(f"Column: {name}, Type: {type_code}, Nullable: {null_ok}")

Sorok száma

Az cursor.rowcount attribútum a következőket jelzi:

  • SELECT esetén: a execute() után –1 értéket ad vissza, amíg a lekérés el nem kezdődik. Miután megkezded a lekérést, az érték az addig lekért sorok összesített számát mutatja.
  • A(z) INSERT/UPDATE/DELETE esetén: az érintett sorok száma.
cursor.execute("SELECT * FROM Production.Product")
print(f"Rows returned: {cursor.rowcount}")

cursor.execute("CREATE TABLE #PriceUpd (Name NVARCHAR(50), Price DECIMAL(10,2), CategoryID INT)")
cursor.execute("INSERT INTO #PriceUpd VALUES ('A',10,1),('B',20,1),('C',30,2)")
cursor.execute("UPDATE #PriceUpd SET Price = Price * 1.1 WHERE CategoryID = 1")
print(f"Rows updated: {cursor.rowcount}")

Kurzor navigáció

skip()

Ugratd át a sorokat anélkül, hogy behoznád őket:

cursor.execute("SELECT * FROM Production.Product ORDER BY ProductID")
cursor.skip(10)  # Skip first 10 rows
row = cursor.fetchone()  # Returns 11th row

görgetés()

Haladj előre a kurzor pozíciójával:

cursor.execute("SELECT * FROM Production.Product ORDER BY ProductID")

# Move forward 5 rows from current position
cursor.scroll(5, mode='relative')

row = cursor.fetchone()

Megjegyzés:

Az illesztőprogram csak a mode='relative' pozitív értékeit támogatja. Az abszolút pozicionálás és hátrafelé görgetés növeli NotSupportedError , mert a driver csak előre mutató kurzorokat használ.

sorszám

Kövesd a jelenlegi helyzetet:

cursor.execute("SELECT * FROM Production.Product")

print(f"Initial position: {cursor.rownumber}")  # -1 (before first fetch)

row = cursor.fetchone()
print(f"After fetchone: {cursor.rownumber}")    # 0 (first row fetched)

Több eredményhalmaz

Több eredményhalmaz feldolgozásához használják nextset() :

cursor.execute("""
    SELECT * FROM Production.Product WHERE Color = 'Black';
    SELECT * FROM Production.ProductCategory;
    SELECT COUNT(*) FROM Production.Product;
""")

# First result set
products = cursor.fetchall()
print(f"Products: {len(products)}")

# Move to second result set
if cursor.nextset():
    categories = cursor.fetchall()
    print(f"Categories: {len(categories)}")

# Move to third result set
if cursor.nextset():
    count = cursor.fetchval()
    print(f"Total count: {count}")

Nagy eredményhalmazok

Nagy eredményhalmazok esetén dolgozz sorokat csomagokban a memória kezelésére:

def process_batch(rows):
    # Example: print each row. Replace with your own logic.
    for row in rows:
        print(row)

cursor.execute("SELECT * FROM LargeTable")
cursor.arraysize = 1000

while True:
    rows = cursor.fetchmany()
    if not rows:
        break

    process_batch(rows)
    print(f"Processed {cursor.rownumber} rows so far")

Környezetkezelők

Használjon kontextuskezelőket az automatikus erőforrás-tisztításhoz:

with mssql_python.connect(connection_string) as conn:
    with conn.cursor() as cursor:
        cursor.execute("SELECT * FROM Production.Product")
        for row in cursor:
            print(row.Name)
# Cursor and connection closed automatically

Bevált gyakorlatok

  • Nagy eredményekhez használdfetchmany(), hogy elkerüld a memóriába való betöltést.
  • Zárd le a kurzorokat, miután végeztél, hogy felszabadítsd a kiszolgáló erőforrásait.
  • Használj oszlopneveket (attribútum-hozzáférést) a sokkal olvashatóbb kódért.
  • Ellenőrzés rowcount adatmódosító utasítások után.
  • A None értékeket kezeld explicit módon, ha az oszlopok NULL értéket is tartalmazhatnak.

Kapcsolódó tartalom

  • Last updated on