readme中ipu-nosql补充;

mongodb使用案例修改;

ipu-rest-scaffold/readme.md

@@ -23,13 +23,34 @@ webapp下可存放静态页面，便于前后端开发联调。
SQL被统一存放在classpath的sql路径下，如：sql.ipu.demo。
使用命名空间+id的方式定位SQL配置，DbSqlMgmtController有代码使用范例。
###四、ipu-nosql组件
- 目前ipu-nosql仅支持mongoDB,对应的配置文件为:ipu-nosql.xml
- 该组件使用案例在:MongoDbController中
- 1.ipu-nosql组件的引入
    - 以maven为例,请在pom.xml中引入ipu-nosql组件和mongodb驱动包
        ```
        <dependency>
            <groupId>com.ai.ipu</groupId>
            <artifactId>ipu-nosql</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.mongodb</groupId>
            <artifactId>mongo-java-driver</artifactId>
            <version>3.11.2</version>
        </dependency>
        ```
- 目前ipu-nosql组件仅支持mongoDB,对应的配置文件为:ipu-nosql.xml
- 该组件支持事务:遵循规则为:execution(* com.ai..service..*Impl.process*(..))
- 若开启事物请在ipu-nosql.xml配置文件中将needTranscation属性设置为true
    ```
    <config name="needTranscation" value="true"/>
    ```
    - 1、execution(): 表达式主体。
    - 2、第一个*号：表示返回类型，*号表示所有的类型。
    - 3、包名：表示需要拦截的包名，后面的两个句点表示当前包和当前包的所有子包，拦截com.ai..service..包、子包下所有类的方法。
    - 4、第二个*号：表示类名，*号表示所有的类,*Impl表示拦截以Impl结尾的类名
    - 5、最后这个星号表示方法名，*号表示所有的方法，process*(..)表示会拦截以process开头的方法,后面括弧里面表示方法的参数，两个句点表示任何参数。
    - 若开启事物请在ipu-nosql.xml配置文件中将needTranscation属性设置为true
        ```
        <config name="needTranscation" value="true"/>
        ```
- 该组件使用案例在:MongoDbController中
###打包运行
java -Dipu.lic.path=ipu.lic -jar ipu-rest-scaffold.jar --server.port=8080

ipu-rest-scaffold/src/main/java/com/ai/ipu/server/control/MongoDbController.java

@@ -1,7 +1,12 @@
package com.ai.ipu.server.control;
import com.ai.ipu.basic.util.IpuUtility;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.nosql.INoSql;
import com.ai.ipu.nosql.mongodb.MongoCacheFactory;
import com.ai.ipu.server.service.MongoDbService;
import com.ai.ipu.server.util.RestScaffoldConstant;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;
@@ -17,28 +22,56 @@ public class MongoDbController {
    @Autowired
    MongoDbService MongoDbService;
    private String connName = "data";
    private String dbName = "test";
    private String tableName = "mycol1";
    @ResponseBody
    @RequestMapping("/select")
    public JMap executeSelect(JMap params) throws Exception{
        return MongoDbService.executeSelect(params);
    public JMap executeSelect(JMap params) throws Exception {
        JMap retMap = new JsonMap();
        try {
            retMap = MongoDbService.executeSelect(params,connName,dbName,tableName);
        } catch (Exception e) {
            IpuUtility.errorCode(RestScaffoldConstant.SERVER_003);
        }
        return retMap;
    }
    @ResponseBody
    @RequestMapping("/insert")
    public JMap executeInsert(JMap params) throws Exception{
        return  MongoDbService.processInsert(params);
    public JMap executeInsert(JMap params) throws Exception {
        JMap retMap = new JsonMap();
        try {
            retMap = MongoDbService.processInsert(params,connName,dbName,tableName);
        } catch (Exception e) {
            IpuUtility.errorCode(RestScaffoldConstant.SERVER_003);
        }
        return retMap;
    }
    @ResponseBody
    @RequestMapping("/update")
    public JMap executeUpdate(JMap params) throws Exception{
        return  MongoDbService.processUpdate(params);
    public JMap executeUpdate(JMap params) throws Exception {
        JMap retMap = new JsonMap();
        try {
            retMap = MongoDbService.processUpdate(params,connName,dbName,tableName);
        } catch (Exception e) {
            IpuUtility.errorCode(RestScaffoldConstant.SERVER_003);
        }
        return retMap;
    }
    @ResponseBody
    @RequestMapping("/delete")
    public JMap executeDelete(JMap params) throws Exception{
        return MongoDbService.processDelete(params);
    public JMap executeDelete(JMap params) throws Exception {
        JMap retMap = new JsonMap();
        try {
            retMap = MongoDbService.processDelete(params,connName,dbName,tableName);
        } catch (Exception e) {
            IpuUtility.errorCode(RestScaffoldConstant.SERVER_003);
        }
        return retMap;
    }
}

ipu-rest-scaffold/src/main/java/com/ai/ipu/server/service/MongoDbService.java

@@ -2,13 +2,17 @@ package com.ai.ipu.server.service;
import com.ai.ipu.data.JMap;
/**
 * @author miaozy@asiainfo.com
 */
public interface MongoDbService {
    JMap executeSelect(JMap params) throws Exception;
    JMap executeSelect(JMap params, String connName, String dbName, String tableName) throws Exception;
    JMap processInsert(JMap params) throws Exception;
    JMap processInsert(JMap params, String connName, String dbName, String tableName) throws Exception;
    JMap processUpdate(JMap params) throws Exception;
    JMap processUpdate(JMap params, String connName, String dbName, String tableName) throws Exception;
    JMap processDelete(JMap params, String connName, String dbName, String tableName) throws Exception;
    JMap processDelete(JMap params) throws Exception;
}

ipu-rest-scaffold/src/main/java/com/ai/ipu/server/service/impl/MongoDbServiceImpl.java

@@ -1,69 +1,55 @@
package com.ai.ipu.server.service.impl;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.nosql.INoSql;
import com.ai.ipu.nosql.mongodb.MongoCacheFactory;
import com.ai.ipu.server.service.MongoDbService;
import com.ai.ipu.server.util.RestScaffoldConstant;
import com.alibaba.fastjson.JSONObject;
import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
 * @author miaozy@asiainfo.com
 */
@Service
public class MongoDbServiceImpl implements MongoDbService {
    private String connName = "data";
    private String dbName = "test";
    private String tableName = "mycol1";
    @Override
    public JMap executeSelect(JMap params) throws Exception {
    public JMap executeSelect(JMap params, String connName, String dbName, String tableName) throws Exception {
        JMap retMap = new JsonMap();
        String condParam = params.getString("condParam");
        String sortParam = params.getString("sortParam") == null ? "{}" : params.getString("sortParam");
        INoSql noSql = MongoCacheFactory.getMongoDao(connName, dbName, tableName);
        JSONObject condParam = new JSONObject();
        condParam.put("nickName", "tom");
        List<String> resultList = noSql.executeSelect(condParam.toJSONString(), "{}");
        params.put("retList",resultList);
        return params;
        retMap.put("retList", noSql.executeSelect(condParam, sortParam));
        return retMap;
    }
    @Override
    public JMap processInsert(JMap params) throws Exception {
    public JMap processInsert(JMap params, String connName, String dbName, String tableName) throws Exception {
        JMap retMap = new JsonMap();
        INoSql noSql = MongoCacheFactory.getMongoDao(connName, dbName, tableName);
        JSONObject param = new JSONObject();
        param.put("name", "mongo");
        JSONObject data = new JSONObject();
        data.put("name", "mongo");
        data.put("age","6");
        data.put("nickName", "tom");
        Map info = new HashMap();
        info.put("ver", 5.0);
        data.put("info", info);
        noSql.executeInsert(data.toJSONString());
        return params;
        String data = params.getString("data");
        noSql.executeInsert(data);
        return retMap;
    }
    @Override
    public JMap processUpdate(JMap params) throws Exception{
    public JMap processUpdate(JMap params, String connName, String dbName, String tableName) throws Exception {
        JMap retMap = new JsonMap();
        String condParam = params.getString("condParam");
        String updateField = params.getString("updateField");
        INoSql noSql = MongoCacheFactory.getMongoDao(connName, dbName, tableName);
        JSONObject condParam = new JSONObject();
        condParam.put("nickName", "tom");
        JSONObject updateField = new JSONObject();
        updateField.put("name", "1256");
        updateField.put("age","11");
        updateField.put("info.ver",10.0);
        noSql.executeUpdateMany(condParam.toJSONString(), updateField.toJSONString());
        return params;
        noSql.executeUpdateMany(condParam, updateField);
        return retMap;
    }
    @Override
    public JMap processDelete(JMap params) throws Exception{
    public JMap processDelete(JMap params, String connName, String dbName, String tableName) throws Exception {
        JMap retMap = new JsonMap();
        String condParam = params.getString("condParam");
        INoSql noSql = MongoCacheFactory.getMongoDao(connName, dbName, tableName);
        JSONObject condParam = new JSONObject();
        condParam.put("nickName", "tom");
        noSql.executeDeleteMany(condParam.toJSONString());
        return params;
        noSql.executeDeleteMany(condParam);
        return retMap;
    }
}