Method execSQL

sql_migration.go:48–61

execSQL executes SQL within a transaction, either as a single exec or split by statements

(ctx context.Context, tx *sql.Tx, query string)

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

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

// 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 {