odbtest/test/atemp/schema/schema_test.go

package odb_test

import (
	"fmt"
	"sort"
	"testing"

	"git.wecise.com/wecise/odbserver/odb/cass"
	"git.wecise.com/wecise/odbserver/odb/config"
	"github.com/stretchr/testify/assert"
)

func TestSchema(t *testing.T) {
	cassOption := cass.Option{Keyspace: "matrix", DisableInitialHostLookup: config.EnvBool("CASSANDRALOOKUP", false)}
	session, err := cass.NewCassSession(cassOption)
	if err != nil {
		assert.Nil(t, err)
		return
	}
	m, _, n, _ := cass.CassandraSchemaVersionInfo(session)
	s := fmt.Sprintln("retrycount: ", n)
	for schema, address := range m {
		addrs := address.List()
		sort.Strings(addrs)
		for _, addr := range addrs {
			s += fmt.Sprintf("%20s        %s\n", addr, schema)
		}
	}
	fmt.Print(s)
}