相同的值被多次添加到 db

Question

// LoginDAO，将 UI 值保存到 DB 中的逻辑...正在添加新值并替换旧值

System.out.println("In Vendor registration i.e LoginDAO class::::::::::"+vendorRegistration.getVid()+""+""+vendorRegistration.getFirstName());
                Session session = getSession();                               
                session.beginTransaction();                                                //begin transaction for the session.
                Query query = session.createQuery("UPDATE VendorRegistration set firstName =:firstname,lastName =:lastname,Email =:email,password =:password,Vid =:vid "); 

                query.setParameter("firstname",vendorRegistration.getFirstName());
                query.setParameter("lastname",vendorRegistration.getLastName());
                query.setParameter("email",vendorRegistration.getEmail());
                query.setParameter("password",vendorRegistration.getPassword());
                query.setParameter("vid",vendorRegistration.getVid());              

                int user = query.executeUpdate();

                 session.save(vendorRegistration);
                 System.out.println("user values are ::::::::::::::::::"+user);
                session.getTransaction().commit();                            //here transaction complete with commit the data in db. 
                session.close();



// Controller class

@RequestMapping(value = {"/signup"}, method = RequestMethod.POST)
    public String saveRegAction(@ModelAttribute("signup") @Validated VendorRegistration vendorRegistration, Model model,HttpSession session,BindingResult bindingResult) throws IOException
    {
        System.out.println("the object is:" + model);
        if(bindingResult.hasErrors())
        {
            logger.info("user details===========" +vendorRegistration.getFirstName()+""+vendorRegistration.getLastName()+""+vendorRegistration.getVid()+""+vendorRegistration.getEmail()+""+vendorRegistration.getPassword());
            logger.info("Returning home.jsp page"); 

            model.addAttribute("vendor", new VendorRegistration()); 
            return "signup";
        }
        loginService.saveNewUser(vendorRegistration);
        session.setAttribute("vendorRegistration", vendorRegistration);

        logger.info("in registration page........... save register action");
        return "vendorLogin";

//值保存多次，保留旧值并将新值保存到数据库中

！[这是 DB 的问题][1]][1]

//pojo类

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


    @Id
    @Column(name = "ID")
    @GeneratedValue(strategy = GenerationType.IDENTITY)  
    private long id;


    @Column(name = "VID")
    private String vid;

    @NotBlank
    @Column(name = "FIRSTNAME")
    private String firstName;

    @Column(name = "LASTNAME")
    private String lastName;

    @Column(name = "EMAIL")
    @Email(message="Please Enter Valid Email ID")
    private String email;

    @Column(name ="PASSWORD")
    private String password;
//getters and setters

Answer 1

您的代码中有几处错误/缺陷。首先是你的控制器，它有一个错误的方法签名。

首先修复方法签名，BindingResult 必须直接跟随它适用的方法参数，在您的情况下是 @ModelAttribute 注释元素。

@RequestMapping(value = {"/signup"}, method = RequestMethod.POST)
public String saveRegAction(@ModelAttribute("signup") @Validated VendorRegistration vendorRegistration, BindingResult bindingResult, Model model,HttpSession session,) throws IOException { ... }

您的数据库出现问题是由于您的 service/dao 方法的实现。您首先执行更新查询，最后插入它。因此，首先会更新所有内容，然后插入新记录。您的方法中应该只有session.save 不多不少。

Session session = getSession();                               
session.beginTransaction();                                                 

session.save(vendorRegistration);
session.getTransaction().commit();                           
session.close();

但是，您的代码的其余部分仍然存在缺陷，因为在出​​现错误/异常的情况下，它可能会导致连接池不足。您应该在代码中使用try/catch/finally。 （或者更好地让 Spring 使用 Spring 托管事务为您执行此操作）。

final Session session = getSession();
try {
    session.beginTransaction();
    session.save(vendorRegistration);
    session.getTransaction().commit();                           
} catch (Exception e) {
    session.getTransaction().rollback();
}  finally {       
    session.close();
}

对于与会话一起使用的每种方法，您基本上都需要类似的东西。如果您不这样做，您的Session 可能会闲逛并使用连接池中的连接。如果发生这种情况，您的应用程序将会死掉或开始爬网。

最好使用 Spring 托管事务。

@Transactional
public saveNewUser(VendorRegistration vendorRegistration) {
    sessionFactory.getCurrentSession().save(vendorRegistration);
}

Spring 现在为您管理会话和事务。

专业提示：不要使用普通的休眠，而是使用 JPA 并使用 Spring Data JPA。那么你只需要这个。

interface VendorRegistrationRepository extends JpaRepository<Long, VendorRegistration> {}

没有实现，只有一个接口，一切都为您管理。

Answer 2

你的问题出在

Query query = session.createQuery("UPDATE VendorRegistration set firstName =:firstname,lastName =:lastname,Email =:email,password =:password,Vid =:vid ");

您没有添加 where 子句。所以所有记录都在更新。