go-xorm连接

package mainimport ("fmt"_ "github.com/go-sql-driver/mysql""time""xorm.io/xorm"
)func MysqlDbContent() {//数据库基本信息var (userName  string = "root"password  string = "12345678"ipAddress string = "127.0.0.1"port      int    = 3306dbName    string = "dt"charset   string = "utf8mb4")//构建数据库连接信息dataSourceName := fmt.Sprintf("%s:%s@tcp(%s:%d)/%s?charset=%s", userName, password, ipAddress, port, dbName, charset)engine, err := xorm.NewEngine("mysql", dataSourceName)if err != nil {fmt.Println("数据库连接失败:")}fmt.Println("数据库连接成功")type User struct {Id      int64Name    stringAvatar  string `xorm:"varchar(200)"`Age     intPasswd  string    `xorm:"varchar(200)"`Created time.Time `xorm:"created"`Updated time.Time `xorm:"updated"`}err = engine.Sync(new(User))if err != nil {fmt.Println("表结构同步失败")}fmt.Println("表结构同步成功")}

数据库增删改查

package mainimport ("fmt"_ "github.com/go-sql-driver/mysql""time""xorm.io/xorm"
)func MysqlDbContent() {//数据库基本信息var (userName  string = "root"password  string = "12345678"ipAddress string = "127.0.0.1"port      int    = 3306dbName    string = "dt"charset   string = "utf8mb4")//构建数据库连接信息dataSourceName := fmt.Sprintf("%s:%s@tcp(%s:%d)/%s?charset=%s", userName, password, ipAddress, port, dbName, charset)engine, err := xorm.NewEngine("mysql", dataSourceName)if err != nil {fmt.Println("数据库连接失败:")}fmt.Println("数据库连接成功")type User struct {Id      int64Name    stringAvatar  string `xorm:"varchar(200)"`Age     intPasswd  string    `xorm:"varchar(200)"`Created time.Time `xorm:"created"`Updated time.Time `xorm:"updated"`}err = engine.Sync(new(User))if err != nil {fmt.Println("表结构同步失败")}fmt.Println("表结构同步成功")//插入数据 插入 对象,返回值：受影响行数user1 := User{Id: 1001, Name: "张三1", Avatar: "http://www.baidu.com", Age: 20, Passwd: "12345678", Created: time.Now(), Updated: time.Now()}user2 := User{Id: 1002, Name: "张三2", Avatar: "http://www.baidu.com", Age: 20, Passwd: "12345678", Created: time.Now(), Updated: time.Now()}user3 := User{Id: 1003, Name: "张三3", Avatar: "http://www.baidu.com", Age: 20, Passwd: "12345678", Created: time.Now(), Updated: time.Now()}insert, _ := engine.Insert(&user1, &user2, &user3)if insert > 1 {fmt.Println("数据插入成功")}var users []Userusers = append(users, User{Id: 1004, Name: "张1", Avatar: "http://www.baidu.com", Age: 20, Passwd: "12345678", Created: time.Now(), Updated: time.Now()})users = append(users, User{Id: 1005, Name: "张2", Avatar: "http://www.baidu.com", Age: 20, Passwd: "12345678", Created: time.Now(), Updated: time.Now()})users = append(users, User{Id: 1006, Name: "张3", Avatar: "http://www.baidu.com", Age: 20, Passwd: "12345678", Created: time.Now(), Updated: time.Now()})//批量插入数据  Inserti, err := engine.Insert(&users)if i > 1 {fmt.Println("批量数据插入成功")}//Update//查询id=1000的数据并修改name字段user := User{Name: "laozhang"}update, err := engine.ID(1000).Update(&user)fmt.Println(update)//Deleteuser1 = User{Name: "张1"}i2, _ := engine.ID(1004).Delete(&user1)fmt.Println(i2)engine.Exec("update user set age = ? where id = ?", 10, 1003)//查询results, _ := engine.Query("select * from user")fmt.Println(results)results2, _ := engine.QueryString("select * from user")fmt.Println(results2)results3, _ := engine.QueryInterface("select * from user")fmt.Println(results3)//Get  select * from user limit 1user11 := User{}engine.Get(&user11)fmt.Println(user11)//指定条件查询用户user12 := User{Name: "张1"}engine.Where("name = ?", user1.Name).Desc("id").Get(&user12)fmt.Println(user12)//获取指定字段的值var name stringengine.Table(&user).Where("id = ?", 1002).Cols("name").Get(&name)fmt.Println(name)//Find 查询多条记录var users112 []Userengine.Where("password=12345678").And("age=20").Limit(10, 0).Find(&users112)fmt.Println(users112)//Count 统计记录数user113 := User{Passwd: "12345678"}count, _ := engine.Count(&user113)fmt.Println(count)//Iterate 和 Rows 根据条件遍历数据库，可以有两种方式: Iterate and Rowsengine.Iterate(&User{Passwd: "12345678"}, func(idx int, bean interface{}) error {user := bean.(*User)fmt.Println(user)return nil})rows, _ := engine.Rows(&User{Passwd: "12345678"})defer rows.Close()userBean := new(User)for rows.Next() {rows.Scan(userBean)fmt.Println(userBean)}
}