update

sqlite.go

@@ -183,17 +183,17 @@ func (db *SQLiteDB) ReverseIterator(start, end []byte) (Iterator, error) {
 	stmt := "SELECT key, value FROM kv"
 	args := []interface{}{}
 
-	if start != nil {
-		stmt += " WHERE key <= ?"
-		args = append(args, start)
-	}
 	if end != nil {
-		if start != nil {
-			stmt += " AND key > ?"
+		stmt += " WHERE key < ?"
+		args = append(args, end)
+	}
+	if start != nil {
+		if end != nil {
+			stmt += " AND key >= ?"
 		} else {
-			stmt += " WHERE key > ?"
+			stmt += " WHERE key >= ?"
 		}
-		args = append(args, end)
+		args = append(args, start)
 	}
 	stmt += " ORDER BY key DESC"
 

sqlite_test.go

@@ -0,0 +1,53 @@
+package db
+
+import (
+	"fmt"
+	"os"
+	"testing"
+
+	"github.com/stretchr/testify/require"
+)
+
+func TestSQLiteDBGetSetDelete(t *testing.T) {
+	name := fmt.Sprintf("test_%x", randStr(12))
+	dir := os.TempDir()
+	db, err := NewSQLiteDB(name, dir)
+	require.NoError(t, err)
+	defer db.Close()
+	defer os.RemoveAll(dir)
+
+	testBackendGetSetDelete(t, SQLiteDBBackend)
+}
+
+func TestSQLiteDBIterator(t *testing.T) {
+	name := fmt.Sprintf("test_%x", randStr(12))
+	dir := os.TempDir()
+	db, err := NewSQLiteDB(name, dir)
+	require.NoError(t, err)
+	defer db.Close()
+	defer os.RemoveAll(dir)
+
+	testDBIterator(t, SQLiteDBBackend)
+}
+
+func TestSQLiteDBBatch(t *testing.T) {
+	name := fmt.Sprintf("test_%x", randStr(12))
+	dir := os.TempDir()
+	db, err := NewSQLiteDB(name, dir)
+	require.NoError(t, err)
+	defer db.Close()
+	defer os.RemoveAll(dir)
+
+	testDBBatch(t, SQLiteDBBackend)
+}
+
+func BenchmarkSQLiteDBRandomReadsWrites(b *testing.B) {
+	name := fmt.Sprintf("test_%x", randStr(12))
+	dir := os.TempDir()
+	db, err := NewSQLiteDB(name, dir)
+	require.NoError(b, err)
+	defer db.Close()
+	defer os.RemoveAll(dir)
+
+	benchmarkRandomReadsWrites(b, db)
+}