1

我正在尝试使用 Hibernate 的自动版本控制，但是当调用 Session 的更新方法 f 时，我看不到查询的 where 子句中的版本字段，也没有在数据库中增加版本。我可能在做一些根本错误的事情，但是什么？调用 sesssionFactory 的 getCurrentSession 有问题吗？

我有以下实体类：

package dslibweb.model;

import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
import javax.persistence.Version;

@Entity
@Table(name = "dsXCT_Recalls")
public class DsXCT_Recalls {

@Id
public String recallId;

public int version;
public String status;
    //...... more properties.....


@Version
public int getVersion() {
    return version;
}

public void setVersion(int version) {
    this.version = version;
}

public String getRecallId() {
    return recallId;
}

public void setRecallId(String recallId) {
    this.recallId = recallId;
}

public String getStatus() {
    return status;
}

public void setStatus(String status) {
    this.status = status;
}


}

我的控制器：

package recalls.controller;

@Controller
public class RecallsDataController {

@Autowired
RecallsService recallsManager;
@Autowired
AuthenticationService authService;

private static final Logger logger = Logger.getLogger(RecallsDataController.class);
private static final String SAVE_RECALLS = "MODIFY XCT RECALLS";
RecallsGrid recalls;

@RequestMapping(value = "/showRecallsGrid")
@ResponseBody
public RecallsGrid showRecallsGrid( HttpSession session, HttpServletResponse response) {
    recalls = recallsManager.getRecallsDataGrid((String) session.getAttribute("socketToken"), new GridFilters(0, 0, "", "", "", "", ""));
    if (recalls.getError() == null || recalls.getError().equals("")) { // no error
        return recalls;
    } else {
        try {
            response.sendError(HttpServletResponse.SC_BAD_REQUEST, recalls.getError());
        } catch (IOException e) {
            e.printStackTrace();
        }
        return recalls;
    }
}

@RequestMapping(value = "/saveRecalls" , method= RequestMethod.POST)
@ResponseBody
public String saveRecalls( HttpSession session, @RequestParam(value="ids[]", required = false) String [] ids, @RequestParam(value="statuses[]", required = false) String [] statuses){
    boolean result = authService.validateUserAction((String) session.getAttribute("socketToken"), SAVE_RECALLS);
    if(result)
        return recallsManager.saveRecalls(ids, statuses, recalls);
    else 
        return "You do not have authority to perform this action.";
}

}

我在哪里检索 DsXCT_Recalls 的集合并将它们展示给用户。集合存储在控制器中。然后，用户更改一个或多个实体的状态，我调用了recallManager 的saveRecalls 方法，该方法创建了一个仅包含已更改实体的列表（与存储在控制器中的集合相比）。

召回管理器（服务层）是：

package recalls.service.defaultimpl;

@Service("recallManager")
public class HibernateRecallsDataService implements RecallsService {

@Autowired
JsonRpcRequest jsonReq;
@Autowired
JsonRpcSocketWriterReader socketWriterReader;
@Autowired
JsonRpcRequestConstructor reqConstructor;
@Autowired
RecallsDao hibernateRecallsDao;
private static final Logger logger = Logger.getLogger(HibernateRecallsDataService.class);

@Transactional
public RecallsGrid getRecallsDataGrid(String socketToken, GridFilters filters) {
    List<DsXCT_Recalls> recalls = hibernateRecallsDao.findRangeOfRecordsFiltered(filters);
    return new RecallsGrid(recalls);
}

@Transactional()
public String saveRecalls(String[] ids, String[] statuses, RecallsGrid recalls) {

    List<DsXCT_Recalls> recallList = recalls.getRecalls();
    List<DsXCT_Recalls> updatedRecallList = new ArrayList<DsXCT_Recalls>();

    for (int i = 0; i < ids.length; i++) {
        for (DsXCT_Recalls recall : recallList) {
            if (recall.recallId.equals(ids[i])) { // recall is found in the list
                if (!statuses[i].equals(recall.getStatus())) { // status has changed
                    recall.setStatus(statuses[i]);
                    updatedRecallList.add(recall);
                }

            }
        }
    }

    return hibernateRecallsDao.saveAll(updatedRecallList);
}

 }

我的 DAO 的 saveAll 方法通过实体更改调用休眠会话的一种更新方法：

package recalls.dao.hibernate;




@Repository
public class HibernateRecallsDao implements RecallsDao {

@Autowired(required = true)
@Resource(name = "mySessionFactory")
private SessionFactory sessionFactory;

@SuppressWarnings("unchecked")
public List<DsXCT_Recalls> findRangeOfRecordsFiltered(GridFilters filters) {
    return sessionFactory.getCurrentSession().createQuery("from DsXCT_Recalls r WHERE SID = 0 ORDER BY Org, Bank, BIC, SetlDate").list();
}

public String saveAll(List<DsXCT_Recalls> recallList){
    int count = 0;
    for(DsXCT_Recalls recall:recallList){
        sessionFactory.getCurrentSession().update(recall);
        count++;
    }
    return count + " recalls were modified.";
}
}
4

1 回答 1

1

所以显然@Version 必须在属性声明之上，而不是在getter 方法之上。我确信我在某个地方看到了这个。浪费了这么多时间:(

于 2013-01-15T10:26:16.700 回答