Spring与MongoDB

左手的ㄟ右手 2022-07-13 10:45 125阅读 0赞

## 1、MongoDB的配置 ##

spring.xml文件：

<bean id="mongoOptions" class="com.mongodb.MongoOptions">
    		<property name="connectionsPerHost" value="40"/>
    		<property name="threadsAllowedToBlockForConnectionMultiplier"
    				  value="2000"/>
    		<property name="autoConnectRetry" value="true"/>
    		<property name="connectTimeout" value="20000"/>
    	</bean>
    	<bean id="serverAddress" class="com.mongodb.ServerAddress">
    		<constructor-arg name="host" value="${mongodb.address}"/>
    		<constructor-arg name="port" value="${mongodb.port}"/>
    	</bean>
    	<bean id="mongo" class="com.mongodb.Mongo">
    		<constructor-arg name="addr" ref="serverAddress"/>
    		<constructor-arg name="options" ref="mongoOptions"/>
    	</bean>
    	<bean id="writeConcern" class="com.mongodb.WriteConcern">
    		<constructor-arg name="w" type="int" value="1"/>
    	</bean>
    	<bean id="mongoTemplate" class="org.springframework.data.mongodb.core.MongoTemplate">
    		<constructor-arg name="mongo" ref="mongo"/>
    		<constructor-arg name="databaseName" value="${mongodb.dbname}"/>
    		<property name="writeConcern" ref="writeConcern"/>
    	</bean>

application.properties文件：

#mongodb config
    mongodb.address=127.0.0.1
    mongodb.port=27017
    mongodb.dbname=test

## 2、Java操作MongoDB查询 ##

### 2.1.1测试数据 ###

/* 0 */
    {
      "_id" : 1,
      "item" : "journal",
      "qty" : "201",
      "type" : "Book",
      "age" : 2017010115,
      "date" : ISODate("2017-01-01T15:00:00Z")
    }
    
    /* 1 */
    {
      "_id" : 2,
      "item" : "journal",
      "qty" : "201",
      "type" : "Book",
      "age" : 2017010116,
      "date" : ISODate("2017-01-01T16:00:00Z")
    }
    
    /* 2 */
    {
      "_id" : 3,
      "item" : "journal",
      "qty" : "201",
      "type" : "Book",
      "age" : 2017010117,
      "date" : ISODate("2017-01-01T17:00:00Z")
    }
    
    /* 3 */
    {
      "_id" : 4,
      "item" : "journal",
      "qty" : "201",
      "type" : "Book",
      "age" : 2017010815,
      "date" : ISODate("2017-01-08T15:00:00Z")
    }
    
    /* 4 */
    {
      "_id" : 5,
      "item" : "journal",
      "qty" : "201",
      "type" : "Book",
      "age" : 2017010816,
      "date" : ISODate("2017-01-08T16:00:00Z")
    }

### 2.1.2测试代码 ###

@RunWith(SpringJUnit4ClassRunner.class) // 指定测试用例的运行器 这里是指定了Junit4
    @ContextConfiguration({"/spring/applicationContext_junit.xml"})
    public class MongoDBServiceImplTest {
        private static Logger logger = LoggerFactory.getLogger(MongoDBServiceImplTest.class);
        @Autowired
        private MongoTemplate mongoTemplate;
    
        private BasicDBObject fieldObject = null;
        private BasicDBObject queryObject = new BasicDBObject();
        private Query query = new BasicQuery(queryObject, fieldObject);
        private Criteria criteria = new Criteria();
    
        @Before
        public void before() throws Exception {
            fieldObject = new BasicDBObject();
            fieldObject.put("type", true);
            fieldObject.put("item", true);
            fieldObject.put("qty", true);
            fieldObject.put("age", true);
        }
    
        /**
         * $gt：>
         * $gte：>=
         * $eq: =
         * $ne: !=
         * $lt: <
         * $lte: <=
         * $in: in(后面的值为bson对象数组)
         * $nin:not in(后面的值为bson对象数组)
         */
        @Test
        public void testFind() {
    
            //与查询  比较字段值的查询  age>24 and type="misc"
            /*BasicDBObject gt = new BasicDBObject("$gt",24);
            queryObject.put("age",gt);
            queryObject.put("type","misc");*/
    
            // or查询  qty="15" or qty="201"
            //第一种方式
            /*BasicDBList values = new BasicDBList();
            values.add(new BasicDBObject("qty","15"));
            values.add(new BasicDBObject("qty","201"));
            queryObject.put("$or", values);*/
            //第二种方式 age>26 or age<24
            /*BasicDBList values = new BasicDBList();
            values.add(new BasicDBObject("age", new BasicDBObject("$gt", 26)));
            values.add(new BasicDBObject("age", new BasicDBObject("$lt", 24)));
            queryObject.put("$or", values);*/
            //第三种方式  qty=15 or age<=24
            /*BasicDBList values = new BasicDBList();
            values.add(new BasicDBObject("qty","15"));
            values.add(new BasicDBObject("age", new BasicDBObject("$lte", 24)));
            queryObject.put("$or", values);*/
    
    
            //in 查询  age in (24,241)
            /*BasicDBList values = new BasicDBList();
            values.add(24);
            values.add(241);
            queryObject.put("age", new BasicDBObject("$in", values));*/
    
            query = new BasicQuery(queryObject, fieldObject);
        }
    
        /**
         * 分页查询并按指定字段排序
         */
        @Test
        public void testFindPage() {
    
            query = new BasicQuery(new BasicDBObject(), fieldObject);
            query.with(new Sort(Sort.Direction.ASC, "type"));
            query.with(new PageRequest(0, 2));
        }
    
        //查询所有
        @Test
        public void testFindAll() {
    
            query = new BasicQuery(new BasicDBObject(), fieldObject);
        }
    
        @Test
        public void testCriteria() {
    
            /** 区分大小写。
             * 例如输入Bo;可以查到Book
             */
            //criteria.orOperator(Criteria.where("type").regex(".*?" + "Bo" + ".*"));
            /** 不区分大小写。
             * 例如输入oO;可以查到book
             */
            //criteria.orOperator(Criteria.where("type").regex(".*?" + "oO" + ".*" + "$", "i"));
            /**
             * bo*O
             * 不区分大小写的查询实现
             * 开头结尾匹配bo*o
             */
            //criteria.orOperator(Criteria.where("type").regex("^" + "bo*O".replace("*",".*") + "$", "i"));
            /**
             * name字段必须存在且不区分大小写的查询实现
             * exists(false)name字段必须不存在
             * 开头结尾匹配bo*o
             */
            //criteria.andOperator(Criteria.where("name").exists(true).andOperator(Criteria.where("type").regex(".*?" + "Bo" + ".*" + "$", "i")));
            /**
             * 不区分大小写的查询实现
             * qty字段类型为Double的对照表见：https://docs.mongodb.com/manual/reference/operator/query/type/
             * 开头结尾匹配bo*o
             */
            criteria.andOperator(Criteria.where("type").regex(".*?" + "Bo" + ".*" + "$", "i").andOperator(
                    Criteria.where("qty").type(1)));
            query = new Query(criteria);
    
        }
    
        @Test
        public void testDate() {
    
            Date after = DateTimeUtil.strToDate(DateTimeUtil.toDateStr(DateTimeUtil.getAddDays(new Date(), 4)), "yyyy-MM-dd");
            Date before = DateTimeUtil.strToDate(DateTimeUtil.toDateStr(DateTimeUtil.getAddDays(new Date(), -3)), "yyyy-MM-dd");
            criteria = Criteria.where("date").gte(before).lt(after);
            logger.info(FastJsonUtil.obj2jsonDateFormat(before + "-----------" + after));
            query.addCriteria(criteria);
            query.with(new Sort(Sort.Direction.ASC, "age"));
    
        }
    
        @After
        public void after() {
            List<MongoDBTest> mongoDBTest = mongoTemplate.find(query, MongoDBTest.class, "inventory");
            logger.info("--------------------------");
            logger.info(FastJsonUtil.obj2jsonDateFormat(mongoDBTest));
        }
    
    }

[mongodb工具][mongodb]

[mongodb]: http://download.csdn.net/detail/a491857321/9730111