in db/script.go [13:23]
func ExecCommands(ctx context.Context, db *sqlx.DB, r io.Reader) error {
scanner := bufio.NewScanner(r)
scanner.Split(scanStatements)
for scanner.Scan() {
stmt := scanner.Text()
if _, err := db.ExecContext(ctx, stmt); err != nil {
return errors.Wrapf(err, "executing statement failed:\n%s", stmt)
}
}
return nil
}