Upgrade sqlparser version, sync between main and arrow crates

Author: returnString

convergence-arrow/Cargo.toml

@@ -9,7 +9,6 @@ repository = "https://github.com/returnString/convergence"
 
 [dependencies]
 tokio = { version = "1" }
-sqlparser = "0.37"
 async-trait = "0.1"
 datafusion = "31"
 convergence = { path = "../convergence", version = "0.14.0" }

convergence-arrow/src/datafusion.rs

@@ -5,9 +5,9 @@ use async_trait::async_trait;
 use convergence::engine::{Engine, Portal};
 use convergence::protocol::{ErrorResponse, FieldDescription, SqlState};
 use convergence::protocol_ext::DataRowBatch;
+use convergence::sqlparser::ast::{Expr, GroupByExpr, Query, Select, SelectItem, SetExpr, Statement, Value};
 use datafusion::error::DataFusionError;
 use datafusion::prelude::*;
-use sqlparser::ast::{Expr, Query, Select, SelectItem, SetExpr, Statement, Value};
 
 fn df_err_to_sql(err: DataFusionError) -> ErrorResponse {
 	ErrorResponse::error(SqlState::DataException, err.to_string())
@@ -29,7 +29,7 @@ fn dummy_query() -> Statement {
 			cluster_by: vec![],
 			distinct: None,
 			distribute_by: vec![],
-			group_by: vec![],
+			group_by: GroupByExpr::Expressions(vec![]),
 			from: vec![],
 			having: None,
 			lateral_views: vec![],

convergence-arrow/tests/test_arrow.rs

@@ -4,11 +4,11 @@ use convergence::engine::{Engine, Portal};
 use convergence::protocol::{ErrorResponse, FieldDescription};
 use convergence::protocol_ext::DataRowBatch;
 use convergence::server::{self, BindOptions};
+use convergence::sqlparser::ast::Statement;
 use convergence_arrow::table::{record_batch_to_rows, schema_to_field_desc};
 use datafusion::arrow::array::{ArrayRef, Date32Array, Float32Array, Int32Array, StringArray, TimestampSecondArray};
 use datafusion::arrow::datatypes::{DataType, Field, Schema, TimeUnit};
 use datafusion::arrow::record_batch::RecordBatch;
-use sqlparser::ast::Statement;
 use std::sync::Arc;
 use tokio_postgres::{connect, NoTls};
 

convergence/Cargo.toml

@@ -13,7 +13,7 @@ tokio-util = { version = "0.7", features = [ "codec" ] }
 thiserror = "1"
 bytes = "1"
 futures = "0.3"
-sqlparser = "0.37"
+sqlparser = "0.38"
 async-trait = "0.1"
 chrono = "0.4"
 

convergence/src/lib.rs

@@ -7,3 +7,5 @@ pub mod engine;
 pub mod protocol;
 pub mod protocol_ext;
 pub mod server;
+
+pub use sqlparser;