mysql

type ConnectionCommonIfc interface {
	InTransaction() bool
	Begin() error
	NewQuery(query SQLQueryIfc) (QueryIfc, error)
	Commit() error
	Rollback() error
	Exec(query SQLQueryIfc, args ...interface{}) (sql.Result, error)
	Query(query SQLQueryIfc, args ...interface{}) (*sql.Rows, error)
	QueryRow(query SQLQueryIfc, args ...interface{}) *sql.Row
}

type ConnectionIfc interface {
	IsConnected() bool
	ConnectionCommonIfc
}

type ConnectionPoolIfc interface {
	// Embedded interface(s)
	startable.StartableIfc
	dep.DependencyInjectableIfc
	cfg.ConfigurableIfc

	// Our own interface
	GetConnection() (*leasedConnection, error)
	Release(leaseKey int64) error
	GetMaxIdle() int
	Close() error
}

type LeasedConnectionIfc interface {
	ConnectionCommonIfc

	Release() error
}

type LeasedConnectionsIfc interface {
	// Public interface
	GetLeaseForConnection(connection PooledConnectionIfc) *leasedConnection
	Release(leaseKey int64) bool
	// contains filtered or unexported methods
}

type PooledConnectionIfc interface {

	// Connections
	IsConnected() bool

	// Leasing
	IsLeased() bool
	MatchesLeaseKey(leaseKey int64) bool
	Lease(leaseKey int64)
	Release() error
	Touch()
	IsExpired() bool

	ConnectionCommonIfc
}

type QueryIfc interface {
	Run(args ...interface{}) (*result, error)
	RunReturnValue(receiver interface{}, args ...interface{}) error
	RunReturnInt(args ...interface{}) (*int, error)
	RunReturnString(args ...interface{}) (*string, error)
	RunReturnOne(args ...interface{}) (*ResultRow, error)
	RunReturnAll(args ...interface{}) (*resultSet, error)
	RunReturnSome(max int, args ...interface{}) (*resultSet, error)
}

type ResultIfc interface {
	GetLastInsertId() (*int64, error)
	GetRowsAffected() (*int64, error)
}

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

type ResultRowIfc interface {
	Get(field string) nullables.NullableIfc
	Set(field string, value nullables.Nullable)
	Has(field string) bool
	Fields() []string
	ToJson() (*string, error)
}

type ResultSetIfc interface {
	// Embedded interface(s)
	it.IterableIfc

	// Our own interface
	Get(rowNum int) *ResultRow
	Len() int
	IsEmpty() bool
	Add(result ResultRowIfc)
	IsFinalized() bool
	Finalize()
	ToJson() (*string, error)
}

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

type SQLQueryIfc interface {
	// Resolve the query as a string or else a non-nil error
	Resolve(args ...interface{}) (string, error)
}