提交 b55f7c46 编写于 作者: 武汉红喜's avatar 武汉红喜

remove some tests code

上级 2ce70ab0
package org.hongxi.whatsmars.elasticsearch;
import com.alibaba.fastjson.JSON;
import org.elasticsearch.action.DocWriteResponse;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.TransportAddress;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentFactory;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.aggregations.Aggregation;
import org.elasticsearch.search.aggregations.AggregationBuilders;
import org.elasticsearch.search.aggregations.bucket.terms.StringTerms;
import org.elasticsearch.search.aggregations.bucket.terms.TermsAggregationBuilder;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.io.IOException;
import java.net.InetAddress;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* Created by shenhongxi on 2018/11/19.
*/
public class TransportClientTest {
private static final String INDEX = "whatsmars";
private TransportClient client;
@Before
public void getClient() throws Exception{
client = new PreBuiltTransportClient(Settings.EMPTY)
.addTransportAddress(new TransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
}
@Test
public void index() throws IOException {
XContentBuilder builder = XContentFactory.jsonBuilder()
.startObject()
.field("user", "javahongxi")
.field("postDate", new Date())
.field("message", "Elasticsearch Study")
.endObject();
IndexResponse response = client.prepareIndex(INDEX, INDEX, "1")
.setSource(builder)
.get();
assert DocWriteResponse.Result.CREATED == response.getResult();
}
@Test
public void index2() {
Map<String, Object> json = new HashMap<>();
json.put("user","hongxi");
json.put("postDate","2013-01-30");
json.put("message","Elastic Stack Study");
IndexResponse response = client.prepareIndex(INDEX, INDEX, "2")
.setSource(json)
.get();
assert DocWriteResponse.Result.CREATED == response.getResult();
}
@Test
public void delete() {
DeleteResponse response = client.prepareDelete(INDEX, INDEX, "1").get();
assert DocWriteResponse.Result.DELETED == response.getResult();
}
@Test
public void update() throws Exception {
UpdateRequest request = new UpdateRequest(INDEX, INDEX, "1");
XContentBuilder builder = XContentFactory.jsonBuilder()
.startObject()
.field("postDate", new Date())
.field("message", "Elastic Stack Study")
.endObject();
request.doc(builder);
UpdateResponse response = client.update(request).get();
assert DocWriteResponse.Result.UPDATED == response.getResult();
}
@Test
public void get() {
GetResponse response = client.prepareGet(INDEX, INDEX, "1").get();
System.out.println(response.getSource());
System.out.println(response.getSourceAsMap());
System.out.println(response.getSourceAsString());
assert response.getSource() != null;
}
@Test
public void search() {
SearchRequestBuilder requestBuilder = client.prepareSearch(INDEX)
.setQuery(QueryBuilders.queryStringQuery("study"));
System.out.println(requestBuilder);
SearchResponse response = requestBuilder.get();
System.out.println(JSON.toJSONString(response));
assert response.getHits().getTotalHits() > 0;
}
// 利用groupBy获取distinct值
@Test
public void distinct() {
TermsAggregationBuilder termsAggregationBuilder = AggregationBuilders.terms("aggs").field("lastName");
SearchResponse response = client.prepareSearch("customer")
.addAggregation(termsAggregationBuilder)
.get();
Aggregation aggregation = response.getAggregations().asMap().get("aggs");
StringTerms stringTerms = (StringTerms) aggregation;
List<String> lastNames = stringTerms.getBuckets()
.stream()
.map(StringTerms.Bucket::getKeyAsString)
.collect(Collectors.toList());
System.out.println(lastNames);
}
@After
public void close() {
client.close();
}
}
#cluster.name: mars
client.transport.sniff: true
\ No newline at end of file
appender.console.type = Console
appender.console.name = console
appender.console.layout.type = PatternLayout
appender.console.layout.pattern = [%d{ISO8601}][%-5p][%-25c{1.}] %marker%m%n
rootLogger.level = ${sys:tests.es.logger.level:-info}
rootLogger.appenderRef.console.ref = console
package org.hongxi.whatsmars.boot.sample.logback;
import org.junit.Rule;
import org.junit.Test;
import org.springframework.boot.test.rule.OutputCapture;
import static org.hamcrest.Matchers.containsString;
import static org.hamcrest.Matchers.not;
public class SampleLogbackApplicationTests {
@Rule
public OutputCapture outputCapture = new OutputCapture();
@Test
public void testLoadedCustomLogbackConfig() throws Exception {
SampleLogbackApplication.main(new String[0]);
this.outputCapture.expect(containsString("Sample Debug Message"));
this.outputCapture.expect(not(containsString("Sample Trace Message")));
}
@Test
public void testProfile() throws Exception {
SampleLogbackApplication
.main(new String[] { "--spring.profiles.active=staging" });
this.outputCapture.expect(containsString("Sample Debug Message"));
this.outputCapture.expect(containsString("Sample Trace Message"));
}
}
\ No newline at end of file
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册