休眠删除操作不更新MySql

Question

我的删除操作没有删除数据库中的重新编码。

我的实体类：

    @Entity  
@Table(name= "User")
public class User {
    @Id
    @GeneratedValue(strategy=GenerationType.AUTO)
    @Column(name="id")
    private int id;  
    private String userName,password,type,fullName; 

    public int getId() {  
        return id;  
    }  
    public void setId(int id) {  
        this.id = id;  
    }  

    public String getFullName() {  
        return fullName;  
    }  
    public void setFullName(String fName) {  
        this.fullName = fName;  
    }

    @Column(name = "USER_ID")
    public String getUserName() {  
        return userName;  
    }  
    public void setUserName(String userName) {  
        this.userName = userName;  
    }  
    public String getPassword() {  
        return password;  
    }  
    public void setPassword(String password) {  
        this.password = password;  
    }     
    public String getType() {  
        return type;  
    }  
    public void setType(String type) {  
        this.type = type;  
    }     



}

    @Entity  
@Table(name= "Cart")
public class Cart {

    @Id
    @GeneratedValue(strategy=GenerationType.AUTO)
    @Column(name="id")
    private int id; 
    private String userName;    
    private String itemSkus;
    private String itemsQuantity;


    public int getId() {  
        return id;  
    }  
    public void setId(int id) {  
        this.id = id;  
    } 

    @OneToOne(cascade = CascadeType.ALL)
    @JoinColumn(name = "USER_ID")
    public String getUserName() {  
        return userName;  
    }  
    public void setUserName(String uName) {  
        this.userName = uName;  
    }

    public String getItems(){
        return this.itemSkus;
    }

    public void setItems(String items){
        this.itemSkus=items;
    }


    public String getItemsQuantity(){
        return this.itemsQuantity;
    }

    public void setItemsQuantity(String itemsQ){
        this.itemsQuantity=itemsQ;
    }



}

购物车的DAO类方法如下：

public int deleteCart(String userID){
    Session currentSession=sessionObject.getSession();
    //String query="from Cart Where  userName :uName";
    String query="DELETE FROM Cart where userName = :uName";

    Query queryResult = currentSession.createQuery(query);
    queryResult.setParameter("uName", userID);

    int result = queryResult.executeUpdate();

    System.out.println("Cart delete result "+result); 

    return result;
}

我尝试在 MySQL 工作台中运行查询，并且表格更新得很好。只有休眠它不更新。

我最终在更新查询结果中有许多结果。

Answer 1

将查询放入事务中，begin 它，execute the delete query 最后是 commit 事务和 rollback 它，当发生错误或异常时：

public int deleteCart(String userID){

    Session currentSession=sessionObject.getSession();
    Transaction tr= currentSession.beginTransaction();
    //String query="from Cart Where  userName :uName";
  try{
    String query="DELETE FROM Cart where userName = :uName";

    Query queryResult = currentSession.createQuery(query);
    queryResult.setParameter("uName", userID);

    int result = queryResult.executeUpdate();
    tr.commit();

    System.out.println("Cart delete result "+result); 

    return result;
  } catch (Exception ex) {
       tr.rollback();
       return null;
  }
}

Answer 2

您的会话需要刷新。像这样printltln在你之前添加这一行。

currentSession.flush();
System.out.println("Cart delete result "+result);