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) }