>  기사  >  백엔드 개발  >  pgx를 사용하여 Go를 사용하여 Postgres에서 대량 삽입을 효율적으로 수행하는 방법은 무엇입니까?

pgx를 사용하여 Go를 사용하여 Postgres에서 대량 삽입을 효율적으로 수행하는 방법은 무엇입니까?

Barbara Streisand
Barbara Streisand원래의
2024-11-01 10:02:02467검색

How to Efficiently Perform Bulk Inserts in Postgres with Go Using pgx?

pgx를 사용하여 Go의 Postgres에서 대량 INSERT: Resolved

주어진 Go 코드에서 INSERT 문을 수동으로 작성하고 실행합니다. pgx.Exec를 사용합니다. 그러나 이 접근 방식은 비효율적일 수 있으며 특히 대량 삽입의 경우 오류가 발생하기 쉽습니다.

문제 식별

"인수 10개를 예상했는데 1개가 있습니다"라는 오류 메시지는 제공된 인수 수와 데이터베이스에서 예상하는 인수 수가 일치하지 않습니다. 이 오류는 INSERT 문을 수동으로 구성하고 인수 개수나 순서에 실수가 있을 수 있기 때문에 발생합니다.

올바른 접근 방식

대량 삽입을 수행하려면 효율적으로 이러한 작업을 위해 설계된 PostgreSQL 복사 프로토콜을 활용하는 pgx의 CopyFrom 기능을 활용하세요. CopyFrom을 사용하면 소스의 행을 테이블에 대량 삽입할 수 있습니다.

CopyFrom을 사용한 코드 예

package main

import (
    "context"
    "fmt"
    "log"

    "github.com/jackc/pgx/v4"
)

const (
    dbUrl = "db url..."
)

type tempKey struct {
    keyVal  string
    lastKey int
}

func main() {
    conn, err := pgx.Connect(context.Background(), dbUrl)
    if err != nil {
        log.Fatalf("Error connecting to the database: %v", err)
    }
    defer conn.Close(context.Background())

    data := []tempKey{
        {keyVal: "abc", lastKey: 10},
        {keyVal: "dns", lastKey: 11},
        {keyVal: "qwe", lastKey: 12},
        {keyVal: "dss", lastKey: 13},
        {keyVal: "xcmk", lastKey: 14},
    }

    copyCount, err := conn.CopyFrom(
        context.Background(),
        pgx.Identifier{"keys"}, // Table name
        []string{"keyval", "lastval"}, // Column names
        pgx.CopyFromRows(data), // Copy from a slice of structs
    )

    if err != nil {
        log.Fatalf("Error copying data to the database: %v", err)
    }

    fmt.Printf("%d rows copied successfully.\n", copyCount)
}

위 내용은 pgx를 사용하여 Go를 사용하여 Postgres에서 대량 삽입을 효율적으로 수행하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.