sql

package

v0.2.1 Latest Latest Go to latest Published: Jun 20, 2019 License: GPL-3.0 Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/signavio/workflow-connector

Links

Open Source Insights

Documentation ¶

Overview ¶

Package sql defines a Backend that is responsible for communicating with SQL databases and other external systems

Index ¶

Variables
func GetWorkflowType(columnWithTable string) interface{}
func New() endpoint.Endpoint
type NullTime
- func (nt *NullTime) Scan(value interface{}) error
- func (nt NullTime) Value() (driver.Value, error)
type SqlBackend

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrUnexpectedJSON         = errors.New("Received JSON data that we are unable to parse")
	ErrMismatchedAffectedRows = errors.New("The amount of rows affected should be sane")
	ErrNoLastInsertID         = errors.New("Database does not support getting the last inserted ID")
)

Functions ¶

func GetWorkflowType ¶

func GetWorkflowType(columnWithTable string) interface{}

func New ¶

func New() endpoint.Endpoint

Types ¶

type NullTime ¶

type NullTime struct {
	Time  time.Time
	Valid bool // Valid is true if Time is not NULL
}

func (*NullTime) Scan ¶

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

Scan implements the Scanner interface.

func (NullTime) Value ¶

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

Value implements the driver Valuer interface.

type SqlBackend ¶

type SqlBackend struct {
	*backend.Backend
	DB                     *sql.DB
	Templates              map[string]string
	SchemaMapping          map[string]*descriptor.SchemaMapping
	FilterPredicateMapping map[filter.Predicate]string
	NewSchemaMapping       func([]string, []*sql.ColumnType) (*descriptor.SchemaMapping, error)
	Transactions           sync.Map
}

func (*SqlBackend) DeleteTx ¶

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

func (*SqlBackend) LoadTx ¶

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

func (*SqlBackend) SaveSchemaMapping ¶

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

func (*SqlBackend) StoreTx ¶

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
mysql
oracle
postgres
sqlserver

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL