example_aws-dynamodb_update-item-set.go

// go run example_aws-dynamodb_base.go example_aws-dynamodb_update-item-set.go
package main

import (
	"fmt"

	"github.com/aws/aws-sdk-go/aws"
	awsdynamodb "github.com/aws/aws-sdk-go/service/dynamodb"
	"github.com/aws/aws-sdk-go/service/dynamodb/expression"
	"github.com/btnguyen2k/prom/dynamodb"
)

func main() {
	adc := createAwsDynamodbConnect()
	defer adc.Close()

	item := map[string]*awsdynamodb.AttributeValue{
		"username": {S: aws.String("user-update")},
		"email":    {S: aws.String("user-update@test.com")},
		"an": {
			NS: []*string{aws.String("1"), aws.String("2"), aws.String("3")},
		},
		"as": {
			SS: []*string{aws.String("1"), aws.String("2"), aws.String("3")},
		},
		"m": {M: map[string]*awsdynamodb.AttributeValue{}},
		"a": {L: []*awsdynamodb.AttributeValue{}},
	}
	keyFilter := map[string]interface{}{"username": "user-update"}
	key := make(map[string]*awsdynamodb.AttributeValue)
	for k, v := range keyFilter {
		key[k] = dynamodb.AwsDynamodbToAttributeValue(v)
	}

	{
		fmt.Println("-== Add Values to Item Attributes ==-")
		fmt.Printf("  Inserting item: %s\n", toJsonDynamodb(item))
		_, err := adc.PutItemRaw(nil, "test1", item, nil)
		if err != nil {
			fmt.Printf("    Error: %s\n", err)
		}
		attrsAndValues := map[string]interface{}{"an": 8, "as": []string{"9", "10"}}
		condition := expression.Name("username").Equal(expression.Value("user-update"))
		dbresult, err := adc.AddValuesToSet(nil, "test1", keyFilter, &condition, attrsAndValues)
		fmt.Printf("  Adding values to attributes: %v - %s\n", dbresult, err)
		dbitem, err := adc.GetItem(nil, "test1", keyFilter)
		if err != nil {
			fmt.Printf("    Error getting item: %s\n", err)
		} else {
			fmt.Printf("    Item after update: %s\n", toJsonDynamodb(dbitem))
		}
		fmt.Println(awsDynamodbSep)
	}
	{
		fmt.Println("-== Delete Values from Item Attributes ==-")
		fmt.Printf("  Inserting item: %s\n", toJsonDynamodb(item))
		_, err := adc.PutItemRaw(nil, "test1", item, nil)
		if err != nil {
			fmt.Printf("    Error: %s\n", err)
		}
		attrsAndValues := map[string]interface{}{"an": []int{1, 2}, "as": []string{"3"}}
		condition := expression.Name("username").Equal(expression.Value("user-update"))
		dbresult, err := adc.DeleteValuesFromSet(nil, "test1", keyFilter, &condition, attrsAndValues)
		fmt.Printf("  Deleting values from attributes: %v - %s\n", dbresult, err)
		dbitem, err := adc.GetItem(nil, "test1", keyFilter)
		if err != nil {
			fmt.Printf("    Error getting item: %s\n", err)
		} else {
			fmt.Printf("    Item after update: %s\n", toJsonDynamodb(dbitem))
		}
		fmt.Println(awsDynamodbSep)
	}
}