odbtest/test/query/testfunc.go

package main

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

// CGO_ENABLED=1 go run --ldflags '-linkmode external -extldflags "-static"' testfunc.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, DisableTask: 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)
	//var aa map[string]string

	//obj := map[string]interface{}{ "class": "/matrix/portal/tools", "name": "作业控制台"}

	//logger.Error( g.getObjectId(obj) )

	//g.UpdateTagDir("script", "", "oRACLE")

	/*if err = g.AddTags("auditlog","",[]interface{}{"0zvZ4KGT3tIs420476a8b-4b4d-490a-8d02-c4a5f2f8406c"},[]string{"更新操作"}); err != nil {
	   logger.Error(err)
	}*/

	//rst,meta,err := g.Query(`select class('app:app4') from /`, &QueryMeta{Return: ReturnAll} )

	//rst,meta,err := g.Query(`select signal('auth') from /`, &QueryMeta{Return: ReturnAll} )

	//rst,meta,err := g.Query(`select json(" /cncc/entity/app ", " deploy='PMTS_102_U' ") from /`, &QueryMeta{Return: ReturnAll} )

	//rst,meta,err := g.Query(`select reset('promdb_dict', 'prom', '/test/bucketpromdb/subpromdb') from /`, &query.QueryMeta{Return: query.ReturnAll})

	//rst,meta,err := g.Query(`select delete('bucket', 'prom_nocache', "2022-12-31") from /`, &query.QueryMeta{Return: query.ReturnAll})

	//rst,meta,err := g.Query(`select copy("promdb", "prom_nocache", "prom_ncache", "bucketpromdbnocache:wecise", "2023-07-31, 2023-07-27") from /`, &query.QueryMeta{Return: query.ReturnAll})

	//rst,meta,err := g.Query(`select rawquery("describe table vobject_test") from /`, &query.QueryMeta{Return: query.ReturnAll})

	//rst,meta,err := g.Query(`select copy("promdb", "prom_nocache", "prom_ncache", "promdb_dict", "/test/bucketpromdbnocache") from /`, &query.QueryMeta{Return: query.ReturnAll})

	rst, meta, err := g.Query(`select compact('/test/malert_status', 'firstoccurrence,corrscore,domaingroup,expiretime,identifier', '2024-01-11') from /`, &query.QueryMeta{Return: query.ReturnAll})

	time.Sleep(time.Second * 1)

	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"])
		logger.Warn(meta["params"])
	}

	//logger.Error(len(aa)>0)
}