springboot 集成mongodb并操作简单增删改查

刺骨的言语ヽ痛彻心扉 2022-04-11 11:55 369阅读 0赞

声明：

运行环境：jdk 1.8、maven3.5.4、spingboot 2.0、mongodb、等

操作步骤：

第一步：pom文件中添加jar包依赖（正常情况下）

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-mongodb</artifactId>
            </dependency>

非正常情况：已经引入log4j2.、jar包时会产生jar包冲突，需要去除logging如下

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-mongodb</artifactId>
                <exclusions>
                    <exclusion>
                        <groupId>org.springframework.boot</groupId>
                        <artifactId>spring-boot-starter-logging</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>

第二步：编写配置文件

此处配置文件为yml文件故为一下格式：

host是你mongodb的地址，如果是本机直接写localhost  port默认 27017  database数据库  username password 看mongodb是否有用户名密码如果没有可以不写

spring:
      data:
        mongodb:
          host: 172.20.94.39
          database: admin
          port: 27017
          username: root
          password: root

第三步：可以直接调用mongodb模板类实现增删改查

示例：运行实现添加功能。更新，查询，删除都可以用 mongoTemplate直接获得方法

import com.mongodb.*;
    import com.mongodb.client.MongoCollection;
    import com.mongodb.client.MongoDatabase;
    import com.mongodb.client.model.InsertOneModel;
    import com.mongodb.client.model.WriteModel;
    import com.rrc.marketing.adsscheduler.AdsMarketingSchedulerApplication;
    import com.rrc.marketing.adsscheduler.utils.MongDBUtil;
    import com.rrc.marketing.core.po.sem.SemAccountInfoEntity;
    import com.rrc.marketing.core.po.sem.SemDownloadTaskEntity;
    import org.apache.commons.lang.StringUtils;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    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.junit4.SpringRunner;
    import tk.mybatis.mapper.entity.Example;
    import javax.annotation.Resource;
    import org.bson.Document;
    import java.security.MessageDigest;
    import java.security.NoSuchAlgorithmException;
    import java.text.SimpleDateFormat;
    import java.util.*;
    import java.util.concurrent.ConcurrentLinkedQueue;
    
    
    @RunWith(SpringRunner.class)
    @SpringBootTest(classes = AdsMarketingSchedulerApplication.class)
    public class SemKeywortReportDataTests {
    
        @Autowired
        private MongoTemplate mongoTemplate;
    
        @Test
        public void testMongodb() {
            SemKeywordReportBaiduEntity semKeywordReportBaiduEntity=new SemKeywordReportBaiduEntity();
            semKeywordReportBaiduEntity.setAccountName("张三");
            semKeywordReportBaiduEntity.setKeyword("关键词1");
            semKeywordReportBaiduEntity.setAccountId(123456L);
            mongoTemplate.save(semKeywordReportBaiduEntity);*/
          
        }
     
         
    }

执行成功的结果：

安装NoSQLBooster for Mongo DB windows可视化工具

安装连接步骤自行搜索百度  
连接上mongodb数据库查看数据内容 根据实体自动创建文档，

注意：如果实体中有Id字段，又想使用mongodb自己生成的md5主键的话，需要把实体中的id参数去除。这样mongodb自己会生成一个\_id 主键，值为不重复的md5字符串。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0FsaWNlX3FpeGlu_size_16_color_FFFFFF_t_70][]

mongodb有，单条数据增加，批量数据增加。单条更新，批量更新，单条删除。批量删除等功能，此处用mongoTemplate可以得到封装好的方法可以直接使用，也可以换一种连接方式

第二种连接方式：直接连接mongodb使用，

同样需要加入上述jar包，然后创建MognDBUtil类，加入连接信息。注意修改ip和库名以及username和password

package com.rrc.marketing.adsscheduler.utils;
    
    import com.mongodb.MongoClient;
    import com.mongodb.MongoCredential;
    import com.mongodb.ServerAddress;
    import com.mongodb.client.MongoDatabase;
    
    import java.util.ArrayList;
    import java.util.List;
    
    //mongodb 连接数据库工具类
    public class MongDBUtil {
        //不通过认证获取连接数据库对象
        public static MongoDatabase getConnect(){
            //连接到 mongodb 服务
            MongoClient mongoClient = new MongoClient("localhost", 27017);
    
            //连接到数据库
            MongoDatabase mongoDatabase = mongoClient.getDatabase("test");
    
            //返回连接数据库对象
            return mongoDatabase;
        }
    
        //需要密码认证方式连接
        public static MongoDatabase getConnect2(){
            List<ServerAddress> adds = new ArrayList<>();
            //ServerAddress()两个参数分别为 服务器地址 和 端口
            ServerAddress serverAddress = new ServerAddress("172.20.94.39", 27017);
            adds.add(serverAddress);
    
            List<MongoCredential> credentials = new ArrayList<>();
            //MongoCredential.createScramSha1Credential()三个参数分别为 用户名 数据库名称 密码
            MongoCredential mongoCredential = MongoCredential.createScramSha1Credential("root", "admin", "root".toCharArray());
            credentials.add(mongoCredential);
    
            //通过连接认证获取MongoDB连接
            MongoClient mongoClient = new MongoClient(adds, credentials);
    
            //连接到数据库
            MongoDatabase mongoDatabase = mongoClient.getDatabase("test");
    
            //返回连接数据库对象
            return mongoDatabase;
        }
    }

创建之后用测试方法测试插入数据

import com.mongodb.*;
    import com.mongodb.client.MongoCollection;
    import com.mongodb.client.MongoDatabase;
    import com.mongodb.client.model.InsertOneModel;
    import com.mongodb.client.model.WriteModel;
    import com.rrc.marketing.adsscheduler.AdsMarketingSchedulerApplication;
    import com.rrc.marketing.adsscheduler.utils.MongDBUtil;
    import com.rrc.marketing.core.po.sem.SemAccountInfoEntity;
    import com.rrc.marketing.core.po.sem.SemDownloadTaskEntity;
    import org.apache.commons.lang.StringUtils;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    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.junit4.SpringRunner;
    import tk.mybatis.mapper.entity.Example;
    import javax.annotation.Resource;
    import org.bson.Document;
    import java.security.MessageDigest;
    import java.security.NoSuchAlgorithmException;
    import java.text.SimpleDateFormat;
    import java.util.*;
    import java.util.concurrent.ConcurrentLinkedQueue;
    
    
    @RunWith(SpringRunner.class)
    @SpringBootTest(classes = AdsMarketingSchedulerApplication.class)
    public class SemKeywortReportDataTests {
    
        @Autowired
        private MongoTemplate mongoTemplate;
    
        @Test
        public void testMongodb() {
            MongoCollection<Document> collection =     MongDBUtil.getConnect2().getCollection("user");
            //创建文档
            Document document = new Document("name","张三")
                    .append("sex", "男")
                    .append("age", 18);
            collection.insertOne(document);
          
        }
     
         
    }

查看插入之后的结果：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0FsaWNlX3FpeGlu_size_16_color_FFFFFF_t_70 1][]

以上就是springboot集成mongodb的简单实例，

感谢观看

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0FsaWNlX3FpeGlu_size_16_color_FFFFFF_t_70]: /images/20220411/6b8199403e7f4cda9b48162c9163f2e1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0FsaWNlX3FpeGlu_size_16_color_FFFFFF_t_70 1]: /images/20220411/144bbd73579a4b3d93817b6a5b12d9b8.png