odbtest/test/query/testnative.go

package main

import (
	//"fmt"
	//"time"
	//"math"
	. "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"' testnative.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 )

	logger.SetConsole(true)
	//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.SetLevel(logger.DEBUG)

	// 测试MQL

	/*==stat, _ := g.Prepare(`insert into /native/cnccbdos@202301271540 (syscode, minute, transuid, comptime, appno, dc, batchno) values(?,?,?,?,?,?,?)`)
	rst,meta,err := stat.Exec(  "IBPS", 202301251540, "aaaaa", 6789, 1, "sahnghai", 1 )*/

	/*stat, _ := g.Prepare(`insert into /native/cnccbdos (syscode, minute, transuid, comptime, appno, dc, batchno) values(?,?,?,?,?,?,?)`)
	rst,meta,err := stat.Exec(  "IBPS", 202301251540, "aaaaa", 6789, 1, "sahnghai", 1 )*/

	/*stat, _ := g.Prepare(`select transuid, appno, comptime, msgdealstatus, atrt from /native/cnccbdos@202301251540 where syscode = ? and minute = ? and batchno = ?`, &query.QueryMeta{AsteriskNoRelation: true})
	rst,meta,err := stat.Exec( "IBPS", 202301251540, 1 )*/

	/*stat, _ := g.Prepare(`update /native/cnccbdos@202301251540 set node=? where syscode = ? and minute = ? and batchno = ? and transuid= ? and appno=?`)
	rst,meta,err := stat.Exec( "bbbbbb", "IBPS", 202301251540, 1, "aaaaa", 1 )*/

	/*stat, _ := g.Prepare(`update /native/cnccbdos set node=? where syscode = ? and minute = ? and batchno = ? and transuid= ? and appno=?`)
	rst, meta, err := stat.Exec("bbbbbb", "IBPS", 202301251540, 1, "aaaaa", 1)
	*/

	//stat, _ := g.Prepare(`insert into /native/cncctrace@202301271540 (syscode, minute, traceid, service, msgs) values(?,?,?,?,?)`, &query.QueryMeta{AsteriskNoRelation: true})
	//rst, meta, err := stat.Exec("IBPS", 202301251540, "bbbb","sahnghai", []string{"msg1", "msg2"})

	stat, err := g.Prepare(`select * from /native/cncctrace where syscode= ? and minute=?`, &query.QueryMeta{AsteriskNoRelation: true})
	if err != nil {
		logger.Error(err)
	}

	rst, meta, err := stat.Exec("IBPS", 202301251540)

	//rst,meta,err := g.Query(`select * from /native/cncctrace@202301271540 where syscode='IBPS' and minute=202301251540` , &query.QueryMeta{AsteriskNoRelation: true})

	//rst,meta,err := g.Query(`select * from /native/cncctrace where syscode='IBPS' and minute=202301251540` , &query.QueryMeta{AsteriskNoRelation: true})

	//rst,meta,err := g.Query(`insert into /native/cncctrace@202301271540 (syscode, minute, traceid, service, msgs) values( 'IBPS', 202301251540, 'aaaaa','sahnghai', ['msg1', 'msg2'])` , &query.QueryMeta{AsteriskNoRelation: true})

	//rst,meta,err := g.Query(`insert into /native/cncctrace@202301271540 (syscode, minute, traceid, service) values( 'IBPS', 202301251540, 'aaaaa','sahnghai')` , &query.QueryMeta{AsteriskNoRelation: true})

	//rst,meta,err := g.Query(`select * from /native/cnccbdos where syscode = 'IBPS' and minute = 202301251540 and batchno = 1` )

	//rst,meta,err := g.Query(`update /native/cnccbdos set node='bbbbbb' where syscode = 'IBPS' and minute = 202301251540 and batchno = 1 and transuid='aaaaa' and appno=1`  )

	//rst,meta,err := g.Query(`insert into /native/cnccbdos (syscode, minute, transuid, comptime, appno, dc) values( 'IBPS', 202301251540, 'aaaaa', 6789, 1, 'sahnghai')` )

	//rst,meta,err := g.Query(`select * from /native/cnccbdos@202301271540` )

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