Package org.springframework.data.mongodb.core

Examples of org.springframework.data.mongodb.core.SimpleMongoDbFactory

57
58
59
60
61
62
63
64
65
66
67
  }

  @Test
  public void testWriteConcern() throws Exception {

    SimpleMongoDbFactory dbFactory = new SimpleMongoDbFactory(new MongoClient("localhost"), "database");
    dbFactory.setWriteConcern(WriteConcern.SAFE);
    dbFactory.getDb();

    assertThat(ReflectionTestUtils.getField(dbFactory, "writeConcern"), is((Object) WriteConcern.SAFE));
  }
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
104
    assertThat(db.getWriteConcern(), is(WriteConcern.REPLICAS_SAFE));
    ctx.close();
  }

  private void assertWriteConcern(ClassPathXmlApplicationContext ctx, WriteConcern expectedWriteConcern) {
    SimpleMongoDbFactory dbFactory = ctx.getBean("first", SimpleMongoDbFactory.class);
    DB db = dbFactory.getDb();
    assertThat(db.getName(), is("db"));

    WriteConcern configuredConcern = (WriteConcern) ReflectionTestUtils.getField(dbFactory, "writeConcern");

    MyWriteConcern myDbFactoryWriteConcern = new MyWriteConcern(configuredConcern);
View Full Code Here
104
105
106
107
108
109
110
   * @return
   * @throws Exception
   */
  @Bean
  public MongoDbFactory mongoDbFactory() throws Exception {
    return new SimpleMongoDbFactory(mongo(), getDatabaseName(), getUserCredentials(), getAuthenticationDatabaseName());
  }
View Full Code Here
37
38
39
40
41
42
43
44
  @Produces
  @ApplicationScoped
  public MongoOperations createMongoTemplate() throws UnknownHostException, MongoException {

    MongoDbFactory factory = new SimpleMongoDbFactory(new MongoClient(), "database");
    return new MongoTemplate(factory);
  }
View Full Code Here
45
46
47
48
49
50
51
  @EnableMongoRepositories(basePackages = "org.springframework.data.mongodb.repository")
  static class Config {

    @Bean
    public MongoOperations mongoTemplate() throws Exception {
      return new MongoTemplate(new SimpleMongoDbFactory(new MongoClient(), "database"));
    }
View Full Code Here
126
127
128
129
130
131
132
  @EnableMongoAuditing
  static class SimpleConfigWithRepositories {

    @Bean
    public MongoTemplate mongoTemplate() throws UnknownHostException {
      return new MongoTemplate(new SimpleMongoDbFactory(new MongoClient(), "database"));
    }
View Full Code Here
136
137
138
139
140
141
142
  @EnableMongoAuditing
  static class SimpleConfig {

    @Bean
    public MongoTemplate mongoTemplate() throws UnknownHostException {
      return new MongoTemplate(new SimpleMongoDbFactory(new MongoClient(), "database"));
    }
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
  @Before
  public void setUp() throws Exception {

    this.mongo = new MongoClient();

    SimpleMongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(this.mongo, DATABASE_NAME);

    MongoMappingContext context = new MongoMappingContext();
    context.setInitialEntitySet(Collections.singleton(Person.class));
    context.afterPropertiesSet();

    this.converter = new MappingMongoConverter(new DefaultDbRefResolver(mongoDbFactory), context);
    this.operations = new MongoTemplate(new SimpleMongoDbFactory(this.mongo, DATABASE_NAME), converter);

    MongoRepositoryFactoryBean<PersonRepository, Person, ObjectId> factory = new MongoRepositoryFactoryBean<PersonRepository, Person, ObjectId>();
    factory.setMongoOperations(operations);
    factory.setRepositoryInterface(PersonRepository.class);
    factory.afterPropertiesSet();
View Full Code Here
63
64
65
66
67
68
69
  @Bean
  @ConditionalOnMissingBean
  public MongoDbFactory mongoDbFactory(Mongo mongo) throws Exception {
    String db = this.properties.getMongoClientDatabase();
    return new SimpleMongoDbFactory(mongo, db);
  }
View Full Code Here
20
21
22
23
24
25
26
27
28
29
30
  private static final Log log = LogFactory.getLog(MongoApp.class);

  public static void main(String[] args) throws Exception {
  BasicConfigurator.configure();   
   
    MongoOperations mongoOps = new MongoTemplate(new SimpleMongoDbFactory(new Mongo(), "database"));

    // Insert is used to initially store the object into the database.
    Car c = new Car("Red", "Opel");
    mongoOps.insert(c);
    Person p = new Person("Joe", 34, c);
View Full Code Here
TOP

Related Classes of org.springframework.data.mongodb.core.SimpleMongoDbFactory

  • $.MongoConfig
  • com.degloba.SpringMongoConfig
  • com.github.jknack.mwa.mongo.MongoModule
  • com.hamidh.azad92.flash.config.MongoConfig
  • com.impromptu.config.DataConfig
  • com.mongodb.DB
  • com.mongodb.Mongo
  • com.skymobi.monitor.model.Project
  • com.xybase.demo.config.DataSourceConfiguration
  • org.cloudfoundry.caldecott.client.HttpTunnelTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.