Update table columns

Author: kjsbot

gateway-ha/src/main/java/io/trino/gateway/ha/DatabaseAuditLogger.java

@@ -37,7 +37,7 @@ public DatabaseAuditLogger(Jdbi jdbi)
     public void logAudit(String user, String ip, String backendName, AuditAction action, AuditContext context, boolean success, String userComment)
     {
         try {
-            dao.log(user, ip, backendName, action.toString(), context.toString(), success ? 1 : 0,
+            dao.log(user, ip, backendName, action.toString(), context.toString(), success,
                     AuditLogger.sanitizeComment(userComment), Timestamp.from(Instant.now()));
         }
         catch (Exception e) {

gateway-ha/src/main/java/io/trino/gateway/ha/persistence/dao/AuditLogDao.java

@@ -22,14 +22,14 @@ public interface AuditLogDao
 {
     @SqlUpdate("""
             INSERT INTO gateway_audit_logs (user_name, ip_address, backend_name, operation, context, success, user_comment, change_time)
-            VALUES (:user_name, :ip_address, :backend_name, :operation, :context, :success, :user_comment, :change_time)
+            VALUES (:user_name, :ip_address, :backend_name, :operation, :context, :success, LEFT(:user_comment, 1024), :change_time)
             """)
     void log(@Bind("user_name") String user_name,
             @Bind("ip_address") String ip_address,
             @Bind("backend_name") String backend_name,
             @Bind("operation") String operation,
             @Bind("context") String context,
-            @Bind("success") int success,
+            @Bind("success") Boolean success,
             @Bind("user_comment") String user_comment,
             @Bind("change_time") Timestamp change_time);
 }

gateway-ha/src/main/resources/gateway-ha-persistence-mysql.sql

@@ -78,15 +78,13 @@ CREATE TABLE IF NOT EXISTS exact_match_source_selectors (
 );
 
 CREATE TABLE IF NOT EXISTS gateway_audit_logs (
-    audit_id BIGINT NOT NULL AUTO_INCREMENT,
+    audit_id BIGINT NOT NULL AUTO_INCREMENT PRIMARY KEY,
     user_name VARCHAR(256) NOT NULL,
     ip_address VARCHAR(45),
     backend_name VARCHAR(256) NOT NULL,
-    operation VARCHAR(256) NOT NULL,
-    context VARCHAR(256) NOT NULL,
+    operation VARCHAR(64) NOT NULL,
+    context VARCHAR(64) NOT NULL,
     success BOOLEAN NOT NULL,
     user_comment VARCHAR(1024),
-    change_time TIMESTAMP NOT NULL,
-
-    PRIMARY KEY(audit_id)
+    change_time TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
 );

gateway-ha/src/main/resources/gateway-ha-persistence-postgres.sql

@@ -78,15 +78,13 @@ CREATE TABLE IF NOT EXISTS exact_match_source_selectors (
 );
 
 CREATE TABLE IF NOT EXISTS gateway_audit_logs (
-    audit_id BIGSERIAL,
+    audit_id BIGSERIAL PRIMARY KEY,
     user_name VARCHAR(256) NOT NULL,
     ip_address VARCHAR(45),
     backend_name VARCHAR(256) NOT NULL,
-    operation VARCHAR(256) NOT NULL,
-    context VARCHAR(256) NOT NULL,
-    success SMALLINT NOT NULL CHECK (success IN (0, 1)),
+    operation VARCHAR(64) NOT NULL,
+    context VARCHAR(64) NOT NULL,
+    success BOOLEAN NOT NULL,
     user_comment VARCHAR(1024),
-    change_time TIMESTAMP NOT NULL,
-
-    PRIMARY KEY(audit_id)
+    change_time TIMESTAMPTZ NOT NULL DEFAULT now()
 );

gateway-ha/src/main/resources/mysql/V1__create_schema.sql

@@ -78,15 +78,13 @@ CREATE TABLE IF NOT EXISTS exact_match_source_selectors (
 );
 
 CREATE TABLE IF NOT EXISTS gateway_audit_logs (
-    audit_id BIGINT NOT NULL AUTO_INCREMENT,
+    audit_id BIGINT NOT NULL AUTO_INCREMENT PRIMARY KEY,
     user_name VARCHAR(256) NOT NULL,
     ip_address VARCHAR(45),
     backend_name VARCHAR(256) NOT NULL,
-    operation VARCHAR(256) NOT NULL,
-    context VARCHAR(256) NOT NULL,
+    operation VARCHAR(64) NOT NULL,
+    context VARCHAR(64) NOT NULL,
     success BOOLEAN NOT NULL,
     user_comment VARCHAR(1024),
-    change_time TIMESTAMP NOT NULL,
-
-    PRIMARY KEY(audit_id)
+    change_time TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
 );

gateway-ha/src/main/resources/oracle/V1__create_schema.sql

@@ -69,14 +69,13 @@ CREATE TABLE exact_match_source_selectors(
 );
 
 CREATE TABLE gateway_audit_logs (
-    audit_id NUMBER GENERATED ALWAYS as IDENTITY(START with 1 INCREMENT by 1),
+    audit_id NUMBER(19) GENERATED BY DEFAULT AS IDENTITY PRIMARY KEY,
     user_name VARCHAR(256) NOT NULL,
     ip_address VARCHAR2(45),
     backend_name VARCHAR(256) NOT NULL,
-    operation VARCHAR(256) NOT NULL,
-    context VARCHAR(256) NOT NULL,
-    success NUMBER(1) NOT NULL CHECK (success IN (0,1)),
+    operation VARCHAR(64) NOT NULL,
+    context VARCHAR(64) NOT NULL,
+    success BOOLEAN NOT NULL,
     user_comment VARCHAR(1024),
-    change_time TIMESTAMP NOT NULL,
-    PRIMARY KEY(audit_id)
+    change_time TIMESTAMP WITH TIME ZONE DEFAULT CURRENT_TIMESTAMP NOT NULL
 );

gateway-ha/src/main/resources/postgresql/V1__create_schema.sql

@@ -78,15 +78,13 @@ CREATE TABLE IF NOT EXISTS exact_match_source_selectors (
 );
 
 CREATE TABLE IF NOT EXISTS gateway_audit_logs (
-    audit_id BIGSERIAL,
+    audit_id BIGSERIAL PRIMARY KEY,
     user_name VARCHAR(256) NOT NULL,
     ip_address VARCHAR(45),
     backend_name VARCHAR(256) NOT NULL,
-    operation VARCHAR(256) NOT NULL,
-    context VARCHAR(256) NOT NULL,
-    success SMALLINT NOT NULL CHECK (success IN (0, 1)),
+    operation VARCHAR(64) NOT NULL,
+    context VARCHAR(64) NOT NULL,
+    success BOOLEAN NOT NULL,
     user_comment VARCHAR(1024),
-    change_time TIMESTAMP NOT NULL,
-
-    PRIMARY KEY(audit_id)
+    change_time TIMESTAMPTZ NOT NULL DEFAULT now()
 );