重写事务示例，使用新的秘钥。

ipu-rest-scaffold/pom.xml

@@ -50,7 +50,7 @@
        <dependency>
            <groupId>com.ai.ipu</groupId>
            <artifactId>ipu-nosql</artifactId>
            <version>0.0.1-SNAPSHOT</version>
            <version>3.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.mongodb</groupId>

ipu-rest-scaffold/readme.md

@@ -24,7 +24,7 @@ SQL被统一存放在classpath的sql路径下，如：sql.ipu.demo。
使用命名空间+id的方式定位SQL配置，DbSqlMgmtController有代码使用范例。
###四、ipu-nosql组件
- 1.ipu-nosql组件的引入
    - 以maven为例,请在pom.xml中引入ipu-nosql组件和mongodb驱动包
    - 以maven为例,请在pom.xml中引入ipu-nosql组件和mongodb驱动包。如果使用的springboot为2.2.1.RELEASE或更高版本时，则不再需要添加mongodb驱动包。因为该版本已支持3.11.2的mongodb驱动包。
        ```
        <dependency>
            <groupId>com.ai.ipu</groupId>

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

@@ -1,10 +1,9 @@
package com.ai.ipu.server.control;
import com.ai.ipu.basic.util.IpuException;
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;
@@ -24,52 +23,99 @@ public class MongoDbController {
    private String connName = "data";
    private String dbName = "test";
    private String tableName = "mycol1";
    
    @ResponseBody
    @RequestMapping("/select")
    @RequestMapping("/selectUser")
    public JMap executeSelect(JMap params) throws Exception {
        JMap retMap = new JsonMap();
        params.put("connName", connName);
        params.put("dbName", dbName);
        if (!params.containsKey("condParam"))
        	params.put("condParam", "{\"name\": \"tom\"}");
        
        try {
            retMap = MongoDbService.executeSelect(params,connName,dbName,tableName);
        	//单独做查询时，不涉及事务控制，因此service的方法名命名就可以不遵照process开头。
            retMap.put("resultList", MongoDbService.executeSelect(params));
        } catch (IpuException ie) {
        	IpuUtility.error(ie.getMessage());
        } catch (Exception e) {
            IpuUtility.errorCode(RestScaffoldConstant.SERVER_003);
            IpuUtility.errorCode(RestScaffoldConstant.SERVER_004);
        }
        return retMap;
    }
    @ResponseBody
    @RequestMapping("/insert")
    @RequestMapping("/insertUser")
    public JMap executeInsert(JMap params) throws Exception {
        JMap retMap = new JsonMap();
        params.put("connName", connName);
        params.put("dbName", dbName);
        if (!params.containsKey("operType"))
        	params.put("operType", "insertUser");
        
        try {
            retMap = MongoDbService.processInsert(params,connName,dbName,tableName);
        	/* 涉及事务控制，因此service的方法名命名就要遵照process开头。
        	 * 一个process开头的方法里，所有对mongodb的增删改都是一个事务
        	 * 如果需要支持多事务，有2种解决方案：
        	 * 1、不同的事务使用不同的service方法；参见processInsertUser和processInsertLog
        	 * 2、在一个service方法里，直接声明独立事务。参见processInsertUserAndLog
        	*/
            MongoDbService.processInsertUserAndLog(params);
            retMap.put("result", "插入一条用户记录成功");
        } catch (IpuException ie) {
        	IpuUtility.error(ie.getMessage());
        } catch (Exception e) {
            IpuUtility.errorCode(RestScaffoldConstant.SERVER_003);
            IpuUtility.errorCode(RestScaffoldConstant.SERVER_005);
        }
        return retMap;
    }
    @ResponseBody
    @RequestMapping("/update")
    @RequestMapping("/updateUser")
    public JMap executeUpdate(JMap params) throws Exception {
        JMap retMap = new JsonMap();
        params.put("connName", connName);
        params.put("dbName", dbName);
        if (!params.containsKey("operType"))
        	params.put("operType", "updateUser");
        if (!params.containsKey("condParam"))
        	params.put("condParam", "{\"name\": \"tom\"}");
        
        try {
            retMap = MongoDbService.processUpdate(params,connName,dbName,tableName);
            try {
            	MongoDbService.processInsertLog(params);
            }catch (Exception e1) {}
            MongoDbService.processUpdateUser(params);
            retMap.put("result", "更改用户记录成功");
        } catch (IpuException ie) {
        	IpuUtility.error(ie.getMessage());
        } catch (Exception e) {
            IpuUtility.errorCode(RestScaffoldConstant.SERVER_003);
            IpuUtility.errorCode(RestScaffoldConstant.SERVER_006);
        }
        return retMap;
    }
    @ResponseBody
    @RequestMapping("/delete")
    @RequestMapping("/deleteUser")
    public JMap executeDelete(JMap params) throws Exception {
        JMap retMap = new JsonMap();
        params.put("connName", connName);
        params.put("dbName", dbName);
        if (!params.containsKey("operType"))
        	params.put("operType", "deleteUser");
        if (!params.containsKey("condParam"))
        	params.put("condParam", "{\"name\": \"tom\"}");
        
        try {
            retMap = MongoDbService.processDelete(params,connName,dbName,tableName);
        	try {
            	MongoDbService.processInsertLog(params);
            }catch (Exception e1) {}
            MongoDbService.processDeleteUser(params);
            retMap.put("result", "删除用户记录成功");
        } catch (IpuException ie) {
        	IpuUtility.error(ie.getMessage());
        } catch (Exception e) {
            IpuUtility.errorCode(RestScaffoldConstant.SERVER_003);
            IpuUtility.errorCode(RestScaffoldConstant.SERVER_007);
        }
        return retMap;
    }

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

@@ -1,18 +1,25 @@
package com.ai.ipu.server.service;
import java.util.List;
import com.ai.ipu.data.JMap;
/**
 * @author miaozy@asiainfo.com
 */
public interface MongoDbService {
    JMap executeSelect(JMap params, String connName, String dbName, String tableName) throws Exception;
    List<String> executeSelect(JMap params) throws Exception;
    JMap processInsert(JMap params, String connName, String dbName, String tableName) throws Exception;
    void processInsertUser(JMap params) throws Exception;
    
    void processInsertLog(JMap params) throws Exception;
    
    void processInsertUserAndLog(JMap params) throws Exception;
    JMap processUpdate(JMap params, String connName, String dbName, String tableName) throws Exception;
    void processUpdateUser(JMap params) throws Exception;
    JMap processDelete(JMap params, String connName, String dbName, String tableName) throws Exception;
    void processDeleteUser(JMap params) throws Exception;
}

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

@@ -1,10 +1,16 @@
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.alibaba.fastjson.JSONObject;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import org.springframework.stereotype.Service;
@@ -13,43 +19,100 @@ import org.springframework.stereotype.Service;
 */
@Service
public class MongoDbServiceImpl implements MongoDbService {
	private String tableUser = "userInfo";
	private String tableLog = "operLog";
    @Override
    public JMap executeSelect(JMap params, String connName, String dbName, String tableName) throws Exception {
        JMap retMap = new JsonMap();
    public List<String> executeSelect(JMap params) throws Exception {
        String condParam = params.getString("condParam");
        String sortParam = params.getString("sortParam") == null ? "{}" : params.getString("sortParam");
        INoSql noSql = MongoCacheFactory.getMongoDao(connName, dbName, tableName);
        retMap.put("retList", noSql.executeSelect(condParam, sortParam));
        return retMap;
        INoSql noSql = MongoCacheFactory.getMongoDao(params.getString("connName"), params.getString("dbName"), tableUser);
        return noSql.executeSelect(condParam, sortParam);
    }
    @Override
    public JMap processInsert(JMap params, String connName, String dbName, String tableName) throws Exception {
        JMap retMap = new JsonMap();
        INoSql noSql = MongoCacheFactory.getMongoDao(connName, dbName, tableName);
        String data = params.getString("data");
        noSql.executeInsert(data);
        return retMap;
    public void processInsertUser(JMap params) throws Exception {
        INoSql noSql = MongoCacheFactory.getMongoDao(params.getString("connName"), params.getString("dbName"), tableUser);
        noSql.executeInsert(buildUser(params));
    }
    
    @Override
    public void processInsertLog(JMap params) throws Exception {
        INoSql noSql = MongoCacheFactory.getMongoDao(params.getString("connName"), params.getString("dbName"), tableLog);
        noSql.executeInsert(buildLog(params));
    }
    
    @Override
    public void processInsertUserAndLog(JMap params) throws Exception {
        INoSql noSql = MongoCacheFactory.getMongoDao(params.getString("connName"), params.getString("dbName"), tableLog);
        noSql.executeInsert(buildLog(params));
        //声明独立事务。operLog和userInfo是不同事务，userInfo插入失败不会回滚operLog。
        //如果不声明，则operLog和userInfo是同一事务；只要任何一个插入失败，则全部做事务回滚。
        MongoCacheFactory.commit(params.getString("connName"), params.getString("dbName"), tableLog);
        MongoCacheFactory.clear(params.getString("connName"), params.getString("dbName"), tableLog);
        
        noSql = MongoCacheFactory.getMongoDao(params.getString("connName"), params.getString("dbName"), tableUser);
        noSql.executeInsert(buildUser(params));
    }
    @Override
    public JMap processUpdate(JMap params, String connName, String dbName, String tableName) throws Exception {
        JMap retMap = new JsonMap();
    public void processUpdateUser(JMap params) throws Exception {
        String condParam = params.getString("condParam");
        String updateField = params.getString("updateField");
        INoSql noSql = MongoCacheFactory.getMongoDao(connName, dbName, tableName);
        String updateField = buildUser(params);
        INoSql noSql = MongoCacheFactory.getMongoDao(params.getString("connName"), params.getString("dbName"), tableUser);
        noSql.executeUpdateMany(condParam, updateField);
        return retMap;
    }
    @Override
    public JMap processDelete(JMap params, String connName, String dbName, String tableName) throws Exception {
        JMap retMap = new JsonMap();
    public void processDeleteUser(JMap params) throws Exception {
        String condParam = params.getString("condParam");
        INoSql noSql = MongoCacheFactory.getMongoDao(connName, dbName, tableName);
        INoSql noSql = MongoCacheFactory.getMongoDao(params.getString("connName"), params.getString("dbName"), tableUser);
        noSql.executeDeleteMany(condParam);
        return retMap;
    }
    
    private String buildUser(JMap params) {
    	StringBuffer result = new StringBuffer();
    	if (params.containsKey("data"))
    		result.append(params.getString("data"));
        else
        {
        	JSONObject data = new JSONObject();
        	for(Entry<String, Object> entry : params.entrySet()){
        		if (entry.getKey().equals("connName") || 
        				entry.getKey().equals("dbName") ||
        				entry.getKey().startsWith("oper") ||
        				entry.getKey().startsWith("cond"))       		
        			continue;
        		
        		data.put(entry.getKey(), entry.getValue());	
        	}
        	if (data.isEmpty())
        	{
        		data.put("name", "tom");
        		data.put("male", true);
        		Map info = new HashMap();
        		info.put("city", "beijing");
        		info.put("tag", "[\"tennis\",\"football\", \"travel\"]");
        		data.put("info", info);
        	}
        	result.append(data.toJSONString());
        }
    	return result.toString();
    }
    
    private String buildLog(JMap params) {
    	JSONObject data = new JSONObject();
    	for(Entry<String, Object> entry : params.entrySet()){
    		if (entry.getKey().equals("connName") || 
    				entry.getKey().equals("dbName") ||
    				entry.getKey().startsWith("oper") ||
    				entry.getKey().startsWith("cond"))       		
    		{
    			data.put(entry.getKey(), entry.getValue());
    		}
    		
    			
    	}
    	return data.toJSONString();
    }
}

ipu-rest-scaffold/src/main/java/com/ai/ipu/server/util/RestScaffoldConstant.java

@@ -1,15 +1,19 @@
package com.ai.ipu.server.util;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2019年11月20日下午3:14:00
 * @desc 常量类。工程名(驼峰)+Constant
 */
public class RestScaffoldConstant {
    /*异常编码*/
    public static final String SERVER_001 = "SERVER_001";
    public static final String SERVER_002 = "SERVER_002";
    public static final String SERVER_003 = "SERVER_003";
}
package com.ai.ipu.server.util;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2019年11月20日下午3:14:00
 * @desc 常量类。工程名(驼峰)+Constant
 */
public class RestScaffoldConstant {
    /*异常编码*/
    public static final String SERVER_001 = "SERVER_001";
    public static final String SERVER_002 = "SERVER_002";
    public static final String SERVER_003 = "SERVER_003";
    public static final String SERVER_004 = "SERVER_004";
    public static final String SERVER_005 = "SERVER_005";
    public static final String SERVER_006 = "SERVER_006";
    public static final String SERVER_007 = "SERVER_007";
}

ipu-rest-scaffold/src/main/resources/dev/ipu-nosql.xml

@@ -17,9 +17,9 @@
        <config name="userName" value="ipuOper"/>
        <!-- 加密后的用户密码，不做身份验证时可空；身份认证时必填 -->
        <!-- 加密算法需要用一对@@包含，并且放在密码的最前面。如果没有发现加密算法，则为明文密码  -->
        <config name="encryptedPasswd" value="@DES@cMBWCqZgG39bQ+PyRkJ4sw=="/>
        <config name="encryptedPasswd" value="@DES@cqKYnoRap2YV9L7xEQ4fyw=="/>
        <!-- 解密秘钥 ，可为空 -->
        <config name="decryptedKey" value="325m@#$rt4vt"/>
        <config name="decryptedKey" value="Mongo4@121#_3$"/>
        <!-- 自定义解密算法需要在pom.xml里引入所需jar，并在此声明带全包名的类 -->
        <config name="decryptedClass" value="com.ai.ipu.nosql.util.DecryptUtil"/>
        <!-- 自定义解密算法的解密算法，加密后的秘钥（可为空，为空则只有1个参数）、密码串是算法的2个参数  -->

ipu-rest-scaffold/src/main/resources/exception_messages_zh_CN.properties

@@ -1,3 +1,7 @@
SERVER_001=条件参数不能为空
SERVER_002=[%v]参数异常
SERVER_003=业务办理失败：主键冲突
SERVER_001=条件参数不能为空
SERVER_002=[%v]参数异常
SERVER_003=业务办理失败：主键冲突
SERVER_004=查询失败
SERVER_005=插入失败
SERVER_006=更改失败
SERVER_007=删除失败