[incubator-opendal] branch add-pg-support updated: Fix build

[xuanwo]

This is an automated email from the ASF dual-hosted git repository.

xuanwo pushed a commit to branch add-pg-support
in repository https://gitbox.apache.org/repos/asf/incubator-opendal.git


The following commit(s) were added to refs/heads/add-pg-support by this push:
     new 867d358e8 Fix build
867d358e8 is described below

commit 867d358e82e82817afe32761a14c982774da3b27
Author: Xuanwo <git...@xuanwo.io>
AuthorDate: Wed Aug 9 16:42:00 2023 +0800

    Fix build
    
    Signed-off-by: Xuanwo <git...@xuanwo.io>
---
 Cargo.lock                              |  1 -
 core/src/services/postgresql/backend.rs | 20 ++++++--------------
 2 files changed, 6 insertions(+), 15 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index 3ebc21270..2d5408af1 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -3445,7 +3445,6 @@ dependencies = [
  "futures",
  "governor",
  "hdrs",
- "hex",
  "http",
  "hyper",
  "lazy-regex",
diff --git a/core/src/services/postgresql/backend.rs 
b/core/src/services/postgresql/backend.rs
index 266623a93..9e33145cc 100644
--- a/core/src/services/postgresql/backend.rs
+++ b/core/src/services/postgresql/backend.rs
@@ -257,7 +257,7 @@ impl kv::Adapter for Adapter {
 
     async fn get(&self, path: &str) -> Result<Option<Vec<u8>>> {
         let query = format!(
-            "SELECT {} FROM {} WHERE {} = $1 LIMIT 1",
+            "SELECT {} FROM {} WHERE {} = '$1' LIMIT 1",
             self.value_field, self.table, self.key_field
         );
         let statement = self
@@ -271,11 +271,7 @@ impl kv::Adapter for Adapter {
             })
             .await?;
 
-        let rows = self
-            .get_client()
-            .await?
-            .query(statement, &[&path.as_bytes()])
-            .await?;
+        let rows = self.get_client().await?.query(statement, &[&path]).await?;
         if rows.is_empty() {
             return Ok(None);
         }
@@ -285,7 +281,7 @@ impl kv::Adapter for Adapter {
 
     async fn set(&self, path: &str, value: &[u8]) -> Result<()> {
         let query = format!(
-            "INSERT INTO {} ({}, {}) VALUES ($1, $2)",
+            "INSERT INTO {} ({}, {}) VALUES ('$1', $2)",
             self.table, self.key_field, self.value_field,
         );
         let statement = self
@@ -302,13 +298,13 @@ impl kv::Adapter for Adapter {
         let _ = self
             .get_client()
             .await?
-            .query(statement, &[&path.as_bytes(), &value])
+            .query(statement, &[&path, &value])
             .await?;
         Ok(())
     }
 
     async fn delete(&self, path: &str) -> Result<()> {
-        let query = format!("DELETE FROM {} WHERE {} = $1", self.table, 
self.key_field);
+        let query = format!("DELETE FROM {} WHERE {} = '$1'", self.table, 
self.key_field);
         let statement = self
             .statement_del
             .get_or_try_init(|| async {
@@ -320,11 +316,7 @@ impl kv::Adapter for Adapter {
             })
             .await?;
 
-        let _ = self
-            .get_client()
-            .await?
-            .query(statement, &[&path.as_bytes()])
-            .await?;
+        let _ = self.get_client().await?.query(statement, &[&path]).await?;
         Ok(())
     }
 }