driverInterface

type HandleResult struct {
	HandleCode int32
	HandleMsg  string
}

type IDbDriver interface {
	OpenConnect(connectJson string, maxIdleTime, maxOpenConnections, connMaxLifetime, maxIdleConnections int) error
	CloseConnect() error
	CheckSQLValid(strSQL, strFilterVal string) ([]tableInfo.ColumnInfo, error)
	GetColumns(tableName string) ([]tableInfo.ColumnInfo, error)
	GetTables() ([]tableInfo.TableInfo, error)
	// PullData 从数据库中拉取数据，并写入到clickhouse中
	PullData(strSQL, filterVal, destTable string, batch int, iTimestamp int64, clickClient *clickHouseLocal.TClickHouseDriver) (int64, error)
	// PushData 从clickhouse中读取数据，并写入到数据库中
	PushData(selectSQL, filterVal, destTable string, batch int, clickClient *clickHouseSQL.TClickHouseSQL) (int64, error) //作为函数参数
	ConvertToClickHouseDDL(tableName string) (*string, error)
	ConvertFromClickHouseDDL(tableName string, columns *[]tableInfo.ColumnInfo) (*string, error)
	// GenerateInsertToClickHouseSQL columns 用户选择查询的字段列表，只含有字段名
	GenerateInsertToClickHouseSQL(tableName string, myColumns *[]tableInfo.ColumnInfo, filterCol string) (*string, error)
	// GenerateInsertFromClickHouseSQL columns 需要调用方处理用户选择的字段列表，并结合clickHouse获取的字段信息
	GenerateInsertFromClickHouseSQL(tableName string, clickColumns *[]tableInfo.ColumnInfo, filterCol string) (*string, error)
	GetQuoteFlag() string
	GetSchema() string
	IsConnected() bool
	NewConnect(connectJson string, maxIdleTime, maxOpenConnections, connMaxLifetime, maxIdleConnections int) (IDbDriver, error)
}

type TDBDriver struct {
	DriverName string
	Schema     string
	Db         *sqlx.DB
	Connected  bool
}