pom文件中加入mongodb依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
配置文件连接mongodb
##端口
server.port=8888
##mongo主机地址
spring.data.mongodb.host=127.0.0.1
##端口号
spring.data.mongodb.port=27017
#数据库名称
spring.data.mongodb.database=test
创建实体类
package com.example.springbootmongodb.bean;
import lombok.Data;
@Data
public class UserInfo {
private Long id;
private String username;
private String password;
}
继承 repository
package com.example.springbootmongodb.repository;
import com.example.springbootmongodb.bean.UserInfo;
import org.springframework.data.mongodb.repository.MongoRepository;
public interface UserRepository extends MongoRepository<UserInfo, Long> {
}
同时可以定义了衍生查询方法,方法功能简明知意。可以直接在方法中调用,不用再实现。
图片.png
MongoRepository封装了包含了操作数据库大部分的功能,阅读源码或查询资料可以进一步了解
写一个controller类实现方法
package com.example.springbootmongodb.controller;
import com.example.springbootmongodb.bean.UserInfo;
import com.example.springbootmongodb.repository.UserRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
@RestController
public class UserController {
@Autowired
private UserRepository userRepository;
@GetMapping("save")
public Object save() {
UserInfo userInfo = new UserInfo();
userInfo.setId(System.currentTimeMillis());
userInfo.setUsername("用户" + System.currentTimeMillis());
userInfo.setPassword("password");
UserInfo save = userRepository.save(userInfo);
return save;
}
@GetMapping("findAll")
public Object findALL() {
List<UserInfo> all = userRepository.findAll();
return all;
}
@GetMapping("deleteById")
public String deleteById(long id) {
userRepository.deleteById(id);
return "success";
}
@GetMapping("count")
public Object count() {
long count = userRepository.count();
return count;
}
@GetMapping("update")
public Object update(Long id,String username,String password){
UserInfo userInfo = new UserInfo();
userInfo.setId(id);
userInfo.setUsername(username);
userInfo.setPassword(password);
UserInfo save = userRepository.save(userInfo);
return save;
}
}
springboot整合mongodb基础curd就整合完成了。
网友评论