fix: enable query with retention policy (openGemini#53)

Signed-off-by: PennyYoon <525296438@qq.com>
Chenxulin97 · Feb 20, 2024 · 5251ec5 · 5251ec5
1 parent 57d345c
commit 5251ec5
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/opengemini/query.go b/opengemini/query.go
@@ -13,8 +13,8 @@ type Query struct {
 }
 
 type keyValue struct {
-	Name string
-	Value   string
+	Name  string
+	Value string
 }
 
 // Query sends a command to the server
@@ -24,6 +24,8 @@ func (c *client) Query(q Query) (*QueryResult, error) {
 	}
 	req.queryValues.Add("db", q.Database)
 	req.queryValues.Add("q", q.Command)
+	req.queryValues.Add("rp", q.RetentionPolicy)
+
 	resp, err := c.executeHttpGet(UrlQuery, req)
 	if err != nil {
 		return nil, err