jypkg/compatible/compatible_test.go

package compatible

import (
	"log"
	"testing"
	"time"

	. "app.yhyue.com/moapp/jybase/mongodb"
	. "app.yhyue.com/moapp/jybase/mysql"
	. "app.yhyue.com/moapp/jypkg/middleground"
)

var (
	mgo          *MongodbSim
	baseService  *Mysql
	mainMysql    *Mysql
	middleground *Middleground
)

func init() {
	mgo = &MongodbSim{
		MongodbAddr: "192.168.3.206:27080",
		Size:        2,
		DbName:      "qfw",
	}
	mgo.InitPool()
	mainMysql = &Mysql{
		Address:      "192.168.3.11:3366",
		UserName:     "root",
		PassWord:     "Topnet123",
		DBName:       "jianyu",
		MaxOpenConns: 2,
		MaxIdleConns: 2,
	}
	mainMysql.Init()
	baseService = &Mysql{
		Address:      "192.168.3.217:4000",
		UserName:     "root",
		PassWord:     "=PDT49#80Z!RVv52_z",
		DBName:       "base_service",
		MaxOpenConns: 2,
		MaxIdleConns: 2,
	}
	baseService.Init()
	middleground = NewMiddleground([]string{"192.168.3.149:2379"}).RegUserCenter("usercenter.rpc")
}
func TestSelect(t *testing.T) {
	c := NewCompatible(mgo, baseService, mainMysql, middleground)
	log.Println(c.Select("60067", `{"o_vipjy.a_items":1,"o_member_jy.a_items":1}`))
}
func TestUpdate(t *testing.T) {
	c := NewCompatible(mgo, baseService, mainMysql, middleground)
	saveData := map[string]interface{}{}
	saveData["o_member_jy.a_items.0.s_item"] = "未分类"
	saveData["o_member_jy.a_items.0.a_key.0.key"] = []string{"软件"}
	saveData["o_member_jy.a_items.0.a_key.0.appendkey"] = []string{}
	saveData["o_member_jy.a_items.0.a_key.0.notkey"] = []string{}
	saveData["o_member_jy.a_items.0.a_key.0.matchway"] = 1
	saveData["o_member_jy.a_items.0.a_key.0.updatetime"] = time.Now().Unix()
	log.Println(c.Update("60067", map[string]interface{}{
		"$set": saveData,
	}))
}