将新实体持久保存到现有数据库 JPA

发布于 2024-12-01 14:40:39 字数 3497 浏览 1 评论 0原文

我已经创建了一个数据库连接和一些实体,现在我正在尝试测试数据库的功能。我有一个 User 实体类,它有一个唯一的用户名以及一些其他信息。现在我正在尝试简单地创建一个新的用户和配置文件并将它们映射在一起,然后保留它们。当我测试代码时,它成功运行,但数据库没有更新。这就是我所拥有的:

package servlets;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

import javax.annotation.Resource;
import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.Persistence;
import javax.persistence.PersistenceUnit;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.transaction.UserTransaction;

import entities.Profile;
import entities.User;


@WebServlet("/NewUser")
public class NewUser extends HttpServlet {

    @Resource
    UserTransaction utx;
    @PersistenceUnit
    EntityManagerFactory emf;

    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        String username = request.getParameter("username");
        String email = request.getParameter("email");
        String firstname = request.getParameter("firstname");
        String lastname = request.getParameter("lastname");
        String phone = request.getParameter("phone");
        String address1 = request.getParameter("address1");
        String address2 = request.getParameter("address2");


        try {
            utx.begin();
            EntityManager em = emf.createEntityManager();

            //create User & Profile
            User u = new User();
            u.setUsername(username);
            Profile p = new Profile();
            p.setUser(username);

            //add email to profile's list
            List<String> emails = new ArrayList<String>();
            emails.add(email);
            p.setEmails(emails);

            //assign the profile to the user
            u.setProfile(p);

            //persist user to the database
            em.persist(u);
            utx.commit();

            em.close();
            emf.close();
        } catch (Exception e) {
            e.printStackTrace();
        }

        response.sendRedirect("index.jsp");
    }
}

我做错了什么还是应用程序中的其他地方有问题?

编辑:我发现以下错误:异常描述:无法从驱动程序 [null]、用户 [null] 和 URL [null] 获取连接。验证您是否已设置预期的驱动程序类和 URL。检查您的登录名、persistence.xml 或sessions.xml 资源。 jdbc.driver 属性应该设置为与您的数据库平台兼容的类,

但是我不确定如何处理该错误,但是...我已经检查了我的数据库连接,一切似乎都按顺序进行。 :/

我的 persistence.xml 文件:

<?xml version="1.0" encoding="UTF-8"?>
<persistence version="2.0" 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 http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd">
    <persistence-unit name="myPersistenceUnit" >
    <jta-data-source>jdbc/mydatasource</jta-data-source>
        <class>entities.User</class>
        <class>entities.Profile</class>
        <class>entities.Message</class>
        <class>entities.Image</class>
        <properties>
            <property name="eclipselink.ddl-generation" value="create-tables"/>
            <property name="eclipselink.ddl-generation.output-mode" value="both"/>
        </properties>
    </persistence-unit>
</persistence>

I've created a database connection and some entities, now I'm trying to test the functionality of my database. I have a User entity class, which has a unique username along with some other information. Right now I'm trying to simply create a new User and Profile and map them together, then persist them. When I test the code, it successfully runs through, but the DB is not updated. Here's what I have:

package servlets;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

import javax.annotation.Resource;
import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.Persistence;
import javax.persistence.PersistenceUnit;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.transaction.UserTransaction;

import entities.Profile;
import entities.User;


@WebServlet("/NewUser")
public class NewUser extends HttpServlet {

    @Resource
    UserTransaction utx;
    @PersistenceUnit
    EntityManagerFactory emf;

    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        String username = request.getParameter("username");
        String email = request.getParameter("email");
        String firstname = request.getParameter("firstname");
        String lastname = request.getParameter("lastname");
        String phone = request.getParameter("phone");
        String address1 = request.getParameter("address1");
        String address2 = request.getParameter("address2");


        try {
            utx.begin();
            EntityManager em = emf.createEntityManager();

            //create User & Profile
            User u = new User();
            u.setUsername(username);
            Profile p = new Profile();
            p.setUser(username);

            //add email to profile's list
            List<String> emails = new ArrayList<String>();
            emails.add(email);
            p.setEmails(emails);

            //assign the profile to the user
            u.setProfile(p);

            //persist user to the database
            em.persist(u);
            utx.commit();

            em.close();
            emf.close();
        } catch (Exception e) {
            e.printStackTrace();
        }

        response.sendRedirect("index.jsp");
    }
}

Am I doing something wrong or is the problem somewhere else in the application?

EDIT: I found the following error: Exception Description: Unable to acquire a connection from driver [null], user [null] and URL [null]. Verify that you have set the expected driver class and URL. Check your login, persistence.xml or sessions.xml resource. The jdbc.driver property should be set to a class that is compatible with your database platform

I'm not sure what to make of the error, however...I've checked my db connection and everything seems to be in order. :/

My persistence.xml file:

<?xml version="1.0" encoding="UTF-8"?>
<persistence version="2.0" 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 http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd">
    <persistence-unit name="myPersistenceUnit" >
    <jta-data-source>jdbc/mydatasource</jta-data-source>
        <class>entities.User</class>
        <class>entities.Profile</class>
        <class>entities.Message</class>
        <class>entities.Image</class>
        <properties>
            <property name="eclipselink.ddl-generation" value="create-tables"/>
            <property name="eclipselink.ddl-generation.output-mode" value="both"/>
        </properties>
    </persistence-unit>
</persistence>

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

べ映画 2024-12-08 14:40:39

我从来没有使用过容器管理的事务,但你的 persistence.xml 至少有。

 <persistence-unit name="myPersistenceUnit" transaction-type="JTA">

I have never use container managed transactions but your persistence.xml at least have.

 <persistence-unit name="myPersistenceUnit" transaction-type="JTA">
~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文