golib/infra/svc/default_test.go

package svc

import (
	"testing"

	"golib/features/mo"
	"golib/infra/ii"
	"golib/log/logs"
)

// func TestFind(t *testing.T) {
// 	Find("test.user", "")
// }

func init() {
	itemList, err := ii.ReadDir("_test")
	if err != nil {
		panic(err)
	}
	client, err := mo.NewClient("mongodb://root:abcd1234@192.168.0.224:27017/?authSource=admin&readPreference=primary&appname=goland&directConnection=true&ssl=false")
	if err != nil {
		panic(err)
	}
	InitDefault(client, ii.NewItems(itemList), logs.Console)
}

func TestInsertMany(t *testing.T) {
	row := mo.A{
		mo.M{"name": "aaa", "age": 20, "gender": "Male", "phone": "13258006534"},
		mo.M{"name": "bbb", "age": 22, "gender": "Female", "phone": "17615452069"},
	}
	ids, err := InsertMany("test.user", row)
	if err != nil {
		t.Error(err)
		return
	}
	for _, id := range ids {
		t.Log(id)
	}
}

func TestInsertManyTask(t *testing.T) {
	row := mo.A{
		mo.M{"title": "task1", "content": "example content11", "name": "aaa"},
		mo.M{"title": "task2", "content": "example content22", "name": "aaa"},
		mo.M{"title": "task3", "content": "example content33", "name": "bbb"},
		mo.M{"title": "task4", "content": "example content44", "name": "ccc"},
	}
	ids, err := InsertMany("test.task", row)
	if err != nil {
		t.Error(err)
		return
	}
	for _, id := range ids {
		t.Log(id)
	}
}

func TestFind(t *testing.T) {
	docs, err := Find("test.user", mo.D{})
	if err != nil {
		t.Error(err)
		return
	}
	for i, doc := range docs {
		t.Log(i, doc)
	}
}

func TestFindOne(t *testing.T) {
	docs, err := FindOne("test.user", mo.D{})
	if err != nil {
		t.Error(err)
		return
	}
	for i, doc := range docs {
		t.Log(i, doc)
	}
}

func TestUpdateOne(t *testing.T) {
	filter := mo.Matcher{}
	filter.Eq("name", "aaa")
	err := UpdateOne("test.user", filter.Done(), mo.M{"name": "ddd"})
	if err != nil {
		t.Error(err)
		return
	}
}