Function Test_isSkipQuery

driver/mysql/binlog/binlog_reader_test.go:1283–1323

func Test_updateCurrentReplicateDoDb(t *testing.T) { tableConfigs := []*common.Table{ {TableName: "tb1", TableRename: "tb1-rename"}, {TableName: "tb2", TableRename: ""}, {TableRegex: "(\\w*)tb-rex1", TableRename: "tb${1}-rex1-rename"}, {TableRegex: "(\\w*)tb-rex2", TableRename: "tb${1}-rex2

(t *testing.T)

//}

func Test_isSkipQuery(t *testing.T) {
	type args struct {
		sql string
	}
	tests := []struct {
		name string
		args args
		want bool
	}{
		{
			name: "create-event",
			args: args{"create event if not exists a.event1 on schedule every 5 second on completion preserve do insert into a.a values (0);"},
			want: true,
		}, {
			name: "create-trigger",
			args: args{`CREATE TRIGGER before_employee_update
	BEFORE UPDATE ON employees FOR EACH ROW
	INSERT INTO employees_audit
	SET action = 'update',
		employeeNumber = OLD.employeeNumber,
		lastname = OLD.lastname,
		changedat = NOW();`},
			want: true,
		}, {
			name: "alter-event",
			args: args{`ALTER EVENT no_such_event ON SCHEDULE EVERY '2:3' DAY_HOUR;`},
			want: true,
		}, {
			name: "create-table",
			args: args{"create table a.`create event on schedule at do insert` (id int)"},
			want: true, // TODO It should be false. Regex cannot handle such a case.
		},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			if got := isSkipQuery(tt.args.sql); got != tt.want {
				t.Errorf("isSkipQuery() = %v, want %v", got, tt.want)
			}
		})
	}
}

func Test_isExpandSyntaxQuery(t *testing.T) {
	type args struct {