Aracılığıyla paylaş

Hızlı Başlangıç: Python için pyodbc sürücüsüne bağlanma

Bu hızlı başlangıçta, bir Python betiğini oluşturduğunuz ve örnek verilerle yüklediğiniz bir veritabanına bağlarsınız. pyodbc Python sürücüsünü kullanarak veritabanınıza bağlanır ve verileri okuma ve yazma gibi temel işlemleri gerçekleştirirsiniz.

pyodbc belgeleri | pyodbc kaynak kodu | Paket (PyPi)

Önkoşullar

  • Python 3

  • pyodbc paketini PyPI'den edinin.

  • SQL Server, Azure SQL Veritabanı veya Fabric'deki SQL veritabanında, örnek bir şema ve geçerli bir bağlantı dizesi.

Kurulum

Python sürücüsünü kullanarak pyodbc bir uygulama geliştirmek üzere geliştirme ortamınızı yapılandırmak için bu adımları izleyin.

Uyarı

Bu sürücü SQL Server'da, Doku'daki SQL veritabanında ve Azure SQL Veritabanı'nda varsayılan olarak etkinleştirilen Tablosal Veri Akışı (TDS) protokollerini kullanır. Ek yapılandırma gerekmez.

pyodbc paketini yükleme

pyodbc Paketi PyPI'dan alın.

  1. Boş bir dizinde bir komut istemi açın.

  2. pyodbc paketini yükleyin.

    pip install pyodbc

python-dotenv paketini yükleme

PyPI'den python-dotenv alın.

  1. Aynı dizinde paketi yükleyin python-dotenv .

    pip install python-dotenv

Yüklü paketleri denetleme

Hedeflenen paketlerinizin yüklendiğini doğrulamak için PyPI komut satırı aracını kullanabilirsiniz.

  1. ile pip listyüklü paketlerin listesini denetleyin.

    pip list

SQL veritabanı oluşturma

Bu hızlı başlangıç için Microsoft SQL Server'da AdventureWorks2025 Basit şeması, Doku'daki SQL veritabanı veya Azure SQL Veritabanı gerekir.

Kodu çalıştır

Yeni dosya oluşturma

  1. app.py adlı yeni bir dosya oluşturun.

  2. Modül docstring ekleyin.

    """
Connects to a SQL database using pyodbc
"""

  3. pyodbc paketini içeri aktarın.

    from os import getenv
from dotenv import load_dotenv
from pyodbc import connect

  4. pyodbc.connect bir SQL veritabanına bağlanmak için işlevini kullanın.

    load_dotenv()
conn = connect(getenv("SQL_CONNECTION_STRING"))

  5. Geçerli dizinde adlı .envyeni bir dosya oluşturun.

  6. dosyasının içine .env bağlantı dizeniz için adlı SQL_CONNECTION_STRINGbir girdi ekleyin. Buradaki örneği gerçek bağlantı dizesi değerinizle değiştirin.

    SQL_CONNECTION_STRING="Driver={ODBC Driver 18 for SQL Server};Server=<server_name>;Database={<database_name>};Encrypt=yes;TrustServerCertificate=no;Authentication=ActiveDirectoryInteractive"

    Tavsiye

    Burada kullanılan bağlantı dizesi büyük ölçüde bağlandığınız SQL veritabanının türüne bağlıdır. Fabric’de bir Azure SQL Veritabanı veya bir SQL Veritabanı’na bağlanıyorsanız, bağlantı dizeleri sekmesindeki ODBC bağlantı dizesini kullanın. Senaryonuza bağlı olarak kimlik doğrulama türünü ayarlamanız gerekebilir. Bağlantı dizeleri ve söz dizimi hakkında daha fazla bilgi için bkz. bağlantı dizesi söz dizimi başvurusu.

Sorgu yürütme

Sorguyu yürütmek ve sonuçları ayrıştırmak için SQL sorgu dizesi kullanın.

  1. SQL sorgu dizesi için bir değişken oluşturun.

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

  2. Veritabanındaki bir sorgudan sonuç kümesi almak için kullanın cursor.execute .

    cursor = conn.cursor()
cursor.execute(SQL_QUERY)

    Uyarı

    Bu işlev temelde herhangi bir sorguyu kabul eder ve cursor.fetchone() kullanımıyla yinelenebilen bir sonuç kümesi döndürür.

  3. Veritabanındaki tüm kayıtları almak için cursor.fetchall, bir foreach döngü ile kullanın. Ardından kayıtları yazdırın.

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

  4. Dosyayı app.py.

  5. Bir terminal açın ve uygulamayı test edin.

    python app.py

    Beklenen çıktı budur.

    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

İşlem olarak bir satır ekle

Bir INSERT deyimini güvenli bir şekilde gerçekleştirin ve parametreleri aktarın. Parametrelerin değer olarak geçirilmesi uygulamanızı SQL ekleme saldırılarına karşı korur.

  1. randrange kitaplığından random içeri aktarmasını app.py üst kısmına ekleyin.

    from random import randrange

  2. app.py Sonuna rastgele bir ürün numarası oluşturmak için kod ekleyin.

    productNumber = randrange(1000)

    Tavsiye

    Burada rastgele bir ürün numarası oluşturmak, bu örneği birden çok kez çalıştırabilmenizi sağlar.

  3. SQL deyimi dizesi oluşturun.

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

  4. cursor.execute kullanarak ifadeyi yürütün.

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

  5. cursor.fetchval kullanarak tek sonucun ilk sütununu getirin, sonucun benzersiz tanımlayıcısını yazdırın ve connection.commit kullanarak işlemi bir transaksiyon olarak gerçekleştirin.

    resultId = cursor.fetchval()
print(f"Inserted Product ID : {resultId}")
conn.commit()

    Tavsiye

    İsteğe bağlı olarak, işlemi geri almak için kullanabilirsiniz connection.rollback .

  6. cursor.close ve connection.close kullanarak imleci ve bağlantıyı kapatın.

    cursor.close()
conn.close()

  7. Dosyayı app.py ve uygulamayı yeniden test edin.

    python app.py

    Beklenen çıktı budur.

    Inserted Product ID : 1001

Sonraki adım

Fikirlere pyodbc katkıda bulunmak veya sorunları bildirmek için daha fazla örnek için sürücü GitHub deposunu ziyaret edin.

GitHub'da pyodbc sürücüsü

  • Last updated on