golang連接mysql

1、mysql數(shù)據(jù)驅(qū)動：github.com/go-sql-driver/mysql

安裝：

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

• 構(gòu)建連接, 格式是：”用戶名:密碼@tcp(IP:端口)/數(shù)據(jù)庫?charset=utf8”
• 打開數(shù)據(jù)庫,前者是驅(qū)動名，所以要導(dǎo)入：_ “github.com/go-sql-driver/mysql”

初始化

func init(){
    db,err:=sql.Open("mysql","root:1111@tcp(127.0.0.1:3306)/test?charset=utf8")
    if err!=nil{
        fmt.Println("dbiniterr:",err)
    }
}

插入數(shù)據(jù) insert

插入前需要提前登錄mysql創(chuàng)建表對應(yīng)的字段。

typeDBworkerstruct{
    Db*sql.DB
}
//插入數(shù)據(jù)測試
func(dbw*DBWorker)insertData(){
//stmt,_:=dbw.Db.Prepare(`INSERTINTOuser1(name,age)VALUES(?,?)`)

//deferstmt.Close()
stmt,err:=dbw.Db.Prepare("INSERTINTO user1 (`user`,`age`) VALUES (?,?)")
  if err!=nil{
    fmt.Println("Preparefail",err)
    return
}

ret,err:=stmt.Exec(1,23)

if err!=nil{
   fmt.Printf("insertdataerror:%v\n",err)
   return
}

if  LastInsertId,err:=ret.LastInsertId();err==nil{
    fmt.Printf("LastInsertId%d\n",LastInsertId)
}

if RowsAffected,err:=ret.RowsAffected();err==nil{
  fmt.Printf("RowsAffected%d\n",RowsAffected)
  }
}

查詢數(shù)據(jù)測試

func (dbw *DBWorker) queryData()  {
    stmt, _ := dbw.Db.Prepare("SELECT * FROM user WHERE age = ?")

    defer stmt.Close()

    user := userTB{}

   //查詢user表中age等于23的數(shù)據(jù)
    rows, err := stmt.Query(23)

    defer rows.Close()

    if err != nil {
        fmt.Printf("query data error : %v\n", err)
        return;
    }

2、驅(qū)動：github.com/jinzhu/gorm

gorm官方中文文檔：https://jasperxu.github.io/gorm-zh/

安裝

go get -u github.com/jinzhu/gorm

連接數(shù)據(jù)庫

要連接到數(shù)據(jù)庫，首先要導(dǎo)入驅(qū)動程序：

import _ "github.com/go-sql-driver/mysql"

連接mysql

import (
    "github.com/jinzhu/gorm"
    _ "github.com/jinzhu/gorm/dialects/mysql"
)

func main() {
  db, err := gorm.Open("mysql", "user:password@/dbname?charset=utf8&parseTime=True&loc=Local")
  defer db.Close()
}

注：為了處理time.Time，您需要包括parseTime作為參數(shù)。

遷移

自動遷移

警告：自動遷移僅僅會創(chuàng)建表，缺少列和索引，并且不會改變現(xiàn)有列的類型或刪除未使用的列以保護(hù)數(shù)據(jù)。

db.AutoMigrate(&User{})

db.AutoMigrate(&User{}, &Product{}, &Order{})

// 創(chuàng)建表時添加表后綴
db.Set("gorm:table_options", "ENGINE=InnoDB").AutoMigrate(&User{})

檢查表是否存在

// 檢查模型`User`表是否存在
db.HasTable(&User{})

// 檢查表`users`是否存在
db.HasTable("users")

創(chuàng)建表

// 為模型`User`創(chuàng)建表
db.CreateTable(&User{})

// 創(chuàng)建表`users'時將“ENGINE = InnoDB”附加到SQL語句
db.Set("gorm:table_options", "ENGINE=InnoDB").CreateTable(&User{})

刪除表

// 刪除模型`User`的表
db.DropTable(&User{})

// 刪除表`users`
db.DropTable("users")

// 刪除模型`User`的表和表`products`
db.DropTableIfExists(&User{}, "products")

修改列

修改列的類型為給定值

// 修改模型`User`的description列的數(shù)據(jù)類型為`text`
db.Model(&User{}).ModifyColumn("description", "text")

刪除列

// 刪除模型`User`的description列
db.Model(&User{}).DropColumn("description")

更多有關(guān)gorm的操作請參考官方文檔