Flink有个问题，就是这整个写法我感觉都是table api的语法啊，没有用到flink-connector-jdbc啊？flink-connector-jdbc在这里面起了什么作用呢？ String createTableDDL = “CREATE TEMPORARY TABLE ams_datasync_test (
” +
” id INT,
” +
” PRIMARY KEY (id) NOT ENFORCED
” +
“) WITH (
” +
” ‘connector’ = ‘jdbc’,
” +
” ‘url’ = ‘jdbc:dm://10.16.26.116:5236/AMS_PCRW_ONLINE’,
” +
” ‘username’ = ‘AMS_PCRW_ONLINE’,
” +
” ‘password’ = ‘2023’,
” +
” ‘table-name’ = ‘ams_datasync_test’,
” +
” ‘driver’ = ‘dm.jdbc.driver.DmDriver’
” +
“)”;
tableEnv.executeSql(createTableDDL);
tableEnv.from("InputTable").insertInto("ams_datasync_test").execute();我这么写确实增删改也没问题，那flink-connector-jdbc在这里面好像也没起什么作用啊？有点迷糊