Das Unmarshalling von Dynamodb-Projekten gibt dasselbe Projekt zurück

PHP-Editor Zimo stellt Ihnen heute vor, wie Sie das Problem der Aufhebung der Gruppierung von DynamoDB-Elementen und der Rückgabe derselben Elemente lösen können. DynamoDB ist eine leistungsstarke, serverlose Schlüsselwertdatenbank, die jedoch manchmal bei der Abfrage dieselben Elemente zurückgibt, was für Entwickler ein heikles Problem sein kann. Machen Sie sich keine Sorgen, wir bieten Ihnen eine Lösung, um sicherzustellen, dass Ihre Abfrageergebnisse eindeutig und korrekt sind. In diesem Artikel erklären wir die Ursache des Problems im Detail und bieten eine einfache und effektive Möglichkeit, es zu lösen. Lass uns einen Blick darauf werfen!

Frageninhalt

Ich habe eine Range-Schleife in Golang, die eine Schleife von type.attributevalues durchläuft, die von Dynamodb mithilfe einer Scan-Funktion zurückgegeben wurde.

Ich habe die integrierte Funktion des Pakets golang aws-sdk-v2 attributevalue.unmarshalmap() verwendet, um diese Karte zu durchlaufen, und dabei habe ich Elemente zurückbekommen, die die gleiche Länge wie das Slice hatten.

Code:

type users struct {
    user *string `dynamodbav:"user"` 
    email *string `dynamodbav:"email"` 
    }

    user := users{}
  
   for _ , dbitem := range dynamoresults.items { 
    err = attributevalue.unmarshalmap(dbitem, &user)
   }

// gives the same pointer location for all 
users[0].user 
users[1].user
users[2].user

Ich habe auch versucht, den Benutzer in den Ergebnissen an das Slice anzuhängen

// this just gives a slice with the same items as above
 u := []Users{}
for _ , dbItem := range dynamoResults.Items { 
        err = attributevalue.UnmarshalMap(dbItem, &Users)
        u = append(u, Users)
       }

Die Lösung, die ich mit attributevalue.unmarshallistofmaps() gefunden habe, besteht darin, der Funktion einfach einen Teil der Elemente von dynamodb bereitzustellen.

Meine Frage ist eigentlich, zu verstehen, warum die Verwendung der beiden oben genannten Lösungen nicht wie erwartet funktioniert. Durchläuft es nicht die Dynamodb-Elemente und übergibt sie einzeln an die Unmarshal-Funktion? Es scheint, als würde man einfach immer das Gleiche tun.

Workaround

Wenn wir das Problem ein wenig ändern – von Dynamo-DB-Unmarshaling zu JSON-Unmarshaling – dann können wir es im go-Spielplatz tun. Im Beispielcode sehe ich zwei Faktoren, die zusammenwirken, um doppelte Slice-Werte zu verursachen:

1. Das Unmarshalling-Ziel wird außerhalb der Schleife definiert (Zeile 51). Wenn also u1out unmarshalled wird, wird das Ergebnis bei jeder Schleifeniteration an dieselbe Stelle geschrieben (Zeile 54).

Die Zeichenfolge, auf die

2. user1 类型的字段为 *string，因此当将循环变量值复制到切片时（第 55 行），user 和 email zeigt, wird nicht kopiert. Es werden nur ihre Zeigerwerte kopiert.

Fügt man diese beiden zusammen, schreibt jede Iteration die nicht gemarshallten Werte user und email an denselben Speicherort. Dies wird durch die ersten beiden Ausgabezeilen demonstriert, die Elemente von

drucken. user 和 email 值写入同一内​​存位置。输出的前两行证明了这一点，它们打印 u1out

Die verbleibenden Ausgabezeilen zeigen die Ergebnisse für drei weitere Fälle: wenn die Zielvariable innerhalb der Schleife verschoben wird (

). In jedem Fall werden erwartungsgemäß neue Speicherorte für nicht gruppierte Werte erstellt und Duplikate werden nicht gedruckt. u1in 和 u2in）或字段更改为 string（u2out

package main

import (
    "encoding/json"
    "fmt"
)

type (
    Users1 struct {
        User  *string
        Email *string
    }
    Users2 struct {
        User  string
        Email string
    }
)

func main() {
    dbItems := []string{
        `{"User":"userA","Email":"<a href="https://www.php.cn/link/89fee0513b6668e555959f5dc23238e9" class="__cf_email__" data-cfemail="a7d2d4c2d5e6e7c2dfc6cad7cbc289c4c8ca">[email&#160;protected]</a>"}`,
        `{"User":"userB","Email":"<a href="https://www.php.cn/link/89fee0513b6668e555959f5dc23238e9" class="__cf_email__" data-cfemail="5a2f293f28181a3f223b372a363f74393537">[email&#160;protected]</a>"}`,
    }

    u1Out := withVarDeclaredOutsideLoop[Users1](dbItems)
    printUsers(u1Out)

    u1In := withVarDeclaredInsideLoop[Users1](dbItems)
    printUsers(u1In)

    u2Out := withVarDeclaredOutsideLoop[Users2](dbItems)
    printUsers(u2Out)

    u2In := withVarDeclaredInsideLoop[Users2](dbItems)
    printUsers(u2In)

    // Output
    // u[0] = {User:0xc000014130 Email:0xc000014140}
    // u[1] = {User:0xc000014130 Email:0xc000014140}
    // u[0] = {User:0xc0000141c0 Email:0xc0000141d0}
    // u[1] = {User:0xc000014210 Email:0xc000014220}
    // u[0] = {User:userA Email:<a href="https://www.php.cn/link/89fee0513b6668e555959f5dc23238e9" class="__cf_email__" data-cfemail="86f3f5e3f4c7c6e3fee7ebf6eae3a8e5e9eb">[email&#160;protected]</a>}
    // u[1] = {User:userB Email:<a href="https://www.php.cn/link/89fee0513b6668e555959f5dc23238e9" class="__cf_email__" data-cfemail="07727462754547627f666a776b622964686a">[email&#160;protected]</a>}
    // u[0] = {User:userA Email:<a href="https://www.php.cn/link/89fee0513b6668e555959f5dc23238e9" class="__cf_email__" data-cfemail="98edebfdead9d8fde0f9f5e8f4fdb6fbf7f5">[email&#160;protected]</a>}
    // u[1] = {User:userB Email:<a href="https://www.php.cn/link/89fee0513b6668e555959f5dc23238e9" class="__cf_email__" data-cfemail="fe8b8d9b8cbcbe9b869f938e929bd09d9193">[email&#160;protected]</a>}
}

func withVarDeclaredOutsideLoop[T any](dbItems []string) []T {
    var t T
    u := []T{}
    for _, dbItem := range dbItems {
        json.Unmarshal([]byte(dbItem), &t)
        u = append(u, t)
    }
    return u
}

func withVarDeclaredInsideLoop[T any](dbItems []string) []T {
    u := []T{}
    for _, dbItem := range dbItems {
        var t T
        json.Unmarshal([]byte(dbItem), &t)
        u = append(u, t)
    }
    return u
}

func printUsers[T any](u []T) {
    for i, user := range u {
        fmt.Printf("u[%d] = %+v\n", i, user)
    }
}

Das obige ist der detaillierte Inhalt vonDas Unmarshalling von Dynamodb-Projekten gibt dasselbe Projekt zurück. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!