source.parser优化

docs/config.md

@@ -60,7 +60,7 @@
         MQ跟着协议走，所以mq的属性值需要被赋值在rest节点上, 由于SncpServlet是自动生成的，故SNCP协议下，mq属性值被赋值在service/services节点上
         name:     服务的名称，用于监控识别，多个mq节点时只能有一个name为空的节点，mq.name不能重复,命名规则: 字母、数字、下划线
         type：    实现类名，必须是org.redkale.mq.MessageAgent的子类
-        threads：线程数，为0表示使用workExecutor。默认: CPU核数, 核数=1的情况下默认值为2，JDK 21以上版本默认使用虚拟线程池
+        threads： 线程数，为0表示使用workExecutor。默认: CPU核数, 核数=1的情况下默认值为2，JDK 21以上版本默认使用虚拟线程池
         rpcfirst：cluster和mq同名组件时，HttpRpcClient优先使用MQ，默认不优先走MQ。
         coder:    MessageRecord的解析器类，必须是org.redkale.mq.MessageCoder<MessageRecord>的实现类, 
              可对数据包进行加密解密，默认值：org.redkale.mq.MessageRecordCoder

src/main/java/org/redkale/source/DataJdbcSource.java

@@ -2629,16 +2629,17 @@ public class DataJdbcSource extends AbstractDataSqlSource {
             }
             long total = -1;
             List<V> list;
+            final String countSql = sinfo.getNativeCountSql();
             if (sinfo.isEmptyNamed()) {
                 Statement stmt = conn.createQueryStatement();
-                ResultSet set = stmt.executeQuery(sinfo.getNativeCountSql());
+                ResultSet set = stmt.executeQuery(countSql);
                 if (set.next()) {
                     total = set.getLong(1);
                 }
                 set.close();
                 conn.offerQueryStatement(stmt);
             } else {
-                final PreparedStatement prestmt = conn.prepareQueryStatement(sinfo.getNativeCountSql());
+                final PreparedStatement prestmt = conn.prepareQueryStatement(countSql);
                 Map<String, Object> paramValues = sinfo.getParamValues();
                 int index = 0;
                 for (String n : sinfo.getParamNames()) {
@@ -2651,7 +2652,7 @@ public class DataJdbcSource extends AbstractDataSqlSource {
                 set.close();
                 conn.offerQueryStatement(prestmt);
             }
-            slowLog(s, sinfo.getNativeCountSql());
+            slowLog(s, countSql);
             if (total > 0) {
                 String listSql = sinfo.getNativeSql();
                 if (mysqlOrPgsql) {

src/main/java/org/redkale/source/DataNativeSqlStatement.java

@@ -6,6 +6,7 @@ package org.redkale.source;
 import java.util.List;
 import java.util.Map;
 import java.util.function.IntFunction;
+import org.redkale.annotation.Nullable;
 import org.redkale.convert.ConvertDisabled;
 import org.redkale.convert.json.JsonConvert;
 
@@ -40,6 +41,7 @@ public class DataNativeSqlStatement {
     protected String nativeSql;
 
     //根据参数值集合重新生成的带?参数可执行的计算总数sql,用于返回Sheet对象
+    @Nullable
     protected String nativeCountSql;
 
     //需要预编译的##{xxx}、#{xxx}参数名, 数量与sql中的?数量一致