.NET と LINQ を使って ScalarDB Cluster SQL をはじめよう
このページは英語版のページが機械翻訳されたものです。英語版との間に矛盾または不一致がある場合は、英語版を正としてください。
このチュートリアルでは、ScalarDB Cluster SQL を LINQ 経由で使用するサンプルアプリケーションを作成する方法について説明します。
概要
このチュートリアルでは、ScalarDB を使用して、商品を注文し、与信枠を使用して支払うことができるサンプルの電子商取引アプリケーションを作成するプロセスを説明します。
このサンプルアプリケーションの目的は ScalarDB を使用する方法を示すことにあるため、アプリケーション固有のエラーハンドリング、認証処理、および類似の機能はサンプルアプリケーションには含まれていません。例外処理の詳細については、ScalarDB Cluster .NET Client SDK における例外処理を参照してください。
以下の図は、サンプルアプリケーションのシステムアーキテクチャを示しています。
このサンプルアプリケーションで実行できること
サンプルアプリケーションは、次の種類のトランザクションをサポートしています:
- 顧客情報を取得します。
- 信用枠を使用して注文を行います。
- 注文のコストが顧客の信用限度額を下回っているかどうかを確認します。
- チェックが成功した場合は、注文履歴を記録し、顧客が支払った金額を更新します。
- 注文 ID で注文情報を取得します。
- 顧客 ID で注文情報を取得します。
- 支払いを行います。
- 顧客が支払った金額を減らします。
このサンプルアプリケーションの前提条件
- .NET SDK 8.0
- Kubernetes クラスターで実行されている ScalarDB Cluster
- Kubernetes 上での ScalarDB Cluster をローカルにデプロイする方法の手順に従ってデプロイした Kubernetes クラスターで ScalarDB Cluster が実行されていることを前提としています。
.NET SDK 8.0 は、このサンプルアプリケーションの作成に使用されたバージョンです。サポートされているすべてのバージョンについては、要件を参照してください。
ScalarDB Cluster のセットアップ
次のセクションでは、サンプルの電子商取引アプリケーションをセットアップする方法について説明します。
ScalarDB サンプルリポジトリのクローンを作成する
ターミナルを開き、次のコマンドを実行して ScalarDB サンプルリポジトリのクローンを作成します。
git clone https://github.com/scalar-labs/scalardb-samples
次に、以下のコマンドを実行して、サンプルアプリケーションが含まれているディレクトリに移動します。
cd scalardb-samples/scalardb-dotnet-samples/scalardb-cluster-linq-sample
ScalarDB.Client パッケージの参照バージョンを更新する
ScalarDB Cluster を使用するには、お好みのテキストエディターで ScalarDbClusterSample.csproj
を開きます。その後、参照されている ScalarDB.Client
パッケージのバージョンを、デプロイされている ScalarDB Cluster のバージョンに合わせて <MAJOR>.<MINOR>
を置き換えて更新します。
<PackageReference Include="ScalarDB.Client" Version="<MAJOR>.<MINOR>.*" />
scalardb-options.json
を変更する
ScalarDB Cluster に接続するには、scalardb-options.json
も変更する必要があります。ただし、その前に、Envoy サービスリソース (scalardb-cluster-envoy
) の EXTERNAL-IP
アドレスを取得する必要が あります。サービスリソースを取得するには、次のコマンドを実行します。
kubectl get svc scalardb-cluster-envoy
以下のような出力が表示されます(実際に表示される CLUSTER-IP
、PORT(S)
、AGE
の値は異なります)。
NAME TYPE CLUSTER-IP EXTERNAL-IP PORT(S) AGE
scalardb-cluster-envoy LoadBalancer 10.105.121.51 localhost 60053:30641/TCP 16h
この場合、EXTERNAL-IP
アドレスは localhost
です。
次のコマンドを実行して scalardb-options.json
を開きます。
vim scalardb-options.json
次に、database.properties
を次のように変更します。
{
"ScalarDbOptions": {
"Address": "http://localhost:60053"
}
}
初期データをロードする
サンプルアプリケーションを実行する前に、次のコマンドを実行して初期データをロードする必要があります。
dotnet run LoadInitialData
スキーマの詳細
上記のコマンドを実行すると、スキーマも適用されます。すべてのテーブルは sample
名前空間に作成されます。
sample.customers
: 顧客情報を管理するテーブルcredit_limit
: 貸し手が顧客に信用枠から支出を許可する最大金額credit_total
: 顧客が信用枠から支出した金額
sample.orders
: 注文情報を管理するテーブルsample.statements
: 注文明細情報を管理するテーブルsample.items
: 注文するアイテムの情報を管理するテーブル
スキーマのエンティティ関係図は次のとおりです。
初期データ
初期データがロードされたら、次のレコードがテーブルに保存されます。
sample.customers
テーブル
customer_id | name | credit_limit | credit_total |
---|---|---|---|
1 | Yamada Taro | 10000 | 0 |
2 | Yamada Hanako | 10000 | 0 |
3 | Suzuki Ichiro | 10000 | 0 |
sample.items
テーブル
item_id | name | price |
---|---|---|
1 | Apple | 1000 |
2 | Orange | 2000 |
3 | Grape | 2500 |
4 | Mango | 5000 |
5 | Melon | 3000 |
サンプルアプリケーションでトランザクションを実行し、データを取得する
次のセクションでは、サンプル電子商取引アプリケーションでトランザクションを実行し、データを取得する方法について説明します。
顧客情報を取得する
次のコマンドを実行して、ID が 1
である顧客に関する情報を取得することから始めます。
dotnet run GetCustomerInfo 1
次の出力が表示されます。
{
"id": 1,
"name": "Yamada Taro",
"credit_limit": 10000,
"credit_total": 0
}