Fix sql bug.

Author: zqburde

conf/dss-apps-server.properties

@@ -16,7 +16,7 @@ wds.linkis.datasource.hikari.minimumIdle=10
 wds.dss.scriptis.global.limits.exportResEnable=false
 wds.dss.scriptis.global.limits.exportTableEnable=false
 wds.dss.scriptis.global.limits.downloadResEnable=true
-wds.dss.scriptis.global.limits.resCopyEnable=false
+wds.dss.scriptis.global.limits.resCopyEnable=true
 wds.dss.scriptis.global.limits.proxyEnable=false
 
 #####user guide#####

dss-appconn/appconns/dss-datachecker-appconn/src/main/java/com/webank/wedatasphere/dss/appconn/datachecker/connector/DataCheckerDao.java

@@ -247,13 +247,15 @@ private PreparedStatement getJobStatement(Connection conn, String dataObject) th
             }
             partitionName = partitionName.replace("\'", "").replace("\"", "");
             tableName = tableName.split("\\{")[0];
-            PreparedStatement pstmt = conn.prepareCall(SQL_SOURCE_TYPE_JOB_PARTITION);
+            PreparedStatement pstmt = conn.prepareStatement(SQL_SOURCE_TYPE_JOB_PARTITION, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
+//            PreparedStatement pstmt = conn.prepareCall(SQL_SOURCE_TYPE_JOB_PARTITION);
             pstmt.setString(1, dbName);
             pstmt.setString(2, tableName);
             pstmt.setString(3, partitionName);
             return pstmt;
         } else if (dataObjectArray.length == 2) {
-            PreparedStatement pstmt = conn.prepareCall(SQL_SOURCE_TYPE_JOB_TABLE);
+            PreparedStatement pstmt = conn.prepareStatement(SQL_SOURCE_TYPE_JOB_TABLE, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
+//            PreparedStatement pstmt = conn.prepareCall(SQL_SOURCE_TYPE_JOB_TABLE);
             pstmt.setString(1, dbName);
             pstmt.setString(2, tableName);
             return pstmt;
@@ -278,9 +280,11 @@ private PreparedStatement getBdpStatement(Connection conn, String dataObject, St
         }
         PreparedStatement pstmt = null;
         if (timeScape.equals("NULL")) {
-            pstmt = conn.prepareCall(SQL_SOURCE_TYPE_BDP);
+            pstmt = conn.prepareStatement(SQL_SOURCE_TYPE_BDP, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
+//            pstmt = conn.prepareCall(SQL_SOURCE_TYPE_BDP);
         } else {
-            pstmt = conn.prepareCall(SQL_SOURCE_TYPE_BDP_WITH_TIME_CONDITION);
+            pstmt = conn.prepareStatement(SQL_SOURCE_TYPE_BDP_WITH_TIME_CONDITION, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
+//            pstmt = conn.prepareCall(SQL_SOURCE_TYPE_BDP_WITH_TIME_CONDITION);
             pstmt.setInt(4, Integer.valueOf(timeScape) * 3600);
         }
         pstmt.setString(1, dbName);

dss-appconn/appconns/dss-eventchecker-appconn/src/main/java/com/webank/wedatasphere/dss/appconn/eventchecker/service/AbstractEventCheckReceiver.java

@@ -114,7 +114,8 @@ String getOffset(int jobId, Properties props, Logger log){
         String lastMsgId = "0";
         try {
             msgConn = getEventCheckerConnection(props,log);
-            pstmtForGetID = msgConn.prepareCall(sqlForReadMsgID);
+            pstmtForGetID = msgConn.prepareStatement(sqlForReadMsgID, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
+//            pstmtForGetID = msgConn.prepareCall(sqlForReadMsgID);
             pstmtForGetID.setString(1, receiver);
             pstmtForGetID.setString(2, topic);
             pstmtForGetID.setString(3, msgName);
@@ -142,7 +143,8 @@ String[] getMsg(Properties props, Logger log,String ... params){
         String[] consumedMsgInfo = null;
         try {
             msgConn = getEventCheckerConnection(props,log);
-            pstmt = msgConn.prepareCall(sqlForReadTMsg);
+            pstmt = msgConn.prepareStatement(sqlForReadTMsg, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
+//            pstmt = msgConn.prepareCall(sqlForReadTMsg);
             pstmt.setString(1, topic);
             pstmt.setString(2, msgName);
             pstmt.setString(3, params[0]);

dss-apps/dss-scriptis-server/src/main/java/com/webank/wedatasphere/dss/scriptis/pojo/entity/DssScriptDownloadAudit.java

@@ -18,8 +18,7 @@ public class DssScriptDownloadAudit {
     private String  creator;
     private String  tenant;
     private String  path;
-     @TableField("`sql`")
-    @NotEmpty(message = "查询语句不能为空")
+    @TableField("`sql`")
     private String  sql;
 
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")