调用repositry上下文不包含key时的Micronaut错误：io.micronaut.tx.STATUS

Question

import io.micronaut.core.annotation.NonNull;
import io.micronaut.data.annotation.GeneratedValue;
import io.micronaut.data.annotation.Id;
import io.micronaut.data.annotation.MappedEntity;
import io.micronaut.data.model.query.builder.sql.Dialect;
import io.micronaut.data.r2dbc.annotation.R2dbcRepository;
import io.micronaut.data.repository.reactive.ReactiveStreamsCrudRepository;
import io.micronaut.http.annotation.Body;
import io.micronaut.http.annotation.Controller;
import io.micronaut.http.annotation.Get;
import io.micronaut.http.annotation.Post;
import io.micronaut.runtime.Micronaut;
import lombok.RequiredArgsConstructor;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public class Application {
    public static void main(String[] args) {
        Micronaut.run(Application.class, args);
    }
}

@Controller
@RequiredArgsConstructor
class CustomerController {

    private final CustomerRepository customerRepository;

    @Get
    public Flux<Customer> getAll() {
        return customerRepository.findAll();
    }

    @Get("/test")
    public Mono<Customer> test() {
        return Mono.from(customerRepository.findById(1L)).map(e -> {
            System.out.println(e);
            return e;
        });
//        System.out.println(customerRepository);
//        return Mono.just("TEST");
    }

    @Post
    public Mono<Customer> create(@Body Customer customer) {
        Customer saveCustomer = new Customer(customer.getName(), customer.getSurname());

        return Mono.from(customerRepository.save(saveCustomer));
    }
}

//@R2dbcRepository(dialect = Dialect.SQL_SERVER)
interface CustomerRepository extends ReactiveStreamsCrudRepository<Customer, Long> {
    //    @NonNull
//    @Override
//    Mono<Customer> findById(@NonNull @NotNull Long id);
//
//    @NonNull
//    @Override
//    Mono<Customer> save(@NonNull @NotNull Customer customer);
//
    @NonNull
    @Override
    Flux<Customer> findAll();
}


@MappedEntity("customer")
class Customer {
    @Id
    @GeneratedValue
    private Long id;


    private final String name;
    private final String surname;

    public Customer(String name, String surname) {
        this.name = name;
        this.surname = surname;
    }

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public String getSurname() {
        return surname;
    }

}

**试图通过终结点调用存储库，但始终出现错误**

Context does not contain key: io.micronaut.tx.STATUS
    at reactor.util.context.Context1.get(Context1.java:67)
    at io.micronaut.data.r2dbc.operations.DefaultR2dbcRepositoryOperations.lambda$withTransaction$27(DefaultR2dbcRepositoryOperations.java:441)
    at reactor.core.publisher.FluxDeferContextual.subscribe(FluxDeferContextual.java:49)
    at reactor.core.publisher.InternalFluxOperator.subscribe(InternalFluxOperator.java:62)
    at reactor.core.publisher.FluxDefer.subscribe(FluxDefer.java:54)
    at reactor.core.publisher.InternalFluxOperator.subscribe(InternalFluxOperator.java:62)

Answer 1

我在micronaut 3上遇到了同样的问题。经过一些测试后，我发现，在我的具体情况下，这个问题是由使用以下模块引起的:

micronaut-security-jwt
micronaut-reactor
micronaut-jackson-xml

如果删除所有这些依赖项，问题就会消失。我认为这个问题是由上述微型机器人模块引起的，所以我在微型机器人-r2dbc github页面上打开了一个问题，希望他们尽快解决这个问题。

编辑：他们修复了这个bug发布了新的micronaut版本3.0.1！！！

Answer 2

我遇到了同样的问题。

检查这个：

@Get
    public Flowable<Customer> getAll() {
        return Flowable.fromPublisher(customerRepository.findAll());
    }

以及哪里是< code > Mono use < code > single . from publisher(your Mono)