MyRose，是Gorose的一个衍生品，但又与Gorose完全无关，只是借鉴了Gorose的设计**（及小部分代码，在构件框架的时候使用了Gorose的方法名），并且将数据库的支持范围缩小到了MySQL及其衍生数据库。
查询器的设计**仍然采用了 PHP 框架 Laravel 的设**。
如果说GoRose是一个方便快捷易用的查询构造器（fizzday仁兄称之为ORM，我持保留意见），那MyRose是一款为了团队开发（特别是团队中有许多喜欢胡乱写SQL的成员的团队）量身定制的Golang的数据库查询构造器。
MyRose的一个特点就是约束，大量的字段检查，大量的条件约束，一不留神在提交SQL到MySQL之前，你就会不停的收到错误。
虽然我觉得是言过其实了，其实没这么吓人，开发这个构造器的目的是打算在团队开发中从 PHP 转换为 Golang，我也比较了许多同类的查询器、ORM，Gorose 是比较适合从 PHP 转到 Golang 的，但是在一个 DEMO 之后就发觉了不少问题，当然了，我也给 fizzday 仁兄提交了一些改进意见。
废话不多说，开始吧！
// SELECT * FROM `users` WHERE `id`=1 LIMIT 1
db.Table("users").Where("id",1).First()
// SELECT `id` AS uid, `name`, `age` FROM `users` WHERE `id`=1 ORDER BY `id` DESC, `name` ASC LIMIT 10
db.Table("users").Fields("id as uid", "name", "age").Where("id",1).Order("id", "desc").Order("name").Limit(10).Get()
// query string
db.Query("SELECT * FROM `user` LIMIT 10")
db.Execute("UPDATE `users` SET `name`='luispater' WHERE id=?", 1)也许你会说这不就是Gorose的代码么？OK，再来点好玩的！
//named parameter in the SQL statement
db.Execute("UPDATE `users` SET `name`=:name WHERE `id`=:id", map[string]interface{}{"name":"luispater", "id":3})
//SELECT * FROM `table_1` WHERE `t1_id` IN (SELECT `t1_id` FROM `table_2` WHERE `t2_id` IN (1, 2))
db.Table("table_1").Where("t1_id", "IN", db.Table("table_2").Fields("t1_id").Where("t2_id", "IN", []int{1, 2}))- 使用查询构造器时进行强制字段约束
- 链式操作
- 连接池（这个不是我实现的……Golang自带了……）
- 标签参数（go-sql-driver/mysql，不乐意实现点这里，我简单实现了一下）
- Golang 1.6+
- Glide (可选的，Golang的依赖管理工具)
- Golang官方安装:
go get -u github.com/luispater/myrose- 或者用 Glide:
glide get github.com/luispater/myrosepackage main
import (
"github.com/luispater/myrose"
"github.com/luispater/myrose/utils"
"fmt"
)
func main() {
// connect
dsn := "test:test@unix(/tmp/mysql.sock)/myrose?charset=utf8"
db, err := myrose.New(dsn)
if err != nil {
fmt.Println(err)
return
}
defer db.Close()
// insert
insert := myrose.NewData()
insert["name"] = "luis"
insert["password"] = utils.Md5("luis")
insert["status"] = 1
intInsertId, err := db.Table("users").Insert(insert)
if err != nil {
fmt.Println(err)
} else {
fmt.Printf("Insert Id: %d\n", intInsertId)
}
// first row query
res, err := db.Table("users").First()
if err != nil {
fmt.Println(err)
}
fmt.Println(res)
// update
update := myrose.NewData()
update["password"] = utils.Md5("luis1")
update["status"] = 0
intAffectedNum, err := db.Table("users").Where("name", "=", "luis").Update(update)
if err != nil {
fmt.Println(err)
} else {
fmt.Printf("Update Affected Number: %d\n", intAffectedNum)
}
// all row query
rows, err := db.Table("users").Where("status", "=", 0).Get()
if err != nil {
fmt.Println(err)
}
fmt.Println(rows)
// add test data
for i:=0; i<1000; i++ {
insert := myrose.NewData()
insert["name"] = fmt.Sprintf("luis_%d", i)
insert["password"] = utils.Md5("luis")
insert["status"] = 1
intInsertId, err := db.Table("users").Insert(insert)
if err != nil {
fmt.Println(err)
} else {
fmt.Printf("Insert Id: %d\n", intInsertId)
insert := myrose.NewData()
insert["user_sex"] = "female"
insert["user_id"] = intInsertId
_, err := db.Table("users_info").Insert(insert)
if err != nil {
fmt.Println(err)
}
}
}
db.Begin()
// all row query
intAffectedNum, err = db.Table("users").Where("id", ">=", 500).Delete()
if err != nil {
fmt.Println(err)
} else {
fmt.Printf("Delete Affected Number: %d\n", intAffectedNum)
}
db.Rollback()
db.Begin()
// all row query
intAffectedNum, err = db.Table("users").Where("id", ">=", 500).Limit(50).Delete()
if err != nil {
fmt.Println(err)
} else {
fmt.Printf("Delete Affected Number: %d\n", intAffectedNum)
}
db.Rollback()
// left join
row, err := db.Table("users").LeftJoin(db.Table("users_info"), "id", "user_id").Where("id", "=", 101).First()
if err != nil {
fmt.Println(err)
}
fmt.Println(row)
// native mysql function
rows, err = db.Table("users").Fields("count(*) as count", "sum(id) as sum").Group("password").Having("sum", ">", 1).Get()
if err != nil {
fmt.Println(err)
}
fmt.Println(rows)
}更多的使用方法，请期待我的文档
MIT
1.0.2
- 为配合gopkg.in，将版本升级至1.0.2，代码无任何改编
0.0.2
- 增加不允许使用原始查询（Query、Execute）开关
- Where及Having中允许使用函数
- UPDATE语句中增加类似a = a + 1的语法，原子操作，避免事务操作中的更新丢失（Lost Update）
0.0.1
- 实现了查询器的基本功能，增删改查都有了
- 强制使用statement进行查询，提高了查询的安全性
- 强制对使用的数据表中的字段进行检查，对查询中不存在的字段，不允许提交查询
- 对Delete、Update等操作进行安全检查，当没有任何Where条件的情况下，不允许提交查询
- 可使用DeleteForce、UpdateForce强制提交没有任何Where条件的查询
- 完成基础配置部分的代码
- 在README.md中添加使用代码
1.0.3
- 目前暂无开发计划
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent