@@ -14,14 +14,22 @@ public RqliteClient(string uri, HttpClient? client = null)
14
14
{
15
15
_httpClient = client ?? new HttpClient ( ) { BaseAddress = new Uri ( uri ) } ;
16
16
}
17
-
17
+
18
+ /// <summary>
19
+ /// Ping Rqlite instance
20
+ /// </summary>
21
+ /// <returns>String containining Rqlite version</returns>
18
22
public async Task < string > Ping ( )
19
23
{
20
24
var x = await _httpClient . GetAsync ( "/status" ) ;
21
25
22
26
return x . Headers . GetValues ( "X-Rqlite-Version" ) . FirstOrDefault ( ) ! ;
23
27
}
24
-
28
+
29
+ /// <summary>
30
+ /// Query DB and return result
31
+ /// </summary>
32
+ /// <param name="query"></param>
25
33
public async Task < QueryResults > Query ( string query )
26
34
{
27
35
var data = "&q=" + Uri . EscapeDataString ( query ) ;
@@ -33,7 +41,10 @@ public async Task<QueryResults> Query(string query)
33
41
var result = JsonSerializer . Deserialize < QueryResults > ( str , new JsonSerializerOptions ( ) { PropertyNameCaseInsensitive = true } ) ;
34
42
return result ;
35
43
}
36
-
44
+
45
+ /// <summary>
46
+ /// Execute command and return result
47
+ /// </summary>
37
48
public async Task < ExecuteResults > Execute ( string command )
38
49
{
39
50
var request = new HttpRequestMessage ( HttpMethod . Post , "/db/execute?timings" ) ;
@@ -43,6 +54,12 @@ public async Task<ExecuteResults> Execute(string command)
43
54
return result ;
44
55
}
45
56
57
+ /// <summary>
58
+ /// Execute one or several commands and return result
59
+ /// </summary>
60
+ /// <param name="commands">Commands to execute</param>
61
+ /// <param name="flags">Command flags, e.g. whether to use transaction</param>
62
+ /// <returns></returns>
46
63
public async Task < ExecuteResults > Execute ( IEnumerable < string > commands , DbFlag ? flags )
47
64
{
48
65
var parameters = GetParameters ( flags ) ;
@@ -55,6 +72,13 @@ public async Task<ExecuteResults> Execute(IEnumerable<string> commands, DbFlag?
55
72
return result ;
56
73
}
57
74
75
+ /// <summary>
76
+ /// Query DB using parametrized statement
77
+ /// </summary>
78
+ /// <param name="query"></param>
79
+ /// <param name="qps"></param>
80
+ /// <typeparam name="T"></typeparam>
81
+ /// <returns></returns>
58
82
public async Task < QueryResults > QueryParams < T > ( string query , params T [ ] qps ) where T : QueryParameter
59
83
{
60
84
var request = new HttpRequestMessage ( HttpMethod . Post , "/db/query?timings" ) ;
0 commit comments