diff --git a/extern/boostd-data/bench/postgres.go b/extern/boostd-data/bench/postgres.go index e6919dbf0..5c2cb42db 100644 --- a/extern/boostd-data/bench/postgres.go +++ b/extern/boostd-data/bench/postgres.go @@ -193,58 +193,58 @@ func (db *Postgres) AddIndexRecords(ctx context.Context, pieceCid cid.Cid, recs defer tx.Rollback() // Add payload to pieces index - if _, err := tx.Exec(` -create temp table PayloadToPiecesTmp (like PayloadToPieces excluding constraints) on commit drop; -`); err != nil { - return fmt.Errorf("create PayloadToPiecesTemp: %w", err) - } + //if _, err := tx.Exec(` + //create temp table PayloadToPiecesTmp (like PayloadToPieces excluding constraints) on commit drop; + //`); err != nil { + //return fmt.Errorf("create PayloadToPiecesTemp: %w", err) + //} - stmt, err := tx.Prepare(`copy PayloadToPiecesTmp (PayloadMultihash, PieceCids) from stdin `) + stmt, err := tx.Prepare(`copy PayloadToPieces (PayloadMultihash, PieceCids) from stdin `) if err != nil { - return fmt.Errorf("prepare copy PayloadToPiecesTemp: %w", err) + return fmt.Errorf("prepare copy PayloadToPieces: %w", err) } for _, rec := range recs { if _, err := stmt.Exec(rec.Cid.Hash(), pieceCid.Bytes()); err != nil { - return fmt.Errorf("exec copy PayloadToPiecesTemp: %w", err) + return fmt.Errorf("exec copy PayloadToPieces: %w", err) } } if err := stmt.Close(); err != nil { return fmt.Errorf("close PayloadToPiecesTemp statement: %w", err) } - if _, err := tx.Exec(` -insert into PayloadToPieces select * from PayloadToPiecesTmp on conflict do nothing -`); err != nil { - return fmt.Errorf("insert into PayloadToPieces: %w", err) - } + //if _, err := tx.Exec(` + //insert into PayloadToPieces select * from PayloadToPiecesTmp on conflict do nothing + //`); err != nil { + //return fmt.Errorf("insert into PayloadToPieces: %w", err) + //} - // Add piece to block info index - if _, err := tx.Exec(` -create temp table PieceBlockOffsetSizeTmp (like PieceBlockOffsetSize excluding constraints) on commit drop; -`); err != nil { - return fmt.Errorf("create PieceBlockOffsetSizeTmp: %w", err) - } + //// Add piece to block info index + //if _, err := tx.Exec(` + //create temp table PieceBlockOffsetSizeTmp (like PieceBlockOffsetSize excluding constraints) on commit drop; + //`); err != nil { + //return fmt.Errorf("create PieceBlockOffsetSizeTmp: %w", err) + //} - stmt, err = tx.Prepare(`copy PieceBlockOffsetSizeTmp (PieceCid, PayloadMultihash, BlockOffset, BlockSize) from stdin `) + stmt, err = tx.Prepare(`copy PieceBlockOffsetSize (PieceCid, PayloadMultihash, BlockOffset, BlockSize) from stdin `) if err != nil { - return fmt.Errorf("prepare copy PieceBlockOffsetSizeTmp: %w", err) + return fmt.Errorf("prepare copy PieceBlockOffsetSize: %w", err) } for _, rec := range recs { if _, err := stmt.Exec(pieceCid.Bytes(), rec.Cid.Hash(), rec.Offset, rec.Size); err != nil { - return fmt.Errorf("exec copy PieceBlockOffsetSizeTmp: %w", err) + return fmt.Errorf("exec copy PieceBlockOffsetSize: %w", err) } } if err := stmt.Close(); err != nil { - return fmt.Errorf("close PieceBlockOffsetSizeTmp statement: %w", err) + return fmt.Errorf("close PieceBlockOffsetSize statement: %w", err) } - if _, err := tx.Exec(` -insert into PieceBlockOffsetSize select * from PieceBlockOffsetSizeTmp on conflict do nothing -`); err != nil { - return fmt.Errorf("insert into PieceBlockOffsetSize: %w", err) - } + //if _, err := tx.Exec(` + //insert into PieceBlockOffsetSize select * from PieceBlockOffsetSizeTmp on conflict do nothing + //`); err != nil { + //return fmt.Errorf("insert into PieceBlockOffsetSize: %w", err) + //} err = tx.Commit() if err != nil {