| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674 |
- package com.persagy.old.dao;
- import com.persagy.old.common.DateUtil;
- import com.persagy.old.common.ToolsUtil;
- import com.sagacloud.json.JSONArray;
- import com.sagacloud.json.JSONObject;
- import net.minidev.json.JSONValue;
- import org.slf4j.Logger;
- import org.slf4j.LoggerFactory;
- import java.util.Arrays;
- public class DBCommonMethods {
- private static final Logger log = LoggerFactory.getLogger(DBCommonMethods.class);
- /**
- *
- * 功能描述:插入记录
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String insertRecord(String tableName, String jsonStr) {
- return insertRecord(DBConst.DATABASE_NAME, tableName, jsonStr);
- }
- /**
- *
- * 功能描述:插入记录,指定操作的数据库
- * @param Database
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String insertRecord(String Database, String tableName, String jsonStr) {
- JSONObject dataJson = (JSONObject) JSONValue.parse(jsonStr);
- JSONObject insertObject = (JSONObject) dataJson.get("insertObject");
- insertObject = processInsertObj(insertObject);
- JSONObject bodyNode = (JSONObject) JSONValue.parse("{}");
- bodyNode.put("QueryType", "insert");
- bodyNode.put("Database", Database);
- bodyNode.put("Datatable", tableName);
- bodyNode.put("InsertObject", dataJson.get("insertObject"));
- log.info(bodyNode.toString());
- try {
- String result = DBAgent.GetAgent().Query(bodyNode).toString();
- // log.info(result);
- return result;
- } catch (Exception e) {
- e.printStackTrace();
- log.error("请求异常:",e);
- return ToolsUtil.errorJsonMsg(Arrays.toString(e.getStackTrace()));
- }
- }
-
- /**
- *
- * 功能描述:插入记录,指定操作的数据库
- * @param Database
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String insertRecord(String Database, String tableName, String jsonStr, boolean notUpdateTime) {
- JSONObject dataJson = (JSONObject) JSONValue.parse(jsonStr);
- JSONObject insertObject = (JSONObject) dataJson.get("insertObject");
- // insertObject = processInsertObj(insertObject);
- // 添加数据有效状态,true-有效,false-无效
- insertObject.put(DBConst.TABLE_FIELD_VALID, true);
-
- JSONObject bodyNode = (JSONObject) JSONValue.parse("{}");
- bodyNode.put("QueryType", "insert");
- bodyNode.put("Database", Database);
- bodyNode.put("Datatable", tableName);
- bodyNode.put("InsertObject", dataJson.get("insertObject"));
- log.info(bodyNode.toString());
- try {
- String result = DBAgent.GetAgent().Query(bodyNode).toString();
- // log.info(result);
- return result;
- } catch (Exception e) {
- e.printStackTrace();
- log.error("请求异常:",e);
- return ToolsUtil.errorJsonMsg(Arrays.toString(e.getStackTrace()));
- }
- }
- /**
- *
- * 功能描述:插入一批记录,指定操作的数据库
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String insertBatchRecord(String tableName, String jsonStr) {
- return insertBatchRecord(DBConst.DATABASE_NAME, tableName, jsonStr);
- }
- /**
- *
- * 功能描述:插入一批记录,指定操作的数据库
- * @param Database
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String insertBatchRecord(String Database, String tableName, String jsonStr) {
- JSONObject dataJson = (JSONObject) JSONValue.parse(jsonStr);
- JSONArray insertObjects = (JSONArray) dataJson.get("insertObjects");
- insertObjects = processInsertArray(insertObjects);
- JSONObject bodyNode = (JSONObject) JSONValue.parse("{}");
- bodyNode.put("QueryType", "batch_insert");
- bodyNode.put("Database", Database);
- bodyNode.put("Datatable", tableName);
- bodyNode.put("InsertObjects", insertObjects);
- log.info(bodyNode.toString());
- try {
- String result = DBAgent.GetAgent().Query(bodyNode).toString();
- // log.info(result);
- return result;
- } catch (Exception e) {
- e.printStackTrace();
- log.error("请求异常:",e);
- return ToolsUtil.errorJsonMsg(Arrays.toString(e.getStackTrace()));
- }
- }
-
- /**
- *
- * 功能描述:修改记录
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String updateRecord(String tableName, String jsonStr) {
- return updateRecord(DBConst.DATABASE_NAME, tableName, jsonStr);
- }
- /**
- *
- * 功能描述:修改记录
- * @param Database
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String updateRecord(String Database, String tableName, String jsonStr) {
- JSONObject dataJson = (JSONObject) JSONValue.parse(jsonStr);
- JSONObject bodyNode = (JSONObject) JSONValue.parse("{}");
- JSONObject set = (JSONObject) dataJson.get("set");
- // 添加更新时间
- set.put(DBConst.TABLE_FIELD_UPDATE_TIME, DateUtil.getNowTimeStr());
-
- bodyNode.put("QueryType", "update");
- bodyNode.put("Database", Database);
- bodyNode.put("Datatable", tableName);
- bodyNode.put("Criteria", dataJson.get("criteria"));
- bodyNode.put("Set", set);
- log.info(bodyNode.toString());
- try {
- String result = DBAgent.GetAgent().Query(bodyNode).toString();
- // log.info(result);
- return result;
- } catch (Exception e) {
- e.printStackTrace();
- log.error("请求异常:",e);
- return ToolsUtil.errorJsonMsg(Arrays.toString(e.getStackTrace()));
- }
- }
-
- /**
- *
- * 功能描述:修改记录
- * @param Database
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String updateRecord(String Database, String tableName, String jsonStr, boolean notUpdateTime) {
- JSONObject dataJson = (JSONObject) JSONValue.parse(jsonStr);
- JSONObject bodyNode = (JSONObject) JSONValue.parse("{}");
- JSONObject set = (JSONObject) dataJson.get("set");
-
- bodyNode.put("QueryType", "update");
- bodyNode.put("Database", Database);
- bodyNode.put("Datatable", tableName);
- bodyNode.put("Criteria", dataJson.get("criteria"));
- bodyNode.put("Set", set);
- log.info(bodyNode.toString());
- try {
- String result = DBAgent.GetAgent().Query(bodyNode).toString();
- // log.info(result);
- return result;
- } catch (Exception e) {
- e.printStackTrace();
- log.error("请求异常:",e);
- return ToolsUtil.errorJsonMsg(Arrays.toString(e.getStackTrace()));
- }
- }
-
- public static String updateBatchRecord(String tableName, String jsonStr){
- return updateBatchRecord(DBConst.DATABASE_NAME, tableName, jsonStr);
- }
-
- /**
- *
- * Description: 批量更新sop发布版本(仅物理世界对象改变时使用,不更新update_time)
- * @param tableName
- * @param jsonStr
- * @return String
- * @author yuecaipu
- * @since 2018年5月29日: 上午11:15:23
- * Update By yuecaipu 2018年5月29日: 上午11:15:23
- */
- public static String updateBatchPublishStatus(String tableName, String jsonStr){
- return updateBatchPublishStatus(DBConst.DATABASE_NAME, tableName, jsonStr);
- }
-
- public static String updateBatchRecord(String Database, String tableName, String jsonStr){
- JSONObject dataJson = (JSONObject) JSONValue.parse(jsonStr);
- JSONObject bodyNode = (JSONObject) JSONValue.parse("{}");
- JSONObject set = (JSONObject) dataJson.get("set");
- // 添加更新时间
- set.put(DBConst.TABLE_FIELD_UPDATE_TIME, DateUtil.getNowTimeStr());
-
- bodyNode.put("QueryType", "batch_update");
- bodyNode.put("Database", Database);
- bodyNode.put("Datatable", tableName);
- bodyNode.put("Criterias", dataJson.get("criterias"));
- bodyNode.put("Set", set);
- log.info(bodyNode.toString());
- try {
- String result = DBAgent.GetAgent().Query(bodyNode).toString();
- // log.info(result);
- return result;
- } catch (Exception e) {
- e.printStackTrace();
- log.error("请求异常:",e);
- return ToolsUtil.errorJsonMsg(Arrays.toString(e.getStackTrace()));
- }
- }
- public static String updateBatchPublishStatus(String Database, String tableName, String jsonStr){
- JSONObject dataJson = (JSONObject) JSONValue.parse(jsonStr);
- JSONObject bodyNode = (JSONObject) JSONValue.parse("{}");
- JSONObject set = (JSONObject) dataJson.get("set");
-
- bodyNode.put("QueryType", "batch_update");
- bodyNode.put("Database", Database);
- bodyNode.put("Datatable", tableName);
- bodyNode.put("Criterias", dataJson.get("criterias"));
- bodyNode.put("Set", set);
- log.info(bodyNode.toString());
- try {
- String result = DBAgent.GetAgent().Query(bodyNode).toString();
- // log.info(result);
- return result;
- } catch (Exception e) {
- e.printStackTrace();
- log.error("请求异常:",e);
- return ToolsUtil.errorJsonMsg(Arrays.toString(e.getStackTrace()));
- }
- }
- /**
- *
- * 功能描述:删除数据
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String deleteRecord(String tableName, String jsonStr) {
- return deleteRecord(DBConst.DATABASE_NAME, tableName, jsonStr);
- }
- /**
- *
- * 功能描述:删除数据
- * @param Database
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String deleteRecord(String Database, String tableName, String jsonStr) {
- JSONObject dataJson = (JSONObject) JSONValue.parse(jsonStr);
- JSONObject setNode = (JSONObject) JSONValue.parse("{}");
- setNode.put(DBConst.TABLE_FIELD_VALID, false);
- setNode.put(DBConst.TABLE_FIELD_UPDATE_TIME, DateUtil.getNowTimeStr());
- JSONObject bodyNode = (JSONObject) JSONValue.parse("{}");
- bodyNode.put("QueryType", "update");
- bodyNode.put("Database", Database);
- bodyNode.put("Datatable", tableName);
- bodyNode.put("Criteria", dataJson.get("criteria"));
- bodyNode.put("Set", setNode);
- log.info(bodyNode.toString());
- try {
- String result = DBAgent.GetAgent().Query(bodyNode).toString();
- // log.info(result);
- return result;
- } catch (Exception e) {
- e.printStackTrace();
- log.error("请求异常:",e);
- return ToolsUtil.errorJsonMsg(Arrays.toString(e.getStackTrace()));
- }
- }
-
- /**
- * 功能描述:批量删除数据
- * @param tableName
- * @param jsonStr
- * @return
- */
- public static String deleteBatchRecord(String tableName, String jsonStr){
- return deleteBatchRecord(DBConst.DATABASE_NAME, tableName, jsonStr);
- }
- /**
- * 功能描述:批量删除数据
- * @param Database
- * @param tableName
- * @param jsonStr
- * @return
- */
- public static String deleteBatchRecord(String Database, String tableName, String jsonStr){
- JSONObject dataJson = (JSONObject) JSONValue.parse(jsonStr);
- JSONObject setNode = (JSONObject) JSONValue.parse("{}");
- setNode.put(DBConst.TABLE_FIELD_VALID, false);
- setNode.put(DBConst.TABLE_FIELD_UPDATE_TIME, DateUtil.getNowTimeStr());
-
- JSONObject bodyNode = (JSONObject) JSONValue.parse("{}");
- bodyNode.put("QueryType", "batch_update");
- bodyNode.put("Database", Database);
- bodyNode.put("Datatable", tableName);
- bodyNode.put("Criterias", dataJson.get("criterias"));
- bodyNode.put("Set", setNode);
- log.info(bodyNode.toString());
- try {
- String result = DBAgent.GetAgent().Query(bodyNode).toString();
- // log.info(result);
- return result;
- } catch (Exception e) {
- e.printStackTrace();
- log.error("请求异常:",e);
- return ToolsUtil.errorJsonMsg(Arrays.toString(e.getStackTrace()));
- }
- }
-
- /**
- *
- * 功能描述:根据主键查询一条记录数据
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String getRecordBykey(String tableName, String jsonStr) {
- return getRecordBykey(DBConst.DATABASE_NAME, tableName, jsonStr);
- }
- /**
- *
- * 功能描述:根据主键查询一条记录数据
- * @param Database
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String getRecordBykey(String Database, String tableName, String jsonStr) {
- JSONObject dataJson = (JSONObject) JSONValue.parse(jsonStr);
- JSONObject bodyNode = (JSONObject) JSONValue.parse("{}");
- bodyNode.put("QueryType", "get");
- bodyNode.put("Database", Database);
- bodyNode.put("Datatable", tableName);
- bodyNode.put("Key", dataJson.get("Key"));
- log.info(bodyNode.toString());
- try {
- String result = DBAgent.GetAgent().Query(bodyNode).toString();
- // log.info(result);
- return result;
- } catch (Exception e) {
- e.printStackTrace();
- log.error("请求异常:",e);
- return ToolsUtil.errorJsonMsg(Arrays.toString(e.getStackTrace()));
- }
- }
- /**
- *
- * 功能描述:根据主键查询多条记录数据
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String getBatchRecordBykeys(String tableName, String jsonStr) {
- return getBatchRecordBykeys(DBConst.DATABASE_NAME, tableName, jsonStr);
- }
- /**
- *
- * 功能描述:根据主键查询多条记录数据
- * @param Database
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String getBatchRecordBykeys(String Database, String tableName, String jsonStr) {
- JSONObject dataJson = (JSONObject) JSONValue.parse(jsonStr);
- JSONObject bodyNode = (JSONObject) JSONValue.parse("{}");
- bodyNode.put("QueryType", "batch_get");
- bodyNode.put("Database", Database);
- bodyNode.put("Datatable", tableName);
- bodyNode.put("Keys", dataJson.get("keys"));
- bodyNode.put("ReturnColumns", dataJson.get("ReturnColumns"));
- log.info(bodyNode.toString());
- try {
- String result = DBAgent.GetAgent().Query(bodyNode).toString();
- // log.info(result);
- return result;
- } catch (Exception e) {
- e.printStackTrace();
- log.error("请求异常:",e);
- return ToolsUtil.errorJsonMsg(Arrays.toString(e.getStackTrace()));
- }
- }
- /**
- *
- * 功能描述:查询所有数据,包括无效数据
- * @param tableName
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String queryAllRecord( String tableName) {
- String jsonStr = "{\"criteria\":{}}" ;
- return queryRecordByCriteria(DBConst.DATABASE_NAME, tableName, jsonStr);
- }
- /**
- *
- * 功能描述:查询所有数据,包括无效数据
- * @param tableName
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String queryAllRecord(String dataSource, String tableName) {
- String jsonStr = "{\"criteria\":{}}" ;
- return queryRecordByCriteria(dataSource, tableName, jsonStr);
- }
- /**
- *
- * 功能描述:查询所有有效数据
- * @param tableName
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String queryAllValidRecord( String tableName) {
- String jsonStr = "{\"criteria\":{}}" ;
- return queryValidRecordByCriteria(DBConst.DATABASE_NAME, tableName, jsonStr);
- }
- /**
- *
- * 功能描述:查询符合条件的数据,包括无效数据
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String queryRecordByCriteria( String tableName, String jsonStr) {
- return queryRecordByCriteria(DBConst.DATABASE_NAME, tableName, jsonStr);
- }
-
- /**
- *
- * 功能描述:查询符合条件的数据,包括无效数据
- * @param Database
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String queryRecordByCriteria(String Database, String tableName, String jsonStr) {
- JSONObject dataJson = (JSONObject) JSONValue.parse(jsonStr);
- JSONObject bodyNode = (JSONObject) JSONValue.parse("{}");
- bodyNode.put("QueryType", "select");
- bodyNode.put("Database", Database);
- bodyNode.put("Datatable", tableName);
- bodyNode.put("Criteria", dataJson.get("criteria"));
- log.info(bodyNode.toString());
- try {
- String result = DBAgent.GetAgent().Query(bodyNode).toString();
- // log.info(result);
- return result;
- } catch (Exception e) {
- e.printStackTrace();
- log.error("请求异常:",e);
- return ToolsUtil.errorJsonMsg(Arrays.toString(e.getStackTrace()));
- }
- }
-
- /**
- * 功能描述:批量查询符合条件的数据,并合并,包括无效数据
- * @param tableName
- * @param jsonStr
- * @return
- */
- public static String queryBathchMergeRecordByCriterias(String tableName, String jsonStr){
- return queryBathchMergeRecordByCriterias(DBConst.DATABASE_NAME, tableName, jsonStr);
- }
- /**
- * 功能描述:批量查询符合条件的数据,并合并,包括无效数据
- * @param dataBase
- * @param tableName
- * @param jsonStr
- * @return
- */
- public static String queryBathchMergeRecordByCriterias(String dataBase, String tableName, String jsonStr){
- JSONObject dataJson = (JSONObject) JSONValue.parse(jsonStr);
- JSONObject bodyNode = (JSONObject) JSONValue.parse("{}");
- bodyNode.put("QueryType", "batch_select_merge");
- bodyNode.put("Database", dataBase);
- bodyNode.put("Datatable", tableName);
- bodyNode.put("Criterias", dataJson.get("criterias"));
- log.info(bodyNode.toString());
- try {
- String result = DBAgent.GetAgent().Query(bodyNode).toString();
- // log.info(result);
- return result;
- } catch (Exception e) {
- e.printStackTrace();
- log.error("请求异常:",e);
- return ToolsUtil.errorJsonMsg(Arrays.toString(e.getStackTrace()));
- }
- }
-
- /**
- *
- * 功能描述:查询符合条件的有效数据
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String queryValidRecordByCriteria( String tableName, String jsonStr) {
- return queryValidRecordByCriteria(DBConst.DATABASE_NAME, tableName, jsonStr);
- }
-
- /**
- *
- * 功能描述:查询符合条件的有效数据
- * @param Database
- * @param tableName
- * @param jsonStr
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- public static String queryValidRecordByCriteria(String Database, String tableName, String jsonStr) {
- JSONObject dataJson = (JSONObject) JSONValue.parse(jsonStr);
- JSONObject bodyNode = (JSONObject) JSONValue.parse("{}");
- bodyNode.put("QueryType", "select");
- bodyNode.put("Database", Database);
- bodyNode.put("Datatable", tableName);
- bodyNode.put("Criteria", dataJson.get("criteria"));
- log.info(bodyNode.toString());
- try {
- JSONObject resJson = DBAgent.GetAgent().Query(bodyNode);
- JSONArray arr = (JSONArray) resJson.get("Content");
- int removeCount = 0;
- for (int i = arr.size() - 1; i > -1; i--) {
- JSONObject node = (JSONObject) arr.get(i);
- if(node.get(DBConst.TABLE_FIELD_VALID) != null && !(Boolean) node.get(DBConst.TABLE_FIELD_VALID)){
- arr.remove(i);
- removeCount += 1;
- }
- }
- resJson.put("Count", (Long)resJson.get("Count")- removeCount);
- // log.info(resJson.toString());
- return resJson.toString();
- } catch (Exception e) {
- e.printStackTrace();
- log.error("请求异常:",e);
- return ToolsUtil.errorJsonMsg(Arrays.toString(e.getStackTrace()));
- }
- }
- /**
- *
- * 功能描述:处理新增数据
- * @param node
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- private static JSONObject processInsertObj(JSONObject node) {
- if(!node.containsKey(DBConst.TABLE_FIELD_CTEATE_TIME)){
- // 添加创建时间
- node.put(DBConst.TABLE_FIELD_CTEATE_TIME, DateUtil.getNowTimeStr());
- }
- // 添加更新时间
- node.put(DBConst.TABLE_FIELD_UPDATE_TIME, DateUtil.getNowTimeStr());
- // 添加数据有效状态,true-有效,false-无效
- node.put(DBConst.TABLE_FIELD_VALID, true);
- return node;
- }
- /**
- *
- * 功能描述:处理新增数据
- * @param nodes
- * @return
- * @创建者 wanghailong
- * @邮箱 wanghailong@persagy.com
- * @修改描述
- */
- private static JSONArray processInsertArray(JSONArray nodes) {
- JSONArray array = new JSONArray();
- for(int i=0; i<nodes.size(); i++){
- array.add(processInsertObj((JSONObject) nodes.get(i)));
- }
- return array;
- }
- }
|