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"' testquad.go // #cgo LDFLAGS: -L/opt/odbserver/sqlite -lsqlite -ldl // #include "/opt/odbserver/sqlite/sqlite.h" // #include // #include // 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} 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) //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(`quad biz:认证系统 runon linux:wecise2`) //rst,meta,err := g.Query(`quad "biz:认证系统" runon +linux:wecise3 {"aa":"bb"}`) //rst,meta,err := g.Query(`quad "biz:认证系统" refer cassandra:{host='wecise'} {"aa":"bb"}`) //rst,meta,err := g.Query(`quad "biz:认证系统" refer +"{class='/matrix/entity/cassandra' and host='wecise'}" {"aa":"bb"}`) //rst,meta,err := g.Query(`quad "interface:RWU9451-900439-1_X2#node:RWU9451-900439-1" connect + "interface:RWU9451-900440-1_X2#node:RWU9451-900440-1"`) rst, meta, err := g.Query(`quad "iinterface:server3_ETH-0#nnode:server3" connect + "iinterface:EYD206-2210-1_Port 3/1#nnode:EYD206-2210-1"`) //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"]) } }