From bdbdfca6ac53da16af96cfe0b16fe0e0c3bf4338 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Philip=20Dub=C3=A9?= Date: Sat, 4 May 2024 14:15:44 +0000 Subject: [PATCH] mysql: limit 0 describe (#1670) --- nexus/peer-mysql/src/lib.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/nexus/peer-mysql/src/lib.rs b/nexus/peer-mysql/src/lib.rs index d57e83b932..6868a53a18 100644 --- a/nexus/peer-mysql/src/lib.rs +++ b/nexus/peer-mysql/src/lib.rs @@ -9,7 +9,7 @@ use peer_cursor::{ }; use pgwire::error::{ErrorInfo, PgWireError, PgWireResult}; use pt::peerdb_peers::MySqlConfig; -use sqlparser::ast::{CloseCursor, Declare, FetchDirection, Statement}; +use sqlparser::ast::{CloseCursor, Declare, Expr, FetchDirection, Statement, Value}; use stream::MyRecordStream; pub struct MySqlQueryExecutor { @@ -202,6 +202,7 @@ impl QueryExecutor for MySqlQueryExecutor { Statement::Query(query) => { let mut query = query.clone(); ast::rewrite_query(&self.peer_name, &mut query); + query.limit = Some(Expr::Value(Value::Number(String::from("0"), false))); Ok(Some(self.query_schema(query.to_string()).await?)) } Statement::Declare { stmts } => {