Skip to content

Commit

Permalink
Cluster Connector Draft
Browse files Browse the repository at this point in the history
  • Loading branch information
akageun committed Jul 3, 2024
1 parent bc328ea commit 2acd2af
Showing 1 changed file with 1 addition and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -50,7 +46,7 @@ public ApiResponse<Map<String, Object>> clusterQueryCommand(
Map<String, Object> 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());
Expand Down

0 comments on commit 2acd2af

Please sign in to comment.