diff --git a/api/core/rag/datasource/vdb/myscale/myscale_vector.py b/api/core/rag/datasource/vdb/myscale/myscale_vector.py
index 2bafe999c8..3b8c562aaf 100644
--- a/api/core/rag/datasource/vdb/myscale/myscale_vector.py
+++ b/api/core/rag/datasource/vdb/myscale/myscale_vector.py
@@ -100,7 +100,7 @@ class MyScaleVector(BaseVector):
                 rows.append(
                     (
                         doc_id,
-                        self.escape_str(doc.page_content),
+                        doc.page_content,
                         embeddings[i],
                         json.dumps(doc.metadata or {}),
                     )
@@ -110,10 +110,6 @@ class MyScaleVector(BaseVector):
             self._client.insert(self._qualified_table, rows, column_names=columns)
         return ids
 
-    @staticmethod
-    def escape_str(value: Any) -> str:
-        return "".join(" " if c in {"\\", "'"} else c for c in str(value))
-
     def text_exists(self, id: str) -> bool:
         results = self._client.query(
             f"SELECT id FROM {self._qualified_table} WHERE id = %(id)s LIMIT 1",