Heim >Backend-Entwicklung >Golang >Wie führt man mit Go effizient Massenaktualisierungen in PostgreSQL durch?

Wie führt man mit Go effizient Massenaktualisierungen in PostgreSQL durch?

Barbara Streisand
Barbara StreisandOriginal
2024-12-05 07:19:11890Durchsuche

How to Efficiently Perform Bulk Updates in PostgreSQL using Go?

Massenaktualisierung in PostgreSQL mit Go Query Builder

Wenn mehrere Zeilen in einer PostgreSQL-Datenbank aktualisiert werden müssen, besteht der traditionelle Ansatz darin, eine separate UPDATE-Anweisung dafür auszuführen jede Zeile. Aus Leistungsgründen ist es jedoch häufig wünschenswert, eine einzelne UPDATE-Anweisung auszuführen, um mehrere Zeilen auf einmal zu aktualisieren.

Abgeleiteter Tabellenansatz

Eine effektive Methode zur Massenaktualisierung in PostgreSQL ist die Verwendung eine abgeleitete Tabelle. Bei dieser Technik wird eine temporäre Tabelle mit den gewünschten Aktualisierungen erstellt und dann die Daten in dieser Tabelle verwendet, um die Zieltabelle zu aktualisieren.

Stellen Sie sich das folgende Szenario vor, in dem wir mehrere Zeilen in der Tabelle „Tabelle“ mit neuen aktualisieren möchten Werte für die Spalten „column_a“ und „column_b“:

import (
    "database/sql"
    _"github.com/jackc/pgx/v4/stdlib" // PostgreSQL driver
)

func main() {
    db, err := sql.Open("pgx", "host=localhost port=5432 dbname=test user=postgres password=mysecretpassword")
    if err != nil {
        panic(err)
    }
    defer db.Close()

    // Prepare the derived table with updated values
    query := `UPDATE t
SET column_a = v.column_a,
    column_b = v.column_b
FROM (VALUES (1, 'FINISH', 1234),
             (2, 'UNFINISH', 3124)
     ) v(id, column_a, column_b)
WHERE v.id = t.id;`
    _, err = db.Exec(query)
    if err != nil {
        panic(err)
    }

    // Optionally, you can verify the updated rows
    rows, err := db.Query("SELECT * FROM table WHERE id IN (1, 2)")
    if err != nil {
        panic(err)
    }
    defer rows.Close()

    for rows.Next() {
        var id int
        var columnA, columnB string
        if err := rows.Scan(&id, &columnA, &columnB); err != nil {
            panic(err)
        }
        fmt.Printf("ID: %d, Column A: %s, Column B: %s\n", id, columnA, columnB)
    }
}

Dieser Ansatz bietet Flexibilität beim Hinzufügen oder Entfernen von Zeilen und Spalten in der abgeleiteten Tabelle, ohne die Hauptabfrage zu ändern. Es hilft auch, versehentliche Fehler im Vergleich zur expliziten Angabe mehrerer UPDATE-Anweisungen zu vermeiden.

Das obige ist der detaillierte Inhalt vonWie führt man mit Go effizient Massenaktualisierungen in PostgreSQL durch?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Stellungnahme:
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn