@Test
    public void testGetOutputFormat() throws IllegalAccessException {
        when(jdbcDialect.defaultDriverName()).thenReturn(Optional.of("dd"));

        MemberModifier.field(MysqlSink.class, "dbUrl").set(mysqlSink, "foo");
        MemberModifier.field(MysqlSink.class, "jdbcDialect").set(mysqlSink, jdbcDialect);
        MemberModifier.field(MysqlSink.class, "userName").set(mysqlSink, "foo");
        MemberModifier.field(MysqlSink.class, "password").set(mysqlSink, "foo");
        MemberModifier.field(MysqlSink.class, "tableName").set(mysqlSink, "foo");
        MemberModifier.field(MysqlSink.class, "fieldNames").set(mysqlSink, new String[]{"foo", "bar"});

        JDBCUpsertOutputFormat format = mysqlSink.getOutputFormat();
    }
@program: flink.sql
@author: wuren
@create: 2020/06/17
mysql/mysql-sink/src/test/java/com/dtstack/flink/sql/sink/mysql/MysqlSinkTest.java