Package sqladapter provides common logic for SQL adapters.



    This section is empty.


    This section is empty.


    func IsKeyValue

    func IsKeyValue(v interface{}) bool

      IsKeyValue reports whether v is a valid value for a primary key that can be used with Find(pKey).

      func NumActiveStatements

      func NumActiveStatements() int64

        NumActiveStatements returns the global number of prepared statements in use at any point.

        func RegisterAdapter

        func RegisterAdapter(name string, adapter AdapterSession) sqlbuilder.Adapter

          RegisterAdapter registers a new SQL adapter.

          func ReplaceWithDollarSign

          func ReplaceWithDollarSign(in string) string

            ReplaceWithDollarSign turns a SQL statament with '?' placeholders into dollar placeholders, like $1, $2, ..., $n

            func TxContext

            func TxContext(ctx context.Context, sess db.Session, fn func(tx db.Session) error, opts *sql.TxOptions) error

              TxContext creates a transaction context and runs fn within it.


              type AdapterSession

              type AdapterSession interface {
              	Template() *exql.Template
              	NewCollection() CollectionAdapter
              	// Open opens a new connection
              	OpenDSN(sess Session, dsn string) (*sql.DB, error)
              	// Collections returns a list of non-system tables from the database.
              	Collections(sess Session) ([]string, error)
              	// TableExists returns an error if the given table does not exist.
              	TableExists(sess Session, name string) error
              	// LookupName returns the name of the database.
              	LookupName(sess Session) (string, error)
              	// PrimaryKeys returns all primary keys on the table.
              	PrimaryKeys(sess Session, name string) ([]string, error)

                AdapterSession defines methods to be implemented by SQL adapters.

                type Collection

                type Collection interface {
                	// Insert inserts a new item into the collection.
                	Insert(interface{}) (db.InsertResult, error)
                	// Name returns the name of the collection.
                	Name() string
                	// Session returns the db.Session the collection belongs to.
                	Session() db.Session
                	// Exists returns true if the collection exists, false otherwise.
                	Exists() (bool, error)
                	// Find defined a new result set.
                	Find(conds ...interface{}) db.Result
                	Count() (uint64, error)
                	// Truncate removes all elements on the collection and resets the
                	// collection's IDs.
                	Truncate() error
                	// InsertReturning inserts a new item into the collection and refreshes the
                	// item with actual data from the database. This is useful to get automatic
                	// values, such as timestamps, or IDs.
                	InsertReturning(item interface{}) error
                	// UpdateReturning updates a record from the collection and refreshes the item
                	// with actual data from the database. This is useful to get automatic
                	// values, such as timestamps, or IDs.
                	UpdateReturning(item interface{}) error
                	// PrimaryKeys returns the names of all primary keys in the table.
                	PrimaryKeys() ([]string, error)
                	// SQLBuilder returns a db.SQL instance.
                	SQL() db.SQL

                  Collection satisfies db.Collection.

                  func NewCollection

                  func NewCollection(sess Session, name string, adapter CollectionAdapter) Collection

                    NewCollection initializes a Collection by wrapping a CollectionAdapter.

                    type CollectionAdapter

                    type CollectionAdapter interface {
                    	// Insert prepares and executes an INSERT statament. When the item is
                    	// succefully added, Insert returns a unique identifier of the newly added
                    	// element (or nil if the unique identifier couldn't be determined).
                    	Insert(Collection, interface{}) (interface{}, error)

                      CollectionAdapter defines methods to be implemented by SQL adapters.

                      type QueryStatus

                      type QueryStatus struct {
                      	SessID uint64
                      	TxID   uint64
                      	RowsAffected *int64
                      	LastInsertID *int64
                      	Query string
                      	Args  []interface{}
                      	Err error
                      	Start time.Time
                      	End   time.Time
                      	Context context.Context

                        QueryStatus represents the status of a query after being executed.

                        func (*QueryStatus) String

                        func (q *QueryStatus) String() string

                          String returns a formatted log message.

                          type Result

                          type Result struct {
                          	// contains filtered or unexported fields

                          func NewResult

                          func NewResult(builder db.SQL, table string, conds []interface{}) *Result

                            NewResult creates and Results a new Result set on the given table, this set is limited by the given exql.Where conditions.

                            func (*Result) All

                            func (r *Result) All(dst interface{}) error

                              All dumps all Results into a pointer to an slice of structs or maps.

                              func (*Result) And

                              func (r *Result) And(conds ...interface{}) db.Result

                                And adds more conditions on top of the existing ones.

                                func (*Result) Base

                                func (r *Result) Base() interface{}

                                func (*Result) Close

                                func (r *Result) Close() error

                                  Close closes the Result set.

                                  func (*Result) Count

                                  func (r *Result) Count() (uint64, error)

                                    Count counts the elements on the set.

                                    func (*Result) Cursor

                                    func (r *Result) Cursor(cursorColumn string) db.Result

                                    func (*Result) Delete

                                    func (r *Result) Delete() error

                                      Delete deletes all matching items from the collection.

                                      func (*Result) Err

                                      func (r *Result) Err() error

                                        Err returns the last error that has happened with the result set, nil otherwise

                                        func (*Result) Exists

                                        func (r *Result) Exists() (bool, error)

                                          Exists returns true if at least one item on the collection exists.

                                          func (*Result) Fn

                                          func (r *Result) Fn(in interface{}) error

                                          func (*Result) GroupBy

                                          func (r *Result) GroupBy(fields ...interface{}) db.Result

                                            GroupBy is used to group Results that have the same value in the same column or columns.

                                            func (*Result) Limit

                                            func (r *Result) Limit(n int) db.Result

                                              Limit determines the maximum limit of Results to be returned.

                                              func (*Result) Next

                                              func (r *Result) Next(dst interface{}) bool

                                                Next fetches the next Result from the set.

                                                func (*Result) NextPage

                                                func (r *Result) NextPage(cursorValue interface{}) db.Result

                                                func (*Result) Offset

                                                func (r *Result) Offset(n int) db.Result

                                                  Offset determines how many documents will be skipped before starting to grab Results.

                                                  func (*Result) One

                                                  func (r *Result) One(dst interface{}) error

                                                    One fetches only one Result from the set.

                                                    func (*Result) OrderBy

                                                    func (r *Result) OrderBy(fields ...interface{}) db.Result

                                                      OrderBy determines sorting of Results according to the provided names. Fields may be prefixed by - (minus) which means descending order, ascending order would be used otherwise.

                                                      func (*Result) Page

                                                      func (r *Result) Page(pageNumber uint) db.Result

                                                      func (*Result) Paginate

                                                      func (r *Result) Paginate(pageSize uint) db.Result

                                                      func (*Result) Prev

                                                      func (r *Result) Prev() immutable.Immutable

                                                      func (*Result) PrevPage

                                                      func (r *Result) PrevPage(cursorValue interface{}) db.Result

                                                      func (*Result) SQL

                                                      func (r *Result) SQL() db.SQL

                                                      func (*Result) Select

                                                      func (r *Result) Select(fields ...interface{}) db.Result

                                                        Select determines which fields to return.

                                                        func (*Result) String

                                                        func (r *Result) String() string

                                                          String satisfies fmt.Stringer

                                                          func (*Result) TotalEntries

                                                          func (r *Result) TotalEntries() (uint64, error)

                                                          func (*Result) TotalPages

                                                          func (r *Result) TotalPages() (uint, error)

                                                          func (*Result) Update

                                                          func (r *Result) Update(values interface{}) error

                                                            Update updates matching items from the collection with values of the given map or struct.

                                                            func (*Result) Where

                                                            func (r *Result) Where(conds ...interface{}) db.Result

                                                              Where sets conditions for the result set.

                                                              type Session

                                                              type Session interface {
                                                              	SQL() db.SQL
                                                              	// PrimaryKeys returns all primary keys on the table.
                                                              	PrimaryKeys(tableName string) ([]string, error)
                                                              	// Collections returns a list of references to all collections in the
                                                              	// database.
                                                              	Collections() ([]db.Collection, error)
                                                              	// Name returns the name of the database.
                                                              	Name() string
                                                              	// Close closes the database session
                                                              	Close() error
                                                              	// Ping checks if the database server is reachable.
                                                              	Ping() error
                                                              	// Reset clears all caches the session is using
                                                              	// Collection returns a new collection.
                                                              	Collection(string) db.Collection
                                                              	// ConnectionURL returns the ConnectionURL that was used to create the
                                                              	// Session.
                                                              	ConnectionURL() db.ConnectionURL
                                                              	// Open attempts to establish a connection to the database server.
                                                              	Open() error
                                                              	// TableExists returns an error if the table doesn't exists.
                                                              	TableExists(name string) error
                                                              	// Driver returns the underlying driver the session is using
                                                              	Driver() interface{}
                                                              	Save(db.Record) error
                                                              	Get(db.Record, interface{}) error
                                                              	Delete(db.Record) error
                                                              	// WaitForConnection attempts to run the given connection function a fixed
                                                              	// number of times before failing.
                                                              	WaitForConnection(func() error) error
                                                              	// BindDB sets the *sql.DB the session will use.
                                                              	BindDB(*sql.DB) error
                                                              	// Session returns the *sql.DB the session is using.
                                                              	DB() *sql.DB
                                                              	// BindTx binds a transaction to the current session.
                                                              	BindTx(context.Context, *sql.Tx) error
                                                              	// Returns the current transaction the session is using.
                                                              	Transaction() *sql.Tx
                                                              	// NewClone clones the database using the given AdapterSession as base.
                                                              	NewClone(AdapterSession, bool) (Session, error)
                                                              	// Context returns the default context the session is using.
                                                              	Context() context.Context
                                                              	// SetContext sets a default context for the session.
                                                              	NewTransaction(ctx context.Context, opts *sql.TxOptions) (Session, error)
                                                              	Tx(fn func(sess db.Session) error) error
                                                              	TxContext(ctx context.Context, fn func(sess db.Session) error, opts *sql.TxOptions) error
                                                              	WithContext(context.Context) db.Session
                                                              	IsTransaction() bool
                                                              	Commit() error
                                                              	Rollback() error

                                                                Session satisfies db.Session.

                                                                func NewSession

                                                                func NewSession(connURL db.ConnectionURL, adapter AdapterSession) Session

                                                                  NewSession creates a new Session.

                                                                  func NewTx

                                                                  func NewTx(adapter AdapterSession, tx *sql.Tx) (Session, error)

                                                                    NewTx wraps a *sql.Tx and returns a Tx.

                                                                    type Stmt

                                                                    type Stmt struct {
                                                                    	// contains filtered or unexported fields

                                                                      Stmt represents a *sql.Stmt that is cached and provides the OnPurge method to allow it to clean after itself.

                                                                      func NewStatement

                                                                      func NewStatement(stmt *sql.Stmt, query string) *Stmt

                                                                        NewStatement creates an returns an opened statement

                                                                        func (*Stmt) Close

                                                                        func (c *Stmt) Close() error

                                                                          Close closes the underlying statement if no other go-routine is using it.

                                                                          func (*Stmt) OnPurge

                                                                          func (c *Stmt) OnPurge()

                                                                            OnPurge marks the statement as ready to be cleaned up.

                                                                            func (*Stmt) Open

                                                                            func (c *Stmt) Open() (*Stmt, error)

                                                                              Open marks the statement as in-use


                                                                              Path Synopsis