odbtest/test/query/testg.go

package main

import (
	//"fmt"
	//"time"
	//"math"
	//"strconv"
	//"time"
	//"bytes"
	//"encoding/json"
	//"encoding/gob"
	. "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"' testg.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: "icbctest", 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)
	//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)
	}*/

	/*if strus, err := g.GetClassChildrenDetail("/", false); err != nil {
	   logger.Error(err)
	}else{
		logger.Info(strus)
	}*/

	//l := g.ChildWithLevel("/",1)
	//logger.Error(l)

	/*if strus, err := g.GetClassStructEx("/matrix/jobs/jobctrl"); err != nil {
	   logger.Error(err)
	}else{
		logger.Info(strus)
	}*/

	/*if err := g.ExecSyncFS(); err != nil {
	   logger.Error(err)
	}*/

	/*if files, err := g.FSIdx().Search([]string{"/opt/knowledge"}, "next", nil, nil) ; err != nil {
		logger.Error(err)
	}else{
		logger.Info(files)
	}*/

	/*sql := `DELETE FROM rels WHERE name = ?`
	for i:=0 ; i<170 ; i++ {
		name := "testname"+strconv.Itoa(i)
		if err := g.GetSession().Exec(sql,name); err != nil {
			logger.Error(err)
		}
	}*/

	/*colmap := map[string][]int{}
	for i:=160 ; i<170 ; i++ {
		name := "testname"+strconv.Itoa(i)
		remark := "testremark"+strconv.Itoa(i)
		if err := g.NewEdgeType(name, remark, 0, colmap) ; err != nil {
			logger.Error(err)
		}
	}*/

	if define, err := g.ClassDefine("/matrix/entity/db2"); err != nil {
		logger.Error(err)
	} else {
		logger.Info(define)
	}

	/*mtype := CacheTrigger | CacheField | CacheClass | CacheRels | CacheBulk | CacheTSDB | CacheBitLog | CachePromdb | CacheTypeDef | CacheNative

	if err := g.RefreshCache(mtype); err != nil {
		logger.Error(err)
	}*/

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