From 6f4beba23950d45de601684bf0f7649466db4768 Mon Sep 17 00:00:00 2001
From: Philip Marzullo <pmarzullo@jumpmind.com>
Date: Fri, 3 Dec 2021 08:05:48 -0500
Subject: [PATCH] 0004826: Raima DDL Reader fails to read triggers for specific
 table

---
 .../db/platform/raima/RaimaDdlReader.java     | 38 +++++++++----------
 1 file changed, 17 insertions(+), 21 deletions(-)

diff --git a/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/raima/RaimaDdlReader.java b/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/raima/RaimaDdlReader.java
index b518042669..13c7281f25 100644
--- a/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/raima/RaimaDdlReader.java
+++ b/symmetric-jdbc/src/main/java/org/jumpmind/db/platform/raima/RaimaDdlReader.java
@@ -19,13 +19,10 @@
 package org.jumpmind.db.platform.raima;
 
 import java.sql.Connection;
-import java.sql.PreparedStatement;
-import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.sql.Types;
 import java.util.ArrayList;
 import java.util.Collection;
-import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
 
@@ -33,7 +30,6 @@
 import org.jumpmind.db.model.ForeignKey;
 import org.jumpmind.db.model.IIndex;
 import org.jumpmind.db.model.IndexColumn;
-import org.jumpmind.db.model.Reference;
 import org.jumpmind.db.model.Table;
 import org.jumpmind.db.model.Trigger;
 import org.jumpmind.db.model.Trigger.TriggerType;
@@ -115,7 +111,7 @@ protected boolean isInternalForeignKeyIndex(Connection connection,
 
     public List<Trigger> getTriggers(final String catalog, final String schema,
             final String tableName) {
-        
+        // TODO This change is for issue 4826, not 4824
         List<Trigger> triggers = new ArrayList<Trigger>();
         
         log.debug("Reading triggers for: " + tableName);
@@ -123,30 +119,30 @@ public List<Trigger> getTriggers(final String catalog, final String schema,
                 .getSqlTemplate();
         
         String sql = "SELECT "
-                        + "TRIGGERNAME, "
-                        + "SCHEMA, "
-                        + "TRIGGER_TYPE, "
-                        + "TABLENAME, "
-                        + "TRIG.* "
-                    + "FROM SYSTEM.TRIGGERS AS TRIG "
-                    + "WHERE TABLENAME=? and SCHEMA=? ;";
+                + "schemaname, "
+                + "tabname, "
+                + "name, "
+                + "event, "
+                + "trig.* "
+                + "FROM sys_trigger trig "
+                + "WHERE tabname = ? AND schemaname = ?";
         triggers = sqlTemplate.query(sql, new ISqlRowMapper<Trigger>() {
             public Trigger mapRow(Row row) {
                 Trigger trigger = new Trigger();
-                trigger.setName(row.getString("TRIGGERNAME"));
-                trigger.setSchemaName(row.getString("SCHEMA"));
-                trigger.setTableName(row.getString("TABLENAME"));
+                trigger.setName(row.getString("NAME"));
+                trigger.setSchemaName(row.getString("SCHEMANAME"));
+                trigger.setTableName(row.getString("TABNAME"));
                 trigger.setEnabled(true);
-                String triggerType = row.getString("TRIGGER_TYPE");
-                if (triggerType.equals("DELETE")
-                        || triggerType.equals("INSERT")
-                        || triggerType.equals("UPDATE")) {
-                    trigger.setTriggerType(TriggerType.valueOf(triggerType));
+                String triggerType = row.getString("EVENT");
+                if (triggerType.equalsIgnoreCase("DELETE")
+                        || triggerType.equalsIgnoreCase("INSERT")
+                        || triggerType.equalsIgnoreCase("UPDATE")) {
+                    trigger.setTriggerType(TriggerType.valueOf(triggerType.toUpperCase()));
                 }
                 trigger.setMetaData(row);
                 return trigger;
             }
-        }, tableName, catalog);
+        }, tableName, schema);
                 
         return triggers;
     }