Wie importiere ich Daten von STDIN nach PostgreSQL mit dem pq-Paket von Go?

Wie importiere ich Zeilen von STDIN nach Postgresql? [Duplikat]

In Go können Sie mithilfe des pq-Pakets Zeilen aus STDIN in PostgreSQL importieren. Hier ist eine Schritt-für-Schritt-Lösung:

Schritt 1: Vorbereiten der Datenbankverbindung

<code class="go">import (
    "database/sql"

    "github.com/lib/pq"
)

db, err := sql.Open("postgres", "dbname=mydb user=myuser password=mypassword")
if err != nil {
    log.Fatalf("open: %v", err)
}</code>

Schritt 2: Starten einer Transaktion

<code class="go">txn, err := db.Begin()
if err != nil {
    log.Fatalf("begin: %v", err)
}</code>

Schritt 3: Vorbereiten die Copy-Anweisung

Verwenden Sie pq.CopyIn(), um eine vorbereitete Anweisung zu erstellen.

<code class="go">stmt, err := txn.Prepare(pq.CopyIn("test_table", "column1", "column2", ...))
if err != nil {
    log.Fatalf("prepare: %v", err)
}</code>

Schritt 4: Führen Sie die Copy-Anweisung aus

Iterieren Sie Ihre Daten und führen Sie stmt aus .Exec() für jede Zeile.

<code class="go">for _, row := range rows {
    _, err = stmt.Exec(row.Column1, row.Column2, ...)
    if err != nil {
        log.Fatalf("exec: %v", err)
    }
}</code>

Schritt 5: Letzte Kopie der Anweisung ausführen

<code class="go">_, err = stmt.Exec()
if err != nil {
    log.Fatalf("exec: %v", err)
}</code>

Schritt 6: Anweisung schließen und Transaktion festschreiben

<code class="go">stmt.Close()
err = txn.Commit()
if err != nil {
    log.Fatalf("commit: %v", err)
}</code>

Dieser Code importiert effizient Zeilen von STDIN in Ihre PostgreSQL-Tabelle.

Das obige ist der detaillierte Inhalt vonWie importiere ich Daten von STDIN nach PostgreSQL mit dem pq-Paket von Go?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!