From d968a802fc542bfec7737ed6dada471f839ca10a Mon Sep 17 00:00:00 2001
From: stremovsky <stremovsky@gmail.com>
Date: Tue, 24 Dec 2019 12:47:06 +0200
Subject: [PATCH] fix error in query

---
 src/qldb.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/qldb.go b/src/qldb.go
index dc8ab5c..8abc228 100644
--- a/src/qldb.go
+++ b/src/qldb.go
@@ -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)
 }