如何推迟 Postgres 中的外键约束
How to defer foreign key constraint in Postgres
我试图设置一个可延迟的外键约束,这样当我插入一个 lookup/pivot table 时它不会被检查直到事务结束。但是,它在 psql shell 中起作用,但它在代码中不起作用。与 psql shell 相同,我也在代码中使用 begin
开始交易。
这是sql:
create table campaign_r_company (
campaign_id uuid not null references campaign(id) on delete cascade deferrable initially deferred,
company_id varchar(32) not null,
primary key (campaign_id, company_id)
);
代码如下:
tx, err := d.Begin()
if err != nil {
return err
}
err = h(tx) // there are two db queries will be called in this function
if err == nil {
err = tx.Commit()
}
h(tx):
_, err := cxt.Exec(fmt.Sprintf(`INSERT INTO hp_campaign (%s) VALUES (%s)`, proplist("", campaignProps), arglist(1, len(campaignProps))),
id, v.Name, created, v.Updated,
)
if err != nil {
return err
}
v.Id = id
v.Created = created
if (opts & StoreOptionStoreRelated) == StoreOptionStoreRelated {
err := d.attach("company", "campaign_r_company", v.Companies, v.Id)
if err != nil {
return err
}
}
附加():
func (d *Database) attach(entityName string, tableName string, ids []string, campaignID string) error {
for _, id := range ids {
stmt := fmt.Sprintf(`INSERT INTO %s (%s) VALUES (, )`, tableName, fmt.Sprintf("campaign_id, %s_id", entityName))
_, err := d.db.Exec(stmt, campaignID, id)
if err != nil {
return err
}
}
return nil
}
错误:
insert or update on table "campaign_r_company" violates foreign key constraint "campaign_r_company_campaign_id_fkey"
如果您不使用手动事务管理,Go+PG 会为您代劳。在这种情况下,任何语句都是单个事务,并且在每个语句末尾检查约束。因此引发异常。
从更新的代码和后续评论中,我们现在知道问题是两个查询是分开执行的,而不是在一个事务中。
我试图设置一个可延迟的外键约束,这样当我插入一个 lookup/pivot table 时它不会被检查直到事务结束。但是,它在 psql shell 中起作用,但它在代码中不起作用。与 psql shell 相同,我也在代码中使用 begin
开始交易。
这是sql:
create table campaign_r_company (
campaign_id uuid not null references campaign(id) on delete cascade deferrable initially deferred,
company_id varchar(32) not null,
primary key (campaign_id, company_id)
);
代码如下:
tx, err := d.Begin()
if err != nil {
return err
}
err = h(tx) // there are two db queries will be called in this function
if err == nil {
err = tx.Commit()
}
h(tx):
_, err := cxt.Exec(fmt.Sprintf(`INSERT INTO hp_campaign (%s) VALUES (%s)`, proplist("", campaignProps), arglist(1, len(campaignProps))),
id, v.Name, created, v.Updated,
)
if err != nil {
return err
}
v.Id = id
v.Created = created
if (opts & StoreOptionStoreRelated) == StoreOptionStoreRelated {
err := d.attach("company", "campaign_r_company", v.Companies, v.Id)
if err != nil {
return err
}
}
附加():
func (d *Database) attach(entityName string, tableName string, ids []string, campaignID string) error {
for _, id := range ids {
stmt := fmt.Sprintf(`INSERT INTO %s (%s) VALUES (, )`, tableName, fmt.Sprintf("campaign_id, %s_id", entityName))
_, err := d.db.Exec(stmt, campaignID, id)
if err != nil {
return err
}
}
return nil
}
错误:
insert or update on table "campaign_r_company" violates foreign key constraint "campaign_r_company_campaign_id_fkey"
如果您不使用手动事务管理,Go+PG 会为您代劳。在这种情况下,任何语句都是单个事务,并且在每个语句末尾检查约束。因此引发异常。
从更新的代码和后续评论中,我们现在知道问题是两个查询是分开执行的,而不是在一个事务中。