odbtest/test/query/testupdate.go

package main

import (
	//"fmt"
	"os"
	"runtime/pprof"

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

// CGO_ENABLED=1 go run --ldflags '-linkmode external -extldflags "-static"' testupdate.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: "icbctest", DisableInitialHostLookup: true, DisableNotify: true}
	cpuFile, err := os.OpenFile(mdir.GetRoot()+"/var/logs/odbserver/update_cpu.pprof", os.O_CREATE|os.O_TRUNC|os.O_RDWR, os.ModePerm)
	if err != nil {
		logger.Fatal(err)
	}
	defer func() {
		_ = cpuFile.Close()
	}()
	defer pprof.StopCPUProfile()
	if err = pprof.StartCPUProfile(cpuFile); err != nil {
		logger.Fatal(err)
	}

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

	g, err := test.NewG(option)
	if err != nil {
		logger.Error(err.Error())
	} else {
		defer g.Close()
	}

	//rst,meta,err := g.Query(` update /matrix/entity/linux set files= files + 'websphere.png'  where id='linux:wecise' `)

	//_,meta,err := g.Query(`update edge type refer '引用引用'`, &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(`update /matrix/entity/linux set name="linux:wecise33" where id="linux:wecise3"`)

	//rst,meta,err := g.Query(`update /matrix/test1 set contain = contain + 'test2' where name = 'Tom'`)

	//rst,meta,err := g.Query(`update /matrix/entity/pod set status=0 where id in ("pod:tomcat-pod3","pod:web-demo-9rfxj")`)

	//rst,meta,err := g.Query(` update /matrix/ldap set email = ['aaa@sss.com'] where id ='15305020520705546474'`)

	//rst,meta,err := g.Query(` update /matrix/entity/ set contain=contain + [{"id":"linux:wecise","intp":5,"floatp":3.9}] where id='app:app1' `)

	//rst,meta,err := g.Query(` update /matrix/devops/performance set entity='linux:wecise' where host='wecise' `)

	//rst,meta,err := g.Query(`update /matrix/tagdir set _group = _group - {"list":["/testorg4"]} where id != null `)

	//rst,meta,err := g.Query(`update  /matrix/entity/hmc set config["hello"]="/testorg4" where id='hmc:node3'`)

	//rst,meta,err := g.Query(`update  /matrix/tagdir set  _group=_group + {"list": "/newadmin" }   where name='数据库' and domain='script'`)

	//rst,meta,err := g.Query(`update /matrix/entity/http set connect["_all"]=["biz:aa"] where id='http:查账http4'`)

	//rst,meta,err := g.Query(`update /matrix/notification/situation set situation='severity>=3',name='微风微风' where id='14642467172326457487'`)

	//rst,meta,err := g.Query(`update  /matrix/devops/performance set tags=tags+'aaaa' where id in ('2566678363362390985', '11005591685547732574') `)

	//rst,meta,err := g.Query(`update /matrix/entity/aix  set config['hello3']='world3' where id='aix:trigger'`)

	//rst,meta,err := g.Query(`update /matrix/devops/alert_status set status= 40 where id='9993383920724275407'`)

	/*rst,meta,err := g.Query(`update /matrix/devops/alert set status = 10 where biz = 'test';
	select biz, src, id, status, ctime, vtime from /matrix/devops/alert where biz = 'test' and host = 'test' and status = 10 order by ctime limit -1;`)*/

	//rst,meta,err := g.Query(`update /test/oo/car set wheel = wheel - ['Wheel:wheel2'] where id='Car:car1'`)

	rst, meta, err := g.Query(`  update /m3event/devops/ set status = 13 where id='5502380574017902809' `)

	//rst,meta,err := g.Query(` update Car set runon = nil where  id='Car:car1' `)

	//rst,meta,err := g.Query(`update alert_status set type=2 where severity in (2,4)`)

	//rst,meta,err := g.Query(`update /matrix/m3mcc/icmp set count=4, eventrule='/matrix/rules/alert', failureinterval=30, failureretry=3, icmpdesc='PING', icmpname='PING_64', packagesize=64, perfrule='/matrix/rules/itm_perf', poll=120, retry=3, rulemould='', timeout=120, type=0, bucketconfig='', forced=false  , tags="h3343", enable=true where id='PING_64'`)

	//rst,meta,err := g.Query(`update /grapetec/tool_body/milling_tool_body/milling_cutter/endmill/ball_endmill set dimension=dimension+"ToolDimension:hello" where id='BallEndmill:915908668883599162_29'`)
	//rst,meta,err := g.Query(`update /matrix/entity/node set connect = connect + "node:DFD9247-940013-1", assetid='222222' where id='node:DFD9255-940106-1'`)

	//rst,meta,err := g.Query(`update edge type connect 'connect' `)

	//rst,meta,err := g.Query(`update /matrix/entity/db2 set ip = '172.16.248.158' where id='db2:db21' `, &QueryMeta{Return: ReturnAll})
	//rst,meta,err := g.Query(`update /matrix/entity/db2 set config = config + {"mykey": "myvalue"} where id='db2:db21' `, &QueryMeta{Return: ReturnAll})
	//rst,meta,err := g.Query(`update /matrix/entity/db2 set connect = connect + "aix:5" where id='db2:db21' `, &QueryMeta{Return: ReturnAll})

	//rst,meta,err := g.Query(`update /matrix/devops/performance set connect = connect + "aix:5" where id='11482121141586154468' `, &QueryMeta{Return: ReturnAll})

	//rst,meta,err := g.Query(`update alert_status set type=2 where severity = 3`, &QueryMeta{Return: ReturnAll})

	//rst,meta,err := g.Query(`update /matrix/entity/aix set ip='192.168.31.202', tags=tags+"world", connect=connect+"aix:1", config = config + {"k1": "v1"} where id = 'aix:test'`, &QueryMeta{Return: ReturnAll})

	//rst,meta,err := g.Query(`update /matrix/entity/aix set ip='192.168.31.200', tags="mytag2", connect="aix:3", config = {"k2": "v2"} where id="aix:test"`, &QueryMeta{Return: ReturnAll})

	//rst,meta,err := g.Query(`update /matrix/entity/http set connect=null where id='http:查账http4'`)

	//rst,meta,err := g.Query(`update /matrix/entity/http set connect["_all"]=null where id='http:查账http4'`)

	//rst,meta,err := g.Query(`update /matrix/entity/http set connect={"_all":[]} where id='http:查账http4'`)

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

	//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,meta,err := g.Query(`update /matrix/system/hostinfo set depot={'test''4': 'values''hh'} where id="15639783474304169459"`)

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

	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"])
	}
}