Polishing.

Signed-off-by: Youssef Aouichaoui <[email protected]>

Author: youssef3wi

src/main/java/org/springframework/data/elasticsearch/core/query/SqlQuery.java

@@ -15,18 +15,11 @@
  */
 package org.springframework.data.elasticsearch.core.query;
 
-import static org.springframework.data.elasticsearch.core.sql.types.ResponseFormat.cbor;
-import static org.springframework.data.elasticsearch.core.sql.types.ResponseFormat.csv;
-import static org.springframework.data.elasticsearch.core.sql.types.ResponseFormat.json;
-import static org.springframework.data.elasticsearch.core.sql.types.ResponseFormat.smile;
-import static org.springframework.data.elasticsearch.core.sql.types.ResponseFormat.yaml;
-
 import java.time.Duration;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.TimeZone;
 
-import org.springframework.data.elasticsearch.core.sql.types.ResponseFormat;
 import org.springframework.lang.Nullable;
 import org.springframework.util.Assert;
 
@@ -38,20 +31,6 @@
  * @since 5.4
  */
 public class SqlQuery {
-	/**
-	 * Separator for CSV results.
-	 * <p>
-	 * Default, this is set to {@code ,}.
-	 */
-	@Nullable private final String delimiter;
-
-	/**
-	 * The format for the response, such as csv, json, txt, can be viewed at the {@link ResponseFormat}. The java client
-	 * of Elasticsearch only supports JSON. See {@link co.elastic.clients.transport.JsonEndpoint}
-	 * <p>
-	 * Default, this is set to {@code json}.
-	 */
-	@Nullable private final ResponseFormat format;
 
 	/**
 	 * If true, returns partial results if there are shard request timeouts or shard failures.
@@ -157,9 +136,6 @@ public class SqlQuery {
 	@Nullable private final Duration waitForCompletionTimeout;
 
 	private SqlQuery(Builder builder) {
-		this.delimiter = builder.delimiter;
-		this.format = builder.format;
-
 		this.allowPartialSearchResults = builder.allowPartialSearchResults;
 
 		this.catalog = builder.catalog;
@@ -185,16 +161,6 @@ private SqlQuery(Builder builder) {
 		this.waitForCompletionTimeout = builder.waitForCompletionTimeout;
 	}
 
-	@Nullable
-	public String getDelimiter() {
-		return delimiter;
-	}
-
-	@Nullable
-	public ResponseFormat getFormat() {
-		return format;
-	}
-
 	@Nullable
 	public Boolean getAllowPartialSearchResults() {
 		return allowPartialSearchResults;
@@ -279,9 +245,6 @@ public static Builder builder(String query) {
 	}
 
 	public static class Builder {
-		@Nullable private String delimiter;
-		@Nullable private ResponseFormat format;
-
 		@Nullable private Boolean allowPartialSearchResults;
 
 		@Nullable private String catalog;
@@ -313,24 +276,6 @@ private Builder(String query) {
 			this.query = query;
 		}
 
-		/**
-		 * Separator for CSV results.
-		 */
-		public Builder withDelimiter(String delimiter) {
-			this.delimiter = delimiter;
-
-			return this;
-		}
-
-		/**
-		 * The format for the response, such as csv, json, txt, can be viewed at the {@link ResponseFormat}.
-		 */
-		public Builder withFormat(ResponseFormat format) {
-			this.format = format;
-
-			return this;
-		}
-
 		/**
 		 * If true, returns partial results if there are shard request timeouts or shard failures.
 		 */
@@ -482,16 +427,6 @@ public Builder withWaitForCompletionTimeout(Duration waitForCompletionTimeout) {
 		}
 
 		public SqlQuery build() {
-			if (Boolean.TRUE.equals(columnar)) {
-				if (!(cbor.equals(format) || json.equals(format) || smile.equals(format) || yaml.equals(format))) {
-					throw new IllegalArgumentException("Columnar format support only YAML, CBOR, JSON and SMILE.");
-				}
-			}
-
-			if (delimiter != null && !csv.equals(format)) {
-				throw new IllegalArgumentException("Delimiter support is only available for CSV responses.");
-			}
-
 			return new SqlQuery(this);
 		}
 	}

src/main/java/org/springframework/data/elasticsearch/core/sql/ReactiveSqlOperations.java

@@ -28,7 +28,7 @@
  */
 public interface ReactiveSqlOperations {
 	/**
-	 * Execute the criteria {@code query} against elasticsearch and return result as {@link SqlResponse}
+	 * Execute the sql {@code query} against elasticsearch and return result as {@link SqlResponse}
 	 *
 	 * @param query the query to execute
 	 * @return {@link SqlResponse} containing the list of found objects

src/main/java/org/springframework/data/elasticsearch/core/sql/SqlOperations.java

@@ -26,7 +26,7 @@
  */
 public interface SqlOperations {
 	/**
-	 * Execute the criteria {@code query} against elasticsearch and return result as {@link SqlResponse}
+	 * Execute the sql {@code query} against elasticsearch and return result as {@link SqlResponse}
 	 *
 	 * @param query the query to execute
 	 * @return {@link SqlResponse} containing the list of found objects

src/main/java/org/springframework/data/elasticsearch/core/sql/SqlResponse.java

@@ -121,18 +121,6 @@ public JsonValue get(Column column) {
 			return row.get(column);
 		}
 
-		/**
-		 * This method should attempt to convert the SQL response into a document if the columns selected in an SQL query
-		 * correspond to the fields in the document.
-		 * 
-		 * @param documentClass The class that represents the document.
-		 * @return an instance of Document {@link T}.
-		 * @param <T> Document type.
-		 */
-		public <T> T toDocument(Class<T> documentClass) {
-			throw new UnsupportedOperationException("Not implemented yet.");
-		}
-
 		public static class Builder {
 			private final Map<Column, JsonValue> row = new HashMap<>();