drivers

Dec 11, 2024

Changes in this version

type DBDriver

+ ConcurrencyLock func()

+ ConcurrencyUnlock func()

type DBconnectionFactory

+ func InitPostgresDBEnginFactory() DBconnectionFactory

type DuckDBEngine

+ func (d *DuckDBEngine) ConcurrencyLock()

+ func (d *DuckDBEngine) ConcurrencyUnlock()

+ type PostgresDBEngine struct

+ func (d *PostgresDBEngine) Begin() (interface{}, error)

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

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

+ func (d *PostgresDBEngine) Close() error

+ func (d *PostgresDBEngine) Commit(tx interface{}) error

+ func (d *PostgresDBEngine) ConcurrencyLock()

+ func (d *PostgresDBEngine) ConcurrencyUnlock()

+ func (d *PostgresDBEngine) Connect() error

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

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

+ func (d *PostgresDBEngine) GetRawConnection() interface{}

+ func (d *PostgresDBEngine) MountSource(sourceProfile *configs.SourceProfile) error

+ func (d *PostgresDBEngine) PersistDataFrame(tx interface{}, name string, df *dataframe.DataFrame) error

+ func (d *PostgresDBEngine) Rallback(tx interface{}) error

+ func (d *PostgresDBEngine) SimpleTest(sqlQuery string) (string, error)

+ func (d *PostgresDBEngine) ToDataFrame(sqlQuery string) (*dataframe.DataFrame, error)

+ func (d *PostgresDBEngine) UnMountSource(sourceProfile *configs.SourceProfile) error

+ type PostgresDBEngineFactory struct

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

Oct 14, 2024

Changes in this version

type DBDriver

+ IsConcurrencyAllowed func() (bool, *sync.Mutex)

type DuckDBEngine

+ Mutex *sync.Mutex

+ func (d *DuckDBEngine) IsConcurrencyAllowed() (bool, *sync.Mutex)

Jul 19, 2024

Changes in this version

type DBDriver

+ SimpleTest func(sql string) (string, error)

type DuckDBEngine

+ func (d *DuckDBEngine) SimpleTest(sqlQuery string) (string, error)

Jul 9, 2024

Changes in this version

type DBDriver

+ GetRawConnection func() interface{}

+ PersistDataFrame func(tx interface{}, name string, df *dataframe.DataFrame) error

+ ToDataFrame func(sql string) (*dataframe.DataFrame, error)

type DuckDBEngine

+ func (d *DuckDBEngine) GetRawConnection() interface{}

+ func (d *DuckDBEngine) PersistDataFrame(tx interface{}, name string, df *dataframe.DataFrame) error

+ func (d *DuckDBEngine) ToDataFrame(sqlQuery string) (*dataframe.DataFrame, error)

Jun 24, 2024

Changes in this version

+ var Factories = map[string]DBconnectionFactory

+ func RegisterConnectionFactory(driverName string, f DBconnectionFactory)

+ type DBDriver interface

+ Begin func() (interface{}, error)

+ CheckSchemaExists func(tx interface{}, schemaName string) bool

+ CheckTableExists func(tx interface{}, tableName string) bool

+ Close func() error

+ Commit func(tx interface{}) error

+ Connect func() error

+ Exec func(tx interface{}, sql string) error

+ GetListOfFields func(tx interface{}, tableName string) []string

+ IsPermanent func() bool

+ MountSource func(sourceProfile *configs.SourceProfile) error

+ Rallback func(tx interface{}) error

+ UnMountSource func(sourceProfile *configs.SourceProfile) error

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

+ type DBconnectionFactory interface

+ CreateConnection func(connection configs.DBConnectionConfig) (DBDriver, error)

+ func InitDuckDBEnginFactory() DBconnectionFactory

+ type DuckDBEngine struct

+ 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 struct

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