odbtest/test/query/testmsg.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: "matrix", 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)
		}
	}*/

	logger.Error("=========================================")

	msg := Bucket_Notify_Message{
		Tid:    2360144,
		TTL:    365,
		Option: 0,
	}

	notify := OMDB_NOTIFY{
		Type:     "promdb_create",
		Message:  &msg,
		Finger:   time.Now().UnixNano(),
		FromDC:   "dc1",
		DCSingle: true,
	}

	var send_content []byte
	if b, err := json.Marshal(notify); err != nil {
		logger.Error(err)
	} else {
		send_content = b
	}

	//============================

	recv_notify := OMDB_NOTIFY{}
	recv_notify.Message = &Bucket_Notify_Message{}

	if err := json.Unmarshal(send_content, &recv_notify); err != nil {
		logger.Error(err)
	}

	logger.Error("===>", recv_notify.Type)

	//var recv_msg Bucket_Notify_Message

	innerMessage := recv_notify.Message.(*Bucket_Notify_Message)

	logger.Info(innerMessage.Tid)

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

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