GOLANG之学习类库-mysql

接着上一篇，我们学习了复用goconfig做本地配置的一些操作，接下来我们复用配置来进行连接mysql数据库的相关操作。

一，准备工作

　　1，导入数据库驱动

　　　　

import (
    "database/sql"
    "fmt"
    "github.com/Unknwon/goconfig"
    _ "github.com/go-sql-driver/mysql"   初始化执行init
    "log"
    "os"
    "time"
)

　　2，准备本地mysql数据库

　　

CREATE TABLE `user` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `name` varchar(20) DEFAULT NULL,
  `age` tinyint(4) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4

二，连接MYSQL

　　

mysqlConfig,err:= ConfigFile.GetSection("mysql")
    if err !=nil{
        fmt.Println("no mysql section config")
        os.Exit(1)
    }

    //生成连接mysql dsn
    fillDns(mysqlConfig)

    //连接mysql
    db,err := sql.Open("mysql",dns)
    if err != nil {
        panic(err.Error())
    }
    defer db.Close()

    //连接超时
    db.SetConnMaxLifetime(10*time.Second)
    //最大连接数
    db.SetMaxOpenConns(100)
    //连接空闲数
    db.SetMaxIdleConns(16)

三，CURD操作

　　INSERT DATA　　

rows,err := db.Exec("insert into user(name,age) values('test',4)")
    if err !=nil{
        fmt.Printf("insert failed:%v
",err)
        return
    }
    lastinsertid,_ := rows.LastInsertId()
    affectedrows,_ := rows.RowsAffected()

　　SELECT DATA

stmtout,err := db.Prepare("select name,age from user where id=?")
    if err!=nil{
        log.Fatalf(err.Error())
    }
    defer stmtout.Close()
    user := new(User)
    err = stmtout.QueryRow(2).Scan(&user.name,&user.age)
    if err !=nil{
        log.Fatalf(err.Error())
    }
    fmt.Println(user.name,user.age)

　　UPDATE DATA

result,err := db.Exec("UPDATE user set age=? where id=?",20,1)
if err != nil{
    fmt.Printf("Insert failed,err:%v",err)
    return
}
rowsaffected,err := result.RowsAffected()

　　DELETE DATA

result,err := db.Exec("delete from user where id=?",1)
    if err !=nil {
        log.Fatalf(err.Error())
    }
    fmt.Println(result.RowsAffected())

四，总结

　　其实对DB的操作和其它语言都类似的，也可以事物，PREPARE预处理SQL等，有一点不太一样，就是其它语言基本不用再次声明对DB操作的结果，可以自动转换，GO中还要壹声明结构体，变更等来接收从DB取出来的数据。

　　学习了配置，学习了基本连接MYSQL，未完待续。