sqlike

Feb 15, 2022

Changes in this version

type Database

+ func (db *Database) Name() string

+ func (db *Database) QueryRow(ctx context.Context, query string, args ...interface{}) SingleResult

Mar 21, 2021

Changes in this version

type SessionContext

+ QueryRow func(query string, args ...interface{}) *sql.Row

type Transaction

+ func (tx *Transaction) QueryRow(query string, args ...interface{}) *sql.Row

Mar 21, 2021

Changes in this version

type SessionContext

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ Prepare func(query string) (*sql.Stmt, error)

+ Query func(query string, args ...interface{}) (*sql.Rows, error)

type Transaction

+ func (tx *Transaction) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (tx *Transaction) Prepare(query string) (*sql.Stmt, error)

+ func (tx *Transaction) Query(query string, args ...interface{}) (*sql.Rows, error)

Sep 12, 2020

Changes in this version

type Column

+ Comment string

May 17, 2020

Changes in this version

type Client

+ func (c *Client) SetStructMapper(mapper reflext.StructMapper) *Client

May 1, 2020

Changes in this version

type Client

+ func ConnectDB(ctx context.Context, driver string, conn driver.Connector) (*Client, error)

+ func MustConnectDB(ctx context.Context, driver string, conn driver.Connector) *Client

type Result

+ func (r *Result) NextResultSet() bool

+ type Resulter interface

+ Close func() error

+ Columns func() []string

+ Next func() bool

+ NextResultSet func() bool

+ Scan func(dests ...interface{}) error

Apr 23, 2020

Changes in this version

type Client

+ func (c *Client) SetCodec(cdc codec.Codecer) *Client

type IndexView

+ func (idv *IndexView) DropAll(ctx context.Context) error

Feb 23, 2020

Changes in this version

+ var EOF = io.EOF

+ var ErrEmptyFields = errors.New("empty fields")

+ var ErrExpectedStruct = errors.New("expected struct as a source")

+ var ErrInvalidCursor = errors.New("sqlike: invalid cursor")

+ var ErrInvalidInput = errors.New("sqlike: invalid input <nil>")

+ var ErrNilEntity = errors.New("sqlike: entity is <nil>")

+ var ErrNoColumn = errors.New("sqlike: no columns to create index")

+ var ErrNoRecordAffected = errors.New("no record affected")

+ var ErrNoRows = sql.ErrNoRows

+ var ErrNoValueUpdate = errors.New("sqlike: no value to update")

+ var ErrUnaddressableEntity = errors.New("sqlike: unaddressable entity")

+ type Client struct

+ func Connect(ctx context.Context, driver string, opt *options.ConnectOptions) (client *Client, err error)

+ func MustConnect(ctx context.Context, driver string, opt *options.ConnectOptions) *Client

+ func MustOpen(ctx context.Context, driver string, opt *options.ConnectOptions) *Client

+ func Open(ctx context.Context, driver string, opt *options.ConnectOptions) (client *Client, err error)

+ func (c *Client) CreateDatabase(ctx context.Context, name string) error

+ func (c *Client) Database(name string) *Database

+ func (c *Client) DropDatabase(ctx context.Context, name string) error

+ func (c *Client) ListDatabases(ctx context.Context) ([]string, error)

+ func (c *Client) SetLogger(logger logs.Logger) *Client

+ func (c *Client) SetPrimaryKey(pk string) *Client

+ type Column struct

+ Charset *string

+ Collation *string

+ DataType string

+ DefaultValue *string

+ Extra string

+ IsNullable types.Boolean

+ Name string

+ Position int

+ Type string

+ type ColumnView struct

+ func (cv *ColumnView) DropOne(ctx context.Context, name string) error

+ func (cv *ColumnView) List(ctx context.Context) ([]Column, error)

+ func (cv *ColumnView) Rename(ctx context.Context, oldColName, newColName string) error

+ type Database struct

+ func (db *Database) BeginTransaction(ctx context.Context, opts ...*sql.TxOptions) (*Transaction, error)

+ func (db *Database) BuildIndexes(ctx context.Context, filepath ...string) error

+ func (db *Database) QueryStmt(ctx context.Context, query interface{}) (*Result, error)

+ func (db *Database) RunInTransaction(ctx context.Context, cb txCallback, opts ...*options.TransactionOptions) error

+ func (db *Database) Table(name string) *Table

+ type DriverInfo struct

+ func (d *DriverInfo) Charset() charset.Code

+ func (d *DriverInfo) Collate() string

+ func (d *DriverInfo) DriverName() string

+ func (d *DriverInfo) Version() *semver.Version

+ type Index struct

+ IsUnique bool

+ Name string

+ Type string

+ type IndexView struct

+ func (idv *IndexView) Create(ctx context.Context, idxs []indexes.Index) error

+ func (idv *IndexView) CreateIfNotExists(ctx context.Context, idxs []indexes.Index) error

+ func (idv *IndexView) CreateOne(ctx context.Context, idx indexes.Index) error

+ func (idv *IndexView) CreateOneIfNotExists(ctx context.Context, idx indexes.Index) error

+ func (idv *IndexView) List(ctx context.Context) ([]Index, error)

+ func (idv IndexView) DropOne(ctx context.Context, name string) error

+ type Paginator struct

+ func (pg *Paginator) All(results interface{}) error

+ func (pg *Paginator) NextCursor(ctx context.Context, cursor interface{}) (err error)

+ type Result struct

+ func (r *Result) All(results interface{}) error

+ func (r *Result) Close() error

+ func (r *Result) ColumnTypes() ([]*sql.ColumnType, error)

+ func (r *Result) Columns() []string

+ func (r *Result) Decode(dst interface{}) error

+ func (r *Result) Error() error

+ func (r *Result) Next() bool

+ func (r *Result) Scan(dests ...interface{}) error

+ func (r *Result) ScanSlice(results interface{}) error

+ type SessionContext interface

+ QueryStmt func(ctx context.Context, query interface{}) (*Result, error)

+ Table func(name string) *Table

+ type SingleResult interface

+ ColumnTypes func() ([]*sql.ColumnType, error)

+ Columns func() []string

+ Decode func(dest interface{}) error

+ Error func() error

+ Scan func(dest ...interface{}) error

+ type Table struct

+ func (tb *Table) Columns() *ColumnView

+ func (tb *Table) Delete(ctx context.Context, act actions.DeleteStatement, ...) (int64, error)

+ func (tb *Table) DeleteOne(ctx context.Context, act actions.DeleteOneStatement, ...) (int64, error)

+ func (tb *Table) DestroyOne(ctx context.Context, delete interface{}) error

+ func (tb *Table) Exists(ctx context.Context) bool

+ func (tb *Table) Find(ctx context.Context, act actions.SelectStatement, opts ...*options.FindOptions) (*Result, error)

+ func (tb *Table) FindOne(ctx context.Context, act actions.SelectOneStatement, ...) SingleResult

+ func (tb *Table) HasIndexByName(ctx context.Context, name string) (bool, error)

+ func (tb *Table) Indexes() *IndexView

+ func (tb *Table) Insert(ctx context.Context, src interface{}, opts ...*options.InsertOptions) (sql.Result, error)

+ func (tb *Table) InsertOne(ctx context.Context, src interface{}, opts ...*options.InsertOneOptions) (sql.Result, error)

+ func (tb *Table) ListColumns(ctx context.Context) ([]Column, error)

+ func (tb *Table) ListIndexes(ctx context.Context) ([]Index, error)

+ func (tb *Table) Migrate(ctx context.Context, entity interface{}) error

+ func (tb *Table) ModifyOne(ctx context.Context, update interface{}, opts ...*options.ModifyOneOptions) error

+ func (tb *Table) Paginate(ctx context.Context, act actions.PaginateStatement, ...) (*Paginator, error)

+ func (tb *Table) Rename(ctx context.Context, name string) error

+ func (tb *Table) Replace(ctx context.Context, fields []string, query *sql.SelectStmt) error

+ func (tb *Table) ReplaceOne(ctx context.Context, src interface{}, opts ...*options.InsertOneOptions) (sql.Result, error)

+ func (tb *Table) Truncate(ctx context.Context) (err error)

+ func (tb *Table) Update(ctx context.Context, act actions.UpdateStatement, ...) (int64, error)

+ func (tb *Table) UpdateOne(ctx context.Context, act actions.UpdateOneStatement, ...) (int64, error)

+ func (tb Table) Drop(ctx context.Context) (err error)

+ func (tb Table) DropIfExists(ctx context.Context) (err error)

+ func (tb Table) MustMigrate(ctx context.Context, entity interface{})

+ func (tb Table) MustUnsafeMigrate(ctx context.Context, entity interface{})

+ func (tb Table) UnsafeMigrate(ctx context.Context, entity interface{}) error

+ type Transaction struct

+ func (tx *Transaction) CommitTransaction() error

+ func (tx *Transaction) QueryStmt(ctx context.Context, query interface{}) (*Result, error)

+ func (tx *Transaction) RollbackTransaction() error

+ func (tx *Transaction) Table(name string) *Table