odbtest/test/query/testdrop.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"' testdrop.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: "ooootest", 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

	//bug
	//rst,meta,err := g.Query(` drop class /matrix/testbucket4 `, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )
	//rst,meta,err := g.Query(`delete logs from it_aix where id='it_aix:192.168.190.175'`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, KeepClassID: false} )

	/*rst,meta,err := g.Query(`create class if not exists /matrix/test/interface2 (
			entityname		varchar	"EntityName",
			ifalias			varchar	"IfAlias",
			ifindex			varchar	"IfIndex",
			ifname			varchar	"IfName",
			iftype			varchar	"IfType",
			interfaceid		varchar	"InterfaceId",
			intname			varchar	"IntName",
			ipaddress		varchar	"IpAddress",
			nodename		varchar	"NodeName",
			parentid		varchar	"ParentId",
			subinterface		interface2[1..?]	"subinterface",

			keys( interfaceid) ,
			index( entityname,ifalias,ifindex,ifname,iftype,interfaceid,intname,ipaddress,nodename,parentid)
	)with version_ttl=365 day , autosearch=true , version=true , key=manu, partition=nodename , alias='interface2' , nickname='interface2' ;
	`)*/
	/*rst,meta,err := g.Query(`create class if not exists /matrix/test/node2 (
			city				varchar	"City",
			classname		varchar	"ClassName",
			ipaddress		varchar	"IpAddress",
			nodeid			varchar	"NodeId",
			nodename		varchar	"NodeName",
			state				varchar	"State",
			sysobjid		varchar	"SysObjId",
			interface		interface2[1..?]	"interface",

			keys( nodeid) ,
			index( city,classname,ipaddress,nodeid,nodename,state,sysobjid)
	)with version_ttl=365 day , autosearch=true , version=true , key=manu, partition=state , alias='node2' , nickname='node2'
	`)*/

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

	//rst,meta,err := g.Query(`delete from /matrix/test/uuid where v_varchar='1' with version`, &QueryMeta{Return: ReturnAll, MinAsteriskField: false, 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"])
	}

}