ReactiveCosmosRepository洗掉功能不起作用

我正在構建一個使用 CosmosDB 作為我的資料庫的 Spring Boot 應用程式。除洗掉功能外，所有功能都有效（創建專案、更新專案、獲取全部、通過 id 獲取...）。他們什么都不做，因為他們的輸出是無效的，所以它也不給我任何日志。

DAO 類：

package projects.trashcanapplication.trashcan.dao;

import com.azure.spring.data.cosmos.core.mapping.Container;
import com.azure.spring.data.cosmos.core.mapping.GeneratedValue;
import com.azure.spring.data.cosmos.core.mapping.PartitionKey;
import org.springframework.data.annotation.Id;
import projects.trashcanapplication.trashcan.models.Address;
import projects.trashcanapplication.trashcan.models.FillStatus;

@Container(containerName = "trashcanData")
public class TrashcanDao{
    @GeneratedValue
    private String attachments;
    private FillStatus fillStatus;
    @GeneratedValue
    private String rid;
    private Address address;
    @Id
    @PartitionKey
    @GeneratedValue
    private String id;
    @GeneratedValue
    private String self;
    @GeneratedValue
    private String etag;
    @GeneratedValue
    private int ts;

    public TrashcanDao(Address address, FillStatus fillStatus) {
        this.fillStatus = fillStatus;
        this.address = address;
    }

    public String getAttachments(){
        return attachments;
    }

    public FillStatus getFillStatus(){
        return fillStatus;
    }

    public String getRid(){
        return rid;
    }

    public Address getAddress(){
        return address;
    }

    public String getId(){
        return id;
    }

    public String getSelf(){
        return self;
    }

    public String getEtag(){
        return etag;
    }

    public int getTs(){
        return ts;
    }
}

存盤庫

package projects.trashcanapplication.trashcan.repositories;

import com.azure.spring.data.cosmos.repository.ReactiveCosmosRepository;
import projects.trashcanapplication.trashcan.dao.TrashcanDao;

public interface TrashcanRepository extends ReactiveCosmosRepository<TrashcanDao, String> {

}

呼叫存盤庫的服務

package projects.trashcanapplication.trashcan.services;

import com.azure.cosmos.models.PartitionKey;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import projects.trashcanapplication.trashcan.dao.TrashcanDao;
import projects.trashcanapplication.trashcan.models.Trashcan;
import projects.trashcanapplication.trashcan.repositories.TrashcanRepository;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

@Slf4j
@Service
@AllArgsConstructor
public class TrashcanServiceImpl implements TrashcanService {
    private final TrashcanRepository trashcanRepository;
    private final TrashcanMapper trashcanMapper;


    public Flux<Trashcan> getAllTrashcans() {
        return trashcanRepository.findAll().map(trashcanMapper::fromDaoToTrashcan);
    }

    public Mono<Trashcan> getTrashcanById(String id) {
        return trashcanRepository.findById(id).map(trashcanMapper::fromDaoToTrashcan);
    }

    public String createTrashcan(Trashcan trashcan) {
        TrashcanDao saveTrashcan = trashcanMapper.fromTrashcanToDao(trashcan);
        trashcanRepository.save(saveTrashcan).subscribe();
        return saveTrashcan.getId();
    }

    public void deleteTrashcan(String id) {
        trashcanRepository.deleteById(id, new PartitionKey(id));
        log.info(String.format("Deleted trashcan %s", id));
    }
}

我臨時設定了一個資料加載器，以便在運行應用程式時用一個專案填充我的資料庫。deleteAll() 函式在這里也不起作用。

package projects.trashcanapplication.trashcan.services;

import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import projects.trashcanapplication.trashcan.dao.TrashcanDao;
import projects.trashcanapplication.trashcan.models.Address;
import projects.trashcanapplication.trashcan.models.FillStatus;
import projects.trashcanapplication.trashcan.repositories.TrashcanRepository;

import javax.annotation.PostConstruct;

@Slf4j
@Component
@AllArgsConstructor
public class DataLoader {
    private final TrashcanRepository trashcanRepository;

    @PostConstruct
    void loadData() {
        Address address1 = new Address("Begijnendijk", "3130", "Liersesteenweg", "181");
        trashcanRepository.deleteAll();
        trashcanRepository.save(new TrashcanDao(address1, FillStatus.EMPTY))
                .flatMap(trashcanRepository::save)
                .thenMany(trashcanRepository.findAll())
                .subscribe(trashcan -> log.info(trashcan.getId().toString()))
        ;
    }
}

uj5u.com熱心網友回復：

您沒有在任何地方訂閱，因此不會執行反應流。

您可以通過手動訂閱來解決該問題：

trashcanRepository.deleteAll().subscribe()

但是，這不是一個好的做法，當然也不是您的做法，DataLoader因為您不能保證執行保存/洗掉邏輯的順序（也許TrashcanDao在您洗掉所有內容之前保存）。

要解決這個問題，您應該創建一個適當的反應流：

trashcanRepository
    .deleteAll()
    .then(trashcanRepository.save(new TrashcanDao(address1, FillStatus.EMPTY)))
    .thenMany(trashcanRepository.findAll())
    // Your previous subscribe() shouldn't compile since it should contain List<TrashcanDao>
    .subscribe(trashcans -> log.info(trashcans.size()));

標籤：爪哇弹簧靴蔚蓝宇宙数据库

上一篇：OpenApi3.0顯示所有HTTP方法

下一篇：無法kill掉redis使用的6379埠