ipu-rest-scaffold/pom.xml

@@ -31,6 +31,7 @@
    <properties>
        <start-class>com.ai.ipu.server.RestScaffoldStart</start-class>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <mongo.java.driver>3.11.2</mongo.java.driver>
        <ipu>3.1-SNAPSHOT</ipu>
    </properties>
@@ -46,6 +47,16 @@
        	<groupId>com.ai.ipu.server</groupId>
        	<artifactId>ipu-restful</artifactId>
        </dependency>
        <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>${mongo.java.driver}</version>
        </dependency>
    </dependencies>
    <build>

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

@@ -0,0 +1,44 @@
package com.ai.ipu.server.control;
import com.ai.ipu.data.JMap;
import com.ai.ipu.server.service.MongoDbService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;
/**
 * @author miaozy@asiainfo.com
 * @desc mongodb使用范例
 */
@Controller
@RequestMapping("/mongodb")
public class MongoDbController {
    @Autowired
    MongoDbService MongoDbService;
    @ResponseBody
    @RequestMapping("/select")
    public JMap executeSelect(JMap params) throws Exception{
        return MongoDbService.executeSelect(params);
    }
    @ResponseBody
    @RequestMapping("/insert")
    public JMap executeInsert(JMap params) throws Exception{
        return  MongoDbService.processInsert(params);
    }
    @ResponseBody
    @RequestMapping("/update")
    public JMap executeUpdate(JMap params) throws Exception{
        return  MongoDbService.processUpdate(params);
    }
    @ResponseBody
    @RequestMapping("/delete")
    public JMap executeDelete(JMap params) throws Exception{
        return MongoDbService.processDelete(params);
    }
}

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

@@ -0,0 +1,14 @@
package com.ai.ipu.server.service;
import com.ai.ipu.data.JMap;
public interface MongoDbService {
    JMap executeSelect(JMap params) throws Exception;
    JMap processInsert(JMap params) throws Exception;
    JMap processUpdate(JMap params) throws Exception;
    JMap processDelete(JMap params) throws Exception;
}

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

@@ -0,0 +1,69 @@
package com.ai.ipu.server.service.impl;
import com.ai.ipu.data.JMap;
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;
@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 {
        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;
    }
    @Override
    public JMap processInsert(JMap params) throws Exception {
        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;
    }
    @Override
    public JMap processUpdate(JMap params) throws Exception{
        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;
    }
    @Override
    public JMap processDelete(JMap params) throws Exception{
        INoSql noSql = MongoCacheFactory.getMongoDao(connName, dbName, tableName);
        JSONObject condParam = new JSONObject();
        condParam.put("nickName", "tom");
        noSql.executeDeleteMany(condParam.toJSONString());
        return params;
    }
}

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

@@ -0,0 +1,69 @@
<?xml version = '1.0' encoding = 'UTF-8'?>
<connections>
    <connection name="data" type="mongo">
        <servers>
            <server ip="10.1.236.121" port="11000" />
            <server ip="10.1.236.121" port="11010" />
            <server ip="10.1.236.121" port="11020" />
        </servers>
        <!-- 连接时数据库名，不做身份验证时可空；身份认证时必填 -->
        <config name="authSource" value="admin"/>
        <!-- 认证机制，不做身份验证时可空；身份认证时必填。mongo3.0及更高版本缺省是SCRAM-SHA-1 -->
        <!-- mongo2.6以前缺省是MONGODB-CR， mongo4.0及更高版本已经不再支持-->
        <!-- 支持SCRAM-SHA-1、SCRAM-SHA-256-->
        <!-- 当前组件不支持x.509证书 -->
        <config name="authMechanism" value="SCRAM-SHA-256"/>
        <!-- 用户名，不做身份验证时可空；身份认证时必填 -->
        <config name="userName" value="ipuOper"/>
        <!-- 加密后的用户密码，不做身份验证时可空；身份认证时必填 -->
        <!-- 加密算法需要用一对@@包含，并且放在密码的最前面。如果没有发现加密算法，则为明文密码  -->
        <config name="encryptedPasswd" value="@DES@cMBWCqZgG39bQ+PyRkJ4sw=="/>
        <!-- 解密秘钥 ，可为空 -->
        <config name="decryptedKey" value="325m@#$rt4vt"/>
        <!-- 自定义解密算法需要在pom.xml里引入所需jar，并在此声明带全包名的类 -->
        <config name="decryptedClass" value="com.ai.ipu.nosql.util.DecryptUtil"/>
        <!-- 自定义解密算法的解密算法，加密后的秘钥（可为空，为空则只有1个参数）、密码串是算法的2个参数  -->
        <config name="decryptedMethod" value="decryptDES"/>
        <!-- 是否支持事务，true为支持，其他值为不支持 -->
        <config name="needTranscation" value="true"/>
        <!-- 复制集名称，可以为空 -->
        <config name="replicaSet" value="lpsa_repl"/>
        <!-- 客户端最大连接数，超过了将会被阻塞，默认100 -->
        <config name="connectionsPerHost" />
        <!-- 客户端最小连接数 -->
        <config name="minConnectionsPerHost" />
        <!-- 可被阻塞的线程数因子，默认值为5，如果connectionsPerHost配置为10， -->
        <!-- 那么最多能阻塞50个线程，超过50个之后就会收到一个异常  -->
        <config name="threadAllowedToBlockForConnectionMultiplier" />
        <!-- 阻塞线程获取连接的最长等待时间，默认120000 ms -->
        <config name="maxWaitTime" />
        <!-- 连接池连接最大空闲时间，默认为0 -->
        <config name="maxConnectionIdleTime" />
        <!-- 连接池连接的最大存活时间，默认为0 -->
        <config name="maxConnectionLifeTime" />
        <!-- 连接超时时间，默认值是0，就是不超时 -->
        <config name="connectTimeout" />
        <!-- 超时时间，默认值是0，就是不超时 -->
        <config name="socketTimeout" />
        <!-- 当没有手动关闭游标时,是否自动释放游标对象。默认为 true。-->
        <config name="cursorFinalizerEnabled" />
        <!-- MongoDB有5种ReadPreference模式 -->
        <!-- primary            主节点，默认模式，读操作只在主节点，如果主节点不可用，报错或者抛出异常。-->
        <!-- primaryPreferred   首选主节点，大多情况下读操作在主节点，如果主节点不可用，如故障转移，读操作在从节点。-->
        <!-- secondary          从节点，读操作只在从节点， 如果从节点不可用，报错或者抛出异常。-->
        <!-- secondaryPreferred 首选从节点，大多情况下读操作在从节点，特殊情况（如单主节点架构）读操作在主节点。-->
        <!-- nearest            最邻近节点，读操作在最邻近的成员，可能是主节点或者从节点-->
        <config name="readPreference" />
    </connection>
    
    <connection name="simple" type="mongo">
        <servers>
            <server ip="10.1.236.121" port="11000" />
            <server ip="10.1.236.121" port="11010" />
            <server ip="10.1.236.121" port="11020" />
        </servers>
        <!-- 复制集名称，可以为空 -->
        <config name="replicaSet" value="lpsa_repl"/>
    </connection>
</connections>

ipu-rest-scaffold/src/main/resources/ipu-spring-mvc.xml

@@ -1,14 +1,17 @@
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
	xmlns:context="http://www.springframework.org/schema/context"
	xmlns:mvc="http://www.springframework.org/schema/mvc"
	xsi:schemaLocation="http://www.springframework.org/schema/beans 
	   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	   xmlns:context="http://www.springframework.org/schema/context"
	   xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:aop="http://www.springframework.org/schema/aop"
	   xsi:schemaLocation="http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
           http://www.springframework.org/schema/context  
        http://www.springframework.org/schema/context/spring-context-3.0.xsd
        http://www.springframework.org/schema/mvc
		http://www.springframework.org/schema/mvc/spring-mvc.xsd">
		http://www.springframework.org/schema/mvc/spring-mvc.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">
    <context:component-scan base-package="com.ai.ipu.server" />
	<aop:aspectj-autoproxy proxy-target-class="true"/>
	<context:annotation-config />
	<bean id="transcationAspects" class="com.ai.ipu.nosql.aspect.TransactionAspect" />
</beans> 

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

@@ -0,0 +1,69 @@
<?xml version = '1.0' encoding = 'UTF-8'?>
<connections>
    <connection name="data" type="mongo">
        <servers>
            <server ip="10.1.236.121" port="11000" />
            <server ip="10.1.236.121" port="11010" />
            <server ip="10.1.236.121" port="11020" />
        </servers>
        <!-- 连接时数据库名，不做身份验证时可空；身份认证时必填 -->
        <config name="authSource" value="admin"/>
        <!-- 认证机制，不做身份验证时可空；身份认证时必填。mongo3.0及更高版本缺省是SCRAM-SHA-1 -->
        <!-- mongo2.6以前缺省是MONGODB-CR， mongo4.0及更高版本已经不再支持-->
        <!-- 支持SCRAM-SHA-1、SCRAM-SHA-256-->
        <!-- 当前组件不支持x.509证书 -->
        <config name="authMechanism" value="SCRAM-SHA-256"/>
        <!-- 用户名，不做身份验证时可空；身份认证时必填 -->
        <config name="userName" value="ipuOper"/>
        <!-- 加密后的用户密码，不做身份验证时可空；身份认证时必填 -->
        <!-- 加密算法需要用一对@@包含，并且放在密码的最前面。如果没有发现加密算法，则为明文密码  -->
        <config name="encryptedPasswd" value="@DES@cMBWCqZgG39bQ+PyRkJ4sw=="/>
        <!-- 解密秘钥 ，可为空 -->
        <config name="decryptedKey" value="325m@#$rt4vt"/>
        <!-- 自定义解密算法需要在pom.xml里引入所需jar，并在此声明带全包名的类 -->
        <config name="decryptedClass" value="com.ai.ipu.nosql.util.DecryptUtil"/>
        <!-- 自定义解密算法的解密算法，加密后的秘钥（可为空，为空则只有1个参数）、密码串是算法的2个参数  -->
        <config name="decryptedMethod" value="decryptDES"/>
        <!-- 是否支持事务，true为支持，其他值为不支持 -->
        <config name="needTranscation" value="true"/>
        <!-- 复制集名称，可以为空 -->
        <config name="replicaSet" value="lpsa_repl"/>
        <!-- 客户端最大连接数，超过了将会被阻塞，默认100 -->
        <config name="connectionsPerHost" />
        <!-- 客户端最小连接数 -->
        <config name="minConnectionsPerHost" />
        <!-- 可被阻塞的线程数因子，默认值为5，如果connectionsPerHost配置为10， -->
        <!-- 那么最多能阻塞50个线程，超过50个之后就会收到一个异常  -->
        <config name="threadAllowedToBlockForConnectionMultiplier" />
        <!-- 阻塞线程获取连接的最长等待时间，默认120000 ms -->
        <config name="maxWaitTime" />
        <!-- 连接池连接最大空闲时间，默认为0 -->
        <config name="maxConnectionIdleTime" />
        <!-- 连接池连接的最大存活时间，默认为0 -->
        <config name="maxConnectionLifeTime" />
        <!-- 连接超时时间，默认值是0，就是不超时 -->
        <config name="connectTimeout" />
        <!-- 超时时间，默认值是0，就是不超时 -->
        <config name="socketTimeout" />
        <!-- 当没有手动关闭游标时,是否自动释放游标对象。默认为 true。-->
        <config name="cursorFinalizerEnabled" />
        <!-- MongoDB有5种ReadPreference模式 -->
        <!-- primary            主节点，默认模式，读操作只在主节点，如果主节点不可用，报错或者抛出异常。-->
        <!-- primaryPreferred   首选主节点，大多情况下读操作在主节点，如果主节点不可用，如故障转移，读操作在从节点。-->
        <!-- secondary          从节点，读操作只在从节点， 如果从节点不可用，报错或者抛出异常。-->
        <!-- secondaryPreferred 首选从节点，大多情况下读操作在从节点，特殊情况（如单主节点架构）读操作在主节点。-->
        <!-- nearest            最邻近节点，读操作在最邻近的成员，可能是主节点或者从节点-->
        <config name="readPreference" />
    </connection>
    
    <connection name="simple" type="mongo">
        <servers>
            <server ip="10.1.236.121" port="11000" />
            <server ip="10.1.236.121" port="11010" />
            <server ip="10.1.236.121" port="11020" />
        </servers>
        <!-- 复制集名称，可以为空 -->
        <config name="replicaSet" value="lpsa_repl"/>
    </connection>
</connections>

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

@@ -0,0 +1,69 @@
<?xml version = '1.0' encoding = 'UTF-8'?>
<connections>
    <connection name="data" type="mongo">
        <servers>
            <server ip="10.1.236.121" port="11000" />
            <server ip="10.1.236.121" port="11010" />
            <server ip="10.1.236.121" port="11020" />
        </servers>
        <!-- 连接时数据库名，不做身份验证时可空；身份认证时必填 -->
        <config name="authSource" value="admin"/>
        <!-- 认证机制，不做身份验证时可空；身份认证时必填。mongo3.0及更高版本缺省是SCRAM-SHA-1 -->
        <!-- mongo2.6以前缺省是MONGODB-CR， mongo4.0及更高版本已经不再支持-->
        <!-- 支持SCRAM-SHA-1、SCRAM-SHA-256-->
        <!-- 当前组件不支持x.509证书 -->
        <config name="authMechanism" value="SCRAM-SHA-256"/>
        <!-- 用户名，不做身份验证时可空；身份认证时必填 -->
        <config name="userName" value="ipuOper"/>
        <!-- 加密后的用户密码，不做身份验证时可空；身份认证时必填 -->
        <!-- 加密算法需要用一对@@包含，并且放在密码的最前面。如果没有发现加密算法，则为明文密码  -->
        <config name="encryptedPasswd" value="@DES@cMBWCqZgG39bQ+PyRkJ4sw=="/>
        <!-- 解密秘钥 ，可为空 -->
        <config name="decryptedKey" value="325m@#$rt4vt"/>
        <!-- 自定义解密算法需要在pom.xml里引入所需jar，并在此声明带全包名的类 -->
        <config name="decryptedClass" value="com.ai.ipu.nosql.util.DecryptUtil"/>
        <!-- 自定义解密算法的解密算法，加密后的秘钥（可为空，为空则只有1个参数）、密码串是算法的2个参数  -->
        <config name="decryptedMethod" value="decryptDES"/>
        <!-- 是否支持事务，true为支持，其他值为不支持 -->
        <config name="needTranscation" value="true"/>
        <!-- 复制集名称，可以为空 -->
        <config name="replicaSet" value="lpsa_repl"/>
        <!-- 客户端最大连接数，超过了将会被阻塞，默认100 -->
        <config name="connectionsPerHost" />
        <!-- 客户端最小连接数 -->
        <config name="minConnectionsPerHost" />
        <!-- 可被阻塞的线程数因子，默认值为5，如果connectionsPerHost配置为10， -->
        <!-- 那么最多能阻塞50个线程，超过50个之后就会收到一个异常  -->
        <config name="threadAllowedToBlockForConnectionMultiplier" />
        <!-- 阻塞线程获取连接的最长等待时间，默认120000 ms -->
        <config name="maxWaitTime" />
        <!-- 连接池连接最大空闲时间，默认为0 -->
        <config name="maxConnectionIdleTime" />
        <!-- 连接池连接的最大存活时间，默认为0 -->
        <config name="maxConnectionLifeTime" />
        <!-- 连接超时时间，默认值是0，就是不超时 -->
        <config name="connectTimeout" />
        <!-- 超时时间，默认值是0，就是不超时 -->
        <config name="socketTimeout" />
        <!-- 当没有手动关闭游标时,是否自动释放游标对象。默认为 true。-->
        <config name="cursorFinalizerEnabled" />
        <!-- MongoDB有5种ReadPreference模式 -->
        <!-- primary            主节点，默认模式，读操作只在主节点，如果主节点不可用，报错或者抛出异常。-->
        <!-- primaryPreferred   首选主节点，大多情况下读操作在主节点，如果主节点不可用，如故障转移，读操作在从节点。-->
        <!-- secondary          从节点，读操作只在从节点， 如果从节点不可用，报错或者抛出异常。-->
        <!-- secondaryPreferred 首选从节点，大多情况下读操作在从节点，特殊情况（如单主节点架构）读操作在主节点。-->
        <!-- nearest            最邻近节点，读操作在最邻近的成员，可能是主节点或者从节点-->
        <config name="readPreference" />
    </connection>
    
    <connection name="simple" type="mongo">
        <servers>
            <server ip="10.1.236.121" port="11000" />
            <server ip="10.1.236.121" port="11010" />
            <server ip="10.1.236.121" port="11020" />
        </servers>
        <!-- 复制集名称，可以为空 -->
        <config name="replicaSet" value="lpsa_repl"/>
    </connection>
</connections>