Function newDB

common/persistence/sql/sqlplugin/sqlite/db.go:35–56

newDB returns an instance of DB, which is a logical connection to the underlying sqlite database

(
	dbKind sqlplugin.DbKind,
	dbName string,
	xdb *sqlx.DB,
	tx *sqlx.Tx,
	logger log.Logger,
)

// newDB returns an instance of DB, which is a logical
// connection to the underlying sqlite database
func newDB(
	dbKind sqlplugin.DbKind,
	dbName string,
	xdb *sqlx.DB,
	tx *sqlx.Tx,
	logger log.Logger,
) *db {
	mdb := &db{
		dbKind:  dbKind,
		dbName:  dbName,
		onClose: make([]func(), 0),
		db:      xdb,
		tx:      tx,
		logger:  logger,
	}
	mdb.conn = xdb
	if tx != nil {
		mdb.conn = tx
	}
	mdb.converter = &converter{}
	return mdb
}

// BeginTx starts a new transaction and returns a reference to the Tx object
func (mdb *db) BeginTx(ctx context.Context) (sqlplugin.Tx, error) {