63 lines
1.1 KiB
Go
63 lines
1.1 KiB
Go
package main
|
||
|
||
import (
|
||
"fmt"
|
||
"github.com/jmoiron/sqlx"
|
||
"log"
|
||
|
||
_ "github.com/go-sql-driver/mysql"
|
||
)
|
||
|
||
// sqlx 另外的库
|
||
|
||
var databasE *sqlx.DB
|
||
|
||
type users struct {
|
||
ID int
|
||
NAME string
|
||
AGE int
|
||
}
|
||
|
||
func main() {
|
||
err := initd()
|
||
if err != nil {
|
||
return
|
||
}
|
||
//查询单行，不需要scan也能拿到结果
|
||
sqlstr := `select id,name,age from user where id=1`
|
||
var u users
|
||
err = databasE.Get(&u, sqlstr)
|
||
if err != nil {
|
||
return
|
||
}
|
||
fmt.Println(u)
|
||
//查询多行
|
||
var ulist = make([]users, 0, 1) //引用类型初始化
|
||
sqlstr2 := `select id,name,age from user`
|
||
//必须要传指针
|
||
err = databasE.Select(&ulist, sqlstr2)
|
||
if err != nil {
|
||
fmt.Println(err)
|
||
return
|
||
}
|
||
fmt.Println(ulist)
|
||
}
|
||
|
||
func initd() (err error) {
|
||
databasE, err = sqlx.Connect("mysql", "root:123456@tcp(43.143.245.135:3306)/user")
|
||
if err != nil {
|
||
log.Println(err)
|
||
return err
|
||
}
|
||
//connect方法提供了ping。所以不需要ping
|
||
//err = databasE.Ping()
|
||
//if err != nil {
|
||
// log.Println(err)
|
||
// return err
|
||
//}
|
||
log.Println("Successfully connected to mysql")
|
||
databasE.SetMaxOpenConns(10)
|
||
databasE.SetMaxIdleConns(5)
|
||
return nil
|
||
}
|