Springboot配置MongoDB连接

卡地亚的生活 發表於 2019-7-16 11:39:00

之前有个项目，用的是Springboot框架，对接的数据库是mongodb，当时花了一些时间去做这个配置MongoDB的连接，现在把这个过程记录下来，以免遗忘。
一、在pom中添加依赖。
<table style="width: 1085px; height: 106px" border="0">
<tbody>
<tr>
<td>
<pre> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-mongodb</artifactId> <version>1.5.9.RELEASE</version> </dependency></pre>
</td>
</tr>
</tbody>
</table>
二、配置数据源
　　在项目中，使用的配置文件是yaml格式的，所以配置信息如下:
<table style="width: 1089px; height: 101px" border="0">
<tbody>
<tr>
<td>
<pre>spring: 　　data: 　　mongodb: 　　uri: mongodb://地址 </pre>
</td>
</tr>
</tbody>
</table>
 
　　如果使用的是properties格式的话，配置信息则是;
<table style="width: 1102px; height: 22px" border="0">
<tbody>
<tr>
<td>
<pre>spring.data.mongodb.uri= mongodb://地址</pre>
</td>
</tr>
</tbody>
</table>
三、在实体中添加注解
　　在实体添加@Document注解，collection= "对应的表名"。
　　在属性上添加@Filed注解，值为对应的字段名。
<table style="width: 1094px; height: 334px" border="0">
<tbody>
<tr>
<td>
<pre>@Getter @Setter @Document(collection = "User") public class User { /* 用户id： */ 　　@Field("id") private String id; /* 用户名 */ @Field("UserName") private String userName; /* 性别 */ @Field("sex") private String sex; }</pre>
</td>
</tr>
</tbody>
</table>
 
四、在业务层使用MongoDb的方法:
<table style="width: 1093px; height: 22px" border="0">
<tbody>
<tr>
<td>
@Service public class UserServiceImpl implements UserService {     @Resource     private MongoTemplate mongoTemplate;     @Override     public long getCount() {         Query query = new Query();         long count = mongoTemplate.count(query,User.class);         return count;     }
}

</td>

</tr>

</tbody>

</table>
 
五、MongoTemplate常使用的方法
　　1.插入
<table style="width: 1111px; height: 22px" border="0">
<tbody>
<tr>
<td>
<pre name="code" class="prettyprint"><code class="hljs javascript has-numbering"> mongoTemplate.insert(Object);</code></pre>
</td>
</tr>
</tbody>
</table>
　　2.删除
<table style="width: 1109px; height: 22px" border="0">
<tbody>
<tr>
<td>
<pre name="code" class="prettyprint"><code class="hljs vbnet has-numbering"> Query query=new Query(Criteria.where("_id").is(id));
mongoTemplate.remove(query,AutomaticAlarm.class); </code></pre>
</td>
</tr>
</tbody>
</table>
　   3. 修改
<table style="width: 1109px; height: 22px" border="0">
<tbody>
<tr>
<td>
　　Query query=new Query(Criteria.where("_id").is(id));
　　Update update = Update.update("要更新的字段", "更新的值");
　　mongoTemplate.updateFirst(query, update, Object.class); 

</td>

</tr>

</tbody>

</table>
　　4.查询
<table style="width: 1110px; height: 452px" border="0">
<tbody>
<tr>
<td>1.查找所有 　　mongoTemplate.findAll(Object.class); 2.条件查询（具体某个字段的值） 　　Query query=new Query(Criteria.where("字段1").is("值1")); 　　mongoTemplate.find(query, Object.class); 3.条件查询（大于小于） 　　Criteria criteria = Criteria.where("字段").gte(某个值).lte(某个值); 　  Query query = new Query(criteria); 　　mongoTemplate.find(query, Object.class); 4.模糊查询 　　Pattern pattern = Pattern.compile("^.*" + searchKey + ".*$");//这里时使用的是正则匹配,searchKey是关键字，接口传参，也可以自己定义。     Criteria criteria = Criteria.where("_id").regex(pattern); 　  mongoTemplate.find(query, Object.class);　 5.分页查询     Query query = new Query();     query.skip("跳过的数据条数").limit("一页的数据条数");     mongoTemplate.find(query, Object.class);      6.聚合查询     Aggregation aggregation1 = Aggregation.newAggregation(Aggregation.group("sex").count().as("peopleCount"));//这里的聚合条件由自己定义     AggregationResults<BasicDBObject> outputTypeCount1 = mongoTemplate.aggregate(aggregation1, "User", BasicDBObject.class);//取出的结果需要自行进行处理，比如可以用getMappedResults来转换</td>

</tr>

</tbody>

</table>
六、增强配置
　　　　如果我们在项目中需要管理MongoDB的最大连接时长、socket保持活跃、最大等待时长等，那么我们在pom文件中需要引入一个增强管理包。
<table style="width: 1113px; height: 102px" border="0">
<tbody>
<tr>
<td>
<pre> <dependency> <groupId>com.spring4all</groupId> <artifactId>mongodb-plus-spring-boot-starter</artifactId> <version>1.0.0.RELEASE</version> </dependency></pre>
</td>
</tr>
</tbody>
</table>
　　　　同时在项目启动类SpringBootMainApplication上添加一个注解@EnableMongoPlus。
　　　　我们就可以在配置文件中添加这些配置了。
<table style="width: 1115px" border="0">
<tbody>
<tr>
<td>
<pre>spring: data: mongodb: uri: mongodb://地址 option: socket-keep-alive: true max-connection-idle-time: 60000 # connect-timeout: 36000 # min-connection-per-host: 5 # threads-allowed-to-block-for-connection-multiplier: 5 # max-wait-time: 120000 # socket-timeout: 0 # max-connection-life-time: 0 # heartbeat-socket-timeout: 36000 # heartbeat-connect-timeout: 36000 # min-heartbeat-frequency: 5 # heartbeat-frequency: 10</pre>
</td>
</tr>
</tbody>
</table>
　　 
来源：https://www.cnblogs.com/kylne/p/11193878.html

頁: [1]

琼殿技术论坛's Archiver

Springboot配置MongoDB连接