Add support for delete operation

- Added new column operation in DB
- Updated existing rows to have 'UPDATE' value for operation field
- Added ability to process both V1 and V2 event schema
- Changed code and testcase to support operation field

Issue-ID: CPS-790
Signed-off-by: Renu Kumari <renu.kumari@bell.ca>
Change-Id: Ife24daa4b442e1499094b162727cc8704c25011e

2 files changed, 52 insertions, 1 deletions

diff --git a/src/main/resources/db/changelog/changelog-master.xml b/src/main/resources/db/changelog/changelog-master.xml
index 6ec36fb..7986d5e 100644
--- a/src/main/resources/db/changelog/changelog-master.xml
+++ b/src/main/resources/db/changelog/changelog-master.xml
@@ -26,5 +26,5 @@
     <include file="db/changelog/schema/01-init-schema.xml"/>
     <include file="db/changelog/data/02-init-data.xml"/>
     <include file="db/changelog/schema/03-rename-network-data-timestamp-fields.xml"/>
-
+    <include file="db/changelog/schema/04-added-operation-field-in-network-data.xml"/>
 </databaseChangeLog>
diff --git a/src/main/resources/db/changelog/schema/04-added-operation-field-in-network-data.xml b/src/main/resources/db/changelog/schema/04-added-operation-field-in-network-data.xml
new file mode 100644
index 0000000..62b93b9
--- /dev/null
+++ b/src/main/resources/db/changelog/schema/04-added-operation-field-in-network-data.xml
@@ -0,0 +1,51 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ============LICENSE_START=======================================================
+  Copyright (c) 2021 Bell Canada.
+  ================================================================================
+  Licensed under the Apache License, Version 2.0 (the "License");
+  you may not use this file except in compliance with the License.
+  You may obtain a copy of the License at
+
+        http://www.apache.org/licenses/LICENSE-2.0
+
+  Unless required by applicable law or agreed to in writing, software
+  distributed under the License is distributed on an "AS IS" BASIS,
+  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  See the License for the specific language governing permissions and
+  limitations under the License.
+
+  SPDX-License-Identifier: Apache-2.0
+  ============LICENSE_END=========================================================
+-->
+
+<databaseChangeLog
+        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+        xmlns="http://www.liquibase.org/xml/ns/dbchangelog"
+        xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog
+            http://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-4.3.xsd">
+
+    <changeSet id="4.1" author="cps">
+        <comment>Add operation field in network data timescale table
+            and set default 'UPDATE' value for existing data
+        </comment>
+        <addColumn tableName="network_data">
+            <column name="operation" type="VARCHAR(20)"
+                    remarks="Field to store the operation type">
+            </column>
+        </addColumn>
+        <update tableName="network_data">
+            <column name="operation" value="UPDATE"/>
+            <where>operation is NULL</where>
+        </update>
+        <rollback>
+            <dropColumn tableName="network_data">
+                <column name="operation"/>
+            </dropColumn>
+        </rollback>
+    </changeSet>
+    <changeSet id="4.2" author="cps">
+        <comment>Remove not null constraint from payload to support delete operation</comment>
+        <dropNotNullConstraint tableName="network_data" columnName="payload"/>
+    </changeSet>
+</databaseChangeLog>