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.
- How to return JSON objects without explicit aliasing in postgresql
- Postgresql + psycopg: Bulk Insert large data with POSTGRESQL function call
- Better way to insert a very large data into PostgreSQL tables
- Cannot drop PostgreSQL role. Error: `cannot be dropped because some objects depend on it`
- pgadmin4 : postgresql application server could not be contacted
- How can I specify the migrations directory for typeorm CLI?
- SQL full outer join, default value to column in other table
- PostgreSQL database not connecting to spring-boot application
- Setting auto increment id in Postgres with Navicat
- Dropping all views in postgreSql
- Where does PostgreSQL store configuration/conf files?
- Query produces "function unnest(unknown) is not unique error", but is executed fine by the application
- SQL statement evaluation order
- Execute multiple queries as one dblink transaction
- Spring Data R2DBC PostgreSQL not saving new record with UUID @Id
- PostgreSQL Stack Builder Installation Certificate verification problem on Windows
- How do you connect to postgres running in a Docker container on OSx?
- Order by the oldest relation Postgres
- How to create a role in postgress db which supports the CRUD operations but doesn't allow to drop the database and tables with that role
- Error calling procedure in posgres "No procedure matches the given name and argument types. You might need to add explicit type casts."
- How To Import a Big .csv(~2GB) Into a PostgreSQL Table
- Rails trying to connect to postgresql on port 5432, but it's configured for 5433
- Power BI, Postgres, and materialized views
- How do you name the PostgreSQL indexes when using Haystack's PgvectorDocumentStore?
- Postgresql showing only one decimal, Grafana showing 2
- Django Postgresql ORM optimisation
- "could not identify an equality operator for type json" when using distinct
- Syntax error at end of input in PostgreSQL
- How to increase the connection limit for the Google Cloud SQL Postgres database?
- postgresql timestamptz conversion to localtime issue