package main

import (
	//"fmt"
	//"time"
	//"math"
	//"strconv"
	. "git.wecise.com/wecise/odbserver/odb"
	"git.wecise.com/wecise/odbserver/odb/test"
	"gitee.com/wecisecode/util/logger"
)

func main() {

	//options := map[string]interface{} {"cache":odb.CacheAll}
	//g,err:= odb.New( options )

	//option := &StoreOption{Cache:CacheAll}
	option := &Option{Cache: CacheAll, Keyspace: "matrix", DisableInitialHostLookup: true, DisableNotify: 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)
	//logger.SetLevel(logger.DEBUG)
	//var aa map[string]string

	//obj := map[string]interface{}{ "class": "/matrix/portal/tools", "name": "作业控制台"}

	//logger.Error( g.getObjectId(obj) )

	//g.UpdateTagDir("script", "", "oRACLE")

	/*if err = g.AddTags("auditlog","",[]interface{}{"0zvZ4KGT3tIs420476a8b-4b4d-490a-8d02-c4a5f2f8406c"},[]string{"更新操作"}); err != nil {
	   logger.Error(err)
	}*/

	/*if strus, err := g.GetClassChildrenDetail("/", false); err != nil {
	   logger.Error(err)
	}else{
		logger.Info(strus)
	}*/

	//l := g.ChildWithLevel("/",1)
	//logger.Error(l)

	/*if strus, err := g.GetClassStructEx("/matrix/jobs/jobctrl"); err != nil {
	   logger.Error(err)
	}else{
		logger.Info(strus)
	}*/

	/*if err := g.ExecSyncFS(); err != nil {
	   logger.Error(err)
	}*/

	/*if files, err := g.FSIdx().Search([]string{"/opt/knowledge"}, "next", nil, nil) ; err != nil {
		logger.Error(err)
	}else{
		logger.Info(files)
	}*/

	/*sql := `DELETE FROM rels WHERE name = ?`
	for i:=0 ; i<170 ; i++ {
		name := "testname"+strconv.Itoa(i)
		if err := g.GetSession().Exec(sql,name); err != nil {
			logger.Error(err)
		}
	}*/

	/*colmap := map[string][]int{}
	for i:=160 ; i<170 ; i++ {
		name := "testname"+strconv.Itoa(i)
		remark := "testremark"+strconv.Itoa(i)
		if err := g.NewEdgeType(name, remark, 0, colmap) ; err != nil {
			logger.Error(err)
		}
	}*/

	if rows, err := g.RawQuery("select tid, ttl from promdb"); err == nil {
		for _, row := range rows {
			tid := row["tid"].(int64)
			g.CreatePromdbTable(uint64(tid), row["ttl"].(int), false)
		}
	}

	/*if define, err := g.ClassDefine("/matrix/test/test2"); err != nil {
	   logger.Error(err)
	}else{
		logger.Info(define)
	}*/

	//logger.Error(len(aa)>0)
}