drivers

Documentation

Index

• Variables
• func RegisterConnectionFactory(driverName string, f DBconnectionFactory)
• type DBDriver
  • func EstablishDBConnection(connection *configs.DBConnectionConfig) (DBDriver, error)
• type DBconnectionFactory
  • func InitDuckDBEnginFactory() DBconnectionFactory
• type DuckDBEngine
  • func (d *DuckDBEngine) Begin() (interface{}, error)
  • func (d *DuckDBEngine) CheckSchemaExists(tx interface{}, tableName string) bool
  • func (d *DuckDBEngine) CheckTableExists(tx interface{}, tableName string) bool
  • func (d *DuckDBEngine) Close() error
  • func (d *DuckDBEngine) Commit(tx interface{}) error
  • func (d *DuckDBEngine) Connect() error
  • func (d *DuckDBEngine) Exec(tx interface{}, sqlQuery string) error
  • func (d *DuckDBEngine) GetListOfFields(tx interface{}, tableName string) []string
  • func (d *DuckDBEngine) IsPermanent() bool
  • func (d *DuckDBEngine) MountSource(sourceProfile *configs.SourceProfile) error
  • func (d *DuckDBEngine) Rallback(tx interface{}) error
  • func (d *DuckDBEngine) UnMountSource(sourceProfile *configs.SourceProfile) error
• type DuckDBEngineFactory
  • func (d *DuckDBEngineFactory) CreateConnection(connection configs.DBConnectionConfig) (DBDriver, error)

Variables

var Factories = map[string]DBconnectionFactory{
	"duckdb": InitDuckDBEnginFactory(),
}

Functions

func RegisterConnectionFactory

func RegisterConnectionFactory(driverName string, f DBconnectionFactory)

Types

type DBDriver

type DBDriver interface {
	Connect() error
	Begin() (interface{}, error)
	Commit(tx interface{}) error
	Rallback(tx interface{}) error
	Close() error
	Exec(tx interface{}, sql string) error
	GetListOfFields(tx interface{}, tableName string) []string
	CheckTableExists(tx interface{}, tableName string) bool
	CheckSchemaExists(tx interface{}, schemaName string) bool
	IsPermanent() bool
	MountSource(sourceProfile *configs.SourceProfile) error
	UnMountSource(sourceProfile *configs.SourceProfile) error
}

func EstablishDBConnection

func EstablishDBConnection(connection *configs.DBConnectionConfig) (DBDriver, error)

type DBconnectionFactory

type DBconnectionFactory interface {
	CreateConnection(connection configs.DBConnectionConfig) (DBDriver, error)
}

func InitDuckDBEnginFactory

func InitDuckDBEnginFactory() DBconnectionFactory

type DuckDBEngine

type DuckDBEngine struct {
	// contains filtered or unexported fields
}

func (*DuckDBEngine) Begin

func (d *DuckDBEngine) Begin() (interface{}, error)

Begin implements DBEngine.

func (*DuckDBEngine) CheckSchemaExists

func (d *DuckDBEngine) CheckSchemaExists(tx interface{}, tableName string) bool

CheckSchemaExists implements DBEngine.

func (*DuckDBEngine) CheckTableExists

func (d *DuckDBEngine) CheckTableExists(tx interface{}, tableName string) bool

CheckTableExists implements DBEngine.

func (*DuckDBEngine) Close

func (d *DuckDBEngine) Close() error

Close implements DBEngine.

func (*DuckDBEngine) Commit

func (d *DuckDBEngine) Commit(tx interface{}) error

Commit implements DBEngine.

func (*DuckDBEngine) Connect

func (d *DuckDBEngine) Connect() error

Connect implements DBEngine.

func (*DuckDBEngine) Exec

func (d *DuckDBEngine) Exec(tx interface{}, sqlQuery string) error

Exec implements DBEngine.

func (*DuckDBEngine) GetListOfFields

func (d *DuckDBEngine) GetListOfFields(tx interface{}, tableName string) []string

GetListOfFields implements DBEngine.

func (*DuckDBEngine) IsPermanent

func (d *DuckDBEngine) IsPermanent() bool

func (*DuckDBEngine) MountSource

func (d *DuckDBEngine) MountSource(sourceProfile *configs.SourceProfile) error

MountSource implements DBDriver.

func (*DuckDBEngine) Rallback

func (d *DuckDBEngine) Rallback(tx interface{}) error

Rallback implements DBEngine.

func (*DuckDBEngine) UnMountSource

func (d *DuckDBEngine) UnMountSource(sourceProfile *configs.SourceProfile) error

UnMountSource implements DBDriver.

type DuckDBEngineFactory

type DuckDBEngineFactory struct {
}

func (*DuckDBEngineFactory) CreateConnection

func (d *DuckDBEngineFactory) CreateConnection(connection configs.DBConnectionConfig) (DBDriver, error)

CreateConnection implements DBconnectionFactory.