fix loop
parent
8b748280a9
commit
67879cf7b0
|
|
@ -57,25 +57,13 @@ func run(ctx context.Context) error {
|
||||||
|
|
||||||
// https://gist.github.com/ololobus/5b25c432f208d7eb31051a5f238dffff
|
// https://gist.github.com/ololobus/5b25c432f208d7eb31051a5f238dffff
|
||||||
// 2e6=1GB, so 2e6/8=12MB
|
// 2e6=1GB, so 2e6/8=12MB
|
||||||
for {
|
for ctx.Err() == nil && presently() < *n {
|
||||||
if presently() >= *n {
|
if _, err := pg.ExecContext(ctx, `
|
||||||
break
|
INSERT INTO fill_with_data (x, y, z)
|
||||||
}
|
SELECT ROUND(RANDOM()), RANDOM(), RANDOM()
|
||||||
for ctx.Err() == nil {
|
FROM generate_series(1, 2e6/8)
|
||||||
if _, err := pg.ExecContext(ctx, `
|
`); err != nil {
|
||||||
INSERT INTO fill_with_data (x, y, z)
|
return fmt.Errorf("failed lo_from_bytea: %w", err)
|
||||||
SELECT ROUND(RANDOM()), RANDOM(), RANDOM()
|
|
||||||
FROM generate_series(1, 2e6/8)
|
|
||||||
`); err != nil {
|
|
||||||
return fmt.Errorf("failed lo_from_bytea: %w", err)
|
|
||||||
} else {
|
|
||||||
break
|
|
||||||
}
|
|
||||||
select {
|
|
||||||
case <-ctx.Done():
|
|
||||||
return ctx.Err()
|
|
||||||
default:
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue