github-personal/databunker
1
0
Fork 0
mirror of https://github.com/outbackdingo/databunker.git synced 2026-01-27 18:18:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix error in query

Browse Source
This commit is contained in:
stremovsky
2019-12-24 12:47:06 +02:00
parent daeb74e078
commit d968a802fc
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/qldb.go
View File

@@ -606,7 +606,7 @@ func (dbobj dbcon) deleteExpired0(t Tbl, expt int32) (int64, error) {
func (dbobj dbcon) deleteExpired(t Tbl, keyName string, keyValue string) (int64, error) {
table := getTable(t)
q := "delete from " + table + " WHERE endtime<$1 AND" + escapeName(keyName) + "=$2"
q := "delete from " + table + " WHERE endtime<$1 AND " + escapeName(keyName) + "=$2"
fmt.Printf("q: %s\n", q)
tx, err := dbobj.db.Begin()
@@ -652,6 +652,7 @@ func (dbobj dbcon) getExpiring(t Tbl, keyName string, keyValue string) ([]bson.M
table := getTable(t)
now := int32(time.Now().Unix())
q := fmt.Sprintf("select * from %s WHERE endtime>0 AND endtime<%d AND %s=$1", table, now, escapeName(keyName))
fmt.Printf("q: %s\n", q)
return dbobj.getListDo(q, keyValue)
}