c 读取mysqlreader

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.connector.jdbc.JdbcInputFormat;
import org.apache.flink.types.Row;

public class MySQLReaderExample {
    public static void main(String[] args) throws Exception {
        final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        JdbcInputFormat jdbcInput = JdbcInputFormat.buildJdbcInputFormat()
            .setDrivername("com.mysql.cj.jdbc.Driver")
            .setDBUrl("jdbc:mysql://localhost:3306/mydatabase")
            .setUsername("myuser")
            .setPassword("mypassword")
            .setQuery("SELECT * FROM mytable")
            .setRowTypeInfo(new RowTypeInfo(BasicTypeInfo.INT_TYPE_INFO, BasicTypeInfo.STRING_TYPE_INFO))
            .finish();

        env.createInput(jdbcInput).print();

        env.execute("MySQL Reader Example");
    }
}