Method execSQLDB

sql_migration.go:64–77

execSQLDB executes SQL on a DB, either as a single exec or split by statements

(ctx context.Context, db *sql.DB, query string)

// execSQLDB executes SQL on a DB, either as a single exec or split by statements
func (s SQLMigration) execSQLDB(ctx context.Context, db *sql.DB, query string) error {
	if !s.splitStatements {
		_, err := db.ExecContext(ctx, query)
		return err
	}

	statements := splitSQLStatementsWithAnnotations(query)
	for _, stmt := range statements {
		if _, err := db.ExecContext(ctx, stmt); err != nil {
			return err
		}
	}
	return nil
}

func (s SQLMigration) Name() string {
	return s.name