diff --git a/src/ast/mod.rs b/src/ast/mod.rs index f782f1f..fd273c4 100644 --- a/src/ast/mod.rs +++ b/src/ast/mod.rs @@ -2374,6 +2374,7 @@ pub enum PeerType { Postgres, S3, SQLServer, + MySql, Kafka, Eventhubs, PubSub, @@ -2389,6 +2390,7 @@ impl fmt::Display for PeerType { PeerType::Postgres => write!(f, "POSTGRES"), PeerType::S3 => write!(f, "S3"), PeerType::SQLServer => write!(f, "SQLSERVER"), + PeerType::MySql => write!(f, "MYSQL"), PeerType::Kafka => write!(f, "KAFKA"), PeerType::Eventhubs => write!(f, "EVENTHUBS"), PeerType::PubSub => write!(f, "PUBSUB"), diff --git a/src/keywords.rs b/src/keywords.rs index ecf0d7b..5317546 100644 --- a/src/keywords.rs +++ b/src/keywords.rs @@ -421,6 +421,7 @@ define_keywords!( MSCK, MULTISET, MUTATION, + MYSQL, NAME, NANOSECOND, NANOSECONDS, diff --git a/src/parser/mod.rs b/src/parser/mod.rs index b389d0f..e2fb619 100644 --- a/src/parser/mod.rs +++ b/src/parser/mod.rs @@ -8396,6 +8396,7 @@ impl<'a> Parser<'a> { Keyword::KAFKA, Keyword::S3, Keyword::SQLSERVER, + Keyword::MYSQL, Keyword::EVENTHUBS, Keyword::PUBSUB, Keyword::ELASTICSEARCH, @@ -8407,6 +8408,7 @@ impl<'a> Parser<'a> { Some(Keyword::KAFKA) => Ok(PeerType::Kafka), Some(Keyword::S3) => Ok(PeerType::S3), Some(Keyword::SQLSERVER) => Ok(PeerType::SQLServer), + Some(Keyword::MYSQL) => Ok(PeerType::MySql), Some(Keyword::EVENTHUBS) => Ok(PeerType::Eventhubs), Some(Keyword::PUBSUB) => Ok(PeerType::PubSub), Some(Keyword::ELASTICSEARCH) => Ok(PeerType::Elasticsearch), @@ -8419,6 +8421,7 @@ impl<'a> Parser<'a> { "KAFKA", "S3", "SQLSERVER", + "MYSQL", "EVENTHUBS", "PUBSUB", "ELASTICSEARCH",