我无法在 Jpa 单元测试中从 H2 获取我的数据

Question

我已经设法让我的查询在 Jpa 中验证——这意味着它们正在运行，但它们没有返回任何内容，我不知道为什么。我的 stockdata 表中似乎有数据，因为如果我尝试将相同的数据两次插入我的表中，我会得到“唯一索引或主键违规”，所以我似乎连接到不同的 H2 数据库。

这是我的全部代码，从我尝试开始的 JUnit 测试开始。

如果您没有发现问题，我仍然希望您有任何意见，因为我正在同时学习 Spring 和 Spring Boot，并且希望得到任何指点！谢谢！

// the unit test that fails - but should not (the list comes back empty)
package com.myorg.stockService.stockservice;

import java.util.List;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringRunner;

import com.myorg.stockService.entity.StockData;

@RunWith(SpringRunner.class)
@SpringBootTest
@ContextConfiguration(classes = {StockServiceConfig.class})
public class StockServiceApplicationTests {

    @Autowired
    StockService stockService;

    @Test
    public void contextLoads() {

        //List<StockData> list = stockService.getAllDailyStockData("TNDM");

        List<StockData> list = stockService.findAll();
        assert(list.size() > 0);
    }

}

实体类：

package com.myorg.stockService.entity;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Index;
import javax.persistence.Table;

@Entity
@Table(name = "stockdata",
        indexes = {@Index(name="symbol_interval_type_index", columnList="symbol,intervalType", unique=false)}
)
public class StockData extends AuditModel {

    private static final long serialVersionUID = 1L;

    public static final int DAILY=1;

    private StockKey key;

    @Column
    private float open;

    @Column
    private float high;

    @Column
    private float low;

    @Column
    private float close;

    @Column(columnDefinition="adjusted_close")
    private float adjustedClose;

    @Column
    private int volume;

    @Column(columnDefinition="dividend_amount")
    private float dividendAmount;

    @Column(columnDefinition="split_coefficient")
    private float splitCoefficient;

    public StockData() {}

    public StockData(StockKey key, float open, float high, float low, float close, float adjustedClose, int volume,
            float dividendAmount, float splitCoefficient) {
        super();
        this.key = key;
        this.open = open;
        this.high = high;
        this.low = low;
        this.close = close;
        this.adjustedClose = adjustedClose;
        this.volume = volume;
        this.dividendAmount = dividendAmount;
        this.splitCoefficient = splitCoefficient;
    }

    @Id
    public StockKey getKey() {
        return key;
    }
    public void setKey(StockKey key) {
        this.key = key;
    }
    public float getOpen() {
        return open;
    }
    public void setOpen(float open) {
        this.open = open;
    }
    public float getHigh() {
        return high;
    }
    public void setHigh(float high) {
        this.high = high;
    }
    public float getLow() {
        return low;
    }
    public void setLow(float low) {
        this.low = low;
    }
    public float getClose() {
        return close;
    }
    public void setClose(float close) {
        this.close = close;
    }
    public float getAdjustedClose() {
        return adjustedClose;
    }
    public void setAdjustedClose(float adjustedClose) {
        this.adjustedClose = adjustedClose;
    }
    public int getVolume() {
        return volume;
    }
    public void setVolume(int volume) {
        this.volume = volume;
    }
    public float getDividendAmount() {
        return dividendAmount;
    }
    public void setDividendAmount(float dividendAmount) {
        this.dividendAmount = dividendAmount;
    }
    public float getSplitCoefficient() {
        return splitCoefficient;
    }
    public void setSplitCoefficient(float splitCoefficient) {
        this.splitCoefficient = splitCoefficient;
    }

    @Override
    public String toString() {
        return "\nStockData [key=" + key + ", open=" + open + ", high=" + high + ", low=" + low + ", close=" + close
                + ", adjustedClose=" + adjustedClose + ", volume=" + volume + ", dividendAmount=" + dividendAmount
                + ", splitCoefficient=" + splitCoefficient + "]";
    }   
}

及其复合键：

package com.myorg.stockService.entity;

import java.io.Serializable;
import java.sql.Timestamp;

import javax.persistence.Embeddable;

// This is the composite key class for StockData

@Embeddable
public class StockKey implements Serializable {

    private static final long serialVersionUID = 1L;

    private String symbol;
    private int intervalType;
    private Timestamp ts;

    public StockKey(String symbol, int intervalType, Timestamp timestamp) {

        this.symbol = symbol;
        this.intervalType = intervalType;
        this.ts= timestamp;
    }

    public String getSymbol() {
        return symbol;
    }
    public void setSymbol(String symbol) {
        this.symbol = symbol;
    }
    public int getIntervalType() {
        return intervalType;
    }
    public void setIntervalType(int intervalType) {
        this.intervalType = intervalType;
    }
    public Timestamp getTimestamp() {
        return ts;
    }
    public void setTimestamp(Timestamp timestamp) {
        this.ts = timestamp;
    }

}

完整性审计模型：

package com.myorg.stockService.entity;

import org.springframework.data.annotation.CreatedDate;
import org.springframework.data.annotation.LastModifiedDate;
import org.springframework.data.jpa.domain.support.AuditingEntityListener;

import com.fasterxml.jackson.annotation.JsonIgnoreProperties;

import javax.persistence.*;
import java.io.Serializable;
import java.util.Date;

@MappedSuperclass
@EntityListeners(AuditingEntityListener.class)
@JsonIgnoreProperties(
        value = {"createdAt", "updatedAt"},
        allowGetters = true
)
public abstract class AuditModel implements Serializable {

    private static final long serialVersionUID = 1L;

    @Temporal(TemporalType.TIMESTAMP)
    @Column(name = "created_at", nullable = false, updatable = false)
    @CreatedDate
    private Date createdAt;

    @Temporal(TemporalType.TIMESTAMP)
    @Column(name = "updated_at", nullable = false)
    @LastModifiedDate
    private Date updatedAt;

    public Date getCreatedAt() {
        return createdAt;
    }

    public void setCreatedAt(Date createdAt) {
        this.createdAt = createdAt;
    }

    public Date getUpdatedAt() {
        return updatedAt;
    }

    public void setUpdatedAt(Date updatedAt) {
        this.updatedAt = updatedAt;
    }
}

我的回购类：

package com.myorg.stockService.repository;

import java.util.List;

import javax.transaction.Transactional;

import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.stereotype.Repository;

import com.myorg.stockService.entity.*;

@Repository
@Transactional
public interface StockRepository extends JpaRepository<StockData, StockKey> {

    //@PersistenceContext
    //EntityManager entityManager;

    @Query("Select s from StockData s where s.key.symbol = ?1 AND s.key.intervalType= ?2")
    public List<StockData> getAllStockData(@Param("symbol") String symbol, @Param("intervalType") int intervalType);

}

我的 JUnit 测试用来从以下位置查找所有内容的库存服务类：

package com.myorg.stockService.stockservice;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.myorg.stockService.entity.StockData;
import com.myorg.stockService.repository.StockRepository;


@Service
public class StockService {

    @Autowired
    private StockRepository stockRepository;

    public List<StockData> getAllDailyStockData(String symbol) {

        return stockRepository.getAllStockData(symbol, 1);
    }

    public List<StockData> findAll() {

        return stockRepository.findAll();
    }
}

应用程序类。请注意，断言在 r​​un 方法中也会失败：

package com.myorg.stockService.stockservice;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.domain.EntityScan;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.CommandLineRunner;

@SpringBootApplication
@EntityScan(basePackages = {"com.myorg.stockService"})
public class StockServiceApplication implements CommandLineRunner {

    private Logger logger = LoggerFactory.getLogger(this.getClass());

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

    @Override
    public void run(String... args) throws Exception {

        List<StockData> list = stockService.findAll();
        assert(list.size() > 0);
    }
}

我的 src/main/resources 文件夹下的 3 个文件：

application.properties：

spring.h2.console.enabled=true
spring.jpa.show-sql=true
logging.level.root=warn

data.sql --> 注意- 我也在 src/test/resources 下添加了这个文件，但这没有帮助

INSERT INTO stockdata(symbol,interval_type,ts,open,high,low,close,adjusted_close,volume,dividend_amount, split_coefficient) VALUES
    ('TNDM', 1, parsedatetime('2018-09-14', 'yyyy-MM-dd'), 112.1200, 113.7250, 112.1200, 112.9100, 112.4174, 26055620, 0.0000, 1.0000);

schema.sql：

// schema.sql:
CREATE TABLE stockdata (

    symbol VARCHAR NOT NULL,
    interval_type INT NOT NULL,
    ts TIMESTAMP NOT NULL,
    open DOUBLE NOT NULL,
    high DOUBLE NOT NULL,
    low DOUBLE NOT NULL,
    close DOUBLE NOT NULL,
    adjusted_close DOUBLE NOT NULL,
    volume INT NOT NULL,
    dividend_amount DOUBLE NOT NULL,
    split_coefficient DOUBLE NOT NULL,
    PRIMARY KEY(symbol, interval_type, ts)
);

pom.xml：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.myorg.stockService</groupId>
    <artifactId>stock-service</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>stock-service</name>
    <description>Demo project for Spring Boot</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.0.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>com.h2database</groupId>
            <artifactId>h2</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>


</project>

Answer 1

我尝试发布的代码似乎有一些问题。

1. 我在测试类中看不到用于 ContextConfiguration 的 StockServiceConfig.class。所以我使用了 StockServiceApplication.class。我还在包结构中将其上移了一个级别，以获取组件扫描以找到存储库。

2. 我不认为 schema.sql 正在运行。它只是让 hibernate 做 ddl-auto。在 application.properties 中设置以下内容以停止此操作：

   spring.jpa.hibernate.ddl-auto=none
   

3. schema.sql 中的 CREATE TABLE 之前有一条注释。 Sringboot 似乎将所有这些连接在一起，并将整个事情视为一个单独的注释行。注释后加分号：

   // schema.sql:;
   CREATE TABLE stockdata (
   
      symbol VARCHAR NOT NULL,
      ... etc
   

4. 您的 StockKey 具有 getTimestamp 和 setTimestamp，而字段是 ts（与 schema.sql 匹配）。将这些更改为 getTs 和 setTs，或者为列名提供合适的注释。还需要一个默认构造函数。

5. StockData 扩展了 AuditModel，但您的 schema.sql 没有定义 AuditModel 中的任何列。要么定义列，要么不扩展 AuditModel。