java - Spring + hibernate : Initializing database with JUnit doesn't work

Question

我有一个简单的数据库，其中有一个车辆表(使用 MySQL):

create table vehicle (
    vehicle_no varchar(10) not null,
    color varchar(10),
    wheel int,
    seat int,
    primary key (vehicle_no)
) engine = InnoDB;

在Java中，我有DAO对象，它应该查询所有车辆(省略了DAO的其他方法)。该 DAO 应加入现​​有事务或根据需要创建新事务:

@Transactional(propagation=Propagation.REQUIRED, readOnly=false)
public class HibernateVehicleDao implements VehicleDao {

    private SessionFactory sessionFactory;
    @Autowired
    public void setSessionFactory(SessionFactory sessionFactory) {
        this.sessionFactory = sessionFactory;
    }

    @Override
    public List<Vehicle> findAll() {
        return currentSession().createQuery("from Vehicle").list();
    }
}

现在，我已经为 DAO 编写了 JUnit 测试 (JUnit4)。在运行测试方法之前，应将 10 辆车插入数据库，运行后应删除所有车辆。我已经使用 Spring 的 JDBC 单独测试了此行为，一切正常，因此应该不会有问题。

@ContextConfiguration(locations = "/sk/xorty/dataaccess/dataaccess-beans.xml")
public class HibernateVehicleDaoTest extends AbstractTransactionalJUnit4SpringContextTests {

    private static final int COUNT = 10;

    @Autowired
    @Qualifier("hibernateVehicleDao")
    private VehicleDao dao;

    @Before
    public void setUp() {
        String insert = 
                "INSERT INTO VEHICLE (VEHICLE_NO, COLOR, WHEEL, SEAT) VALUES (?, ?, ?, ?)";
        List<Object[]> argsList = new ArrayList<>();
        for (int i = 0; i < COUNT; i++) {
            argsList.add(VehicleUtil.nextVehicleArgs());
        }
        simpleJdbcTemplate.batchUpdate(insert, argsList);
    }

    @After
    public void tearDown() {
        simpleJdbcTemplate.update("DELETE FROM VEHICLE", (Object[]) null);
    }

    @Test
    public void testFindAll() {
        assertEquals (COUNT, dao.findAll().size());
    }
}

一切都会加载，所以我怀疑配置是否正确并且依赖项已正确注入(inject)。

问题是，测试失败，因为数据库为空(没有车辆)。另一方面，当我手动插入它们时，它们永远不会被删除。

请尝试注意使用事务注释，我对此还很陌生，我认为我可能在某个地方犯了错误。

这是我的 bean 配置文件(如果有帮助的话):

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd">

    <context:annotation-config />
    <tx:annotation-driven />

    <!-- shared data source -->
    <bean id="dataSource" 
        class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" 
            value="com.mysql.jdbc.jdbc2.optional.MysqlDataSource" />
        <property name="url" value="jdbc:mysql://localhost/vehicles" />
        <property name="username" value="root" />
        <property name="password" value="" />
    </bean>

    <!-- JDBC transaction manager -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource" />
    </bean>

    <!-- hibernate session factory -->
    <bean id="sessionFactory"
        class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
        <property name="dataSource" ref="dataSource" />
        <property name="annotatedClasses" >
            <list>
                <value>sk.xorty.dataaccess.Vehicle</value>
            </list>
        </property>
        <property name="hibernateProperties">
            <props>
                <prop key="dialect">org.hibernate.dialect.MySQL5InnoDBDialect</prop>
                <prop key="hibernate.show_sql">true</prop>
                <prop key="hibernate.hbm2ddl.auto">update</prop>
            </props>
        </property> 
    </bean>

    <bean id="hibernateVehicleDao" class="sk.xorty.dataaccess.HibernateVehicleDao" />

</beans>

编辑:请求的车辆实体代码:

@Entity
@Table(name="vehicle")
public class Vehicle implements Serializable {

    @Id
    @Column(name="VEHICLE_NO", nullable=false, length=10)
    private String vehicleNo;
    private String color;
    private int wheel;
    private int seat;

    public Vehicle() {}

    public Vehicle(String vehicleNo, String color, int wheel, int seat) {
        this.vehicleNo = vehicleNo;
        this.color = color;
        this.wheel = wheel;
        this.seat = seat;
    }

    public String getVehicleNo() {
        return vehicleNo;
    }

    public void setVehicleNo(String vehicleNo) {
        this.vehicleNo = vehicleNo;
    }

    public String getColor() {
        return color;
    }

    public void setColor(String color) {
        this.color = color;
    }

    public int getWheel() {
        return wheel;
    }

    public void setWheel(int wheel) {
        this.wheel = wheel;
    }

    public int getSeat() {
        return seat;
    }

    public void setSeat(int seat) {
        this.seat = seat;
    }

    @Override
    public String toString() {
        return "Vehicle [vehicleNo=" + vehicleNo + ", color=" + color
                + ", wheel=" + wheel + ", seat=" + seat + "]";
    }

    @Override
    public int hashCode() {
        final int prime = 31;
        int result = 1;
        result = prime * result + ((color == null) ? 0 : color.hashCode());
        result = prime * result + seat;
        result = prime * result
                + ((vehicleNo == null) ? 0 : vehicleNo.hashCode());
        result = prime * result + wheel;
        return result;
    }

    @Override
    public boolean equals(Object obj) {
        if (this == obj)
            return true;
        if (obj == null)
            return false;
        if (getClass() != obj.getClass())
            return false;
        Vehicle other = (Vehicle) obj;
        if (color == null) {
            if (other.color != null)
                return false;
        } else if (!color.equals(other.color))
            return false;
        if (seat != other.seat)
            return false;
        if (vehicleNo == null) {
            if (other.vehicleNo != null)
                return false;
        } else if (!vehicleNo.equals(other.vehicleNo))
            return false;
        if (wheel != other.wheel)
            return false;
        return true;
    }

}

Answer 1

我不确定这是否重要，但以下方法中的大小写不正确:

@Override
public List<Vehicle> findAll() {
    return currentSession().createQuery("from Vehicle").list();
}

表名以“vehicle”中的小写 v 开头，而此方法使用大写“V”。

我从文档中读到的另一件有趣的事情:

simpleJdbcTemplate: useful for querying to confirm state. For example, you might query before and after testing application code that creates an object and persists it using an ORM tool, to verify that the data appears in the database. (Spring will ensure that the query runs in the scope of the same transaction.) You will need to tell your ORM tool to 'flush' its changes for this to work correctly, for example using the flush() method on Hibernate's Session interface.

在执行查询之前尝试刷新 session 。