From 2acd2af9522f355d8e03405fbc8140d69edf8c9d Mon Sep 17 00:00:00 2001 From: akageun Date: Thu, 4 Jul 2024 00:49:54 +0900 Subject: [PATCH] Cluster Connector Draft --- .../cadio/web/route/cluster/query/ClusterQueryApi.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/cadio-web/src/main/java/kr/hakdang/cadio/web/route/cluster/query/ClusterQueryApi.java b/cadio-web/src/main/java/kr/hakdang/cadio/web/route/cluster/query/ClusterQueryApi.java index 441e0899..2bdb0751 100644 --- a/cadio-web/src/main/java/kr/hakdang/cadio/web/route/cluster/query/ClusterQueryApi.java +++ b/cadio-web/src/main/java/kr/hakdang/cadio/web/route/cluster/query/ClusterQueryApi.java @@ -6,11 +6,7 @@ import kr.hakdang.cadio.core.domain.cluster.TempClusterConnector; import kr.hakdang.cadio.web.common.dto.response.ApiResponse; import kr.hakdang.cadio.web.route.BaseSample; -import lombok.AccessLevel; -import lombok.Getter; -import lombok.NoArgsConstructor; import lombok.extern.slf4j.Slf4j; -import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; @@ -50,7 +46,7 @@ public ApiResponse> clusterQueryCommand( Map map = new HashMap<>(); try (CqlSession session = tempClusterConnector.makeSession(clusterId)) { //TODO : interface 작업할 때 facade layer 로 변경 예정 - ClusterQueryCommanderResult result1 = clusterQueryCommander.execute(session, request.getQuery(), request.getNextCursor()); + ClusterQueryCommanderResult result1 = clusterQueryCommander.execute(session, request.makeArgs()); map.put("wasApplied", result1.isWasApplied()); map.put("nextCursor", result1.getNextCursor());