JPA 合并似乎不起作用

发布于 2024-07-25 18:27:04 字数 2066 浏览 6 评论 0原文

我正在运行以下代码,根据从 CSV 文件读取的数据更新数据库。 我尝试调试并检查控制台,它正在运行整个 800 条记录。 我没有收到任何错误,但只插入了第一条记录。 如果我使用持久而不是合并,则会收到“无法持久分离对象”错误。

        for (String[] data : dataList) {
            log.debug("Reading data no " + (i++));
            EntityManager em = PersistenceUtil.getAgisDbEntityManager();
            EntityTransaction tr = em.getTransaction();
            tr.begin();

            try {
                AddressEntity address = new AddressEntity();
                updateAddress(data, address);
                em.merge(address);
                //em.persist(address);

                em.flush();
                tr.commit();
            } catch (Exception exc) {
                log.error(exc.getMessage(), exc);
                if (tr.isActive())
                    tr.rollback();
            }
        }

这是我的 updateAddress 方法,基本上它是更新一些字段。

private void updateAddress(String[] data, AddressEntity address) throws NoSuchMethodException, InvocationTargetException, IllegalAccessException {
    //setting the column data
    for (int i = 0; i < data.length; i++) {
        final String column = dataColumns.get(i);
        if (!column.equals("#IGNORE#")) {
            setProperty(address, column, data[i]);
        }
    }
    for (String field : this.defaultColumns.keySet()) {
        if (!field.startsWith("#"))
            setProperty(address, field, this.defaultColumns.get(field));
    }        
}

这是我的 persistence.xml 供您参考。

<persistence-unit name="agisdb-PU">
    <class>com.agis.livedb.domain.AddressEntity</class>
    <properties>
        <property name="toplink.jdbc.url" value="jdbc:mysql://localhost:3306/agisdb"/>
        <property name="toplink.jdbc.driver" value="com.mysql.jdbc.Driver"/>
        <property name="toplink.jdbc.user" value="root"/>
        <property name="toplink.jdbc.password" value="password"/>
    </properties>
</persistence-unit>

你认为我错过了什么吗? 多谢! 罗伯特

I'm running the following code to update the database according to the data I read from CSV file. I've tried to debug, and check the console and it's running through the whole 800 records. I don't get any error, but only the first record is inserted. If I'm using persist instead of merge, I got "Cannot persist detached object" error.

        for (String[] data : dataList) {
            log.debug("Reading data no " + (i++));
            EntityManager em = PersistenceUtil.getAgisDbEntityManager();
            EntityTransaction tr = em.getTransaction();
            tr.begin();

            try {
                AddressEntity address = new AddressEntity();
                updateAddress(data, address);
                em.merge(address);
                //em.persist(address);

                em.flush();
                tr.commit();
            } catch (Exception exc) {
                log.error(exc.getMessage(), exc);
                if (tr.isActive())
                    tr.rollback();
            }
        }

And here is my updateAddress method, basically it's updating some of the fields.

private void updateAddress(String[] data, AddressEntity address) throws NoSuchMethodException, InvocationTargetException, IllegalAccessException {
    //setting the column data
    for (int i = 0; i < data.length; i++) {
        final String column = dataColumns.get(i);
        if (!column.equals("#IGNORE#")) {
            setProperty(address, column, data[i]);
        }
    }
    for (String field : this.defaultColumns.keySet()) {
        if (!field.startsWith("#"))
            setProperty(address, field, this.defaultColumns.get(field));
    }        
}

Here is my persistence.xml for your reference.

<persistence-unit name="agisdb-PU">
    <class>com.agis.livedb.domain.AddressEntity</class>
    <properties>
        <property name="toplink.jdbc.url" value="jdbc:mysql://localhost:3306/agisdb"/>
        <property name="toplink.jdbc.driver" value="com.mysql.jdbc.Driver"/>
        <property name="toplink.jdbc.user" value="root"/>
        <property name="toplink.jdbc.password" value="password"/>
    </properties>
</persistence-unit>

Do you think I missed out something?
Thanks a lot!
Robert

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

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

发布评论

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

评论(2

好听的两个字的网名 2024-08-01 18:27:04

好的,问题出在我的地址实体对象上,我必须将以下内容添加到 id 字段中。
@GenerateValue(strategy=GenerationType.identity)

谢谢 dfa!
罗伯特

Ok, the problem is with my Address Entity object, I have to add the following to the id field.
@GeneratedValue(strategy=GenerationType.identity)

Thanks dfa!
Robert

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