org.springframework.boot.ApplicationRunner#org.springframework.data.mongodb.core.MongoOperations源码实例Demo

下面列出了org.springframework.boot.ApplicationRunner#org.springframework.data.mongodb.core.MongoOperations 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： Learning-Spring-Boot-2.0-Second-Edition 文件： InitDatabase.java

@Bean
CommandLineRunner init(MongoOperations operations) {
	return args -> {
		// tag::log[]
		operations.dropCollection(Image.class);

		operations.insert(new Image("1",
			"learning-spring-boot-cover.jpg"));
		operations.insert(new Image("2",
			"learning-spring-boot-2nd-edition-cover.jpg"));
		operations.insert(new Image("3",
			"bazinga.png"));

		operations.findAll(Image.class).forEach(image -> {
			System.out.println(image.toString());
		});
		// end::log[]
	};
}

源代码2 项目： Learning-Spring-Boot-2.0-Second-Edition 文件： InitDatabase.java

@Bean
CommandLineRunner init(MongoOperations operations) {
	return args -> {
		// tag::log[]
		operations.dropCollection(Image.class);

		operations.insert(new Image("1",
			"learning-spring-boot-cover.jpg"));
		operations.insert(new Image("2",
			"learning-spring-boot-2nd-edition-cover.jpg"));
		operations.insert(new Image("3",
			"bazinga.png"));

		operations.findAll(Image.class).forEach(image -> {
			System.out.println(image.toString());
		});
		// end::log[]
	};
}

源代码3 项目： Learning-Spring-Boot-2.0-Second-Edition 文件： InitDatabase.java

@Bean
CommandLineRunner init(MongoOperations operations) {
	return args -> {
		// tag::log[]
		operations.dropCollection(Image.class);

		operations.insert(new Image("1",
			"learning-spring-boot-cover.jpg"));
		operations.insert(new Image("2",
			"learning-spring-boot-2nd-edition-cover.jpg"));
		operations.insert(new Image("3",
			"bazinga.png"));

		operations.findAll(Image.class).forEach(image -> {
			System.out.println(image.toString());
		});
		// end::log[]
	};
}

源代码4 项目： Learning-Spring-Boot-2.0-Second-Edition 文件： InitUsers.java

@Bean
CommandLineRunner initializeUsers(MongoOperations operations) {
	return args -> {
		operations.dropCollection(User.class);

		operations.insert(
			new User(
				null,
				"greg", "turnquist",
				new String[]{"ROLE_USER", "ROLE_ADMIN"}));
		operations.insert(
			new User(
				null,
				"phil", "webb",
				new String[]{"ROLE_USER"}));

		operations.findAll(User.class).forEach(user -> {
			System.out.println("Loaded " + user);
		});
	};
}

源代码5 项目： Learning-Spring-Boot-2.0-Second-Edition 文件： InitDatabase.java

@Bean
CommandLineRunner init(MongoOperations operations) {
	return args -> {
		// tag::log[]
		operations.dropCollection(Image.class);

		operations.insert(new Image("1",
			"learning-spring-boot-cover.jpg"));
		operations.insert(new Image("2",
			"learning-spring-boot-2nd-edition-cover.jpg"));
		operations.insert(new Image("3",
			"bazinga.png"));

		operations.findAll(Image.class).forEach(image -> {
			System.out.println(image.toString());
		});
		// end::log[]
	};
}

源代码6 项目： Learning-Spring-Boot-2.0-Second-Edition 文件： InitDatabase.java

@Bean
CommandLineRunner init(MongoOperations operations) {
	return args -> {
		// tag::log[]
		operations.dropCollection(Image.class);

		operations.insert(new Image("1",
			"learning-spring-boot-cover.jpg"));
		operations.insert(new Image("2",
			"learning-spring-boot-2nd-edition-cover.jpg"));
		operations.insert(new Image("3",
			"bazinga.png"));

		operations.findAll(Image.class).forEach(image -> {
			System.out.println(image.toString());
		});
		// end::log[]
	};
}

源代码7 项目： Learning-Spring-Boot-2.0-Second-Edition 文件： InitDatabase.java

@Bean
CommandLineRunner init(MongoOperations operations) {
	return args -> {
		// tag::log[]
		operations.dropCollection(Image.class);

		operations.insert(new Image("1",
			"learning-spring-boot-cover.jpg"));
		operations.insert(new Image("2",
			"learning-spring-boot-2nd-edition-cover.jpg"));
		operations.insert(new Image("3",
			"bazinga.png"));

		operations.findAll(Image.class).forEach(image -> {
			System.out.println(image.toString());
		});
		// end::log[]
	};
}

源代码8 项目： Learning-Spring-Boot-2.0-Second-Edition 文件： InitDatabase.java

@Bean
CommandLineRunner init(MongoOperations operations) {
	return args -> {
		// tag::log[]
		operations.dropCollection(Image.class);

		operations.insert(new Image("1",
			"learning-spring-boot-cover.jpg"));
		operations.insert(new Image("2",
			"learning-spring-boot-2nd-edition-cover.jpg"));
		operations.insert(new Image("3",
			"bazinga.png"));

		operations.findAll(Image.class).forEach(image -> {
			System.out.println(image.toString());
		});
		// end::log[]
	};
}

源代码9 项目： Learning-Spring-Boot-2.0-Second-Edition 文件： InitDatabase.java

@Bean
CommandLineRunner init(MongoOperations operations) {
	return args -> {
		// tag::log[]
		operations.dropCollection(Image.class);

		operations.insert(new Image("1",
			"learning-spring-boot-cover.jpg"));
		operations.insert(new Image("2",
			"learning-spring-boot-2nd-edition-cover.jpg"));
		operations.insert(new Image("3",
			"bazinga.png"));

		operations.findAll(Image.class).forEach(image -> {
			System.out.println(image.toString());
		});
		// end::log[]
	};
}

源代码10 项目： Learning-Spring-Boot-2.0-Second-Edition 文件： InitDatabase.java

@Bean
CommandLineRunner init(MongoOperations operations) {
	return args -> {
		// tag::log[]
		operations.dropCollection(Image.class);

		operations.insert(new Image("1",
			"learning-spring-boot-cover.jpg", "greg"));
		operations.insert(new Image("2",
			"learning-spring-boot-2nd-edition-cover.jpg", "greg"));
		operations.insert(new Image("3",
			"bazinga.png", "greg"));

		operations.findAll(Image.class).forEach(image -> {
			System.out.println(image.toString());
		});
		// end::log[]
	};
}

源代码11 项目： Learning-Spring-Boot-2.0-Second-Edition 文件： InitDatabase.java

@Bean
CommandLineRunner init(MongoOperations operations) {
	return args -> {
		operations.dropCollection(Image.class);

		operations.insert(new Image("1",
			"learning-spring-boot-cover.jpg"));
		operations.insert(new Image("2",
			"learning-spring-boot-2nd-edition-cover.jpg"));
		operations.insert(new Image("3",
			"bazinga.png"));

		operations.findAll(Image.class).forEach(image -> {
			System.out.println(image.toString());
		});
	};
}

源代码12 项目： Learning-Spring-Boot-2.0-Second-Edition 文件： InitDatabase.java

@Bean
CommandLineRunner init(MongoOperations operations) {
	return args -> {
		// tag::log[]
		operations.dropCollection(Image.class);

		operations.insert(new Image("1",
			"learning-spring-boot-cover.jpg"));
		operations.insert(new Image("2",
			"learning-spring-boot-2nd-edition-cover.jpg"));
		operations.insert(new Image("3",
			"bazinga.png"));

		operations.findAll(Image.class).forEach(image -> {
			System.out.println(image.toString());
		});
		// end::log[]
	};
}

源代码13 项目： Learning-Spring-Boot-2.0-Second-Edition 文件： InitDatabase.java

@Bean
CommandLineRunner init(MongoOperations operations) {
	return args -> {
		// tag::log[]
		operations.dropCollection(Image.class);

		operations.insert(new Image("1",
			"learning-spring-boot-cover.jpg"));
		operations.insert(new Image("2",
			"learning-spring-boot-2nd-edition-cover.jpg"));
		operations.insert(new Image("3",
			"bazinga.png"));

		operations.findAll(Image.class).forEach(image -> {
			System.out.println(image.toString());
		});
		// end::log[]
	};
}

源代码14 项目： spring-five-functional-reactive 文件： WebfluxDemo.java

/**
 * Application runner to initialize a capped collection for {@link Event}s and insert a new {@link Event} every two
 * seconds.
 * 
 * @param operations
 * @param reactiveOperations
 * @return
 */
@Bean
ApplicationRunner onStart(MongoOperations operations, ReactiveMongoOperations reactiveOperations) {

	return args -> {

		CollectionOptions options = CollectionOptions.empty() //
				.capped() //
				.size(2048) //
				.maxDocuments(1000);

		operations.dropCollection(Event.class);
		operations.createCollection(Event.class, options);

		Flux.interval(Duration.ofSeconds(2)) //
				.map(counter -> new Event(LocalDateTime.now())) //
				.flatMap(reactiveOperations::save) //
				.log() //
				.subscribe();
	};
}

源代码15 项目： journaldev 文件： SpringDataMongoDBMain.java

public static void main(String[] args) {
	try {
		MongoClient mongo = new MongoClient(
				MONGO_HOST, MONGO_PORT);
		MongoOperations mongoOps = new MongoTemplate(mongo, DB_NAME);
		Person p = new Person("113", "PankajKr", "Bangalore, India");
		mongoOps.insert(p, PERSON_COLLECTION);

		Person p1 = mongoOps.findOne(
				new Query(Criteria.where("name").is("PankajKr")),
				Person.class, PERSON_COLLECTION);

		System.out.println(p1);
		
		mongoOps.dropCollection(PERSON_COLLECTION);
		mongo.close();
		
	} catch (UnknownHostException e) {
		e.printStackTrace();
	}
}

源代码16 项目： spring-data-dev-tools 文件： MongoDbFixture.java

MongoDbFixture() {

		SpringApplication application = new SpringApplication();
		application.addPrimarySources(Collections.singletonList(MongoDbApplication.class));
		application.setAdditionalProfiles("jpa");
		application.setLazyInitialization(true);

		this.context = application.run();
		
		MongoOperations operations = context.getBean(MongoOperations.class);
		
		operations.dropCollection(Book.class);
		
		IntStream.range(0, Constants.NUMBER_OF_BOOKS) //
			.mapToObj(it -> new Book("title" + it, it)) //
			.forEach(operations::save);
	}

源代码17 项目： spring-data-examples 文件： StoreInitializer.java

@Autowired
public StoreInitializer(StoreRepository repository, MongoOperations operations) throws Exception {

	if (repository.count() != 0) {
		return;
	}

	Iterable<? extends IndexDefinition> indexDefinitions = IndexResolver
			.create(operations.getConverter().getMappingContext())
			.resolveIndexFor(Store.class);
	
	indexDefinitions.forEach(operations.indexOps(Store.class)::ensureIndex);

	List<Store> stores = readStores();
	log.info("Importing {} stores into MongoDB…", stores.size());
	repository.saveAll(stores);
	log.info("Successfully imported {} stores.", repository.count());
}

源代码18 项目： spring-5-examples 文件： ReservationsApplication.java

@Bean
  InitializingBean initializingBean(final ReservationRepository reservations,
                                    final MongoOperations ops) {

    final AtomicLong atomicLong = new AtomicLong(1);
    final LocalDate base = LocalDate.now();

    if (ops.collectionExists(Reservation.class))
      ops.dropCollection(Reservation.class);

    ops.createCollection(Reservation.class, new CollectionOptions(1_000_000_000_000_000L, null, true));

    return () -> Flux.just(1, 2, 3)
                     .map(days -> new Reservation().setCheckIn(base.plusDays(atomicLong.incrementAndGet()))
                                                   .setCheckOut(base.plusDays(atomicLong.incrementAndGet())))
                     .flatMap(reservations::save)
                     .subscribe(r -> {
                       log.info("created: {}", r);
                       ops.executeCommand("db.runCommand({ convertToCapped: 'reservation', size: 1111111111 })");
                     });

/*
    return () -> Flux.just(1, 2)
                     .map(String::valueOf)
                     .map(string -> new Reservation().setCheckIn(LocalDate.now())
                                                     .setCheckOut(LocalDate.now().plusDays(1)))
                     .flatMap(reservations::save)
                     .subscribe(r -> log.info("created: {}", r));
*/
/*
    return () -> reservations.deleteAll()
                             .thenMany(
                                 Flux.just(1, 2)
                                     .map(String::valueOf)
                                     .map(string -> new Reservation().setCheckIn(LocalDate.now())
                                                                     .setCheckOut(LocalDate.now().plusDays(1)))
                                     .flatMap(reservations::save))
                             .subscribe(r -> log.info("created: {}", r));
*/
  }

源代码19 项目： service-block-samples 文件： MongoConfig.java

@Bean
CommandLineRunner commandLineRunner(MongoOperations operations) {
    return (args) -> {
        // Setup the streaming data endpoint
        if (operations.collectionExists("tightCouplingEvent")) {
            operations.dropCollection("tightCouplingEvent");
        }
        if (operations.collectionExists("query")) {
            operations.dropCollection("query");
        }

        CollectionOptions options = new CollectionOptions(5242880, 100000, true);
        operations.createCollection("tightCouplingEvent", options);
    };
}

源代码20 项目： attic-rave 文件： MongoDbAuthorityRepositoryTest.java

@Before
public void setup() {
    template = createMock(MongoOperations.class);
    converter = createNiceMock(HydratingConverterFactory.class);
    repo = new MongoDbAuthorityRepository();
    repo.setTemplate(template);
    repo.setConverter(converter);

}

源代码21 项目： OpenLRW 文件： EventService.java

@Autowired
public EventService(
        TenantRepository tenantRepository,
        MongoEventRepository mongoEventRepository,
        UserIdConverter userIdConverter,
        ClassIdConverter classIdConverter,
        MongoOperations mongoOperations,
        MongoEnrollmentRepository mongoEnrollmentRepository) {
  this.tenantRepository = tenantRepository;
  this.mongoEventRepository = mongoEventRepository;
  this.userIdConverter = userIdConverter;
  this.classIdConverter = classIdConverter;
  this.mongoOps = mongoOperations;
  this.mongoEnrollmentRepository = mongoEnrollmentRepository;
}

源代码22 项目： attic-rave 文件： MongoDbPortalPreferenceRepositoryTest.java

@Before
public void setup(){
    preferenceRepository = new MongoDbPortalPreferenceRepository();
    template = createMock(MongoOperations.class);
    converter = createMock(HydratingConverterFactory.class);
    preferenceRepository.setConverter(converter);
    preferenceRepository.setTemplate(template);
}

源代码23 项目： mongodb-aggregate-query-support 文件： AggregateMongoQuery.java

/**
 * Creates a new {@link AbstractMongoQuery} from the given {@link MongoQueryMethod} and {@link MongoOperations}.
 *
 * @param method must not be {@literal null}.
 * @param projectionFactory - the projection factory
 */
@Autowired
public AggregateMongoQuery(Method method, RepositoryMetadata metadata, MongoOperations mongoOperations,
                           ProjectionFactory projectionFactory, MongoQueryExecutor queryExecutor) {
  super(new MongoQueryMethod(method, metadata, projectionFactory, mongoOperations.getConverter().getMappingContext()),
        mongoOperations);
  this.mongoOperations = mongoOperations;
  this.method = method;
  this.queryExecutor = queryExecutor;
}

源代码24 项目： mongodb-aggregate-query-support 文件： NonReactiveAggregateMongoQuery.java

/**
 * Creates a new {@link AbstractMongoQuery} from the given {@link MongoQueryMethod} and {@link MongoOperations}.
 *
 * @param method must not be {@literal null}.
 * @param projectionFactory - the projection factory
 */
@Autowired
public NonReactiveAggregateMongoQuery(Method method, RepositoryMetadata metadata, MongoOperations mongoOperations,
                                      ProjectionFactory projectionFactory, MongoQueryExecutor queryExecutor) {
  super(new MongoQueryMethod(method, metadata, projectionFactory, mongoOperations.getConverter().getMappingContext()),
        mongoOperations,
        new SpelExpressionParser(),
        CONTEXT_PROVIDER);
  this.mongoOperations = mongoOperations;
  this.method = method;
  this.queryExecutor = queryExecutor;
}

源代码25 项目： attic-rave 文件： MongoDbAuthorityRepositoryTest.java

@Test
public void setTemplate(){
    MongoOperations temp1 = createNiceMock(MongoOperations.class);

    repo.setTemplate(temp1);
    assertThat(repo.getTemplate(), is(sameInstance(temp1)));

}

源代码26 项目： attic-rave 文件： MongoDbAuthorityRepositoryTest.java

@Test
public void getTemplate(){
    MongoOperations temp1;

    temp1 = repo.getTemplate();
    assertThat(temp1, is(sameInstance(template)));
}

源代码27 项目： attic-rave 文件： MongoDbCategoryRepositoryTest.java

@Before
public void setup(){
    categoryRepository = new MongoDbCategoryRepository();
    template = createMock(MongoOperations.class);
    converter = createMock(HydratingConverterFactory.class);
    categoryRepository.setConverter(converter);
    categoryRepository.setTemplate(template);
}

源代码28 项目： sinavi-jfw 文件： TestMongoKeeper.java

/**
 * MongoDBを初期化します。
 * @param context 現在のテスト実行コンテキスト
 * @param config コンフィグ
 */
protected void initialize(TestContext context, MongoInitialize config) {
    String[] candidates = createFileLocationCandidates(context, config);
    MongoOperations operations = findMongoOperations(context, config);
    Class<?> mapping = findMapping(context, config);
    truncate(operations, config);
    if (mapping != Void.class) {
        String content = readJsonFile(candidates, context, config);
        Object executables = createExecutables(content, mapping);
        insert(operations, executables, config);
    }
}

源代码29 项目： sinavi-jfw 文件： TestMongoKeeper.java

/**
 * {@link MongoInitialize#truncate()}で<code>true</code>が指定されたときにMongoDBより指定されたCollectionをすべて削除します。
 * @param operations {@link MongoOperations}
 * @param config {@link MongoInitialize}
 */
protected void truncate(MongoOperations operations, MongoInitialize config) {
    if (config.truncate()) {
        L.info(Strings.substitute(R.getString("I-MONGO-TEST#0002"), Maps.hash("collectionName", config.collectionName())));
        operations.dropCollection(findCollectionName(config));
    }
}

源代码30 项目： sinavi-jfw 文件： TestMongoKeeper.java

/**
 * テストデータをMongoDBに登録します。
 * @param operations {@link MongoOperations}
 * @param executables 登録するJSONデータ
 * @param config {@link MongoInitialize}
 */
protected void insert(MongoOperations operations, Object executables, MongoInitialize config) {
    L.info(Strings.substitute(R.getString("I-MONGO-TEST#0003"), Maps.hash("value", executables.toString())));
    if (executables.getClass().isArray()) {
        List<Object> gen = Lists.gen((Object[])executables);
        operations.insert(gen, findCollectionName(config));
    } else {
        operations.insert(executables, findCollectionName(config));
    }
}

方法所在类

org.springframework.boot.ApplicationRunner