DynamoDB サービスレベル API を使用する - AWS Mobile SDK

AWSの Mobile SDK for Xamarin が、AWS SDK for .NETに含まれるようになりました。このガイドでは、Mobile SDK for Xamarin のアーカイブバージョンについて説明します。

DynamoDB サービスレベル API を使用する

Dynamo サービスレベルの API を使用して、テーブルを作成、更新、削除することができます。この API を使用して、テーブル内の項目に対して、一般的な作成、読み込み、更新、削除 (CRUD) のオペレーションを実行することもできます。

DynamoDB クライアントの作成

DynamoDB クライアントを作成するには、以下を行います。

AmazonDynamoDBClient client = new AmazonDynamoDBClient(credentials,region);

CRUD オペレーション

項目の保存

DynamoDB テーブルに項目を保存するには、以下を行います。

// Create a client AmazonDynamoDBClient client = new AmazonDynamoDBClient(credentials,region); // Define item attributes Dictionary<string, AttributeValue> attributes = new Dictionary<string, AttributeValue>(); // Author is hash-key attributes["Author"] = new AttributeValue { S = "Mark Twain" }; attributes["Title"] = new AttributeValue { S = "The Adventures of Tom Sawyer" }; attributes["PageCount"] = new AttributeValue { N = "275" }; attributes["Price"] = new AttributeValue{N = "10.00"}; attributes["Id"] = new AttributeValue{N="10"}; attributes["ISBN"] = new AttributeValue{S="111-1111111"}; // Create PutItem request PutItemRequest request = new PutItemRequest { TableName = "Books", Item = attributes }; // Issue PutItem request var response = await client.PutItemAsync(request);

項目の取得

項目を取得するには、以下を行います。

// Create a client AmazonDynamoDBClient client = new AmazonDynamoDBClient(credentials,region); Dictionary<string, AttributeValue> key = new Dictionary<string, AttributeValue> { { "Id", new AttributeValue { N = "10" } } }; // Create GetItem request GetItemRequest request = new GetItemRequest { TableName = "Books", Key = key, }; // Issue request var result = await client.GetItemAsync(request); // View response Console.WriteLine("Item:"); Dictionary<string, AttributeValue> item = result.Item; foreach (var keyValuePair in item) { Console.WriteLine("Author := {0}", item["Author"]); Console.WriteLine("Title := {0}", item["Title"]); Console.WriteLine("Price:= {0}", item["Price"]); Console.WriteLine("PageCount := {0}", item["PageCount"]); }

項目の更新

項目を更新するには:

// Create a client AmazonDynamoDBClient client = new AmazonDynamoDBClient(credentials,region); Dictionary<string, AttributeValue> key = new Dictionary<string, AttributeValue> { { "Id", new AttributeValue { N = "10" } } }; // Define attribute updates Dictionary<string, AttributeValueUpdate> updates = new Dictionary<string, AttributeValueUpdate>(); // Add a new string to the item's Genres SS attribute updates["Genres"] = new AttributeValueUpdate() { Action = AttributeAction.ADD, Value = new AttributeValue { SS = new List<string> { "Bildungsroman" } } }; // Create UpdateItem request UpdateItemRequest request = new UpdateItemRequest { TableName = "Books", Key = key, AttributeUpdates = updates }; // Issue request var response = await client.UpdateItemAsync(request);

項目の削除

項目を削除するには:

// Create a client AmazonDynamoDBClient client = new AmazonDynamoDBClient(credentials,region); Dictionary<string, AttributeValue> key = new Dictionary<string, AttributeValue> { { "Id", new AttributeValue { N = "10" } } }; // Create DeleteItem request DeleteItemRequest request = new DeleteItemRequest { TableName = "Books", Key = key }; // Issue request var response = await client.DeleteItemAsync(request);

クエリおよびスキャン

作成者が「Mark Twain」であるすべての書籍を検索して取得するには、以下を行います。

public void Query(AWSCredentials credentials, RegionEndpoint region) { using(var client = new AmazonDynamoDBClient(credentials, region)) { var queryResponse = await client.QueryAsync(new QueryRequest() { TableName = "Books", IndexName = "Author-Title-index", KeyConditionExpression = "Author = :v_Id", ExpressionAttributeValues = new Dictionary < string, AttributeValue > { { ":v_Id", new AttributeValue { S = "Mark Twain" } } } }); queryResponse.Items.ForEach((i) = > { Console.WriteLine(i["Title"].S); }); } }

以下のスキャンのサンプルコードでは、テーブルに含まれるすべての本を返します。

public void Scan(AWSCredentials credentials, RegionEndpoint region) { using(var client = new AmazonDynamoDBClient(credentials, region)) { var queryResponse = client.Scan(new ScanRequest() { TableName = "Books" }); queryResponse.Items.ForEach((i) = > { Console.WriteLine(i["Title"].S); }); } }