Cloudpods/backend/vendor/github.com/ClickHouse/clickhouse-go/clickhouse_read_block.go

package clickhouse

import (
	"github.com/ClickHouse/clickhouse-go/lib/data"
)

func (ch *clickhouse) readBlock() (*data.Block, error) {
	if _, err := ch.decoder.String(); err != nil { // temporary table
		return nil, err
	}

	ch.decoder.SelectCompress(ch.compress)
	var block data.Block
	if err := block.Read(&ch.ServerInfo, ch.decoder); err != nil {
		return nil, err
	}
	ch.decoder.SelectCompress(false)
	return &block, nil
}