go get github.com/go-sql-driver/mysql

import(

    "database/sql"

    _"github.com/Go-SQL-Driver/MySQL"

    "log"

    "strconv"

    //"reflect"    //获取变量类型用

)

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?charset=utf8")

    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,)    //int64 转string 需要引入 strconv包

    log.Println("lastInsertId = " + last_insert_id_string)

}

func main (){

    //delete

    del_sql := "delete from users where id=?"

    del_stmt,del_err := db.Prepare(del_sql)

    del_stmt.Exec()//不返回任何结果

}

func main (){

    //update

    update_sql := "update users set name=? where id=?"

    update_stmt,update_err := db.Prepare(update_sql)

    if update_err != nil {

            log.Println(update_err)

            return;

    }

    update_res,update_err := update_stmt.Exec("username",)

    if update_err != nil {

            log.Printf("%v",update_err)

            return

    }

    affect_count,_ := update_res.RowsAffected()    //返回影响的条数,注意有两个返回值

    log.Printf("%v",affect_count)

}

type User struct{

    id int

    name string

    pwd string

    nickname string

}

func main (){

    //select

    var user User

    select_sql := "select * from users where id > ?"

    select_err := db.QueryRow(select_sql,).Scan(&user.id,&user.name,&user.pwd,&user.nickname)//查询一条，返回一条结果。并赋值到user这个结构体类型的变量中,就算查询到的是多条，单返回的还是一条

    if select_err != nil {//如果没有查询到任何数据就进入if中err：no rows in result set

            log.Println(select_err)

            return

    }

    log.Println(user)

}

func main (){

    //查询多条

    select_rows,select_err := db.Query(select_sql,)

    if select_err != nil {

            log.Println(select_err)

            return

    }

    defer select_rows.Close()

    for select_rows.Next(){

        var id int

        var name string

        var pwd string

        var nickname string

        if err := select_rows.Scan(&id,&name,&pwd,&nickname); err != nil {

                log.Println(err)

                return

        }

        log.Printf("id=%v,name=%v,pwd=%v,nickname=%v",id,name,pwd,nickname)

    }

}

func main (){

    //事务

    tx,err := db.Begin()        //声明一个事务的开始

    if err != nil {

            log.Println(err)

            return

    }

    insert_sql := "insert into users (name,pwd,nickname) value(?,?,?)"

    insert_stmt,insert_err := tx.Prepare(insert_sql)

    if insert_err != nil {

            log.Println(insert_err)

            return

    }

    insert_res,insert_err := insert_stmt.Exec("tx_name","tx_pwd","tx_nickname")

    last_insert_id,_ := insert_res.LastInsertId()

    log.Println(last_insert_id)

    defer tx.Rollback()            //回滚之前上面的last_login_id是有的，但在回滚后该操作没有被提交，被回滚了，所以上面打印的Last_login_id的这条数据是不存在于数据库表中的

    //tx.Commit()                        //这里提交了上面的操作，所以上面的执行的sql 会在数据库中产生一条数据

}

db,err := sql.Open("mysql","数据库登录名:数据库密码@tcp(服务器:端口)/数据库名?charset=utf8") 对应修改；

defer db.Close()　　defer 是延迟或异常或者该方法结束时执行的操作。这里表示有异常就关闭db 可与 panic(err.Error())=》抛出异常。配合使用。一种情况不可执行＝》你的方法进入了死循环，该方法不会结束与异常则不可执行。

LastInsertId()　　获取插入第一条的id　　有用

RowsAffected()　　获取影响/插入的条数　　有用

reflect.TypeOf(i)　　reflect包中TypeOf 返回的是变量i的类型

strconv.FormatInt(int64位变量,)　　strconv包中FormatInt将int64位的变量转为string

https://github.com/go-sql-driver/mysql