sdk

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

type Conn interface {
	// QueryContext sends a query and returns a QueryResult
	// The query result can be used to export to a file
	QueryContext(ctx context.Context, query string) (*QueryResult, error)
	// QueryContextWithExternalTable sends a query with an external table
	// The name of the external table in the query has to correspond to that in the externalTable you are sending
	QueryContextWithExternalTable(ctx context.Context, query string, externalTable *ExternalTable) (*QueryResult, error)
	// QueryContextWithExternalTable sends a query with an external table from an io.Reader (can be a file)
	// The name of the external table in the query has to correspond to that in the externalTable you are sending
	QueryContextWithExternalTableReader(ctx context.Context, query string, externalTable *ExternalTableReader) (*QueryResult, error)
	// PrepareContext is used for batch insertion
	// PrepareContext sends the query to the database and return a Stmt interface
	// The Stmt interface can be used to send the arguments for the query
	PrepareContext(ctx context.Context, query string) (Stmt, error)
	// InsertFromReader inserts data from io.Reader
	// Can be used for insert with files such as csv or json
	// DataPacket will be read from the reader until io.EOF is returned as an error from reader.Read()
	InsertFromReader(ctx context.Context, query string, reader io.Reader) (int, error)
}

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

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

type Gateway struct {
	Conn *conn.GatewayConn
}

type HostOverride func() (host string, err error)

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

type Logf func(s string, args ...interface{})

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

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

type Stmt interface {
	// ExecContext is used to send a row of query argument to the clickhouse server
	ExecContext(ctx context.Context, args ...interface{}) error
	// Close sends leftover queued query arguments to the clickhouse server and closes the stmt
	// Close has to be called at the end for each Stmt
	Close() error
}