diff --git a/whatsmars-elasticsearch/src/test/java/org/hongxi/whatsmars/elasticsearch/TransportClientTest.java b/whatsmars-elasticsearch/src/test/java/org/hongxi/whatsmars/elasticsearch/TransportClientTest.java deleted file mode 100644 index 91bd55335a2af7a7e9bb28cfeb89d87cae103fc4..0000000000000000000000000000000000000000 --- a/whatsmars-elasticsearch/src/test/java/org/hongxi/whatsmars/elasticsearch/TransportClientTest.java +++ /dev/null @@ -1,136 +0,0 @@ -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 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 lastNames = stringTerms.getBuckets() - .stream() - .map(StringTerms.Bucket::getKeyAsString) - .collect(Collectors.toList()); - System.out.println(lastNames); - } - - @After - public void close() { - client.close(); - } -} diff --git a/whatsmars-elasticsearch/src/test/resources/elasticsearch.yml b/whatsmars-elasticsearch/src/test/resources/elasticsearch.yml deleted file mode 100644 index 3346dd519019b0e33aafb2009f0bd64af766f94a..0000000000000000000000000000000000000000 --- a/whatsmars-elasticsearch/src/test/resources/elasticsearch.yml +++ /dev/null @@ -1,2 +0,0 @@ -#cluster.name: mars -client.transport.sniff: true \ No newline at end of file diff --git a/whatsmars-elasticsearch/src/test/resources/log4j2-test.properties b/whatsmars-elasticsearch/src/test/resources/log4j2-test.properties deleted file mode 100644 index 828555ed52e6f3084e6f3d8bd46513e9816093e9..0000000000000000000000000000000000000000 --- a/whatsmars-elasticsearch/src/test/resources/log4j2-test.properties +++ /dev/null @@ -1,7 +0,0 @@ -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 diff --git a/whatsmars-spring-boot-samples/whatsmars-boot-sample-logback/src/test/java/org/hongxi/whatsmars/boot/sample/logback/SampleLogbackApplicationTests.java b/whatsmars-spring-boot-samples/whatsmars-boot-sample-logback/src/test/java/org/hongxi/whatsmars/boot/sample/logback/SampleLogbackApplicationTests.java deleted file mode 100644 index 2cc32c9903c64c9a16526b7cb6b196df38722046..0000000000000000000000000000000000000000 --- a/whatsmars-spring-boot-samples/whatsmars-boot-sample-logback/src/test/java/org/hongxi/whatsmars/boot/sample/logback/SampleLogbackApplicationTests.java +++ /dev/null @@ -1,31 +0,0 @@ -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