transaction.go

package go_ora

import (
	"context"

	"github.com/victorien-a/go-ora/v2/network"
)

type Transaction struct {
	conn *Connection
	ctx  context.Context
}

func (tx *Transaction) Commit() error {
	if tx.conn.State != Opened {
		return &network.OracleError{ErrCode: 6413, ErrMsg: "ORA-06413: Connection not open"}
	}
	tx.conn.autoCommit = true
	tx.conn.session.ResetBuffer()
	tx.conn.session.StartContext(tx.ctx)
	defer tx.conn.session.EndContext()
	return (&simpleObject{connection: tx.conn, operationID: 0xE}).exec()
}

func (tx *Transaction) Rollback() error {
	if tx.conn.State != Opened {
		return &network.OracleError{ErrCode: 6413, ErrMsg: "ORA-06413: Connection not open"}
	}
	tx.conn.autoCommit = true
	tx.conn.session.ResetBuffer()
	tx.conn.session.StartContext(tx.ctx)
	defer tx.conn.session.EndContext()
	return (&simpleObject{connection: tx.conn, operationID: 0xF}).exec()
}