sql

Apr 17, 2019

Changes in this version

+ var ErrMismatchedAffectedRows = errors.New("The amount of rows affected should be sane")

+ var ErrNoLastInsertID = errors.New("Database does not support getting the last inserted ID")

+ var ErrUnexpectedJSON = errors.New("Received JSON data that we are unable to parse")

+ func GetWorkflowType(columnWithTable string) interface

+ func New() endpoint.Endpoint

+ type NullTime struct

+ Time time.Time

+ Valid bool

+ func (nt *NullTime) Scan(value interface{}) error

+ func (nt NullTime) Value() (driver.Value, error)

+ type SqlBackend struct

+ DB *sql.DB

+ FilterPredicateMapping map[filter.Predicate]string

+ NewSchemaMapping func([]string, []*sql.ColumnType) (*descriptor.SchemaMapping, error)

+ SchemaMapping map[string]*descriptor.SchemaMapping

+ Templates map[string]string

+ Transactions sync.Map

+ func (s *SqlBackend) DeleteTx(key interface{})

+ func (s *SqlBackend) LoadTx(key interface{}) (value interface{}, ok bool)

+ func (s *SqlBackend) SaveSchemaMapping() (err error)

+ func (s *SqlBackend) StoreTx(key, value interface{})