From 8e99a52f3d4f7831f9f788bc605119acc740f71a Mon Sep 17 00:00:00 2001 From: Alvaro Vega Date: Tue, 19 Sep 2023 09:45:55 +0200 Subject: [PATCH] add erPK to error log table --- CHANGES_NEXT_RELEASE | 1 + .../iot/cygnus/backends/sql/SQLBackendImpl.java | 10 ++++++---- 2 files changed, 7 insertions(+), 4 deletions(-) diff --git a/CHANGES_NEXT_RELEASE b/CHANGES_NEXT_RELEASE index 74ef01343..b569e5950 100644 --- a/CHANGES_NEXT_RELEASE +++ b/CHANGES_NEXT_RELEASE @@ -1,3 +1,4 @@ +- [cygnus-commons] [SQL] Add Primary Key on Timestamp to Error Log table (#2302) - [cygnus-commons] Upgrade gson dependency from 2.6.2 to 2.10.1 - [cygnus-ngsi][cygnus-common] upgrade mockito dep from 1.9.5 to 5.5.0 - [cygnus-ngsi] Fix runtime error: check access aggregator size (#2293) diff --git a/cygnus-common/src/main/java/com/telefonica/iot/cygnus/backends/sql/SQLBackendImpl.java b/cygnus-common/src/main/java/com/telefonica/iot/cygnus/backends/sql/SQLBackendImpl.java index d1aec7ae3..239d1bdce 100644 --- a/cygnus-common/src/main/java/com/telefonica/iot/cygnus/backends/sql/SQLBackendImpl.java +++ b/cygnus-common/src/main/java/com/telefonica/iot/cygnus/backends/sql/SQLBackendImpl.java @@ -583,13 +583,15 @@ public void createErrorTable(String dataBase, String schema) errorTableName = schema + "." + dataBase + DEFAULT_ERROR_TABLE_SUFFIX; } String typedFieldNames = "(" + - "timestamp TIMESTAMP" + + "timestamp TIMESTAMP NOT NULL" + ", error text" + - ", query text)"; + ", query text" + + ", CONSTRAINT PK_ErrorLog PRIMARY KEY (timestamp) )"; String typedFieldNamesOracle = "(" + - "timestamp TIMESTAMP" + + "timestamp TIMESTAMP NOT NULL" + ", error clob" + - ", query clob)"; + ", query clob" + + ", CONSTRAINT PK_ErrorLog PRIMARY KEY (timestamp) )"; Statement stmt = null; // get a connection to the given destination