未在Micronaut项目中创建jOOQ DSLContext Bean

Question

我试图在我的Micronaut应用程序中使用jOOQ，并将jOOQ DSLContext作为一个注入bean自动提供给我的构造函数，但它无法找到该bean。

我在application.yml中配置了数据源以连接到postgres db，并声明了如下构造函数：

@Singleton
public class RepositoryImpl implements Repository
{
    private final DSLContext context;

    public RepositoryImpl(DSLContext context)
    {
        this.context = context;
    }
}

datasources:
  default:
    url: "jdbc:postgresql://localhost:5432/my_db"
    username: "user"
    password: "password"
    driver-class-name: "org.postgresql.Driver"

我在我的构建中包含了以下依赖项。gradle

    compile 'io.micronaut.configuration:micronaut-jooq'
    runtime 'org.postgresql:postgresql:42.2.4'

我希望可以访问DSLContext并在RepositoryImpl类中编写查询，但在尝试使用implementation类时，代码失败了，但出现以下异常：

Caused by: io.micronaut.context.exceptions.NoSuchBeanException: No bean of type [org.jooq.DSLContext] exists. Make sure the bean is not disabled by bean requirements (enable trace logging for 'io.micronaut.context.condition' to check) and if the bean is enabled then ensure the class is declared a bean and annotation processing is enabled (for Java and Kotlin the 'micronaut-inject-java' dependency should be configured as an annotation processor).

有没有人能够成功地使用这个bean,就像这里的micronaut-sql指南中所描述的那样？https://micronaut-projects.github.io/micronaut-sql/snapshot/guide/index.html#jooq

Answer 1

dslcontext存在于org.jooq.configuration上，因此首先必须实例化后一个。

您可以定义一个用@factory注释的类，并将javax.sql.datasource注入其包含Micronaut数据源配置的构造函数。之后，您应该在该类中定义一个方法（用@singleton注释），该方法应该返回一个org.jooq.configuration。在此方法中，您可以配置jOOQ，基本上您可以使用defaultconfiguration()，但是您必须通过在其上调用setSQLDialect(SqlDialt.Postgres)来设置您的SQL方言，您还必须设置您的数据源(set(datasource)

import io.micronaut.context.annotation.Factory;
import org.jooq.Configuration;
import org.jooq.SQLDialect;
import org.jooq.impl.DefaultConfiguration;

import javax.inject.Singleton;
import javax.sql.DataSource;

@Factory
public class JooqConfigurationFactory {
    private final DataSource dataSource;

    public JooqConfigurationFactory(DataSource dataSource) {
        this.dataSource = dataSource;
    }

    @Singleton
    public Configuration configuration() {
        DefaultConfiguration configuration = new DefaultConfiguration();
        configuration.setSQLDialect(SQLDialect.POSTGRES);
        configuration.set(dataSource);

        return configuration;
    }
}

您的存储库将如下所示：

import org.jooq.Configuration;
import org.jooq.DSLContext;

public class ExampleRepository {
    private final DSLContext context;

    public ExampleRepository(Configuration config) {
        this.context = config.dsl();
    }
}