route

type Hint struct {
	OnMaster bool
	Nodes    []string
}

type Plan interface {
	Route
	Execute(executor func(statements []sqlparser.Statement, results []*mysql.Result,
		dataNodes []string, isSlave bool,
		queryDataNodes map[sqlparser.Statement][]string) (backendConnAddrs []string, err error),
		clientAddr net.Addr, logSQLEnabled bool, slowLogTime int, counter *statistic.Counter) error

	ExecuteWithStmtPrepare(executor func(statements []sqlparser.Statement, results []*mysql.Result,
		dataNodes []string, isSlave bool,
		queryDataNodes map[sqlparser.Statement][]string) (*mysql.Stmt, error),
		clientAddr net.Addr, logSQLEnabled bool, slowLogTime int, counter *statistic.Counter) (*mysql.Stmt, error)
}

type Route interface {
	GetPlanSQL() string
	GetNodeNames() []string
	OnSlave() bool
}

type Router struct {
	SchemaName   string
	Schemas      map[string]*config.SchemaConfig
	Nodes        map[string]*config.NodeConfig
	ConnectionID uint32
	User         string
	InTrans      bool
}

type ShardAlgorithm func(val string, dataNodeCount int, params ...interface{}) (int, error)