persistence

package

v0.4.0 Latest Latest Go to latest Published: Oct 18, 2019 License: MIT Imports: 3 Imported by: 0

Details

Package persistence provides MySQL-specific implementations of the interfaces in Ax's top-level "persistence" package.

This section is empty.

This section is empty.

func ExtractDB(ds persistence.DataStore) *sql.DB

ExtractDB returns the SQL database within ds. It panics if ds is not a *DataStore.

func ExtractTx(tx persistence.Tx) *sql.Tx

ExtractTx returns the SQL transaction within tx. It panics if tx is not a *Tx.

type DataStore struct {
	DB *sql.DB
}

DataStore is a MySQL-backed implementation of Ax's persistence.DataStore interface.

func (ds *DataStore) BeginTx(ctx context.Context) (persistence.Tx, persistence.Committer, error)

BeginTx starts a new transaction.

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

Tx is a MySQL-backed implementation of Ax's persistence.Tx interface.

func (tx *Tx) DataStore() persistence.DataStore

DataStore returns the DataStore that the transaction operates on.