修改sql查询的默认配置

Author: dapeng

oracle/oracle-side/oracle-async-side/src/main/java/com/dtstack/flink/sql/side/oracle/OracleAsyncReqRow.java

@@ -56,7 +56,7 @@ public void open(Configuration parameters) throws Exception {
                 .put("user", rdbSideTableInfo.getUserName())
                 .put("password", rdbSideTableInfo.getPassword())
                 .put("provider_class", DT_PROVIDER_CLASS)
-                .put("preferred_test_query", PREFERRED_TEST_QUERY_SQL)
+                .put("preferred_test_query", "select 1 from dual")
                 .put("idle_connection_test_period", DEFAULT_IDLE_CONNECTION_TEST_PEROID)
                 .put("test_connection_on_checkin", DEFAULT_TEST_CONNECTION_ON_CHECKIN);
 

rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/async/RdbAsyncReqRow.java

@@ -78,7 +78,7 @@ public class RdbAsyncReqRow extends BaseAsyncReqRow {
 
     public final static String DT_PROVIDER_CLASS = "com.dtstack.flink.sql.side.rdb.provider.DTC3P0DataSourceProvider";
 
-    public final static String PREFERRED_TEST_QUERY_SQL = "select 1 from dual";
+    public final static String PREFERRED_TEST_QUERY_SQL = "select 1";
 
     private transient SQLClient rdbSqlClient;