func ConnectInfoGet()

in state/clusters.go [81:129]
38 lines of code
14 McCabe index (conditional complexity)

func ConnectInfoGet(l *db.Loc, connType db.ConnectionType) (*db.Addr, error) {
	var a db.Addr

	//FIXME: Add connection type to info in state

	if mgr.conn == nil {
		log.Debugf("State hasn't been initialized yet")
		return nil, nil
	}

	a.Name = l.Cluster
	if l.Cluster == "" {
		err := util.QueryRowSQL(mgr.conn, "SELECT cluster FROM state WHERE service=? AND db=?", l.Service,
			l.Name).Scan(&a.Name)
		if err != nil && err != sql.ErrNoRows {
			log.E(err)
			return nil, err
		}
		if a.Name != "" {
			log.Debugf("Cluster name resolved from state: %v by service=%v, db=%v, connType=%v", a.Name, l.Service,
				l.Name, connType)
		}
	}

	err := selectCluster(&a, connType)
	//If the connection type is not available then check if the other type is
	if err == sql.ErrNoRows && connType == db.Slave {
		err = selectCluster(&a, db.Master)
	} else if err == sql.ErrNoRows && connType == db.Master {
		err = selectCluster(&a, db.Slave)
	}

	if err == sql.ErrNoRows {
		return nil, nil
	}

	if log.E(err) {
		return nil, err
	}

	if l.Cluster != "" && a.Name != l.Cluster {
		log.Errorf("Cluster name mismatch, given: %v, in state %v", l.Cluster, a.Name)
		return nil, nil
	}

	a.DB = l.Name

	return &a, nil
}