From c7a17e602632c170c58289a2e8f0aceed0b4a86c Mon Sep 17 00:00:00 2001 From: Luca Frosini Date: Fri, 9 Apr 2021 23:39:42 +0200 Subject: [PATCH] Escaped string properly --- .../analytics/persistence/postgresql/Query.java | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/src/main/java/org/gcube/accounting/analytics/persistence/postgresql/Query.java b/src/main/java/org/gcube/accounting/analytics/persistence/postgresql/Query.java index c82594e..3e7bf64 100644 --- a/src/main/java/org/gcube/accounting/analytics/persistence/postgresql/Query.java +++ b/src/main/java/org/gcube/accounting/analytics/persistence/postgresql/Query.java @@ -1,5 +1,6 @@ package org.gcube.accounting.analytics.persistence.postgresql; +import java.sql.SQLException; import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.Collection; @@ -120,7 +121,7 @@ public class Query extends PostgreSQLQuery { return date; } - protected void addFilters() { + protected void addFilters() throws SQLException { if(filters!=null && filters.size()>0) { // The first filter if the time_bucket stringBuffer.append(" AND "); @@ -138,7 +139,7 @@ public class Query extends PostgreSQLQuery { } } - protected void addOrConditions(String key, Set values) { + protected void addOrConditions(String key, Set values) throws SQLException { if(values!=null && values.size()>0) { // The first filter if the time_bucket stringBuffer.append(" AND ("); @@ -158,11 +159,11 @@ public class Query extends PostgreSQLQuery { } - protected void addContextFilter() { + protected void addContextFilter() throws SQLException { addOrConditions(UsageRecord.SCOPE, contexts); } - protected void addOrConditionFilter() { + protected void addOrConditionFilter() throws SQLException { addOrConditions(orConditionKey, orConditionValues); } @@ -260,7 +261,7 @@ public class Query extends PostgreSQLQuery { stringBuffer.append("SELECT "); } - protected void addTemporalConstraintToQuery() { + protected void addTemporalConstraintToQuery() throws SQLException { stringBuffer.append(" WHERE "); String tableField = getTableField(AggregatedRecord.START_TIME); stringBuffer.append(tableField);