Merge pull request #3046 from YevhenBondarenko/feature/uuid-update

Feature/UUID update

application/src/main/data/upgrade/3.0.1/schema_update_to_uuid.sql

@@ -33,9 +33,794 @@ BEGIN
                             ) + (
                                 (((get_byte(bytes, 6)::bigint & 15) << 8 | get_byte(bytes, 7)::bigint) & 4095) << 48
                             ) - 122192928000000000
-                    ) / 10000::double precision
+                ) / 10000::double precision;
-        ;
 END
 $$ LANGUAGE plpgsql
-    IMMUTABLE PARALLEL SAFE
+    IMMUTABLE
+    PARALLEL SAFE
     RETURNS NULL ON NULL INPUT;
+
+
+CREATE OR REPLACE FUNCTION column_type_to_uuid(table_name varchar, column_name varchar) RETURNS VOID
+    LANGUAGE plpgsql AS
+$$
+BEGIN
+    execute format('ALTER TABLE %s RENAME COLUMN %s TO old_%s;', table_name, column_name, column_name);
+    execute format('ALTER TABLE %s ADD COLUMN %s UUID;', table_name, column_name);
+    execute format('UPDATE %s SET %s = to_uuid(old_%s) WHERE old_%s is not null;', table_name, column_name, column_name, column_name);
+    execute format('ALTER TABLE %s DROP COLUMN old_%s;', table_name, column_name);
+END;
+$$;
+
+CREATE OR REPLACE FUNCTION get_column_type(table_name varchar, column_name varchar, OUT data_type varchar) RETURNS varchar
+    LANGUAGE plpgsql AS
+$$
+BEGIN
+    execute (format('SELECT data_type from information_schema.columns where table_name = %L and column_name = %L',
+                    table_name, column_name)) INTO data_type;
+END;
+$$;
+
+
+CREATE OR REPLACE PROCEDURE drop_all_idx()
+    LANGUAGE plpgsql AS
+$$
+BEGIN
+    DROP INDEX IF EXISTS idx_alarm_originator_alarm_type;
+    DROP INDEX IF EXISTS idx_event_type_entity_id;
+    DROP INDEX IF EXISTS idx_relation_to_id;
+    DROP INDEX IF EXISTS idx_relation_from_id;
+    DROP INDEX IF EXISTS idx_device_customer_id;
+    DROP INDEX IF EXISTS idx_device_customer_id_and_type;
+    DROP INDEX IF EXISTS idx_device_type;
+    DROP INDEX IF EXISTS idx_asset_customer_id;
+    DROP INDEX IF EXISTS idx_asset_customer_id_and_type;
+    DROP INDEX IF EXISTS idx_asset_type;
+END;
+$$;
+
+CREATE OR REPLACE PROCEDURE create_all_idx()
+    LANGUAGE plpgsql AS
+$$
+BEGIN
+    CREATE INDEX IF NOT EXISTS idx_alarm_originator_alarm_type ON alarm(originator_id, type, start_ts DESC);
+    CREATE INDEX IF NOT EXISTS idx_event_type_entity_id ON event(tenant_id, event_type, entity_type, entity_id);
+    CREATE INDEX IF NOT EXISTS idx_relation_to_id ON relation(relation_type_group, to_type, to_id);
+    CREATE INDEX IF NOT EXISTS idx_relation_from_id ON relation(relation_type_group, from_type, from_id);
+    CREATE INDEX IF NOT EXISTS idx_device_customer_id ON device(tenant_id, customer_id);
+    CREATE INDEX IF NOT EXISTS idx_device_customer_id_and_type ON device(tenant_id, customer_id, type);
+    CREATE INDEX IF NOT EXISTS idx_device_type ON device(tenant_id, type);
+    CREATE INDEX IF NOT EXISTS idx_asset_customer_id ON asset(tenant_id, customer_id);
+    CREATE INDEX IF NOT EXISTS idx_asset_customer_id_and_type ON asset(tenant_id, customer_id, type);
+    CREATE INDEX IF NOT EXISTS idx_asset_type ON asset(tenant_id, type);
+END;
+$$;
+
+
+-- admin_settings
+CREATE OR REPLACE PROCEDURE update_admin_settings()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'admin_settings';
+    column_id  varchar := 'id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE admin_settings DROP CONSTRAINT admin_settings_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE admin_settings ADD CONSTRAINT admin_settings_pkey PRIMARY KEY (id);
+        ALTER TABLE admin_settings ADD COLUMN created_time BIGINT;
+        UPDATE admin_settings SET created_time = extract_ts(id) WHERE id is not null;
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+END;
+$$;
+
+
+-- alarm
+CREATE OR REPLACE PROCEDURE update_alarm()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'alarm';
+    column_id  varchar := 'id';
+    column_originator_id varchar := 'originator_id';
+    column_tenant_id varchar := 'tenant_id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE alarm DROP CONSTRAINT alarm_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE alarm ADD COLUMN created_time BIGINT;
+        UPDATE alarm SET created_time = extract_ts(id) WHERE id is not null;
+        ALTER TABLE alarm ADD CONSTRAINT alarm_pkey PRIMARY KEY (id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_originator_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_originator_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_originator_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_originator_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_tenant_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_tenant_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_tenant_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_tenant_id;
+    END IF;
+END;
+$$;
+
+
+-- asset
+CREATE OR REPLACE PROCEDURE update_asset()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'asset';
+    column_id  varchar := 'id';
+    column_customer_id varchar := 'customer_id';
+    column_tenant_id varchar := 'tenant_id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE asset DROP CONSTRAINT asset_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE asset ADD COLUMN created_time BIGINT;
+        UPDATE asset SET created_time = extract_ts(id) WHERE id is not null;
+        ALTER TABLE asset ADD CONSTRAINT asset_pkey PRIMARY KEY (id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_customer_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_customer_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_customer_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_customer_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_tenant_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE asset DROP CONSTRAINT asset_name_unq_key;
+        PERFORM column_type_to_uuid(table_name, column_tenant_id);
+        ALTER TABLE asset ADD CONSTRAINT asset_name_unq_key UNIQUE (tenant_id, name);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_tenant_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_tenant_id;
+    END IF;
+    END;
+$$;
+
+-- attribute_kv
+CREATE OR REPLACE PROCEDURE update_attribute_kv()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'attribute_kv';
+    column_entity_id  varchar := 'entity_id';
+BEGIN
+    data_type := get_column_type(table_name, column_entity_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE attribute_kv DROP CONSTRAINT attribute_kv_pkey;
+        PERFORM column_type_to_uuid(table_name, column_entity_id);
+        ALTER TABLE attribute_kv ADD CONSTRAINT attribute_kv_pkey PRIMARY KEY (entity_type, entity_id, attribute_type, attribute_key);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_entity_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_entity_id;
+    END IF;
+END;
+$$;
+
+-- audit_log
+CREATE OR REPLACE PROCEDURE update_audit_log()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'audit_log';
+    column_id  varchar := 'id';
+    column_customer_id varchar := 'customer_id';
+    column_tenant_id varchar := 'tenant_id';
+    column_entity_id varchar := 'entity_id';
+    column_user_id varchar := 'user_id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE audit_log DROP CONSTRAINT audit_log_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE audit_log ADD COLUMN created_time BIGINT;
+        UPDATE audit_log SET created_time = extract_ts(id) WHERE id is not null;
+        ALTER TABLE audit_log ADD CONSTRAINT audit_log_pkey PRIMARY KEY (id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_customer_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_customer_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_customer_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_customer_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_tenant_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_tenant_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_tenant_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_tenant_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_entity_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_entity_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_entity_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_entity_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_user_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_user_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_user_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_user_id;
+    END IF;
+END;
+$$;
+
+
+-- component_descriptor
+CREATE OR REPLACE PROCEDURE update_component_descriptor()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'component_descriptor';
+    column_id  varchar := 'id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE component_descriptor DROP CONSTRAINT component_descriptor_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE component_descriptor ADD CONSTRAINT component_descriptor_pkey PRIMARY KEY (id);
+        ALTER TABLE component_descriptor ADD COLUMN created_time BIGINT;
+        UPDATE component_descriptor SET created_time = extract_ts(id) WHERE id is not null;
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+END;
+$$;
+
+-- customer
+CREATE OR REPLACE PROCEDURE update_customer()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'customer';
+    column_id  varchar := 'id';
+    column_tenant_id  varchar := 'tenant_id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE customer DROP CONSTRAINT customer_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE customer ADD CONSTRAINT customer_pkey PRIMARY KEY (id);
+        ALTER TABLE customer ADD COLUMN created_time BIGINT;
+        UPDATE customer SET created_time = extract_ts(id) WHERE id is not null;
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_tenant_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_tenant_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_tenant_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_tenant_id;
+    END IF;
+END;
+$$;
+
+
+-- dashboard
+CREATE OR REPLACE PROCEDURE update_dashboard()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'dashboard';
+    column_id  varchar := 'id';
+    column_tenant_id  varchar := 'tenant_id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE dashboard DROP CONSTRAINT dashboard_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE dashboard ADD CONSTRAINT dashboard_pkey PRIMARY KEY (id);
+        ALTER TABLE dashboard ADD COLUMN created_time BIGINT;
+        UPDATE dashboard SET created_time = extract_ts(id) WHERE id is not null;
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_tenant_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_tenant_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_tenant_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_tenant_id;
+    END IF;
+END;
+$$;
+
+-- device
+CREATE OR REPLACE PROCEDURE update_device()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'device';
+    column_id  varchar := 'id';
+    column_customer_id varchar := 'customer_id';
+    column_tenant_id varchar := 'tenant_id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE device DROP CONSTRAINT device_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE device ADD COLUMN created_time BIGINT;
+        UPDATE device SET created_time = extract_ts(id) WHERE id is not null;
+        ALTER TABLE device ADD CONSTRAINT device_pkey PRIMARY KEY (id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_customer_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_customer_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_customer_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_customer_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_tenant_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE device DROP CONSTRAINT device_name_unq_key;
+        PERFORM column_type_to_uuid(table_name, column_tenant_id);
+        ALTER TABLE device ADD CONSTRAINT device_name_unq_key UNIQUE (tenant_id, name);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_tenant_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_tenant_id;
+    END IF;
+END;
+$$;
+
+
+-- device_credentials
+CREATE OR REPLACE PROCEDURE update_device_credentials()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'device_credentials';
+    column_id  varchar := 'id';
+    column_device_id varchar := 'device_id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE device_credentials DROP CONSTRAINT device_credentials_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE device_credentials ADD COLUMN created_time BIGINT;
+        UPDATE device_credentials SET created_time = extract_ts(id) WHERE id is not null;
+        ALTER TABLE device_credentials ADD CONSTRAINT device_credentials_pkey PRIMARY KEY (id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_device_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_device_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_device_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_device_id;
+    END IF;
+END;
+$$;
+
+
+-- event
+CREATE OR REPLACE PROCEDURE update_event()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'event';
+    column_id  varchar := 'id';
+    column_entity_id varchar := 'entity_id';
+    column_tenant_id varchar := 'tenant_id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE event DROP CONSTRAINT event_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE event ADD COLUMN created_time BIGINT;
+        UPDATE event SET created_time = extract_ts(id) WHERE id is not null;
+        ALTER TABLE event ADD CONSTRAINT event_pkey PRIMARY KEY (id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+
+    ALTER TABLE event DROP CONSTRAINT event_unq_key;
+
+    data_type := get_column_type(table_name, column_entity_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_entity_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_entity_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_entity_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_tenant_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_tenant_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_tenant_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_tenant_id;
+    END IF;
+
+    ALTER TABLE event ADD CONSTRAINT event_unq_key UNIQUE (tenant_id, entity_type, entity_id, event_type, event_uid);
+END;
+$$;
+
+
+-- relation
+CREATE OR REPLACE PROCEDURE update_relation()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'relation';
+    column_from_id varchar := 'from_id';
+    column_to_id varchar := 'to_id';
+BEGIN
+    ALTER TABLE relation DROP CONSTRAINT relation_pkey;
+
+    data_type := get_column_type(table_name, column_from_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_from_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_from_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_from_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_to_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_to_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_to_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_to_id;
+    END IF;
+
+    ALTER TABLE relation ADD CONSTRAINT relation_pkey PRIMARY KEY (from_id, from_type, relation_type_group, relation_type, to_id, to_type);
+END;
+$$;
+
+
+-- tb_user
+CREATE OR REPLACE PROCEDURE update_tb_user()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'tb_user';
+    column_id  varchar := 'id';
+    column_customer_id varchar := 'customer_id';
+    column_tenant_id varchar := 'tenant_id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE tb_user DROP CONSTRAINT tb_user_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE tb_user ADD COLUMN created_time BIGINT;
+        UPDATE tb_user SET created_time = extract_ts(id) WHERE id is not null;
+        ALTER TABLE tb_user ADD CONSTRAINT tb_user_pkey PRIMARY KEY (id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_customer_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_customer_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_customer_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_customer_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_tenant_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_tenant_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_tenant_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_tenant_id;
+    END IF;
+END;
+$$;
+
+
+-- tenant
+CREATE OR REPLACE PROCEDURE update_tenant()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'tenant';
+    column_id  varchar := 'id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE tenant DROP CONSTRAINT tenant_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE tenant ADD COLUMN created_time BIGINT;
+        UPDATE tenant SET created_time = extract_ts(id) WHERE id is not null;
+        ALTER TABLE tenant ADD CONSTRAINT tenant_pkey PRIMARY KEY (id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+END;
+$$;
+
+
+-- user_credentials
+CREATE OR REPLACE PROCEDURE update_user_credentials()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'user_credentials';
+    column_id  varchar := 'id';
+    column_user_id varchar := 'user_id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE user_credentials DROP CONSTRAINT user_credentials_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE user_credentials ADD COLUMN created_time BIGINT;
+        UPDATE user_credentials SET created_time = extract_ts(id) WHERE id is not null;
+        ALTER TABLE user_credentials ADD CONSTRAINT user_credentials_pkey PRIMARY KEY (id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_user_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE user_credentials DROP CONSTRAINT user_credentials_user_id_key;
+        ALTER TABLE user_credentials RENAME COLUMN user_id TO old_user_id;
+        ALTER TABLE user_credentials ADD COLUMN user_id UUID UNIQUE;
+        UPDATE user_credentials SET user_id = to_uuid(old_user_id) WHERE old_user_id is not null;
+        ALTER TABLE user_credentials DROP COLUMN old_user_id;
+        RAISE NOTICE 'Table % column % updated!', table_name, column_user_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_user_id;
+    END IF;
+END;
+$$;
+
+
+-- widget_type
+CREATE OR REPLACE PROCEDURE update_widget_type()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'widget_type';
+    column_id  varchar := 'id';
+    column_tenant_id varchar := 'tenant_id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE widget_type DROP CONSTRAINT widget_type_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE widget_type ADD COLUMN created_time BIGINT;
+        UPDATE widget_type SET created_time = extract_ts(id) WHERE id is not null;
+        ALTER TABLE widget_type ADD CONSTRAINT widget_type_pkey PRIMARY KEY (id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_tenant_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_tenant_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_tenant_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_tenant_id;
+    END IF;
+END;
+$$;
+
+
+-- widgets_bundle
+CREATE OR REPLACE PROCEDURE update_widgets_bundle()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'widgets_bundle';
+    column_id  varchar := 'id';
+    column_tenant_id varchar := 'tenant_id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE widgets_bundle DROP CONSTRAINT widgets_bundle_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE widgets_bundle ADD COLUMN created_time BIGINT;
+        UPDATE widgets_bundle SET created_time = extract_ts(id) WHERE id is not null;
+        ALTER TABLE widgets_bundle ADD CONSTRAINT widgets_bundle_pkey PRIMARY KEY (id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_tenant_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_tenant_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_tenant_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_tenant_id;
+    END IF;
+END;
+$$;
+
+
+-- rule_chain
+CREATE OR REPLACE PROCEDURE update_rule_chain()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'rule_chain';
+    column_id  varchar := 'id';
+    column_first_rule_node_id varchar := 'first_rule_node_id';
+    column_tenant_id varchar := 'tenant_id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE rule_chain DROP CONSTRAINT rule_chain_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE rule_chain ADD COLUMN created_time BIGINT;
+        UPDATE rule_chain SET created_time = extract_ts(id) WHERE id is not null;
+        ALTER TABLE rule_chain ADD CONSTRAINT rule_chain_pkey PRIMARY KEY (id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_first_rule_node_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_first_rule_node_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_first_rule_node_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_first_rule_node_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_tenant_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_tenant_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_tenant_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_tenant_id;
+    END IF;
+END;
+$$;
+
+
+-- rule_node
+CREATE OR REPLACE PROCEDURE update_rule_node()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'rule_node';
+    column_id  varchar := 'id';
+    column_rule_chain_id varchar := 'rule_chain_id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE rule_node DROP CONSTRAINT rule_node_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE rule_node ADD COLUMN created_time BIGINT;
+        UPDATE rule_node SET created_time = extract_ts(id) WHERE id is not null;
+        ALTER TABLE rule_node ADD CONSTRAINT rule_node_pkey PRIMARY KEY (id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_rule_chain_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_rule_chain_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_rule_chain_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_rule_chain_id;
+    END IF;
+END;
+$$;
+
+
+-- entity_view
+CREATE OR REPLACE PROCEDURE update_entity_view()
+    LANGUAGE plpgsql AS
+$$
+DECLARE
+    data_type  varchar;
+    table_name varchar := 'entity_view';
+    column_id  varchar := 'id';
+    column_entity_id varchar := 'entity_id';
+    column_tenant_id varchar := 'tenant_id';
+    column_customer_id varchar := 'customer_id';
+BEGIN
+    data_type := get_column_type(table_name, column_id);
+    IF data_type = 'character varying' THEN
+        ALTER TABLE entity_view DROP CONSTRAINT entity_view_pkey;
+        PERFORM column_type_to_uuid(table_name, column_id);
+        ALTER TABLE entity_view ADD COLUMN created_time BIGINT;
+        UPDATE entity_view SET created_time = extract_ts(id) WHERE id is not null;
+        ALTER TABLE entity_view ADD CONSTRAINT entity_view_pkey PRIMARY KEY (id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_entity_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_entity_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_entity_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_entity_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_tenant_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_tenant_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_tenant_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_tenant_id;
+    END IF;
+
+    data_type := get_column_type(table_name, column_customer_id);
+    IF data_type = 'character varying' THEN
+        PERFORM column_type_to_uuid(table_name, column_customer_id);
+        RAISE NOTICE 'Table % column % updated!', table_name, column_customer_id;
+    ELSE
+        RAISE NOTICE 'Table % column % already updated!', table_name, column_customer_id;
+    END IF;
+END;
+$$;

application/src/main/java/org/thingsboard/server/install/ThingsboardInstallService.java

@@ -159,6 +159,10 @@ public class ThingsboardInstallService {
                             log.info("Updating system data...");
                             systemDataLoaderService.updateSystemWidgets();
                             break;
+                        case "3.0.1":
+                            log.info("Upgrading ThingsBoard from version 3.0.1 to 3.1.0 ...");
+                            databaseEntitiesUpgradeService.upgradeDatabase("3.0.1");
+                            break;
                         default:
                             throw new RuntimeException("Unable to upgrade ThingsBoard, unsupported fromVersion: " + upgradeFromVersion);
 

application/src/main/java/org/thingsboard/server/service/install/SqlDatabaseUpgradeService.java

@@ -30,7 +30,11 @@ import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.sql.Connection;
 import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.SQLException;
 import java.sql.SQLSyntaxErrorException;
+import java.sql.SQLWarning;
+import java.sql.Statement;
 
 import static org.thingsboard.server.service.install.DatabaseHelper.ADDITIONAL_INFO;
 import static org.thingsboard.server.service.install.DatabaseHelper.ASSIGNED_CUSTOMERS;
@@ -183,18 +187,22 @@ public class SqlDatabaseUpgradeService implements DatabaseEntitiesUpgradeService
                     log.info("Updating schema ...");
                     try {
                         conn.createStatement().execute("ALTER TABLE asset ADD COLUMN label varchar(255)"); //NOSONAR, ignoring because method used to execute thingsboard database upgrade script
-                    } catch (Exception e) {}
+                    } catch (Exception e) {
+                    }
                     schemaUpdateFile = Paths.get(installScripts.getDataDir(), "upgrade", "2.4.2", SCHEMA_UPDATE_SQL);
                     loadSql(schemaUpdateFile, conn);
                     try {
                         conn.createStatement().execute("ALTER TABLE device ADD CONSTRAINT device_name_unq_key UNIQUE (tenant_id, name)"); //NOSONAR, ignoring because method used to execute thingsboard database upgrade script
-                    } catch (Exception e) {}
+                    } catch (Exception e) {
+                    }
                     try {
                         conn.createStatement().execute("ALTER TABLE device_credentials ADD CONSTRAINT device_credentials_id_unq_key UNIQUE (credentials_id)"); //NOSONAR, ignoring because method used to execute thingsboard database upgrade script
-                    } catch (Exception e) {}
+                    } catch (Exception e) {
+                    }
                     try {
                         conn.createStatement().execute("ALTER TABLE asset ADD CONSTRAINT asset_name_unq_key UNIQUE (tenant_id, name)"); //NOSONAR, ignoring because method used to execute thingsboard database upgrade script
-                    } catch (Exception e) {}
+                    } catch (Exception e) {
+                    }
                     log.info("Schema updated.");
                 }
                 break;
@@ -233,6 +241,58 @@ public class SqlDatabaseUpgradeService implements DatabaseEntitiesUpgradeService
                     log.info("Schema updated.");
                 }
                 break;
+            case "3.0.1":
+                try (Connection conn = DriverManager.getConnection(dbUrl, dbUserName, dbPassword)) {
+                    log.info("Updating schema ...");
+                    if (isOldSchema(conn, 3000001)) {
+                        String[] tables = new String[]{"admin_settings", "alarm", "asset", "audit_log", "attribute_kv",
+                                "component_descriptor", "customer", "dashboard", "device", "device_credentials", "event",
+                                "relation", "tb_user", "tenant", "user_credentials", "widget_type", "widgets_bundle",
+                                "rule_chain", "rule_node", "entity_view"};
+                        schemaUpdateFile = Paths.get(installScripts.getDataDir(), "upgrade", "3.0.1", "schema_update_to_uuid.sql");
+                        loadSql(schemaUpdateFile, conn);
+
+                        conn.createStatement().execute("call drop_all_idx()");
+
+                        for (String table : tables) {
+                            log.info("Updating table {}.", table);
+                            Statement statement = conn.createStatement();
+                            statement.execute("call update_" + table + "();");
+
+                            SQLWarning warnings = statement.getWarnings();
+                            if (warnings != null) {
+                                log.info("{}", warnings.getMessage());
+                                SQLWarning nextWarning = warnings.getNextWarning();
+                                while (nextWarning != null) {
+                                    log.info("{}", nextWarning.getMessage());
+                                    nextWarning = nextWarning.getNextWarning();
+                                }
+                            }
+
+                            conn.createStatement().execute("DROP PROCEDURE update_" + table);
+                            log.info("Table {} updated.", table);
+                        }
+                        conn.createStatement().execute("call create_all_idx()");
+
+                        conn.createStatement().execute("DROP PROCEDURE drop_all_idx");
+                        conn.createStatement().execute("DROP PROCEDURE create_all_idx");
+                        conn.createStatement().execute("DROP FUNCTION column_type_to_uuid");
+
+                        log.info("Updating alarm relations...");
+                        conn.createStatement().execute("DELETE from relation WHERE relation_type_group = 'ALARM' AND relation_type <> 'ALARM_ANY';");
+
+                        conn.createStatement().execute("UPDATE relation SET relation_type = 'ANY' WHERE relation_type_group = 'ALARM' AND relation_type = 'ALARM_ANY';");
+                        log.info("Alarm relations updated.");
+
+                        conn.createStatement().execute("UPDATE tb_schema_settings SET schema_version = 3001000;");
+
+                        conn.createStatement().execute("VACUUM FULL");
+                    }
+                    log.info("Schema updated.");
+                } catch (Exception e) {
+                    log.error("Failed updating schema!!!", e);
+                }
+                break;
             default:
                 throw new RuntimeException("Unable to upgrade SQL database, unsupported fromVersion: " + fromVersion);
         }
@@ -243,4 +303,24 @@ public class SqlDatabaseUpgradeService implements DatabaseEntitiesUpgradeService
         conn.createStatement().execute(sql); //NOSONAR, ignoring because method used to execute thingsboard database upgrade script
         Thread.sleep(5000);
     }
+
+    protected boolean isOldSchema(Connection conn, long fromVersion) {
+        boolean isOldSchema = true;
+        try {
+            Statement statement = conn.createStatement();
+            statement.execute("CREATE TABLE IF NOT EXISTS tb_schema_settings ( schema_version bigint NOT NULL, CONSTRAINT tb_schema_settings_pkey PRIMARY KEY (schema_version));");
+            Thread.sleep(1000);
+            ResultSet resultSet = statement.executeQuery("SELECT schema_version FROM tb_schema_settings;");
+            if (resultSet.next()) {
+                isOldSchema = resultSet.getLong(1) <= fromVersion;
+            } else {
+                resultSet.close();
+                statement.execute("INSERT INTO tb_schema_settings (schema_version) VALUES (" + fromVersion + ")");
+            }
+            statement.close();
+        } catch (InterruptedException | SQLException e) {
+            log.info("Failed to check current PostgreSQL schema due to: {}", e.getMessage());
+        }
+        return isOldSchema;
+    }
 }