Method executeInAutoCommitMode

backend/plugin/db/redshift/redshift.go:291–319

executeInAutoCommitMode executes statements sequentially in auto-commit mode

(ctx context.Context, commands []base.Statement, opts db.ExecuteOptions)

// executeInAutoCommitMode executes statements sequentially in auto-commit mode
func (d *Driver) executeInAutoCommitMode(ctx context.Context, commands []base.Statement, opts db.ExecuteOptions) (int64, error) {
	totalRowsAffected := int64(0)

	for i, command := range commands {
		opts.LogCommandExecute(command.Range, command.Text)
		// Log the query statement in char code to see if there are some control characters that cause issues.
		var charCode []rune
		for _, r := range command.Text {
			charCode = append(charCode, r)
		}
		slog.Debug("executing command", slog.Any("command", charCode), slog.Int("index", i))
		sqlResult, err := d.db.ExecContext(ctx, command.Text)
		if err != nil {
			opts.LogCommandResponse(0, nil, err.Error())
			// In auto-commit mode, we stop at the first error
			// The database is left in a partially migrated state
			return totalRowsAffected, err
		}
		rowsAffected, err := sqlResult.RowsAffected()
		if err != nil {
			// Since we cannot differentiate DDL and DML yet, we have to ignore the error.
			slog.Debug("rowsAffected returns error", log.BBError(err))
		}
		opts.LogCommandResponse(rowsAffected, nil, "")
		totalRowsAffected += rowsAffected
	}

	return totalRowsAffected, nil
}

func getDatabaseInCreateDatabaseStatement(createDatabaseStatement string) (string, error) {
	raw := strings.TrimRight(createDatabaseStatement, ";")