odbtest/test/unit/mql/partition/mpartition.go

package partition

import (
	"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 MPartitionTests struct {
	Test *testing.T
	g    *Gutil
}

func MPartitionTest(t *testing.T) {

	g := test.TestG()

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

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

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

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

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

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

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

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

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

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

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

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

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

	// namespace test
	//t.g.Query(` create class if not exists /test() with namespace="test" `)
	//t.g.Query(` create edge type test.connect `)
}

func (t *MPartitionTests) Class() {

	_, _, err := t.g.Query(`

	create class if not exists /test/mpartition (
		
		mv_varchar		varchar,
		v_text			text,
		v_int			int,
		v_bigint		bigint,
		v_smalldouble	double,
		v_double		double,
		v_float			float,
		v_bool			bool,
		
		indexes(mv_varchar, v_text, v_int, v_bigint, v_double, v_float, v_smalldouble, v_bool),
		keys(mv_varchar, v_text, v_int)
	) with partition=(mv_varchar,v_int), onconflict=(v_bigint incr), cache=6000
	;
	delete from /test/mpartition with version
	;
	`)

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

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

func (t *MPartitionTests) Data() {
	var err error
	_, _, err = t.g.Query(`insert into /test/mpartition (mv_varchar, v_text, v_int, v_bigint, v_float, v_double, v_smalldouble, v_bool) values ('1', 'hello word 2003 123-456-789 中华人民共和国是中国的唯一合法政府，台湾是中国一部分。  Mercury, Venus2，Earch%。Mars$Uranus CeresAndJupiterOrSaturn #Neptune Pluto_Charon"\""', 1, 1234567890123456789, 1.1, 1.1234567890123456, 1.123456, true  )`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	require.Nil(t.Test, err, fmt.Sprint(err))

	_, _, err = t.g.Query(`insert into /test/mpartition (mv_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  )`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	require.Nil(t.Test, err, fmt.Sprint(err))

	_, _, err = t.g.Query(`insert into /test/mpartition (mv_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 *MPartitionTests) Valid() {

	rtn, _, err := t.g.Query(`select * from /test/mpartition 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["mv_varchar"].(string) {

				case "1":
					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")

				}
			}
		}
	}
}

func (t *MPartitionTests) Int() {

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

	rtn, _, err = t.g.Query(`select count(*) as count from /test/mpartition where v_int = 1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		if assert.NotNil(t.Test, rtn) {
			assert.Equal(t.Test, int64(3), rtn[0]["count"].(int64), fmt.Sprintf("not find v_int = %v", "1"))
		}
	}

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

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

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

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

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

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

}

func (t *MPartitionTests) Bool() {

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

	rtn, _, err = t.g.Query(`select count(*) as count from /test/mpartition where v_bool = true`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		if assert.NotNil(t.Test, rtn) {
			assert.Equal(t.Test, int64(2), rtn[0]["count"].(int64), fmt.Sprintf("not find v_bool = %v", "true"))
		}
	}

	rtn, _, err = t.g.Query(`select count(*) as count from /test/mpartition where v_bool = false`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		if assert.NotNil(t.Test, rtn) {
			assert.Equal(t.Test, int64(1), rtn[0]["count"].(int64), fmt.Sprintf("not find v_bool = %v", "false"))
		}
	}
}

func (t *MPartitionTests) Float() {

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

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

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

	rtn, _, err = t.g.Query(`select count(*) as count from /test/mpartition where v_float = 1.1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		if assert.NotNil(t.Test, rtn) {
			assert.Equal(t.Test, int64(3), rtn[0]["count"].(int64), fmt.Sprintf("not find v_float = %v", "1.1"))
		}
	}

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

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

func (t *MPartitionTests) Double() {

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

	rtn, _, err = t.g.Query(`select * from /test/mpartition where v_double >= 1.1234567890123456`)
	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_double >= %v", "1.1234567890123456"))
		}
	}

	//??????
	rtn, _, err = t.g.Query(`select * from /test/mpartition 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 count(*) as count from /test/mpartition where v_double > 1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		if assert.NotNil(t.Test, rtn) {
			assert.Equal(t.Test, int64(3), rtn[0]["count"].(int64), fmt.Sprintf("not find v_double > %v", "1"))
		}
	}

	rtn, _, err = t.g.Query(`select count(*) as count from /test/mpartition where v_double = 1.1234567890123456`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		if assert.NotNil(t.Test, rtn) {
			assert.Equal(t.Test, int64(3), rtn[0]["count"].(int64), fmt.Sprintf("not find v_double = %v", "1.1234567890123456"))
		}
	}

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

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

func (t *MPartitionTests) Prefix() {

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

	rtn, _, err = t.g.Query(`select count(*) as count from /test/mpartition where v_text='*hell*'`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		if assert.NotNil(t.Test, rtn) {
			assert.Equal(t.Test, int64(1), rtn[0]["count"].(int64), fmt.Sprintf("not find %v", "hello"))
		}
	}

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

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

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

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

func (t *MPartitionTests) Update() {

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

	stat, err := t.g.Prepare(`insert into /test/mpartition (mv_varchar, v_int, v_float, v_text, v_bool) values(?, ?, ?, ?, ?) on conflict update v_bool=v_bool, v_float=v_float+1`)
	assert.Nil(t.Test, err)

	_, _, err = stat.Exec("test001", 1, 1.1, "hello", true)
	assert.Nil(t.Test, err)

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

	_, _, err = stat.Exec("test001", 1, 12, "hello", false)
	assert.Nil(t.Test, err)

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

	rtn, _, err = t.g.Query(`select v_bool, v_float from /test/mpartition where mv_varchar='test001' and v_int=1 and v_text='hello' refresh`)
	if assert.Nil(t.Test, err) {
		if assert.NotNil(t.Test, rtn) {
			assert.Equal(t.Test, 1, len(rtn), "no return")
			assert.Equal(t.Test, float64(2.1), rtn[0]["v_float"].(float64), "v_float != 2.1")
			assert.Equal(t.Test, true, rtn[0]["v_bool"].(bool), "v_bool != true")
		}
	}

	rtn, _, err = t.g.Query(` update / set tags=tags+'hello' where mv_varchar= '1' and v_int=1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		if assert.NotNil(t.Test, rtn) {
			count := 0
			for _, row := range rtn {
				count = count + row["success"].(int)
			}
			assert.Equal(t.Test, 1, count, fmt.Sprintf("not find %v", "中国"))
		}
	}

	//	/test/uuid
	//	/test/sequence
	//	/test/mpartition
	//	/test/idpartition

	rtn, _, err = t.g.Query(` update /test/ set tags=tags+'world' where mv_varchar= '1' and v_int=1`)
	if err != nil {
		logger.Errorf("%v", err)
	}
	if assert.Nil(t.Test, err) {
		if assert.NotNil(t.Test, rtn) {
			assert.Equal(t.Test, int(1), rtn[0]["success"].(int), fmt.Sprintf("not find %v", "中国"))
		}
	}
}

func (t *MPartitionTests) FullSearch() {

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

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

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

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

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

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