下面的代码应指导您要走的方向:
package mainimport ( "fmt" "log" "os" "os/exec" "strings")func main() { keys := []string{"customer"} sqlCmd := fmt.Sprintf("COPY tester(%s) FROM STDIN (FORMAT CSV)", strings.Join(keys, ",")) cmd := exec.Command("psql", "<dbname>", "-U", "<username>", "-h", "<host_ip>", "--no-password", "-c", sqlCmd) cmd.Stdin = os.Stdin output, _ := cmd.CombinedOutput() log.Println(string(output))}
如果密钥需要动态,则可以从中获取密钥
os.Args。
请注意,如果您打算使用psql命令,则不需要导入数据库/ sql或lib / pq。如果您对使用lib / pq感兴趣,请参阅lib /
pq文档中的Bulk imports。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)