Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

sqlike

package

Go to main page

Versions in this module

v1

v1.0.8

Jan 22, 2024

v1.0.7

Jan 19, 2024

v1.0.6

Mar 17, 2023

v1.0.5

Feb 2, 2023

v1.0.4

Jan 20, 2023

v1.0.3

Jan 18, 2023

v1.0.2

Oct 27, 2022

v1.0.1

Oct 27, 2022

Changes in this version

type Database

+ func (tb *Database) InjectResolution(ctx context.Context, queries ...primitive.Group) context.Context

type Table

+ func (tb *Table) InjectResolution(ctx context.Context, queries ...primitive.Group) context.Context

v1.0.0

Sep 21, 2022

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 ConnectDB(ctx context.Context, driver string, conn driver.Connector) (*Client, error)

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

+ func MustConnectDB(ctx context.Context, driver string, conn driver.Connector) *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) SetCodec(cdc codec.Codecer) *Client

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

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

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

+ type Column struct

+ Charset *string

+ Collation *string

+ Comment 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, paths ...string) error

+ func (db *Database) Name() string

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

+ 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) DropAll(ctx context.Context) 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) NextResultSet() bool

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

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

+ type Resulter interface

+ Close func() error

+ Columns func() []string

+ Next func() bool

+ NextResultSet func() bool

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

+ type SessionContext interface

+ 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)

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

+ QueryStmt func(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{}, opts ...*options.DestroyOneOptions) 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) MustUnsafeMigrate(ctx context.Context, entity interface{})

+ 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) UnsafeMigrate(ctx context.Context, entity interface{}) 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{})

+ type Transaction struct

+ func (tx *Transaction) CommitTransaction() error

+ 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)

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

+ func (tx *Transaction) QueryStmt(query interface{}) (*Result, error)

+ func (tx *Transaction) RollbackTransaction() error

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