java - spring jpa setup 无法更新数据库

Question

我是一个长期的读者，第一次海报。

本质上，我正在编写一个基于 spring 3 showcase 的网络应用程序。 .

随后，我插入了基于 this tutorial 写入数据库的功能。 .

我测试所有 ORM 内容的集成测试看起来很开心，但是当我将项目部署到 tomcat 并尝试通过网站进行数据库更新时，数据库不会更新!

配置:

appContext.xml

<!-- holding properties for database connectivity / -->
<context:property-placeholder location="classpath:jdbc.properties" />
<!-- enabling annotation driven configuration / -->
<context:annotation-config />
<context:component-scan base-package="wcpackage" />
<tx:annotation-driven transaction-manager="transactionManager" />

<bean class="org.springframework.orm.jpa.support.PersistenceAnnotationBeanPostProcessor" />

<bean id="dataSource"
    class="org.springframework.jdbc.datasource.DriverManagerDataSource"
    p:driverClassName="${jdbc.driverClassName}" p:url="${jdbc.url}" />

<bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager"
    p:entityManagerFactory-ref="entityManagerFactory" />

<bean id="entityManagerFactory"
    class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"
    p:dataSource-ref="dataSource" p:jpaVendorAdapter-ref="jpaAdapter">
    <property name="loadTimeWeaver">
        <bean
            class="org.springframework.instrument.classloading.InstrumentationLoadTimeWeaver" />
    </property>
    <property name="persistenceUnitName" value="wctemplatePU"></property>
</bean>

<bean id="jpaAdapter"
    class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter"
    p:showSql="${jpa.showSql}" />

jdbc.properties

jpa.database=gm
jpa.showSql=true
jdbc.driverClassName=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/gm?user=gmuser&password=gmuser

持久性.xml

<persistence xmlns="http://java.sun.com/xml/ns/persistence"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/persistence">

<persistence-unit name="wctemplatePU" transaction-type="RESOURCE_LOCAL">
    <properties>
        <property name="hibernate.hbm2ddl.auto" value="validate" />
    </properties>
</persistence-unit>

应该提交到数据库的代码

    @Transactional(propagation=Propagation.REQUIRED, rollbackFor=Exception.class)
protected Sequence persistGame(PGNGame game) {
    Sequence seq = new Sequence();
    seq.setType(SequenceType.GAME);
    seq.setEvent(game.getTag("Event"));
    seq.setSite(game.getTag("Site"));

            ...

    sequenceDao.persist(seq);

    return seq;
}

SequenceDao 本质上是

public abstract class JpaDao<K, E> implements Dao<K, E> {
protected Class<E> entityClass;

@PersistenceContext
protected EntityManager entityManager;

public JpaDao() {
    ParameterizedType genericSuperclass = (ParameterizedType) getClass().getGenericSuperclass();
    this.entityClass = (Class<E>) genericSuperclass.getActualTypeArguments()[1];
}

public void persist(E entity) { entityManager.persist(entity); }

public void remove(E entity) { entityManager.remove(entity); }

public E findById(K id) { return entityManager.find(entityClass, id); }
}

我没有在控制台/日志中看到任何类型的错误。我究竟做错了什么？

当我将 hibernate 日志记录到 DEBUG 时，我注意到一件事

DEBUG:org.springframework.orm.jpa.SharedEntityManagerCreator$SharedEntityManagerInvocationHandler - Creating new EntityManager for shared EntityManager invocation
    DEBUG: org.hibernate.impl.SessionImpl - opened session at timestamp: 12975078282
    DEBUG: org.hibernate.event.def.AbstractSaveEventListener - delaying identity-insert due to no transaction in progress
    DEBUG: org.hibernate.event.def.AbstractSaveEventListener - delaying identity-insert due to no transaction in progress
    DEBUG: org.springframework.orm.jpa.EntityManagerFactoryUtils - Closing JPA EntityManager

TRACE 日志是

DEBUG:org.springframework.orm.jpa.SharedEntityManagerCreator$SharedEntityManagerInvocationHandler - Creating new EntityManager for shared EntityManager invocation
DEBUG: org.hibernate.impl.SessionImpl - opened session at timestamp: 12975085724
TRACE: org.hibernate.engine.IdentifierValue - id unsaved-value: 0
TRACE: org.hibernate.event.def.AbstractSaveEventListener - transient instance of: net.samuelbergin.gm.model.Player
TRACE: org.hibernate.event.def.DefaultPersistEventListener - saving transient instance
TRACE: org.hibernate.event.def.AbstractSaveEventListener - saving [net.samuelbergin.gm.model.Player#<null>]
TRACE: org.hibernate.engine.Cascade - processing cascade ACTION_PERSIST_SKIPLAZY for: net.samuelbergin.gm.model.Player
TRACE: org.hibernate.engine.Cascade - done processing cascade ACTION_PERSIST_SKIPLAZY for: net.samuelbergin.gm.model.Player
TRACE: org.hibernate.event.def.WrapVisitor - Wrapped collection in role: net.samuelbergin.gm.model.Player.sequenceList
DEBUG: org.hibernate.event.def.AbstractSaveEventListener - delaying identity-insert due to no transaction in progress
TRACE: org.hibernate.engine.Cascade - processing cascade ACTION_PERSIST_SKIPLAZY for: net.samuelbergin.gm.model.Player
TRACE: org.hibernate.engine.Cascade - cascade ACTION_PERSIST_SKIPLAZY for collection: net.samuelbergin.gm.model.Player.sequenceList
TRACE: org.hibernate.engine.CascadingAction - cascading to persist: net.samuelbergin.gm.model.Sequence
TRACE: org.hibernate.engine.IdentifierValue - id unsaved-value: 0
TRACE: org.hibernate.event.def.AbstractSaveEventListener - transient instance of: net.samuelbergin.gm.model.Sequence
TRACE: org.hibernate.event.def.DefaultPersistEventListener - saving transient instance
TRACE: org.hibernate.event.def.AbstractSaveEventListener - saving [net.samuelbergin.gm.model.Sequence#<null>]
TRACE: org.hibernate.engine.Cascade - processing cascade ACTION_PERSIST_SKIPLAZY for: net.samuelbergin.gm.model.Sequence
TRACE: org.hibernate.engine.Cascade - done processing cascade ACTION_PERSIST_SKIPLAZY for: net.samuelbergin.gm.model.Sequence
TRACE: org.hibernate.event.def.WrapVisitor - Wrapped collection in role: net.samuelbergin.gm.model.Sequence.commentList
TRACE: org.hibernate.engine.IdentifierValue - id unsaved-value: 0
DEBUG: org.hibernate.event.def.AbstractSaveEventListener - delaying identity-insert due to no transaction in progress
TRACE: org.hibernate.engine.Cascade - processing cascade ACTION_PERSIST_SKIPLAZY for: net.samuelbergin.gm.model.Sequence
TRACE: org.hibernate.engine.Cascade - cascade ACTION_PERSIST_SKIPLAZY for collection: net.samuelbergin.gm.model.Sequence.commentList
TRACE: org.hibernate.engine.Cascade - done cascade ACTION_PERSIST_SKIPLAZY for collection: net.samuelbergin.gm.model.Sequence.commentList
TRACE: org.hibernate.engine.Cascade - done processing cascade ACTION_PERSIST_SKIPLAZY for: net.samuelbergin.gm.model.Sequence
TRACE: org.hibernate.engine.Cascade - done cascade ACTION_PERSIST_SKIPLAZY for collection: net.samuelbergin.gm.model.Player.sequenceList
TRACE: org.hibernate.engine.Cascade - done processing cascade ACTION_PERSIST_SKIPLAZY for: net.samuelbergin.gm.model.Player
DEBUG: org.springframework.orm.jpa.EntityManagerFactoryUtils - Closing JPA EntityManager
TRACE: org.hibernate.impl.SessionImpl - closing session

实体定义

@Entity
@Table(name="sequences")
public class Sequence {
    @Id
    @GeneratedValue
    private int id;
    @Enumerated(EnumType.STRING)
    private SequenceType type;
    private String event;
    private String site;
    @Temporal(TemporalType.DATE)
    private Date date;
    private int round;
    private String result;
    private String eco;
    private String description;
    private String moves;
    @ManyToOne
    private Player whitePlayer;
    @ManyToOne
    private Player blackPlayer;
    @OneToMany(cascade={CascadeType.ALL})
    @JoinTable(name="sequenceComments",
            joinColumns={@JoinColumn(name="sequence_fk")},
            inverseJoinColumns={@JoinColumn(name="comment_fk")})
    private List<Comment> commentList = new ArrayList<Comment>();
        ...

Controller

@Controller
@RequestMapping("/fileupload")
public class FileUploadController {

    private static Logger logger = LoggerFactory.getLogger(FileUploadController.class);

    @Autowired private SequenceService sequenceService;

    @RequestMapping(method=RequestMethod.POST)
    public void processUpload(@RequestParam MultipartFile file, HttpServletRequest request, Model model) throws IOException {
        //TODO: parse pgn
        List<PGNGame> pgnGameList;
        String filename = file.getOriginalFilename();
        try {
            pgnGameList = PGNProcessor.parse(file.getInputStream());

            sequenceService.createSequences(pgnGameList);

            String message = "File '" + filename + "' uploaded successfully";
            model.addAttribute("message", new Message(MessageType.success, message));

        } catch (PGNProcessorException ppe) {
            logger.error("Failed to process "+filename, ppe);
            model.addAttribute("message", new Message(MessageType.error, "Failed to process "+filename+".  Reason: "+ppe.getMessage()));
        }
        // else whole html pg is rendered instead of just a div to update
        model.addAttribute("ajaxRequest", AjaxUtils.isAjaxUploadRequest(request));  
    }
}

服务

public class JpaSequenceService implements SequenceService {

    ...

public List<Sequence> createSequences(List<PGNGame> gameList) {
    List<Sequence> seqList = new ArrayList<Sequence>();
    for (PGNGame game : gameList) {
        Sequence seq = persistGame(game);
        seqList.add(seq);
    }
    return seqList;
}

@Transactional(propagation=Propagation.REQUIRED, rollbackFor=Exception.class)
protected Sequence persistGame(PGNGame game) {
        /*...as above...*/
}

Answer 1

@Transactional仅在将其放置在从其他对象(而不是在同一对象内)调用的公共(public)方法上时才有效。

通过围绕对象创建代理来处理事务。来自外部的调用被代理拦截，因此启动事务。代理不会拦截同一对象内的调用。

所以在你的情况下:

@Transactional(propagation=Propagation.REQUIRED, rollbackFor=Exception.class)
public List<Sequence> createSequences(List<PGNGame> gameList) {

请注意，将工作单元包装在事务中通常是一种好习惯。即使您的代码有效，它也会不必要地打开和关闭多个事务。除非你想单独坚持每场比赛。如果是这种情况，那么要么在 Controller 中迭代列表，要么创建一个新类来保存游戏。

正如 Augusto 所说，如果您使用 proxy-target-class="true"对于您的代理，您可以通过内部调用启动事务。但是我不鼓励这样做，因为您越来越依赖此配置选项，并且如果您将来出于其他原因进行更改，您可能会浪费时间查找现有功能停止工作的原因。