Golang-Postgresql-Abfrage mit Transaktionen und Squirrel

Frageninhalt

Ich verstehe, wie man Eichhörnchen und Transaktionen getrennt verwendet, aber ich verstehe nicht, wie man sie zusammen verwendet. Wann sollte ich ein Rollback oder Commit durchführen? Ist mein Versuch richtig? Wenn nicht, was habe ich falsch gemacht...

tx, err := db.repo.GetDatabase().Begin()
if err != nil {
    return nil, err
}

sb := squirrel.StatementBuilder.
    Insert("dependencies").
    Columns("correlation_id", "name", "age").
    PlaceholderFormat(squirrel.Dollar).
    RunWith(db.repo.GetDatabase())

for _, human:= range humans{
    sb = sb.Values(
        human.CorrelationID,
        human.Name,
        human.Age,
    )
}

_, err = sb.Exec()
if err != nil {
    if err := tx.Rollback(); err != nil {
        return nil, err
    }
}

if err := tx.Commit(); err != nil {
    return nil, err
}

Soweit ich es verstanden habe, versuche ich ein Rollback oder Commit durchzuführen, nachdem ich eine Abfrage in Postgresql ausgeführt habe.

Richtige Antwort

Ihre Bemühungen sind großartig. Aber ....runwith(db.repo.getdatabase()) 在这种情况下是不正确的。因为您应该传递事务连接 tx . Weist Squirrel an, ein Transaktionsobjekt als Datenbankverbindung für die Abfrage zu verwenden.

Wenn Sie eine Datenbankverbindung anstelle einer Transaktionsverbindung verwenden, ist die Squirrel-Abfrage nicht Teil der Transaktion. Jede Abfrage wird einzeln ausgeführt und sofort an die Datenbank übermittelt.

Wir können auch die defer 语句更新 rollback 和 commit-Anweisung verwenden, die sicherstellt, dass die Transaktion ordnungsgemäß verarbeitet und abgeschlossen wird, bevor die Funktion beendet wird.

Dies ist der aktualisierte Code..

tx, err := db.repo.GetDatabase().Begin()
if err != nil {
    return nil, err
}

// added defer rollback and commit
defer func() {
    if err != nil {
        fmt.Println("An error happened while executing the queries - ", err)
        tx.Rollback()
        return
    }
    err = tx.Commit()
}()

response := make([]storage.URLStorage, 0, len(urls))

sb := squirrel.StatementBuilder.
    Insert("dependencies").
    Columns("correlation_id", "name", "age").
    PlaceholderFormat(squirrel.Dollar).
    RunWith(tx)

for _, human := range humans {
    sb = sb.Values(
        human.CorrelationID,
        human.Name,
        human.Age,
    )
}

// the error will be handled by the defer
_, err = sb.Exec()

// you can execute multiple queries with the transaction
for _, human := range someOtheSlice {
    sb = sb.Values(
        human.CorrelationID,
        human.Name,
        human.Age,
    )
}

_, err = sb.Exec()

// If any error happened this query executions, all will be roll backed with the defer

Ich hoffe, das hilft.

Siehe auch

• Datenbank/SQL-TX – Commit oder Rollback erkennen李>
• Aufschieben verwenden

Das obige ist der detaillierte Inhalt vonGolang-Postgresql-Abfrage mit Transaktionen und Squirrel. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!