go并发写入mysql数据库

package main

import (
    "database/sql"
    "fmt"
    "sync"
    _ "github.com/go-sql-driver/mysql"
)

func main() {
    // 创建数据库连接
    db, err := sql.Open("mysql", "username:password@tcp(127.0.0.1:3306)/database")
    if err != nil {
        fmt.Println("数据库连接失败：", err)
        return
    }
    defer db.Close()

    // 并发写入数据
    var wg sync.WaitGroup
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func(n int) {
            defer wg.Done()

            // 执行SQL插入操作
            _, err := db.Exec("INSERT INTO table (column) VALUES (?)", n)
            if err != nil {
                fmt.Println("写入数据失败：", err)
            }
        }(i)
    }
    wg.Wait()

    fmt.Println("并发写入数据完成")
}