fix(jdbc): add name as a column to be able to filter on it

Will be usefull for the next steps on metric usage
kestra-io · Mar 10, 2023 · d1acf9c · d1acf9c
1 parent 376f398
commit d1acf9c
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 0 deletions.
diff --git a/jdbc-h2/src/main/resources/migrations/h2/V6__metrics.sql b/jdbc-h2/src/main/resources/migrations/h2/V6__metrics.sql
@@ -23,6 +23,7 @@ CREATE TABLE metrics (
      "task_id" VARCHAR(150) GENERATED ALWAYS AS (JQ_STRING("value", '.taskId')),
      "execution_id" VARCHAR(150) NOT NULL GENERATED ALWAYS AS (JQ_STRING("value", '.executionId')),
      "taskrun_id" VARCHAR(150) GENERATED ALWAYS AS (JQ_STRING("value", '.taskRunId')),
+     "metric_name" VARCHAR(150) GENERATED ALWAYS AS (JQ_STRING("value", '.name')),
      "timestamp" TIMESTAMP NOT NULL GENERATED ALWAYS AS (PARSEDATETIME(JQ_STRING("value", '.timestamp'), 'yyyy-MM-dd''T''HH:mm:ss.SSS''Z'''))
 );
 

diff --git a/jdbc-mysql/src/main/resources/migrations/mysql/V6__metrics.sql b/jdbc-mysql/src/main/resources/migrations/mysql/V6__metrics.sql
@@ -23,6 +23,7 @@ CREATE TABLE metrics (
     `task_id` VARCHAR(150) GENERATED ALWAYS AS (value ->> '$.taskId') STORED,
     `execution_id` VARCHAR(150) GENERATED ALWAYS AS (value ->> '$.executionId') STORED NOT NULL,
     `taskrun_id` VARCHAR(150) GENERATED ALWAYS AS (value ->> '$.taskRunId') STORED,
+    `metric_name` VARCHAR(150) GENERATED ALWAYS AS (value ->> '$.name') STORED,
     `timestamp` DATETIME(6) GENERATED ALWAYS AS (STR_TO_DATE(value ->> '$.timestamp' , '%Y-%m-%dT%H:%i:%s.%fZ')) STORED NOT NULL,
     INDEX ix_metrics_flow_id (deleted, namespace, flow_id),
     INDEX ix_metrics_execution_id (deleted, execution_id),

diff --git a/jdbc-postgres/src/main/resources/migrations/postgres/V7__metrics.sql b/jdbc-postgres/src/main/resources/migrations/postgres/V7__metrics.sql
@@ -10,6 +10,7 @@ CREATE TABLE metrics (
     task_id VARCHAR(150) NOT NULL GENERATED ALWAYS AS (value ->> 'taskId') STORED,
     execution_id VARCHAR(150) NOT NULL GENERATED ALWAYS AS (value ->> 'executionId') STORED,
     taskrun_id VARCHAR(150) NOT NULL GENERATED ALWAYS AS (value ->> 'taskRunId') STORED,
+    metric_name VARCHAR(150) NOT NULL GENERATED ALWAYS AS (value ->> 'name') STORED,
     timestamp TIMESTAMPTZ NOT NULL GENERATED ALWAYS AS (PARSE_ISO8601_DATETIME(value ->> 'timestamp')) STORED
 );