📣
TiDB Cloud Premium はパブリックプレビュー中です。エンタープライズワークロード向けの無制限のスケーリング、即時の弾力性、高度なセキュリティを提供します。このページは自動翻訳されたものです。原文はこちらからご覧ください。

peeweeを使用してTiDBに接続します。



TiDBはMySQL互換のデータベースであり、PythonはPythonで人気のPeeweeリレーショナルマッパー(ORM)です。

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

  • 環境をセットアップしてください。
  • peeweeを使用してTiDBに接続します。
  • アプリケーションをビルドして実行します。必要に応じて、基本的なCRUD操作のサンプルコードスニペットも利用できます。

前提条件

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

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を使用しています。PyMySQLは、TiDBと互換性があり、すべてのプラットフォームにインストール可能な、純粋なPython製のMySQLクライアントライブラリです。詳細については、 Peewee公式ドキュメントを参照してください。

ステップ3:接続情報の設定

選択したTiDBのデプロイオプションに応じて、TiDBに接続してください。

    1. My TiDBページに移動し、対象のTiDB Cloud StarterまたはEssentialインスタンスの名前をクリックして、概要ページに移動します。

    2. 右上隅のConnectをクリックしてください。接続ダイアログが表示されます。

    3. 接続ダイアログの設定がご使用のオペレーティング環境と一致していることを確認してください。

      • Connection TypePublicに設定されています。

      • Branchmainに設定されています。

      • Connect WithGeneralに設定されています。

      • お使いの環境に合ったOperating Systemを選択してください。

    4. Generate Passwordをクリックすると、ランダムなパスワードが生成されます。

    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. My TiDBページに移動し、対象のTiDB Cloud Premiumインスタンスの名前をクリックして概要ページに移動します。

    2. 左側のナビゲーションペインで、 Settings > Networkingをクリックします。

    3. Networkingページで、Public EndpointEnableをクリックし、次にAdd IP Addressをクリックします。

      クライアントのIPアドレスがアクセスリストに追加されていることを確認してください。

    4. 左側のナビゲーションペインでOverviewをクリックすると、インスタンスの概要ページに戻ります。

    5. 右上隅のConnectをクリックしてください。接続ダイアログが表示されます。

    6. 接続ダイアログで、 Connection TypeドロップダウンリストからPublicを選択します。

      • 公開エンドポイントがまだ有効化中であることを示すメッセージが表示された場合は、処理が完了するまでお待ちください。
      • まだパスワードを設定していない場合は、ダイアログのSet Root Passwordをクリックしてください。
      • サーバー証明書を確認する必要がある場合、または接続に失敗して認証局(CA)証明書が必要な場合は、 CA certをクリックしてダウンロードしてください。
      • Public接続タイプに加えて、 TiDB Cloud Premium はPrivate Endpoint接続をサポートします。詳細については、 AWS PrivateLink経由でTiDB Cloud Premiumに接続しますを参照してください。
    7. .env.exampleをコピーして.envに名前を変更するには、次のコマンドを実行します。

      cp .env.example .env
    8. 対応する接続​​文字列.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'

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

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

    1. My TiDBページに移動し、対象のTiDB Cloud Dedicatedクラスタの名前をクリックして概要ページに移動します。

    2. 右上隅のConnectをクリックしてください。接続ダイアログが表示されます。

    3. 接続ダイアログで、 Connection TypeドロップダウンリストからPublicを選択し、 CA certをクリックしてCA証明書をダウンロードします。

      IP アクセス リストを設定していない場合は、最初の接続の前に、 Configure IP Access Listをクリックするか、IP アクセス リストを設定するの手順に従って設定します。

      TiDB Cloud Dedicated は、Public接続タイプに加えて、Private EndpointおよびVPC Peering接続タイプもサポートしています。詳細については、 TiDB Cloud Dedicatedクラスタに接続しますを参照してください。

    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. Expected-Output.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"

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

    データを挿入する

    # 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()

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

    次のステップ

    お困りですか?

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