peewee で TiDB に接続する

TiDB は MySQL 互換データベースであり、 ピーピーは Python 用の一般的なオブジェクト リレーショナル マッパー (ORM) です。

このチュートリアルでは、TiDB と peeweee を使用して次のタスクを実行する方法を学習できます。

  • 環境をセットアップします。
  • peewee を使用して TiDB クラスターに接続します。
  • アプリケーションをビルドして実行します。オプションで、基本的な CRUD 操作のサンプル コード スニペットを見つけることができます。

注記:

このチュートリアルは、TiDB サーバーレス、TiDB 専用、および TiDB セルフホスト クラスターで動作します。

前提条件

このチュートリアルを完了するには、次のものが必要です。

TiDB クラスターがない場合は、次のように作成できます。

サンプル アプリを実行して TiDB に接続する

このセクションでは、サンプル アプリケーション コードを実行して TiDB に接続する方法を説明します。

ステップ 1: サンプル アプリ リポジトリのクローンを作成する

ターミナル ウィンドウで次のコマンドを実行して、サンプル コード リポジトリのクローンを作成します。

git clone https://github.com/tidb-samples/tidb-python-peewee-quickstart.git cd tidb-python-peewee-quickstart

ステップ 2: 依存関係をインストールする

次のコマンドを実行して、サンプル アプリに必要なパッケージ (peewee および PyMySQL を含む) をインストールします。

pip install -r requirements.txt

PyMySQL を使用する理由

Peewee は、複数のデータベースで動作する ORM ライブラリです。これはデータベースの高レベルの抽象化を提供し、開発者がよりオブジェクト指向の方法で SQL ステートメントを作成するのに役立ちます。ただし、peewee にはデータベース ドライバーが含まれていません。データベースに接続するには、データベース ドライバーをインストールする必要があります。このサンプル アプリケーションは、データベース ドライバーとして PyMySQL を使用します。これは、TiDB と互換性があり、すべてのプラットフォームにインストールできる純粋な Python MySQL クライアント ライブラリです。詳細については、 ピーウィー公式ドキュメントを参照してください。

ステップ 3: 接続情報を構成する

選択した TiDB デプロイメント オプションに応じて、TiDB クラスターに接続します。

  • TiDB Serverless
  • TiDB Dedicated
  • TiDB Self-Hosted
  1. クラスターページに移動し、ターゲット クラスターの名前をクリックして、その概要ページに移動します。

  2. 右上隅にある「接続」をクリックします。接続ダイアログが表示されます。

  3. 接続ダイアログの設定が動作環境と一致していることを確認してください。

    • エンドポイント タイプはPublicに設定されます

    • ブランチはmainに設定されています

    • [接続先]Generalに設定されています

    • オペレーティング システムが環境に一致します。

    ヒント:

    プログラムが Windows Subsystem for Linux (WSL) で実行されている場合は、対応する Linux ディストリビューションに切り替えます。

  4. 「パスワードの生成」をクリックして、ランダムなパスワードを作成します。

    ヒント:

    以前にパスワードを作成したことがある場合は、元のパスワードを使用するか、 「パスワードのリセット」をクリックして新しいパスワードを生成できます。

  5. 次のコマンドを実行して.env.exampleをコピーし、名前を.envに変更します。

    cp .env.example .env
  6. 対応する接続​​文字列をコピーして.envファイルに貼り付けます。結果の例は次のとおりです。

    TIDB_HOST='{host}' # e.g. gateway01.ap-northeast-1.prod.aws.tidbcloud.com TIDB_PORT='4000' TIDB_USER='{user}' # e.g. xxxxxx.root TIDB_PASSWORD='{password}' TIDB_DB_NAME='test' CA_PATH='{ssl_ca}' # e.g. /etc/ssl/certs/ca-certificates.crt (Debian / Ubuntu / Arch)

    プレースホルダー{} 、接続ダイアログから取得した接続パラメーターに必ず置き換えてください。

  7. .envファイルを保存します。

  1. クラスターページに移動し、ターゲット クラスターの名前をクリックして、その概要ページに移動します。

  2. 右上隅にある「接続」をクリックします。接続ダイアログが表示されます。

  3. 「どこからでもアクセスを許可」をクリックし、 「TiDB クラスター CA のダウンロード」をクリックして CA 証明書をダウンロードします。

    接続文字列の取得方法の詳細については、 TiDB専用標準接続を参照してください。

  4. 次のコマンドを実行して.env.exampleをコピーし、名前を.envに変更します。

    cp .env.example .env
  5. 対応する接続​​文字列をコピーして.envファイルに貼り付けます。結果の例は次のとおりです。

    TIDB_HOST='{host}' # e.g. tidb.xxxx.clusters.tidb-cloud.com TIDB_PORT='4000' TIDB_USER='{user}' # e.g. root TIDB_PASSWORD='{password}' TIDB_DB_NAME='test' CA_PATH='{your-downloaded-ca-path}'

    必ずプレースホルダー{}接続ダイアログから取得した接続パラメーターに置き換え、 CA_PATH前の手順でダウンロードした証明書パスで構成してください。

  6. .envファイルを保存します。

  1. 次のコマンドを実行して.env.exampleをコピーし、名前を.envに変更します。

    cp .env.example .env
  2. 対応する接続​​文字列をコピーして.envファイルに貼り付けます。結果の例は次のとおりです。

    TIDB_HOST='{tidb_server_host}' TIDB_PORT='4000' TIDB_USER='root' TIDB_PASSWORD='{password}' TIDB_DB_NAME='test'

    必ずプレースホルダー{}接続パラメーターに置き換えて、 CA_PATH行を削除してください。 TiDB をローカルで実行している場合、デフォルトのホスト アドレスは127.0.0.1で、パスワードは空です。

  3. .envファイルを保存します。

ステップ 4: コードを実行して結果を確認する

  1. 次のコマンドを実行してサンプル コードを実行します。

    python peewee_example.py
  2. 予想される出力.txtチェックして、出力が一致するかどうかを確認します。

サンプルコードスニペット

次のサンプル コード スニペットを参照して、独自のアプリケーション開発を完了できます。

完全なサンプル コードとその実行方法については、 tidb-samples/tidb-python-peewee-quickstartリポジトリを確認してください。

TiDB に接続する

from peewee import MySQLDatabase def get_db_engine(): config = Config() connect_params = {} if ${ca_path}: connect_params = { "ssl_verify_cert": True, "ssl_verify_identity": True, "ssl_ca": ${ca_path}, } return MySQLDatabase( ${tidb_db_name}, host=${tidb_host}, port=${tidb_port}, user=${tidb_user}, password=${tidb_password}, **connect_params, )

この関数を使用する場合、 ${tidb_host}${tidb_port}${tidb_user}${tidb_password}${tidb_db_name}および${ca_path}を TiDB クラスターの実際の値に置き換える必要があります。

テーブルを定義する

from peewee import Model, CharField, IntegerField db = get_db_engine() class BaseModel(Model): class Meta: database = db class Player(BaseModel): name = CharField(max_length=32, unique=True) coins = IntegerField(default=0) goods = IntegerField(default=0) class Meta: table_name = "players"

詳細については、 peeee ドキュメント: モデルとフィールドを参照してください。

データの挿入

# Insert a single record Player.create(name="test", coins=100, goods=100) # Insert multiple records Player.insert_many( [ {"name": "test1", "coins": 100, "goods": 100}, {"name": "test2", "coins": 100, "goods": 100}, ] ).execute()

詳細については、 データの挿入を参照してください。

クエリデータ

# Query all records players = Player.select() # Query a single record player = Player.get(Player.name == "test") # Query multiple records players = Player.select().where(Player.coins == 100)

詳細については、 クエリデータを参照してください。

データを更新する

# Update a single record player = Player.get(Player.name == "test") player.coins = 200 player.save() # Update multiple records Player.update(coins=200).where(Player.coins == 100).execute()

詳細については、 データを更新するを参照してください。

データの削除

# Delete a single record player = Player.get(Player.name == "test") player.delete_instance() # Delete multiple records Player.delete().where(Player.coins == 100).execute()

詳細については、 データの削除を参照してください。

次のステップ

助けが必要?

不和またはサポートチケットを作成するについて質問してください。

このページは役に立ちましたか?