to fix watcher action

Author: fupelaqu

README.md

@@ -34,25 +34,28 @@ softclient4es --host localhost --port 9200
 ```sql
 -- Create a table (index)
 CREATE TABLE users (
-  id KEYWORD PRIMARY KEY,
-  name TEXT,
+  id KEYWORD,
+  name TEXT FIELDS(
+    raw KEYWORD
+  ) OPTIONS (fielddata = true),
   email KEYWORD,
   age INTEGER,
-  created_at DATE
+  created_at DATE,
+  PRIMARY KEY (id)
 );
 
 -- Insert data
 INSERT INTO users (id, name, email, age) 
 VALUES ('1', 'Alice', 'alice@example.com', 30);
 
 -- Query with SQL
-SELECT name, email FROM users WHERE age > 25 ORDER BY name;
+SELECT name, email, age FROM users WHERE age > 25 ORDER BY name;
 
 -- Update records
 UPDATE users SET age = 31 WHERE id = '1';
 
 -- Show tables
-SHOW TABLES;
+SHOW TABLES LIKE 'user%';
 ```
 
 📖 **[Full REPL Documentation](documentation/client/repl.md)**
@@ -78,13 +81,18 @@ SHOW TABLES;
 
 ```sql
 CREATE TABLE products (
-  id KEYWORD PRIMARY KEY,
-  name TEXT,
+  id KEYWORD,
+  name TEXT FIELDS(
+    raw KEYWORD
+  ) OPTIONS (fielddata = true),
+  email KEYWORD,
   price DOUBLE,
-  tags KEYWORD[]
+  tags KEYWORD,
+  PRIMARY KEY (id)
 );
 
 ALTER TABLE products ADD COLUMN stock INTEGER;
+DESCRIBE TABLE products;
 DROP TABLE old_products;
 TRUNCATE TABLE logs;
 ```

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

@@ -679,7 +679,7 @@ class TableExecutor(
             logger.info(s"♻️ Alter index $indexName.")
             alterExistingIndex(indexName, alter)
 
-          // 5) Error on indexExists
+          // 4) Error on indexExists
           case ElasticFailure(elasticError) =>
             Future.successful(
               ElasticFailure(elasticError.copy(operation = Some("schema")))

sql/src/main/scala/app/softnetwork/elastic/sql/watcher/WatcherAction.scala

@@ -40,7 +40,7 @@ case class LoggingActionConfig(
   level: Option[LoggingLevel] = Some(LoggingLevel.INFO)
 ) extends DdlToken {
 
-  def sql: String = s"\"$text\"" + level.map(l => s" AT $l").getOrElse("")
+  def sql: String = s""""$text"${level.map(l => s" AT $l").getOrElse("")}"""
 
   def node: JsonNode = {
     val node = mapper.createObjectNode()
@@ -98,7 +98,7 @@ case class LoggingAction(
 ) extends WatcherAction {
 
   def sql: String = s"LOG $logging" +
-    foreach.map(f => s" FOREACH \"$f\"").getOrElse("") +
+    foreach.map(f => s""" FOREACH "$f"""").getOrElse("") +
     limit.map(mi => s" LIMIT $mi").getOrElse("")
 
   override def node: JsonNode = {
@@ -128,7 +128,7 @@ case class WebhookAction(
   limit: Option[Int] = None
 ) extends WatcherAction {
   def sql: String = s"WEBHOOK $webhook" +
-    foreach.map(f => s" FOREACH \"$f\"").getOrElse("") +
+    foreach.map(f => s""" FOREACH "$f"""").getOrElse("") +
     limit.map(mi => s" LIMIT $mi").getOrElse("")
 
   override def node: JsonNode = {