sabri
I am trying to insert many records into database, one by one as:
rec= SRepo.get_by(Trackware.Schools.Parent, mobile_number: father_head.mobile_number)
father_id= case rec do
nil ->
# its not inserted in DB before
{:ok, %Trackware.Schools.Parent{ id: father_id }} = SRepo.insert(father_head)
father_id
father ->
#its inserted before, return the record id
father.id
end
this work fine, however, if I try to use Stream.chunk and have the code above run in concurrent processes, I get error like:
** (Ecto.ConstraintError) constraint error when attempting to insert struct:
* unique: parents_mobile_number_uindex
If you would like to convert this constraint into an error, please
call unique_constraint/3 in your changeset and define the proper
constraint name. The changeset has not defined any constraint.
Although I check before insert a new record, but it seems such error is a result of concurrent process..
How can I solve this?
I tried to use insert_or_update but I got the same error as it seems processes are raising on the same line?
Where Next?
Trending in Questions
Other Trending Topics
Latest Phoenix Threads
Latest on Elixir Forum
Sponsor Spotlight
Practical resources that improve the lives of professional developers.
Categories:
Sub Categories:
Forums
Popular Tags
- #ecto
- #liveview
- #troubleshooting
- #learning-elixir
- #library
- #deployment
- #erlang
- #testing
- #genserver
- #mix
- #absinthe
- #remote-other
- #otp
- #plug
- #how-to-question
- #macros
- #postgres
- #elixirconf
- #channels
- #exunit
- #discussion
- #code-sync
- #podcasts
- #javascript
- #onsite
- #dialyzer
- #docker
- #authentication
- #umbrella
- #full-time-contract
- #podcasts-by-brainlid
- #ai
- #ecto-query
- #elixirconf-us
- #blog-post
- #elixir-ls
- #phoenix_html
- #iex
- #graphql
- #genstage
- #websockets
- #supervisor
- #advent-of-code
- #distillery
- #processes
- #elixirconf-eu
- #api
- #forms
- #metaprogramming
- #hex
Our Sponsors
Build Elixir applications with speed and confidence.
Supporting innovation across the BEAM ecosystem.
We build reliable cloud platforms for business-critical systems.
Catch errors, track performance, monitor hosts and more.
Error tracking, logs, uptime, and Just Enough APM. Built for developers.
Master modern tools, write cleaner code, and tackle real-world challenges.
**Building the future of software with AI, trust, and human connection.**
The deployment platform built for Elixir: PaaS ease, VPS control.
The team behind Membrane, Popcorn, LiveDebugger. Available for hire.
Courses that'll move you from confusion to "Aha, now I get it!"
Showing Posts 1 to 8- Show Best Posts
- Show All (oldest first)
- Show All (newest first)
outlog
can’t quite make out your code.. but look at insert_all which does an “upsert” Ecto.Repo — Ecto v3.14.0 then you decide how to handle the conflict.
sabri
I did not use insert_all, because the student record belongs to one parent, and I need to save that parent, and get its id, then to set the parent_id in the student before saving it..
OvermindDL1
When you have such combined things you really need to be using Ecto.Multi.
sabri
Can I use
Ecto.Multito add records and associate them too? as I have belongs to relationOvermindDL1
Yep.
Ecto.Multiis just ‘transactions’ in Ecto, so definitely yes.outlog
sorry, was to fast and there was a bug in the documentation, I guess I meant use upsert options for insert (doc bug fixed here Repo: Reference correct function in insert/2 upsert docs (#1909) · elixir-ecto/ecto@acf8016 · GitHub)
{:ok, %Trackware.Schools.Parent{ id: father_id }} = SRepo.insert(father_head , on_conflict: :replace_all, conflict_target: :mobile_number)should be able to replace the entire code snippet you posted.
I would guess this would still be needed in a multi, as you might have student siblings that gives you these conflicts.
sabri
Is there an example for such case in Ecto.multi? Inserting two records in different tables and set the foreign key of one to point to the other?
OvermindDL1
Well you can insert the other first then insert the original that points to the first, that is the usual way (in a transaction of course).
Or you can insert the first with a null foreign key, then the other, then update the first with with the key, but that is too many calls.
Basically for the first method just Multi.insert the first, then Multi.run to grab the id and insert the second.