「労働者が自分の仕事をうまくやりたいなら、まず自分の道具を研ぎ澄まさなければなりません。」 - 孔子、「論語。陸霊公」
表紙 > プログラミング > Go の pq パッケージを使用して STDIN から PostgreSQL にデータをインポートするにはどうすればよいですか?

Go の pq パッケージを使用して STDIN から PostgreSQL にデータをインポートするにはどうすればよいですか?

2024 年 11 月 17 日に公開
ブラウズ:746

How to Import Data from STDIN to PostgreSQL Using Go\'s pq Package?

STDIN から Postgresql に行をインポートするにはどうすればよいですか? [重複]

Go では、pq パッケージを使用して STDIN から PostgreSQL に行をインポートできます。段階的な解決策は次のとおりです:

ステップ 1: データベース接続を準備する

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)
}

ステップ 2: トランザクションを開始する

txn, err := db.Begin()
if err != nil {
    log.Fatalf("begin: %v", err)
}

ステップ 3: コピー ステートメントを準備する

pq.CopyIn() を使用して、準備されたステートメントを作成します。

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

ステップ 4: コピー ステートメントを実行します

データを反復処理し、行ごとに stmt.Exec() を実行します。

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

ステップ 5: 最終コピー ステートメントを実行する

_, err = stmt.Exec()
if err != nil {
    log.Fatalf("exec: %v", err)
}

ステップ 6: ステートメントを閉じてトランザクションをコミットする

stmt.Close()
err = txn.Commit()
if err != nil {
    log.Fatalf("commit: %v", err)
}

このコードは、STDIN から PostgreSQL テーブルに行を効率的にインポートします。

リリースステートメント この記事は次の場所に転載されています: 1729744624 侵害がある場合は、[email protected] に連絡して削除してください。
最新のチュートリアル もっと>

免責事項: 提供されるすべてのリソースの一部はインターネットからのものです。お客様の著作権またはその他の権利および利益の侵害がある場合は、詳細な理由を説明し、著作権または権利および利益の証拠を提出して、電子メール [email protected] に送信してください。 できるだけ早く対応させていただきます。

Copyright© 2022 湘ICP备2022001581号-3