【发布时间】:2017-04-12 02:55:33
【问题描述】:
我尝试设置一个可延迟的外键约束,以便在我插入查找/数据透视表直到事务结束时不会对其进行检查。但是,它可以在 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 ($1, $2)`, 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"
【问题讨论】:
-
也许您的代码在启用自动提交的情况下运行?您会在什么时候收到该错误消息?
-
怎么样?你开始事务,然后你里面有两个事务然后你结束它?..什么>//这个函数中有两个db事务是什么意思?..
-
是的,就是这样。我开始事务,然后调用一个包含两个数据库事务的函数。并最终结束。
-
一个事务中不能有“两个事务”。如果您提交事务,则会检查约束并结束事务。
-
ctx.Exec和d.db.Exec在d.attach内使用相同的事务吗?你传给h的那个?从提供的代码来看,它们看起来不像。
标签: sql postgresql go deferrable-constraint