sqly

Oct 26, 2020

Changes in this version

type Capsule

+ func (c *Capsule) Close() error

+ func (c *Capsule) IsTrans(ctx context.Context) (bool, error)

Sep 16, 2020

Changes in this version

+ var ErrCapsule = errors.New("query capsule is not available")

+ var ErrEmptyArrayInStatement = errors.New("has empty array in query arguments")

+ type CapFunc func(ctx context.Context) (interface{}, error)

+ type Capsule struct

+ func NewCapsule(sqlY *SqlY) *Capsule

+ func (c *Capsule) Delete(ctx context.Context, query string, args ...interface{}) (*Affected, error)

+ func (c *Capsule) Exec(ctx context.Context, query string, args ...interface{}) (*Affected, error)

+ func (c *Capsule) ExecMany(ctx context.Context, queries []string) error

+ func (c *Capsule) Get(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (c *Capsule) Insert(ctx context.Context, query string, args ...interface{}) (*Affected, error)

+ func (c *Capsule) InsertMany(ctx context.Context, query string, args [][]interface{}) (*Affected, error)

+ func (c *Capsule) Query(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (c *Capsule) StartCapsule(ctx context.Context, isTrans bool, capFunc CapFunc) (interface{}, error)

+ func (c *Capsule) Update(ctx context.Context, query string, args ...interface{}) (*Affected, error)

+ func (c *Capsule) UpdateMany(ctx context.Context, query string, args [][]interface{}) (*Affected, error)

May 30, 2020

Changes in this version

type SqlY

+ func (s *SqlY) UpdateMany(query string, args [][]interface{}) (*Affected, error)

+ func (s *SqlY) UpdateManyCtx(ctx context.Context, query string, args [][]interface{}) (*Affected, error)

type Trans

+ func (t *Trans) UpdateMany(query string, args [][]interface{}) (*Affected, error)

+ func (t *Trans) UpdateManyCtx(ctx context.Context, query string, args [][]interface{}) (*Affected, error)

May 6, 2020

Changes in this version

type SqlY

+ func (s *SqlY) Close() error

Nov 27, 2019

Changes in this version

+ var ErrArgType = errors.New("invalid variable type for argument")

+ var ErrContainer = errors.New("invalid container for scanning (struct pointer, not nil)")

+ var ErrEmpty = errors.New("no result for get query ")

+ var ErrFieldsMatch = errors.New("queried fields not match with struct fields")

+ var ErrMultiRes = errors.New("get more than one results for get query")

+ var ErrQueryFmt = errors.New("query can't be formatted")

+ var ErrStatement = errors.New("sql statement syntax error")

+ func QueryFmt(fmtStr string, args ...interface{}) (string, error)

+ type Affected struct

+ LastId int64

+ RowsAffected int64

+ type Boolean bool

+ func (b *Boolean) Scan(val interface{}) error

+ type NullBool sql.NullBool

+ func (ns *NullBool) MarshalJSON() ([]byte, error)

+ func (ns *NullBool) Scan(val interface{}) error

+ func (ns *NullBool) UnmarshalJSON(b []byte) error

+ type NullFloat64 sql.NullFloat64

+ func (ns *NullFloat64) MarshalJSON() ([]byte, error)

+ func (ns *NullFloat64) Scan(val interface{}) error

+ func (ns *NullFloat64) UnmarshalJSON(b []byte) error

+ type NullInt32 sql.NullInt32

+ func (ns *NullInt32) MarshalJSON() ([]byte, error)

+ func (ns *NullInt32) Scan(val interface{}) error

+ func (ns *NullInt32) UnmarshalJSON(b []byte) error

+ type NullInt64 sql.NullInt64

+ func (ns *NullInt64) MarshalJSON() ([]byte, error)

+ func (ns *NullInt64) Scan(val interface{}) error

+ func (ns *NullInt64) UnmarshalJSON(b []byte) error

+ type NullString sql.NullString

+ func (ns *NullString) MarshalJSON() ([]byte, error)

+ func (ns *NullString) Scan(val interface{}) error

+ func (ns *NullString) UnmarshalJSON(b []byte) error

+ type NullTime sql.NullTime

+ func (ns *NullTime) MarshalJSON() ([]byte, error)

+ func (ns *NullTime) Scan(val interface{}) error

+ func (ns *NullTime) UnmarshalJSON(b []byte) error

+ type Option struct

+ ConnMaxLifeTime time.Duration

+ DriverName string

+ Dsn string

+ MaxIdleConns int

+ MaxOpenConns int

+ type SqlY struct

+ func New(opt *Option) (*SqlY, error)

+ func (s *SqlY) Delete(query string, args ...interface{}) (*Affected, error)

+ func (s *SqlY) DeleteCtx(ctx context.Context, query string, args ...interface{}) (*Affected, error)

+ func (s *SqlY) Exec(query string, args ...interface{}) (*Affected, error)

+ func (s *SqlY) ExecCtx(ctx context.Context, query string, args ...interface{}) (*Affected, error)

+ func (s *SqlY) ExecMany(queries []string) error

+ func (s *SqlY) ExecManyCtx(ctx context.Context, queries []string) error

+ func (s *SqlY) Get(dest interface{}, query string, args ...interface{}) error

+ func (s *SqlY) GetCtx(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (s *SqlY) Insert(query string, args ...interface{}) (*Affected, error)

+ func (s *SqlY) InsertCtx(ctx context.Context, query string, args ...interface{}) (*Affected, error)

+ func (s *SqlY) InsertMany(query string, args [][]interface{}) (*Affected, error)

+ func (s *SqlY) InsertManyCtx(ctx context.Context, query string, args [][]interface{}) (*Affected, error)

+ func (s *SqlY) NewTrans() (*Trans, error)

+ func (s *SqlY) Ping() error

+ func (s *SqlY) Query(dest interface{}, query string, args ...interface{}) error

+ func (s *SqlY) QueryCtx(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (s *SqlY) Transaction(txFunc TxFunc) (interface{}, error)

+ func (s *SqlY) Update(query string, args ...interface{}) (*Affected, error)

+ func (s *SqlY) UpdateCtx(ctx context.Context, query string, args ...interface{}) (*Affected, error)

+ type Trans struct

+ func (t *Trans) Commit() error

+ func (t *Trans) Delete(query string, args ...interface{}) (*Affected, error)

+ func (t *Trans) DeleteCtx(ctx context.Context, query string, args ...interface{}) (*Affected, error)

+ func (t *Trans) Exec(query string, args ...interface{}) (*Affected, error)

+ func (t *Trans) ExecCtx(ctx context.Context, query string, args ...interface{}) (*Affected, error)

+ func (t *Trans) ExecMany(queries []string) error

+ func (t *Trans) ExecManyCtx(ctx context.Context, queries []string) error

+ func (t *Trans) Get(dest interface{}, query string, args ...interface{}) error

+ func (t *Trans) GetCtx(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (t *Trans) Insert(query string, args ...interface{}) (*Affected, error)

+ func (t *Trans) InsertCtx(ctx context.Context, query string, args ...interface{}) (*Affected, error)

+ func (t *Trans) InsertMany(query string, args [][]interface{}) (*Affected, error)

+ func (t *Trans) InsertManyCtx(ctx context.Context, query string, args [][]interface{}) (*Affected, error)

+ func (t *Trans) Query(dest interface{}, query string, args ...interface{}) error

+ func (t *Trans) QueryCtx(ctx context.Context, dest interface{}, query string, args ...interface{}) error

+ func (t *Trans) Rollback() error

+ func (t *Trans) Update(query string, args ...interface{}) (*Affected, error)

+ func (t *Trans) UpdateCtx(ctx context.Context, query string, args ...interface{}) (*Affected, error)

+ type TxFunc func(tx *Trans) (interface{}, error)