PoliBa-DeepLearning/NanoSocrates
2
0
Fork 0
Code Issues 3 Pull Requests 1 Actions Packages Projects Releases Wiki Activity

update sql_endpoint to work with the new pipeline

Browse Source
This commit is contained in:
GassiGiuseppe
2025-10-05 14:58:03 +02:00
parent acb43fc899
commit 7307916891
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
Scripts/Libs/CleaningPipeline/sql_endpoint.py
View File

@@ -133,6 +133,11 @@ class SqlEndpoint():
GROUP BY RelationshipURI; GROUP BY RelationshipURI;
""" """
return pd.read_sql_query(QUERY, self.sql_engine) return pd.read_sql_query(QUERY, self.sql_engine)
def get_dataframe_from_query(self, query: str, params=None):
if params is None:
return pd.read_sql_query(query, self.sql_engine)
return pd.read_sql_query(query, self.sql_engine, params=params)