使用Go从一个postgres数据库复制到另一个数据库

使用Go从一个PostgreSQL数据库复制到另一个数据库，可以通过以下步骤实现：

首先，确保已经安装了Go编程语言和相关的PostgreSQL驱动程序。可以使用go get命令安装所需的驱动程序，例如go get github.com/lib/pq。
在Go代码中导入所需的包，包括database/sql和github.com/lib/pq。

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

创建源数据库和目标数据库的连接。使用sql.Open函数打开两个数据库的连接，并分别传入相应的数据库连接字符串。

sourceDB, err := sql.Open("postgres", "source_db_connection_string")
if err != nil {
    // 处理连接错误
}

targetDB, err := sql.Open("postgres", "target_db_connection_string")
if err != nil {
    // 处理连接错误
}
defer sourceDB.Close()
defer targetDB.Close()

查询源数据库中的数据。使用sourceDB.Query函数执行查询语句，并获取结果集。

rows, err := sourceDB.Query("SELECT * FROM table_name")
if err != nil {
    // 处理查询错误
}
defer rows.Close()

遍历结果集并插入到目标数据库。使用rows.Next函数迭代结果集中的每一行数据，并使用targetDB.Exec函数将数据插入到目标数据库中。

for rows.Next() {
    var column1, column2 string
    err := rows.Scan(&column1, &column2)
    if err != nil {
        // 处理扫描错误
    }

    _, err = targetDB.Exec("INSERT INTO table_name (column1, column2) VALUES ($1, $2)", column1, column2)
    if err != nil {
        // 处理插入错误
    }
}