ent-go o2m upsert duplication
I am trying to upsert table A, with relations to table B - also, upserting via ent-go's framework with Postgres.
CmdbCiServerVmwareVirtualMachine:
+----------------+--------------------------------+--------+----------+----------+---------+---------------+-----------+---------------------------------+------------+---------+
| Field | Type | Unique | Optional | Nillable | Default | UpdateDefault | Immutable | StructTag | Validators | Comment |
+----------------+--------------------------------+--------+----------+----------+---------+---------------+-----------+---------------------------------+------------+---------+
| id | uuid.UUID | false | false | false | true | false | false | json:"id,omitempty" | 0 | |
| created_at | time.Time | false | false | false | true | false | true | json:"created_at,omitempty" | 0 | |
| updated_at | time.Time | false | false | false | true | true | false | json:"updated_at,omitempty" | 0 | |
| deleted_at | time.Time | false | true | false | false | true | false | json:"deleted_at,omitempty" | 0 | |
| sysId | uuid.UUID | true | false | false | false | false | false | json:"sysId,omitempty" | 0 | |
| name | string | false | true | false | false | false | false | json:"name,omitempty" | 0 | |
| vCpu | int | false | true | false | false | false | false | json:"vCpu,omitempty" | 0 | |
| coresPerSocket | int | false | true | false | false | false | false | json:"coresPerSocket,omitempty" | 0 | |
| memory | int | false | true | false | false | false | false | json:"memory,omitempty" | 0 | |
| hwVersion | string | false | true | false | false | false | false | json:"hwVersion,omitempty" | 0 | |
| guestOS | string | false | true | false | false | false | false | json:"guestOS,omitempty" | 0 | |
| guestOSFamily | string | false | true | false | false | false | false | json:"guestOSFamily,omitempty" | 0 | |
| guestOSFqdn | string | false | true | false | false | false | false | json:"guestOSFqdn,omitempty" | 0 | |
| powerState | string | false | true | false | false | false | false | json:"powerState,omitempty" | 0 | |
| customFields | []struct { Key int | false | false | false | false | false | false | json:"customFields,omitempty" | 0 | |
| | "json:\"Key\""; Value string | | | | | | | | | |
| | "json:\"Value\"" } | | | | | | | | | |
| data | vmware.VCenterVirtualMachine | false | true | false | false | false | false | json:"data,omitempty" | 0 | |
+----------------+--------------------------------+--------+----------+----------+---------+---------------+-----------+---------------------------------+------------+---------+
+--------+---------------------------------------------+---------+---------+----------+--------+----------+---------+
| Edge | Type | Inverse | BackRef | Relation | Unique | Optional | Comment |
+--------+---------------------------------------------+---------+---------+----------+--------+----------+---------+
| fields | CmdbCiServerVmwareVirtualMachineCustomField | false | | O2M | false | true | |
+--------+---------------------------------------------+---------+---------+----------+--------+----------+---------+
CmdbCiServerVmwareVirtualMachineCustomField:
+------------+-----------+--------+----------+----------+---------+---------------+-----------+-----------------------------+------------+---------+
| Field | Type | Unique | Optional | Nillable | Default | UpdateDefault | Immutable | StructTag | Validators | Comment |
+------------+-----------+--------+----------+----------+---------+---------------+-----------+-----------------------------+------------+---------+
| id | uuid.UUID | false | false | false | true | false | false | json:"id,omitempty" | 0 | |
| created_at | time.Time | false | false | false | true | false | true | json:"created_at,omitempty" | 0 | |
| updated_at | time.Time | false | false | false | true | true | false | json:"updated_at,omitempty" | 0 | |
| deleted_at | time.Time | false | true | false | false | true | false | json:"deleted_at,omitempty" | 0 | |
| sysId | uuid.UUID | false | false | false | false | false | false | json:"sysId,omitempty" | 0 | |
| key | int | false | false | false | false | false | false | json:"key,omitempty" | 0 | |
| value | string | false | true | false | false | false | false | json:"value,omitempty" | 0 | |
+------------+-----------+--------+----------+----------+---------+---------------+-----------+-----------------------------+------------+---------+
+----------------+----------------------------------+---------+---------+----------+--------+----------+---------+
| Edge | Type | Inverse | BackRef | Relation | Unique | Optional | Comment |
+----------------+----------------------------------+---------+---------+----------+--------+----------+---------+
| virtualMachine | CmdbCiServerVmwareVirtualMachine | true | fields | M2O | true | true | |
+----------------+----------------------------------+---------+---------+----------+--------+----------+---------+
As you can see, i have my Edge, and my index is unique for sys_id and key on the fields table.
// Indexes of the CmdbCiServerVmwareVirtualMachineCustomField.
func (CmdbCiServerVmwareVirtualMachineCustomField) Indexes() []ent.Index {
return []ent.Index{
index.Fields("key", "sysId").
Edges("virtualMachine").Unique(),
}
}
The following code seems to create the rows/relationships OK, however it will not upsert on the second run - only duplicate and give a NULL entry in the relationship column.
I am using the following code:
http://pastie.org/p/6vx6yugIWwlChKmSSJNPIs
Solution
func (CmdbCiServerVmwareVirtualMachineCustomField) Indexes() []ent.Index {
return []ent.Index{
index.Fields("key", "sysId").Unique(),
}
}
The above index, combined with :
...
.OnConflictColumns(
cmdbciservervmwarevirtualmachinecustomfield.FieldSysId,
cmdbciservervmwarevirtualmachinecustomfield.FieldKey).
UpdateNewValues().
ID(context.Background())
was enough for this to work correctly.
- Can't drop role because it has privileges that are not revoked even when REVOKE statement is successful
- How to transfer string from one column to another if it doesn’t contains substring
- How to use uuid with postgresql gist index type?
- How to format date if it can be null spring
- Postrgres Regex to replace part of a String
- Query Condition in Laravel 5
- How to restrict RLS on certain column(s) in PostgreSQL/Supabase?
- Joining too many tables makes Postgres query extremely slow
- Laravel and PHP8.3 can't connect to Postgres database
- CASE vs Multiple UPDATE queries for large data sets - Performance
- Invalid resource manager ID in primary checkpoint record
- postgresql list and order tables by size
- PgAdmin 4: Cannot edit rows from one table
- Add PRIMARY KEY constraint to existing table
- Count of available items with start and end dates grouped by month
- Hibernate mapping between Postgres array of varchar and a Java/Kotlin collection of enum
- Correct way to install psql without full Postgres on macOS?
- Why pg_typeof(TIMESTAMP '2004-10-19 10:23:54+02') shows timestamp without time zone
- "extra data after last expected column" while trying to import a csv file into postgresql
- Postgres - using select statement inside CASE WHEN
- How to split events into periods of activity in postgres?
- Streak for a given endDate SQL (Postgres)
- How to set a timestamptz column in postgres to a range of values to simulate real world data?
- Why is string literal '2021-02-16 09:00' without timezone information interpreted as `timestamp with time zone` with AT TIME ZONE?
- Postgres won't accept table alias before column name
- Named argument passed as a dict: SyntaxError: syntax error at or near "%" or SyntaxError: type modifiers must be simple constants or identifiers
- pg_cron - can not query cron.job after job is scheduled
- PostgreSQL Selecting Most Recent Entry for a Given ID
- Difference between timestamps with/without time zone in PostgreSQL
- connect superset to postgresql in a docker container - The port is closed