func (p *processor) Close(doLoad bool) {
	if doLoad {
		p.db.Close()
	}
}
load.ProcessorCloser interface implementation
package clickhouse
import (
	"fmt"
	"github.com/jmoiron/sqlx"
	"github.com/timescale/tsbs/pkg/targets"
	"strconv"
	"strings"
	"sync"
	"time"
)
type processor struct {
	db   *sqlx.DB
	csi  *syncCSI
	conf *ClickhouseConfig
}
func (p *processor) Init(workerNum int, doLoad, hashWorkers bool) {
	if doLoad {
		p.db = sqlx.MustConnect(dbType, getConnectString(p.conf, true))
		if hashWorkers {
			p.csi = newSyncCSI()
		} else {
			p.csi = globalSyncCSI
		}
	}
}