增加 mongodb 整合用例

spring/spring-mongodb-annotation/src/main/java/com/heibaiying/bean/Programmer.java

@@ -0,0 +1,25 @@
+package com.heibaiying.bean;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.Date;
+
+/**
+ * @author : heibaiying
+ * @description :
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class Programmer {
+
+    private String name;
+
+    private int age;
+
+    private float salary;
+
+    private Date birthday;
+}

spring/spring-mongodb-annotation/src/main/java/com/heibaiying/config/MongoConfig.java

@@ -0,0 +1,39 @@
+package com.heibaiying.config;
+
+import com.mongodb.MongoClient;
+import com.mongodb.MongoClientOptions;
+import com.mongodb.ServerAddress;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.mongodb.MongoDbFactory;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.SimpleMongoDbFactory;
+
+/**
+ * @author : heibaiying
+ * @description : Mongo 配置类
+ */
+
+@Configuration
+@ComponentScan(value = "com.heibaiying.*")
+public class MongoConfig {
+
+    @Bean
+    public MongoDbFactory mongoDbFactory(MongoProperty mongo) {
+        MongoClientOptions options = MongoClientOptions.builder()
+                .threadsAllowedToBlockForConnectionMultiplier(mongo.getMultiplier())
+                .connectionsPerHost(mongo.getConnectionsPerHost())
+                .connectTimeout(mongo.getConnectTimeout())
+                .maxWaitTime(mongo.getMaxWaitTime())
+                .socketTimeout(mongo.getSocketTimeout())
+                .build();
+        MongoClient client = new MongoClient(new ServerAddress(mongo.getHost(), mongo.getPort()), options);
+        return new SimpleMongoDbFactory(client, mongo.getDbname());
+    }
+
+    @Bean
+    public MongoTemplate mongoTemplate(MongoDbFactory mongoDbFactory) {
+        return new MongoTemplate(mongoDbFactory);
+    }
+}

spring/spring-mongodb-annotation/src/main/java/com/heibaiying/config/MongoProperty.java

@@ -0,0 +1,35 @@
+package com.heibaiying.config;
+
+import lombok.Data;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.PropertySource;
+
+/**
+ * @author : heibaiying
+ * @description : Mongo 配置属性
+ */
+@Data
+@Configuration
+@PropertySource(value = "classpath:mongodb.properties")
+public class MongoProperty {
+
+    @Value("${mongo.host}")
+    private String host;
+    @Value("${mongo.port}")
+    private int port;
+    @Value("${mongo.dbname}")
+    private String dbname;
+    @Value("${mongo.connectionsPerHost}")
+    private int connectionsPerHost;
+    @Value("${mongo.threadsAllowedToBlockForConnectionMultiplier}")
+    private int multiplier;
+    @Value("${mongo.connectTimeout}")
+    private int connectTimeout;
+    @Value("${mongo.maxWaitTime}")
+    private int maxWaitTime;
+    @Value("${mongo.socketKeepAlive}")
+    private boolean socketKeepAlive;
+    @Value("${mongo.socketTimeout}")
+    private int socketTimeout;
+}

spring/spring-mongodb-annotation/src/main/resources/mongodb.properties

@@ -0,0 +1,17 @@
+mongo.host=192.168.200.228
+mongo.port=27017
+# 数据库名称. 默认是'db'.
+mongo.dbname=database
+# 每个主机允许的连接数
+mongo.connectionsPerHost=10
+# 线程队列数，它和上面connectionsPerHost值相乘的结果就是线程队列最大值。如果连接线程排满了队列就会抛出异常
+mongo.threadsAllowedToBlockForConnectionMultiplier=5
+# 连接超时的毫秒 0是默认值且无限大。
+mongo.connectTimeout=1000
+# 最大等待连接的线程阻塞时间 默认是120000 ms (2 minutes).
+mongo.maxWaitTime=1500
+# 保持活动标志，控制是否有套接字保持活动超时 官方默认为true 且不建议禁用
+mongo.socketKeepAlive=true
+# 用于群集心跳的连接的套接字超时。
+mongo.socketTimeout=1500
+

spring/spring-mongodb-annotation/src/test/java/com/heibaiying/mongo/MongoDBTest.java

@@ -0,0 +1,72 @@
+package com.heibaiying.mongo;
+
+import com.heibaiying.bean.Programmer;
+import com.heibaiying.config.MongoConfig;
+import com.mongodb.client.result.DeleteResult;
+import com.mongodb.client.result.UpdateResult;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringRunner;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+import static org.springframework.data.mongodb.core.query.Criteria.where;
+import static org.springframework.data.mongodb.core.query.Query.query;
+import static org.springframework.data.mongodb.core.query.Update.update;
+
+/**
+ * @author : heibaiying
+ * @description : MongoDB 查询
+ */
+@RunWith(SpringRunner.class)
+@ContextConfiguration(classes = MongoConfig.class)
+public class MongoDBTest {
+
+    @Autowired
+    private MongoTemplate mongoTemplate;
+
+    @Test
+    public void insert() {
+        // 单条插入
+        mongoTemplate.insert(new Programmer("xiaoming", 12, 5000.21f, new Date()));
+        List<Programmer> programmers = new ArrayList<Programmer>();
+        // 批量插入
+        programmers.add(new Programmer("xiaohong", 21, 52200.21f, new Date()));
+        programmers.add(new Programmer("xiaolan", 34, 500.21f, new Date()));
+        mongoTemplate.insert(programmers, Programmer.class);
+    }
+
+    // 条件查询
+    @Test
+    public void select() {
+        Criteria criteria = new Criteria();
+        criteria.andOperator(where("name").is("xiaohong"), where("age").is(21));
+        Query query = new Query(criteria);
+        Programmer one = mongoTemplate.findOne(query, Programmer.class);
+        System.out.println(one);
+    }
+
+
+    // 更新数据
+    @Test
+    public void MUpdate() {
+        UpdateResult updateResult = mongoTemplate.updateMulti(query(where("name").is("xiaoming")), update("age", 35), Programmer.class);
+        System.out.println("更新记录数：" + updateResult.getModifiedCount());
+    }
+
+    // 删除指定数据
+    @Test
+    public void delete() {
+        DeleteResult result = mongoTemplate.remove(query(where("name").is("xiaolan")), Programmer.class);
+        System.out.println("影响记录数：" + result.getDeletedCount());
+        System.out.println("是否成功：" + result.wasAcknowledged());
+    }
+
+}