springbootmongodb的多數(shù)據(jù)源配置的方法步驟

1、springboot-mongodb的多數(shù)據(jù)源配置的方法步驟在日常工作中，我們可能需要連接多個(gè)ongo數(shù)據(jù)源，比如用戶(hù)庫(kù)Ser日志庫(kù)o。本章我們來(lái)記錄連接多個(gè)數(shù)據(jù)源的步驟，以?xún)蓚€(gè)數(shù)據(jù)源為例，多個(gè)數(shù)據(jù)源類(lèi)推。ipom中引入mongodb依賴(lài)gropdorgspringrmorbootgropdrtitdspring-boot-strtr-dt-mongodbrtitdgropdorgprotombogropdrtitdombortitdgropdorgspringrmorbootgropdrtitdspring-boot-toonigrrtitdrsionrsionombo是個(gè)可以通過(guò)簡(jiǎn)單的注解

2、形式來(lái)幫助我們簡(jiǎn)化消除一些必須有但顯得很臃腫的代碼的工具，通過(guò)使用對(duì)應(yīng)的注解，可以在編譯源碼的時(shí)候生成對(duì)應(yīng)的方法。簡(jiǎn)單試了以下這個(gè)工具還挺好玩的，加上注解我們就不用手動(dòng)寫(xiě)gttrs、構(gòu)建方式類(lèi)似的代碼了。配置1mongodb:primrostportdatabase:testsondrostportdatabase:test1配置個(gè)庫(kù)的數(shù)據(jù)源Dataonigrtionroprtisprimongodbpbisstipongoroprtispritongoroprtisprimrnongoroprtispritongoroprtissondrnongoroprtis第一個(gè)庫(kù)封裝Configura

3、tionnbongopositorisbsgsomnomodrpositorprimrmongomptrimrongoonigpbissrimrongoonigprottdsttiintringprimrongompt第二個(gè)庫(kù)封裝ConfigurationnbongopositorisbsgsomnomodrpositorsondrmongomptondrongoonigpbissondrongoonigprottdsttiintringsondrongomptmongoTempConfigurationpublicclassMultipleMongoConfigAutowiredprivat

4、eMultipleMongoPropertiesmongoProperties;PrimaryBean(name=PrimaryMongoConfig.MONGO_TEMPLATE)publicMongoTemplateprimaryMongoTemplate()throwsExceptionreturnnewMongoTemplate(primaryFactory(this.mongoProperties.getPrimary();BeanQualifier(SecondaryMongoConfig.MONGO_TEMPLATE)publicMongoTemplatesecondaryMon

5、goTemplate()throwsExceptionreturnnewMongoTemplate(secondaryFactory(this.mongoProperties.getSecondary();BeanPrimarypublicMongoDbFactoryprimaryFactory(MongoPropertiesmongo)throwsExceptionreturnnewSimpleMongoDbFactory(newMongoClient(mongo.getHost(),mongo.getPort(),mongo.getDatabase();BeanpublicMongoDbF

6、actorysecondaryFactory(MongoPropertiesmongo)throwsExceptionreturnnewSimpleMongoDbFactory(newMongoClient(mongo.getHost(),mongo.getPort(),mongo.getDatabase();4,創(chuàng)建2個(gè)庫(kù)對(duì)應(yīng)的repository:DataAllArgsConstructorNoArgsConstructorDocument(collection=first_mongo)publicclassPrimaryMongoObjectIdprivateStringid;priva

7、teStringvalue;OverridepublicStringtoString()returnPrimaryMongoObject+id=+id+,value=+value+;publicinterfacePrimaryRepositoryextendsMongoRepository測(cè)試:RunWith(SpringRunner.class)SpringBootTestpublicclassMuliDatabaseTestAutowiredprivatePrimaryRepositoryprimaryRepository;AutowiredprivateSecondaryReposito

8、rysecondaryRepository;TestpublicvoidTestSave()System.out.println(II*11System.out.println(測(cè)試開(kāi)始);this.primaryRepository.save(newPrimaryMongoObject(null,第一個(gè)庫(kù)的對(duì)象)；this.secondaryRepository.save(newSecondaryMongoObject(null,第二個(gè)庫(kù)的對(duì)象)；Listprimaries=this.primaryRepository.findAll()；for(PrimaryMongoObjectprimary:primaries)System.out.println(primary.toString()；Listsecondaries=this.secondaryRepository.findAll()；for(SecondaryMongoObjectsecondary:secondaries)System.out.pri