如何在无Shell/psql环境下用Go实现远程PostgreSQL的CSV无结构导入导出？

刚好碰到过类似的场景，结合你没法用psql、小数据量、无需定义结构体的需求，给你整理下可行的方案：

一、CSV导出：用sqltocsv就对了 #

你已经找到的sqltocsv确实是这个场景的最优解——完全不需要提前定义任何结构体或表Schema，直接基于SQL查询结果生成CSV，上手特别快。给你贴个极简示例：

package main

import (
    "database/sql"
    "os"
    _ "github.com/lib/pq" // 也可以用pgx的驱动
    "github.com/joho/sqltocsv"
)

func main() {
    // 先建立数据库连接，这里用pq驱动举例子
    db, err := sql.Open("postgres", "postgres://user:password@remote-host:5432/your-db?sslmode=disable")
    if err != nil {
        panic(err)
    }
    defer db.Close()

    // 创建要写入的CSV文件
    outputFile, err := os.Create("exported_data.csv")
    if err != nil {
        panic(err)
    }
    defer outputFile.Close()

    // 直接执行查询并导出，连结构体都不用写
    if err := sqltocsv.Write(db, outputFile, "SELECT * FROM your_target_table"); err != nil {
        panic(err)
    }
}

这个工具会自动读取查询结果的列名和对应数据，直接映射到CSV的表头和行，完美适配你的无Schema需求。

二、CSV导入：自动适配表结构的两种方式 #

导入的话，Go的标准库database/sql、pq或pgx本身不支持自动推断Schema，但因为数据量小，我们可以用两种简单的方式实现：

1. 先查表结构，动态构造COPY语句 #

我们可以先从PostgreSQL的information_schema里拿到目标表的列信息，再动态生成COPY命令（和psql的\copy逻辑一致），代码示例：

package main

import (
    "database/sql"
    "fmt"
    "os"
    "strings"
    _ "github.com/lib/pq"
)

func main() {
    db, err := sql.Open("postgres", "postgres://user:password@remote-host:5432/your-db?sslmode=disable")
    if err != nil {
        panic(err)
    }
    defer db.Close()

    // 第一步：查询目标表的所有列名（按顺序）
    rows, err := db.Query(`SELECT column_name 
                           FROM information_schema.columns 
                           WHERE table_name = 'your_target_table' 
                           ORDER BY ordinal_position`)
    if err != nil {
        panic(err)
    }
    defer rows.Close()

    var columns []string
    for rows.Next() {
        var colName string
        if err := rows.Scan(&colName); err != nil {
            panic(err)
        }
        columns = append(columns, colName)
    }

    // 第二步：构造COPY语句，指定列名
    copyQuery := fmt.Sprintf("COPY %s (%s) FROM STDIN WITH (FORMAT csv, HEADER)", 
        "your_target_table", strings.Join(columns, ","))
    
    // 第三步：执行COPY导入
    tx, err := db.Begin()
    if err != nil {
        panic(err)
    }
    defer tx.Rollback()

    stmt, err := tx.Prepare(copyQuery)
    if err != nil {
        panic(err)
    }
    defer stmt.Close()

    // 打开要导入的CSV文件
    csvFile, err := os.Open("to_import.csv")
    if err != nil {
        panic(err)
    }
    defer csvFile.Close()

    // 把CSV内容传入执行
    _, err = stmt.Exec(csvFile)
    if err != nil {
        panic(err)
    }

    // 提交事务完成导入
    if err := tx.Commit(); err != nil {
        panic(err)
    }
}

这个方法完全不需要提前定义结构体，自动适配目标表的Schema，适合小数据量的场景。

2. 找第三方导入工具（可选） #

如果不想自己写表结构查询的逻辑，可以找类似sqltocsv的导入工具，不过这类工具相对少一些，上面的手动方案已经足够简单可控了。

三、关于你问的几个库的说明 #

• database/sql：标准库本身没有Schema推断能力，但可以结合pq/pgx驱动执行动态生成的SQL，实现无结构体操作。
• pq/pgx：这两个都是PostgreSQL的Go驱动，都支持COPY命令的STDIN模式，能配合动态生成的列名实现无Schema导入，pgx性能更优，用法和pq大同小异。
• gorm：正如你体验的，它是ORM框架，必须依赖结构体映射表结构，确实不适合你的无Schema需求。

内容的提问来源于stack exchange，提问作者randobuzzer17