Function convertAttributeValueMapToRow

backend/plugin/db/dynamodb/dynamodb.go:292–335

(items map[string]types.AttributeValue)

}

func convertAttributeValueMapToRow(items map[string]types.AttributeValue) map[string]*dynamodbQueryResultMeta {
	result := make(map[string]*dynamodbQueryResultMeta, len(items))
	var columnType string
	for item, attributeValue := range items {
		switch attributeValue.(type) {
		case *types.AttributeValueMemberB:
			columnType = "Binary"
		case *types.AttributeValueMemberBOOL:
			columnType = "Boolean"
		case *types.AttributeValueMemberBS:
			columnType = "BinarySet"
		case *types.AttributeValueMemberL:
			columnType = "List"
		case *types.AttributeValueMemberM:
			columnType = "Map"
		case *types.AttributeValueMemberN:
			columnType = "Number"
		case *types.AttributeValueMemberNS:
			columnType = "NumberSet"
		case *types.AttributeValueMemberNULL:
			columnType = "Null"
		case *types.AttributeValueMemberS:
			columnType = "String"
		case *types.AttributeValueMemberSS:
			columnType = "StringSet"
		default:
			columnType = "Unknown"
		}
		value, err := convertAttributeValueToRowValue(attributeValue)
		var r *v1pb.RowValue
		if err != nil {
			r = &v1pb.RowValue{
				Kind: &v1pb.RowValue_StringValue{StringValue: err.Error()},
			}
		} else {
			r = value
		}
		result[item] = &dynamodbQueryResultMeta{
			columnType: columnType,
			value:      r,
		}
	}
	return result
}

func convertAttributeValueToRowValue(attributeValue types.AttributeValue) (*v1pb.RowValue, error) {
	switch attributeValue := attributeValue.(type) {