From 6734287789d65ec676c977b758b3f77ee1e5eeec Mon Sep 17 00:00:00 2001 From: Mike Greenberg Date: Mon, 17 Aug 2020 17:31:17 -0400 Subject: [PATCH] fix(chainwatch): Change tmp table names to not collide --- cmd/lotus-chainwatch/processor/common_actors.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/cmd/lotus-chainwatch/processor/common_actors.go b/cmd/lotus-chainwatch/processor/common_actors.go index 698badcce..f74168485 100644 --- a/cmd/lotus-chainwatch/processor/common_actors.go +++ b/cmd/lotus-chainwatch/processor/common_actors.go @@ -232,12 +232,12 @@ func (p *Processor) storeActorHeads(actors map[cid.Cid]ActorTips) error { return err } if _, err := tx.Exec(` - create temp table a (like actors excluding constraints) on commit drop; + create temp table a_tmp (like actors excluding constraints) on commit drop; `); err != nil { return xerrors.Errorf("prep temp: %w", err) } - stmt, err := tx.Prepare(`copy a (id, code, head, nonce, balance, stateroot) from stdin `) + stmt, err := tx.Prepare(`copy a_tmp (id, code, head, nonce, balance, stateroot) from stdin `) if err != nil { return err } @@ -260,7 +260,7 @@ func (p *Processor) storeActorHeads(actors map[cid.Cid]ActorTips) error { return err } - if _, err := tx.Exec(`insert into actors select * from a on conflict do nothing `); err != nil { + if _, err := tx.Exec(`insert into actors select * from a_tmp on conflict do nothing `); err != nil { return xerrors.Errorf("actor put: %w", err) } @@ -278,12 +278,12 @@ func (p *Processor) storeActorStates(actors map[cid.Cid]ActorTips) error { return err } if _, err := tx.Exec(` - create temp table a (like actor_states excluding constraints) on commit drop; + create temp table as_tmp (like actor_states excluding constraints) on commit drop; `); err != nil { return xerrors.Errorf("prep temp: %w", err) } - stmt, err := tx.Prepare(`copy a (head, code, state) from stdin `) + stmt, err := tx.Prepare(`copy as_tmp (head, code, state) from stdin `) if err != nil { return err } @@ -306,7 +306,7 @@ func (p *Processor) storeActorStates(actors map[cid.Cid]ActorTips) error { return err } - if _, err := tx.Exec(`insert into actor_states select * from a on conflict do nothing `); err != nil { + if _, err := tx.Exec(`insert into actor_states select * from as_tmp on conflict do nothing `); err != nil { return xerrors.Errorf("actor put: %w", err) }