@Test
    public void testSqlserverUpdateAndDelete() throws Exception {
        submitSQLJob(sqlFile, jdbcJar, sqlserverJar, mysqlJar);
        waitUntilJobRunning(Duration.ofSeconds(10));

        // generate input
        try (Connection conn =
                DriverManager.getConnection(SQLSERVER_CONTAINER.getJdbcUrl(), SQLSERVER_CONTAINER.getUsername(),
                        SQLSERVER_CONTAINER.getPassword());
                Statement stat = conn.createStatement()) {
            stat.execute("USE test;");
            stat.execute(
                    "SET IDENTITY_INSERT test_input1 ON;" +
                            "INSERT INTO test_input1 (id, name, description) "
                            + "VALUES (1, 'jacket','water resistent white wind breaker');" +
                            "SET IDENTITY_INSERT test_input1 OFF;");
            stat.execute(
                    "SET IDENTITY_INSERT test_input1 ON;" +
                            "INSERT INTO test_input1 (id, name, description) " +
                            "VALUES (2,'scooter','Big 2-wheel scooter ');" +
                            "SET IDENTITY_INSERT test_input1 OFF;");
            stat.execute(
                    "update test_input1 set name = 'tom' where id = 2;");
            stat.execute(
                    "delete from test_input1 where id = 1;");
        } catch (SQLException e) {
            LOG.error("Update table for CDC failed.", e);
            throw e;
        }

        JdbcProxy proxy =
                new JdbcProxy(STAR_ROCKS.getJdbcUrl(), STAR_ROCKS.getUsername(),
                        STAR_ROCKS.getPassword(),
                        STAR_ROCKS.getDriverClassName());
        List<String> expectResult =
                Arrays.asList("2,tom,Big 2-wheel scooter ");
        proxy.checkResultWithTimeout(
                expectResult,
                "test_output1",
                3,
                60000L);
    }
Test flink sql postgresql cdc to StarRocks

@throws Exception The exception may throws when execute the case
inlong-sort/sort-end-to-end-tests/sort-end-to-end-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/Sqlserver2StarRocksTest.java