UserServiceImpl.java

package com.krunal.mongodb.service;

import com.krunal.mongodb.model.User;
import com.krunal.mongodb.repository.UserRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import reactor.core.publisher.Flux;

import java.util.List;

@Service
public class UserServiceImpl implements UserService {

    @Autowired
    UserRepository userRepository;

    //save the user
    public User createUser(User user) {
        return userRepository.save(user);
    }

    //retrive the user
    public List<User> getAll() {
        Flux<List<User>> userFlux = Flux.just(userRepository.findAll());
        return userRepository.findAll();
    }

    //get user
    public User findByFirstName(String firstName) {
        return userRepository.findByFirstName(firstName);
    }

    //update user
    public User updateUser(User user) {
        return userRepository.save(user);
    }

    //delete user
    public void deleteUser(String id) {
        userRepository.deleteById(id);
    }

    //delete all user
    public void deleteAll() {
        userRepository.deleteAll();
    }
}