import org.mongeez.Mongeez; //导入依赖的package包/类
/**
 * Init.
 *
 * @return the mongeez
 */
@Bean(initMethod = "process")
public Mongeez loadInitialData(final Mongo mongo) {
    logger.info("Initializing default data");
    final Mongeez mongeez = new Mongeez();
    mongeez.setMongo(mongo);
    mongeez.setDbName(databaseName);
    mongeez.setFile(new ClassPathResource(initialLoadingFile));
    return mongeez;
}
 

import org.mongeez.Mongeez; //导入依赖的package包/类
/**
 * Load initial data mongeez.
 *
 * @param mongo the mongo
 * @return the mongeez
 */
@Bean(initMethod = "process")
public Mongeez loadInitialData(final Mongo mongo) {
    final Mongeez mongeez = new Mongeez();
    mongeez.setMongo(mongo);
    mongeez.setDbName(FinerLeagueTestConstants.DB_NAME);
    mongeez.setFile(new ClassPathResource("db/mongeez_test.xml"));
    mongeez.process();
    return mongeez;
}
 

import org.mongeez.Mongeez; //导入依赖的package包/类
@Test
public void shouldDoNothingIfDisabled() {
    EnvironmentTestUtils.addEnvironment(this.context, "mongeez.enabled:false");
    registerAndRefresh(MongoAutoConfiguration.class, MongeezAutoConfiguration.class);
    assumeThat(this.context.getBeanNamesForType(Mongo.class), not(emptyArray()));
    assertThat(this.context.getBeanNamesForType(Mongeez.class), emptyArray());
}
 

import org.mongeez.Mongeez; //导入依赖的package包/类
@Test
public void shouldUseDatabaseFromMongoProperties() {
    String database = "foo";
    EnvironmentTestUtils.addEnvironment(this.context, "spring.data.mongodb.database:" + database);
    registerAndRefresh(DoNotExecuteMongeezPostProcessor.class,
            MongoAutoConfiguration.class, MongeezAutoConfiguration.class);
    Mongeez mongeez = this.context.getBean(Mongeez.class);
    Object mongeezDatabase = ReflectionTestUtils.getField(mongeez, "dbName");
    assertThat(mongeezDatabase.toString(), equalTo(database));
}
 

import org.mongeez.Mongeez; //导入依赖的package包/类
@Test
public void shouldUseDatabaseOverrideFromMongeezProperties() {
    String mongoDatabase = "foo";
    String mongeezOverrideDatabase = "bar";
    EnvironmentTestUtils.addEnvironment(this.context, "spring.data.mongodb.database:" + mongoDatabase);
    EnvironmentTestUtils.addEnvironment(this.context, "mongeez.database:" + mongeezOverrideDatabase);
    registerAndRefresh(DoNotExecuteMongeezPostProcessor.class,
            MongoAutoConfiguration.class, MongeezAutoConfiguration.class);
    Mongeez mongeez = this.context.getBean(Mongeez.class);
    Object mongeezActualDatabase = ReflectionTestUtils.getField(mongeez, "dbName");
    assertThat(mongeezActualDatabase.toString(), equalTo(mongeezOverrideDatabase));
}
 

import org.mongeez.Mongeez; //导入依赖的package包/类
@Test
public void shouldUseAuthenticationDatabaseFromMongoProperties() {
    String database = "foo";
    EnvironmentTestUtils.addEnvironment(this.context, "spring.data.mongodb.authenticationDatabase:" + database);
    EnvironmentTestUtils.addEnvironment(this.context, "mongeez.username:user");
    EnvironmentTestUtils.addEnvironment(this.context, "mongeez.password:pass");
    registerAndRefresh(DoNotExecuteMongeezPostProcessor.class,
            MongoAutoConfiguration.class, MongeezAutoConfiguration.class);
    Mongeez mongeez = this.context.getBean(Mongeez.class);
    String authDb = ((MongoAuth) ReflectionTestUtils.getField(mongeez, "auth")).getAuthDb();
    assertThat(authDb, equalTo(database));
}
 

import org.mongeez.Mongeez; //导入依赖的package包/类
@Test
public void shouldUseAuthenticationDatabaseOverrideFromMongeezProperties() {
    String database = "foo";
    String mongeezOverrideDatabase = "bar";
    EnvironmentTestUtils.addEnvironment(this.context, "spring.data.mongodb.authenticationDatabase:" + database);
    EnvironmentTestUtils.addEnvironment(this.context, "mongeez.authenticationDatabase:" + mongeezOverrideDatabase);
    EnvironmentTestUtils.addEnvironment(this.context, "mongeez.username:user");
    EnvironmentTestUtils.addEnvironment(this.context, "mongeez.password:pass");
    registerAndRefresh(DoNotExecuteMongeezPostProcessor.class,
            MongoAutoConfiguration.class, MongeezAutoConfiguration.class);
    Mongeez mongeez = this.context.getBean(Mongeez.class);
    String authDb = ((MongoAuth) ReflectionTestUtils.getField(mongeez, "auth")).getAuthDb();
    assertThat(authDb, equalTo(mongeezOverrideDatabase));
}
 

import org.mongeez.Mongeez; //导入依赖的package包/类
@Override
public void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException {
    String[] mongeezBeanNames = beanFactory.getBeanNamesForType(Mongeez.class);
    Assert.state(mongeezBeanNames.length == 1);
    BeanDefinition beanDefinition = beanFactory.getBeanDefinition(mongeezBeanNames[0]);
    Assert.state(beanDefinition instanceof RootBeanDefinition);
    ((RootBeanDefinition) beanDefinition).setInitMethodName(null);
}
 

import org.mongeez.Mongeez; //导入依赖的package包/类
@PostConstruct
    private void init() throws Exception {
        //~ Execute database changeset(s)
        log.info("Attempt to execute mongodb changesets..");
        Mongeez mongeez = new Mongeez();
        mongeez.setFile(new ClassPathResource("/mongodb-changesets/mongeez.xml"));
        mongeez.setMongo(mongo());
        mongeez.setDbName(this.dbName);
//        mongeez.process();
    }
 

import org.mongeez.Mongeez; //导入依赖的package包/类
@Test
public void shouldDoNothingIfNoMongoBean() {
    registerAndRefresh(MongeezAutoConfiguration.class);
    assertThat(this.context.getBeanNamesForType(Mongeez.class), emptyArray());
}