From 08581418850ed44449390d1404e49832bc15a488 Mon Sep 17 00:00:00 2001 From: TommyLemon <1184482681@qq.com> Date: Mon, 7 Nov 2022 05:11:57 +0800 Subject: [PATCH] =?UTF-8?q?=E8=BF=9C=E7=A8=8B=E5=87=BD=E6=95=B0=EF=BC=9A?= =?UTF-8?q?=E8=A7=A3=E5=86=B3=20key-()=20=E4=BC=98=E5=85=88=E6=89=A7?= =?UTF-8?q?=E8=A1=8C=E7=BB=93=E6=9E=9C=E4=B8=8D=E4=BC=9A=E4=BD=9C=E4=B8=BA?= =?UTF-8?q?=20SQL=20=E9=83=A8=E5=88=86=EF=BC=8C=E8=A7=A3=E5=86=B3=E9=9D=9E?= =?UTF-8?q?=E8=A1=A8=E5=AF=B9=E8=B1=A1=E4=B8=AD=20key()=20=E6=89=A7?= =?UTF-8?q?=E8=A1=8C=E6=97=B6=E6=9C=BA=E6=BB=9E=E5=90=8E=E4=BA=8E=E5=AD=90?= =?UTF-8?q?=E5=AF=B9=E8=B1=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- APIJSONORM/src/main/java/apijson/Log.java | 2 +- .../apijson/orm/AbstractFunctionParser.java | 4 +- .../apijson/orm/AbstractObjectParser.java | 200 ++++++++++-------- .../main/java/apijson/orm/AbstractParser.java | 2 +- .../main/java/apijson/orm/ObjectParser.java | 2 +- 5 files changed, 113 insertions(+), 97 deletions(-) diff --git a/APIJSONORM/src/main/java/apijson/Log.java b/APIJSONORM/src/main/java/apijson/Log.java index 5efb2f89..09a725bb 100755 --- a/APIJSONORM/src/main/java/apijson/Log.java +++ b/APIJSONORM/src/main/java/apijson/Log.java @@ -14,7 +14,7 @@ public class Log { public static boolean DEBUG = true; - public static final String VERSION = "5.3.0"; + public static final String VERSION = "5.4.0"; public static final String KEY_SYSTEM_INFO_DIVIDER = "\n---|-----APIJSON SYSTEM INFO-----|---\n"; public static final String OS_NAME; diff --git a/APIJSONORM/src/main/java/apijson/orm/AbstractFunctionParser.java b/APIJSONORM/src/main/java/apijson/orm/AbstractFunctionParser.java index 795062d7..7b38a36d 100755 --- a/APIJSONORM/src/main/java/apijson/orm/AbstractFunctionParser.java +++ b/APIJSONORM/src/main/java/apijson/orm/AbstractFunctionParser.java @@ -144,9 +144,9 @@ public class AbstractFunctionParser implements FunctionParser { /**反射调用 * @param parser - * @param request * @param function 例如get(Map:map,key)，参数只允许引用，不能直接传值 - * @return {@link #invoke(AbstractFunctionParser, String, Class[], Object[])} + * @param currentObject + * @return {@link #invoke(AbstractFunctionParser, String, Class[], Object[])} */ public static Object invoke(@NotNull AbstractFunctionParser parser, @NotNull String function, @NotNull JSONObject currentObject) throws Exception { diff --git a/APIJSONORM/src/main/java/apijson/orm/AbstractObjectParser.java b/APIJSONORM/src/main/java/apijson/orm/AbstractObjectParser.java index 0ab8ffad..53276dbf 100755 --- a/APIJSONORM/src/main/java/apijson/orm/AbstractObjectParser.java +++ b/APIJSONORM/src/main/java/apijson/orm/AbstractObjectParser.java @@ -20,7 +20,6 @@ import com.alibaba.fastjson.JSONObject; import javax.activation.UnsupportedDataTypeException; import java.rmi.ServerException; -import java.sql.SQLException; import java.util.ArrayList; import java.util.Arrays; import java.util.LinkedHashMap; @@ -70,10 +69,6 @@ public abstract class AbstractObjectParser implements ObjectParser { protected final boolean drop; /**for single object - * @param parentPath - * @param request - * @param name - * @throws Exception */ public AbstractObjectParser(@NotNull JSONObject request, String parentPath, SQLConfig arrayConfig , boolean isSubquery, boolean isTable, boolean isArrayMainTable) throws Exception { @@ -157,7 +152,7 @@ public abstract class AbstractObjectParser implements ObjectParser { protected JSONObject response; protected JSONObject sqlRequest; - protected JSONObject sqlReponse; + protected JSONObject sqlResponse; /** * 自定义关键词 */ @@ -200,7 +195,7 @@ public abstract class AbstractObjectParser implements ObjectParser { breakParse = false; response = new JSONObject(true);//must init - sqlReponse = null;//must init + sqlResponse = null;//must init if (isReuse == false) { sqlRequest = new JSONObject(true);//must init @@ -239,23 +234,27 @@ public abstract class AbstractObjectParser implements ObjectParser { } //条件>>>>>>>>>>>>>>>>>>> - String key; - Object value; int index = 0; + //hasOtherKeyNotFun = false; for (Entry entry : set) { if (isBreakParse()) { break; } - value = entry.getValue(); + Object value = entry.getValue(); if (value == null) { continue; } - key = entry.getKey(); + String key = entry.getKey(); try { - if (key.startsWith("@") || key.endsWith("@") || (key.endsWith("<>") && value instanceof JSONObject)) { + boolean startsWithAt = key.startsWith("@"); + //if (startsWithAt || (key.endsWith("()") == false)) { + // hasOtherKeyNotFun = true; + //} + + if (startsWithAt || key.endsWith("@") || (key.endsWith("<>") && value instanceof JSONObject)) { if (onParse(key, value) == false) { invalidate(); } @@ -331,8 +330,9 @@ public abstract class AbstractObjectParser implements ObjectParser { + //private boolean hasOtherKeyNotFun = false; - /**解析普通成员 + /**解析普通成员 * @param key * @param value * @return whether parse succeed @@ -438,15 +438,12 @@ public abstract class AbstractObjectParser implements ObjectParser { String type; //远程函数比较少用，一般一个Table:{}内用到也就一两个，所以这里用 "-","0","+" 更直观，转用 -1,0,1 对性能提升不大。 boolean isMinus = k.endsWith("-"); + boolean isPlus = isMinus == false && k.endsWith("+"); if (isMinus) { //不能封装到functionMap后批量执行，否则会导致非Table内的 key-():function() 在onChildParse后执行！ type = "-"; k = k.substring(0, k.length() - 1); - - if (isTable == false) { - parseFunction(k, (String) value, parentPath, name, request); - } } - else if (k.endsWith("+")) { + else if (isPlus) { type = "+"; k = k.substring(0, k.length() - 1); } @@ -454,7 +451,10 @@ public abstract class AbstractObjectParser implements ObjectParser { type = "0"; } - if (isMinus == false || isTable) { + if (isPlus == false && isTable == false) { + parseFunction(k, (String) value, parentPath, name, request, isMinus); + } + else { //远程函数比较少用，一般一个Table:{}内用到也就一两个，所以这里循环里new出来对性能影响不大。 Map map = functionMap.get(type); if (map == null) { @@ -466,7 +466,7 @@ public abstract class AbstractObjectParser implements ObjectParser { } } else if (isTable && key.startsWith("@") && JSONRequest.TABLE_KEY_LIST.contains(key) == false) { - customMap.put(key, value); + customMap.put(key, value); } else { sqlRequest.put(key, value); @@ -718,37 +718,37 @@ public abstract class AbstractObjectParser implements ObjectParser { public AbstractObjectParser executeSQL() throws Exception { //执行SQL操作数据库 if (isTable == false) {//提高性能 - sqlReponse = new JSONObject(sqlRequest); + sqlResponse = new JSONObject(sqlRequest); } else { - try { - sqlReponse = onSQLExecute(); - } - catch (Exception e) { - if (e instanceof NotExistException || (e instanceof CommonException && e.getCause() instanceof NotExistException)) { - // Log.e(TAG, "getObject try { response = getSQLObject(config2); } catch (Exception e) {"); - // if (e instanceof NotExistException) {//非严重异常，有时候只是数据不存在 - // // e.printStackTrace(); - sqlReponse = null;//内部吃掉异常，put到最外层 - // requestObject.put(JSONResponse.KEY_MSG - // , StringUtil.getString(requestObject.get(JSONResponse.KEY_MSG) - // + "; query " + path + " cath NotExistException:" - // + newErrorResult(e).getString(JSONResponse.KEY_MSG))); - // } else { - // throw e; - // } + try { + sqlResponse = onSQLExecute(); + } + catch (Exception e) { + if (e instanceof NotExistException || (e instanceof CommonException && e.getCause() instanceof NotExistException)) { + // Log.e(TAG, "getObject try { response = getSQLObject(config2); } catch (Exception e) {"); + // if (e instanceof NotExistException) {//非严重异常，有时候只是数据不存在 + // // e.printStackTrace(); + sqlResponse = null;//内部吃掉异常，put到最外层 + // requestObject.put(JSONResponse.KEY_MSG + // , StringUtil.getString(requestObject.get(JSONResponse.KEY_MSG) + // + "; query " + path + " cath NotExistException:" + // + newErrorResult(e).getString(JSONResponse.KEY_MSG))); + // } else { + // throw e; + // } + } + else { + throw e; + } + } } - else { - throw e; + + if (drop) {//丢弃Table，只为了向下提供条件 + sqlResponse = null; } - } - } - if (drop) {//丢弃Table，只为了向下提供条件 - sqlReponse = null; - } - - return this; + return this; } /** @@ -757,12 +757,12 @@ public abstract class AbstractObjectParser implements ObjectParser { */ @Override public JSONObject response() throws Exception { - if (sqlReponse == null || sqlReponse.isEmpty()) { + if (sqlResponse == null || sqlResponse.isEmpty()) { if (isTable) {//Table自身都获取不到值，则里面的Child都无意义，不需要再解析 return null; // response; } } else { - response.putAll(sqlReponse); + response.putAll(sqlResponse); } @@ -791,17 +791,22 @@ public abstract class AbstractObjectParser implements ObjectParser { //解析函数function Set> functionSet = map == null ? null : map.entrySet(); if (functionSet != null && functionSet.isEmpty() == false) { - JSONObject json = "-".equals(type) ? request : response; // key-():function 是实时执行，而不是在这里批量执行 + boolean isMinus = "-".equals(type); + JSONObject json = isMinus ? sqlRequest : response; // key-():function 是实时执行，而不是在这里批量执行 for (Entry entry : functionSet) { - parseFunction(entry.getKey(), entry.getValue(), parentPath, name, json); + parseFunction(entry.getKey(), entry.getValue(), parentPath, name, json, isMinus); } } } - public void parseFunction(String key, String value, String parentPath, String currentName, JSONObject currentObject) throws Exception { + //public void parseFunction(String key, String value, String parentPath, String currentName, JSONObject currentObject) throws Exception { + // parseFunction(key, value, parentPath, currentName, currentObject, false); + //} + public void parseFunction(String key, String value, String parentPath, String currentName, JSONObject currentObject, boolean isMinus) throws Exception { Object result; - if (key.startsWith("@")) { + boolean isProcedure = key.startsWith("@"); + if (isProcedure) { FunctionBean fb = AbstractFunctionParser.parseFunction(value, currentObject, true); SQLConfig config = newSQLConfig(true); @@ -814,12 +819,23 @@ public abstract class AbstractObjectParser implements ObjectParser { result = parser.onFunctionParse(key, value, parentPath, currentName, currentObject); } - if (result != null) { - String k = AbstractSQLConfig.getRealKey(method, key, false, false); + String k = AbstractSQLConfig.getRealKey(method, key, false, false); - response.put(k, result); - parser.putQueryResult(AbstractParser.getAbsPath(path, k), result); - } + if (isProcedure == false && isMinus) { + if (result != null) { + sqlRequest.put(k, result); + } else { + sqlRequest.remove(k); + } + } + + if (result != null) { + response.put(k, result); + } else { + response.remove(k); + } + + parser.putQueryResult(AbstractParser.getAbsPath(path, k), result); } @Override @@ -863,47 +879,47 @@ public abstract class AbstractObjectParser implements ObjectParser { result = parser.executeSQL(sqlConfig, isSubquery); boolean isSimpleArray = false; - // 提取并缓存数组主表的列表数据 - List rawList = result == null ? null : (List) result.remove(AbstractSQLExecutor.KEY_RAW_LIST); + // 提取并缓存数组主表的列表数据 + List rawList = result == null ? null : (List) result.remove(AbstractSQLExecutor.KEY_RAW_LIST); - if (isArrayMainTable && position == 0 && rawList != null) { + if (isArrayMainTable && position == 0 && rawList != null) { - isSimpleArray = (functionMap == null || functionMap.isEmpty()) - && (customMap == null || customMap.isEmpty()) - && (childMap == null || childMap.isEmpty()) - && (table.equals(arrayTable)); + isSimpleArray = (functionMap == null || functionMap.isEmpty()) + && (customMap == null || customMap.isEmpty()) + && (childMap == null || childMap.isEmpty()) + && (table.equals(arrayTable)); - // APP JOIN 副表时副表返回了这个字段 rawList = (List) result.remove(AbstractSQLExecutor.KEY_RAW_LIST); - String arrayPath = parentPath.substring(0, parentPath.lastIndexOf("[]") + 2); + // APP JOIN 副表时副表返回了这个字段 rawList = (List) result.remove(AbstractSQLExecutor.KEY_RAW_LIST); + String arrayPath = parentPath.substring(0, parentPath.lastIndexOf("[]") + 2); - if (isSimpleArray == false) { - long startTime = System.currentTimeMillis(); + if (isSimpleArray == false) { + long startTime = System.currentTimeMillis(); - for (int i = 1; i < rawList.size(); i++) { // 从 1 开始，0 已经处理过 - JSONObject obj = rawList.get(i); + for (int i = 1; i < rawList.size(); i++) { // 从 1 开始，0 已经处理过 + JSONObject obj = rawList.get(i); - if (obj != null) { - parser.putQueryResult(arrayPath + "/" + i + "/" + name, obj); // 解决获取关联数据时requestObject里不存在需要的关联数据 + if (obj != null) { + parser.putQueryResult(arrayPath + "/" + i + "/" + name, obj); // 解决获取关联数据时requestObject里不存在需要的关联数据 + } + } + + long endTime = System.currentTimeMillis(); // 3ms - 8ms + Log.e(TAG, "\n onSQLExecute <<<<<<<<<<<<<<<<<<<<<<<<<<<<\n for (int i = 1; i < list.size(); i++) startTime = " + startTime + + "; endTime = " + endTime + "; duration = " + (endTime - startTime) + "\n >>>>>>>>>>>>>>>>>>>>>>>>>>>>>\n "); + } + + parser.putArrayMainCache(arrayPath, rawList); } - } - long endTime = System.currentTimeMillis(); // 3ms - 8ms - Log.e(TAG, "\n onSQLExecute <<<<<<<<<<<<<<<<<<<<<<<<<<<<\n for (int i = 1; i < list.size(); i++) startTime = " + startTime - + "; endTime = " + endTime + "; duration = " + (endTime - startTime) + "\n >>>>>>>>>>>>>>>>>>>>>>>>>>>>>\n "); + if (isSubquery == false && result != null) { + parser.putQueryResult(path, result); // 解决获取关联数据时requestObject里不存在需要的关联数据 + + if (isSimpleArray && rawList != null) { + result.put(AbstractSQLExecutor.KEY_RAW_LIST, rawList); + } + } } - parser.putArrayMainCache(arrayPath, rawList); - } - - if (isSubquery == false && result != null) { - parser.putQueryResult(path, result); // 解决获取关联数据时requestObject里不存在需要的关联数据 - - if (isSimpleArray && rawList != null) { - result.put(AbstractSQLExecutor.KEY_RAW_LIST, rawList); - } - } - } - return result; } @@ -941,7 +957,7 @@ public abstract class AbstractObjectParser implements ObjectParser { request = null; response = null; sqlRequest = null; - sqlReponse = null; + sqlResponse = null; functionMap = null; customMap = null; @@ -959,7 +975,7 @@ public abstract class AbstractObjectParser implements ObjectParser { if (this.method != method) { this.method = method; sqlConfig = null; - //TODO ? sqlReponse = null; + //TODO ? sqlResponse = null; } return this; } @@ -1007,8 +1023,8 @@ public abstract class AbstractObjectParser implements ObjectParser { return sqlRequest; } @Override - public JSONObject getSqlReponse() { - return sqlReponse; + public JSONObject getSqlResponse() { + return sqlResponse; } @Override diff --git a/APIJSONORM/src/main/java/apijson/orm/AbstractParser.java b/APIJSONORM/src/main/java/apijson/orm/AbstractParser.java index 58bd20e5..3ac4b28d 100755 --- a/APIJSONORM/src/main/java/apijson/orm/AbstractParser.java +++ b/APIJSONORM/src/main/java/apijson/orm/AbstractParser.java @@ -1084,7 +1084,7 @@ public abstract class AbstractParser implements Parser, Par else { // 对聚合函数字段通过 query:2 分页查总数返回值错误 RequestMethod method = op.getMethod(); - rp = op.setMethod(RequestMethod.HEAD).setSQLConfig().executeSQL().getSqlReponse(); + rp = op.setMethod(RequestMethod.HEAD).setSQLConfig().executeSQL().getSqlResponse(); op.setMethod(method); } diff --git a/APIJSONORM/src/main/java/apijson/orm/ObjectParser.java b/APIJSONORM/src/main/java/apijson/orm/ObjectParser.java index 3fbea855..2f0b3a3c 100755 --- a/APIJSONORM/src/main/java/apijson/orm/ObjectParser.java +++ b/APIJSONORM/src/main/java/apijson/orm/ObjectParser.java @@ -156,7 +156,7 @@ public interface ObjectParser { SQLConfig getSQLConfig(); JSONObject getResponse(); JSONObject getSqlRequest(); - JSONObject getSqlReponse(); + JSONObject getSqlResponse(); Map getCustomMap(); Map> getFunctionMap();