support query with raw sql.

Author: kamillecao

src/lib.rs

@@ -308,9 +308,14 @@ impl Client {
         inserter::Inserter::new(self, table)
     }
 
-    /// Starts a new SELECT/DDL query.
+    /// Starts a new SELECT/DDL query with sql rendering
     pub fn query(&self, query: &str) -> query::Query {
-        query::Query::new(self, query)
+        query::Query::new(self, query, true)
+    }
+
+    /// Starts a new SELECT/DDL query with a raw sql
+    pub fn query_with_raw_sql(&self, query: &str) -> query::Query {
+        query::Query::new(self, query, false)
     }
 
     /// Starts a new WATCH query.

src/query.rs

@@ -26,10 +26,10 @@ pub struct Query {
 }
 
 impl Query {
-    pub(crate) fn new(client: &Client, template: &str) -> Self {
+    pub(crate) fn new(client: &Client, template: &str, need_render: bool) -> Self {
         Self {
             client: client.clone(),
-            sql: SqlBuilder::new(template),
+            sql: SqlBuilder::new_with_need_render(template, need_render),
         }
     }
 

src/sql/mod.rs

@@ -47,24 +47,31 @@ impl fmt::Display for SqlBuilder {
 }
 
 impl SqlBuilder {
+    #[cfg(test)]
     pub(crate) fn new(template: &str) -> Self {
+        Self::new_with_need_render(template, true)
+    }
+
+    pub(crate) fn new_with_need_render(template: &str, need_render: bool) -> Self {
         let mut parts = Vec::new();
         let mut rest = template;
-        while let Some(idx) = rest.find('?') {
-            if rest[idx + 1..].starts_with('?') {
-                parts.push(Part::Text(rest[..idx + 1].to_string()));
-                rest = &rest[idx + 2..];
-                continue;
-            } else if idx != 0 {
-                parts.push(Part::Text(rest[..idx].to_string()));
-            }
+        if need_render {
+            while let Some(idx) = rest.find('?') {
+                if rest[idx + 1..].starts_with('?') {
+                    parts.push(Part::Text(rest[..idx + 1].to_string()));
+                    rest = &rest[idx + 2..];
+                    continue;
+                } else if idx != 0 {
+                    parts.push(Part::Text(rest[..idx].to_string()));
+                }
 
-            rest = &rest[idx + 1..];
-            if let Some(restfields) = rest.strip_prefix("fields") {
-                parts.push(Part::Fields);
-                rest = restfields;
-            } else {
-                parts.push(Part::Arg);
+                rest = &rest[idx + 1..];
+                if let Some(restfields) = rest.strip_prefix("fields") {
+                    parts.push(Part::Fields);
+                    rest = restfields;
+                } else {
+                    parts.push(Part::Arg);
+                }
             }
         }