SpringBoot整合MongoDB超详细

　　一、介绍
　　在前面的文章中，我们详细的介绍了MongoDB的配置和使用，如果你对MongoDB还不是很了解，也没关系，在MongoDB中有三个比较重要的名词：数据库、集合、文档！数据库（Database）：和关系型数据库一样，每个数据库中有自己的用户权限，不同的项目组可以使用不同的数据库集合（Collection）：集合指的是文档组（类似于Mysql中的表的概念），里面可以存储许多文档文档（Document）：文档是MongoDB中最基本的数据单元，由键值对组成，类似于JSON格式，可以存储不同字段，字段的值可以包括其他文档、数组和文档数组
　　搞懂这三个名词，基本就可以上手了，今天我们以Java语言为例，详细的介绍Java客户端改如何操作MongoDB！
　　话不多说，直接开撸！二、Java客户端2。1、MongoDB连接
　　Java连接MongoDB服务器，与我们常用的连接关系型数据库方式类似！
　　标准URI连接语法：mongodb：username：passwordhost1：port1，host2：port2，。。。，hostN：portNdatabase？options
　　参数说明：mongodb：：这是固定的格式，必须要指定username：password：可选项，如果设置，在连接数据库服务器之后，驱动都会尝试登录这个数据库host1：port1：主机IP和端口号，必须指定至少一个host。如果要连接复制集，请指定多个主机地址database：如果指定了username：password，连接时会验证并登录指定数据库。若不指定，默认打开test数据库？options：连接可选项，例如connectTimeoutMS5000ms，表示连接等待时间最长5秒
　　例如，无密码连接MongoDBmongodb：127。0。0。1：27017
　　使用用户名test，密码test登录MongoDB的testdb数据库mongodb：test：test127。0。0。1：27017testdb
　　无密码连接指定三台服务器（端口27017，27018，和27019）mongodb：127。0。0。1：27017，127。0。0。1：27018，127。0。0。1：270192。2、添加依赖包
　　和关系型数据库操作一样，在Java程序中如果要使用MongoDB，先要添加对应的MongoDBJDBC驱动器，然后才能继续操作！
　　在选择的版本号的时候，注意需要和服务器中的安装版本匹配，具体的版本号选择可以从如下地址中获取到最新的版本：mongojavadriverdependencygroupIdorg。mongodbgroupIdmongojavadriverartifactIdversion3。12。7versiondependency2。3、连接数据库
　　连接数据库的Java代码如下：privatestaticMongoClientmongoClient；static｛try｛连接到MongoDB服务如果是远程连接可以替换localhost为服务器所在IP地址mongoClientMongoClients。create（mongodb：test：test127。0。0。1：27017testdb）；System。out。println（Connecttodatabasesuccessfully）；｝catch（Exceptione）｛System。err。println（e。getClass（）。getName（）：e。getMessage（））；｝｝
　　上文中采用的是用户名和密码方式登录数据库，因为数据库已经开启了权限验证，因此需要通过用户名和密码才能登录。2。4、创建集合
　　com。mongodb。client包里面都帮我们集成好了大部分常用的api，我们可以通过MongoDatabase类中的createCollection（）方法来创建集合。
　　创建一个tbrole集合，代码片段如下：创建集合paramargspublicstaticvoidmain（String〔〕args）｛连接到数据库MongoDatabasemongoDatabasemongoClient。getDatabase（testdb）；System。out。println（Connecttodatabasesuccessfully）；mongoDatabase。createCollection（tbrole）；System。out。println（集合创建成功）；｝
　　如果想删除集合，操作也很简单！删除集合paramargspublicstaticvoidmain（String〔〕args）｛连接到数据库MongoDatabasemongoDatabasemongoClient。getDatabase（testdb）；System。out。println（Connecttodatabasesuccessfully）；mongoDatabase。getCollection（tbrole）。drop（）；System。out。println（集合tbrole删除成功）；｝2。5、创建文档
　　我们可以通过MongoCollection类中的insertMany（）方法来插入一个文档。
　　向tbrole集合中插入文档，代码片段如下：插入文档paramargspublicstaticvoidmain（String〔〕args）｛连接到数据库MongoDatabasemongoDatabasemongoClient。getDatabase（testdb）；System。out。println（Connecttodatabasesuccessfully）；获取集合MongoCollectionDocumentcollectionmongoDatabase。getCollection（tbrole）；向集合中插入文档DocumentdocumentnewDocument（name，管理员）。append（code，manager）。append（sort，100）；ListDocumentdocumentsnewArrayList（）；documents。add（document）；collection。insertMany（documents）；System。out。println（文档插入成功）；｝2。6、更新文档
　　我们可以通过MongoCollection类中的updateMany（）方法来更新集合中的文档。
　　更新tbrole集合中的指定文档信息，代码片段如下：更新文档paramargspublicstaticvoidmain（String〔〕args）｛连接到数据库MongoDatabasemongoDatabasemongoClient。getDatabase（testdb）；System。out。println（Connecttodatabasesuccessfully）；获取集合MongoCollectionDocumentcollectionmongoDatabase。getCollection（tbrole）；更新文档collection。updateMany（Filters。eq（code，manager），newDocument（set，newDocument（name，经理）））；遍历所有文档FindIterableDocumentfindIterablecollection。find（）；MongoCursorDocumentmongoCursorfindIterable。iterator（）；while（mongoCursor。hasNext（））｛System。out。println（mongoCursor。next（））；｝｝
　　上文操作类似于SQL语句中的updatetbrolesetname经理wherecodemanager！2。7、删除文档
　　我们可以通过MongoCollection类中的deleteOne（）或者deleteMany方法来删除集合中的文档。
　　删除tbrole集合中的指定文档信息，代码片段如下：删除文档paramargspublicstaticvoidmain（String〔〕args）｛连接到数据库MongoDatabasemongoDatabasemongoClient。getDatabase（testdb）；System。out。println（Connecttodatabasesuccessfully）；获取集合MongoCollectionDocumentcollectionmongoDatabase。getCollection（tbrole）；删除符合条件的第一个文档collection。deleteOne（Filters。eq（code，manager））；删除所有符合条件的文档collection。deleteMany（Filters。eq（code，manager））；遍历所有文档FindIterableDocumentfindIterablecollection。find（）；MongoCursorDocumentmongoCursorfindIterable。iterator（）；while（mongoCursor。hasNext（））｛System。out。println（mongoCursor。next（））；｝｝
　　在这里需要注意一下，在删除的时候，官方推荐尽可能先查询一下这个数据是否存在，如果存在，然后在执行删除操作，可以调用findOneAndDelete（）方法进行删除！2。8、查询文档
　　MongoCollection类中提供了非常丰富的检索文档的方法，例如，我们可以通过find（）方法来获取集合中的所有文档。
　　检索tbrole集合中的文档信息，代码片段如下：查询文档paramargspublicstaticvoidmain（String〔〕args）｛连接到数据库MongoDatabasemongoDatabasemongoClient。getDatabase（testdb）；System。out。println（Connecttodatabasesuccessfully）；获取集合MongoCollectionDocumentcollectionmongoDatabase。getCollection（tbrole）；遍历所有文档FindIterableDocumentfindIterablecollection。find（）；MongoCursorDocumentmongoCursorfindIterable。iterator（）；while（mongoCursor。hasNext（））｛System。out。println（mongoCursor。next（））；｝查询当前集合所有文档数量longcountcollection。countDocuments（）；System。out。println（当前文档数量：count）；带条件遍历文档FindIterableDocumentdocumentFindIterablecollection。find（Filters。eq（code，manager））；MongoCursorDocumentdocumentMongoCursordocumentFindIterable。iterator（）；while（documentMongoCursor。hasNext（））｛System。out。println（documentMongoCursor。next（））；｝｝三、SpringBoot整合MongoDB
　　采用SpringBoot来对接MongoDB，可以说极其简单，下面就以常用的几个操作为例来介绍，过程如下！3。1、创建SpringBoot工程，添加MongoDB依赖包！引入springbootparentgroupIdorg。springframework。bootgroupIdspringbootstarterparentartifactIdversion2。1。0。RELEASEversionparentdependencygroupIdorg。springframework。bootgroupIdspringbootstarterdatamongodbartifactIddependency3。2、添加配置文件
　　在application。properties文件中添加mongodb配置配置数据库连接地址spring。data。mongodb。urimongodb：test123：test123127。0。0。1：27017testdb3。3、创建实体类
　　创建用于示例中测试的实体类Person。
　　其中注解Document（collectionpersons）用于指定当前文档属于集合persons。
　　注解Id表示当前id字段属于主键类型。使用Document注解指定集合名称Document（collectionpersons）publicclassPersonimplementsSerializable｛privatestaticfinallongserialVersionUID3258839839160856613L；使用Id注解指定MongoDB中的id主键IdprivateLongid；privateStringuserName；privateStringpassWord；privateIntegerage；privateDatecreateTime；。。。getsetOverridepublicStringtoString（）｛returnPerson｛idid，userNameuserName，passWordpassWord，ageage，createTimecreateTime｝；｝｝3。4、操作MongoDB
　　Springboot操作MongoDB有两种方式。第一种方式是采用Springboot官方推荐的JPA方式，这种操作方式，使用简单但是灵活性比较差。第二种方式是采用SpringDataMongoDB封装的MongoDB官方Java驱动MongoTemplate对MongoDB进行操作，这种方式非常灵活，能满足绝大部分需求。
　　本文将采用第二种方式进行介绍！3。5、插入文档
　　MongoTemplate提供了insert（）方法，用于插入文档，示例代码如下：用于插入文档
　　没指定集合名称时，会取Document注解中的集合名称RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；插入文档throwsExceptionTestpublicvoidinsert（）throwsException｛PersonpersonnewPerson（）；person。setId（1l）；person。setUserName（张三）；person。setPassWord（123456）；person。setCreateTime（newDate（））；mongoTemplate。insert（person）；｝｝自定义集合名称，插入文档RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；自定义集合，插入文档throwsExceptionTestpublicvoidinsertCustomCollection（）throwsException｛PersonpersonnewPerson（）；person。setId（1l）；person。setUserName（张三）；person。setPassWord（123456）；person。setCreateTime（newDate（））；mongoTemplate。insert（person，customperson）；｝｝自定义集合，批量插入文档
　　如果采用批量插入文档，必须指定集合名称RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；自定义集合，批量插入文档throwsExceptionTestpublicvoidinsertBatch（）throwsException｛ListPersonpersonListnewArrayList（）；Personperson1newPerson（）；person1。setId（10l）；person1。setUserName（张三）；person1。setPassWord（123456）；person1。setCreateTime（newDate（））；personList。add（person1）；Personperson2newPerson（）；person2。setId（11l）；person2。setUserName（李四）；person2。setPassWord（123456）；person2。setCreateTime（newDate（））；personList。add（person2）；mongoTemplate。insert（personList，customperson）；｝｝3。6、存储文档
　　MongoTemplate提供了save（）方法，用于存储文档。
　　在存储文档的时候会通过主键ID进行判断，如果存在就更新，否则就插入，示例代码如下：存储文档，如果没有插入，否则通过主键ID更新RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；存储文档，如果没有插入，否则更新throwsExceptionTestpublicvoidsave（）throwsException｛PersonpersonnewPerson（）；person。setId（13l）；person。setUserName（八八）；person。setPassWord（123456）；person。setAge（40）；person。setCreateTime（newDate（））；mongoTemplate。save（person）；｝｝自定义集合，存储文档RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；自定义集合，存储文档throwsExceptionTestpublicvoidsaveCustomCollection（）throwsException｛PersonpersonnewPerson（）；person。setId（1l）；person。setUserName（张三）；person。setPassWord（123456）；person。setCreateTime（newDate（））；mongoTemplate。save（person，customperson）；｝｝3。7、更新文档
　　MongoTemplate提供了updateFirst（）和updateMulti（）方法，用于更新文档，示例代码如下：更新文档，匹配查询到的文档数据中的第一条数据RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；更新文档，匹配查询到的文档数据中的第一条数据throwsExceptionTestpublicvoidupdateFirst（）throwsException｛更新对象PersonpersonnewPerson（）；person。setId（1l）；person。setUserName（张三123）；person。setPassWord（123456）；person。setCreateTime（newDate（））；更新条件QueryquerynewQuery（Criteria。where（id）。is（person。getId（）））；更新值UpdateupdatenewUpdate（）。set（userName，person。getUserName（））。set（passWord，person。getPassWord（））；更新查询满足条件的文档数据（第一条）UpdateResultresultmongoTemplate。updateFirst（query，update，Person。class）；if（result！null）｛System。out。println（更新条数：result。getMatchedCount（））；｝｝｝更新文档，匹配查询到的文档数据中的所有数据RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；更新文档，匹配查询到的文档数据中的所有数据throwsExceptionTestpublicvoidupdateMany（）throwsException｛更新对象PersonpersonnewPerson（）；person。setId（1l）；person。setUserName（张三）；person。setPassWord（123456）；person。setCreateTime（newDate（））；更新条件QueryquerynewQuery（Criteria。where（id）。is（person。getId（）））；更新值UpdateupdatenewUpdate（）。set（userName，person。getUserName（））。set（passWord，person。getPassWord（））；更新查询满足条件的文档数据（全部）UpdateResultresultmongoTemplate。updateMulti（query，update，Person。class）；if（result！null）｛System。out。println（更新条数：result。getMatchedCount（））；｝｝｝3。8、删除文档
　　MongoTemplate提供了remove（）、findAndRemove（）和findAllAndRemove（）方法，用于删除文档，示例代码如下：删除符合条件的所有文档RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；删除符合条件的所有文档throwsExceptionTestpublicvoidremove（）throwsException｛PersonpersonnewPerson（）；person。setId（1l）；person。setUserName（张三）；person。setPassWord（123456）；person。setCreateTime（newDate（））；QueryquerynewQuery（Criteria。where（userName）。is（person。getUserName（）））；DeleteResultresultmongoTemplate。remove（query，Person。class）；System。out。println（删除条数：result。getDeletedCount（））；｝｝删除符合条件的单个文档，并返回删除的文档RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；删除符合条件的单个文档，并返回删除的文档throwsExceptionTestpublicvoidfindAndRemove（）throwsException｛PersonpersonnewPerson（）；person。setId（1l）；person。setUserName（张三）；person。setPassWord（123456）；person。setCreateTime（newDate（））；QueryquerynewQuery（Criteria。where（id）。is（person。getId（）））；PersonresultmongoTemplate。findAndRemove（query，Person。class）；System。out。println（删除的文档数据：result。toString（））；｝｝删除符合条件的所有文档，并返回删除的文档RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；删除符合条件的所有文档，并返回删除的文档throwsExceptionTestpublicvoidfindAllAndRemove（）throwsException｛PersonpersonnewPerson（）；person。setId（1l）；person。setUserName（张三）；person。setPassWord（123456）；person。setCreateTime（newDate（））；QueryquerynewQuery（Criteria。where（id）。is（person。getId（）））；ListPersonresultmongoTemplate。findAllAndRemove（query，Person。class）；System。out。println（删除的文档数据：result。toString（））；｝｝3。9、查询文档
　　MongoTemplate提供了非常多的文档查询方法，日常开发中用的最多的就是find（）方法，示例代码如下：查询集合中的全部文档数据RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；查询集合中的全部文档数据throwsExceptionTestpublicvoidfindAll（）throwsException｛ListPersonresultmongoTemplate。findAll（Person。class）；System。out。println（查询结果：result。toString（））；｝｝查询集合中指定的ID文档数据RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；查询集合中指定的ID文档数据throwsExceptionTestpublicvoidfindById（）｛longid1l；PersonresultmongoTemplate。findById（id，Person。class）；System。out。println（查询结果：result。toString（））；｝｝根据条件查询集合中符合条件的文档，返回第一条数据RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；根据条件查询集合中符合条件的文档，返回第一条数据TestpublicvoidfindOne（）｛StringuserName张三；QueryquerynewQuery（Criteria。where（userName）。is（userName））；PersonresultmongoTemplate。findOne（query，Person。class）；System。out。println（查询结果：result。toString（））；｝｝根据条件查询集合中符合条件的文档RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；根据条件查询集合中符合条件的文档TestpublicvoidfindByCondition（）｛StringuserName张三；QueryquerynewQuery（Criteria。where（userName）。is（userName））；ListPersonresultmongoTemplate。find（query，Person。class）；System。out。println（查询结果：result。toString（））；｝｝根据【AND】关联多个查询条件，查询集合中的文档数据RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；根据【AND】关联多个查询条件，查询集合中的文档数据TestpublicvoidfindByAndCondition（）｛创建条件CriteriacriteriaUserNameCriteria。where（userName）。is（张三）；CriteriacriteriaPassWordCriteria。where（passWord）。is（123456）；创建条件对象，将上面条件进行AND关联CriteriacriterianewCriteria（）。andOperator（criteriaUserName，criteriaPassWord）；创建查询对象，然后将条件对象添加到其中QueryquerynewQuery（criteria）；ListPersonresultmongoTemplate。find（query，Person。class）；System。out。println（查询结果：result。toString（））；｝｝根据【OR】关联多个查询条件，查询集合中的文档数据RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；根据【OR】关联多个查询条件，查询集合中的文档数据TestpublicvoidfindByOrCondition（）｛创建条件CriteriacriteriaUserNameCriteria。where（userName）。is（张三）；CriteriacriteriaPassWordCriteria。where（passWord）。is（123456）；创建条件对象，将上面条件进行OR关联CriteriacriterianewCriteria（）。orOperator（criteriaUserName，criteriaPassWord）；创建查询对象，然后将条件对象添加到其中QueryquerynewQuery（criteria）；ListPersonresultmongoTemplate。find（query，Person。class）；System。out。println（查询结果：result。toString（））；｝｝根据【IN】关联多个查询条件，查询集合中的文档数据RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；根据【IN】关联多个查询条件，查询集合中的文档数据TestpublicvoidfindByInCondition（）｛设置查询条件参数ListLongidsArrays。asList（1l，10l，11l）；创建条件CriteriacriteriaCriteria。where（id）。in（ids）；创建查询对象，然后将条件对象添加到其中QueryquerynewQuery（criteria）；ListPersonresultmongoTemplate。find（query，Person。class）；System。out。println（查询结果：result。toString（））；｝｝根据【逻辑运算符】查询集合中的文档数据RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；根据【逻辑运算符】查询集合中的文档数据TestpublicvoidfindByOperator（）｛设置查询条件参数intmin20；intmax35；CriteriacriteriaCriteria。where（age）。gt（min）。lte（max）；创建查询对象，然后将条件对象添加到其中QueryquerynewQuery（criteria）；ListPersonresultmongoTemplate。find（query，Person。class）；System。out。println（查询结果：result。toString（））；｝｝根据【正则表达式】查询集合中的文档数据RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；根据【正则表达式】查询集合中的文档数据TestpublicvoidfindByRegex（）｛设置查询条件参数Stringregex张；CriteriacriteriaCriteria。where（userName）。regex（regex）；创建查询对象，然后将条件对象添加到其中QueryquerynewQuery（criteria）；ListPersonresultmongoTemplate。find（query，Person。class）；System。out。println（查询结果：result。toString（））；｝｝根据条件查询集合中符合条件的文档，获取其文档列表并排序RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；根据条件查询集合中符合条件的文档，获取其文档列表并排序TestpublicvoidfindByConditionAndSort（）｛StringuserName张三；QueryquerynewQuery（Criteria。where（userName）。is（userName））。with（Sort。by（age））；ListPersonresultmongoTemplate。find（query，Person。class）；System。out。println（查询结果：result。toString（））；｝｝根据单个条件查询集合中的文档数据，并按指定字段进行排序与限制指定数目RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；根据单个条件查询集合中的文档数据，并按指定字段进行排序与限制指定数目TestpublicvoidfindByConditionAndSortLimit（）｛StringuserName张三；从第一行开始，查询2条数据返回QueryquerynewQuery（Criteria。where（userName）。is（userName））。with（Sort。by（createTime））。limit（2）。skip（1）；ListPersonresultmongoTemplate。find（query，Person。class）；System。out。println（查询结果：result。toString（））；｝｝统计集合中符合【查询条件】的文档【数量】RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；统计集合中符合【查询条件】的文档【数量】TestpublicvoidcountNumber（）｛设置查询条件参数Stringregex张；CriteriacriteriaCriteria。where（userName）。regex（regex）；创建查询对象，然后将条件对象添加到其中QueryquerynewQuery（criteria）；longcountmongoTemplate。count（query，Person。class）；System。out。println（统计结果：count）；｝｝4。0、创建索引
　　索引在所有的数据库中，暂居的位置非常重要，例如当你检索一张上百万的数据表的时候，如果没走索引，查询效率会极其缓慢，对于MongoDB来说，同样如此。
　　示例如下：创建升序索引RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；创建升序索引TestpublicvoidcreateAscendingIndex（）｛设置字段名称StringfielduserName；创建索引mongoTemplate。getCollection（persons）。createIndex（Indexes。ascending（field））；｝｝移除索引RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；根据索引名称移除索引TestpublicvoidremoveIndex（）｛设置字段名称StringfielduserName；删除索引mongoTemplate。getCollection（persons）。dropIndex（field）；｝｝查询集合中所有的索引RunWith（SpringRunner。class）SpringBootTestpublicclassPersonServiceTest｛AutowiredprivateMongoTemplatemongoTemplate；查询集合中所有的索引TestpublicvoidgetIndexAll（）｛获取集合中所有列表ListIndexesIterableDocumentindexListmongoTemplate。getCollection（persons）。listIndexes（）；获取集合中全部索引信息for（Documentdocument：indexList）｛System。out。println（索引列表：document）；｝｝｝我们还可以通过在实体类上加注解方式来创建索引使用Document注解指定集合名称Document（collectionpersons）publicclassPersonimplementsSerializable｛privatestaticfinallongserialVersionUID3258839839160856613L；使用Id注解指定MongoDB中的id主键IdprivateLongid；privateStringuserName；privateStringpassWord；privateIntegerage；创建一个5秒之后文档自动删除的索引Indexed（expireAfterSeconds5）privateDatecreateTime；。。。getsetOverridepublicStringtoString（）｛returnPerson｛idid，userNameuserName，passWordpassWord，ageage，createTimecreateTime｝；｝｝4。1、引入MongoDB中的事务
　　单节点mongodb不支持事务，需要搭建MongoDB复制集。配置事务管理器ConfigurationpublicclassTransactionConfig｛BeanMongoTransactionManagertransactionManager（MongoDatabaseFactorydbFactory）｛returnnewMongoTransactionManager（dbFactory）；｝｝
　　事务服务测试！ServicepublicclassTransactionExample｛AutowiredprivateMongoTemplatemongoTemplate；Transactional（rollbackForException。class）publicObjecttransactionTest（）｛PersonpersonnewPerson（）；person。setId（1l）；person。setUserName（张三）；person。setPassWord（123456）；person。setCreateTime（newDate（））；PersonnewPersonmongoTemplate。insert（person）；抛出异常，观察数据是否进行回滚if（11）｛thrownewRuntimeException（异常）；｝returnnewPerson；｝｝四、小结
　　本文主要围绕MongoDB的Java客户端使用进行基本的增删改查操作介绍，在实际的业务场景中，可能还需要用到聚合函数等高级查询，大家如果有这种需求，可以访问如下地址获取更加详细的api文档介绍：MongoDB文档查询api介绍
　　demo获取地址：https：github。comjustdojavaspringbootexamplemongodb五、参考
　　1、菜鸟教程mongodb
　　2、超级小豆丁MongoDB介绍