クイックスタート: Python 用 mssql-python ドライバーを使用して接続する

2025-06-26

このクイックスタートでは、サンプルデータを作成して読み込んだデータベースに Python スクリプトを接続します。 Python 用の mssql-python ドライバーを使用してデータベースに接続し、データの読み取りと書き込みなどの基本的な操作を実行します。

mssql-python のドキュメント | mssql-python ソースコード | パッケージ (PyPi)

[前提条件]

Python 3
- Pythonをまだお持ちでない場合は、Python ランタイムと Python パッケージインデックス (PyPI) パッケージマネージャーを python.org からインストールします。
- 自身の環境以外を使用しますか？ GitHub Codespacesを使用して devcontainer として開きます。
PyPI からの mssql-python パッケージ。
AdventureWorks2022サンプルスキーマと有効な接続文字列を含む、Fabric の SQL Server、Azure SQL Database、または SQL データベース上のデータベース。

セットアップ中

次の手順に従って、 mssql-python Python ドライバーを使用してアプリケーションを開発するように開発環境を構成します。

注

このドライバーでは、TDS プロトコルが使用されます。このプロトコルは、SQL Server、Fabric の SQL データベース、Azure SQL Database で既定で有効になっています。追加の構成は不要です。

mssql-python パッケージをインストールする

PyPI からmssql-python パッケージを取得します。

空のファイルディレクトリでコマンドプロンプトを開きます。
mssql-python パッケージをインストールします。
```
pip install mssql-python
```

インストールしたパッケージを確認する

PyPI コマンドラインツールを使用して、目的のパッケージがインストールされていることを確認できます。

pip list でインストールされているパッケージの一覧を確認します。
```
pip list
```

SQL Database の作成

このクイックスタートでは、Microsoft SQL Server の AdventureWorks2022 Lightweight スキーマ、Fabric の SQL データベース、または Azure SQL Database が必要です。

Azure ポータルを使用して数分で SQL データベースを作成する

[新しいファイルの作成]

app.py という名前で新しいファイルを作成します。

モジュール docstringを追加します。

"""
Connects to a SQL database using mssql-python
"""

mssql-pythonを含むパッケージをインポートします。

from os import getenv
from dotenv import load_dotenv
from mssql_python import connect

mssql-python.connect 関数を使用して SQL データベースに接続します。
```
load_dotenv()
conn = connect(getenv("SQL_CONNECTION_STRING"))
```
現在のディレクトリに、 *.envという名前の新しいファイルを作成します。
*.env ファイル内に、SQL_CONNECTION_STRINGという名前の接続文字列のエントリを追加します。ここでの例を実際の接続文字列の値に置き換えます。
```
SQL_CONNECTION_STRING="Server=<server_name>;Database={<database_name>};Encrypt=yes;TrustServerCertificate=no;Authentication=ActiveDirectoryInteractive"
```
ヒント

ここで使用される接続文字列は、接続先の SQL データベースの種類によって大きく異なります。接続文字列とその構文の詳細については、接続文字列の構文リファレンスを参照してください。

クエリを実行する

SQL クエリ文字列を使用してクエリを実行し、結果を解析します。

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

cursor.executeを使用してデータベースに対するクエリから結果セットを取得します。
```
cursor = conn.cursor()
cursor.execute(SQL_QUERY)
```
注

この関数は基本的に任意のクエリを受け取り、cursor.fetchone()を使用して反復処理できる結果セットを返します。
cursor.fetchallを foreach ループとともに使用して、データベースからすべてのレコードを取得します。次に、レコードを出力します。
```
records = cursor.fetchall()
for r in records:
    print(f"{r.CustomerID}\t{r.OrderCount}\t{r.CompanyName}")
```
app.py ファイルを保存します。

ターミナルを開き、アプリケーションをテストします。

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

トランザクションとして行を挿入する

INSERT ステートメントを安全に実行し、パラメーターを渡します。パラメーターを値として渡すと、 SQL インジェクション攻撃からアプリケーションが保護されます。

random ライブラリからapp.pyの上部にrandrangeのインポートを追加します。
```
from random import randrange
```
app.pyの最後に、ランダムな製品番号を生成するコードを追加します。
```
productNumber = randrange(1000)
```
ヒント

ここでランダムな製品番号を生成することで、このサンプルを複数回実行できるようになります。

SQL ステートメント文字列を作成します。

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

cursor.executeを使用してステートメントを実行します。

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

cursor.fetchone を使用して単一の結果をフェッチし、結果の一意識別子を出力した後、connection.commit を使用して操作をトランザクションとしてコミットします。
```
result = cursor.fetchone()
print(f"Inserted Product ID : {result['ProductID']}")
conn.commit()
```
ヒント

必要に応じて、 connection.rollback を使用してトランザクションをロールバックできます。
cursor.close と connection.closeを使用してカーソルと接続を閉じます。
```
cursor.close()
conn.close()
```
app.py ファイルを保存し、アプリケーションをもう一度テストします。
```
python app.py
```
予想される出力を次に示します。
```
Inserted Product ID : 1001
```

次のステップ

その他の例については、 mssql-python ドライバーの GitHub リポジトリを参照して、アイデアの投稿や問題の報告を行います。

GitHub の mssql-python ドライバー