SwordFish_Interface_Service/sword_base/elastic/elasticSim_test.go

package elastic

import (
	"testing"
)

func _GetES() *Elastic {
	es := &Elastic{
		S_esurl: "http://192.168.3.18:9800",
		I_size:  5,
	}
	es.InitElasticSize()
	return es
}

func Test_bulksave(t *testing.T) {
	es := _GetES()
	defer es.Close()
	es.BulkSave("qyfw", "qyfw", &[]map[string]interface{}{
		map[string]interface{}{
			"EntName": "Test1",
			"RegNo":   "1234568",
			"_id":     5,
		},
		map[string]interface{}{
			"EntName": "Test2",
			"RegNo":   "11117",
			"_id":     9,
		},
	}, true)
}