java-spring与mongodb的整合方式一 自动注入xml（5）

look_w

相关配置文件xml:

common-beans.xml   可更改操作的数据库名称 目前为student 和 链接地址 192.168.0.121

    <?xml version="1.0" encoding="utf-8"?>
    <!-- 指定Spring配置文件的Schema信息 -->
    <beans xmlns="http://www.springframework.org/schema/beans"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
        xmlns:p="http://www.springframework.org/schema/p" xmlns:tx="http://www.springframework.org/schema/tx"
        xmlns:mongo="http://www.springframework.org/schema/data/mongo"
        xmlns:context="http://www.springframework.org/schema/context"
        xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
        http://www.springframework.org/schema/tx
        http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
        http://www.springframework.org/schema/context
        http://www.springframework.org/s ... ing-context-3.1.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop-3.1.xsd">
     
        <bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
            <constructor-arg name="mongo" ref="mongo" />
            <constructor-arg name="databaseName" value="student"/>
        </bean>
        <bean id="mongo" class="org.springframework.data.mongodb.core.MongoFactoryBean">
            <property name="host" value="192.168.0.121"/>
            <property name="port" value="27017"/>
        </bean>
    </beans>


info-reposity.xml

    <?xml version="1.0" encoding="GBK"?>
    <!-- 指定Spring配置文件的Schema信息 -->
    <beans xmlns="http://www.springframework.org/schema/beans"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
        xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">
        <!-- 配置DAO组件的模板 -->
        <bean id="genericReposity" class="com.mongo.reposity.Impl.GenericReposityImpl"
            parent="mongoTemplate">
        </bean>   
        <bean id="userReposity" class="com.mongo.reposity.Impl.UserReposityImpl"
            parent="mongoTemplate">
        </bean>
    </beans>



getDateAcition.java

    package com.mongo.action;
     
    import java.util.Map;
     
    import net.sf.json.JSONObject;
    import net.sf.json.JsonConfig;
    import net.sf.json.util.CycleDetectionStrategy;
     
    import org.springframework.data.mongodb.core.MongoOperations;
    import org.springframework.data.mongodb.core.MongoTemplate;
    import org.springframework.data.mongodb.core.mapreduce.MapReduceOptions;
    import org.springframework.data.mongodb.core.mapreduce.MapReduceResults;
     
    import com.mongo.entity.User;
    import com.mongo.reposity.UserReposity;
    import com.mongodb.DBCollection;
    import com.mongodb.DBCursor;
    import com.mongodb.MapReduceOutput;
    import com.opensymphony.xwork2.ActionSupport;
     
    public class getDataAction extends ActionSupport {
        /**
         *
         */
        private UserReposity userReposity;
     
        public void setUserReposity(UserReposity userReposity) {
            this.userReposity = userReposity;
        }
     
        private JSONObject user;
     
        private static final long serialVersionUID = 535742118015700220L;
     
        @Override
        public String execute() {
            JsonConfig jsonConfig = new JsonConfig();
            jsonConfig.setIgnoreDefaultExcludes(false);
            // jsonConfig.setExcludes(new String[] { "name" });
            jsonConfig.setCycleDetectionStrategy(CycleDetectionStrategy.LENIENT);
     
            // 新增数据
            // User u=new User();
            // u.setName("zoe");
            // u.setMessage("first blood");
            // userReposity.saveObject(u);
            // System.out.println("写入完成"+u.toString());
     
            // //查询数据
            // //获取全部
            // List<User> us=userReposity.getAllObjects(User.class);
            // //从数目上查询取0到1000
            // List<User> us1=userReposity.getUsers(0, 1000);
            // //条件查询
            // List<Condition> cds=new ArrayList<Condition>();
            // Condition cd=new Condition();
            // cd.setKey("name");
            // cd.setValue("zoe");
            // cds.add(cd);
            // List<User> us2=userReposity.getUsers(0, 1000, cds);
            // //模糊查询
            // List<User> us3=userReposity.getUsers("oe");
            // //查询数量
            // long count=userReposity.getCount("first blood");
            // //查询属于的集合(in) 不属于(nin)
            // List<String> names=new ArrayList<String>();
            // names.add("zoe");
            // names.add("koe");
            // List<User> us4=userReposity.getUsersBynames(0, 1000,names);
            //
            // //更新
            // User u=userReposity.getAllObjects(User.class).get(0);
            // userReposity.updateUserUpdateName(u, "joe");
            //
            // //删除
            // userReposity.deleteObject(User.class, "534cea00cf20ab0525bdc53e");
     
            // mapreduce
            MongoTemplate m =  (MongoTemplate) userReposity;
            DBCollection coll =  m.getCollection("user"); //集合名
            String map = "function() { emit(this.name, {count:1});}";  
            String reduce = "function(key, values) {var total = 0;for(var i=0;i<values.length;i++){total += values.count;}return {count:total};}";  
            String result = "resultCollection";  
            MapReduceOutput mapReduceOutput = coll.mapReduce(map,  
                reduce.toString(), result, null);  
            DBCollection resultColl = mapReduceOutput.getOutputCollection();  
            DBCursor cursor = resultColl.find();  
            while (cursor.hasNext()) {
                   System.out.println(cursor.next());
    //            Map object = cursor.next().toMap();
    //            System.out.println(object.get("value"));
            }  
    //        MongoOperations mongoOps = (MongoOperations) userReposity;
    //        String map = "function() { emit(this.name, {count:1});}";
    //        String reduce = "function(key, values) {var total = 0;for(var i=0;i<values.length;i++){total += values.count;}return {count:total};}";
    //        try {
    //            MapReduceResults<User> results = mongoOps.mapReduce("requesterBill",
    //                    map,
    //                    reduce,
    ////                    new MapReduceOptions().outputCollection("mr_out"),
    //                    User.class);
    //            for (User valueObject : results) {
    //                System.out.println(valueObject);
    //            }
    //        } catch (Exception e) {
    //            e.printStackTrace();
    //        }
     
        
            // String jsonfacility =
            // "{\"id\":\"PublicSecurity\",\"name\":\"数据\",\"value\":\"123\"}";
            // user = JSONObject.fromObject(jsonfacility);
    //        userReposity.mapReduse();
            return SUCCESS;
        }
     
        public JSONObject getUser() {
            return user;
        }
     
        public void setUser(JSONObject user) {
            this.user = user;
        }
     
    }