Merge pull request #19 from SOFTNETWORK-APP/refactoring

add support for : 
- RLIKE
- CONVERT, TRY_CAST, SAFE_CAST functions
- CAST OPERATOR (::)
- OFFSET with LIMIT
- TOP HITS aggregations (FIRST_VALUE / FIRST, LAST_VALUE / LAST)
- GROUP BY with field index
- TODAY
- LAST_DAY / LAST
- WEEK_OF_YEAR / WEEK
- DAY_OF_WEEK / WEEKDAY
- DAY_OF_YEAR / YEARDAY
- NANO_OF_SECOND / NANOSECOND
- MICRO_OF_SECOND / MICROSECOND
- MILLI_OF_SECOND / MILLISECOND
- EPOCH_DAY / EPOCHDAY
- OFFSET_SECONDS / OFFSET
- QUARTER_OF_YEAR / QUARTER
- ARRAY_AGG aggregation
- LTRIM, RTRIM, LEFT, RIGHT, REPLACE, REVERSE, POSITION and REGEXP_LIKE string functions
- Temporal and geo distance BETWEEN
- temporal parsing and formatting using MySQL-style date time formats

Author: fupelaqu

README.md

@@ -20,7 +20,7 @@ This project provides a trait-based interface (`ElasticClientApi`) that aggregat
 By relying on these concrete implementations, developers can switch between versions with minimal changes to their business logic.
 
 **SQL to Elasticsearch Query Translation**  
-Elastic Client includes a parser capable of translating SQL `SELECT` queries into Elasticsearch queries. The parser produces an intermediate representation, which is then converted into [Elastic4s](https://github.com/sksamuel/elastic4s) DSL queries and ultimately into native Elasticsearch queries. This allows data engineers and analysts to express queries in familiar SQL syntax.
+Elastic Client includes a parser capable of translating SQL `SELECT` queries into Elasticsearch queries. The parser produces an intermediate representation, which is then converted into [Elastic4s](https://github.com/sksamuel/elastic4s) DSL queries and ultimately into native Elasticsearch queries. This allows data engineers and analysts to express queries in familiar [SQL](documentation/README.md) syntax.
 
 **Dynamic Mapping Migration**  
 Elastic Client provides tools to analyze and compare existing mappings with new ones. If differences are detected, it can automatically perform safe migrations. This includes creating temporary indices, reindexing, and renaming — all while preserving data integrity. This eliminates the need for manual mapping migrations and reduces downtime.

build.sbt

@@ -19,7 +19,7 @@ ThisBuild / organization := "app.softnetwork"
 
 name := "softclient4es"
 
-ThisBuild / version := "0.8.0"
+ThisBuild / version := "0.9.0"
 
 ThisBuild / scalaVersion := scala213
 

core/src/main/scala/app/softnetwork/elastic/client/AggregateResult.scala

@@ -1,6 +1,6 @@
 package app.softnetwork.elastic.client
 
-import app.softnetwork.elastic.sql.AggregateFunction
+import app.softnetwork.elastic.sql.function.aggregate.AggregateFunction
 
 sealed trait AggregateResult {
   def field: String

core/src/main/scala/app/softnetwork/elastic/client/ElasticClientApi.scala

@@ -8,7 +8,7 @@ import _root_.akka.stream.{FlowShape, Materializer}
 import akka.stream.scaladsl._
 import app.softnetwork.persistence.model.Timestamped
 import app.softnetwork.serialization._
-import app.softnetwork.elastic.sql.{SQLQuery, SQLSearchRequest}
+import app.softnetwork.elastic.sql.query.{SQLQuery, SQLSearchRequest}
 import com.google.gson.JsonParser
 import com.typesafe.config.{Config, ConfigFactory}
 import org.json4s.{DefaultFormats, Formats}

core/src/main/scala/app/softnetwork/elastic/client/MappingComparator.scala

@@ -3,7 +3,7 @@ package app.softnetwork.elastic.client
 import com.google.gson._
 import com.typesafe.scalalogging.StrictLogging
 
-import scala.collection.JavaConverters._
+import scala.jdk.CollectionConverters._
 import scala.util.{Failure, Success, Try}
 
 object MappingComparator extends StrictLogging {

core/src/main/scala/app/softnetwork/elastic/client/package.scala

@@ -13,7 +13,7 @@ import scala.collection.mutable
 import scala.language.reflectiveCalls
 import scala.util.{Failure, Success, Try}
 
-import scala.collection.JavaConverters._
+import scala.jdk.CollectionConverters._
 
 /** Created by smanciot on 30/06/2018.
   */

core/src/main/scala/app/softnetwork/elastic/persistence/query/ElasticProvider.scala

@@ -1,7 +1,7 @@
 package app.softnetwork.elastic.persistence.query
 
 import app.softnetwork.elastic.client.ElasticClientApi
-import app.softnetwork.elastic.sql.SQLQuery
+import app.softnetwork.elastic.sql.query.SQLQuery
 import mustache.Mustache
 import org.json4s.Formats
 import app.softnetwork.persistence._

core/testkit/src/main/scala/app/softnetwork/elastic/client/ElasticClientSpec.scala

@@ -4,7 +4,7 @@ import akka.actor.ActorSystem
 import app.softnetwork.elastic.model.{Binary, Child, Parent, Sample}
 import app.softnetwork.elastic.persistence.query.ElasticProvider
 import app.softnetwork.elastic.scalatest.ElasticDockerTestKit
-import app.softnetwork.elastic.sql.SQLQuery
+import app.softnetwork.elastic.sql.query.SQLQuery
 import app.softnetwork.persistence._
 import app.softnetwork.persistence.person.model.Person
 import com.fasterxml.jackson.core.JsonParseException

core/testkit/src/main/scala/app/softnetwork/elastic/client/MockElasticClientApi.scala

@@ -3,7 +3,7 @@ package app.softnetwork.elastic.client
 import akka.NotUsed
 import akka.actor.ActorSystem
 import akka.stream.scaladsl.Flow
-import app.softnetwork.elastic.sql.{SQLQuery, SQLSearchRequest}
+import app.softnetwork.elastic.sql.query.{SQLQuery, SQLSearchRequest}
 import org.json4s.Formats
 import app.softnetwork.persistence.model.Timestamped
 import org.slf4j.{Logger, LoggerFactory}

documentation/README.md

@@ -0,0 +1,15 @@
+# SQL Engine Documentation
+
+Welcome to the SQL Engine Documentation. Navigate through the sections below:
+
+- [Query Structure](request_structure.md)
+- [Operators](operators.md)
+- [Operator Precedence](operator_precedence.md)
+- [Aggregate Functions](functions_aggregate.md)
+- [Date/Time Functions](functions_date_time.md)
+- [Math Functions](functions_math.md)
+- [String Functions](functions_string.md)
+- [Type Conversion](type_conversion.md)
+- [Conditional Functions](functions_conditional.md)
+- [Geo Functions](functions_geo.md)
+- [Keywords](keywords.md)