mongodb数据库基础 之 mongodb 快速入门大全

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);
}
}