Spring Boot + MongoDB

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Spring Boot + MongoDB，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含4319字，纯文字阅读大概需要7分钟。

内容图文

项目结构

下面直接进入代码操作

创建一个Springboot项目，pom.xml引入MongoDB依赖

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

接下来配置MongoDB数据源，此处我用的是本地安装的MongoDB，所以没有用户名和密码，有用户名和密码的格式是：  spring.data.mongodb.uri=mongodb://name:pass@localhost:27017/test，其中name是用户名，pass是密码

如果要配置多个数据库，则中间用 "," 分割，例如 spring.data.mongodb.uri=mongodb://192.168.1.1:20000,192.168.1.2:20000,192.168.252.12:20000/test

application.properties：

spring.data.mongodb.uri=mongodb://localhost:27017/mydb

User.class

package com.zyu.entity;

/**
 * @program: SpringBoot-mongo
 * @description:
 * @author: zyu
 * @create: 2019-11-28 16:06
 */
public class User {

    private String id;

    private String name;

    private Integer age;

    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Integer getAge() {
        return age;
    }

    public void setAge(Integer age) {
        this.age = age;
    }

    @Override
    public String toString() {
        final StringBuffer sb = new StringBuffer("User{");
        sb.append("id='").append(id).append('\'');
        sb.append(", name='").append(name).append('\'');
        sb.append(", age=").append(age);
        sb.append('}');
        return sb.toString();
    }
}

UserDao.class

package com.zyu.dao;

import com.zyu.entity.User;
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.data.mongodb.core.query.Update;
import org.springframework.stereotype.Component;

import java.util.List;

/**
 * @program: SpringBoot-mongo
 * @description:
 * @author: zyu
 * @create: 2019-11-29 16:05
 */
@Component
public class UserDao {

    @Autowired
    private MongoTemplate mongoTemplate;


    /**
     * 创建对象
     * @param user
     */
    public User saveUser(User user) {
        User save = mongoTemplate.save(user);
        return save;
    }


    /**
     * 更新对象
     * @param user
     */
    public void updateUser(User user) {
        Query query = new Query(Criteria.where("id").is(user.getId()));
        Update update = new Update().set("name", user.getName()).set("age", user.getAge());
        mongoTemplate.updateFirst(query, update, User.class);
    }


    /**
     * 根据用户名查询对象
     * @param name
     * @return
     */
    public User findUserByName(String name) {
        Query query = new Query(Criteria.where("name").is(name));
        User user = mongoTemplate.findOne(query, User.class);
        return user;
    }


    /**
     * 查询所有对象
     * @return
     */
    public List<User> findUserList() {
        List<User> all = mongoTemplate.findAll(User.class);
        return all;
    }


    /**
     * 删除对象
     * @param id
     */
    public void deleteUserById(String id) {
        Query query = new Query(Criteria.where("id").is(id));
        mongoTemplate.remove(query, User.class);
    }
}

HomeController.class

package com.zyu.controller;

import com.zyu.dao.UserDao;
import com.zyu.entity.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

/**
 * @program: SpringBoot-mongo
 * @description:
 * @author: zyu
 * @create: 2019-11-28 16:08
 */
@RestController
public class HomeController {

    @Autowired
    private UserDao userDao;

    @GetMapping("/findList")
    public List<User> findUserList() {
        List<User> userList = userDao.findUserList();
        return userList;
    }


    @GetMapping("/findByName")
    public User findUserByName(@RequestParam String name) {
        User userByName = userDao.findUserByName(name);
        return userByName;
    }


    @GetMapping("/save")
    public User saveUser(@RequestParam String name, @RequestParam Integer age) {
        User user = new User();
        user.setName(name);
        user.setAge(age);
        return userDao.saveUser(user);
    }


    @GetMapping("/update")
    public String updateUser(@RequestParam String id, @RequestParam String name, @RequestParam Integer age) {
        User user = new User();
        user.setName(name);
        user.setAge(age);
        user.setId(id);
        userDao.updateUser(user);
        return "Success";
    }

}

下面我们启动程序进行测试

1. 新增： http://localhost:8080/save?name=张三&age=20

可以看到新增成功

2. 查询：http://localhost:8080/findList

可以看到数据插入成功

3. 修改：http://localhost:8080/update?name=张三&age=22&id=5de0dbee2a21b94db4fc367b

其他接口大家自己去测试吧

内容总结

以上是互联网集市为您收集整理的Spring Boot + MongoDB全部内容，希望文章能够帮你解决Spring Boot + MongoDB所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端