File tree Expand file tree Collapse file tree 1 file changed +57
-0
lines changed Expand file tree Collapse file tree 1 file changed +57
-0
lines changed Original file line number Diff line number Diff line change @@ -3610,6 +3610,20 @@ fn parse_create_mirror_with_schema() {
3610
3610
3611
3611
#[ test]
3612
3612
fn parse_drop_mirror ( ) {
3613
+ match pg ( ) . verified_stmt ( "DROP MIRROR m1" ) {
3614
+ Statement :: DropMirror {
3615
+ if_exists,
3616
+ mirror_name,
3617
+ } => {
3618
+ assert ! ( !if_exists) ;
3619
+ assert_eq ! ( mirror_name, ObjectName ( vec![ Ident :: new( "m1" ) ] ) ) ;
3620
+ }
3621
+ _ => unreachable ! ( ) ,
3622
+ }
3623
+ }
3624
+
3625
+ #[ test]
3626
+ fn parse_drop_mirror_if_exists ( ) {
3613
3627
match pg ( ) . verified_stmt ( "DROP MIRROR IF EXISTS m1" ) {
3614
3628
Statement :: DropMirror {
3615
3629
if_exists,
@@ -3622,8 +3636,51 @@ fn parse_drop_mirror() {
3622
3636
}
3623
3637
}
3624
3638
3639
+
3640
+ #[ test]
3641
+ fn parse_pause_mirror ( ) {
3642
+ match pg ( ) . verified_stmt ( "PAUSE MIRROR m1" ) {
3643
+ Statement :: PauseMirror {
3644
+ if_exists,
3645
+ mirror_name,
3646
+ } => {
3647
+ assert ! ( !if_exists) ;
3648
+ assert_eq ! ( mirror_name, ObjectName ( vec![ Ident :: new( "m1" ) ] ) ) ;
3649
+ }
3650
+ _ => unreachable ! ( ) ,
3651
+ }
3652
+ }
3653
+
3654
+ #[ test]
3655
+ fn parse_pause_mirror_if_exists ( ) {
3656
+ match pg ( ) . verified_stmt ( "PAUSE MIRROR IF EXISTS m1" ) {
3657
+ Statement :: PauseMirror {
3658
+ if_exists,
3659
+ mirror_name,
3660
+ } => {
3661
+ assert ! ( if_exists) ;
3662
+ assert_eq ! ( mirror_name, ObjectName ( vec![ Ident :: new( "m1" ) ] ) ) ;
3663
+ }
3664
+ _ => unreachable ! ( ) ,
3665
+ }
3666
+ }
3667
+
3625
3668
#[ test]
3626
3669
fn parse_drop_peer ( ) {
3670
+ match pg ( ) . verified_stmt ( "DROP PEER p1" ) {
3671
+ Statement :: DropPeer {
3672
+ if_exists,
3673
+ peer_name,
3674
+ } => {
3675
+ assert ! ( !if_exists) ;
3676
+ assert_eq ! ( peer_name, ObjectName ( vec![ Ident :: new( "p1" ) ] ) ) ;
3677
+ }
3678
+ _ => unreachable ! ( ) ,
3679
+ }
3680
+ }
3681
+
3682
+ #[ test]
3683
+ fn parse_drop_peer_if_exists ( ) {
3627
3684
match pg ( ) . verified_stmt ( "DROP PEER IF EXISTS p1" ) {
3628
3685
Statement :: DropPeer {
3629
3686
if_exists,
You can’t perform that action at this time.
0 commit comments