Spring Boot集成MongoDB

1.引入依赖

	 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-mongodb</artifactId></dependency>

2.配置application.yml

server:port: 8888
spring:application:name: dmeo-appdata:mongodb:#host: localhost#port: 27017uri:  mongodb://root:123456@localhost:27017 # mongodb的连接地址与端口database: dmeo # mongodb的连接的数据库      

3.创建User文档对象

@Document:标识映射到Mongodb文档上的领域对象, 即表明这是一个文档对象，名称为user，对应Mongo DB里的user表@Id:标示某个域为ID域, 即标注主键字段, String类型的主键值在插入的时候Mongo DB会自动生成@Indexed:标示某个字段为Mongodb的索引字段@Transient: 如果对象中的某个属性为非表字段 ,使用注解@Transient进行排除

@Data
@Document(collection = "user")
public class User {@Idprivate String uid;@Indexedprivate String name;private Integer age;private String address;
}

4.创建UserRepository接口

创建Dao接口，继承MongoRepository并指定泛型分别为实体类型和主键类型。

在MongoRepository中定义了很多现成的方法，可以更方便的使用。

5.多条件查询

UserRepository通过继承MongoRepository已经具有了JPA的特性，可以通过方法名来构建多查询条件的SQL。

Spring Data mongodb也提供了自定义方法的规则，按照findByXXX，findByXXXAndYYY、countByXXXAndYYY等规则定义方法，实现查询操作。

/*** @Author: CJ* @Description:**/
public interface UserRepository extends MongoRepository<User,String> {/*** 根据名字查询* @param name* @return*/User findByName(String name);/*** 根据姓名和年龄查询* @param name* @param age* @return*/User findByNameAndAge(String name,Integer age);/*** 根据姓名和年龄查询记录数* @param name* @param age* @return*/int countByNameAndAge(String name,Integer age);/*** 根据名字和地址分页查询* @param name* @param address* @param pageable* @return*/Page<User> findByNameAndAddress(String name, String address, Pageable pageable);
}

6.编写测试类

@SpringBootTest
@RunWith(SpringRunner.class)
public class UserRepositoryTest {@Autowiredprivate UserRepository userRepository;@Testpublic void testFindAll() {//分页从0开始int page = 0;int size = 10;Pageable pageable = PageRequest.of(page, size);Page<User> all = userRepository.findAll(pageable);System.out.println(all);}@Testpublic void testSave() {User user = new User();user.setName("lisi");user.setAddress("China");user.setAge(12);userRepository.save(user);System.out.println(user);}@Testpublic void testDelete() {userRepository.deleteById("5fce3a0728df2033145874fc");}@Testpublic void testUpdate() {Optional<User> optional = userRepository.findById("5fce3a0728df2033145874fc");if (optional.isPresent()) {User user = optional.get();user.setAge(22);userRepository.save(user);}}@Testpublic void testFindByName() {User user = userRepository.findByName("lisi");System.out.println(user);}@Testpublic void testCountByNameAndAge() {int count = userRepository.countByNameAndAge("lisi", 12);System.out.println(count);}@Testpublic void testExample() {//设置条件值User user= new User ();user.setAge(22);user.setAddress("China");//条件匹配器ExampleMatcher exampleMatcher = ExampleMatcher.matching();//ExampleMatcher.GenericPropertyMatchers.contains() 包含关键字,即模糊查询exampleMatcher = exampleMatcher.withMatcher("address",ExampleMatcher.GenericPropertyMatchers.contains());//创建条件实例Example<User> example = Example.of(user, exampleMatcher);//分页对象Pageable pageable = new PageRequest(0, 10);//分页查询Page<User> UserList = UserRepository.findAll(example, pageable);System.out.println(UserList);}@Autowiredprivate MongoTemplate template;@Testpublic void test() {Query query = new Query();Criteria criteria = new Criteria();criteria.and("name").is("小白");//模糊查询criteria.and("address").regex("四川");query.addCriteria(criteria);// 使用age字段降序排序Sort sort = Sort.by(Sort.Direction.DESC, "age");// size表示每页显示的条数，page表示当前页码数，0表示第一页Pageable pageable = PageRequest.of(1, 2, sort);List<User> users = template.find(query.with(pageable), User.class);Page<User> page = PageableExecutionUtils.getPage(users, pageable, () -> template.count(query, User.class));List<User> content = page.getContent();System.out.println(content);}
}

7.配置启动类

@SpringBootApplication
@EntityScan("cn.ybzy.model")
public class Application {public static void main(String[] args) {SpringApplication.run(Application .class, args);}
}

8.GridFS的使用

GridFS是MongoDB提供的用于持久化存储文件的模块。它的工作原理是：

GridFS存储文件是将文件分块存储，文件会按照256KB的大小分割成多个块进行存储，GridFS使用两个集合（collection）存储文件，一个集合是chunks, 用于存储文件的二进制数据；一个集合是files，用于存储文件的元数据信息（文件名称、块大小、上传时间等信息）。

详细参考：官网文档

1、存放文件

	@AutowiredGridFsTemplate gridFsTemplate;@Testpublic void testSaveFile() throws FileNotFoundException {//要存储的文件File file = new File("C:\\Users\\JackChen\\Desktop\\360截图18141222225269.png");//定义输入流FileInputStream inputStram = new FileInputStream(file);//向GridFS存储文件ObjectId objectId =  gridFsTemplate.store(inputStram, "1.png", "");//得到文件IDString fileId = objectId.toString();//5fd46f5c3629763ad83f9b86System.out.println(fileId);}

文件存储成功得到一个文件id，该文件id是fs.files集合中的主键。

可以通过文件id查询fs.chunks表中的记录，得到文件的内容。当GridFS中读取文件时，若文件分成多块，需要对文件的各分块进行组装、合并。

2、读取文件

定义一个Mongodb的配置类，初始化项目时创建一个GridFSBucket对象，用于打开下载流对象。

@Configuration
public class MongoConfig {@Value("${spring.data.mongodb.database}")String db;@Beanpublic GridFSBucket getGridFSBucket(MongoClient mongoClient){MongoDatabase database = mongoClient.getDatabase(db);GridFSBucket bucket = GridFSBuckets.create(database);return bucket;}
}

    @Testpublic void testReadFile() throws IOException {//根据文件id查询文件GridFSFile gridFSFile = gridFsTemplate.findOne(Query.query(Criteria.where("_id").is("5fd46f5c3629763ad83f9b86")));//打开一个下载流对象GridFSDownloadStream gridFSDownloadStream = gridFSBucket.openDownloadStream(gridFSFile.getObjectId());//创建GridFsResource对象，获取流GridFsResource gridFsResource = new GridFsResource(gridFSFile,gridFSDownloadStream);File file = new File("C:\\Users\\JackChen\\Desktop\\2.png");FileOutputStream fileOutputStream = new FileOutputStream(file);IOUtils.copy(gridFsResource.getInputStream(),fileOutputStream);fileOutputStream.close();}

3、删除文件

	@AutowiredGridFsTemplate gridFsTemplate;@Testpublic void testDelFile() throws IOException {//根据文件id删除fs.files和fs.chunks中的记录gridFsTemplate.delete(Query.query(Criteria.where("_id").is("5fd46f5c3629763ad83f9b86")));}