databaseDriver

package

v0.0.0-...-737200f Latest Latest Go to latest Published: Jun 20, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/drkisler/dataPedestal

Links

Open Source Insights

Documentation ¶

Index ¶

type DriverLib
- func LoadDriver(libPath string) (*DriverLib, error)
- func LoadDriverLib(libPath string) (*DriverLib, error)
type DriverOperation
- func NewDriverOperation(dbDriverDir string, ds *module.TDataSource) (*DriverOperation, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DriverLib ¶

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

func LoadDriver ¶

func LoadDriver(libPath string) (*DriverLib, error)

func LoadDriverLib ¶

func LoadDriverLib(libPath string) (*DriverLib, error)

func (*DriverLib) CheckSQLValid ¶

func (l *DriverLib) CheckSQLValid(strSQL, filterVal string) *driverInterface.HandleResult

func (*DriverLib) Close ¶

func (l *DriverLib) Close()

func (*DriverLib) ConvertFromClickHouseDDL ¶

func (l *DriverLib) ConvertFromClickHouseDDL(tableName string, columns *[]tableInfo.ColumnInfo) *driverInterface.HandleResult

func (*DriverLib) ConvertToClickHouseDDL ¶

func (l *DriverLib) ConvertToClickHouseDDL(tableName string) *driverInterface.HandleResult

func (*DriverLib) CreateDriver ¶

func (l *DriverLib) CreateDriver()

func (*DriverLib) DestroyDriver ¶

func (l *DriverLib) DestroyDriver()

func (*DriverLib) GenerateInsertFromClickHouseSQL ¶

func (l *DriverLib) GenerateInsertFromClickHouseSQL(tableName string, columns *[]tableInfo.ColumnInfo, filterCol string) *driverInterface.HandleResult

func (*DriverLib) GenerateInsertToClickHouseSQL ¶

func (l *DriverLib) GenerateInsertToClickHouseSQL(tableName string, columns *[]tableInfo.ColumnInfo, filterCol string) *driverInterface.HandleResult

func (*DriverLib) GetColumns ¶

func (l *DriverLib) GetColumns(tableName string) *driverInterface.HandleResult

func (*DriverLib) GetDriverHandle ¶

func (l *DriverLib) GetDriverHandle() C.uintptr_t

func (*DriverLib) GetQuoteFlag ¶

func (l *DriverLib) GetQuoteFlag() *driverInterface.HandleResult

func (*DriverLib) GetTables ¶

func (l *DriverLib) GetTables() *driverInterface.HandleResult

func (*DriverLib) IsConnected ¶

func (l *DriverLib) IsConnected() *driverInterface.HandleResult

func (*DriverLib) OpenConnect ¶

func (l *DriverLib) OpenConnect(connectJson string,
	maxIdleTime, maxOpenConnections, connMaxLifetime, maxIdleConnections int) *driverInterface.HandleResult

func (*DriverLib) PullData ¶

func (l *DriverLib) PullData(strSQL, filterVal, destTable string, batch int, iTimestamp int64, clickClient *clickHouseLocal.TClickHouseDriver) *driverInterface.HandleResult

func (*DriverLib) PushData ¶

func (l *DriverLib) PushData(strSQL, filterVal, destTable string, batch int, clickClient *clickHouseSQL.TClickHouseSQL) *driverInterface.HandleResult

type DriverOperation ¶

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

func NewDriverOperation ¶

func NewDriverOperation(dbDriverDir string, ds *module.TDataSource) (*DriverOperation, error)

NewDriverOperation creates a new driver operation instance.dbDriverDir is the full path to the directory where the driver library is located.

func (*DriverOperation) CheckSQLValid ¶

func (op *DriverOperation) CheckSQLValid(strSQL, filterVal string) *driverInterface.HandleResult

func (*DriverOperation) ConvertFromClickHouseDDL ¶

func (op *DriverOperation) ConvertFromClickHouseDDL(tableName string, columns *[]tableInfo.ColumnInfo) *driverInterface.HandleResult

func (*DriverOperation) ConvertToClickHouseDDL ¶

func (op *DriverOperation) ConvertToClickHouseDDL(tableName string) *driverInterface.HandleResult

func (*DriverOperation) FreeDriver ¶

func (op *DriverOperation) FreeDriver()

func (*DriverOperation) GenerateInsertFromClickHouseSQL ¶

func (op *DriverOperation) GenerateInsertFromClickHouseSQL(tableName string, columns *[]tableInfo.ColumnInfo, filterCol string) *driverInterface.HandleResult

func (*DriverOperation) GenerateInsertToClickHouseSQL ¶

func (op *DriverOperation) GenerateInsertToClickHouseSQL(tableName string, columns *[]tableInfo.ColumnInfo, filterCol string) *driverInterface.HandleResult

func (*DriverOperation) GetColumns ¶

func (op *DriverOperation) GetColumns(tableName string) *driverInterface.HandleResult

func (*DriverOperation) GetQuoteFlag ¶

func (op *DriverOperation) GetQuoteFlag() *driverInterface.HandleResult

func (*DriverOperation) GetTables ¶

func (op *DriverOperation) GetTables() *driverInterface.HandleResult

func (*DriverOperation) IsConnected ¶

func (op *DriverOperation) IsConnected() *driverInterface.HandleResult

func (*DriverOperation) PullData ¶

func (op *DriverOperation) PullData(strSQL, filterVal, destTable string, batch int, iTimestamp int64, clickClient *clickHouseLocal.TClickHouseDriver) *driverInterface.HandleResult

func (*DriverOperation) PushData ¶

func (op *DriverOperation) PushData(strSQL, filterVal, destTable string, batch int, clickClient *clickHouseSQL.TClickHouseSQL) *driverInterface.HandleResult

PushData strSQL : insert into table_name (col1, col2,...)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
driverInterface
driverwrapper
mysql

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