mongodb三分钟入门大全

<? xml version = "1.0" encoding = "UTF-8" ?>

< project xmlns = "http://maven.apache.org/POM/4.0.0"

          xmlns:xsi = "http://HdhCmsTestw3.org/2001/XMLSchema-instance"

          xsi:schemaLocation = "http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" >

     < modelVersion >4.0.0</ modelVersion >

     < groupId >org.example</ groupId >

     < artifactId >MongoDBProject</ artifactId >

     < version >1.0-SNAPSHOT</ version >

     < parent >

         < groupId >org.springframework.boot</ groupId >

         < artifactId >spring-boot-starter-parent</ artifactId >

         < version >2.2.4.RELEASE</ version >

         < relativePath />

     </ parent >

     < dependencies >

         < 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 >

         </ dependency >

         < dependency >

             < groupId >org.springframework.boot</ groupId >

             < artifactId >spring-boot-starter-data-mongodb</ artifactId >

         </ dependency >

     </ dependencies >

</ project >

package com.guor;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.boot.builder.SpringApplicationBuilder;

import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;

@SpringBootApplication

public class Application extends SpringBootServletInitializer {

     @Override

     protected SpringApplicationBuilder configure(SpringApplicationBuilder builder) {

         return builder.sources(Application. class );

     }

     public static void main(String[] args) {

         SpringApplication.run(Application. class , args);

     }

}

package com.guor;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.boot.builder.SpringApplicationBuilder;

import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;

@SpringBootApplication

public class Application extends SpringBootServletInitializer {

     @Override

     protected SpringApplicationBuilder configure(SpringApplicationBuilder builder) {

         return builder.sources(Application. class );

     }

     public static void main(String[] args) {

         SpringApplication.run(Application. class , args);

     }

} package com.guor.bean;

import org.springframework.data.annotation.Id;

import java.io.Serializable;

public class User implements Serializable {

     @Id

     private String id; //主键

     //该属性对应mongodb的字段的名字，如果一致，则无需该注解

     private String name;

     private Integer age;

     private String phone;

     private String parentid; //上级ID

     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;

     }

     public String getPhone() {

         return phone;

     }

     public void setPhone(String phone) {

         this .phone = phone;

     }

     public String getParentid() {

         return parentid;

     }

     public void setParentid(String parentid) {

         this .parentid = parentid;

     }

     @Override

     public String toString() {

         return "User{" +

                 "id='" + id + '\ '' +

                 ", name='" + name + '\ '' +

                 ", age=" + age +

                 ", phone='" + phone + '\ '' +

                 ", parentid='" + parentid + '\ '' +

                 '}' ;

     }

}

package com.guor.dao;

import com.guor.bean.User;

import org.springframework.data.domain.Page;

import org.springframework.data.domain.Pageable;

import org.springframework.data.mongodb.repository.MongoRepository;

public interface UserRepository extends MongoRepository<User,String> {

     Page<User> getPageByid(String parentId, Pageable pageable);

}

package com.guor.service;

import com.guor.bean.User;

import com.guor.dao.UserRepository;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.data.domain.Page;

import org.springframework.data.domain.PageRequest;

import org.springframework.stereotype.Service;

import java.util.List;

@Service

public class UserService {

     @Autowired

     private UserRepository userRepository;

     public void insertUser(User user){

         userRepository.save(user);

     }

     public void updateUser(User user){

         userRepository.save(user);

     }

     public void deleteUserById(String id){

         userRepository.deleteById(id);

     }

     public List<User> getAllUser(){

         return userRepository.findAll();

     }

     /**

      * 根据id查询评论

      */

     public User getUserById(String id){

         return userRepository.findById(id).get();

     }

     /**

     * 分页

     */

     public Page<User> getPageByid(String parentId, int page , int size){

         return userRepository.getPageByid(parentId, PageRequest.of(page- 1 ,size));

     }

}

package com.guor;

import com.guor.bean.User;

import com.guor.service.UserService;

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.domain.Page;

import org.springframework.test.context.junit4.SpringRunner;

import java.util.List;

@RunWith (SpringRunner. class )

@SpringBootTest (classes = Application. class )

public class MongoDBTest {

     @Autowired

     private UserService userService;

     @Test

     public void saveUser(){

         User user= new User();

         user.setName( "比比东" );

         user.setAge( 22 );

         user.setPhone( "1314" );

         userService.insertUser(user);

     }

     @Test

     public void getUser(){

         List<User> list = userService.getAllUser();

         for (User user : list){

             System.out.println(user);

         }

     }

     @Test

     public void updateUser(){

         User user= new User();

         user.setId( "61e3d9ac57b3da05fd0fffed" );

         user.setName( "云韵" );

         user.setAge( 29 );

         user.setPhone( "18525351592" );

         user.setParentid( "1" );

         userService.updateUser(user);

     }

     @Test

     public void getUserPage(){

         Page<User> pageResponse = userService.getPageByid( "1" , 1 , 2 );

         System.out.println( "----总记录数：" +pageResponse.getTotalElements());

         System.out.println( "----当前页数据：" +pageResponse.getContent());

     }

     @Test

     public void deleteUser(){

         String id = "61e3daf31faa1f5b0e6849f8" ;

         userService.deleteUserById(id);

     }

}