odbtest/test/query/testoo.go

package main

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

// CGO_ENABLED=1 go run --ldflags '-linkmode external -extldflags "-static"' testoo.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();
func main() {

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

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

	// 测试MQL

	//rst,meta,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,meta,err := g.Query(`match ("biz:数字国网","biz:开发测试")-[*]->() return name,status,.*`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: 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(`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(`select count(id) from /matrix/filesystem`)

	//rst,meta,err := g.Query(`select * from /matrix/entity/ where id='sanstorage:sanstorage1'`)

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

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

	//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} )

	//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} )

	//bug
	//rst,meta,err := g.Query(`SELECT  contain FROM  /matrix/entity/biz where contain is not null`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//bug

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

		v_varchar		varchar,
		v_map			map<varchar, varchar>,
		v_list			list<varchar>,
		v_set			set<varchar>,

		indexes(v_varchar, v_map, v_list, v_set),
		keys(v_varchar)
	)`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )*/

	/*rst,meta,err := g.Query(`select e.bk_inst_name as instName,
	       i.name as serverName,
	       i.park_id as parkId
	from /matrix/entity/physical_resource_obj/firewall e join (i:/matrix/entity/physical_resource_obj/server) on e.park_id=i.park_id
	where i.park_id = '133103'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )*/

	/*rst,meta,err := g.Query(`select bk_inst_name
	from /matrix/entity/physical_resource_obj/firewall e left join (i:/matrix/entity/physical_resource_obj/server) on e.park_id=i.park_id
	where i.park_id = '133103'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )*/

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

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

	//rst,meta,err := g.Query(`select e.id as id,e.name as name,e.severity,p.id,p.name as p_name from /matrix/devops/event e join (p:pod) on e.entity = p.id`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT distinct e.biz,e.id,e.entity FROM /matrix/devops/event e  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2[0-2,3,4] as fff FROM /matrix/testbucket  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2[ 'iparam1', 'iparam2', 'fparam1', 'fparam2', 'sparam1'] FROM /matrix/testbucket  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2[-1,-2,-3,-4,-5] FROM /matrix/testbucket  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2 FROM /matrix/testbucket  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2[-1 - 1] FROM /matrix/testbucket  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )
	//rst,meta,err := g.Query(` SELECT bk2[1 - -1] FROM /matrix/testbucket  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )
	//rst,meta,err := g.Query(` SELECT bk2[ 4-3] FROM /matrix/testbucket  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )
	//rst,meta,err := g.Query(` SELECT bk2[ 'iparam1', 3-1, 4] FROM /matrix/testbucket  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2[ 'iparam1', 1-3, 4] FROM /matrix/testbucket  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )
	//rst,meta,err := g.Query(` SELECT bk2 FROM /matrix/testbucket  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2[ 'iparam1', 'iparam2', 2-3, 4 ].time('2020-04-22 08:10', '').(iparam1=1).count(iparam1)  as iparam1  FROM /matrix/testbucket4  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2[ 'iparam1', 'iparam2', 2-3, 4 ].time('2020-04-22 08:10', '').(iparam1=1).count(iparam1)  as iparam1  FROM /matrix/testbucket4  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2[ 'iparam1', 'iparam2', 2-3, 4 ].time().(iparam1=1)   FROM /matrix/testbucket4  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2[  3-4, 5 ].time('2020-05-23 22:24:15', '').([1]=1).title()  FROM /matrix/testbucket4  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	/*rst,meta,err := g.Query(`SELECT
	  id,logs.time('2020-05-30 04:36:24','2020-06-30 04:36:24')
	FROM
	  /test/bucketlog`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )*/

	//rst,meta,err := g.Query(`SELECT id, disk[1].time(1580755071774, 1690755071774).limit(3)  FROM /matrix/entity/it/it_linux`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2[ 'iparam1', 1-3, 4 ].time('2020-04-22', '').filter(fparam1 >= 0.992315).filter(iparam1 = 56).filter(fparam2 <> 0.418309)  as iparam1  FROM /matrix/testbucket  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2.time('2020-04-22', '').filter(fparam1 >= 0.992315).filter(iparam1 = 56).filter(fparam2 <> 0.418309)  as iparam1  FROM /matrix/testbucket  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2.time('2020-04-22', '').(fparam1 >= 0.992315).(iparam1 in [56,99]) FROM /matrix/testbucket4  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2[-1 - 1].time('2020-04-22', '').find(fparam1 >= 0.992315).count(fparam1) as iparm1 FROM /matrix/testbucket4  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	/*rst,meta,err := g.Query(` SELECT
		 id, bk2
	FROM
		 /matrix/testbucket7/`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )*/

	//rst,meta,err := g.Query(` SELECT bk2[-1 - 1].time('2020-04-22', '') FROM /matrix/testbucket4  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )
	//rst,meta,err := g.Query(` SELECT bk2[-1 - 1].date('2020-05-23').find(fparam1=3.4) FROM /matrix/testbucket4  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2 FROM /matrix/testbucket4  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT id,logs.time('2020-06-15','') FROM /matrix/ where id='linux:wecise'  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT id, class FROM /matrix/ where id='linux:wecise' `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` select values[0,2].time(1590231429,1590231439).find(pused='bbbbbbbbbbbbbbbbbbbb') from /test/donghuan/d  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` select values.time(1590231429,1590231439).find(pused='bbbbbbbbbbbbbbbbbbbb') from /test/donghuan/d  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bklog FROM /matrix/testbucket5  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bklog.time('2020-04-22', '').file() FROM /matrix/testbucket5  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2.date("2020-05-15").file() FROM /matrix/testbucket5  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bklog["file*.log"{116669996670004, 116669996680008}] FROM /matrix/testbucket5 `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT id,logs["aaa.log"{142883909780000}]FROM /matrix/entity/it/it_aix where id='it_aix:192.168.190.175' `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2["file1.log"{1,3,6,7}].time('2020-05-15 00:49:59,667', '').find( "twcs skipping" ) FROM /matrix/testbucket5  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT bk2 FROM /matrix/testbucket5  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT 	 bklog["file1.log"].time("2020-06-25","") FROM 	 /matrix/testbucket5 `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`	select * from /matrix/portal/tools where id in('') and groups['group'] = null or groups['group'] = '' order by seat asc `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`	select * from /matrix/entity/hmc where  host='wecise' and name='唯简'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`	select * from /matrix/system/hostinfo where  host='wecise' and name='9132822350366988138'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`	select * from /matrix/entity/ where  class='/matrix/entity/hmc' and host='wecise' and name='9132822350366988138'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`	select * from /matrix/entity/ where  class='/matrix/entity/hmc' `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`	select id,name,class,host,iplist,agentstatus,depot['文件系统检测'],config,zabbix['文件系统检测-1.0.0'] from /matrix/system/hostinfo where depot != null limit -1 `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`select id, domain, creater from /matrix/tagdir where domain = 'script' and creater = '' and name = 'ORACLE' limit 1 `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`select name, domain from /matrix/tagdir where domain = 'script' and creater = '' limit -1 `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false, User:"U/newadmin/lyt1" , Group:[]string{ "/newadmin"}} )

	//rst,meta,err := g.Query(`select count(severity) as num, max(severity) as maxsss, min(severity) as minsss from /matrix/devops/alert where severity > 2 group by biz limit -1 `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	/*rst,meta,err := g.Query(`SELECT
	  id,status,host,vtime
	FROM
	  /matrix/system/hostinfo where status = 1`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )*/

	/*rst,meta,err := g.Query(`SELECT
	  count(*) , types
	FROM
	  /matrix/entity/perbasisinfo group by types order by types limit 100000`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )*/

	/*rst,meta,err := g.Query(`SELECT
		 name
	FROM
		 /matrix/entity/aix where name=/aix:5ed617adaca22f8517f5e67[123]/` )*/

	//rst,meta,err := g.Query(`refresh /matrix/filesystem`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`select name, _group from /matrix/tagdir where _group != "/testorg"`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`select name, contain from /matrix/entity/cluster where contain != 'app:app2' and contain != 'app:Bapp2'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`SELECT  id FROM 	 /matrix/entity/aix where id != 'aix:tes*'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`refresh /matrix/filesystem`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	/*rst,meta,err := g.Query(`SELECT
	  id,disk_perf.time('2021-04-01','2021-04-02').find("mount_point" = "/").title().min("free", "pfree").max("pfree").max("free").count().groupby("mount_point", 12h)
	FROM
	  /matrix/entity/linux where id='linux:node3'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )*/

	/*rst,meta,err := g.Query(`SELECT
		 id, vtime, severity
	FROM
		 /matrix/devops/alert where severity > 0 and vtime > '2021-03-23 23:35:18.992' and  vtime < '2021-04-23 23:35:18.992'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )*/

	/*rst,meta,err := g.Query(`SELECT
	  assetid,biz,class,company,config,contact,ctel,day,dc,department,element,files,host,id,ip,location,model,mylist,mymap["key2"] as aaa,mymap["key1"] as bbb,myset,name,period,port,rack,region,room,sn,status,tags,tel,type,unit,vtime
	FROM
	  /matrix/entity/mydevice`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )*/

	//rst,meta,err := g.Query(`SELECT v_varchar, v_text FROM  /matrix/test/search where v_text like 'Cassandr*'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`insert into /matrix/test/buckettsdb (id, bk2[ 'iparam1', 'iparam2', 'fparam1', 'fparam2', 'sparam1', 'vparam1']) values ('linux:wecise', [1, nil, 3.3, 6.5, '1234567890', 'abcdefghhhhh'] ) at '2020-07-24 10:24:16'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`select bklog.time('2020-06-24','').limit(1000)  FROM /matrix/test/bucketlog`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`select id,logs.stats(3600) from /matrix/entity/linux where id = 'linux:node3' `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`select id,logs.time('2021-01-01','2021-05-15').find("ssl_req").stats(3600) from /matrix/entity/`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`SELECT id,ip,host,disk_perf.time('2018-07-27','2020-07-28').title().max("pfree","free") FROM /matrix/entity/it/it_aix`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`select id from  /matrix/test/oo/wheel where dim.length >= 100`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`select id,wheel[*] from  /matrix/entity/car/camry where wheel.rotations.time('2021-09-13 00:00:00','').sum(count).assert($1 > 12000)`, &QueryMeta{Return: ReturnAll} )

	//rst,meta,err := g.Query(`select id,wheel from  /matrix/entity/car/camry where wheel.rotations.time('2021-09-13 00:00:00','').sum(count).assert($1 > 12000)`, &QueryMeta{Return: ReturnAll} )

	// rst,meta,err := g.Query(`select * from  /matrix/entity/onewheelcar `, &QueryMeta{Return: ReturnAll} )

	//rst,meta,err := g.Query( `typedef CarMorph = Morph<Chair, Light>`, &QueryMeta{Return: ReturnAll, AsteriskNoRelation: true, AsteriskKeep: strset.New("class", "id")} )

	//rst,meta,err := g.Query( `typeundef CarMorph`, &QueryMeta{Return: ReturnAll, AsteriskNoRelation: true, AsteriskKeep: strset.New("class", "id")} )
	/*rst,meta,err := g.Query( `create class if not exists Wheel : /matrix/test/oo (

		dim				Dimension,
		mymorph			CarMorph[2],
		remark		varchar,

		indexes(remark)
	) with key=manu  `, &QueryMeta{Return: ReturnAll, AsteriskNoRelation: true, AsteriskKeep: strset.New("class", "id")} )*/

	rst, meta, err := g.Query(` typedef CharacterizedProductDefinition = morph <
        Product_Definition
        Product_Definition_Relationship
> `, &QueryMeta{Return: ReturnAll})
	/*rst,meta,err := g.Query( `CREATE CLASS IF NOT EXISTS ApplicationInstance(
	uuid text
	) with alias = 'ApplicationInstance', nickname = 'ApplicationInstance', version = true;

	-- TYPE : ENTITY
	CREATE CLASS IF NOT EXISTS application_context : ApplicationInstance (
	        application     text
	) with alias = 'ApplicationContext', nickname = 'ApplicationContext', version = true;

	-- TYPE : ENTITY
	CREATE CLASS IF NOT EXISTS application_context_element : ApplicationInstance (
	        name    text,
	        frame_of_reference      ApplicationContext
	) with alias = 'ApplicationContextElement', nickname = 'ApplicationContextElement', version = true;

	-- TYPE : ENTITY
	CREATE CLASS IF NOT EXISTS product_context : ApplicationContextElement (
	        discipline_type text
	) with alias = 'ProductContext', nickname = 'ProductContext', version = true;

	-- TYPE : ENTITY
	CREATE CLASS IF NOT EXISTS product : ApplicationInstance (
	        id      text,
	        name    text,
	        description     text,
	        frame_of_reference      ProductContext[?]
	) with alias = 'Product', nickname = 'Product', version = true;

	-- TYPE : ENTITY
	CREATE CLASS IF NOT EXISTS product_definition_formation : ApplicationInstance (
	        id      text,
	        description     text,
	        of_product      Product
	) with alias = 'ProductDefinitionFormation', nickname = 'ProductDefinitionFormation', version = true;

	-- TYPE : ENTITY
	CREATE CLASS IF NOT EXISTS product_definition_context : ApplicationContextElement (
	        life_cycle_stage        text
	) with alias = 'ProductDefinitionContext', nickname = 'ProductDefinitionContext', version = true;

	-- TYPE : ENTITY
	CREATE CLASS IF NOT EXISTS product_definition : ApplicationInstance (
	        id      text,
	        description     text,
	        formation       ProductDefinitionFormation,
	        frame_of_reference      ProductDefinitionContext
	) with alias = 'ProductDefinition', nickname = 'ProductDefinition', version = true;

	-- TYPE : ENTITY
	CREATE CLASS IF NOT EXISTS product_definition_relationship : ApplicationInstance (
	        id      text,
	        name    text,
	        description     text,
	        relating_product_definition     ProductDefinition,
	        related_product_definition      ProductDefinition
	) with alias = 'ProductDefinitionRelationship', nickname = 'ProductDefinitionRelationship', version = true;

	-- TYPE : SELECT
	typedef IF NOT EXISTS CharacterizedProductDefinition = morph <
	        Product_Definition,
	        Product_Definition_Relationship
	>;

	-- TYPE : ENTITY
	CREATE CLASS IF NOT EXISTS characterized_object : ApplicationInstance (
	        name    text,
	        description     text
	) with alias = 'CharacterizedObject', nickname = 'CharacterizedObject', version = true;

	-- TYPE : ENTITY
	CREATE CLASS IF NOT EXISTS product_definition_shape : PropertyDefinition (

	) with alias = 'ProductDefinitionShape', nickname = 'ProductDefinitionShape', version = true;

	-- TYPE : ENTITY
	CREATE CLASS IF NOT EXISTS shape_aspect : ApplicationInstance (
	        name    text,
	        description     text,
	        of_shape        ProductDefinitionShape,
	        product_definitional    boolean
	) with alias = 'ShapeAspect', nickname = 'ShapeAspect', version = true;

	-- TYPE : ENTITY
	CREATE CLASS IF NOT EXISTS shape_aspect_relationship : ApplicationInstance (
	        name    text,
	        description     text,
	        relating_shape_aspect   ShapeAspect,
	        related_shape_aspect    ShapeAspect
	) with alias = 'ShapeAspectRelationship', nickname = 'ShapeAspectRelationship', version = true;

	-- TYPE : SELECT
	typedef ShapeDefinition = morph <
	        Product_Definition_Shape
	        Shape_Aspect
	        Shape_Aspect_Relationship
	>;

	-- TYPE : SELECT
	typedef CharacterizedDefinition = morph <
	        Characterized_Object
	        Characterized_Product_Definition
	        Shape_Definition
	>;

	-- TYPE : ENTITY
	CREATE CLASS IF NOT EXISTS property_definition : ApplicationInstance (
	        name    text,
	        description     text,
	        definition      CharacterizedDefinition
	) with alias = 'PropertyDefinition', nickname = 'PropertyDefinition', version = true;
	`, &QueryMeta{Return: ReturnAll, AsteriskNoRelation: true, AsteriskKeep: strset.New("class", "id")} )*/

	// rst,meta,err := g.Query(`select class from /matrix/test/ where id='5596563062509798226'`, &QueryMeta{Return: ReturnAll} )

	//rst,meta,err := g.Query(` SELECT  bklog.time("2020-01-01", "").stats(3600) FROM 	 /matrix/test/bucketlog `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	// rst,meta,err := g.Query(`select *  from /matrix/test/collect where v_map = 'val3'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	/*rst,meta,err := g.Query(`SELECT
	  id,disk_perf.time('2019-01-01','2021-04-06').title().limit(50)
	FROM
	  /matrix/entity/linux where id='linux:node3'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )*/

	/*rst,meta,err := g.Query(`SELECT
		 id,bkdata.time("2020-08-01","").find(vparam1 like '*jj*')
	FROM
		 /matrix/testbucket4 `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )*/

	/*rst,meta,err := g.Query(`SELECT
	  bklog.time('2020-06-23 14:50','2020-06-23 15:00').find('twcs'),id
	FROM
	  /matrix/testbucket5 `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )*/

	/*rst,meta,err := g.Query(`SELECT
	  id,disk_test.time('2020-07-27','')
	FROM
	  /matrix/entity/it/it_aix `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )*/

	/*rst,meta,err := g.Query(`SELECT
		 bkdata,class,day,host,id,name,real,status,tags,vtime
	FROM
		 /matrix/testbucket4`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )*/

	/*rst,meta,err := g.Query(` SELECT
		 id
	FROM
		 /matrix/testbucket5/ where bklog.time("2020-05-01","").find("INFO")  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )*/

	//rst,meta,err := g.Query(`select name, pprefix, pmatch, _group from /matrix/perms/api where _group = '测试组' `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` select depot['df302'] from /matrix/system/hostinfo `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	/*rst,meta,err := g.Query(`SELECT
		 depot
	FROM
		 /matrix/system/hostinfo where depot = nil`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )*/

	//rst,meta,err := g.Query(` SELECT bk2.time('2020-04-22 08:09', '').filter( "iparam1" <= 2 )  as iparam1  FROM /matrix/testbucket  `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(` SELECT * FROM /matrix/filesystem   `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )
	//rst,meta,err := g.Query(`select ip,host,msg,entity,severity from /matrix/devops/event e join ("biz:数字国网")-[*]->("app:*")-[*]->(h:linux) on e.entity = h.id where e.severity > 3`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//rst,meta,err := g.Query(`select id, config["aa","bb"], email[0,2] from /matrix/ldap where id='8999302930065828009'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

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

	//bug
	//rst,meta,err := g.Query(`select 1, "hello" as strcol, contain from "/matrix/devops/performance" where contain is null`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//bug
	//rst,meta,err := g.Query(`select * from "/matrix/devops/performance" where host='123'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//bug
	//rst,meta,err := g.Query(`select g1, avg(v1) as avgv1 from "/matrix/testgroup" group by g1`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )
	//rst,meta,err := g.Query(`select avg(v1) as avgv1 from "/matrix/testgroup" `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//bug
	///rst,meta,err := g.Query(`select avg(v1) as avgv1 from "/matrix/testgroup" group by g1,g3`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	//t1 := time.Now()
	//rst,meta,err := g.Query(`select wecise FROM asdf/matrix/devops/event where host = "wecise"`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	/*rst,meta,err := g.Query(`SELECT
		 app,biz,card,class,ctime,day,entity,hdware,host,id,inst,ip,msg,name,org,param,script,severity,src,status,tags,vtime
	FROM
		 /matrix/devops/event where host in ('wecise') `, &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(`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(`SELECT  count(*) FROM 	 /matrix/devops/event`)

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

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

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

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

	//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(`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} )

	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"])
		logger.Warn(meta["params"])
	}
}