PAUSE MIRROR parsing, will add tests later

Author: heavycrystal

src/ast/mod.rs

@@ -2146,7 +2146,7 @@ pub enum Statement {
         if_not_exists: bool,
         create_mirror: CreateMirror,
     },
-    /// DROP MIRROR [IF EXISTS] mirror_name
+    // DROP MIRROR [IF EXISTS] mirror_name
     DropMirror {
         #[cfg_attr(feature = "derive-visitor", drive(skip))]
         if_exists: bool,
@@ -2162,6 +2162,12 @@ pub enum Statement {
         mirror_name: ObjectName,
         with_options: Vec<SqlOption>,
     },
+    // DROP MIRROR [IF EXISTS] mirror_name
+    PauseMirror {
+        #[cfg_attr(feature = "derive-visitor", drive(skip))]
+        if_exists: bool,
+        mirror_name: ObjectName,
+    }
 }
 
 #[derive(Debug, Clone, PartialEq, PartialOrd, Eq, Ord, Hash)]
@@ -3655,6 +3661,17 @@ impl fmt::Display for Statement {
             Statement::ExecuteMirror { mirror_name } => {
                 write!(f, "EXECUTE MIRROR {mirror_name}", mirror_name = mirror_name)?;
                 Ok(())
+            },
+            Statement::PauseMirror {
+                if_exists,
+                mirror_name,
+            } => {
+                write!(
+                    f,
+                    "PAUSE MIRROR {if_exists}{mirror_name}",
+                    if_exists = if *if_exists { "IF EXISTS " } else { "" },
+                )?;
+                Ok(())
             }
             Statement::ResyncMirror {
                 if_exists,

src/keywords.rs

@@ -471,6 +471,7 @@ define_keywords!(
     PARTITIONS,
     PASSWORD,
     PATTERN,
+    PAUSE,
     PEER,
     PERCENT,
     PERCENTILE_CONT,

src/parser/mod.rs

@@ -522,6 +522,7 @@ impl<'a> Parser<'a> {
                 // `PRAGMA` is sqlite specific https://www.sqlite.org/pragma.html
                 Keyword::PRAGMA => Ok(self.parse_pragma()?),
                 Keyword::RESYNC => Ok(self.parse_resync()?),
+                Keyword::PAUSE => Ok(self.parse_pause_mirror()?),
                 _ => self.expected("an SQL statement", next_token),
             },
             Token::LParen => {
@@ -8104,6 +8105,16 @@ impl<'a> Parser<'a> {
         })
     }
 
+    pub fn parse_pause_mirror(&mut self) -> Result<Statement, ParserError> {
+        self.expect_keyword(Keyword::MIRROR)?;
+        let if_exists = self.parse_keywords(&[Keyword::IF, Keyword::EXISTS]);
+        let mirror_name = self.parse_object_name()?;
+        return Ok(Statement::PauseMirror {
+            if_exists,
+            mirror_name,
+        });
+    }
+
     /// The index of the first unprocessed token.
     pub fn index(&self) -> usize {
         self.index