Comment effectuer des mises à jour groupées dans PostgreSQL avec Go ?-Golang-php.cn

Comment effectuer des mises à jour groupées dans PostgreSQL avec Go ?

Susan Sarandon

Libérer： 2024-12-13 11:32:11

original

433 Les gens l'ont consulté

How to Perform Bulk Updates in PostgreSQL with Go?

Mise à jour groupée de plusieurs lignes dans une seule requête à l'aide de PostgreSQL

Question :

Comment peut-on plusieurs lignes soient mises à jour simultanément à l'aide d'une seule instruction SQL dans PostgreSQL et Allez-y ?

Réponse :

Pour réaliser des mises à jour groupées dans PostgreSQL à l'aide d'une seule requête, il est recommandé d'utiliser une table dérivée. L'exemple suivant montre comment mettre à jour plusieurs lignes à l'aide d'une table dérivée :

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;

Copier après la connexion

Implémentation Go :

Le code Go suivant illustre l'exécution de la requête de mise à jour groupée :

import (
    "context"
    "database/sql"
    "fmt"

    _ "github.com/lib/pq" // PostgreSQL driver
)

func main() {
    // Open a database connection
    db, err := sql.Open("postgres", "user=postgres password=mypassword host=localhost port=5432 database=mydatabase")
    if err != nil {
        panic(err)
    }
    defer db.Close()

    // Create the derived table
    derivedTableQuery := `
CREATE TEMP TABLE BulkUpdate AS
SELECT 1 AS id, 'FINISH' AS column_a, 1234 AS column_b
UNION ALL
SELECT 2, 'UNFINISH', 3124
`
    if _, err := db.Exec(derivedTableQuery); err != nil {
        panic(err)
    }

    // Execute the bulk update query
    bulkUpdateQuery := `
UPDATE t
SET column_a = v.column_a,
    column_b = v.column_b
FROM BulkUpdate v
WHERE v.id = t.id
`

    // Create a context for the query execution
    ctx := context.Background()

    // Execute the bulk update query
    result, err := db.ExecContext(ctx, bulkUpdateQuery)
    if err != nil {
        panic(err)
    }

    // Retrieve the number of rows affected
    rowsAffected, err := result.RowsAffected()
    if err != nil {
        panic(err)
    }

    // Print the number of rows affected
    fmt.Printf("%d rows updated\n", rowsAffected)
}

Copier après la connexion

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!