时间戳

首页 > 解决方案 > 带有 Postgres 的 Micronaut 数据 (JDBC) 使用 backtics 生成 SQL `

postgresql - 带有 Postgres 的 Micronaut 数据 (JDBC) 使用 backtics 生成 SQL `

问题描述

我的应用程序在 H2 测试数据库中运行良好，但是当我使用 Postgresql 运行它时，它会创建带有反引号的 sql。我错过了什么？

编辑

这是一个环境问题。我有一个测试存储库，它扩展了下面的存储库，但使用了 H2 方言。我无意中把这个 bean 放在了 src.main.java 而不是 src.test.java 中。如果您遇到此问题，请查看使用 H2 的任何测试资源或配置。

INSERT INTO `email_event` (`event_dts`,`category`,`email`,`event`,`sg_template_name`,`template_id`,`template_version_id`,`uid`,`campaign_name`,`major_classification`,`minor_classification`,`sg_event_id`) VALUES (?,?,?,?,?,?,?,?,?,?,?,?)

Postgresql 不喜欢它并且应用程序抛出这个异常：

io.micronaut.data.exceptions.DataAccessException: SQL Error executing INSERT: ERROR: syntax error at or near "`" Position: 13

构建.gradle

我正在使用 Micronaut Data、JDBC、micronaut-hibernate-jpa（用于实体类）、hikari db 连接池和 Postgres jdbc 驱动程序。

dependencies {
    annotationProcessor("io.micronaut.data:micronaut-data-processor")
    implementation("io.micronaut:micronaut-validation")
    implementation("io.micronaut:micronaut-runtime")
    implementation("javax.annotation:javax.annotation-api")
    implementation("io.micronaut:micronaut-http-client")
    implementation("io.micronaut.sql:micronaut-jdbc-hikari")
    implementation("io.micronaut.data:micronaut-data-jdbc")
    compileOnly("io.micronaut.sql:micronaut-hibernate-jpa") //For @Entity
    compileOnly("io.micronaut.spring:micronaut-spring-context")
    runtimeOnly("ch.qos.logback:logback-classic")
    runtimeOnly("com.h2database:h2")
    compile("org.postgresql:postgresql:42.2.16")// <- Tried changing versions with no luck
}

应用程序.yml

我在配置中指定了 POSTGRES 方言（也许我在这里需要更多？）。

datasources:
  default:
    url: jdbc:postgresql://my.dburl.com:5432/my_db
    driverClassName: org.postgresql.Driver
    username: username
    password: supersecret
    dialect: POSTGRES
    auto-commit: true

存储库类

存储库是基本的并重复方言配置。

package com.access.dao;

import com.access.model.EmailEvent;
import io.micronaut.data.jdbc.annotation.JdbcRepository;
import io.micronaut.data.model.query.builder.sql.Dialect;
import io.micronaut.data.repository.CrudRepository;


@JdbcRepository(dialect = Dialect.POSTGRES)
public interface EventRepository extends CrudRepository<EmailEvent, String> {
}

实体类

Entity 类也是基本的。

package com.access.model;

import com.fasterxml.jackson.annotation.JsonProperty;
import io.micronaut.core.annotation.Introspected;
import io.micronaut.data.annotation.Id;
import io.micronaut.data.annotation.MappedEntity;

import javax.annotation.Nullable;
import javax.persistence.Column;
import java.time.Instant;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.util.List;

@Introspected
@MappedEntity
public class EmailEvent {
    @Id
    @JsonProperty("sg_event_id")
    @Column(name = "sg_event_id")
    private String sgEventID;

    private List<String> category;
    @Column
    private String email;
    @Column
    private String event;

    @JsonProperty("sg_template_name")
    @Column(name="sg_template_name")
    @Nullable
    private String sgTemplateName;

    @JsonProperty("template_id")
    @Column(name = "template_id")
    @Nullable
    private String templateID;

    @JsonProperty("template_version_id")
    @Column(name = "template_version_id")
    @Nullable
    private String templateVersionID;

    private Long timestamp;

    @Nullable
    private String uid;

    @JsonProperty("campaign_name")
    @Column(name="campaign_name")
    @Nullable
    private String campaignName;

    @JsonProperty("major_classification")
    @Column(name = "major_classification")
    @Nullable
    private String majorClassification;

    @JsonProperty("minor_classification")
    @Column(name = "minor_classification")
    @Nullable
    private String minorClassification;

    
    @Column(name="event_dts")
    public LocalDateTime getEventDts(){
        return Instant
                .ofEpochSecond(this.timestamp)
                .atZone(
                        ZoneId.of("America/Denver")
                ).toLocalDateTime();
    }

    public String getCategory(){
        return String.join(",", this.category);
    }

    public void setCategory(List<String> category) {
        this.category = category;
    }

    // Other getters/setters
}

标签： postgresqlmicronautmicronaut-data

解决方案

这是我放置测试存储库的位置的问题。我（通过复制生产类）创建了一个测试存储库，用于内存中的 H2 数据库。

@Replaces(EventRepository.class)
@JdbcRepository(dialect = Dialect.H2)
public interface TestEventRepository extends EventRepository {

}

但是，我忽略了将这个类移动到 src.test.java 目录，所以它与生产版本冲突。

推荐阅读