加入分片功能呢

wuxw

2019-05-13 02727f5389622a22d023bfd2d3baaf6b02fea098

 java110-service/src/main/java/com/java110/service/smo/impl/QueryServiceSMOImpl.java

@@ -38,7 +38,7 @@
public class QueryServiceSMOImpl extends LoggerEngine implements IQueryServiceSMO {


    private final static Logger logger = LoggerFactory.getLogger(QueryServiceSMOImpl.class);
    private static Logger logger = LoggerFactory.getLogger(QueryServiceSMOImpl.class);


    @Autowired
@@ -85,6 +85,7 @@


    }

    @Override
    public void commonDoService(DataQuery dataQuery) throws BusinessException {
        //查询缓存查询 对应处理的ServiceSql
@@ -115,12 +116,13 @@

    /**
     * {"PARAM:"{
     "param1": "$.a.#A#Object",
     "param2": "$.a.b.A#B#Array",
     "param3": "$.a.b.c.A.B#C#Array"
     },"TEMPLATE":"{}"
     }
     * "param1": "$.a.#A#Object",
     * "param2": "$.a.b.A#B#Array",
     * "param3": "$.a.b.c.A.B#C#Array"
     * },"TEMPLATE":"{}"
     * }
     * 执行sql
     *
     * @param dataQuery
     */
    private void doExecuteUpdateSql(DataQuery dataQuery) throws BusinessException{
@@ -164,6 +166,7 @@

    /**
     * 执行java脚本
     *
     * @param dataQuery
     * @throws BusinessException
     */
@@ -190,14 +193,16 @@
            throw new BusinessException(ResponseConstant.RESULT_CODE_INNER_ERROR,"数据交互异常。。。");
        }
    }

    /**
     * {"PARAM:"{
     "param1": "$.a.#A#Object",
     "param2": "$.a.b.A#B#Array",
     "param3": "$.a.b.c.A.B#C#Array"
     },"TEMPLATE":"{}"
     }
     * "param1": "$.a.#A#Object",
     * "param2": "$.a.b.A#B#Array",
     * "param3": "$.a.b.c.A.B#C#Array"
     * },"TEMPLATE":"{}"
     * }
     * 执行sql
     *
     * @param dataQuery
     */
    private void doExecuteSql(DataQuery dataQuery) throws BusinessException{
@@ -234,6 +239,7 @@

    /**
     * 处理 jsonObject
     *
     * @param obj
     * @param dataQuery
     * @param values
@@ -316,6 +322,7 @@

    /**
     * 处理JSONArray
     *
     * @param objs
     * @param dataQuery
     * @param values
@@ -330,6 +337,7 @@

    /**
     * 执行存储
     *
     * @param dataQuery
     */
    private void doExecuteUpdateProc(DataQuery dataQuery){
@@ -351,6 +359,7 @@

    /**
     * 校验 返回模板
     *
     * @param template
     * @return
     * @throws BusinessException
@@ -378,6 +387,7 @@

    /**
     * 执行存储
     *
     * @param dataQuery
     */
    private void doExecuteProc(DataQuery dataQuery){