common_utils/mongodb/mgo_test.go

package mongodb

import (
	"fmt"
	"testing"
	"time"
)

var mgo *MongodbSim

func init() {
	mgo = &MongodbSim{
		MongodbAddr: "127.0.0.1:27017",
		DbName:      "wcc",
		Size:        10,
		UserName:    "",
		Password:    "",
	}
	mgo.InitPool()
}

func TestMongodbSim_DropColl(t *testing.T) {

	res := mgo.DropColl("wcc", "wcc_sbyj")
	if res {
		fmt.Println("删除成功")
	} else {
		fmt.Println("删除失败")
	}
}

func TestMongodbSim_Save(t *testing.T) {
	data := map[string]interface{}{
		"name":    "wcc_wcc",
		"title":   "测试",
		"content": "这是一个测试内容",
	}

	res := mgo.Save("wcc_wcc", data)
	fmt.Println(res)
}

func TestMongodbSim_InsertOrUpdate(t *testing.T) {
	data := map[string]interface{}{
		"_id":        StringTOBsonId("5f289ea352c1d9fbf84e1f1b"),
		"num":        12,
		"createtime": time.Now().Unix(),
	}
	err := mgo.InsertOrUpdate("wcc", "bidding_hot", data)
	fmt.Println(err)
}