diff --git a/initializer-service/src/main/java/com/schbrain/initializer/service/StarrocksService.java b/initializer-service/src/main/java/com/schbrain/initializer/service/StarrocksService.java deleted file mode 100644 index ef2086c6bc5664aea902499355c27cec022192c3..0000000000000000000000000000000000000000 --- a/initializer-service/src/main/java/com/schbrain/initializer/service/StarrocksService.java +++ /dev/null @@ -1,11 +0,0 @@ -package com.schbrain.initializer.service; - -/** - * @author liaozan - * @since 2023/11/27 - */ -public interface StarrocksService { - - boolean streamLoad(String tableName, Object content); - -} diff --git a/initializer-service/src/main/java/com/schbrain/initializer/service/config/StarrocksProperties.java b/initializer-service/src/main/java/com/schbrain/initializer/service/config/StarrocksProperties.java deleted file mode 100644 index e05188cf3eb2b791343dfb22692c94a1dfa813d8..0000000000000000000000000000000000000000 --- a/initializer-service/src/main/java/com/schbrain/initializer/service/config/StarrocksProperties.java +++ /dev/null @@ -1,16 +0,0 @@ -package com.schbrain.initializer.service.config; - -import lombok.Data; -import org.springframework.boot.context.properties.ConfigurationProperties; - -/** - * @author liaozan - * @since 2023/11/23 - */ -@Data -@ConfigurationProperties(prefix = "starrocks") -public class StarrocksProperties { - - private String feServerUrl = "schbrain-fe-svc.starrocks:8030"; - -} diff --git a/initializer-service/src/main/java/com/schbrain/initializer/service/impl/StarrocksServiceImpl.java b/initializer-service/src/main/java/com/schbrain/initializer/service/impl/StarrocksServiceImpl.java deleted file mode 100644 index c16e0103899fac4e03497007cd780d8bb65e7ac1..0000000000000000000000000000000000000000 --- a/initializer-service/src/main/java/com/schbrain/initializer/service/impl/StarrocksServiceImpl.java +++ /dev/null @@ -1,47 +0,0 @@ -package com.schbrain.initializer.service.impl; - -import cn.hutool.http.HttpRequest; -import com.fasterxml.jackson.databind.JsonNode; -import com.schbrain.common.util.JacksonUtils; -import com.schbrain.initializer.service.StarrocksService; -import com.schbrain.initializer.service.config.StarrocksProperties; -import lombok.extern.slf4j.Slf4j; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Service; - -/** - * @author liaozan - * @since 2023/11/27 - */ -@Slf4j -@Service -public class StarrocksServiceImpl implements StarrocksService { - - private static final String STREAM_LOAD_TEMPLATE = "http://%s/api/schbrain_mosaic/%s/_stream_load"; - - @Autowired - private StarrocksProperties starrocksProperties; - - @Override - public boolean streamLoad(String tableName, Object content) { - String streamLoadUrl = getStreamLoadUrl(tableName); - String res = HttpRequest.put(streamLoadUrl) - .header("strict_mode", Boolean.TRUE.toString()) - .header("Expect", "100-continue") - .header("format", "json") - .basicAuth("mosaic_admin", "schbrain111623") - .setFollowRedirects(true) - .body(JacksonUtils.toJsonString(content)) - .execute() - .body(); - System.out.println(res); - JsonNode loadResponse = JacksonUtils.getJsonNode(res); - log.info("stream load response: {}", loadResponse); - return true; - } - - private String getStreamLoadUrl(String tableName) { - return String.format(STREAM_LOAD_TEMPLATE, starrocksProperties.getFeServerUrl(), tableName); - } - -} diff --git a/initializer-starter/src/main/java/com/schbrain/initializer/Application.java b/initializer-starter/src/main/java/com/schbrain/initializer/Application.java index a8455caa8f28bb0c291a80b04120d86d3aeac687..e0ad37a709c699b8f27a3c25a9afa074331ee46a 100644 --- a/initializer-starter/src/main/java/com/schbrain/initializer/Application.java +++ b/initializer-starter/src/main/java/com/schbrain/initializer/Application.java @@ -1,32 +1,15 @@ package com.schbrain.initializer; -import com.schbrain.initializer.service.StarrocksService; -import com.schbrain.initializer.service.config.StarrocksProperties; -import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; -import org.springframework.boot.context.properties.EnableConfigurationProperties; -import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; -import java.util.Map; - @RestController @SpringBootApplication -@EnableConfigurationProperties(StarrocksProperties.class) public class Application { - @Autowired - private StarrocksService starrocksService; - public static void main(String[] args) { SpringApplication.run(Application.class, args); } - @GetMapping("/load") - public void doLoad() { - Map content = Map.of("id", "1", "city", "name"); - starrocksService.streamLoad("test", content); - } - } diff --git a/initializer-web/src/main/java/com/schbrain/initializer/web/controller/EntityController.java b/initializer-web/src/main/java/com/schbrain/initializer/web/controller/EntityController.java index d324fa015b63e02bef6a58f7479b8faa7b15ddd5..85ee00a5dcd5e99c72f959563dea9129c9b4d2a6 100644 --- a/initializer-web/src/main/java/com/schbrain/initializer/web/controller/EntityController.java +++ b/initializer-web/src/main/java/com/schbrain/initializer/web/controller/EntityController.java @@ -15,6 +15,7 @@ import org.apache.commons.lang3.tuple.Triple; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; +import javax.servlet.http.HttpServletRequest; import java.time.LocalDate; import java.util.*; @@ -32,6 +33,11 @@ public class EntityController { @Autowired private EntityWithLogicDeleteService entityWithLogicDeleteService; + @GetMapping("/header") + public void printHeaders(HttpServletRequest request) { + request.getHeaderNames().asIterator().forEachRemaining(name -> log.info(name + ": " + request.getHeader(name))); + } + @GetMapping("/copy") public void copy() { Entity entity = new Entity(); diff --git a/pom.xml b/pom.xml index 8ebe35a8d3e4a1b4a8eb10a0089c0e46684443b1..805f8f3bd651c9da4416b7befaac698704990d3a 100644 --- a/pom.xml +++ b/pom.xml @@ -8,7 +8,7 @@ com.schbrain.framework schbrain-parent - 3.0.9-SNAPSHOT + 3.0.11 com.schbrain