go database/sql sql-driver/mysql 操作

nawawa001

func main (){//insert　　name := "name"
　　pwd := "password"
　　nickname := "nickname"
　　db,err := sql.Open("mysql","go_mysql_user:go_mysql_pwd@tcp(localhost:3306)/go_mysql?")
　　if err != nil{
　　panic(err.Error())
　　log.Println(err)
　　return
　　}
　　defer db.Close()  //只有在前面用了 panic[抛出异常] 这时defer才能起作用，如果链接数据的时候出问题，他会往err写数据。defer:延迟，这里立刻申请了一个关闭sql 链接的草错，defer 后的方法，或延迟执行。在函数抛出异常一会被执行
　　insert_sql := "insert into users (name,pwd,nickname) value (?,?,?),(?,?,?),(?,?,?),(?,?,?)"
　　stmt,err := db.Prepare(insert_sql)        //准备一个sql操作，返回一个*Stmt,用户后面的执行,这个Stmt可以被多次执行，或者并发执行
　　/*
　　*    这个stmt的主要方法:Exec、Query、QueryRow、Close
　　*/
　　if err != nil {
　　log.Println(err)
　　return
　　}
　　res,err := stmt.Exec(name,pwd,nickname,name,pwd,nickname,name,pwd,nickname,name,pwd,nickname)
　　if err != nil {
　　log.Println(err)
　　return
　　}
　　lastInsertId,err := res.LastInsertId()        //批量插入的时候LastInserId返回的是第一条id,单条插入则返回这条的id
　　//lastInsertId,err := res.RowsAffected()        //插入的是后RowsAffected 返回的是插入的条数
　　if err != nil {
　　log.Println(err)
　　return
　　}
　　//log.Println(reflect.TypeOf(lastInsertId))    //打印变量类型
　　last_insert_id_string := strconv.FormatInt(lastInsertId,10)    //int64 转string 需要引入 strconv包
　　log.Println("lastInsertId = " + last_insert_id_string)
　　
}