fixup! feat(query): Fetch query response in JSON format.

Rename to `fetch_json`.

Author: pravic

src/query.rs

@@ -87,7 +87,7 @@ impl Query {
 
     /// Executes the query, returning a [`RowJsonCursor`] to obtain results.
     #[cfg(feature = "watch")]
-    pub fn json<T>(mut self) -> Result<watch::RowJsonCursor<T>> {
+    pub fn fetch_json<T>(mut self) -> Result<watch::RowJsonCursor<T>> {
         self.sql.append(" FORMAT JSONEachRowWithProgress");
 
         let response = self.do_execute(true)?;
@@ -98,11 +98,11 @@ impl Query {
     ///
     /// Note that `T` must be owned.
     #[cfg(feature = "watch")]
-    pub async fn json_one<T>(self) -> Result<T>
+    pub async fn fetch_json_one<T>(self) -> Result<T>
     where
         T: for<'b> Deserialize<'b>,
     {
-        match self.json()?.next().await {
+        match self.fetch_json()?.next().await {
             Ok(Some(row)) => Ok(row),
             Ok(None) => Err(Error::RowNotFound),
             Err(err) => Err(err),
@@ -113,24 +113,24 @@ impl Query {
     ///
     /// Note that `T` must be owned.
     #[cfg(feature = "watch")]
-    pub async fn json_optional<T>(self) -> Result<Option<T>>
+    pub async fn fetch_json_optional<T>(self) -> Result<Option<T>>
     where
         T: for<'b> Deserialize<'b>,
     {
-        self.json()?.next().await
+        self.fetch_json()?.next().await
     }
 
     /// Executes the query and returns all the generated results,
     /// collected into a [`Vec`].
     ///
     /// Note that `T` must be owned.
     #[cfg(feature = "watch")]
-    pub async fn json_all<T>(self) -> Result<Vec<T>>
+    pub async fn fetch_json_all<T>(self) -> Result<Vec<T>>
     where
         T: for<'b> Deserialize<'b>,
     {
         let mut result = Vec::new();
-        let mut cursor = self.json::<T>()?;
+        let mut cursor = self.fetch_json::<T>()?;
 
         while let Some(row) = cursor.next().await? {
             result.push(row);

tests/it/query.rs

@@ -222,15 +222,15 @@ async fn fetches_json_row() {
 
     let value = client
         .query("SELECT 1,2,3")
-        .json_one::<serde_json::Value>()
+        .fetch_json_one::<serde_json::Value>()
         .await
         .unwrap();
 
     assert_eq!(value, serde_json::json!({ "1": 1, "2": 2, "3": 3}));
 
     let value = client
         .query("SELECT (1,2,3) as data")
-        .json_one::<serde_json::Value>()
+        .fetch_json_one::<serde_json::Value>()
         .await
         .unwrap();
 
@@ -252,7 +252,7 @@ async fn fetches_json_struct() {
 
     let value = client
         .query("SELECT -1 as one, '2' as two, 3.0 as three, false as four")
-        .json_one::<Row>()
+        .fetch_json_one::<Row>()
         .await
         .unwrap();
 
@@ -274,7 +274,7 @@ async fn describes_table() {
 
     let columns = client
         .query("DESCRIBE TABLE system.users")
-        .json_all::<serde_json::Value>()
+        .fetch_json_all::<serde_json::Value>()
         .await
         .unwrap();
     for c in &columns {