类org.springframework.boot.autoconfigure.mongo.MongoProperties源码实例Demo

下面列出了怎么用org.springframework.boot.autoconfigure.mongo.MongoProperties的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: spring-fu   文件: ReactiveMongoDsl.java
@Override
public void initialize(GenericApplicationContext context) {
	super.initialize(context);
	this.dsl.accept(this);
	if (properties.getUri() == null) {
		properties.setUri(MongoProperties.DEFAULT_URI);
	}
	new MongoDataInitializer(properties).initialize(context);
	new MongoReactiveDataInitializer(properties).initialize(context);
	new MongoReactiveInitializer(properties, embedded).initialize(context);
}
 
@Bean
MongoClient mongoClient(MongoProperties properties) {
    ConnectionString connectionString = new ConnectionString(properties.determineUri());
    MongoClientSettings.Builder builder = MongoClientSettings
            .builder()
            .streamFactoryFactory(NettyStreamFactory::new)
            .applyToClusterSettings(b -> b.applyConnectionString(connectionString))
            .applyToConnectionPoolSettings(b -> b.applyConnectionString(connectionString))
            .applyToServerSettings(b -> b.applyConnectionString(connectionString))
            .applyToSslSettings(b -> b.applyConnectionString(connectionString))
            .applyToSocketSettings(b -> b.applyConnectionString(connectionString))
            .codecRegistry(fromRegistries(
                MongoClients.getDefaultCodecRegistry(),
                fromProviders(PojoCodecProvider.builder()
                                               .automatic(true)
                                               .register(News.class)
                                               .build())
            ));

    if (connectionString.getReadPreference() != null) {
        builder.readPreference(connectionString.getReadPreference());
    }
    if (connectionString.getReadConcern() != null) {
        builder.readConcern(connectionString.getReadConcern());
    }
    if (connectionString.getWriteConcern() != null) {
        builder.writeConcern(connectionString.getWriteConcern());
    }
    if (connectionString.getApplicationName() != null) {
        builder.applicationName(connectionString.getApplicationName());
    }
    return MongoClients.create(builder.build());
}
 
private void copyMissingProperties(MongoProperties mongoProperties, MongeezProperties mongeezProperties) {
    if (StringUtils.isEmpty(mongeezProperties.getDatabase())) {
        mongeezProperties.setDatabase(mongoProperties.getMongoClientDatabase());
    }
    if (StringUtils.isEmpty(mongeezProperties.getAuthenticationDatabase())) {
        mongeezProperties.setAuthenticationDatabase(mongoProperties.getAuthenticationDatabase());
    }
    if (!mongeezProperties.hasCredentials() && hasCredentials(mongoProperties)) {
        // cannot copy credentials because Spring Data MongoDB clears the password after using it
        String msg = "Found credentials for Spring Data MongoDB but no credentials for Mongeez. " +
                "You need to define both for authentication to work.";
        throw new BeanCreationException(msg);
    }
}
 
源代码4 项目: spring-fu   文件: EmbeddedMongoInitializer.java
public EmbeddedMongoInitializer(MongoProperties mongoProperties, EmbeddedMongoProperties embeddedProperties) {
	this.properties = mongoProperties;
	this.embeddedProperties = embeddedProperties;
}
 
源代码5 项目: spring-fu   文件: MongoReactiveDataInitializer.java
public MongoReactiveDataInitializer(MongoProperties properties) {
	this.properties = properties;
}
 
源代码6 项目: spring-fu   文件: MongoDataInitializer.java
public MongoDataInitializer(MongoProperties properties) {
	this.properties = properties;
}
 
源代码7 项目: spring-fu   文件: ReactiveMongoDsl.java
EmbeddedMongoDsl(MongoProperties properties, Consumer<EmbeddedMongoDsl> dsl) {
	this.dsl = dsl;
	this.mongoProperties = properties;
}
 
源代码8 项目: webFluxTemplate   文件: MongoConfiguration.java
@Autowired
public MongoConfiguration(MongoProperties mongoProperties) {
    this.mongoProperties = mongoProperties;
}
 
源代码9 项目: canal-mongo   文件: MultipleMongoProperties.java
public MongoProperties getNaive() {
    return naive;
}
 
源代码10 项目: canal-mongo   文件: MultipleMongoProperties.java
public void setNaive(MongoProperties naive) {
    this.naive = naive;
}
 
源代码11 项目: canal-mongo   文件: MultipleMongoProperties.java
public MongoProperties getComplete() {
    return complete;
}
 
源代码12 项目: canal-mongo   文件: MultipleMongoProperties.java
public void setComplete(MongoProperties complete) {
    this.complete = complete;
}
 
private boolean hasCredentials(MongoProperties properties) {
    return properties.getUsername() != null && properties.getPassword() != null;
}
 
源代码14 项目: micro-service   文件: MultiMongoProperties.java
@Primary
@Bean(name="companyMongoProperties")
@ConfigurationProperties(prefix="spring.data.mongodb.company")
public MongoProperties companyMongoProperties() {
    return new MongoProperties();
}
 
源代码15 项目: micro-service   文件: MultiMongoProperties.java
@Bean(name="organizationMongoProperties")
@ConfigurationProperties(prefix="spring.data.mongodb.organization")
public MongoProperties organizationMongoProperties() {
    return new MongoProperties();
}
 
 类方法
 同包方法