Method Execute

backend/plugin/db/oracle/oracle.go:105–151

Execute executes the migration, `beforeCommitTxFunc` will be called before transaction commit and after executing `statement`. Callers can use `beforeCommitTx` to do some extra work before transaction commit, like get the transaction id. Any error returned by `beforeCommitTx` will rollback the tran

(ctx context.Context, statement string, opts db.ExecuteOptions)

// Callers can use `beforeCommitTx` to do some extra work before transaction commit, like get the transaction id.
// Any error returned by `beforeCommitTx` will rollback the transaction, so it is the callers' responsibility to return nil if the error occurs in `beforeCommitTx` is not fatal.
func (d *Driver) Execute(ctx context.Context, statement string, opts db.ExecuteOptions) (int64, error) {
	if opts.CreateDatabase {
		return 0, errors.New("create database is not supported for Oracle")
	}

	// Parse transaction mode from the script
	config, cleanedStatement := base.ParseTransactionConfig(statement)
	statement = cleanedStatement
	transactionMode := config.Mode

	// Apply default when transaction mode is not specified
	if transactionMode == common.TransactionModeUnspecified {
		transactionMode = common.GetDefaultTransactionMode()
	}

	var commands []base.Statement
	if len(statement) <= common.MaxSheetCheckSize {
		// Use Oracle sql parser.
		singleSQLs, err := plsqlparser.SplitSQL(statement)
		if err != nil {
			return 0, errors.Wrapf(err, "failed to split sql")
		}
		singleSQLs = base.FilterEmptyStatements(singleSQLs)
		if len(singleSQLs) == 0 {
			return 0, nil
		}
		commands = singleSQLs
	} else {
		commands = []base.Statement{
			{
				Text: statement,
			},
		}
	}

	conn, err := d.db.Conn(ctx)
	if err != nil {
		return 0, errors.Wrapf(err, "failed to get connection")
	}
	defer conn.Close()

	// Execute based on transaction mode
	if transactionMode == common.TransactionModeOff {
		return d.executeInAutoCommitMode(ctx, conn, commands, opts)
	}
	return d.executeInTransactionMode(ctx, conn, commands, opts)
}

// executeInTransactionMode executes statements within a single transaction
func (*Driver) executeInTransactionMode(ctx context.Context, conn *sql.Conn, commands []base.Statement, opts db.ExecuteOptions) (int64, error) {