connection

Documentation

Index

• func CopyDirect(conn database.Connection, tableFName string, srcFile Connection) (cnt uint64, ok bool, err error)
• func ReadConnections(path string) (conns map[string]Connection, err error)
• func ReadConnectionsEnv(env map[string]interface{}) (conns map[string]Connection, err error)
• func ReadDbtConnections() (conns map[string]Connection, err error)
• type Connection
  • func NewConnection(Name string, t dbio.Type, Data map[string]interface{}) (conn Connection, err error)
  • func NewConnectionFromDbt(name string) (c Connection, err error)
  • func NewConnectionFromMap(m map[string]interface{}) (c Connection, err error)
  • func NewConnectionFromProfiles(name string) (c Connection, err error)
  • func NewConnectionFromURL(Name, URL string) (conn Connection, err error)
  • func (c *Connection) AsAirbyte() (*airbyte.Airbyte, error)
  • func (c *Connection) AsDatabase() (database.Connection, error)
  • func (c *Connection) AsFile() (filesys.FileSysClient, error)
  • func (c *Connection) Close() error
  • func (c *Connection) ConnSetDatabase(dbName string) *Connection
  • func (c *Connection) Context() *g.Context
  • func (c *Connection) DataS(lowerCase ...bool) map[string]string
  • func (c *Connection) Info() Info
  • func (c *Connection) Set(m map[string]interface{})
  • func (c *Connection) ToMap() map[string]interface{}
  • func (c *Connection) URL() string
• type ConnectionInt
• type Info
  • func (i *Info) IsURL() bool

Functions

func CopyDirect

func CopyDirect(conn database.Connection, tableFName string, srcFile Connection) (cnt uint64, ok bool, err error)

CopyDirect copies directly from cloud files (without passing through dbio)

func ReadConnections

func ReadConnections(path string) (conns map[string]Connection, err error)

func ReadConnectionsEnv

func ReadConnectionsEnv(env map[string]interface{}) (conns map[string]Connection, err error)

ReadConnections loads the connections

func ReadDbtConnections

func ReadDbtConnections() (conns map[string]Connection, err error)

Types

type Connection

type Connection struct {
	Name string                 `json:"name,omitempty"`
	Type dbio.Type              `json:"type,omitempty"`
	Data map[string]interface{} `json:"data,omitempty"`
	// contains filtered or unexported fields
}

Connection is the base connection struct

func NewConnection

func NewConnection(Name string, t dbio.Type, Data map[string]interface{}) (conn Connection, err error)

NewConnection creates a new connection

func NewConnectionFromDbt

func NewConnectionFromDbt(name string) (c Connection, err error)

NewConnectionFromDbt loads a Connection from a DBT Profile

func NewConnectionFromMap

func NewConnectionFromMap(m map[string]interface{}) (c Connection, err error)

NewConnectionFromMap loads a Connection from a Map

func NewConnectionFromProfiles

func NewConnectionFromProfiles(name string) (c Connection, err error)

NewConnectionFromProfiles loads a Connection from YAML Profiles

func NewConnectionFromURL

func NewConnectionFromURL(Name, URL string) (conn Connection, err error)

NewConnectionFromURL creates a new connection from a url

func (*Connection) AsAirbyte

func (c *Connection) AsAirbyte() (*airbyte.Airbyte, error)

func (*Connection) AsDatabase

func (c *Connection) AsDatabase() (database.Connection, error)

func (*Connection) AsFile

func (c *Connection) AsFile() (filesys.FileSysClient, error)

func (*Connection) Close

func (c *Connection) Close() error

Close closes the connection

func (*Connection) ConnSetDatabase

func (c *Connection) ConnSetDatabase(dbName string) *Connection

ConnSetDatabase returns a new connection with the specified database name

func (*Connection) Context

func (c *Connection) Context() *g.Context

Context returns the context

func (*Connection) DataS

func (c *Connection) DataS(lowerCase ...bool) map[string]string

DataS returns data as map[string]string

func (*Connection) Info

func (c *Connection) Info() Info

Info returns connection information

func (*Connection) Set

func (c *Connection) Set(m map[string]interface{})

Set sets key/values from a map

func (*Connection) ToMap

func (c *Connection) ToMap() map[string]interface{}

ToMap transforms DataConn to a Map

func (*Connection) URL

func (c *Connection) URL() string

URL returns the url string

type ConnectionInt

type ConnectionInt interface {
	// Self() Connection
	Close() error
	Context() g.Context
	Info() Info
	URL() string
	DataS(lowerCase ...bool) map[string]string
	ToMap() map[string]interface{}
	AsDatabase() (database.Connection, error)
	AsFile() (filesys.FileSysClient, error)
	// AsAPI() interface{}
	Set(map[string]interface{})
}

ConnectionInt is a connection

type Info

type Info struct {
	Name     string
	Type     dbio.Type
	LongType string
	Database string
	Data     map[string]interface{}
}

Info is the connection type

func (*Info) IsURL

func (i *Info) IsURL() bool