草庐IT

java - 删除然后创建记录导致Spring Data JPA重复 key 冲突

coder 2024-03-27 原文

因此,在这种情况下,我需要记录头记录,删除它的详细信息,然后以其他方式重新创建详细信息。更新细节将带来太多麻烦。

我基本上有:

@Transactional
public void create(Integer id, List<Integer> customerIDs) {

    Header header = headerService.findOne(id);
    // header is found, has multiple details

    // Remove the details
    for(Detail detail : header.getDetails()) {
        header.getDetails().remove(detail);
    }

    // Iterate through list of ID's and create Detail with other objects
    for(Integer id : customerIDs) {
        Customer customer = customerService.findOne(id);

        Detail detail = new Detail();
        detail.setCustomer(customer);

        header.getDetails().add(detail);
    }

    headerService.save(header);
}

现在,数据库具有如下约束:
Header
=================================
ID, other columns...

Detail
=================================
ID, HEADER_ID, CUSTOMER_ID

Customer
=================================
ID, other columns...

Constraint:  Details must be unique by HEADER_ID and CUSTOMER_ID so:

Detail  (VALID)
=================================
1, 123, 10
2, 123, 12

Detail  (IN-VALID)
=================================
1, 123, 10
1, 123, 10

好的,当我运行此代码并传递2、3、20等客户时,只要以前没有任何记录,它就会创建所有Detail记录。

如果我再次运行它,并传入其他客户列表,则我希望首先删除ALL详细信息,然后再创建NEW详细信息列表。

但是正在发生的事情是,删除似乎在创建之前不被接受。因为错误是重复的键约束。重复的 key 是上面的“有效”方案。

如果我用大量细节手动填充数据库并注释掉CREATE details部分(仅运行删除操作),那么将记录删除就好了。因此删除有效。创建作品。只是两者不能一起工作。

我可以提供更多需要的代码。我正在使用Spring Data JPA

谢谢

更新

我的实体基本上带有以下注释:
@Entity
@Table
public class Header {
...
    @OneToMany(mappedBy = "header", orphanRemoval = true, cascade = {CascadeType.ALL}, fetch = FetchType.EAGER)
    private Set<Detail> Details = new HashSet<>();

...
}

@Entity
@Table
public class Detail {
...
    @ManyToOne(optional = false)
    @JoinColumn(name = "HEADER_ID", referencedColumnName = "ID", nullable = false)
    private Header header;
...
}

更新2

@克劳斯·格伦拜克

实际上,我最初并未提及此事,但我是第一次这样做。另外,我正在使用Cascading.ALL,我假设它包括PERSIST。

仅出于测试目的,我将代码更新为以下内容:
@Transactional
public void create(Integer id, List<Integer> customerIDs) {

    Header header = headerService.findOne(id);

    // Remove the details
    detailRepository.delete(header.getDetails());       // Does not work

    // I've also tried this:
    for(Detail detail : header.getDetails()) {
        detailRepository.delete(detail);
    }


    // Iterate through list of ID's and create Detail with other objects
    for(Integer id : customerIDs) {
        Customer customer = customerService.findOne(id);

        Detail detail = new Detail();
        detail.setCustomer(customer);
        detail.setHeader(header);

        detailRepository.save(detail)
    }
}

再次...我要重申....如果我之后没有立即创建,则删除将起作用。如果我之前没有删除操作,则创建将起作用。但是,由于数据库中存在重复的键约束错误,因此它们在一起时都不起作用。

我尝试了相同的情况,有和没有级联删除。

最佳答案

坚持不懈,因为这是一个很长的解释,但是当我查看您的代码时,您似乎缺少了一些有关JPA工作原理的关键概念。

首先,将实体添加到集合中或从集合中删除实体并不意味着将在数据库中发生相同的操作,除非使用级联或orphanRemoval传播持久性操作。

要将实体添加到数据库,必须直接调用EntityManager.persist()或通过级联持久调用。这基本上就是JPARepository.save()内部发生的事情

如果要删除实体,则必须直接或通过级联操作或通过EntityManager.remove()调用JpaRepository.delete()

如果您拥有一个受管实体(一个已加载到持久性上下文中的实体),并且您在事务内部修改了一个基本字段(非实体,非集合),那么当事务提交时,即使是更改,该更改也会写入数据库中,即使如果您没有致电persist/save。持久性上下文会保留每个已加载实体的内部副本,并且在提交事务时,它将遍历内部副本并与当前状态进行比较,并且任何基本的归档更改都会触发更新查询。

如果已将新实体(A)添加到另一个实体(B)上的集合中,但尚未在A上调用持久化,则A将不会保存到数据库中。如果在B上调用persist,则将发生以下两种情况之一:如果持久操作是级联的,则A也将保存到数据库中。如果persist没有进行级联,则将出现错误,因为托管实体引用了非托管实体,这在EclipseLink上给出了此错误:“在同步期间,通过未标记为层叠PERSIST的关系找到了新对象”。级联持久是有意义的,因为您经常创建一个父实体和它的子实体。

当您要从另一个实体B上的集合中删除实体A时,您不能依赖级联,因为您没有删除B。相反,您必须直接调用A上的remove,将其从B上的集合中删除不会具有任何效果,因为尚未在EntityManager上调用任何持久性操作。您也可以使用orphanRemoval触发删除,但是我建议您在使用此功能时要格外小心,尤其是因为您似乎缺少有关持久性操作的基本知识。

通常,它有助于考虑持久性操作以及必须将其应用于哪个实体。如果我编写了代码,这就是它的外观。

@Transactional
public void create(Integer id, List<Integer> customerIDs) {

    Header header = headerService.findOne(id);
    // header is found, has multiple details

    // Remove the details
    for(Detail detail : header.getDetails()) {
        em.remove(detail);
    }

    // em.flush(); // In some case you need to flush, see comments below

    // Iterate through list of ID's and create Detail with other objects
    for(Integer id : customerIDs) {
        Customer customer = customerService.findOne(id);

        Detail detail = new Detail();
        detail.setCustomer(customer);
        detail.setHeader(header);  // did this happen inside you service?
        em.persist(detail);
    }
}

首先,没有理由要保留 header ,它是一个托管实体,并且在事务提交时,您修改的任何基本字段都会更改。 header 恰好是Details实体的外键,这意味着重要的是detail.setHeader(header);em.persist(details),因为您必须设置所有外部关系,并保留所有新的Details
同样,从Header中删除现有详细信息与Header无关,定义关系(外键)在Details中,因此从持久性上下文中删除详细信息就是将其从数据库中删除的原因。您也可以使用orphanRemoval,但是这对于每个事务都需要附加的逻辑,而且我认为,如果每个持久性操作都是显式的,则代码更易于阅读,因此您无需回到实体来阅读注释。

最后:代码中的持久性操作顺序不会改变为对数据库执行的查询顺序。 Hibernate和EclipseLink都将首先插入新实体,然后删除现有实体。以我的经验,这是“主键已存在”的最常见原因。如果删除具有特定主键的实体,然后添加具有相同主键的新实体,则插入将首先发生,并导致键冲突。可以通过告诉JPA将当前的持久性状态刷新到数据库来解决此问题。 em.flush()将删除查询推送到数据库,因此您可以插入另一行,该行的主键与已删除的键相同。

那是很多信息,请让我知道您是否不了解或需要我澄清。

关于java - 删除然后创建记录导致Spring Data JPA重复 key 冲突,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/42124030/

有关java - 删除然后创建记录导致Spring Data JPA重复 key 冲突的更多相关文章

  1. ruby - 如何在 Ruby 中顺序创建 PI - 2

    出于纯粹的兴趣,我很好奇如何按顺序创建PI,而不是在过程结果之后生成数字,而是让数字在过程本身生成时显示。如果是这种情况,那么数字可以自行产生,我可以对以前看到的数字实现垃圾收集,从而创建一个无限系列。结果只是在Pi系列之后每秒生成一个数字。这是我通过互联网筛选的结果:这是流行的计算机友好算法,类机器算法:defarccot(x,unity)xpow=unity/xn=1sign=1sum=0loopdoterm=xpow/nbreakifterm==0sum+=sign*(xpow/n)xpow/=x*xn+=2sign=-signendsumenddefcalc_pi(digits

  2. python - 如何使用 Ruby 或 Python 创建一系列高音调和低音调的蜂鸣声? - 2

    关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题?更新问题,以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点?我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等),但我确实想创建一个输出文件。

  3. ruby - 使用 Vim Rails,您可以创建一个新的迁移文件并一次性打开它吗? - 2

    使用带有Rails插件的vim,您可以创建一个迁移文件,然后一次性打开该文件吗?textmate也可以这样吗? 最佳答案 你可以使用rails.vim然后做类似的事情::Rgeneratemigratonadd_foo_to_bar插件将打开迁移生成的文件,这正是您想要的。我不能代表textmate。 关于ruby-使用VimRails,您可以创建一个新的迁移文件并一次性打开它吗?,我们在StackOverflow上找到一个类似的问题: https://sta

  4. ruby-on-rails - 如何从 format.xml 中删除 <hash></hash> - 2

    我有一个对象has_many应呈现为xml的子对象。这不是问题。我的问题是我创建了一个Hash包含此数据,就像解析器需要它一样。但是rails自动将整个文件包含在.........我需要摆脱type="array"和我该如何处理?我没有在文档中找到任何内容。 最佳答案 我遇到了同样的问题;这是我的XML:我在用这个:entries.to_xml将散列数据转换为XML,但这会将条目的数据包装到中所以我修改了:entries.to_xml(root:"Contacts")但这仍然将转换后的XML包装在“联系人”中,将我的XML代码修改为

  5. ruby - 我可以使用 Ruby 从 CSV 中删除列吗? - 2

    查看Ruby的CSV库的文档,我非常确定这是可能且简单的。我只需要使用Ruby删除CSV文件的前三列,但我没有成功运行它。 最佳答案 csv_table=CSV.read(file_path_in,:headers=>true)csv_table.delete("header_name")csv_table.to_csv#=>ThenewCSVinstringformat检查CSV::Table文档:http://ruby-doc.org/stdlib-1.9.2/libdoc/csv/rdoc/CSV/Table.html

  6. ruby-on-rails - 无法使用 Rails 3.2 创建插件? - 2

    我对最新版本的Rails有疑问。我创建了一个新应用程序(railsnewMyProject),但我没有脚本/生成,只有脚本/rails,当我输入ruby./script/railsgeneratepluginmy_plugin"Couldnotfindgeneratorplugin.".你知道如何生成插件模板吗?没有这个命令可以创建插件吗?PS:我正在使用Rails3.2.1和ruby​​1.8.7[universal-darwin11.0] 最佳答案 随着Rails3.2.0的发布,插件生成器已经被移除。查看变更日志here.现在

  7. ruby - 如何使用 RSpec::Core::RakeTask 创建 RSpec Rake 任务? - 2

    如何使用RSpec::Core::RakeTask初始化RSpecRake任务?require'rspec/core/rake_task'RSpec::Core::RakeTask.newdo|t|#whatdoIputinhere?endInitialize函数记录在http://rubydoc.info/github/rspec/rspec-core/RSpec/Core/RakeTask#initialize-instance_method没有很好的记录;它只是说:-(RakeTask)initialize(*args,&task_block)AnewinstanceofRake

  8. ruby - 我可以使用 aws-sdk-ruby 在 AWS S3 上使用事务性文件删除/上传吗? - 2

    我发现ActiveRecord::Base.transaction在复杂方法中非常有效。我想知道是否可以在如下事务中从AWSS3上传/删除文件:S3Object.transactiondo#writeintofiles#raiseanexceptionend引发异常后,每个操作都应在S3上回滚。S3Object这可能吗?? 最佳答案 虽然S3API具有批量删除功能,但它不支持事务,因为每个删除操作都可以独立于其他操作成功/失败。该API不提供任何批量上传功能(通过PUT或POST),因此每个上传操作都是通过一个独立的API调用完成的

  9. ruby - Sinatra:运行 rspec 测试时记录噪音 - 2

    Sinatra新手;我正在运行一些rspec测试,但在日志中收到了一堆不需要的噪音。如何消除日志中过多的噪音?我仔细检查了环境是否设置为:test,这意味着记录器级别应设置为WARN而不是DEBUG。spec_helper:require"./app"require"sinatra"require"rspec"require"rack/test"require"database_cleaner"require"factory_girl"set:environment,:testFactoryGirl.definition_file_paths=%w{./factories./test/

  10. ruby - 为什么 SecureRandom.uuid 创建一个唯一的字符串? - 2

    关闭。这个问题需要detailsorclarity.它目前不接受答案。想改进这个问题吗?通过editingthispost添加细节并澄清问题.关闭8年前。Improvethisquestion为什么SecureRandom.uuid创建一个唯一的字符串?SecureRandom.uuid#=>"35cb4e30-54e1-49f9-b5ce-4134799eb2c0"SecureRandom.uuid方法创建的字符串从不重复?

随机推荐