mysql连接问题，goruntime里执行总是出错，程序一直崩溃

ylqjgm · 2015-05-24 03:02:46 · 3597 次点击

初学golang，尝试写一个程序，但是在mysql操作时遇到了问题~ 看网上文章，推荐mysql直接创建一个db全局变量，然后连接一次，以后使用到直接用这个db，我按照这样的方法，然后进行操作，可是程序却一直崩溃，代码如下：

var db *sql.DB

func put(str string) bool {
    // 执行到这里就崩溃
    rows, err := db.Query("SELECT `id` FROM `user` WHERE `username`='"+str+"';")
    if err != nil{
        panic(err)
    }
    defer rows
}

func main(){
    var err error
    db, err = sql.Open("mysql", "root:123456@tcp(127.0.0.1:3306)/dht?charset=utf8")
    if err != nil {
        panic(err)
    }
    defer db.Close()

    // 获取信息代码

    for{
        go func(str string) {
            ok := put(str)
            if !ok {
                fmt.Println("error")
            }
        }(str)

        time.Sleep(10 * time.Second)
    }
}