Function newClusterSessionWithSqlDialect

client/session.go:1319–1352

(clusterConfig *ClusterConfig)

}

func newClusterSessionWithSqlDialect(clusterConfig *ClusterConfig) (Session, error) {
	session := Session{}
	session.endPointList = make([]endPoint, len(clusterConfig.NodeUrls))
	for i := 0; i < len(clusterConfig.NodeUrls); i++ {
		node := endPoint{}
		node.Host = strings.Split(clusterConfig.NodeUrls[i], ":")[0]
		node.Port = strings.Split(clusterConfig.NodeUrls[i], ":")[1]
		session.endPointList[i] = node
	}
	var err error
	for i := range session.endPointList {
		ep := session.endPointList[i]
		session.trans = thrift.NewTSocketConf(net.JoinHostPort(ep.Host, ep.Port), &thrift.TConfiguration{
			ConnectTimeout: time.Duration(0), // Use 0 for no timeout
		})
		// session.trans = thrift.NewTFramedTransport(session.trans)	// deprecated
		tmp_conf := thrift.TConfiguration{MaxFrameSize: thrift.DEFAULT_MAX_FRAME_SIZE}
		session.trans = thrift.NewTFramedTransportConf(session.trans, &tmp_conf)
		if !session.trans.IsOpen() {
			err = session.trans.Open()
			if err != nil {
				log.Println(err)
			} else {
				session.config = getConfig(ep.Host, ep.Port,
					clusterConfig.UserName, clusterConfig.Password, clusterConfig.FetchSize, clusterConfig.TimeZone, clusterConfig.ConnectRetryMax, clusterConfig.Database, clusterConfig.sqlDialect)
				break
			}
		}
	}
	if !session.trans.IsOpen() {
		return session, fmt.Errorf("no server can connect")
	}
	return session, nil
}

func (s *Session) initClusterConn(node endPoint) error {
	var err error