Shulou(Shulou.com)06/02 Report--

Today, I will talk to you about how to set the account password of Springboot2.0.X+mongodb multi-data sources, which may not be well understood by many people. in order to make you understand better, the editor has summarized the following contents for you. I hope you can get something according to this article.

Before rising in the Springboot2.X + Mongodb multi-data source, it was found that there was no user name and password, and the replacement did not work, and then rewrite a multi-data source with user name and password, which is convenient for enterprise use. Currently, it is suitable for 2.0.X version. If the higher version, the configuration Factory will expire, so wait for time in the entire high version of the configuration blog.

1. Pom depends on org.springframework.boot spring-boot-starter-data-mongodb org.springframework.boot spring-boot-starter-web org.projectlombok lombok true2, Application.propertiesspring.data.mongodb.first.database= database name spring.data.mongodb.first.uri=mongodb:// account: password @ address host:3717/ database name? maxIdleTimeMS=3000spring.data.mongodb.second.database= database name spring.data.mongodb.second.uri=mongodb:// account: password @ address host:3717/ database name? maxIdleTimeMS=30003, Config configuration @ Configuration@Slf4jpublic class MultiMongoDbConfig {@ Bean (name= "firstMongoProperties") @ Primary @ ConfigurationProperties (prefix= "spring.data.mongodb.first") public MongoProperties firstMongoProperties () {log.info ("- liveMongoProperties init -") Return new MongoProperties ();} @ Bean (name= "secondMongoProperties") @ ConfigurationProperties (prefix= "spring.data.mongodb.second") public MongoProperties secondMongoProperties () {log.info ("- monitorMongoProperties init -"); return new MongoProperties () } / * if you do not write this conversion tool class, you will add a _ class field to the table when you insert data into the table by default through mongoTempleate, and this _ class field will not appear after conversion through this transformation class. * @ param factory mongodb factory class * @ param context context * @ param beanFactory bean factory * @ return MappingMongoConverter * / @ Bean (name = "mongoConverter") public MappingMongoConverter mappingMongoConverter (MongoDbFactory factory, MongoMappingContext context, BeanFactory beanFactory) {DbRefResolver dbRefResolver = new DefaultDbRefResolver (factory); MappingMongoConverter mappingConverter = new MappingMongoConverter (dbRefResolver, context); try {mappingConverter.setCustomConversions (beanFactory.getBean (CustomConversions.class)) } catch (NoSuchBeanDefinitionException ignore) {} / / Don't save _ class to mongo mappingConverter.setTypeMapper (new DefaultMongoTypeMapper (null)); return mappingConverter;}}

First library configuration

@ Configuration@EnableMongoRepositories (basePackages = "com.sports.statistics.repository.live", mongoTemplateRef = "liveMongo") public class LiveMongoTemplate {@ Autowired @ Qualifier ("firstMongoProperties") private MongoProperties mongoProperties; @ Primary @ Bean (name = "liveMongo") public MongoTemplate firstMongoTemplate () {return new MongoTemplate (firstFactory (this.mongoProperties)); / / return new MongoTemplate (firstFactory (this.mongoProperties), MongoTemplateHolder.mongoConverter ()) @ Bean @ Primary public MongoDbFactory firstFactory (MongoProperties mongoProperties) {MongoClientOptions.Builder options = new MongoClientOptions.Builder (); options.readPreference (ReadPreference.primary ()); options.connectionsPerHost (10); return new SimpleMongoDbFactory (new MongoClientURI (mongoProperties.getUri (), options));}}

Second library configuration

@ Configuration@EnableMongoRepositories (basePackages = "com.sports.statistics.repository.monitor", mongoTemplateRef = "monitorMongo") public class MonitorMongoTemplate {@ Autowired @ Qualifier ("secondMongoProperties") private MongoProperties mongoProperties; @ Bean (name = "monitorMongo") public MongoTemplate secondTemplate () {return new MongoTemplate (secondFactory (this.mongoProperties)); / / return new MongoTemplate (secondFactory (this.mongoProperties), MongoTemplateHolder.mongoConverter ();} @ Bean public MongoDbFactory secondFactory (MongoProperties mongoProperties) {MongoClientOptions.Builder options = new MongoClientOptions.Builder () Options.readPreference (ReadPreference.primary ()); options.connectionsPerHost (10); return new SimpleMongoDbFactory (new MongoClientURI (mongoProperties.getUri (), options));} @ Componentpublic class MongoTemplateHolder implements ApplicationContextAware {private static ApplicationContext applicationContext; @ Override public void setApplicationContext (ApplicationContext applicationContext) throws BeansException {if (MongoTemplateHolder.applicationContext = = null) {MongoTemplateHolder.applicationContext = applicationContext }} / * get the container * @ return ApplicationContext * / public static ApplicationContext getApplicationContext () {return applicationContext } / * * get MongoTemplate template * @ param source data source (the data source you want to get) * @ return MongoTemplate * / public static MongoTemplate getBean (String source) throws Exception {if (StringUtils.isEmpty (source)) {throw new Exception ("= data source name cannot be empty =");} return (MongoTemplate) getApplicationContext (). GetBean (source) } / * obtain mongodbTemplate * @ author chengjian * @ date corresponding to different data sources at 9:47 on 2020-9-15 * @ param mongoDbEnum data source information * / public static MongoTemplate getBean (MongoDbEnum mongoDbEnum) throws Exception {if (mongoDbEnum = = null) {throw new Exception ("= data source name cannot be empty =");} return (MongoTemplate) getApplicationContext () .getBean (mongoDbEnum.getDatabaseName ()) } / * @ param source data source * @ param name database name * @ return MongoCollection * / public static DBCollection getCollection (String source, String name) throws Exception {if (StringUtils.isEmpty (source)) {throw new Exception ("= data source name cannot be empty =");} if (StringUtils.isEmpty (name)) {throw new Exception ("= empty table name cannot get MongoCollection=") } MongoTemplate template = (MongoTemplate) getApplicationContext (). GetBean (source); return (DBCollection) template.getCollection (name);} public static MappingMongoConverter mongoConverter () {return (MappingMongoConverter) getApplicationContext (). GetBean ("mongoConverter");}} 4, enumerate @ Getter@AllArgsConstructor@NoArgsConstructorpublic enum MongoDbEnum {/ * data source * / LIVE ("liveMongo"), MONITOR ("monitorMongo"); private String databaseName;} 5, repository

First library table

Public interface UserRepository extends MongoRepository {}

Second library table

Public interface ChatBanRepository extends MongoRepository {} 6, controller Test @ RestController@RequestMapping (value = "/ user") public class UserController {@ Resource UserRepository userRepository; @ Resource ChatBanRepository chatBanRepository; @ GetMapping (value = "/ test1") public String test1 () throws Exception {System.out.println ("first Library: user quantity =" + userRepository.count ()); Query query = new Query (); MongoTemplate mongoTemplate = MongoTemplateHolder.getBean (MongoDbEnum.LIVE.getDatabaseName ()) System.out.println ("first library: user quantity = =" + mongoTemplate.count (query, "user")); System.out.println ("second library: chat quantity = =" + chatBanRepository.count ()); return "OK";}} 7, result

Test success 1

After reading the above, do you have any further understanding of how to set the account password of Springboot2.0.X+mongodb multi-data sources? If you want to know more knowledge or related content, please follow the industry information channel, thank you for your support.

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.