mongoDB数据库原生配置

Posted 2022-08-06 qinyuanyuan

最近小冷在工作中使用到了mongoDB数据库，所以就简单的写了个demo，和大家简单分享下，如果大家也有想分享的东西或者需要分享的东西，生活或者其他都行，可以关注小冷公众号秦川以北或者加小冷微信qxy5288分享你的故事。。。?

 

废话不说开始搞：

 

MongoDB简单介绍：

MongoDB是一个基于分布式文件存储的数据库。由C++语言编写。旨在为WEB应用提供可扩展的高性能数据存储解决方案。

MongoDB是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库的。它支持的数据结构非常松散，是类似json的bson格式，因此可以存储比较复杂的数据类型。Mongo最大的特点是它支持的查询语言非常强大，其语法有点类似于面向对象的查询语言，几乎可以实现类似关系数据库单表查询的绝大部分功能，而且还支持对数据建立索引。

 

springboot中的其中一种连接和使用方式：

 

1. 需要导入的maven坐标

<!-- mongoDB数据库驱动-->
<dependency>
    <groupId>org.mongodb</groupId>
    <artifactId>mongo-java-driver</artifactId>
    <version>3.0.4</version>
</dependency>

 

2.封装mongoDBUtil工具类

 1 //不通过认证获取连接数据库对象
 2     public static MongoCollection<Document> getConnect()
 3         //连接到 mongodb 服务
 4         MongoClient mongoClient = new MongoClient("ip", 27017);
 5 ?
 6         //连接到数据库
 7         MongoDatabase mongoDatabase = mongoClient.getDatabase("数据库名称");
 8 ?
 9         //连接数据库表
10         MongoCollection<Document> personalData = mongoDatabase.getCollection("表名称");
11 ?
12         //返回连接数据库表对象
13         return personalData;
14     
15 ?
16     //需要密码认证方式连接
17     public static MongoCollection<Document> getConnect2()
18         List<ServerAddress> adds = new ArrayList<>();
19         //ServerAddress()两个参数分别为 服务器地址 和 端口
20         ServerAddress serverAddress = new ServerAddress("localhost", 27017);
21         adds.add(serverAddress);
22 ?
23         List<MongoCredential> credentials = new ArrayList<>();
24         //MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码
25         MongoCredential mongoCredential = MongoCredential.createScramSha1Credential("username", "databaseName", "password".toCharArray());
26         credentials.add(mongoCredential);
27 ?
28         //通过连接认证获取MongoDB连接
29         MongoClient mongoClient = new MongoClient(adds, credentials);
30 ?
31         //连接到数据库
32         MongoDatabase mongoDatabase = mongoClient.getDatabase("test");
33 ?
34         //连接数据库表
35         MongoCollection<Document> personalData = mongoDatabase.getCollection("表名");
36 ?
37         //返回连接数据库对象
38         return personalData;
39     

测试类

 1  @Test
 2     public void deom01()
 3         MongoCollection<Document> connect = MongoDBUtil.getConnect();
 4 ?
 5         JSONObject json = new JSONObject();
 6         json.put("111","hasidffhasedfhed");
 7         json.put("222","hasidffhasedfhed");
 8         json.put("333","hasidffhasedfhed");
 9         json.put("444","hasidffhasedfhed");
10         json.put("5555","hasidffhasedfhed");
11         Document json1 = new Document(json);
12         connect.insertOne(json1);
13     

 

?

大家可以关注我的公众号秦川以北后续有更多精彩实用内容分享谢谢！