clp-s: Add boilerplate for new sql parser

components/core/CMakeLists.txt

@@ -479,6 +479,7 @@ set(SOURCE_FILES_unitTest
         tests/test-Stopwatch.cpp
         tests/test-StreamingCompression.cpp
         tests/test-string_utils.cpp
+        tests/test-sql.cpp
         tests/test-TimestampPattern.cpp
         tests/test-utf8_utils.cpp
         tests/test-Utils.cpp
@@ -499,6 +500,7 @@ target_link_libraries(unitTest
         LibArchive::LibArchive
         MariaDBClient::MariaDBClient
         spdlog::spdlog
+        sql
         ${sqlite_LIBRARY_DEPENDENCIES}
         ${STD_FS_LIBS}
         clp::regex_utils

components/core/src/clp_s/CMakeLists.txt

@@ -1,4 +1,5 @@
 add_subdirectory(search/kql)
+add_subdirectory(search/sql)
 
 set(
         CLP_SOURCES

components/core/src/clp_s/search/sql/CMakeLists.txt

@@ -0,0 +1,28 @@
+ANTLR_TARGET(
+        SqlParser
+        Sql.g4
+        LEXER PARSER VISITOR
+        PACKAGE sql
+)
+
+add_library(
+        sql
+        ../../Utils.hpp
+        ../AndExpr.hpp
+        ../BooleanLiteral.hpp
+        ../ColumnDescriptor.hpp
+        ../DateLiteral.hpp
+        ../EmptyExpr.hpp
+        ../Expression.hpp
+        ../FilterExpr.hpp
+        ../Integral.hpp
+        ../NullLiteral.hpp
+        ../OrExpr.hpp
+        ../StringLiteral.hpp
+        ${ANTLR_SqlParser_CXX_OUTPUTS}
+        sql.cpp
+        sql.hpp
+)
+target_compile_features(sql PRIVATE cxx_std_20)
+target_include_directories(sql PRIVATE ${ANTLR_SqlParser_OUTPUT_DIR})
+target_link_libraries(sql PRIVATE antlr4_static Boost::filesystem)

components/core/src/clp_s/search/sql/Sql.g4

@@ -0,0 +1,5 @@
+grammar Sql;
+
+start: EOF ;
+
+SPACE:  [ \t\r\n] -> skip ;

components/core/src/clp_s/search/sql/sql.cpp

@@ -0,0 +1,69 @@
+#include <iostream>
+#include <string>
+
+#include <antlr4-runtime.h>
+#include <spdlog/spdlog.h>
+
+#include "../EmptyExpr.hpp"
+#include "SqlBaseVisitor.h"
+#include "SqlLexer.h"
+#include "SqlParser.h"
+
+using namespace antlr4;
+using namespace sql;
+
+namespace clp_s::search::sql {
+class ErrorListener : public BaseErrorListener {
+public:
+    void syntaxError(
+            Recognizer* recognizer,
+            Token* offending_symbol,
+            size_t line,
+            size_t char_position_in_line,
+            std::string const& msg,
+            std::exception_ptr e
+    ) override {
+        m_error = true;
+        m_error_message = msg;
+    }
+
+    bool error() const { return m_error; }
+
+    std::string const& message() const { return m_error_message; }
+
+private:
+    bool m_error{false};
+    std::string m_error_message;
+};
+
+class ParseTreeVisitor : public SqlBaseVisitor {
+public:
+    std::any visitStart(SqlParser::StartContext* ctx) override { return EmptyExpr::create(); }
+};
+
+std::shared_ptr<Expression> parse_sql_expression(std::istream& in) {
+    ErrorListener lexer_error_listener;
+    ErrorListener parser_error_listener;
+
+    ANTLRInputStream input(in);
+    SqlLexer lexer(&input);
+    lexer.removeErrorListeners();
+    lexer.addErrorListener(&lexer_error_listener);
+    CommonTokenStream tokens(&lexer);
+    SqlParser parser(&tokens);
+    parser.removeErrorListeners();
+    parser.addErrorListener(&parser_error_listener);
+    SqlParser::StartContext* tree = parser.start();
+
+    if (lexer_error_listener.error()) {
+        SPDLOG_ERROR("Lexer error: {}", lexer_error_listener.message());
+        return {};
+    } else if (parser_error_listener.error()) {
+        SPDLOG_ERROR("Parser error: {}", parser_error_listener.message());
+        return {};
+    }
+
+    ParseTreeVisitor visitor;
+    return std::any_cast<std::shared_ptr<Expression>>(visitor.visitStart(tree));
+}
+}  // namespace clp_s::search::sql

components/core/src/clp_s/search/sql/sql.hpp

@@ -0,0 +1,17 @@
+#ifndef CLP_S_SEARCH_SQL_SQL_HPP
+#define CLP_S_SEARCH_SQL_SQL_HPP
+
+#include <istream>
+
+#include "../Expression.hpp"
+
+namespace clp_s::search::sql {
+/**
+ * Generate a search AST from an SQL expression in an input stream
+ * @param in input stream containing an SQL expression followed by EOF
+ * @return a search AST on success, nullptr otherwise
+ */
+std::shared_ptr<Expression> parse_sql_expression(std::istream& in);
+}  // namespace clp_s::search::sql
+
+#endif  // CLP_S_SEARCH_SQL_SQL_HPP

components/core/tests/test-sql.cpp

@@ -0,0 +1,27 @@
+#include <sstream>
+#include <string>
+#include <vector>
+
+#include <Catch2/single_include/catch2/catch.hpp>
+#include <spdlog/spdlog.h>
+
+#include "../src/clp_s/search/EmptyExpr.hpp"
+#include "../src/clp_s/search/sql/sql.hpp"
+#include "LogSuppressor.hpp"
+
+using clp_s::search::EmptyExpr;
+using clp_s::search::sql::parse_sql_expression;
+using std::string;
+using std::stringstream;
+using std::vector;
+
+TEST_CASE("Test parsing SQL", "[SQL]") {
+    // Suppress logging
+    LogSuppressor suppressor{};
+
+    SECTION("Stub accepts empty string") {
+        stringstream empty_string{""};
+        auto filter = std::dynamic_pointer_cast<EmptyExpr>(parse_sql_expression(empty_string));
+        REQUIRE(nullptr != filter);
+    }
+}