Eng 1086 create syntax sugar for sql queries

integration_tests/sdk/sql_integration_test.py

@@ -37,3 +37,13 @@ def test_invalid_destination_integration(client):
         output_artifact.save(
             config=db.config(table=generate_table_name(), update_mode=LoadUpdateMode.REPLACE)
         )
+
+
+def test_sugar_syntax_sql(client):
+    db = client.integration(name=get_integration_name())
+    sql_artifact_today = db.sql(query="select * from hotel_reviews where review_date = {{today}}")
+    assert sql_artifact_today.get().empty
+    sql_artifact_not_today = db.sql(
+        query="select * from hotel_reviews where review_date != {{today}}"
+    )
+    assert len(sql_artifact_not_today.get()) == 100

src/python/aqueduct_executor/operators/connectors/tabular/relational.py

@@ -1,6 +1,7 @@
 from typing import List
 
 import pandas as pd
+from datetime import date
 from sqlalchemy import engine, inspect
 from sqlalchemy.exc import SQLAlchemyError
 
@@ -24,7 +25,12 @@ def discover(self) -> List[str]:
         return inspect(self.engine).get_table_names()
 
     def extract(self, params: extract.RelationalParams) -> pd.DataFrame:
-        df = pd.read_sql(params.query, con=self.engine)
+        query = params.query
+        if "{{today}}" in query:
+            today_python = date.today()
+            today_sql = "'" + today_python.strftime("%Y-%m-%d") + "'"
+            query = query.replace("{{today}}", today_sql)
+        df = pd.read_sql(query, con=self.engine)
         return df
 
     def load(self, params: load.RelationalParams, df: pd.DataFrame) -> None: