odbtest/test/query/testtruncate.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"' testtruncate.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)

	//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(`truncate namespace 'cncc' bucket stats`)

	rst, meta, err := g.Query(`truncate class /native/cnccbdos`)

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

}