不能自动连线Mongo运算bean

Question

我想创建一个蒙戈上限集合，为此，我在教程中看到，我需要使用蒙戈操作bean。但是我不能自动连接它。

描述：

com中构造函数的参数1。戴蒙。反应性Spring。初始化。ItemDataInitializer需要“org”类型的bean。springframework。数据mongodb。果心找不到MongoOperations。

行动：

考虑在您的配置中定义一个类型为“org.springframework.data.mongodb.core.蒙戈操作”的bean。

build.gradle：

plugins {
    id 'org.springframework.boot' version '2.3.1.RELEASE'
    id 'io.spring.dependency-management' version '1.0.9.RELEASE'
    id 'java'
}

group = 'com.daimon.reactivespring'
version = '0.0.1-SNAPSHOT'
sourceCompatibility = '1.8'

configurations {
    compileOnly {
        extendsFrom annotationProcessor
    }
}

repositories {
    mavenCentral()
}

dependencies {
    implementation 'org.springframework.boot:spring-boot-starter-data-mongodb-reactive'
    implementation 'org.springframework.boot:spring-boot-starter-webflux'
    compileOnly 'org.projectlombok:lombok'
    annotationProcessor 'org.projectlombok:lombok'
    testImplementation('org.springframework.boot:spring-boot-starter-test') {
        exclude group: 'org.junit.vintage', module: 'junit-vintage-engine'
    }
    testImplementation 'de.flapdoodle.embed:de.flapdoodle.embed.mongo'
    testImplementation 'io.projectreactor:reactor-test'
}

test {
    useJUnitPlatform()
    exclude 'com/daimon/reactivespring/fluxmono/**'
}

我需要注入它的类：

@Component
@RequiredArgsConstructor
@Profile("!test")
public class ItemDataInitializer implements CommandLineRunner {

    //@Autowired
    private final ItemReactiveRepository itemReactiveRepository;
    //@Autowired
    private final MongoOperations mongoOperations;

    @Override
    public void run(String... args) throws Exception {
        initialDatSetup();
        createCappedCollection();
    }

    private void initialDatSetup() {
        itemReactiveRepository.deleteAll()
                .thenMany(Flux.fromIterable(initItems()))
                .flatMap(itemReactiveRepository::save)
                .subscribe(item -> System.out.println("Item inserted " + item));
    }

    private List<Item> initItems() {
        return Arrays.asList(new Item(null, "Samsung TV", 200.0),
                new Item(null, "Apple TV", 300.0), new Item(null, "LG TV", 400.0));
    }

    private void createCappedCollection() {
        mongoOperations.dropCollection(ItemCapped.class);
        mongoOperations.createCollection(ItemCapped.class, CollectionOptions.empty().maxDocuments(20).size(50000).capped());
    }
}

谢谢你

Answer 1

尝试添加此构造函数：

    public ItemDataInitializer(ItemReactiveRepository itemReactiveRepository, MongoOperations mongoOperations){
           this.itemReactiveRepository = itemReactiveRepository;
           this.mongoOperations = mongoOperations;
    }

Answer 2

有人建议切换到反应式合作。但由于某些原因，它并没有创造一个封顶的集合。我换成了spring boot 2.2.7。发布版本，它成功了