odbtest/test/prepare/testexec/testexec.go

package main

import (
	//"fmt"
	"time"

	"git.wecise.com/wecise/mring"
	"git.wecise.com/wecise/odbserver/odb"
	. "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"' testexec.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() {
	odb.ODB = odb.NewOMDB()
	odb.MRingHandle = mring.Default()

	//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.TRACE)

	//stat,err := g.Prepare(`insert into /matrix/clickcount count=?`)

	//stat,err := g.Prepare(`update /matrix/makdb/gyspj set vordercode = ?,   jobcode = ?,   jobname = ?,   custcode = ?,   custname = ?,   dorderdate = ?,   nordernum = ?,   ntaxpricemny = ? WHERE  ( ( vordercode = ?  ) ) AND    ( ( jobcode = ?  ) ) AND    ( ( jobname = ?  ) ) AND    ( ( custcode = ?  ) ) AND    ( ( custname = ?  ) ) AND    ( ( dorderdate = ?  ) ) AND    ( ( nordernum = ?  ) ) AND    ( ( ntaxpricemny = ?  ) ) `)

	//stat,err := g.Prepare(`update /matrix/entity/hmc set config=config +?, location=? where id= ? `)

	//stat,err := g.Prepare(` insert into /matrix/tagdir (creater, domain, name, parent, path, tags) values (?, ?, ?, ?, ?, ?) `)

	//stat,err := g.Prepare(`delete from /matrix/system/hostinfo where host=? `)

	//stat,err := g.Prepare(`update /matrix/ldap set config = config + ? where otype=? refresh`)

	//stat,err := g.Prepare(`update /matrix/ldap set config = config + ? where otype=? refresh`)

	//stat,err := g.Prepare(`insert into /matrix/entity/hmc (id, config) values (?, ?)`)

	//stat,err := g.Prepare(`update / set tags = tags - 'abcdssssss123' where id in ?`)

	//stat,err := g.Prepare(`update /matrix/portal/tools set _group=_group+? where name in ? refresh`)

	//stat,err := g.Prepare(`insert into /matrix/devops/alert (src, ctime, type, _tokens, ip, entity, severity, msg) values (?, ?, ?, ?, ?, ?, ?, ?)`)

	//stat,err := g.Prepare(`insert into /matrix/action/callrecord (id, location, longitude, lac, ci, oppositenumber, starttime, bycall, name, blocation, dimensionality, phonenumber, period, callto) values (?,?,?,?,?,?,?,?,?,?,?,?,?,?)`)

	//stat,err := g.Prepare(`insert into /matrix/action/callrecord (id, blocation, longitude, period, location, name, dimensionality, oppositenumber, phonenumber, starttime, callto, bycall, ci, lac, _tokens) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`)

	//stat,err := g.Prepare(`insert into /matrix/action/callrecord (id, callto, name, period, bycall, _tokens, longitude, phonenumber, dimensionality, starttime, ci, location, lac, oppositenumber, blocation) values (?,?,?,?,?,?,?,?,?,?,?,?,?,?, ?)`)

	//stat,err := g.Prepare(`insert into /matrix/testbucket6 (id, bkdata[?]) values (?, ?) at ? `)

	//stat,err := g.Prepare(`update / set tags = tags + "aaa" where id in ?`)

	//stat,err := g.Prepare(`insert into /matrix/testbucket5 (id, bk2['file1.log']) values (?, ?) `)

	//stat,err := g.Prepare(` insert into /matrix/entity/linux (id,disk_perf) values (?, ?) at ?`)

	//stat,err := g.Prepare(`insert into /matrix/test/mpartition (v_varchar, v_int, v_float, v_text, v_bool) values(?, ?, ?, ?, ?) on conflict update v_bool=v_bool, v_float=v_float+1`)

	//stat, err := g.Prepare(`insert into /matrix/test/alert_status (identifier, severity, lastoccurrence, maintenance, msg, type, agent, firstoccurrence, omni_class, nodealias, alertgroup, node, manager, _tokens, originalseverity, summary) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) on conflict update firstoccurrence=firstoccurrence, servicenowstate=servicenowstate, emailstatus=emailstatus, tally=tally+1`)

	//stat, err := g.Prepare(`insert into /matrix/test/bucketlog (id, bklog['file1.log']) values (?, ?)`)

	//stat,err := g.Prepare(`update /matrix/portal/tools set _group = _group + ? where name in ?`)
	//stat,err := g.Prepare(`insert into /matrix/devops/alert_status (originalseverity, nodealias, alertgroup, firstoccurrence, _tokens, identifier, maintenance, entity, node, type, severity, lastoccurrence, summary, ttuser, omni_class, manager, alertkey, agent) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) on conflict update firstoccurrence=firstoccurrence, servicenowstate=servicenowstate, emailstatus=emailstatus, tally=tally+1`)

	//stat, err := g.Prepare( `insert into /matrix/test/bucketlog (id, bklog[?]) values (?, ?)`)

	//stat,err := g.Prepare(`insert into /matrix/devops/alert_status (identifier, severity, lastoccurrence, maintenance, msg, type, agent, firstoccurrence, omni_class, nodealias, alertgroup, node, manager, _tokens, originalseverity, summary) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) on conflict update firstoccurrence=firstoccurrence, servicenowstate=servicenowstate, emailstatus=emailstatus, tally=tally+1`)

	//stat,err := g.Prepare(`insert into /matrix/devops/alert_status (identifier, severity, lastoccurrence, maintenance, msg, type, agent, firstoccurrence, omni_class, nodealias, alertgroup, node, manager, _tokens, originalseverity, summary) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) on conflict update firstoccurrence=firstoccurrence, servicenowstate=servicenowstate, emailstatus=emailstatus, tally=tally+1`)

	//stat,err := g.Prepare(` insert into /matrix/devops/alert_status (identifier, firstoccurrence) values (?, ?) `)

	//stat,err := g.Prepare(`update /matrix/entity/node set connect = connect + ?, assetid= ? where id=?`)

	//stat,err := g.Prepare(` insert into /matrix/system/depot set tags =? , name=?, version=?, remark=?`)

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

	/*if stat,err := g.Prepare(`update  /matrix/clickcount set count=1 where id=?`) ;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()

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

	/*if err != nil {
		logger.Errorf("%v", err)
		return
	}*/
	//for i:=0 ;i <=10 ; i++ {
	//if rst,meta,err := stat.Exec( []string{"SCRIPT"}, "test12", "10", nil ) ; err != nil {
	/*if rst,meta,err := stat.Exec( "linux:wecise", []interface{}{`DEBUG [CompactionExecutor:584] 2020-05-15 00:49:59,666 TimeWindowCompactionStrategy.java:124 - TWCS skipping check for fully expired SSTables
	DEBUG [CompactionExecutor:583] 2020-05-15 00:49:59,666 TimeWindowCompactionStrategy.java:124 - TWCS skipping check for fully expired SSTables
	DEBUG [CompactionExecutor:584] 2020-05-15 00:49:59,666 TimeWindowCompactionStrategy.java:124 - TWCS skipping check for fully expired SSTables
	DEBUG [CompactionExecutor:583] 2020-05-15 00:49:59,666 TimeWindowCompactionStrategy.java:117 - TWCS expired check sufficiently far in the past, checking for fully expired SSTables
	DEBUG [CompactionExecutor:583] 2020-05-15 00:49:59,667 TimeWindowCompactionStrategy.java:124 - TWCS skipping check for fully expired SSTables
	DEBUG [CompactionExecutor:583] 2020-05-15 00:49:59,667 TimeWindowCompactionStrategy.java:124 - TWCS skipping check for fully expired SSTables
	WARN  [Native-Transport-Requests-1] 2020-05-15 00:50:01,043 SelectStatement.java:429 - Aggregation query used without partition key
	WARN  [Native-Transport-Requests-1] 2020-05-15 00:50:04,072 SelectStatement.java:429 - Aggregation query used without partition key
	INFO  [Thread-3] 2020-05-15 00:50:08,837 IndexMatrixSchema.java:143 - [object] No need to add fields
	INFO  [Thread-8] 2020-05-15 00:50:08,840 IndexMatrixSchema.java:143 - [vobject] No need to add fields
	WARN  [Native-Transport-Requests-2] 2020-05-15 00:50:14,231 SelectStatement.java:429 - Aggregation query used without partition key
	WARN  [Native-Transport-Requests-2] 2020-05-15 00:50:31,326 SelectStatement.java:429 - Aggregation query used without partition key
	WARN  [Native-Transport-Requests-1] 2020-05-15 00:50:34,163 SelectStatement.java:429 - Aggregation query used without partition key
	WARN  [Native-Transport-Requests-1] 2020-05-15 00:50:44,342 SelectStatement.java:429 - Aggregation query used without partition key` } ) ; err != nil {*/

	//if rst,meta,err := stat.Exec("callrecord:13962088589_10658112210002_2019-12-03 12:47:10","","0.0000","0","江苏盐城","接打电话:13962088589_10658112210002_2019-12-03 12:47:10","0.0000","10658112210002","13962088589",1575348430000,[]string{"phonenumber:10658112210002"},[]string{"phonenumber:13962088589"},"","",map[string]string{"_raw":"\t\t\t\t0\t\t\t0.0000\t0.0000\t10658112210002\t\t2019-12-03 12:47:10\t江苏盐城\t13962088589\t0\n"} ) ; err != nil {

	//if rst,meta,err := stat.Exec("callrecord:18861998197_10658112210002_2020-04-25 21:06:17","江苏盐城","0.0000","","","10658112210002",0,[]interface{}{"phonenumber:18861998197"},"接打电话:18861998197_10658112210002_2020-04-25 21:06:17","","0.0000","18861998197","0",[]interface{}{"phonenumber:10658112210002"}) ; err != nil {
	//if rst,meta,err := stat.Exec("id1",[]string{"id5"}) ; err != nil {
	//if rst,meta,err := stat.Exec( "linux:wecise", [][]interface{}{ []interface{}{i, nil, 3.3, 6.5, "5234567890"}, []interface{}{i, nil, 3.4, 6.6, "44444"}  }, time.Now().UnixNano()/1000000 ) ; err != nil {
	//if rst,meta,err := stat.Exec( "linux:wecise", []interface{}{ 1, nil, 3.3, 6.5, "3234567890" }, "2020-04-24 22:24:15" ) ; err != nil {
	//if rst,meta,err := stat.Exec("domain", "name", 60, 100, 5, 50, 100, 10, []string{"hello:world"}) ; err != nil {

	//if rst,meta,err := stat.Exec("zabbix","2019-09-10 10:01:04","1",map[string]interface{}{"_raw":"{\"EventTime\":\"2019.09.10 10:01:04\",\"EventName\": \"Failed to fetch nginx stub status page\",\"HostName\": \"Nginx102_勿删\",\"HostIP\": \"10.0.44.102\",\"Severity\":\"Warning\",\"EventID\": \"5648\",\"EventValue\":\"1\",\"ItemValue\":\"*UNKNOWN*\" ,\"ItemName\":\"Get Nginx stub status\",\"Status\":\"1\" }"},"10.0.44.102","Nginx102_勿删",4,"Failed to fetch nginx stub status page") ; err != nil {
	/*if rst,meta,err := stat.Exec( "wecise3",[]string{"192.168.100.100", "192.168.31.125"}, "aix",`{
	  "os": "aix",
	  "host": "wecise3",
	  "pid": "188776",
	  "matrixroot": "/opt/matrix",
	  "cpu_usedpercent": "0.00",
	  "memory_usedpercent": "17.80",
	  "disk_usedpercent": "0.54",
	  "disk_total": "139776",
	  "disk_free": "64000"
	}`) ; err != nil {*/

	//if rst,meta,err := stat.Exec( []string{ "node:DFD9255-940106-1"} ) ; err != nil {
	/*if rst,meta,err := stat.Exec( "file1.log", "linux:wecise", []string{"1-1--DEBUG [CompactionExecutor:584] 2020-09-25 00:49:59,666 TimeWindowCompactionStrategy.java:124 - TWCS skipping check for fully expired SSTables", "1-2--DEBUG [CompactionExecutor:583] 2020-09-25 00:49:59,666 TimeWindowCompactionStrategy.java:124 - TWCS skipping check for fully expired SSTables", "1-3--DEBUG [CompactionExecutor:584] 2020-09-25 00:49:59,666 TimeWindowCompactionStrategy.java:124 - TWCS skipping check for fully expired SSTables", "1-4--DEBUG [CompactionExecutor:583] 2020-09-25 00:49:59,666 TimeWindowCompactionStrategy.java:117 - TWCS expired check sufficiently far in the past, checking for fully expired SSTables", "1-5--DEBUG [CompactionExecutor:583] 2020-09-25 00:49:59,667 TimeWindowCompactionStrategy.java:124 - TWCS skipping check for fully expired SSTables", "1-6--DEBUG [CompactionExecutor:583] 2020-09-25 00:49:59,667 TimeWindowCompactionStrategy.java:124 - TWCS skipping check for fully expired SSTables", "1-7--WARN  [Native-Transport-Requests-1] 2020-09-25 00:50:01,043 SelectStatement.java:429 - Aggregation query used without partition key", "1-8--WARN  [Native-Transport-Requests-1] 2020-09-25 00:50:04,072 SelectStatement.java:429 - Aggregation query used without partition key", "1-9--INFO  [Thread-3] 2020-09-25 00:50:08,837 IndexMatrixSchema.java:143 - [object] No need to add fields", "1-10--INFO  [Thread-8] 2020-09-25 00:50:08,840 IndexMatrixSchema.java:143 - [vobject] No need to add fields"} ) ; err != nil {*/

	/*if rst,meta,err := stat.Exec( "file1.log", "linux:wecise", `1-1--DEBUG [CompactionExecutor:584] 2020-11-25 00:49:59,666 TimeWindowCompactionStrategy.java:124 - TWCS skipping check for fully expired SSTables
	1-2--DEBUG [CompactionExecutor:583] 2020-11-25 00:49:59,666 TimeWindowCompactionStrategy.java:124 - TWCS skipping check for fully expired SSTables
	1-3--DEBUG [CompactionExecutor:584] 2020-11-25 00:49:59,666 TimeWindowCompactionStrategy.java:124 - TWCS skipping check for fully expired SSTables
	1-4--DEBUG [CompactionExecutor:583] 2020-11-25 00:49:59,666 TimeWindowCompactionStrategy.java:117 - TWCS expired check sufficiently far in the past, checking for fully expired SSTables
	1-5--DEBUG [CompactionExecutor:583] 2020-11-25 00:49:59,667 TimeWindowCompactionStrategy.java:124 - TWCS skipping check for fully expired SSTables
	1-6--DEBUG [CompactionExecutor:583] 2020-11-25 00:49:59,667 TimeWindowCompactionStrategy.java:124 - TWCS skipping check for fully expired SSTables
	1-7--WARN  [Native-Transport-Requests-1] 2020-11-25 00:50:01,043 SelectStatement.java:429 - Aggregation query used without partition key
	1-8--WARN  [Native-Transport-Requests-1] 2020-11-25 00:50:04,072 SelectStatement.java:429 - Aggregation query used without partition key
	1-9--INFO  [Thread-3] 2020-11-25 00:50:08,837 IndexMatrixSchema.java:143 - [object] No need to add fields
	1-10--INFO  [Thread-8] 2020-11-25 00:50:08,840 IndexMatrixSchema.java:143 - [vobject] No need to add fields` ) ; err != nil {*/
	//if rst,meta,err := stat.Exec( 1, "wecise2", "oidgroup2", 1.62399934e+12, map[string]interface{}{"_raw":map[string]interface{}{"IPaddress":"172.26.38.248","Node":"172.26.38.248","PeerAddress":"172.26.38.248","PeerIPaddress":"172.26.38.248","Protocol":"udp","ReceivedPort":161,"ReceivedTime":0,"ReqId":106339259,"SNMP_Version":"2c","community":"public","contextEngineID":"","enterprise":"","generic-trap":0,"host":"172.26.38.248","message":"","monitorHost":"wecise","oidGroupName":"oidgroup2","pollInterval":20,"port":161,"profile":"","requestTime":1623581834003,"responseTIme":1623581834038,"returnStatus":"success","securityEngineID":"1234","securityLevel":"authPriv","securityName":"user","service":"snmp","snmpName1":"hostname","snmpName2":"ifIndex","snmpName3":"ifDescr","snmpName4":"ifSpeed","snmpName5":"ifAdminStatus","snmpName6":"ifInOctets","snmpName7":"ifOutOctets","snmpOid1":".1.3.6.1.2.1.1.5.0","snmpOid2":".1.3.6.1.2.1.2.2.1.1.2","snmpOid3":".1.3.6.1.2.1.2.2.1.2.2","snmpOid4":".1.3.6.1.2.1.2.2.1.5.2","snmpOid5":".1.3.6.1.2.1.2.2.1.7.2","snmpOid6":".1.3.6.1.2.1.2.2.1.10.2","snmpOid7":".1.3.6.1.2.1.2.2.1.16.2","snmpResult1":"wecise2","snmpResult2":2,"snmpResult3":"eth0","snmpResult4":0,"snmpResult5":1,"snmpResult6":2800559630,"snmpResult7":4261235364,"specific-trap":0,"taskTime":1623581834001}}, "172.26.38.248eth0oidgroup221", 2, "linux:172.26.38.248", "172.26.38.248", 2, 1, 1.623581834e+12, "设备: 172.26.38.248 端口: eth0 进流量当前值为: 137499 出流量当前值为: 4444444", "刘东", "300", "SNMP Monitor", "eth0", "linux SNMP Monitor") ; err != nil {
	//if rst,meta,err := stat.Exec( "hmc:node3", map[string]string{"list":"/testorg-6"}) ; err != nil {
	//if rst,meta,err := stat.Exec( []interface{}{"/newadmin2", nil}) ; err != nil {
	//if rst,meta,err := stat.Exec( map[string]string{"list2":"/testorg-6"}, "hmc:node3" ) ; err != nil {
	//if rst,meta,err := stat.Exec( "wecise" ) ; err != nil {
	//if rst,meta,err := stat.Exec( map[string]string{"home":"matrix/files"}, "usr" ) ; err != nil {
	//if rst,meta,err := stat.Exec( "list2", "hmc:node3" ) ; err != nil {
	//if rst,meta,err := stat.Exec( map[string]string{"list3":"/testorg+2"}, "wecise", "hmc:node3" ) ; err != nil {

	//stat,err := g.Prepare(`update /matrix/devops/alert set status = 12 where id = ? `)
	//stat,err := g.Prepare(`update /matrix/devops/alert set props = props + ? where severity = ? `)

	//stat, err := g.Prepare(`update /matrix/portal/tools set _group = ? where name in ? `)
	/*stat, err := g.Prepare(`insert into /native/nntest (syscode, appname, minute, busuid, origsenddate, msgtype, node, msgdealsch) values (?, ?, ?, ?, ?, ?, ?, ?) `)
	if err != nil {
		logger.Errorf("%v", err)
	}*/

	//_, _, err = stat.Exec( map[string][]interface{}{ "add": []interface{}{"网络部"}, "delete": []interface{}{"网络部"}, "edit": []interface{}{"网络部"}, "list": []interface{}{"网络部"}}, []interface{}{"配置管理"} )

	//_, _, err = stat.Exec( map[string][]interface{}{ "add": []interface{}{"市场部"}}, []interface{}{"配置管理"} )

	//_, _, err = stat.Exec( nil, []interface{}{"配置管理"} )

	/*_, _, err = stat.Exec( "BEPS" , "PMTS", 3, "2022060961524878", "20220725", "ccms.990.001.02", "9102-CCPC", 5.5 )
	if err != nil {
		logger.Errorf("%v", err)
	}*/

	/*stat, err := g.Prepare(`insert into /test/prepare (v_varchar, v_text, v_int, v_bigint, v_float, v_double, v_smalldouble, v_bool, v_timestamp) values (?, ?, ?, ?, ?, ?, ?, ? ,? )`)

	_, _, err = stat.Exec("*abc*", `hello word 2003 123-456-789 中华人民共和国是中国的唯一合法政府，台湾是中国一部分。  Mercury, Venus2，Earch%。Mars$Uranus CeresAndJupiterOrSaturn #Neptune Pluto_Charon"\""`, 1, 1234567890123456789, 1.1, 1.1234567890123456, 1.123456, true, nil)*/

	/*stat, err := g.Prepare(`insert into /test/bucketpromdb (id, prom) values (?, ? )`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	//_, _, err = stat.Exec("bucketpromdb:wecise", []interface{}{
	_, _, err = stat.Exec(123456, []interface{}{
		 map[string]interface{} { "__name__":"key1", "__value__":2.7, "disk":"/opt/matrix", "CPU":"CPU1"},
		 map[string]interface{} { "__name__":"key2", "__value__":2.8, "disk":"/opt/matrix", "CPU":"CPU2"},
		 map[string]interface{} { "__name__":"key3", "__value__":2.9, "disk":"/opt/matrix", "CPU":"CPU3"},
		 map[string]interface{} { "__name__":"key48", "__value__":2.9, "disk":"/opt/matrix", "CPU":"CPU48"} }, 1659958260000 )*/

	/*_, _, err = stat.Exec("bucketpromdb:wecise", []map[string]interface{}{
	{ "name":"key1", "value":2.7, "timestamp":"2021-07-28 11:24:17"},
	{ "name":"key2", "value":2.8, "timestamp":"2021-07-28 11:25:18"} } )
	*/

	/*stat, err := g.Prepare(`update /matrix/group set sdata = sdata - ? where fullname = ?`)
	if err != nil {
		logger.Errorf("%v", err)
	}

	_, _, err = stat.Exec( map[string]interface{}{ "/matrix/devops/alerts_status": "{ \"type\": \"match\", \"field\": \"varchar_126\", \"value\":\"alertgroup\" }",
										   "~/matrix/devops/alerts_status": "alertgroup='alertgroup'" }, "/网络部")

	//_, _, err = stat.Exec( []string{ "/matrix/devops/alerts_status", "~/matrix/devops/alerts_status" }, "/网络部")

	if err != nil {
		logger.Errorf("%v", err)
	}*/

	stat3, err := g.Prepare(`insert into /testdata1(key, msg) values (?, ?)`)
	if err != nil {
		logger.Errorf("%v", err)
	}

	_, _, err = stat3.Exec("test", "hello")

	if err != nil {
		logger.Errorf("%v", err)
	}

	time.Sleep(5 * time.Second)
	//g.Query(`SELECT prom.date("2021-07-28") FROM /test/bucketpromdb`)

	/*stat, err = g.Prepare(`insert into /matrix/ldap (fullname, id, isactive, isadmin, lft, otype, parent, passwd, rands, rgt, salt, username) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	_, _, err = stat.Exec("/admin", "8614306950096011366", true, true, 2, "usr", "/", "e9c4b39cf0b7f2e9b38c0b26b44d19ce3781a4c94491b05a4ec0f5284201f841b934480361c361879053fa2780b659609eb1", "fEEWuYMPG8", 3, "V614xVB9nQ", "admin")

	if err != nil {
		logger.Errorf("%v", err)
	}*/
	logger.Info("ok")
}