Unit test Request with timeout

db/db.go

@@ -876,6 +876,18 @@ func (db *DB) RequestStringStmts(stmts []string) ([]*command.ExecuteQueryRespons
 	return db.Request(req, false)
 }
 
+// RequestStringStmtsWithTimeout processes a request that can contain both executes and queries.
+func (db *DB) RequestStringStmtsWithTimeout(stmts []string, timeout time.Duration) ([]*command.ExecuteQueryResponse, error) {
+	req := &command.Request{}
+	for _, q := range stmts {
+		req.Statements = append(req.Statements, &command.Statement{
+			Sql: q,
+		})
+	}
+	req.DbTimeout = int64(timeout)
+	return db.Request(req, false)
+}
+
 // Request processes a request that can contain both executes and queries.
 func (db *DB) Request(req *command.Request, xTime bool) ([]*command.ExecuteQueryResponse, error) {
 	stats.Add(numRequests, int64(len(req.Statements)))

db/db_test.go

@@ -1090,28 +1090,28 @@ func Test_QueryShouldTimeout(t *testing.T) {
 	}
 }
 
-// func Test_RequestShouldTimeout(t *testing.T) {
+func Test_RequestShouldTimeout(t *testing.T) {
-// 	db, path := mustSetupDBForTimeoutTests(t, 1000)
+	db, path := mustSetupDBForTimeoutTests(t, 1000)
-// 	defer db.Close()
+	defer db.Close()
-// 	defer os.Remove(path)
+	defer os.Remove(path)
-
+
-// 	q := `SELECT key1, key_id, key2, key3, key4, key5, key6, data
+	q := `SELECT key1, key_id, key2, key3, key4, key5, key6, data
-// 	FROM test_table
+	FROM test_table
-// 	ORDER BY key2 ASC`
+	ORDER BY key2 ASC`
-// 	r, err := db.QueryStringStmtWithTimeout(q, 1*time.Microsecond)
+	res, err := db.RequestStringStmtsWithTimeout([]string{q}, 1*time.Microsecond)
-// 	if err != nil {
+	if err != nil {
-// 		t.Fatalf("failed to run query: %s", err.Error())
+		t.Fatalf("failed to run query: %s", err.Error())
-// 	}
+	}
-
+
-// 	if len(r) != 1 {
+	if len(res) != 1 {
-// 		t.Fatalf("expected one result, got %d: %s", len(r), asJSON(r))
+		t.Fatalf("expected one result, got %d: %s", len(res), asJSON(res))
-// 	}
+	}
-
+
-// 	res := r[0]
+	r := res[0]
-// 	if !strings.Contains(res.Error, "context deadline exceeded") {
+	if !strings.Contains(r.GetQ().Error, "context deadline exceeded") {
-// 		t.Fatalf("expected context.DeadlineExceeded, got %s", res.Error)
+		t.Fatalf("expected context.DeadlineExceeded, got %s", r.GetQ().Error)
-// 	}
+	}
-// }
+}
 
 func mustCreateOnDiskDatabase() (*DB, string) {
 	var err error