golang mysql 批量

在golang中，有许多可用的数据库管理驱动程序，MySQL便是其中之一。 如果要大规模处理MySQL数据库中的数据，往往需要使用批量操作。 以下是有关在golang中使用MySQL批量处理的一些示例代码。

import (
"database/sql"
"fmt"
_ "github.com/go-sql-driver/mysql"
)
func main() {
db, err := sql.Open("mysql", "user:password@/dbname")
if err != nil {
panic(err.Error())
}
defer db.Close()
rows, err := db.Query("SELECT * FROM users")
if err != nil {
panic(err.Error())
}
defer rows.Close()
// 遍历结果集
var users []User
for rows.Next() {
var user User
err := rows.Scan(&user.ID, &user.Name, &user.Email)
if err != nil {
panic(err.Error())
}
users = append(users, user)
}
// 批量插入数据
values := []interface{}{}
for _, user := range users {
values = append(values, user.Name, user.Email)
}
stmt, err := db.Prepare("INSERT INTO users (name, email) VALUES (?, ?)")
if err != nil {
panic(err.Error())
}
defer stmt.Close()
_, err = stmt.Exec(values...)
if err != nil {
panic(err.Error())
}
fmt.Printf("插入 %d 条数据成功！", len(users))
}

在上面的代码中，我们首先打开MySQL数据库的连接。然后，我们执行一个SELECT查询来获取数据。我们使用批量操作将这些数据插入到users表中。

值得注意的是，我们在每个语句的末尾都添加了defer语句，这是为了在操作完成后关闭连接和任何打开的结果集和语句。