Function TestBinlogReader_resolveQuery

driver/mysql/binlog/binlog_reader_test.go:304–369

func Test_loadMapping(t *testing.T) { replicateDoDbWithRename := []*common.DataSource{ { TableSchema: "db1", TableSchemaRename: "db1-rename", Tables: []*common.Table{ { TableName: "tb1", TableRename: "db1-tb1-rename", TableSchema: "db1",

(t *testing.T)

//}

func TestBinlogReader_resolveQuery(t *testing.T) {
	skipFunc1 := func(schema string, tableName string) bool {
		return schema == "skip" || tableName == "skip"
	}
	b := &BinlogReader{
		lowerCaseTableNames: mysqlconfig.LowerCaseTableNames0,
		logger: hclog.Default(),
	}

	type args struct {
		currentSchema string
		sql           string
	}
	tests := []struct {
		name       string
		args       args
		wantResult parseQueryResult
		wantErr    bool
	}{
		{
			name: "drop-table-1",
			args: args{
				currentSchema: "",
				sql:           "drop table a.b, skip.c, d",
			},
			wantResult: parseQueryResult{
				sql: "DROP TABLE `a`.`b`, `d`",
			},
			wantErr: false,
		}, {
			name: "drop-table-2",
			args: args{
				currentSchema: "",
				sql:           "drop table if exists skip.b, skip.c",
			},
			wantResult: parseQueryResult{
				sql: "DROP TABLE IF EXISTS `skip`.`b`",
			},
			wantErr: false,
		}, {
			name:       "empty",
			args:       args{
				currentSchema: "",
				sql:           "",
			},
			wantResult: parseQueryResult{
				isRecognized: false,
				sql:          "",
			},
			wantErr:    false,
		},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			gotResult, err := b.resolveQuery(tt.args.currentSchema, tt.args.sql, skipFunc1)
			if (err != nil) != tt.wantErr {
				t.Errorf("resolveQuery() error = %v, wantErr %v", err, tt.wantErr)
				return