Categorygithub.com/jesusslim/slimmysql
modulepackage
2.1.0+incompatible
Repository: https://github.com/jesusslim/slimmysql.git
Documentation: pkg.go.dev

# README

slimmysql

a nice tool for mysql query

go语言下的mysql工具类 摈弃了ORM

contact me:[email protected]

github地址:https://github.com/jesusslim/slimmysql

使用:
//初始化
err = slimmysql.InitSqlDefault("user", "pass", "ip", "port", "db", "prefix", false) //last param true:check sql safe

//More connections? 多个数据库连接
err = slimysql.InitSql(1,"user", "pass", "ip", "port", "db", "prefix", false) //last param true:check sql safe
//How to use? 切换数据库连接
slimsql.SetConn(1)	

if err != nil {
	this.Ctx.WriteString(err.Error())
}

slimsql := new(slimmysql.Sql)

//查询
采用map[string]interface{}作为查询条件传入
map的key代表字段 value代表指
like/>/</between等等都在字段名称后面加上__like等
例如 nickname like : key=nickname__like
默认为=
like:__like
>:__gt
>=:__egt
<:__lt
<=:__elt
!=:__neq
between:__between
in:__in
notin:__notin
isnull:__isnull
isnotnull:__isnotnull

key=relation表示and、or等 默认为and
如果需嵌套condition 则key="__" value=map[string]interfcae{}
例子:
	condition := map[string]interface{}{
	"relation":       "or",
	"nickname__like": "Jesus",
	"_": map[string]interface{}{
		"id__gt": 10385,
		"_": map[string]interface{}{
			"relation": "or",
			"_": map[string]interface{}{
				"status":    1,
				"acoin__gt": 200,
			},
			"type": 2,
		},
		"create_time__between": "1431619200|1433088000",
	},
	"id__egt": 10575,
}

stds, err := slimsql.Table("students").Where(condition).Page(1, 10).Order("id desc").Fields("id,nickname,nickname_cn,acoin,mobile").Select()

//mysql:Select: SELECT id,nickname,nickname_cn,acoin,mobile FROM `pre_students`  WHERE  ( id > 10385  AND ( ( status = '1'  AND acoin > 200 ) OR type = '2' ) AND  ( create_time >= 1431619200 AND create_time <= 1433088000 ) ) OR id >= 10575  OR nickname LIKE '%Jesus%'  ORDER BY id desc  LIMIT 0,10

函数:
where
group
having
order
page
pk 设置主键
join :slimsql.Table("A").join("left join B on A.id = B.aid")
count
find 查询单个 返回一个map
select 返回一个map数组
getField 与select类似 返回一个value为map的map 以getfield中第一个字段作为key
setinc 增长
save update
add insert
delete

事务支持
starttrans
commit
rollback

锁表等
Lock
Unlock
LockRow(forupdate)

ping 测试连接状态

clear 清除slimmysql.Sql对象中的值(不清楚的情况下可重复使用 例如select之后 直接调用count可获得数量 而不需要重新传入condition等)

具体可参考gowalker:https://gowalker.org/github.com/jesusslim/slimmysql



例子
//example:

//function in a controller based on beego
初始化
err = slimmysql.InitSqlDefault("user", "pass", "ip", "port", "db", "prefix", false) //last param true:check sql safe

if err != nil {
	this.Ctx.WriteString(err.Error())
}

slimsql := new(slimmysql.Sql)

condition := map[string]interface{}{
	"relation":       "or",
	"nickname__like": "Jesus",
	"_": map[string]interface{}{
		"id__gt": 10385,
		"_": map[string]interface{}{
			"relation": "or",
			"_": map[string]interface{}{
				"status":    1,
				"acoin__gt": 200,
			},
			"type": 2,
		},
		"create_time__between": "1431619200|1433088000",
	},
	"id__egt": 10575,
}

stds, err := slimsql.Table("students").Where(condition).Page(1, 10).Order("id desc").Fields("id,nickname,nickname_cn,acoin,mobile").Select()

//mysql:Select: SELECT id,nickname,nickname_cn,acoin,mobile FROM `pre_students`  WHERE  ( id > 10385  AND ( ( status = '1'  AND acoin > 200 ) OR type = '2' ) AND  ( create_time >= 1431619200 AND create_time <= 1433088000 ) ) OR id >= 10575  OR nickname LIKE '%Jesus%'  ORDER BY id desc  LIMIT 0,10

count, err := slimsql.Count("id")

//mysql:Count: SELECT count(id) FROM `pre_students`  WHERE  ( id > 10385  AND ( ( status = '1'  AND acoin > 200 ) OR type = '2' ) AND  ( create_time >= 1431619200 AND create_time <= 1433088000 ) ) OR id >= 10575  OR nickname LIKE '%Jesus%'

slimsql2 := new(slimmysql.Sql)

tchs, err := slimsql2.Table("teachers").Where("status = 4").Page(1, 10).Fields("id,nickname").Select()

//mysql:Select: SELECT id,nickname FROM `pre_teachers`  WHERE status = 4  LIMIT 0,10

//Transaction
sql := new(slimmysql.Sql)
sql2 := new(slimmysql.Sql)
sql.StartTrans()
sql2.StartTrans()
data := map[string]interface{}{
	"nickname": "tx",
}
data2 := map[string]interface{}{
	"nickname": "tx2",
}
sql.Table("students").Where("id=10605").Save(data)
sql2.Table("students").Where("id=10606").Save(data2)
sql.Rollback()
sql2.Commit()

# Functions

* * [NewSqlInstance Get a new instance for user] * @param {[string]} name string [connection name] * @return (*Sql, error) */.
* * [NewSqlInstanceDefault Get a new instance for user] */.
* * [RegisterConnection Reg a connection] * @param {[string]} name string [connection name] * @param {[bool]} rwSep bool [use RWseparate] * @param {[string]} hosts [hosts for exp:192.168.0.1,192.168.0.2] * @param {[string]} port [port for exp:3306,3307] * @param {[string]} dbname [dbnames] * @param {[string]} user [users] * @param {[string]} pass string [passwords] * @param {[string]} pre string [prefix] * @param {[bool]} safe bool [safemode] * @param {[int]} maxOpenConnsNmaxIdleConns ...int [maxOpenConns and maxIdleConns for exp:2000,1000] */.
* * [RegisterConnectionDefault Reg the default connection] * @param {[bool]} rwSep bool [use RWseparate] * @param {[string]} hosts [hosts for exp:192.168.0.1,192.168.0.2] * @param {[string]} port [port for exp:3306,3307] * @param {[string]} dbname [dbnames] * @param {[string]} user [users] * @param {[string]} pass string [passwords] * @param {[string]} pre string [prefix] * @param {[bool]} safe bool [safemode] * @param {[int]} maxOpenConnsNmaxIdleConns ...int [maxOpenConns and maxIdleConns for exp:2000,1000] */.

# Constants

No description provided by the author

# Structs

No description provided by the author
No description provided by the author