package main
import (
"fmt"
"time"
_ "github.com/go-sql-driver/mysql"
"github.com/go-xorm/core"
"github.com/go-xorm/xorm"
)
type Member struct {
Memberid int64 `xorm:"int(10) pk not null autoincr 'member_id'"`
Member_name string `xorm:"char(50) not null"`
Member_pwd string `xorm:"char(32) not null"`
Member_count int64 `xorm:"smallint(6) not null default 0 "`
Member_ok string `xorm:"varchar(50) not null"`
Member_del int64 `xorm:"bigint(1) not null default 0 "`
Member_email string `xorm:"varchar(40) not null"`
Member_logintime time.Time `xorm:"updated"`
Member_createtime int64 `xorm:"int(11) not null default 0"`
Member_updatetime int64 `xorm:"int(11) not null default 0"`
Member_ip string `xorm:"varchar(40) not null"`
Member_version int64 `xorm:"version"`
}
var (
engine *xorm.Engine
)
func main() {
//數據庫連接參數
params := fmt.Sprintf("%s:%s@tcp(%s)/%s?charset=utf8&parseTime=true", "root", "root", "localhost:3306", "go")
var err error
//連接數據庫
engine, err = xorm.NewEngine("mysql", params)
if err != nil {
panic(err)
}
//添加統一前綴
tbMapper := core.NewPrefixMapper(core.SnakeMapper{}, "go_")
engine.SetTableMapper(tbMapper)
defer engine.Close()
member := new(Member)
//Count查詢總條數
total, terr := engine.Count(member)
if terr != nil {
panic(terr)
}
fmt.Println("go_member總信息條數為: ", total, "條")
//Rows逐條執行查詢到的記錄
getrow := member
rows, rerr := engine.Where("member_id > ?", 1).Desc("member_id").Limit(10,0).Rows(getrow)
if rerr != nil {
panic(rerr)
}
defer rows.Close()
for rows.Next() {
rerr = rows.Scan(getrow)
if rerr != nil {
panic(rerr)
}
fmt.Println(getrow)
}
}