noth/surrealpatch
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Use uint64 as limit in mysql backend connector

Browse source
This commit is contained in:
Tobie Morgan Hitchcock 2016-11-17 14:18:11 +00:00
parent efa641e175
commit a57c2733fa
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
kvs/mysql/tx.go
View file

@ -144,7 +144,7 @@ func (tx *TX) RGet(beg, end []byte, max uint64) (kvs []kvs.KV, err error) {
max = math.MaxUint64
}
res, err := tx.tx.Query("SELECT `key`, `val` FROM kv WHERE `key` BETWEEN ? AND ? ORDER BY `key` ASC LIMIT ?", beg, end, int(max))
res, err := tx.tx.Query("SELECT `key`, `val` FROM kv WHERE `key` BETWEEN ? AND ? ORDER BY `key` ASC LIMIT ?", beg, end, max)
if err != nil {
return nil, err
}
@ -301,7 +301,7 @@ func (tx *TX) RDel(beg, end []byte, max uint64) (err error) {
max = math.MaxUint64
}
if _, err = tx.tx.Exec("DELETE FROM kv WHERE `key` BETWEEN ? AND ? ORDER BY `key` ASC LIMIT ?", beg, end, int(max)); err != nil {
if _, err = tx.tx.Exec("DELETE FROM kv WHERE `key` BETWEEN ? AND ? ORDER BY `key` ASC LIMIT ?", beg, end, max); err != nil {
err = &kvs.DBError{err}
return
}