feature(query): fix read quoted string

common/io/src/buffer/buffer_read_ext.rs

@@ -46,8 +46,42 @@ pub trait BufferReadExt: BufferRead {
 
     fn read_quoted_text(&mut self, buf: &mut Vec<u8>, quota: u8) -> Result<()> {
         self.must_ignore_byte(quota)?;
-        self.keep_read(buf, |b| b != quota)?;
-        self.must_ignore_byte(quota)
+
+        loop {
+            self.keep_read(buf, |b| b != quota && b != b'\\')?;
+            if self.ignore_byte(quota)? {
+                return Ok(());
+            } else if self.ignore_byte(b'\\')? {
+                let b = self.fill_buf()?;
+                if b.is_empty() {
+                    return Err(std::io::Error::new(
+                        ErrorKind::InvalidData,
+                        "Expected to have terminated string literal.".to_string(),
+                    ));
+                }
+                let c = b[0];
+                self.ignore_byte(c)?;
+                match c {
+                    b'n' => buf.push(b'\n'),
+                    b't' => buf.push(b'\t'),
+                    b'r' => buf.push(b'\r'),
+                    b'0' => buf.push(b'\0'),
+                    b'\'' => buf.push(b'\''),
+                    b'\\' => buf.push(b'\\'),
+                    b'\"' => buf.push(b'\"'),
+                    _ => {
+                        buf.push(b'\\');
+                        buf.push(c);
+                    }
+                }
+            } else {
+                break;
+            }
+        }
+        Err(std::io::Error::new(
+            ErrorKind::InvalidData,
+            "Expected to have terminated string literal.".to_string(),
+        ))
     }
 
     fn read_escaped_string_text(&mut self, buf: &mut Vec<u8>) -> Result<()> {

tests/suites/0_stateless/03_dml/03_0016_insert_into_values.result

@@ -1,3 +1,5 @@
 -1	33	2021-08-15 10:00:00.000000	string1234
 101	67	2021-11-15 10:00:00.000000	string5678
 100	100
+a"b"c'd
+a"b"c\\'d

tests/suites/0_stateless/03_dml/03_0016_insert_into_values.sql

@@ -12,4 +12,11 @@ select * from t1;
 select sum(a),sum(b) from t1;
 
 
+CREATE TABLE IF NOT EXISTS t_str(a Varchar);
+INSERT INTO t_str(a) values( 'a"b\"c\'d');
+INSERT INTO t_str(a) values( 'a"b\"c\\\'d');
+select * from t_str;
+
+drop table t_str;
+
 DROP DATABASE db1;