您好,登录后才能下订单哦!
密码登录
登录注册
点击 登录注册 即表示同意《亿速云用户服务条款》
SpringBoot中怎么对MongoDB 进行增删改查操作,针对这个问题,这篇文章详细介绍了相对应的分析和解答,希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。
引入MongoDB
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.3.2.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.kailo</groupId> <artifactId>kailo-mongodb</artifactId> <version>0.0.1-SNAPSHOT</version> <name>kailo-mongodb</name> <description>MongoDB</description> <properties> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> <exclusions> <exclusion> <groupId>org.junit.vintage</groupId> <artifactId>junit-vintage-engine</artifactId> </exclusion> </exclusions> </dependency> <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-data-mongodb --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-mongodb</artifactId> <version>2.3.2.RELEASE</version> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.61</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
添加配置文件:application.properties
server.port=8080 spring.data.mongodb.uri=mongodb://127.0.0.1:27017/xxx #spring.data.mongodb.host=127.0.0.1 #spring.data.mongodb.port=27017 #spring.data.mongodb.database=xxx # 默认没有账号密码 #spring.data.mongodb.username= #spring.data.mongodb.password=
增删改查代码:ProductController
@Log4j2 @RequestMapping("/product") @RestController public class ProductController { private final ProductRepository productRepository; private final MongoTemplate mongoTemplate; @Autowired public ProductController(ProductRepository productRepository, MongoTemplate mongoTemplate) { this.productRepository = productRepository; this.mongoTemplate = mongoTemplate; } // 增 @PostMapping("save") public ResponseEntity<Result<Product>> save(Product product) { if (!StringUtils.isEmpty(product.get_id())) { return ResultUtils.error(); } productRepository.save(product); return ResultUtils.ok(product); } // 删 单个删除 @GetMapping("deleteById") public ResponseEntity<Result<String>> deleteById(String id) { if (StringUtils.isEmpty(id)) { return ResultUtils.error(); } productRepository.deleteById(id); return ResultUtils.ok(); } // 删 批量删除 @DeleteMapping("deleteByIds") public ResponseEntity<Result<String>> deleteByIds(@RequestBody String[] ids) { if (ids == null) { return ResultUtils.error(); } List<String> idList = Arrays.asList(ids); Iterable<Product> deleteProducts = productRepository.findAllById((Iterable<String>) idList.iterator()); productRepository.deleteAll(deleteProducts); return ResultUtils.ok(); } // 改 单个 @PostMapping("update") public ResponseEntity<Result<Product>> update(Product product) { if (StringUtils.isEmpty(product.get_id())) { return ResultUtils.error(); } product = productRepository.save(product); return ResultUtils.ok(product, "更新成功"); } // 查 查单个 @GetMapping("findById") public ResponseEntity<Result<Product>> findById(String id) { Product product = productRepository.findById(id).get(); return ResultUtils.ok(product); } // 查 查全部列表 @GetMapping("findAll") public ResponseEntity<Result<List<Product>>> findAll() { List<Product> products = productRepository.findAll(); return ResultUtils.ok(products); } // 查 分页查询 @GetMapping("findPage") public ResponseEntity<Result<Pagination<Product>>> findPage(int page, int size) { PageRequest pageRequest = PageRequest.of(page, size, Sort.unsorted()); Page<Product> productPage = productRepository.findAll(pageRequest); log.error(productPage.getClass()); log.error(productPage.getPageable().getClass()); return ResultUtils.ok(Pagination.from(productPage)); } // 查 模糊查询 @GetMapping("findByNameLike") public ResponseEntity<Result<List<Product>>> findByNameLike(String name) { List<Product> products = null; if (StringUtils.isEmpty(name)) { products = productRepository.findAll(); } else { products = productRepository.findByNameLike(name); } return ResultUtils.ok(products); } @GetMapping("findPageByNameMongoTemplate") public ResponseEntity<Result<List<Product>>> findPageByNameMongoTemplate(int page, int size, String name) { Query query = new Query(); query.addCriteria(Criteria.where("name").regex(name)); List<Product> products = mongoTemplate.find(query, Product.class); return ResultUtils.ok(products); } // 查 根据条件过滤 @GetMapping("findPageByNameLike") public ResponseEntity<Result<Pagination<Product>>> findPageByNameLike(int page, int size, String name) { if (StringUtils.isEmpty(name)) { return ResultUtils.error(); } PageRequest pageRequest = PageRequest.of(page, size, Sort.unsorted()); Query query = new Query(); query.addCriteria(Criteria.where("name").regex(name)); List<Product> products = mongoTemplate.find(query, Product.class); long total = mongoTemplate.count(query, Product.class); return ResultUtils.ok(Pagination.build(products, total, pageRequest)); } }
相关代码
@Data @Document(value = "xxx") public class Product implements Serializable { @Id @JSONField(name="_id") // fastjson 会过滤 _ private String _id; @Field private String name; @Field private String user; @Field private Double ccc; }
public interface ProductRepository extends MongoRepository<Product, String> { List<Product> findByNameLike(String name); }
分页相关:不用自带的Page,自定义Pagination,解决序列化和反序列化问题
@Data public class Pagination<T> implements Serializable { private long total; private List<T> content = new ArrayList(); private PaginationRequest pageable; public Pagination() { } public long getTotal() { return this.total; } /** * 根据Page,转化成 Pagination * * @param page * @param <T> * @return */ public static <T> Pagination<T> from(Page<T> page) { if (page == null) { return new Pagination<>(); } return build(page.getContent(), page.getTotalElements(), page.getPageable()); } /** * 根据参数,初始化 Pagination * * @param content * @param totalElements * @param pageable * @param <T> * @return */ public static <T> Pagination<T> build(List<T> content, long totalElements, Pageable pageable) { Pagination<T> pageResult = new Pagination<>(); pageResult.setTotal(totalElements); pageResult.setContent(content); pageResult.setPageable(PaginationRequest.from(pageable)); return pageResult; } public int getTotalPages() { return this.getSize() == 0 ? 1 : (int) Math.ceil((double) this.total / (double) this.getSize()); } public long getTotalElements() { return this.total; } public boolean hasNext() { return this.getNumber() + 1 < this.getTotalPages(); } public int getNumber() { return this.pageable.getPageNumber(); } public int getSize() { return this.pageable.getPageSize(); } public int getNumberOfElements() { return this.content.size(); } public boolean hasPrevious() { return this.getNumber() > 0; } public boolean isFirst() { return !this.hasPrevious(); } public boolean isLast() { return !this.hasNext(); } public PaginationRequest nextPageable() { return this.hasNext() ? this.pageable.next() : null; } public PaginationRequest previousPageable() { return this.hasPrevious() ? this.pageable.previousOrFirst() : null; } public boolean hasContent() { return !this.content.isEmpty(); } public List<T> getContent() { return Collections.unmodifiableList(this.content); } public Iterator<T> iterator() { return this.content.iterator(); } }
@Data public class PaginationRequest implements Serializable { private int page; private int size; public PaginationRequest() {} public PaginationRequest(int page, int size) { this.page = page; this.size = size; } public static PaginationRequest from(Pageable pageable) { Sort sort = pageable.getSort(); return new PaginationRequest(pageable.getPageNumber(), pageable.getPageSize() ); } public PaginationRequest next() { return new PaginationRequest(this.getPageNumber() + 1, this.getPageSize()); } public PaginationRequest previous() { return this.getPageNumber() == 0 ? this : new PaginationRequest(this.getPageNumber() - 1, this.getPageSize()); } public PaginationRequest first() { return new PaginationRequest(0, this.getPageSize()); } public int getPageSize() { return this.size; } public int getPageNumber() { return this.page; } public long getOffset() { return (long)this.page * (long)this.size; } public boolean hasPrevious() { return this.page > 0; } public PaginationRequest previousOrFirst() { return this.hasPrevious() ? this.previous() : this.first(); } }
@Data public class Result<T> implements Serializable { private int code; private String message; private T data; private long timestamp = Date.from(Instant.now()).getTime(); }
@Data public class ResultUtils implements Serializable { public static final int SUCCESS = 200; public static final int NOT_FOUND = 404; public static final int ERROR = 500; public static final String OPT_SUCCESS_LANG = "操作成功"; public static final String OPT_ERROR_LANG = "操作失败"; public static <T> ResponseEntity<Result<T>> ok() { return ok(OPT_SUCCESS_LANG); } public static <T> ResponseEntity<Result<T>> ok(String message) { return ok(null, message); } public static <T> ResponseEntity<Result<T>> ok(T data) { return ok(data, null); } public static <T> ResponseEntity<Result<T>> ok(T data, String message) { Result<T> result = new Result<>(); result.setCode(SUCCESS); result.setMessage(message); result.setData(data); return ResponseEntity.ok(result); } public static <T> ResponseEntity<Result<T>> error() { return ok(OPT_ERROR_LANG); } public static <T> ResponseEntity<Result<T>> error(String message) { return ok(null, message); } public static <T> ResponseEntity<Result<T>> error(T data) { return ok(data, null); } public static <T> ResponseEntity<Result<T>> error(T data, String message) { Result<T> result = new Result<>(); result.setCode(ERROR); result.setMessage(message); result.setData(data); return ResponseEntity.ok(result); } }
关于SpringBoot中怎么对MongoDB 进行增删改查操作问题的解答就分享到这里了,希望以上内容可以对大家有一定的帮助,如果你还有很多疑惑没有解开,可以关注亿速云行业资讯频道了解更多相关知识。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。