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 // #include // 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"])*/ } //} //} }