odbtest/test/query/testcreate.go

package main

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

// CGO_ENABLED=1 go run --ldflags '-linkmode external -extldflags "-static"' testcreate.go

// #cgo LDFLAGS: -L/opt/odbserver/sqlite -lsqlite -ldl
// #include "/opt/odbserver/sqlite/sqlite.h"
// #include <stdint.h>
// #include <stdlib.h>
// extern int64_t uhaha_seed;
// extern int64_t uhaha_ts;
// void uhaha_begin_reader();
// void uhaha_end_reader();
import "C"

func main() {

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

	//option := &StoreOption{Cache:CacheAll}
	option := &Option{Cache: CacheAll, Keyspace: "oootest", DisableInitialHostLookup: true, DisableTask: 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)

	// 测试 返回树形结构
	/*
		str,err  := g.GetClassChildren(-1)
		if err != nil {
			fmt.Println("GetClassChildren error:"+err.Error())
		}else{
			fmt.Println("Children:=>" + str)
		}
	*/
	// 测试 插入、更新类，删除field ,"cid":2,

	// 测试 删除类

	/*
		err := g.DeleteClass(8)
		if err != nil {
			fmt.Println("DeleteClass error:"+err.Error())
		}
	*/

	// 测试 插入对象

	/*
		objsstr := `[ {"class":"test","id":11}, {"class":"test"}, {"class":"test2","vtime":"1970-01-01T00:00:00Z"}]`
		if err := g.CreateObjectsFromjson(objsstr,[]string{"class","aaa"}) ;err != nil {
			logger.Fatal(err.Error())
		}
	*/

	/*
		objs := make([]map[string]interface{},3)

		objs[0] = map[string]interface{}{"class":"test","id" :"1234567890"}
		objs[1] = map[string]interface{}{"class":"test"}
		objs[2] = map[string]interface{}{"class":"test2","vtime":"1970-01-01T00:00:00Z"}

		if err := g.CreateObjectsFromMap(objs,[]string{"class","aaa"}) ;err != nil {
			logger.Fatal(err.Error())
		}
	*/

	// 测试 返回对象名称
	/*
		if rtn,err := g.GetDisplayName([]string{"class","id"},"") ;err != nil {
			logger.Fatal(err.Error())
		}else{
			for k,v := range rtn {
				fmt.Printf(" %s :",k)
				for i:=0 ;i<len(v) ;i++ {
					fmt.Printf(" %s :",v)
				}
				fmt.Println()
			}
		}

		if rtn,err := g.GetDisplayName([]string{"class","id"},"1") ;err != nil {
			logger.Fatal(err.Error())
		}else{
			for k,v := range rtn {
				fmt.Printf(" %s :",k)
				for i:=0 ;i<len(v) ;i++ {
					fmt.Printf(" %s :",v)
				}
				fmt.Println()
			}
		}
	*/

	// 测试MQL

	//rst,err := g.Query(`SELECT id,vtime,usname FROM /core/user/ WHERE usname prefix 'admin' && email like 'admin*' `)
	//rst,err := g.Query(`SELECT id,vtime,usname FROM /core/user `)
	//rst,err := g.Query(`SELECT * FROM /matrix/jobs/runinfo`)
	//rst,err := g.Query(`SELECT id,vtime,class FROM / WHERE class IN ('test') LIMIT 10`)
	//rst,err := g.Query(`SELECT id,vtime,class FROM / WHERE id = 1234567890 LIMIT 10`)
	//rst,err := g.Query(`SELECT type,id FROM /matrix/log/cassandra WHERE type =~ '^[C' limit 10`)
	//rst,err := g.Query(`SELECT id,vtime,class FROM /core/ `)
	//rst,err := g.Query(`SELECT id,vtime,class FROM /matrix/performance WHERE id='13722093446131916505' limit 10`, false)
	//rst,err := g.Query(`SELECT id,vtime,class FROM /matrix/performance WHERE id='13722093446131916505' limit 10`, false)
	//rst,err := g.Query(`SELECT id,vtime,class,kpi_code FROM /matrix/performance WHERE  mydate daterange ('20150324','20150325') limit 10`)
	//rst,err := g.Query(`select name,jobstatus as status from /matrix/jobs/jobrun where jobstatus > 5 limit 10`,false)
	//rst,err := g.Query(`select * from /matrix/jobs/jobrun where vtime > '2016-03-07 15:51:43.581'`,false)
	//rst,err := g.Query(`select host, inst, param, value, vtime from /matrix/devops/performance/ where vtime >= 1461054031485 order by host, vtime asc limit 10 with version`,false)

	//rst,err := g.Query(`select host, inst, param, value, vtime from /matrix/devops/performance/  where  host='mxsvr201' with version`)

	//rst,meta,err := g.Query(`insert into /matrix/system/policy name = 'test', domain = 'cmd', innername = 'test', branch = 'test', version = '1.1', policy = {"args":"","bin":"test.sh","cron":"0/1 * * * * * *","dir":"test-1.1","rule":"/matrix/rules/test"}, tags = ["test"]`)

	//rst,meta,err := g.Query(`DELETE FROM 	/matrix/system/depot WHERE 	id ='18179445224353971852' with version;`)

	/*rst,err := g.Query(`select app,
	biz,
	card,
	class,
	ctime,
	hdware,
	host,
	id,
	inst,
	ip,
	name,
	org,
	param,
	src,
	tags,
	value,
	vtime from /matrix/devops/performance  limit 200 with version`,false)*/

	//rst,meta,err := g.Query(`select id,connect from /matrix/entity/switch where id like 'switch:10[1-9]switch41' `,map[string]interface{}{"meta":true})

	//rst,meta,err := g.Query(`select name from /matrix/system/depot where branch = 'test1' and domian = 'cmd' limit 1`)

	/*rst,meta,err := g.Query(`
	CREATE CLASS IF NOT EXISTS /matrix/clickcount (
	date varchar "日期",
	count int "点击次数",
	INDEX(date),
	KEYS(date)
	) WITH autosearch=true,Alias='点击次数',nickname='clickcount'`) */

	/*rst,meta,err := g.Query(`create class /matrix/testaa (
		bbssss varchar "22222",
		keys(bbssss),
		index(bbssss)
	)`)
	*/

	/*rst,meta,err := g.Query(`create class if not exists /matrix/portal/tools2 (
	 	cnname		varchar,
		enname		varchar,
		url			varchar,
		icon		varchar,
		seat		int,
		target		varchar,
		selected	int,
		groups 		map<varchar, varchar>,

		indexes(name,cnname,enname,url,icon,seat,target,selected,groups),
		keys(name, cnname)
	);`)*/

	/*rst,err := g.Query(`create class if not exists /matrix (
		&name ,
		status 				int     '状态',
		indexes(name,status)
	);
	create class if not exists /matrix/tags (
		&name,
		keys(name)
	);
	create class if not exists /matrix/devops (
		biz			varchar		,
		org			varchar		,

		host		varchar    ,
		ip			  varchar    ,

		app			varchar		  ,
		inst		 varchar		,
		param	  varchar		,
		hdware    	varchar	      ,
		card     varchar	      ,

		src varchar,

		script text,

		keys(biz,org,ip,app,inst,param,hdware,card),
		indexes(biz,org,host,ip,app,inst,param,hdware,card, src,script)
	);
	create class if not exists /matrix/jobs ();
	create class if not exists /matrix/jobs/jobrun (
		runid				bigint,
		boxid				bigint,

		dir					text,
		cmds				list<varchar>,

		jobstatus			int,
		stime				timestamp,
		etime				timestamp,

		keys(dir,name),
		indexes(runid,boxid,name,dir,cmds,jobstatus,stime{"type":"date", "pattern":"yyyy/MM/dd HH:mm:ss.SSS"},etime{"type":"date", "pattern":"yyyy/MM/dd HH:mm:ss.SSS"})
	);
	create class if not exists /matrix/jobs/cmdrun (

		&runid,
		&boxid,

		&dir,
		&host,

		jobtype				int,
		source				text,

		cmd					text,
		pid					int,

		&jobstatus,
		&stime,
		&etime,

		code				int,
		out					text,
		err					text,

		keys(dir,name,cmd),
		indexes(jobtype,source,cmd,pid,code,out,err)
	);
	create class if not exists /matrix/devops/performance (
		value				float    '性能值',
		ctime				timestamp    '采集时间',

		kpiid varchar,
		kpiencode varchar,

		indexes(param,value,ctime{"type":"date", "pattern":"yyyy/MM/dd HH:mm:ss.SSS"}, kpiid, kpiencode)
	);
	create class if not exists /matrix/devops/event (
		severity		    varchar    '级别',
		msg 				text    '摘要',
		eventstatus	        varchar  '告警状态',
		&ctime			'采集时间',

		&kpiid,
		&kpiencode,

		indexes(severity,eventstatus,msg, kpiid, kpiencode)
	);

	`,false)*/

	/*rst,meta, err := g.Query(`create class if not exists /matrix/entity/physical_resource_obj/park ( keys( id) )with autosearch=true , alias='physical_resource_obj' , nickname='park' ;
	`,&QueryMeta{Return: ReturnAll, MinAsteriskField: true, KeepClassID: false})
	*/
	/*
	   rst,meta, err := g.Query(`create class if not exists /matrix/testbucket7/subbk(

	   		host	varchar,

	   		real	map<varchar,varchar> ,

	   		bk2		bucket 'full',

	       	keys(host),
	       	indexes(host)

	   ) with nickname='subbk';`,&QueryMeta{Return: ReturnAll, MinAsteriskField: true, KeepClassID: false})
	*/
	/*
	   rst,meta, err := g.Query(`create class if not exists /matrix/testbucket5 (

	   		host	varchar,

	   		real	map<varchar,varchar>,

	   		bklog	bucket {
	   						"type"  : 	"bitlog",
	   						"files":	["*.log"],
	   						"sample" :	["2020-05-15 00:49:59,666"],
	   						"ttl"   :   365
	   					   } 'full',

	       	keys(host),
	       	indexes(host)

	   ) with nickname='testbucket5';`,&QueryMeta{Return: ReturnAll, MinAsteriskField: true, KeepClassID: false})
	*/

	//rst,meta, err := g.Query(`drop class if exists /matrix/devops/alert_status`,&QueryMeta{Return: ReturnAll, MinAsteriskField: true, KeepClassID: false})

	/*rst,meta, err := g.Query(`create class if not exists /matrix/test/Car (

				wheel		Wheel[4..4],
				remark		varchar,

				indexes(remark)
			) with nickname='Car', key=manu ;
	`,&QueryMeta{Return: ReturnAll, MinAsteriskField: true, KeepClassID: false})*/

	/*rst,meta, err := g.Query(`drop class /matrix/test/oo/dimension
	  `,&QueryMeta{Return: ReturnAll, MinAsteriskField: true, KeepClassID: false})*/

	/*
	   rst,meta, err := g.Query(`create class if not exists /seedo/model/mpdu (
	   desc		varchar	"设备描述"		,
	    devicename		varchar	"设备名称"		,
	    deviceoid		varchar	"OID"		,
	    ip		varchar	"ip"		,
	    perfstructure		varchar	"性能结构描述"		,
	    values		bucket {"desc":["在线点","电压值 L1","回路电压值 C1","回路电压值 C2","电流值 L1","回路电流值 C1","回路电流值 C2","功率值 L1","回路功率值 C1","回路功率值 C2","电能值 L1","回路电能值 C1","回路电能值 C2","功率因数值 L1","回路功率因数值 C1","回路功率因数值 C2","Output 1 电流值","Output 2 电流值","Output 3 电流值","Output 4 电流值","Output 5 电流值","Output 6 电流值","Output 7 电流值","Output 8 电流值","Output 9 电流值","Output 10 电流值","Output 11 电流值","Output 12 电流值","Output 13 电流值","Output 14 电流值","Output 15 电流值","Output 16 电流值","Output 17 电流值","Output 18 电流值","Output 19 电流值","Output 20 电流值","Output 21 电流值","Output 22 电流值","Output 23 电流值","Output 24 电流值","Output 1 功率值","Output 2 功率值","Output 3 功率值","Output 4 功率值","Output 5 功率值","Output 6 功率值","Output 7 功率值","Output 8 功率值","Output 9 功率值","Output 10 功率值","Output 11 功率值","Output 12 功率值","Output 13 功率值","Output 14 功率值","Output 15 功率值","Output 16 功率值","Output 17 功率值","Output 18 功率值","Output 19 功率值","Output 20 功率值","Output 21 功率值","Output 22 功率值","Output 23 功率值","Output 24 功率值","Output 1 电能值","Output 2 电能值","Output 3 电能值","Output 4 电能值","Output 5 电能值","Output 6 电能值","Output 7 电能值","Output 8 电能值","Output 9 电能值","Output 10 电能值","Output 11 电能值","Output 12 电能值","Output 13 电能值","Output 14 电能值","Output 15 电能值","Output 16 电能值","Output 17 电能值","Output 18 电能值","Output 19 电能值","Output 20 电能值","Output 21 电能值","Output 22 电能值","Output 23 电能值","Output 24 电能值","Output 1 功率因数值","Output 2 功率因数值","Output 3 功率因数值","Output 4 功率因数值","Output 5 功率因数值","Output 6 功率因数值","Output 7 功率因数值","Output 8 功率因数值","Output 9 功率因数值","Output 10 功率因数值","Output 11 功率因数值","Output 12 功率因数值","Output 13 功率因数值","Output 14 功率因数值","Output 15 功率因数值","Output 16 功率因数值","Output 17 功率因数值","Output 18 功率因数值","Output 19 功率因数值","Output 20 功率因数值","Output 21 功率因数值","Output 22 功率因数值","Output 23 功率因数值","Output 24 功率因数值","Output 1 开/关状态","Output 2 开/关状态","Output 3 开/关状态","Output 4 开/关状态","Output 5 开/关状态","Output 6 开/关状态","Output 7 开/关状态","Output 8 开/关状态","Output 9 开/关状态","Output 10 开/关状态","Output 11 开/关状态","Output 12 开/关状态","Output 13 开/关状态","Output 14 开/关状态","Output 15 开/关状态","Output 16 开/关状态","Output 17 开/关状态","Output 18 开/关状态","Output 19 开/关状态","Output 20 开/关状态","Output 21 开/关状态","Output 22 开/关状态","Output 23 开/关状态","Output 24 开/关状态","温度值 1","温度值 2","温度值 3","温度值 4","总电压告警 L1","回路电压告警 C1","回路电压告警 C2","总电流告警 L1","回路电流告警 C1","回路电流告警 C2","Output 1 电流告警","Output 2 电流告警","Output 3 电流告警","Output 4 电流告警","Output 5 电流告警","Output 6 电流告警","Output 7 电流告警","Output 8 电流告警","Output 9 电流告警","Output 10 电流告警","Output 11 电流告警","Output 12 电流告警","Output 13 电流告警","Output 14 电流告警","Output 15 电流告警","Output 16 电流告警","Output 17 电流告警","Output 18 电流告警","Output 19 电流告警","Output 20 电流告警","Output 21 电流告警","Output 22 电流告警","Output 23 电流告警","Output 24 电流告警","温度告警 1","温度告警 2","湿度告警 1","湿度告警 2","第一路断路器告警标识","第二路断路器告警标识","总电能 L1 清零","回路电能 C1 清零","回路电能 C2 清零","Output 1 电能清零","Output 2 电能清零","Output 3 电能清零","Output 4 电能清零","Output 5 电能清零","Output 6 电能清零","Output 7 电能清零","Output 8 电能清零","Output 9 电能清零","Output 10 电能清零","Output 11 电能清零","Output 12 电能清零","Output 13 电能清零","Output 14 电能清零","Output 15 电能清零","Output 16 电能清零","Output 17 电能清零","Output 18 电能清零","Output 19 电能清零","Output 20 电能清零","Output 21 电能清零","Output 22 电能清零","Output 23 电能清零","Output 24 电能清零"],"params":[["${1,113-136,141-203}","int","","${desc[0,112-135,140-202]}","1,113-136,141-203"],["${2-4}","int","V","${desc[1-3]}","2-4"],["${5-7,17-40}","int","A","${desc[4-6,16-39]}","5-7,17-40"],["${8-10,41-64}","int","KVA","${desc[7-9,40-63]}","8-10,41-64"],["${11-13,65-88}","int","KWH","${desc[10-12,64-87]}","11-13,65-88"],["${14-16,89-112}","int","%","${desc[13-15,88-111]}","14-16,89-112"],["${137-140}","int","℃","${desc[136-139]}","137-140"]],"ttl":365,"type":"tsdb"}	"full"		,
	    keys( devicename,deviceoid,ip) ,
	    index( desc,devicename,deviceoid,ip,perfstructure)
	   )with alias='mpdu' , nickname='mpdu' ;`,&QueryMeta{Return: ReturnAll, MinAsteriskField: true, KeepClassID: false})
	*/
	/*
	   rst,meta, err := g.Query(`create class if not exists /matrix/bucket10 (

	   		host	varchar,

	   		real	map<varchar,varchar>,

	   		bk2		bucket {
	   						"type"  : 	"tsdb",
	   						"params":	[["iparam${1-4}","int","ms","this is iparam${1-4}","1-4"],
	   									 ["iparam${7-9,11}","int","ms","this is iparam${7-9,11}","7-9,11"],
	   									 ["fparam${10}","decimal(4)","ms","this is fparam","10"],
	   									  ["fparam${12,13-16,17-19}","decimal(4)","ms","this is fparam","12,13-16,17-19"],
	   									  ["fparam${5,6}","decimal(4)","ms","this is fparam","5,6"]
	   									 ],
	   						"ttl"   :   365
	   					   } 'full',

	       	keys(host),
	       	indexes(host)

	   ) with nickname='bucket10';`,&QueryMeta{Return: ReturnAll, MinAsteriskField: true, KeepClassID: false})
	*/

	/*rst,meta, err := g.Query(`create class if not exists /test/donghuan/B (
	   ip  varchar "ip"  ,
	   devicename  varchar "设备名称"  ,
	   deviceoid  varchar "OID"  ,
	   perfstructure varchar "性能结构描述",
	   desc varchar "设备描述",

	    values  bucket {
	        "type"  :  "tsdb",
	        "params": [
	     ["${1-5}","int","","${desc[1-5]}"],
	     ["${6-9}","int","MB","${desc[6-9]}"],
	     ["10","int","%","CUP使用率"],
	     ["${11-12,15-16}","int","MB","${desc[11-12,15-16]}"],
	     ["${13-14,17-18}","int","KB/s","${desc[13-14,17-18]}"]
	     ],
	     "desc": ["在线点","及早期火警","及早期预警","DO1","DO2","系统分区总容量","系统分区剩余量","数据分区总容量","数据分区剩余量","内存总容量","内存剩余量","网卡1上行速度","网卡1下行速度","网卡1上行总量","网卡1下行总量","网卡2上行速度","网卡2下行速度","网卡2上行总量","网卡2下行总量"],
	        "ttl"   :   365
	          } 'full',

	       keys(ip,devicename,deviceoid),
	       indexes(ip,devicename,deviceoid)

	  ) with alias='A', nickname='A';`,&QueryMeta{Return: ReturnAll, MinAsteriskField: true, KeepClassID: false})
	*/

	/*
		rst,err := g.Query(`

			drop class /matrix/nnnn2;

		`,false)
	*/

	//rst,err := g.Query(`drop class /matrix/ldapaa `,false)

	/*rst,_,err := g.Query(`select _tokens,
	class,
	day,
	id,
	name,
	status,
	vtime from /matrix/`)
	*/

	//rst,_,err := g.Query(`delete from /matrix/devops/event/`)

	//rst,_,err := g.Query(`delete from /matrix/devops/log/test2  with version`)

	//rst,meta,err := g.Query(`select count(*) from /matrix/devops/event`,&QueryMeta{Return: ReturnAll, MinAsteriskField: true, KeepClassID: false})

	//rst,meta,err := g.Query(`match ("biz:查账系统")-[*]->("esx:esx1") return name,status`)

	//rst,meta,err := g.Query(`match ("biz:查账系统")-[*]->("linux:*")-[*1]->("esx:esx4")`)

	//rst,meta,err := g.Query(`match ("biz:查账系统")-[*]->("linux:*")-[*1]->("esx:esx4")`)

	//rst,err := g.Query(`create edge type aaa '萨芬', bbb '斯蒂芬'`)

	//rst,err := g.Query(`insert edge (host:测试服务器1, app:weblogic1), (host:测试服务器2, app:weblogic2) with contain`)

	//rst,_,err := g.Query(`insert edge from host:测试服务器1, app:weblogic1 to host:测试服务器2, app:weblogic2 with contain {this is test option}`)

	//rst, _,err := g.Query(`select node id from host:mxsvr201 with contain,depend`)

	//rst,err := g.Query(`drop edge type aaa, bbb`)

	//rst,meta,err := g.Query(`select entity from /matrix/devops/event e join ("linux:wecise")-[*]->(p:app) on e.entity=p.id`)

	//rst,meta,err := g.Query(`select id, host, entity from /matrix/devops/event e join (p:"app:cassandra1") on e.entity=p.id`)

	//rst,meta,err := g.Query(`select id, host, entity, p.name from /matrix/devops/event e join (p:/matrix/entity/app where id='app:app1') on e.entity=p.id`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`select count(*) from /matrix/devops/event/ e join (p:/matrix/entity/switch where  id = 'switch:switch1' or id='switch:switch2') on e.entity=p.id`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`select value, ctime from /matrix/devops/performance where id = 'id1' and ctime >= 1555661943158 and ctime < 1555665543158 with version`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	// slow
	//rst,meta,err := g.Query(`select entity,msg,host,p.id,p.name from /matrix/devops/event/ e join (p:/matrix/entity/switch where  id like 'switch:*') on e.entity=p.id limit 1 where entity like 'switch:*'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//bug
	//rst,meta,err := g.Query(`select entity,msg,host,p.id,p.name from /matrix/devops/event/ e join (p:/matrix/entity/db2) on e.entity=p.id limit -1`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//bug
	//rst,meta,err := g.Query(`select entity,p.param as param from /matrix/devops/event/ e join (p:/matrix/devops/performance/ where entity like 'switch:*' and value>30) on e.entity=p.entity limit 1`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//bug
	//rst,meta,err := g.Query(`select count(*) from /matrix/devops/event/ e join (i:/matrix/entity/switch where id='switch:switch1' and name='switch:switch2') on e.entity=i.id and e.entity=i.name limit -1 where entity like 'switch:*' `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`match ("biz:查账系统")-[*]->("linux:*")-[*1]->("esx:*") `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//bug
	//rst,meta,err := g.Query(`match ("biz:查账系统")-[*]->("linux:*") `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//bug
	//rst,meta,err := g.Query(`match ("biz:查账系统")-[:contain*1]->()-[*]->("linux:*")-[*1]->("esx:*") `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//bug !!!
	//rst,meta,err := g.Query(`SELECT  max(value) FROM  /matrix/devops/performance`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//bug
	//rst,meta,err := g.Query(`SELECT max(severity) FROM 	/matrix/devops/event`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//bug
	//rst,meta,err := g.Query(`select param from /matrix/devops/performance/  order by param asc`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//_,meta,err := g.Query(`update edge type refer '引用引用'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	/*t1 := time.Now()
	_,meta,err := g.Query(`select entity,msg,host,i.id,i.name,p.param,p.value,l.msg from /matrix/devops/event/ e join (i:/matrix/entity/switch where id='switch:switch1' or name='switch:switch2') on e.entity=i.id and e.entity=i.name join (p:/matrix/devops/performance/ where entity like 'switch:*' and value>30) on e.entity=p.entity join (l:/matrix/devops/log where entity like 'switch:*' and msg like '*error*') on e.entity=l.entity limit -1`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )
	logger.Warn("duration ==>", time.Now().Sub(t1))
	*/

	//bug
	//rst,meta,err := g.Query(`select host,ip,h.name from /matrix/devops/event/omnibus o join ("biz:查账系统")-[*]->("esx:*")-[:connect*]->(h:switch) on o.entity = h.id where o.severity=5`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`match ("biz:查账系统")-[:refer*1]->()`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`match ("biz:认证系统")-[*1]->()`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`match ("9788404371073416132")-[*1]->()`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//bug
	//rst,meta,err := g.Query(`match ("biz:查账系统")-[*]->("linux:linux[1-5]")-[*1]->("esx:esx1")`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`match ("biz:查账系统")-[*]->("esx:esx1") return name,status`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`select id, host, entity, p.name from /matrix/devops/event e join (p:'app:app1') on e.entity=p.id`)

	//rst,meta,err := g.Query(`select id, host, entity from /matrix/devops/event e join (p:"app:app1") on e.host=p.host`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`select host,msg,id,class from /matrix/devops/event where host='mxsvr221'   facet severity{"critical":[3,],"warning":[,3]} `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`select host,msg,id,class from /matrix/devops/event where host='wecise'   facet severity{"critical":[3,],"warning":[,3]} `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`select host,id,class,value,vtime from /matrix/devops/performance/ where host='wecise'   facet value{"big":[4,],"small":[,3]} `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`select host,ip from /matrix/devops/event/omnibus o join ("biz:查账系统")-[*]->("esx:*")-[:connect*]->(h:switch) on o.entity = h.id where o.severity=5`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`UPDATE /matrix/entity/zdgt_host SET virtual3=['zdgt_vm:vm4'] where zdgt_id=3`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	/*rst,meta,err := g.Query(`
		  create class if not exists /test/bucketpromdb (

			host varchar,

			prom  bucket {
					 "type"  :  "promdb",
					 "ttl"   :   365
				 } 'full',

			keys(host),
			indexes(host)

		) with key=manu, nickname='bucketpromdb'
	`, &QueryMeta{Return: ReturnAll} )*/

	/*
	   rst,meta,err := g.Query(`
	   	 create class if not exists /matrix/applet (
	                   xid               int         "id",
	                   xcode             varchar     "code",
	                   xkey              varchar     "key",
	                   xcreateBy         varchar     "createBy",
	                   xcreateByView     varchar     "createByView",
	                   xcreateTime       timestamp   "createTime",
	                   xupdateBy         varchar     "updateBy",
	                   xupdateByView     varchar     "updateByView",
	                   xupdateTime       timestamp   "updateTime",
	                   xversion          int         "version",
	                   xlocale           varchar     "locale",
	                   xsortNumber       int         "sortNumber",
	                   xenableFlag       int         "enableFlag",
	                   xdeleteFlag       int         "deleteFlag",
	                   xextend           text        "",
	                   vtime             timestamp   "vtime",
	                   keys(xid),
	                   indexes(xid,xcode,xkey)
	   );
	   create class if not exists /matrix/applet/dash095();
	   create class if not exists /matrix/applet/dash095/report();
	   alter class /matrix/applet/dash095/report add index column z8038reportname varchar 'reportName', z8043reportgroup varchar 'reportGroup', z8039setcodes varchar 'setCodes', z8040setparam varchar 'setParam', z8041reporttype varchar 'reportType', z8042reportimage varchar 'reportImage', z8035reportdesc varchar 'reportDesc', z8036jsonstr varchar 'jsonStr', z8037total varchar 'total' ;
	   `, &QueryMeta{Return: ReturnAll} )*/

	//rst,meta,err := g.Query(` 	drop class /test/bucketpromdbsync `, &QueryMeta{Return: ReturnAll} )

	rst, meta, err := g.Query(`
create class if not exists cypher : / ()with ttl=366 day , autosearch=true , version=false , key=manu, alias='cypher', namespace='cypher';
`)

	/*rst, meta, err := g.Query(`


	  `)*/

	/*rst,meta,err := g.Query(` create class if not exists /matrix/alerts_status (
	acknowledged		int	"acknowledged",
	admin				varchar	"admin",
	adminphone		varchar	"adminphone",
	agent				varchar	"agent",
	alarmkey		varchar	"alarmkey",
	alarmtype		varchar	"alarmtype",
	alertgroup		varchar	"alertgroup",
	alertkey		varchar	"alertkey",
	duration		int	"duration",
	severity		enum {
		"3":["Info", "消息"],
		"4":["Warn", "警告"],
		"5":["Error", "错误"],
		"6":["Fatal", "致命错误"],
		"0":["Unknown", "未知"],
		"1":["Trace", "追踪"],
		"2":["Debug", "调试"]}	"severity",
	alertsubtype		varchar	"alertsubtype",
	alerttype		varchar	"alerttype",
	area				varchar	"area",
	bname				varchar	"bname",
	bsm_classname		varchar	"bsm_classname",
	bsm_identity		varchar	"bsm_identity",
	bsm_subidentity		varchar	"bsm_subidentity",
	businessimpact		int	"businessimpact",
	bussinesscategory		varchar	"bussinesscategory",
	causetype		int	"causetype",
	ccpc				int	"ccpc",
	ccpcbank		varchar	"ccpcbank",
	chineseflag		int	"chineseflag",
	ciid				varchar	"ciid",
	cmdbenrichstatus		int	"cmdbenrichstatus",
	cname				varchar	"cname",
	cnsummary		varchar	"cnsummary",
	contact			varchar	"contact",
	contactman		varchar	"contactman",
	contactphone		varchar	"contactphone",
	corrscore		int	"corrscore",
	customer		varchar	"customer",
	deviceios		varchar	"deviceios",
	devicelocation		varchar	"devicelocation",
	devicemodel		varchar	"devicemodel",
	devicepurpose		varchar	"devicepurpose",
	devicetype		varchar	"devicetype",
	domaingroup		varchar	"domaingroup",
	domainsubgroup		varchar	"domainsubgroup",
	emailstatus		int	"emailstatus",
	entity			varchar	"entity",
	eventclass		varchar	"eventclass",
	eventid			varchar	"eventid",
	eventstatus		int	"eventstatus",
	eventtime		varchar	"eventtime",
	eventtype		enum {
		"13":["应用类告警"],
		"14":["硬件类告警"],
		"99":["其他类告警"],
		"10":["主机告警"],
		"11":["数据库告警"],
		"12":["中间件类告警"]}	"eventtype",
	evtproccode		varchar	"evtproccode",
	expiretime		int	"expiretime",
	explain			varchar	"explain",
	extendedattr		varchar	"extendedattr",
	firstoccurrence		timestamp	"firstoccurrence",
	flag				int	"flag",
	flash				int	"flash",
	grade				int	"grade",
	identifier		varchar	"identifier",
	idname			varchar	"idname",
	impactflag		int	"impactflag",
	instance		varchar	"instance",
	internallast		timestamp	"internallast",
	itmdisplayitem		varchar	"itmdisplayitem",
	lastoccurrence		timestamp	"lastoccurrence",
	localnodealias		varchar	"localnodealias",
	localobjrelate		int	"localobjrelate",
	localpriobj		varchar	"localpriobj",
	localrootobj		varchar	"localrootobj",
	localsecobj		varchar	"localsecobj",
	localtertobj		varchar	"localtertobj",
	location		varchar	"location",
	logticket		int	"logticket",
	lpar				varchar	"lpar",
	machineid		varchar	"machineid",
	maintainstatus		int	"maintainstatus",
	maintenance		enum {
		"2":["false", "维护期外"],
		"0":["Unknown", "未知"],
		"1":["true", "维护期内"]}	"maintenance",
	manager			varchar	"manager",
	market			varchar	"market",
	msg_id			varchar	"msg_id",
	n_maintenance_status		int	"n_maintenance_status",
	netype			varchar	"netype",
	nmoscausetype		int	"nmoscausetype",
	nmosdomainname		varchar	"nmosdomainname",
	nmosentityid		int	"nmosentityid",
	nmoseventmap		varchar	"nmoseventmap",
	nmosmanagedstatus		int	"nmosmanagedstatus",
	nmosobjinst		int	"nmosobjinst",
	nmosserial		varchar	"nmosserial",
	node				varchar	"node",
	nodealias		varchar	"nodealias",
	nodename		varchar	"nodename",
	nodetype		varchar	"nodetype",
	objectfullname		varchar	"objectfullname",
	oldrow			int	"oldrow",
	omni_class		varchar	"omni_class",
	omni_serial		int	"omni_serial",
	orgcode			varchar	"orgcode",
	originalseverity		int	"originalseverity",
	ownergid		int	"ownergid",
	owneruid		int	"owneruid",
	phone				varchar	"phone",
	physicalcabinet		varchar	"physicalcabinet",
	physicalcard		varchar	"physicalcard",
	physicallocation		varchar	"physicallocation",
	physicalport		int	"physicalport",
	physicalslot		int	"physicalslot",
	plateng			varchar	"plateng",
	platform		varchar	"platform",
	poll				int	"poll",
	probesubsecondid		int	"probesubsecondid",
	processreq		int	"processreq",
	recordtime		int	"recordtime",
	region			varchar	"region",
	remotenodealias		varchar	"remotenodealias",
	remoteobjrelate		int	"remoteobjrelate",
	remotepriobj		varchar	"remotepriobj",
	remoterootobj		varchar	"remoterootobj",
	remotesecobj		varchar	"remotesecobj",
	remotetertobj		varchar	"remotetertobj",
	resolve			varchar	"resolve",
	rowserial		int	"rowserial",
	servername		varchar	"servername",
	serverserial		int	"serverserial",
	service			varchar	"service",
	servicenowerrorcode		int	"servicenowerrorcode",
	servicenowstate		int	"servicenowstate",
	servicenowsysid		varchar	"servicenowsysid",
	siteid			varchar	"siteid",
	situationfullname		varchar	"situationfullname",
	smsflag			int	"smsflag",
	statechange		timestamp	"statechange",
	submodel		varchar	"submodel",
	subsystem		varchar	"subsystem",
	summary			varchar	"summary",
	suppressescl		int	"suppressescl",
	syscode			varchar	"syscode",
	sysplex			varchar	"sysplex",
	tally				int	"tally",
	tasklist		int	"tasklist",
	ticketstatus		varchar	"ticketstatus",
	tiggerflag		int	"tiggerflag",
	tsrmflag		int	"tsrmflag",
	ttnumber		varchar	"ttnumber",
	ttstate			int	"ttstate",
	ttuser			varchar	"ttuser",
	type				enum {
		"0":["Type not set"],
		"1":["problem", "问题"],
		"2":["resolution", "恢复"],
		"7":["ISM new alarm", "问题"],
		"8":["ISM old alarm", "恢复"]}	"type",
	upgradeflag		int	"upgradeflag",
	url					varchar	"url",
	x733corrnotif		varchar	"x733corrnotif",
	x733eventtype		int	"x733eventtype",
	x733probablecause		int	"x733probablecause",
	x733specificprob		varchar	"x733specificprob",

	keys( identifier) ,



	)with ttl=3 day , expire=3 day , autosearch=true , version=true , key=manu, alias='Tivoli告警事件' , nickname='alerts_status' , namespace='cncc' ; `);*/

	/*rst,meta,err := g.Query(`
	  	 create class if not exists /matrix/applet (
	                  xid               int         "id",
	  				xcode             varchar     "code",
	                  xcode1             varchar     "code",
	  				xcode2             varchar     "code",
	  				xcode3             varchar     "code",
	  				xcode4             varchar     "code",
	  				xcode5             varchar     "code",
	  				xcode6             varchar     "code",
	  				xcode7             varchar     "code",
	  				xcode8             varchar     "code",
	  				xcode9             varchar     "code",
	  				xcode10             varchar     "code",
	  				xcode11             varchar     "code",
	  				xcode12             varchar     "code",
	  				xcode13             varchar     "code",
	  				xcode14             varchar     "code",
	  				xcode15             varchar     "code",
	  				xcode16             varchar     "code",
	  				xcode17             varchar     "code",
	  				xcode18             varchar     "code",
	  				xcode19             varchar     "code",
	  				xcode20             varchar     "code",
	  				xcode21             varchar     "code",
	  				xcode22             varchar     "code",
	  				xcode23             varchar     "code",
	  				xcode24             varchar     "code",
	  				xcode25             varchar     "code",
	  				xcode26             varchar     "code",
	  				xcode27             varchar     "code",
	  				xcode28             varchar     "code",
	  				xcode29             varchar     "code",
	  				xcode30             varchar     "code",
	  				xcode31             varchar     "code",
	  				xcode32             varchar     "code",
	  				xcode33             varchar     "code",
	  				xcode34             varchar     "code",
	  				xcode35             varchar     "code",
	  				xcode36             varchar     "code",
	  				xcode37             varchar     "code",
	  				xcode38             varchar     "code",
	  				xcode39             varchar     "code",
	  				xcode40             varchar     "code",
	  				xcode41             varchar     "code",
	  				xcode42             varchar     "code",

	                  xkey              varchar     "key",
	                  xcreateBy         varchar     "createBy",
	                  xcreateByView     varchar     "createByView",
	                  xcreateTime       timestamp   "createTime",
	                  xupdateBy         varchar     "updateBy",
	                  xupdateByView     varchar     "updateByView",
	                  xupdateTime       timestamp   "updateTime",
	                  xversion          int         "version",
	                  xlocale           varchar     "locale",
	                  xsortNumber       int         "sortNumber",
	                  xenableFlag       int         "enableFlag",
	                  xdeleteFlag       int         "deleteFlag",
	                  xextend           text        "",
	                  vtime             timestamp   "vtime",
	                  keys(xid),
	                  indexes(xid,xcode,xkey)
	  )
	  ` )*/

	//rst,meta,err := g.Query(``, &QueryMeta{Return: ReturnAll} )

	//rst,meta,err := g.Query(`DROP CLASS aaWorkPiece `, &QueryMeta{Return: ReturnAll} )

	//rst,meta,err := g.Query(`select id from  /matrix/test/oo/wheel where dim.bk2.time("2020-05-15", "").sum(iparam1).groupby(sparam1).assert($2 > 0)`, &QueryMeta{Return: ReturnAll} )

	//rst,meta,err := g.Query(`insert into /matrix/test/myconflict(mykey, bb, cc) values(1, "test2", 12)`, &QueryMeta{Return: ReturnAll} )

	//rst,meta,err := g.Query(`insert into /matrix/test/myconflict(mykey, bb, cc) values(1, "test", 100) on conflict update bb=this.bb, cc=this.cc`, &QueryMeta{Return: ReturnAll} )

	//rst,meta,err := g.Query(`select bb, cc from /matrix/test/myconflict`, &QueryMeta{Return: ReturnAll} )

	//rst,meta,err := g.Query(`insert into /matrix/testgroup g1='g1' , g2='g2', g3='g34' , v1=1 , v2=2 , f1=1.1 , f2=1.2`)

	//rst,meta,err := g.Query(`update /matrix/entity/linux set name="linux:wecise33" where id="linux:wecise3"`)

	//rst,meta,err := g.Query(`SELECT  count(*) FROM 	 /matrix/devops/event`)

	/*rst,meta,err := g.Query(`select * from /matrix/devops/event`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false})*/
	//rst,meta,err := g.Query(`match ("linux:*")-[*]->("esx:*")-[*1]->("switch:*")`)

	//rst,meta,err := g.Query(`match ("biz:查账系统")-[*]->("linux:*")-[*1]->("esx:*")`)

	//rst,meta,err := g.Query(`match (p:"linux:linux[1-5]")-[*]->(q:"esx:esx4")`)

	//rst,meta,err := g.Query(`update /matrix/entity/linux set contain=["app:cassandra"] where id="linux:wecise"`)

	//rst,meta,err := g.Query(`alter class /matrix/devops/performance add index column taggroup2 map<varchar,varchar>`)

	//rst,meta,err := g.Query(`delete from /matrix/devops/performance with version`)

	//rst,meta,err := g.Query(`update /matrix/entity/linux set contain=nil where id="linux:wecise"`)

	//rst,meta,err := g.Query(`update /matrix/entity/linux set contain={"_all": ["app:cassandra"]} where id="linux:wecise",`)

	//rst,_,err := g.Query(`select * from /matrix/devops/中文测试`)

	//rst,err := g.Query(`drop class /matrix/relations`,false)

	//rst,err := g.Query(`drop class /matrix`,false)

	//rst,meta,err := g.Query(`update /matrix/system/hostinfo set depot={'test''4': 'values''hh'} where id="15639783474304169459"`)

	//rst,meta,err := g.Query(`SELECT 	 depot FROM 	 /matrix/system/hostinfo where depot[key]='test''4'`)

	//rst,meta,err := g.Query(`update /matrix/entity/switch set element=element + {"aa":"bb"}  where id='switch:0switch1'`)

	//rst,meta,err := g.Query(`update /matrix/test set name="test8" , test="test" WHERE test2 = "Test22"`)

	//rst,meta,err := g.Query(`update json  '{"class":"/matrix/ldap", "id":"15305020520705546474", "remark":"15919268718129958720,729969318835110277"}' `)

	//rst,err := g.Query(`delete from /matrix/ldap where fullname in ('/测试组','/测试组/testuser')`,false)
	//rst,err := g.Query(`delete from /matrix/ldap where fullname in ('aaa','testuser')`,false)

	//rst,meta,err := g.Query(`SELECT * FROM /matrix/system/hostinfo where depot['111']='11'`)

	//rst,meta,err := g.Query(`match ("well:well1")-[*]->("tank:tank1")`)

	//rst,meta,err := g.Query(`Insert into /matrix/portal/tools name='对象管理' cnname='对象管理' enname='OMDB' icon='omdb.png' seat=10 selected=0 url='/janesware/omdb'`)

	//rst,meta,err := g.Query(`insert into /matrix/entity/linux (id, contain) values ('linux:wecise',["app:cassandra1"])`)

	//rst,meta,err := g.Query(`match ("well:well1")-[*]->() with timeout=100`)

	//rst,meta,err := g.Query(`match ("well:well1")-[:connect*]->(:/matrix/entity/valve where name = 'valve:valve1')`)

	//rst,meta,err := g.Query(`SELECT host as host2, class, app FROM /matrix/devops/event/ facet host2 as hello`, &QueryMeta{Return: ReturnAll, MinAsteriskField: true, KeepClassID: false, NotAddFields:true} )

	//rst,meta,err := g.Query(`select * from /matrix/devops/event/ facet vtime{"old":[,'-1 day'],"new":['-1 day',]}`, &QueryMeta{Return: ReturnAll, MinAsteriskField: true, KeepClassID: false} )

	//rst,meta,err := g.Query(`select * from /matrix/devops/performance facet value{"small":[,10],"big":[10,]}`, &QueryMeta{Return: ReturnAll, MinAsteriskField: true, KeepClassID: false} )

	//rst,err := g.Query(`Insert into /matrix/flowmark/btndef script='return "hello" ',name='test',wfid=-1  `,false)

	/*
		rst,err := g.Query(`

		Insert into /matrix/flowmark/btndef script='print("hello")',name='test1',wfid=-1 	;
		Insert into /matrix/flowmark/btndef script='print("hello")',name='test2',wfid=-1 	;
		Insert into /matrix/flowmark/btndef script='print("hello")',name='test3',wfid=-1	;
		Insert into /matrix/flowmark/btndef script='print("hello")',name='test4',wfid=-1	;
		Insert into /matrix/flowmark/btndef script='print("hello")',name='test5',wfid=-1	;

		`,false)
	*/

	/*
		if fields, err := g.Query("select node,agent,summary from /matrix/event/tivoli where severity>=0 "); err != nil {
			fmt.Println(err.Error())
		}else{
			for i:=0 ; i< len(fields) ;i++ {
				fmt.Println(fields[i]["agent"].(string),fields[i]["summary"].(string))
			}
		}
	*/
	/*
		if _, err := g.Query("truncate /matrix/event/open"); err != nil {
			fmt.Println(err.Error())
		}else{
		}
	*/

	// 测试 Alter Table
	/*
		for i:=0 ; i<1000 ;i++ {
			sql := fmt.Sprintf(`ALTER  TABLE object ADD H%d %s`,i,"text")
			logger.Debugf(sql)
			if err := g.GetSession().Query(sql).Consistency(gocql.Quorum).Exec(); err != nil {
				logger.Fatalf("ADD ERROR %v",err)
			}

	*/
	/*
		for i:=0 ; i<1000 ;i++ {
			sql := fmt.Sprintf(`ALTER TABLE object DROP  H%d `,i)
			logger.Debugf(sql)
			if err := g.GetSession().Query(sql).Consistency(gocql.Quorum).Exec(); err != nil {
				logger.Fatalf("DROP ERROR %v",err)
			}
		}
	*/

	//rst,meta,err := g.Query(`create class if not exists Camry : Car () with key=manu`)
	//rst,meta,err := g.Query(`drop class /matrix/test/oo/car`)
	//rst,meta,err := g.Query(`delete from /matrix/test/oo/car with version`)

	/*if def, err := g.ClassDefine(316) ; err == nil {
		logger.Warn( def )
	}*/

	/*dfs := NewDFS(g)
	err = dfs.Rename("/temp/test", "/temp/testaaa")
	logger.Error(err)*/

	/*rst,meta,err := g.Query(`
	delete from /matrix/test/collectaa with version ;
	drop class /matrix/test/collectaa`)*/

	/*rst,meta,err := g.Query(`
	create class if not exists /matrix/test();
	create class if not exists /matrix/test/collectaa (

		v_varchar		varchar,
		v_map			map<varchar, varchar>,
		v_list			list<varchar>,
		d_list			double[1..5],
		f_list			FFFLIST,
		i_list			list<int>,
		v_set			set<varchar>,
		v_type			VVENUM,
		indexes(v_varchar, v_map, v_list, v_set, v_type, d_list, f_list, i_list),
		keys(v_varchar)
	);`)*/

	//rst,meta,err := g.Query(`drop class if exists /matrix/test/oo/wheel ;		`)

	/*rst,meta,err := g.Query(`create class if not exists /matrix/test/buckettsdb (

		host varchar,

		bk2  bucket {
				 "type"  :  "tsdb",
				 "param" : ["iparam1","iparam2","fparam1","fparam2","sparam1","vparam1"],
				 "ptype" : ["i","i","f","f","s","s"],
				 "unit"  : ["%","m","ms","ns","",""]
				 "precision":[0,0,3,4,0,0],
				 "ttl"   :   365,
				 "crc"	 :	["iparam1", "sparam1"]
			 } 'full',

		keys(host),
		indexes(host)

	) with key=manu, nickname='buckettsdb'
		`)*/

	/*rst,meta,err := g.Query(`CREATE CLASS IF NOT EXISTS MachineToolSpecification: MachineTool (
		machine_class				MachineClass,
		device_id					DeviceId,
		location					Locator
	); `)*/

	/*rst,meta,err := g.Query(`create class if not exists interface : /matrix/entity (

		aa				int,
		myinterface 	interface,
		keys(aa)
	) `)*/

	//rst,meta,err := g.Query(`drop class /matrix/test/oo/car/camry 	`)
	//rst,meta,err := g.Query(`create class if not exists Camry : Car () with key=manu ; 	`)

	/*rst,meta,err := g.Query(`

	create class if not exists Camry : Car () with key=manu
	`)*/

	/*rst,meta,err := g.Query(`

	create class if not exists /matrix/entity/wheel (
	 size int '尺寸',
	 color varchar '颜色'
	) with ttl=366 day , alias='wheel', nickname='wheel';
	`)*/

	/*rst,meta,err := g.Query(`

		create class if not exists /matrix/entity/wheel (
	  sise   int "尺寸",
	  color     varchar "颜色"
	) with ttl=366 day , alias='wheel', nickname='wheel';

	create class if not exists /matrix/entity/car (
	    wheel     wheel[4..4] "轮子",
	  sise   int "尺寸",
	  color     varchar "颜色"
	) with ttl=366 day , alias='car', nickname='car';

		`)*/

	if err != nil {
		logger.Info("Query error:" + err.Error())
		logger.Warn(meta["type"])
	} else {
		logger.Info("rst ===>", rst)
		//logger.Error("meta ===>", meta)

		if meta["trace"] != nil && len(meta["trace"].([]string)) > 0 {
			for _, msg := range meta["trace"].([]string) {
				logger.Error(msg)
			}
		}

		logger.Warn(meta["columns"])
	}

}