odbtest/test/prepare/testselect.go

package main

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

// CGO_ENABLED=1 go run --ldflags '-linkmode external -extldflags "-static"' testselect.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 Init() {
	conf := ODBConfig("0.0.0")
	ODB = NewOMDB(conf)
	MRingHandle = MRingStart()
}*/

func main() {

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

	//option := &StoreOption{Cache:CacheAll}
	option := &Option{Cache: notify.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.TRACE)

	//stat,err := g.Prepare(`select * from /matrix/clickcount where id=?`)

	//stat,err := g.Prepare(`select class,id,host,name,config from /matrix/entity/hmc where  host=? and name=?`)

	//stat,err := g.Prepare(`select count(severity) as num, max(severity) as maxsss, min(severity) as minsss from /matrix/devops/alert where severity > 2 group by biz limit -1 `)

	//stat,err := g.Prepare(`select tadd, tdelete, tedit, tlist from group where fullname in ? and (tadd[key] = ? or tdelete[key] = ? or tedit[key] = ? or tlist[key] = ?)`)

	//stat,err := g.Prepare(`select tadd, tdelete, tedit, tlist from group where fullname in ? and (tadd[key] = ? or tdelete[key] = ? or tedit[key] = ? or tlist[key] = ?)`)

	
	ids := []int64{}
	for i:= int64(5416548253991264705) ; i<5416548253991264705+30000 ; i++ {
		ids = append(ids, i)
	}
	
	partitions := []int{}
	for i:= 19935 ; i<19935+1 ; i++ {
		partitions = append(partitions, i)
	}
	
	//logger.Info("ppp ===>", ids, partitions)
	rst, err :=  g.RawQuery(`SELECT id FROM oootest_tsdb.promdb_8867463498570274429  WHERE id in ? and partition in ?`,ids, partitions)

	/*for i := 0; i < 20000; i++ {
		_, _, err = stat.Exec("222.129.134.178.1.3.6.1.4.1.2011.5.25.219.2.5.665.25.219.2.5.6", 5, 1622249715000, 1, "设备:222.129.134.178电源整体功能恢复!", 2, "huawei mttrapd", 1622211715023, "300", "222.129.134.178", "huawei_power_func", "222.129.134.178", "MTTrapd Probe", map[string]interface{}{"_raw": "{\"1\":\"SNMP Trap Test.see more:http://www.micmiu.com\",\"1_hex\":\"53 4e 4d 50 20 54 72 61 70 20 54 65 73 74 2e 73 65 65 20 6d 6f 72 65 3a 68 74 74 70 3a 2f 2f 77 77 77 2e 6d 69 63 6d 69 75 2e 63 6f 6d\",\"1_raw\":\"SNMP Trap Test.see more:http://www.micmiu.com\",\"1_text\":\"SNMP Trap Test.see more:http://www.micmiu.com\",\"2\":\"1000\",\"2_hex\":\"1000\",\"2_raw\":\"1000\",\"2_text\":\"1000\",\"3\":\".1.3.6.1.4.1.2011.5.25.219.2.5.6\",\"3_hex\":\".1.3.6.1.4.1.2011.5.25.219.2.5.6\",\"3_raw\":\".1.3.6.1.4.1.2011.5.25.219.2.5.6\",\"3_text\":\".1.3.6.1.4.1.2011.5.25.219.2.5.6\",\"4\":\"SNMPTEST\",\"4_hex\":\"53 4e 4d 50 54 45 53 54\",\"4_raw\":\"SNMPTEST\",\"4_text\":\"SNMPTEST\",\"5\":10,\"5_hex\":10,\"5_raw\":10,\"5_text\":10,\"6\":\"Sat May 29 08:55:14 CST 2021\",\"6_hex\":\"53 61 74 20 4d 61 79 20 32 39 20 30 38 3a 35 35 3a 31 34 20 43 53 54 20 32 30 32 31\",\"6_raw\":\"Sat May 29 08:55:14 CST 2021\",\"6_text\":\"Sat May 29 08:55:14 CST 2021\",\"IPaddress\":\"222.129.134.178\",\"Node\":\"222.129.134.178\",\"OID1\":\".1.3.6.1.2.1.1.1.1\",\"OID2\":\".1.3.6.1.2.1.1.3.0\",\"OID3\":\".1.3.6.1.6.3.1.1.4.1.0\",\"OID4\":\".1.3.6.1.4.1.2011.2.15.2.1.2.1.1.1.1\",\"OID5\":\".1.3.6.1.4.1.2011.2.15.2.1.2.1.1.1.2\",\"OID6\":\".1.3.6.1.4.1.2011.2.15.2.1.2.1.1.1.3\",\"PeerAddress\":\"222.129.134.178\",\"PeerIPaddress\":\"222.129.134.178\",\"Protocol\":\"udp\",\"ReceivedPort\":9162,\"ReceivedTime\":0,\"ReqId\":176301626,\"SNMP_Version\":\"2c\",\"UpTime\":\"1000\",\"Uptime\":\"8:16:40.00\",\"community\":\"public\",\"contextEngineID\":\"\",\"enterprise\":\"\",\"generic-trap\":0,\"notify\":\".1.3.6.1.4.1.2011.5.25.219.2.5.6\",\"securityEngineID\":\"1234\",\"securityLevel\":\"authPriv\",\"securityName\":\"user\",\"specific-trap\":0}"}, 5, "设备:222.129.134.178电源整体功能恢复!", 1)
	}*/
	//stat,err := g.Prepare(-1)

	//stat,err := g.Prepare(`quad "biz:认证系统" refer "{class='/matrix/entity/cassandra' and host='wecise'}" {"aa":"bb"}`)

	//stat,err := g.Prepare(`quad "biz:认证系统" refer "{class='/matrix/entity/aix' and name='aix:2'}" {"aa":"bb"}`)

	/*if stat,err := g.Prepare(`insert into /matrix/testgroup g1=?, g2=?, g3=?, v1=? , v2=? , f1=? , f2=?`) ;err != nil {
		logger.Info("Prepare error:"+err.Error())
	}else{
		logger.Errorf("%v", stat)
		//rst,meta,err := stat.Exec( [][]interface{}{{"g1111","g2222", map[string]interface{}{"bank":"tag1","core":"tag2"}, 11 , 22, 11.11,22.22}, {"g1111","3333", map[string]interface{}{"bank":"tag3","core":"tag3"}, 33 , 44,33.33,44.44 }})

		rst,meta,err := stat.Exec( "g0000","g00", map[string]interface{}{"bank":"tag8","core":"tag8"}, 88 , 88, 88.88,88.88 )

		if err != nil {
			logger.Info("Query error:"+err.Error())
		}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"])
		}
	}*/

	//

	//for i:=1 ; i<2 ; i++{
	/*if stat,err := g.Prepare(`SELECT vordercode, jobcode, jobname, custcode, custname, dorderdate, nordernum, ntaxpricemny
	  FROM /matrix/makdb/gyspj
	  WHERE  ( ( vordercode = ?  ) )  AND  ( ( jobcode = ?  ) )  AND  ( ( jobname = ?  ) )
	  AND  ( ( custcode = ?  ) )  AND  ( ( dorderdate = ?  ) )
	  AND  ( ( nordernum = ?  ) )  AND  ( ( ntaxpricemny = ?  ) )`, &QueryMeta{Return: ReturnColMeta, MinAsteriskField: true}) ;err != nil {*/

	/*if stat,err := g.Prepare(`update /matrix/group set member = member - ? where member = ? `) ;err != nil {

		logger.Info("Prepare error:"+err.Error())
	}else{*/

	//logger.Infof("%v", stat)
	//rst,meta,err := stat.Exec( [][]interface{}{{"g1111","g2222", map[string]interface{}{"bank":"tag1","core":"tag2"}, 11 , 22, 11.11,22.22}, {"g1111","3333", map[string]interface{}{"bank":"tag3","core":"tag3"}, 33 , 44,33.33,44.44 }})

	//rst,meta,err := stat.Exec("CD1204070091", "209", "PRO", "110329", 1570607126000, 2, 500)
	// mytime, _ := time.ParseInLocation("2006-01-02 15:04:05", "2020-03-17 15:22:22", time.Local)
	//rst,meta,err := stat.Exec(5, mytime )

	// rst,meta,err := stat.Exec("U/testorg/klyh", "U/testorg/klyh" )

	//rst,meta,err := stat.Exec("wecise", "9132822350366988138" )

	//rst,meta,err := stat.Exec( []string{"/admin"}, "/matrix/filesystem", "/matrix/filesystem", "/matrix/filesystem", "/matrix/filesystem" )

	/*if err != nil {
		logger.Error("err ===>", err)
	}
	rst,meta,err := stat.Exec( "IBPS" )*/

	//rst,meta,err := stat.Exec("/testorg" )

	//rst,meta,err := stat.Exec( )

	//rst,meta,err := stat.Exec(5, "2020-03-17")
	//rst,meta,err := stat.Exec("9266939748343023800")

	if err != nil {
		logger.Info("Query error:" + err.Error())
	} 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"])*/
	}
	//}
	//}
}