transaction

package
v2.16.6-pre Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 10, 2023 License: MIT Imports: 12 Imported by: 0

Documentation

Overview

Package transaction is a generated GoMock package.

Package transaction is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Begin 

type Begin interface {
	// Begin transaction on the underlying transactable datastructure and
	// return it
	Begin() (Implementation, error)
}

Begin has methods for starting transactions

type Implementation 

type Implementation interface {
	// NamedQuery within a transaction.
	// Any named placeholder parameters are replaced with fields from arg.
	NamedQuery(query string, arg interface{}) (*sqlx.Rows, error)
	// NamedExec a named query within a transaction.
	// Any named placeholder parameters are replaced with fields from arg.
	NamedExec(query string, arg interface{}) (sql.Result, error)
	// QueryRowx within a transaction.
	// Any placeholder parameters are replaced with supplied args.
	QueryRowx(query string, args ...interface{}) *sqlx.Row
	// Select within a transaction.
	// Any placeholder parameters are replaced with supplied args.
	Select(dest interface{}, query string, args ...interface{}) error
	// Exec a query within a transaction.
	// Any named placeholder parameters are replaced with fields from arg.
	Exec(query string, args ...any) (sql.Result, error)
	// Commit this transaction
	Commit() error
	// Rollback this transaction
	Rollback() error
}

type MockImplementation 

type MockImplementation struct {
	// contains filtered or unexported fields
}

MockImplementation is a mock of Implementation interface.

func NewMockImplementation 

func NewMockImplementation(ctrl *gomock.Controller) *MockImplementation

NewMockImplementation creates a new mock instance.

func (*MockImplementation) Commit 

func (m *MockImplementation) Commit() error

Commit mocks base method.

func (*MockImplementation) EXPECT 

func (m *MockImplementation) EXPECT() *MockImplementationMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockImplementation) Exec 

func (m *MockImplementation) Exec(query string, args ...any) (sql.Result, error)

Exec mocks base method.

func (*MockImplementation) NamedExec 

func (m *MockImplementation) NamedExec(query string, arg interface{}) (sql.Result, error)

NamedExec mocks base method.

func (*MockImplementation) NamedQuery 

func (m *MockImplementation) NamedQuery(query string, arg interface{}) (*sqlx.Rows, error)

NamedQuery mocks base method.

func (*MockImplementation) QueryRowx 

func (m *MockImplementation) QueryRowx(query string, args ...interface{}) *sqlx.Row

QueryRowx mocks base method.

func (*MockImplementation) Rollback 

func (m *MockImplementation) Rollback() error

Rollback mocks base method.

func (*MockImplementation) Select 

func (m *MockImplementation) Select(dest interface{}, query string, args ...interface{}) error

Select mocks base method.

type MockImplementationMockRecorder 

type MockImplementationMockRecorder struct {
	// contains filtered or unexported fields
}

MockImplementationMockRecorder is the mock recorder for MockImplementation.

func (*MockImplementationMockRecorder) Commit 

func (mr *MockImplementationMockRecorder) Commit() *gomock.Call

Commit indicates an expected call of Commit.

func (*MockImplementationMockRecorder) Exec 

func (mr *MockImplementationMockRecorder) Exec(query interface{}, args ...interface{}) *gomock.Call

Exec indicates an expected call of Exec.

func (*MockImplementationMockRecorder) NamedExec 

func (mr *MockImplementationMockRecorder) NamedExec(query, arg interface{}) *gomock.Call

NamedExec indicates an expected call of NamedExec.

func (*MockImplementationMockRecorder) NamedQuery 

func (mr *MockImplementationMockRecorder) NamedQuery(query, arg interface{}) *gomock.Call

NamedQuery indicates an expected call of NamedQuery.

func (*MockImplementationMockRecorder) QueryRowx 

func (mr *MockImplementationMockRecorder) QueryRowx(query interface{}, args ...interface{}) *gomock.Call

QueryRowx indicates an expected call of QueryRowx.

func (*MockImplementationMockRecorder) Rollback 

func (mr *MockImplementationMockRecorder) Rollback() *gomock.Call

Rollback indicates an expected call of Rollback.

func (*MockImplementationMockRecorder) Select 

func (mr *MockImplementationMockRecorder) Select(dest, query interface{}, args ...interface{}) *gomock.Call

Select indicates an expected call of Select.

type MockTransaction 

type MockTransaction struct {
	// contains filtered or unexported fields
}

MockTransaction is a mock of Transaction interface.

func NewMockTransaction 

func NewMockTransaction(ctrl *gomock.Controller) *MockTransaction

NewMockTransaction creates a new mock instance.

func (*MockTransaction) Commit 

func (m *MockTransaction) Commit() errors.TracerError

Commit mocks base method.

func (*MockTransaction) Create 

func (m *MockTransaction) Create(arg0 record.Record) errors.TracerError

Create mocks base method.

func (*MockTransaction) Delete 

func (m *MockTransaction) Delete(arg0 record.Record) errors.TracerError

Delete mocks base method.

func (*MockTransaction) DeleteWhere 

func (m *MockTransaction) DeleteWhere(arg0 record.Record, arg1 *qb.ConditionExpression) errors.TracerError

DeleteWhere mocks base method.

func (*MockTransaction) EXPECT 

func (m *MockTransaction) EXPECT() *MockTransactionMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTransaction) Implementation 

func (m *MockTransaction) Implementation() Implementation

Implementation mocks base method.

func (*MockTransaction) List 

func (m *MockTransaction) List(arg0 record.Record, arg1 any, arg2 record.ListOptions) errors.TracerError

List mocks base method.

func (*MockTransaction) ListWhere 

func (m *MockTransaction) ListWhere(arg0 record.Record, arg1 any, arg2 *qb.ConditionExpression, arg3 record.ListOptions) errors.TracerError

ListWhere mocks base method.

func (*MockTransaction) Read 

func (m *MockTransaction) Read(arg0 record.Record, arg1 record.PrimaryKeyValue) errors.TracerError

Read mocks base method.

func (*MockTransaction) ReadOneWhere 

func (m *MockTransaction) ReadOneWhere(arg0 record.Record, arg1 *qb.ConditionExpression) errors.TracerError

ReadOneWhere mocks base method.

func (*MockTransaction) Rollback 

func (m *MockTransaction) Rollback() errors.TracerError

Rollback mocks base method.

func (*MockTransaction) Select 

func (m *MockTransaction) Select(arg0 any, arg1 *qb.SelectQuery, arg2 record.ListOptions) errors.TracerError

Select mocks base method.

func (*MockTransaction) Update 

func (m *MockTransaction) Update(arg0 record.Record) errors.TracerError

Update mocks base method.

func (*MockTransaction) UpdateWhere 

func (m *MockTransaction) UpdateWhere(arg0 record.Record, arg1 *qb.ConditionExpression, arg2 ...qb.FieldValue) (int64, errors.TracerError)

UpdateWhere mocks base method.

func (*MockTransaction) Upsert 

func (m *MockTransaction) Upsert(arg0 record.Record) errors.TracerError

Upsert mocks base method.

type MockTransactionMockRecorder 

type MockTransactionMockRecorder struct {
	// contains filtered or unexported fields
}

MockTransactionMockRecorder is the mock recorder for MockTransaction.

func (*MockTransactionMockRecorder) Commit 

func (mr *MockTransactionMockRecorder) Commit() *gomock.Call

Commit indicates an expected call of Commit.

func (*MockTransactionMockRecorder) Create 

func (mr *MockTransactionMockRecorder) Create(arg0 interface{}) *gomock.Call

Create indicates an expected call of Create.

func (*MockTransactionMockRecorder) Delete 

func (mr *MockTransactionMockRecorder) Delete(arg0 interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockTransactionMockRecorder) DeleteWhere 

func (mr *MockTransactionMockRecorder) DeleteWhere(arg0, arg1 interface{}) *gomock.Call

DeleteWhere indicates an expected call of DeleteWhere.

func (*MockTransactionMockRecorder) Implementation 

func (mr *MockTransactionMockRecorder) Implementation() *gomock.Call

Implementation indicates an expected call of Implementation.

func (*MockTransactionMockRecorder) List 

func (mr *MockTransactionMockRecorder) List(arg0, arg1, arg2 interface{}) *gomock.Call

List indicates an expected call of List.

func (*MockTransactionMockRecorder) ListWhere 

func (mr *MockTransactionMockRecorder) ListWhere(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

ListWhere indicates an expected call of ListWhere.

func (*MockTransactionMockRecorder) Read 

func (mr *MockTransactionMockRecorder) Read(arg0, arg1 interface{}) *gomock.Call

Read indicates an expected call of Read.

func (*MockTransactionMockRecorder) ReadOneWhere 

func (mr *MockTransactionMockRecorder) ReadOneWhere(arg0, arg1 interface{}) *gomock.Call

ReadOneWhere indicates an expected call of ReadOneWhere.

func (*MockTransactionMockRecorder) Rollback 

func (mr *MockTransactionMockRecorder) Rollback() *gomock.Call

Rollback indicates an expected call of Rollback.

func (*MockTransactionMockRecorder) Select 

func (mr *MockTransactionMockRecorder) Select(arg0, arg1, arg2 interface{}) *gomock.Call

Select indicates an expected call of Select.

func (*MockTransactionMockRecorder) Update 

func (mr *MockTransactionMockRecorder) Update(arg0 interface{}) *gomock.Call

Update indicates an expected call of Update.

func (*MockTransactionMockRecorder) UpdateWhere 

func (mr *MockTransactionMockRecorder) UpdateWhere(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateWhere indicates an expected call of UpdateWhere.

func (*MockTransactionMockRecorder) Upsert 

func (mr *MockTransactionMockRecorder) Upsert(arg0 interface{}) *gomock.Call

Upsert indicates an expected call of Upsert.

type Transaction 

type Transaction interface {
	// Create initializes a Record and inserts it into the Database
	Create(record.Record) errors.TracerError
	// Upsert a new entry into the database for the Record
	Upsert(record.Record) errors.TracerError
	// Read populates a Record from the database
	Read(record.Record, record.PrimaryKeyValue) errors.TracerError
	// ReadOneWhere populates a Record from a custom where clause
	ReadOneWhere(record.Record, *qb.ConditionExpression) errors.TracerError
	// List populates obj with a list of Records from the database
	// TODO: [COR-586] we can expand the Record interface to return an collection
	// 		 of its type so we don't have to pass this clumsily
	List(record.Record, any, record.ListOptions) errors.TracerError
	// ListWhere populates target with a list of Records from the database
	// TODO: [COR-586] we can expand the Record interface to return a collection
	// 		 of its type so we don't have to pass this clumsily
	ListWhere(record.Record, any, *qb.ConditionExpression, record.ListOptions) errors.TracerError
	// Select executes a given select query and populates the target
	// TODO: [COR-586] we can expand the Record interface to return a collection
	// 		 of its type so we don't have to pass this clumsily
	Select(any, *qb.SelectQuery, record.ListOptions) errors.TracerError
	// Update replaces an entry in the database for the Record
	Update(record.Record) errors.TracerError
	// UpdateWhere updates fields for the Record based on a supplied where clause in a transaction
	UpdateWhere(record.Record, *qb.ConditionExpression, ...qb.FieldValue) (int64, errors.TracerError)
	// Delete removes a row from the database
	Delete(record.Record) errors.TracerError
	// DeleteWhere removes row(s) from the database based on a supplied where clause
	DeleteWhere(record.Record, *qb.ConditionExpression) errors.TracerError
	// Commit this transaction
	Commit() errors.TracerError
	// Rollback this transaction
	Rollback() errors.TracerError

	// Implementation that is backing this transaction
	Implementation() Implementation
}

Transaction is an in-progress database transaction.

A transaction must end with a call to Commit or Rollback.

After a call to Commit or Rollback, all operations on the transaction fail with ErrTxDone.

func New 

func New(db Begin, logger log.Logger, slow time.Duration) (Transaction, error)

New transaction that will log query executions that are slower than the passed duration

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.