Documentation
¶
Index ¶
- type Connection
- type Execer
- func (ex *Execer) Exec() (*dat.Result, error)
- func (ex *Execer) QueryScalar(destinations ...interface{}) error
- func (ex *Execer) QuerySlice(dest interface{}) error
- func (ex *Execer) QueryStruct(dest interface{}) error
- func (ex *Execer) QueryStructs(dest interface{}) error
- func (ex *Execer) Queryx() (*sqlx.Rows, error)
- type M
- type Queryable
- func (q *Queryable) DeleteFrom(table string) *dat.DeleteBuilder
- func (q *Queryable) ExecBuilder(b dat.Builder) error
- func (q *Queryable) InsertInto(table string) *dat.InsertBuilder
- func (q *Queryable) SQL(sql string, args ...interface{}) *dat.RawBuilder
- func (q *Queryable) Select(columns ...string) *dat.SelectBuilder
- func (q *Queryable) Update(table string) *dat.UpdateBuilder
- type Session
- type Tx
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connection ¶
Connection is a connection to the database with an EventReceiver
func NewConnection ¶
func NewConnection(db *sql.DB, driverName string) *Connection
NewConnection instantiates a Connection for a given database/sql connection
func (*Connection) Begin ¶
func (conn *Connection) Begin() (*Tx, error)
Begin creates a transaction for the given session
func (*Connection) Exec ¶
func (conn *Connection) Exec(sql string, args ...interface{}) (sql.Result, error)
func (*Connection) ExecMulti ¶
func (conn *Connection) ExecMulti(sql string) error
ExecMulti executes group SQL statemetns in a string marked by a marker. The deault marker is "GO"
func (*Connection) NewSession ¶
func (cxn *Connection) NewSession() (*Session, error)
NewSession instantiates a Session for the Connection
type Execer ¶
type Execer struct {
// contains filtered or unexported fields
}
Execer implements dat.Execer
func (*Execer) QueryScalar ¶
QueryScalar executes builder's query and scans returned row into destinations.
func (*Execer) QuerySlice ¶
QuerySlice executes builder's query and builds a slice of values from each row, where each row only has one column.
func (*Execer) QueryStruct ¶
QueryStruct executes builders' query and scans the result row into dest.
func (*Execer) QueryStructs ¶
QueryStructs executes builders' query and scans each row as an item in a slice of structs.
type Queryable ¶
type Queryable struct {
// contains filtered or unexported fields
}
Queryable is an object that can be queried.
func (*Queryable) DeleteFrom ¶
func (q *Queryable) DeleteFrom(table string) *dat.DeleteBuilder
DeleteFrom creates a new DeleteBuilder for the given table.
func (*Queryable) ExecBuilder ¶
ExecBuilder executes the SQL in builder.
func (*Queryable) InsertInto ¶
func (q *Queryable) InsertInto(table string) *dat.InsertBuilder
InsertInto creates a new InsertBuilder for the given table.
func (*Queryable) SQL ¶
func (q *Queryable) SQL(sql string, args ...interface{}) *dat.RawBuilder
SQL creates a new raw SQL builder.
type Session ¶
type Session struct {
*Tx
}
Session represents a business unit of execution for some connection
type Tx ¶
Tx is a transaction for the given Session
func (*Tx) AutoCommit ¶
AutoCommit commits a transaction IF neither Commit or Rollback were called.
func (*Tx) AutoRollback ¶
AutoRollback rolls back transaction IF neither Commit or Rollback were called.
Source Files