odbtest/test/unit/mql/basic/basic.go

package basic

import (
	"encoding/json"
	"fmt"
	"testing"
	"time"

	. "git.wecise.com/wecise/odbserver/odb"
	"git.wecise.com/wecise/odbserver/odb/test"
	"gitee.com/wecisecode/util/logger"
	"github.com/stretchr/testify/assert"
	"github.com/stretchr/testify/require"
)

type BasicTests struct {
	Test *testing.T
	g    *Gutil
}

func BasicTest(t *testing.T) {

	g := test.TestG()

	t.Run("InitG", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.InitG()
	})

	t.Run("Class", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Class()
	})

	t.Run("Data", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Data()
	})

	time.Sleep(time.Duration(5) * time.Second)

	t.Run("Valid", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Valid()
	})

	t.Run("Int", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Int()
	})

	t.Run("Bool", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Bool()
	})

	t.Run("FullSearch", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.FullSearch()
	})

	t.Run("Prefix", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Prefix()
	})

	t.Run("NotIn", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.NotIn()
	})

	/*t.Run("Rename", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Rename()
	})*/

	t.Run("Float", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Float()
	})

	t.Run("Double", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Double()
	})

	t.Run("Aggr", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Aggr()
	})

	t.Run("PrivateField", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.PrivateField()
	})

	t.Run("Data2", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Data2()
	})

	t.Run("Valid2", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Valid2()
	})

	t.Run("Int2", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Int2()
	})

	t.Run("Bool2", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Bool2()
	})

	t.Run("FullSearch2", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.FullSearch2()
	})

	t.Run("Prefix2", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Prefix2()
	})

	t.Run("NotIn2", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.NotIn2()
	})

	t.Run("Float2", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Float2()
	})

	t.Run("Double2", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Double2()
	})

	t.Run("Aggr2", func(t *testing.T) {
		test := &BasicTests{Test: t, g: g}
		test.Aggr2()
	})

}

func (t *BasicTests) InitG() {
	require.NotNil(t.Test, t.g)

	// namespace test
	_, _, err := t.g.Query(` create class if not exists /test() with namespace="test" `)
	if err != nil {
		fmt.Printf("%s, %v", t.g.Keyspace, err)
		logger.Errorf("%v", err)
	}

	_, _, err = t.g.Query(` create edge type if not exists test.connect `)
	if err != nil {
		fmt.Printf("%s, %v", t.g.Keyspace, err)
		logger.Errorf("%v", err)
	}
	//normal test
	//t.g.Query(` create class if not exists /test() `)

}

func (t *BasicTests) Class() {

	// clear exists data
	t.g.Query(`
	delete from /test/basic with version;
	`)
	t.g.Query(`
	delete from /test/basic2 with version;
	`)
	_, _, err := t.g.Query(`
	drop class if exists /test/basic/;
	`)
	if err != nil {
		fmt.Printf("%s, %v", t.g.Keyspace, err)
		logger.Errorf("%v", err)
	}
	_, _, err = t.g.Query(`
	drop class if exists /test/basic2/;
	`)
	if err != nil {
		fmt.Printf("%s, %v", t.g.Keyspace, err)
		logger.Errorf("%v", err)
	}

	require.Nil(t.Test, err, fmt.Sprint(err))

	_, _, err = t.g.Query(`
	
	typedef  if not exists STRSTR = varchar ;
	typedef  if not exists DOUDOU  = double ;
	`)
	if err != nil {
		fmt.Printf("%s, %v", t.g.Keyspace, err)
		logger.Errorf("%v", err)
	}

	require.Nil(t.Test, err, fmt.Sprint(err))

	_, _, err = t.g.Query(`
	
	create class if not exists /test/basic (
		
		v_varchar		STRSTR,
		v_text			text,
		v_int			int,
		v_bigint		bigint,
		v_smalldouble	double,
		v_double		DOUDOU,
		v_float			float,
		v_bool			bool,
		v_blob			blob,
		
		indexes(v_varchar, v_text, v_int, v_bigint, v_double, v_float, v_smalldouble, v_bool),
		keys(v_varchar, v_text)
	);
	
	create class if not exists /test/basic2 (
		
		v_varchar		STRSTR,
		v_text			text,
		v_int			int,
		v_bigint		bigint,
		v_smalldouble	double,
		v_double		DOUDOU,
		v_float			float,
		v_bool			bool,
		v_blob			blob,
		
		indexes(v_varchar, v_text, v_int, v_bigint, v_double, v_float, v_smalldouble, v_bool),
		keys(v_varchar, v_text)
	) with core=memory ;
	
	create class if not exists /test/basic/mxfield () with autosearch=true , version=false , key=manu, nickname = 'mxfield' ;
	
	--must have nickname for private field
	alter class /test/basic with nickname='basic' ;
	
	--taget define in tools, its string
	alter class /test/basic add column target int ;
	
	--test hello:version, hello:policy field
	create class if not exists /matrix/system/test (
	  version   int,
	  policy	int,
	  keys(name)
	)with nickname='hello';

	create class if not exists /test/basic2 (
		name	text,
		keys(name)
	) with nickname='basic2';
	
	
	`)

	if err != nil {
		fmt.Printf("%s, %v", t.g.Keyspace, err)
		logger.Errorf("%v", err)
	}

	require.Nil(t.Test, err, fmt.Sprint(err))
}

func (t *BasicTests) Data() {
	var err error

	_, _, err = t.g.Query(`insert into /matrix/system/test (name, version, policy) values ('hello', 1, 1)`)
	require.Nil(t.Test, err, fmt.Sprint(err))

	_, _, err = t.g.Query(`insert into /matrix/system/test (name, version, policy) values ('hello', 2, 2)`)
	require.Nil(t.Test, err, fmt.Sprint(err))

	_, _, err = t.g.Query(`insert into /matrix/system/test (name, version, policy) values ('hello', 3, 3)`)
	require.Nil(t.Test, err, fmt.Sprint(err))

	_, _, err = t.g.Query(`update /matrix/system/test set version = 4, policy = 4 where name = 'hello' `)
	require.Nil(t.Test, err, fmt.Sprint(err))

	_, _, err = t.g.Query(`update /matrix/system/test set version = 5, policy = 5 where name = 'hello' `)
	require.Nil(t.Test, err, fmt.Sprint(err))

	_, _, err = t.g.Query(`insert into /test/basic (v_varchar, v_text, v_int, v_bigint, v_float, v_double, v_smalldouble, v_bool, v_blob) values ('*abc*', 'hello word 2003 123-456-789 中华人民共和国是中国的唯一合法政府，台湾是中国一部分。  Mercury, Venus2，Earch%。Mars$Uranus CeresAndJupiterOrSaturn #Neptune Pluto_Charon"\""', 5, 1234567890123456789, 1.1, 1.1234567890123456, 1.123456, true, "hello"  )`)

	require.Nil(t.Test, err, fmt.Sprint(err))

	//reinsert
	_, _, err = t.g.Query(`insert into /test/basic (v_varchar, v_text, v_int, v_bigint, v_float, v_double, v_smalldouble, v_bool) values ('*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  )`)

	require.Nil(t.Test, err, fmt.Sprint(err))

	_, _, err = t.g.Query(`insert into /test/basic (name) values ('hello')`)

	//require.Nil(t.Test, err, fmt.Sprint(err))

	_, _, err = t.g.Query(`insert into /test/basic (v_varchar, v_text, v_int, v_bigint, v_float, v_double, v_smalldouble, v_bool) values ('2', 'because in both case, Cassandra guarantees that these queries performance will be proportional to the amount of data returned. In particular, if no users are born in 1981, then the second query performance will not depend of the number of user profile stored in the database (not directly at least: due to secondary index implementation consideration, this query may still depend on the number of node in the cluster, which indirectly depends on the amount of data stored. Nevertheless, the number of nodes will always be multiple number of magnitude lower than the number of user profile stored). Of course, both query may return very large result set in practice, but the amount of data returned can always be controlled by adding a LIMIT.', 1, 1234567890123456789, 1.1, 1.1234567890123456, 1.123456,false  )`)

	require.Nil(t.Test, err, fmt.Sprint(err))

	_, _, err = t.g.Query(`insert into /test/basic (v_varchar, v_text, v_int, v_bigint, v_float, v_double, v_smalldouble, v_bool) values ('3', '{
			  "id": "omdb-query-query",
			  "bid": "omdb-query-query",
			  "type": "json-update",
			  "data": {
				"message": [
				{
				  "graph": {
					"nodes": [
					{
					  "_icon": "app",
					  "class": "/matrix/entity/app",
					  "id": "app:demoapp3",
					  "name": "app:demoapp3",
					  "status": 5
					},
					{
					  "class": "/matrix/entity/pod",
					  "id": "pod:web-demo-f6dsp"
					},
					{
					  "_icon": "mysql",
					  "class": "/matrix/entity/mysql",
					  "id": "mysql:demodb",
					  "name": "mysql:demodb",
					  "status": 0
					},
					{
					  "_icon": "biz",
					  "class": "/matrix/entity/biz",
					  "id": "biz:开发测试",
					  "name": "biz:开发测试",
					  "status": 4
					},
					{
					  "_icon": "linux",
					  "class": "/matrix/entity/linux",
					  "id": "linux:node2",
					  "name": "linux:node2",
					  "status": 0
					},
					{
					  "_icon": "mysql",
					  "class": "/matrix/entity/mysql",
					  "id": "mysql:appdb",
					  "name": "mysql:appdb",
					  "status": 0
					},
					{
					  "_icon": "app",
					  "class": "/matrix/entity/app",
					  "id": "app:demoapp2",
					  "name": "app:demoapp2",
					  "status": 0
					},
					{
					  "_icon": "app",
					  "class": "/matrix/entity/app",
					  "id": "app:tomcat-app3",
					  "name": "app:tomcat-app3",
					  "status": 5
					},
					{
					  "_icon": "linux",
					  "class": "/matrix/entity/linux",
					  "id": "linux:node1",
					  "name": "linux:node1",
					  "status": 0
					},
					{
					  "_icon": "pod",
					  "class": "/matrix/entity/pod",
					  "id": "pod:tomcat-pod1",
					  "name": "pod:tomcat-pod1",
					  "status": 4
					},
					{
					  "_icon": "linux",
					  "class": "/matrix/entity/linux",
					  "id": "linux:node4",
					  "name": "linux:node4",
					  "status": 0
					},
					{
					  "_icon": "app",
					  "class": "/matrix/entity/app",
					  "id": "app:demoapp1",
					  "name": "app:demoapp1",
					  "status": 0
					},
					{
					  "_icon": "pod",
					  "class": "/matrix/entity/pod",
					  "id": "pod:mysql-demo-pod1",
					  "name": "pod:mysql-demo-pod1",
					  "status": 4
					},
					{
					  "_icon": "pod",
					  "class": "/matrix/entity/pod",
					  "id": "pod:tomcat-pod2",
					  "name": "pod:tomcat-pod2",
					  "status": 4
					},
					{
					  "class": "/matrix/entity/pod",
					  "id": "pod:tomcat-pod3"
					},
					{
					  "_icon": "app",
					  "class": "/matrix/entity/app",
					  "id": "app:tomcat-app1",
					  "name": "app:tomcat-app1",
					  "status": 0
					},
					{
					  "_icon": "app",
					  "class": "/matrix/entity/app",
					  "id": "app:tomcat-app2",
					  "name": "app:tomcat-app2",
					  "status": 0
					},
					{
					  "class": "/matrix/entity/pod",
					  "id": "pod:web-demo-j6qxj"
					},
					{
					  "class": "/matrix/entity/pod",
					  "id": "pod:web-demo-9rfxj"
					},
					{
					  "_icon": "biz",
					  "class": "/matrix/entity/biz",
					  "id": "biz:数字国网",
					  "name": "biz:数字国网",
					  "status": 4
					}
					],
					"edges": [
					{
					  "attrs": {},
					  "class": "connect",
					  "id": "app:demoapp1-mysql:demodb",
					  "source": "app:demoapp1",
					  "target": "mysql:demodb"
					},
					{
					  "attrs": {},
					  "class": "contain",
					  "id": "biz:开发测试-app:demoapp2",
					  "source": "biz:开发测试",
					  "target": "app:demoapp2"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "mysql:appdb-linux:node4",
					  "source": "mysql:appdb",
					  "target": "linux:node4"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "mysql:demodb-pod:mysql",
					  "source": "mysql:demodb",
					  "target": "pod:mysql"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "app:tomcat-app2",
					  "source": "app:tomcat",
					  "target": "app2"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "pod:tomcat-pod2",
					  "source": "pod:tomcat",
					  "target": "pod2"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "app:demoapp1-pod:web",
					  "source": "app:demoapp1",
					  "target": "pod:web"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "pod:mysql-demo",
					  "source": "pod:mysql",
					  "target": "demo"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "app:demoapp2-pod:web",
					  "source": "app:demoapp2",
					  "target": "pod:web"
					},
					{
					  "attrs": {},
					  "class": "connect",
					  "id": "app:demoapp3-mysql:demodb",
					  "source": "app:demoapp3",
					  "target": "mysql:demodb"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "app:demoapp3-pod:web",
					  "source": "app:demoapp3",
					  "target": "pod:web"
					},
					{
					  "attrs": {
						"floatp": 3.4,
						"intp": 1
					  },
					  "class": "contain",
					  "id": "biz:数字国网-app:tomcat",
					  "source": "biz:数字国网",
					  "target": "app:tomcat"
					},
					{
					  "attrs": {},
					  "class": "connect",
					  "id": "app:tomcat-app3",
					  "source": "app:tomcat",
					  "target": "app3"
					},
					{
					  "attrs": {},
					  "class": "contain",
					  "id": "biz:开发测试-app:demoapp3",
					  "source": "biz:开发测试",
					  "target": "app:demoapp3"
					},
					{
					  "attrs": {},
					  "class": "contain",
					  "id": "biz:开发测试-app:demoapp1",
					  "source": "biz:开发测试",
					  "target": "app:demoapp1"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "pod:tomcat-pod1",
					  "source": "pod:tomcat",
					  "target": "pod1"
					},
					{
					  "attrs": {},
					  "class": "connect",
					  "id": "app:tomcat-app1",
					  "source": "app:tomcat",
					  "target": "app1"
					},
					{
					  "attrs": {},
					  "class": "connect",
					  "id": "app:demoapp2-mysql:demodb",
					  "source": "app:demoapp2",
					  "target": "mysql:demodb"
					}
					],
					"paths": null,
					"diff": null,
					"pathtags": null
				  }
				}
				],
				"meta": {
				"type": "graph"
				},
				"status": "ok"
			  }
			}', 1, 1234567890123456789, 1.1, 1.1234567890123456, 1.123456, true  )`)

	if err != nil {
		logger.Errorf("%v", err)
	}
	require.Nil(t.Test, err, fmt.Sprint(err))

}

func (t *BasicTests) Data2() {
	var err error

	_, _, err = t.g.Query(`insert into /test/basic2 (v_varchar, v_text, v_int, v_bigint, v_float, v_double, v_smalldouble, v_bool, v_blob) values ('*abc*', 'hello word 2003 123-456-789 中华人民共和国是中国的唯一合法政府，台湾是中国一部分。  Mercury, Venus2，Earch%。Mars$Uranus CeresAndJupiterOrSaturn #Neptune Pluto_Charon"\""', 5, 1234567890123456789, 1.1, 1.1234567890123456, 1.123456, true, "hello"  )`)

	require.Nil(t.Test, err, fmt.Sprint(err))

	//reinsert
	_, _, err = t.g.Query(`insert into /test/basic2 (v_varchar, v_text, v_int, v_bigint, v_float, v_double, v_smalldouble, v_bool) values ('*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  )`)

	require.Nil(t.Test, err, fmt.Sprint(err))

	//_, _, err = t.g.Query(`insert into /test/basic2 (name) values ('hello')`)

	require.Nil(t.Test, err, fmt.Sprint(err))

	_, _, err = t.g.Query(`insert into /test/basic2 (v_varchar, v_text, v_int, v_bigint, v_float, v_double, v_smalldouble, v_bool) values ('2', 'because in both case, Cassandra guarantees that these queries performance will be proportional to the amount of data returned. In particular, if no users are born in 1981, then the second query performance will not depend of the number of user profile stored in the database (not directly at least: due to secondary index implementation consideration, this query may still depend on the number of node in the cluster, which indirectly depends on the amount of data stored. Nevertheless, the number of nodes will always be multiple number of magnitude lower than the number of user profile stored). Of course, both query may return very large result set in practice, but the amount of data returned can always be controlled by adding a LIMIT.', 1, 1234567890123456789, 1.1, 1.1234567890123456, 1.123456,false  )`)

	require.Nil(t.Test, err, fmt.Sprint(err))

	_, _, err = t.g.Query(`insert into /test/basic2 (v_varchar, v_text, v_int, v_bigint, v_float, v_double, v_smalldouble, v_bool) values ('3', '{
			  "id": "omdb-query-query",
			  "bid": "omdb-query-query",
			  "type": "json-update",
			  "data": {
				"message": [
				{
				  "graph": {
					"nodes": [
					{
					  "_icon": "app",
					  "class": "/matrix/entity/app",
					  "id": "app:demoapp3",
					  "name": "app:demoapp3",
					  "status": 5
					},
					{
					  "class": "/matrix/entity/pod",
					  "id": "pod:web-demo-f6dsp"
					},
					{
					  "_icon": "mysql",
					  "class": "/matrix/entity/mysql",
					  "id": "mysql:demodb",
					  "name": "mysql:demodb",
					  "status": 0
					},
					{
					  "_icon": "biz",
					  "class": "/matrix/entity/biz",
					  "id": "biz:开发测试",
					  "name": "biz:开发测试",
					  "status": 4
					},
					{
					  "_icon": "linux",
					  "class": "/matrix/entity/linux",
					  "id": "linux:node2",
					  "name": "linux:node2",
					  "status": 0
					},
					{
					  "_icon": "mysql",
					  "class": "/matrix/entity/mysql",
					  "id": "mysql:appdb",
					  "name": "mysql:appdb",
					  "status": 0
					},
					{
					  "_icon": "app",
					  "class": "/matrix/entity/app",
					  "id": "app:demoapp2",
					  "name": "app:demoapp2",
					  "status": 0
					},
					{
					  "_icon": "app",
					  "class": "/matrix/entity/app",
					  "id": "app:tomcat-app3",
					  "name": "app:tomcat-app3",
					  "status": 5
					},
					{
					  "_icon": "linux",
					  "class": "/matrix/entity/linux",
					  "id": "linux:node1",
					  "name": "linux:node1",
					  "status": 0
					},
					{
					  "_icon": "pod",
					  "class": "/matrix/entity/pod",
					  "id": "pod:tomcat-pod1",
					  "name": "pod:tomcat-pod1",
					  "status": 4
					},
					{
					  "_icon": "linux",
					  "class": "/matrix/entity/linux",
					  "id": "linux:node4",
					  "name": "linux:node4",
					  "status": 0
					},
					{
					  "_icon": "app",
					  "class": "/matrix/entity/app",
					  "id": "app:demoapp1",
					  "name": "app:demoapp1",
					  "status": 0
					},
					{
					  "_icon": "pod",
					  "class": "/matrix/entity/pod",
					  "id": "pod:mysql-demo-pod1",
					  "name": "pod:mysql-demo-pod1",
					  "status": 4
					},
					{
					  "_icon": "pod",
					  "class": "/matrix/entity/pod",
					  "id": "pod:tomcat-pod2",
					  "name": "pod:tomcat-pod2",
					  "status": 4
					},
					{
					  "class": "/matrix/entity/pod",
					  "id": "pod:tomcat-pod3"
					},
					{
					  "_icon": "app",
					  "class": "/matrix/entity/app",
					  "id": "app:tomcat-app1",
					  "name": "app:tomcat-app1",
					  "status": 0
					},
					{
					  "_icon": "app",
					  "class": "/matrix/entity/app",
					  "id": "app:tomcat-app2",
					  "name": "app:tomcat-app2",
					  "status": 0
					},
					{
					  "class": "/matrix/entity/pod",
					  "id": "pod:web-demo-j6qxj"
					},
					{
					  "class": "/matrix/entity/pod",
					  "id": "pod:web-demo-9rfxj"
					},
					{
					  "_icon": "biz",
					  "class": "/matrix/entity/biz",
					  "id": "biz:数字国网",
					  "name": "biz:数字国网",
					  "status": 4
					}
					],
					"edges": [
					{
					  "attrs": {},
					  "class": "connect",
					  "id": "app:demoapp1-mysql:demodb",
					  "source": "app:demoapp1",
					  "target": "mysql:demodb"
					},
					{
					  "attrs": {},
					  "class": "contain",
					  "id": "biz:开发测试-app:demoapp2",
					  "source": "biz:开发测试",
					  "target": "app:demoapp2"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "mysql:appdb-linux:node4",
					  "source": "mysql:appdb",
					  "target": "linux:node4"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "mysql:demodb-pod:mysql",
					  "source": "mysql:demodb",
					  "target": "pod:mysql"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "app:tomcat-app2",
					  "source": "app:tomcat",
					  "target": "app2"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "pod:tomcat-pod2",
					  "source": "pod:tomcat",
					  "target": "pod2"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "app:demoapp1-pod:web",
					  "source": "app:demoapp1",
					  "target": "pod:web"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "pod:mysql-demo",
					  "source": "pod:mysql",
					  "target": "demo"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "app:demoapp2-pod:web",
					  "source": "app:demoapp2",
					  "target": "pod:web"
					},
					{
					  "attrs": {},
					  "class": "connect",
					  "id": "app:demoapp3-mysql:demodb",
					  "source": "app:demoapp3",
					  "target": "mysql:demodb"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "app:demoapp3-pod:web",
					  "source": "app:demoapp3",
					  "target": "pod:web"
					},
					{
					  "attrs": {
						"floatp": 3.4,
						"intp": 1
					  },
					  "class": "contain",
					  "id": "biz:数字国网-app:tomcat",
					  "source": "biz:数字国网",
					  "target": "app:tomcat"
					},
					{
					  "attrs": {},
					  "class": "connect",
					  "id": "app:tomcat-app3",
					  "source": "app:tomcat",
					  "target": "app3"
					},
					{
					  "attrs": {},
					  "class": "contain",
					  "id": "biz:开发测试-app:demoapp3",
					  "source": "biz:开发测试",
					  "target": "app:demoapp3"
					},
					{
					  "attrs": {},
					  "class": "contain",
					  "id": "biz:开发测试-app:demoapp1",
					  "source": "biz:开发测试",
					  "target": "app:demoapp1"
					},
					{
					  "attrs": {},
					  "class": "runon",
					  "id": "pod:tomcat-pod1",
					  "source": "pod:tomcat",
					  "target": "pod1"
					},
					{
					  "attrs": {},
					  "class": "connect",
					  "id": "app:tomcat-app1",
					  "source": "app:tomcat",
					  "target": "app1"
					},
					{
					  "attrs": {},
					  "class": "connect",
					  "id": "app:demoapp2-mysql:demodb",
					  "source": "app:demoapp2",
					  "target": "mysql:demodb"
					}
					],
					"paths": null,
					"diff": null,
					"pathtags": null
				  }
				}
				],
				"meta": {
				"type": "graph"
				},
				"status": "ok"
			  }
			}', 1, 1234567890123456789, 1.1, 1.1234567890123456, 1.123456, true  )`)

	if err != nil {
		logger.Errorf("%v", err)
	}
	require.Nil(t.Test, err, fmt.Sprint(err))

}

func (t *BasicTests) Valid() {

	rtn, _, err := t.g.Query(`select * from /test/basic refresh`)

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

	if assert.Nil(t.Test, err) {
		if assert.NotNil(t.Test, rtn) {
			assert.Equal(t.Test, 3, len(rtn), "they should be equal")
			for _, row := range rtn {
				switch row["v_varchar"].(string) {

				case "*abc*":
					assert.Equal(t.Test, `hello word 2003 123-456-789 中华人民共和国是中国的唯一合法政府，台湾是中国一部分。  Mercury, Venus2，Earch%。Mars$Uranus CeresAndJupiterOrSaturn #Neptune Pluto_Charon"\""`, row["v_text"].(string), "they should be equal")

				}
			}
		}
	}

	rtn, _, err = t.g.Query(` select * from /test/basic where v_varchar=='*abc*' `)

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

	if assert.Nil(t.Test, err) {
		if assert.NotNil(t.Test, rtn) {
			assert.Equal(t.Test, 1, len(rtn), "they should be equal")
		}
	}

	rtn, _, err = t.g.Query(`select * from / where v_varchar=='*abc*' `)

	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		count := 0
		for _, m := range rtn {
			v := m["class"]
			if c, ok := v.(string); ok && c == "/test/basic" {
				count++
			}
		}
		assert.Equal(t.Test, 1, count, "they should be equal")
	}

	rtn, _, err = t.g.Query(`select * from /test/ where v_varchar=='*abc*' `)

	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		count := 0
		for _, m := range rtn {
			v := m["class"]
			if c, ok := v.(string); ok && c == "/test/basic" {
				count++
			}
		}
		assert.Equal(t.Test, 1, count, "they should be equal")
	}
}

func (t *BasicTests) Valid2() {

	rtn, _, err := t.g.Query(`select * from /test/basic2`)

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

	if false {
		bs, _ := json.MarshalIndent(rtn, "", "  ")
		fmt.Println("/test/basic2 data:\n", string(bs))
	}

	if assert.Nil(t.Test, err) {
		if assert.NotNil(t.Test, rtn) {
			assert.Equal(t.Test, 3, len(rtn), "they should be equal")
			for _, row := range rtn {
				switch row["v_varchar"].(string) {

				case "*abc*":
					assert.Equal(t.Test, `hello word 2003 123-456-789 中华人民共和国是中国的唯一合法政府，台湾是中国一部分。  Mercury, Venus2，Earch%。Mars$Uranus CeresAndJupiterOrSaturn #Neptune Pluto_Charon"\""`, row["v_text"].(string), "they should be equal")

				}
			}
		}
	}

	rtn, _, err = t.g.Query(` select * from /test/basic2 where v_varchar=='*abc*' `)

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

	if assert.Nil(t.Test, err) {
		if assert.NotNil(t.Test, rtn) {
			assert.Equal(t.Test, 1, len(rtn), "they should be equal")
		}
	}

	// 内存库延迟持久化写入 1s + cassandra索引延迟 1s + cassandra分布式数据同步 1s
	time.Sleep(3 * time.Second)

	rtn, _, err = t.g.Query(`select * from / where v_varchar=='*abc*' `)

	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		count := 0
		for _, m := range rtn {
			v := m["class"]
			if c, ok := v.(string); ok && (c == "/test/basic" || c == "/test/basic2") {
				count++
			}
		}
		assert.Equal(t.Test, 2, count, "they should be equal")
	}

	rtn, _, err = t.g.Query(`select * from /test/ where v_varchar=='*abc*' `)

	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		count := 0
		for _, m := range rtn {
			v := m["class"]
			if c, ok := v.(string); ok && (c == "/test/basic" || c == "/test/basic2") {
				count++
			}
		}
		assert.Equal(t.Test, 2, count, "they should be equal")
	}
}

func (t *BasicTests) Int() {

	var err error
	var rtn []map[string]interface{}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_int = 1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_int = %v", "1"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_int > 0`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_int > %v", "0"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_int < 2`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_int < %v", "2"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_int >= 1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_int >= %v", "1"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_int <= 1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_int <= %v", "1"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_int >= 1.1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 0, len(rtn), fmt.Sprintf("not find v_int >= %v", "1.1"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_int > 1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 0, len(rtn), fmt.Sprintf("not find v_int > %v", "1"))
	}
}

func (t *BasicTests) Int2() {

	var err error
	var rtn []map[string]interface{}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_int = 1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_int = %v", "1"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_int > 0`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_int > %v", "0"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_int < 2`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_int < %v", "2"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_int >= 1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_int >= %v", "1"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_int <= 1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_int <= %v", "1"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_int >= 1.1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 0, len(rtn), fmt.Sprintf("not find v_int >= %v", "1.1"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_int > 1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 0, len(rtn), fmt.Sprintf("not find v_int > %v", "1"))
	}
}

func (t *BasicTests) Bool() {

	var err error
	var rtn []map[string]interface{}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_bool = true`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 2, len(rtn), fmt.Sprintf("not find v_bool = %v", "true"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_bool = false`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find v_bool = %v", "false"))
	}
}

func (t *BasicTests) Bool2() {

	var err error
	var rtn []map[string]interface{}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_bool = true`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 2, len(rtn), fmt.Sprintf("not find v_bool = %v", "true"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_bool = false`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find v_bool = %v", "false"))
	}
}

func (t *BasicTests) Float() {

	var err error
	var rtn []map[string]interface{}
	var allfalse = false

	rtn, _, err = t.g.Query(`select * from /test/basic where v_float >= 1.1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		allfalse = allfalse || assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_float >= %v", "1.1"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_float > 1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		allfalse = allfalse || assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_float > %v", "1"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_float = 1.1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		allfalse = allfalse || assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_float = %v", "1.1"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_float < 2`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		allfalse = allfalse || assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_float < %v", "2"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_float <= 1.1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		allfalse = allfalse || assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_float <= %v", "1.1"))
	}

	if allfalse == false {
		assert.Nil(t.Test, "浮点数怎么判断都不对，重启cassandra试试")
	}
}

func (t *BasicTests) Float2() {

	var err error
	var rtn []map[string]interface{}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_float >= 1.1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_float >= %v", "1.1"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_float > 1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_float > %v", "1"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_float = 1.1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_float = %v", "1.1"))

	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_float < 2`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_float < %v", "2"))

	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_float <= 1.1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_float <= %v", "1.1"))
	}
}

func (t *BasicTests) Double() {

	var err error
	var rtn []map[string]interface{}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_double >= 1.1234567890123456`)
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_double >= %v", "1.1234567890123456"))
	}

	//??????
	rtn, _, err = t.g.Query(`select * from /test/basic where v_smalldouble >= 1.123456`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		if assert.NotNil(t.Test, rtn) {
			assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find , v_smalldouble >= %v", "1.123456"))
		}
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_double > 1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_double > %v", "1"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_double = 1.1234567890123456`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.NotEqual(t.Test, int64(3), len(rtn), fmt.Sprintf("not find v_double = %v", "1.1234567890123456"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_double < 2`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_double < %v", "2"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_double <= 1.1234567890123456`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_double <= %v", "1.1234567890123456"))
	}
}

func (t *BasicTests) Double2() {

	var err error
	var rtn []map[string]interface{}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_double >= 1.1234567890123456`)
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_double >= %v", "1.1234567890123456"))
	}

	//??????
	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_smalldouble >= 1.123456`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		if assert.NotNil(t.Test, rtn) {
			assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find , v_smalldouble >= %v", "1.123456"))
		}
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_double > 1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_double > %v", "1"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_double = 1.1234567890123456`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.NotEqual(t.Test, int64(3), len(rtn), fmt.Sprintf("not find v_double = %v", "1.1234567890123456"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_double < 2`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_double < %v", "2"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_double <= 1.1234567890123456`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("not find v_double <= %v", "1.1234567890123456"))
	}
}

func (t *BasicTests) NotIn() {

	var err error
	var rtn []map[string]interface{}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_varchar not in('2', '3')`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "hello"))
	}
}

func (t *BasicTests) NotIn2() {

	var err error
	var rtn []map[string]interface{}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_varchar not in('2', '3')`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "hello"))
	}
}

func (t *BasicTests) Prefix() {

	var err error
	var rtn []map[string]interface{}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_text=^'hell'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "hello"))
	}

	rtn, _, err = t.g.Query(`select *from /test/basic where v_text='*20*'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "2003"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_text='*123-456*'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "123-456-789"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_text='*中*'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "中国"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_text='*magni*'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "magnitude"))
	}
}

func (t *BasicTests) Prefix2() {

	var err error
	var rtn []map[string]interface{}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_text=^'hell'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "hello"))
	}

	rtn, _, err = t.g.Query(`select *from /test/basic2 where v_text='*20*'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "2003"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_text='*123-456*'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "123-456-789"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_text='*中*'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "中国"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_text='*magni*'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "magnitude"))
	}
}

func (t *BasicTests) FullSearch() {

	var err error
	var rtn []map[string]interface{}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_text='hello'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "hello"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_text='2003'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "2003"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_text='123-456-789'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "123-456-789"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_text='中国'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "中国"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic where v_text='magnitude'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "magnitude"))
	}
}

func (t *BasicTests) FullSearch2() {

	var err error
	var rtn []map[string]interface{}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_text='hello'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "hello"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_text='2003'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "2003"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_text='123-456-789'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "123-456-789"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_text='中国'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "中国"))
	}

	rtn, _, err = t.g.Query(`select * from /test/basic2 where v_text='magnitude'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 1, len(rtn), fmt.Sprintf("not find %v", "magnitude"))
	}
}

func (t *BasicTests) Aggr() {

	var err error
	var rtn []map[string]interface{}

	_, _, err = t.g.Query(`insert into /test/basic (v_varchar, v_text, v_int, v_bigint, v_float, v_double, v_smalldouble, v_bool) values ('2', 'hhhhhh', 1, 1534567890123456789, 1.3, 2.1234567890123456, 1.223456, true  )`)

	rtn, _, err = t.g.Query(`select count(*) from /test/basic group by v_varchar`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("count group by %v", "varchar"))
	}

	rtn, _, err = t.g.Query(`select sum(v_float), min(v_int), max(v_double) , avg(v_int) as avgint, v_varchar from /test/basic group by v_varchar`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("agr group by %v", "varchar"))
	}
}

func (t *BasicTests) Aggr2() {

	var err error
	var rtn []map[string]interface{}

	_, _, err = t.g.Query(`insert into /test/basic2 (v_varchar, v_text, v_int, v_bigint, v_float, v_double, v_smalldouble, v_bool) values ('2', 'hhhhhh', 1, 1534567890123456789, 1.3, 2.1234567890123456, 1.223456, true  )`)

	rtn, _, err = t.g.Query(`select count(*) from /test/basic2 group by v_varchar`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("count group by %v", "varchar"))
	}

	rtn, _, err = t.g.Query(`select sum(v_float), min(v_int), max(v_double) , avg(v_int) as avgint, v_varchar from /test/basic2 group by v_varchar`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		assert.Equal(t.Test, 3, len(rtn), fmt.Sprintf("agr group by %v", "varchar"))
	}
}

func (t *BasicTests) PrivateField() {

	//rtn, _, err := t.g.Query(`select class from /system/field where name='basic:target'`)
	_, _, err := t.g.Query(`select class from /system/field where namespace='test' and name='basic:target'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		//assert.Equal(t.Test, 2, len(rtn[0]["class"].([]int)), fmt.Sprintf("private field should 2"))
	}
}