package main

import (
	"reflect"

	"git.wecise.com/wecise/odbserver/odb/test"
	"gitee.com/wecisecode/util/logger"
)

func main() {
	option := &Option{Cache: CacheAll, Keyspace: "ootest", DisableInitialHostLookup: true}
	g, err := test.NewG(option)

	if err != nil {
		logger.Error(err.Error())
	} else {
		defer g.Close()
	}

	//logger.SetRollingDaily("C:/test/zkcron/src/test", "test.log")
	logger.SetConsole(true)

	//params := []interface{}{ "/test/4bae8e2c-5a89-4fc3-b928-a93974f591a0", "{\"age\":15,\"name\":\"Jack\"}", "/test/4bae8e2c-5a89-4fc3-b928-a93974f591a0", 600 }
	//err = g.GetSession().Exec("insert into appcontext (key, data, \"_key\" ) values (?, ?, ?) using ttl ?", params...)

	/*err = g.GetSession().Query(`CREATE TABLE IF NOT EXISTS testtype (
		name                varchar,
		intv				int,
		intbigv				bigint,
		myfloat				float,
		mytime				timestamp,

	    PRIMARY KEY (name)
	) WITH caching = {'keys':'NONE', 'rows_per_partition':'ALL' }`).Exec()

		if err != nil {
			logger.Fatal(err)
		}

		g.GetSession().Exec(`insert into testtype (name, intv, intbigv,  mytime, myfloat) values ('i', 1, 1000, null, 1.1)`)

		if rows, err := g.RawQuery(`select * from testtype`) ;err == nil {
			for _, row := range rows {
				logger.Info( row )
				logger.Info( row["myfloat"].(float64) )
				//logger.Info( "%v , %v", reflect.TypeOf(row["intv"]) , reflect.TypeOf(row["intbigv"]) )
			}
		}else{
			logger.Error(err)
		}*/

	if rows, err := g.GetSession().SliceMap(`select listen_address, schema_version from system.local`); err != nil {
		logger.Warn(err)
	} else {
		for _, row := range rows {
			logger.Warn(reflect.TypeOf(row["listen_address"]))
			//schema  := row["schema_version"].(string)

		}
	}

}