fix: no need for special case since datafusion updated (#5458)

* fix: no need for special case since datafusion updated Signed-off-by: yihong0618 <[email protected]> * fix: drop useless tests Signed-off-by: yihong0618 <[email protected]> --------- Signed-off-by: yihong0618 <[email protected]>
GreptimeTeam · Jan 26, 2025 · 5b6279f · 5b6279f
1 parent 698b28c
commit 5b6279f
Showing 1 changed file with 0 additions and 9 deletions.
diff --git a/src/servers/src/postgres/fixtures.rs b/src/servers/src/postgres/fixtures.rs
@@ -115,11 +115,7 @@ pub(crate) fn process<'a>(query: &str, query_ctx: QueryContextRef) -> Option<Vec
     }
 }
 
-static LIMIT_CAST_PATTERN: Lazy<Regex> =
-    Lazy::new(|| Regex::new("(?i)(LIMIT\\s+\\d+)::bigint").unwrap());
 pub(crate) fn rewrite_sql(query: &str) -> Cow<'_, str> {
-    //TODO(sunng87): remove this when we upgraded datafusion to 43 or newer
-    let query = LIMIT_CAST_PATTERN.replace_all(query, "$1");
     // DBeaver tricky replacement for datafusion not support sql
     // TODO: add more here
     query
@@ -218,11 +214,6 @@ mod test {
 
     #[test]
     fn test_rewrite() {
-        let sql = "SELECT * FROM number LIMIT 1::bigint";
-        let sql2 = "SELECT * FROM number limit      1::BIGINT";
-
-        assert_eq!("SELECT * FROM number LIMIT 1", rewrite_sql(sql));
-        assert_eq!("SELECT * FROM number limit      1", rewrite_sql(sql2));
         assert_eq!(
             "SELECT db.oid as _oid,db.* FROM pg_catalog.pg_database db",
             rewrite_sql("SELECT db.oid,db.* FROM pg_catalog.pg_database db")