odbtest/test/testcypher.go

package main

import (
	//"fmt"
	"os"
	"runtime/pprof"

	"git.wecise.com/wecise/odbserver/odb/test"
	"gitee.com/wecisecode/util/logger"
)

func main() {

	//options := map[string]interface{} {"cache":odb.CacheAll}
	//g,err:= odb.New( options )

	//option := &StoreOption{Cache:CacheAll}
	option := &Option{Cache: CacheAll, Keyspace: "matrix"}
	g, err := test.NewG(option)

	if err != nil {
		logger.Error(err.Error())
	} else {
		defer g.Close()
	}

	// go tool pprof -http=127.0.0.1:8080 E:\test\test_cpu.pprof

	pf, err := os.Create("E:/test/test_cpu.pprof")
	if err != nil {
		logger.Fatal(err)
	}
	defer pf.Close()
	pprof.StartCPUProfile(pf)
	defer pprof.StopCPUProfile()

	//logger.SetRollingDaily("C:/test/zkcron/src/test", "test.log")
	logger.SetConsole(true)
	//logger.SetLevel(logger.DEBUG)

	//rst,meta,err := g.Query(` match ()-[]->() `)

	rst, meta, err := g.Query(`match ("biz:查账系统")-[*]->( :esx where name="esx:esx1") return status,name,tags`)
	//rst,meta,err := g.Query(`match ("biz:查账系统")-[*]->( :/matrix/entity/esx ) return status,name,tags`)
	//rst,meta,err := g.Query(`match ('linux:wecise')-[*]->()`)
	//rst,meta,err := g.Query(`match ("biz:查账系统")-[*]->()`)
	//rst,meta,err := g.Query(`match ('linux:wecise')-[*]->()-[*]->("etcd:etcd1") with timeout=3,level=10`)
	//rst,meta,err := g.Query(`match ()-[*]->("etcd:etcd1")`)

	//rst,meta,err := g.Query(`match ("linux:*")-[*]->("esx:esx4")`)
	//rst,meta,err := g.Query(`match ( :linux )-[*]->("esx:esx4")`)

	//rst,meta,err := g.Query(`match ("biz:查账系统")-[*]->("linux:linux1")-[*]->("esx:esx4")`)
	//rst,meta,err := g.Query(`match ("linux:wecise")-->()`)
	//rst,meta,err := g.Query(`match ("biz:查账系统")-[:contain]-()-[*]-()`)
	//rst,meta,err := g.Query(`match ("linux:wecise")-[*]->("etcd:etcd")`)
	//rst,meta,err := g.Query(`match ("biz:查账系统")-[:contain]-("cluster:查账系统web集群")-[*]-()`)
	//rst,meta,err := g.Query(`match ()-[:contain]->('app:cassandra1')`)
	//rst,meta,err := g.Query(`match ()-[:contain*]->('etcd:etcd')`)

	//rst,meta,err := g.Query(`match ('linux:wecise')-[:contain]->()->[:contain]->('etcd:etcd')`)

	//rst,meta,err := g.Query(`match ('linux:wecise')-[:contain]-(node) return node `)

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