odbtest/test/query/testdelete.go

package main

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

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

	/*conf := redisvr.ODBConfig("0.0.0")
	odb.ODB = odb.NewOMDB(conf)
	odb.MRingHandle = odb.MRingStart()
	*/
	//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(`delete prom FROM  /test/malert_status  where id= '8209095587217160598'`)

	rst, meta, err := g.Query(` delete from /test/malert_status`)

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

}