SHA256
349 lines
17 KiB
PL/PgSQL
349 lines
17 KiB
PL/PgSQL
BEGIN;
|
|
|
|
-- v18: fast profile projection, effective social/voting statistics and qualified likes.
|
|
-- Source of truth remains users_params / connections_state / reactions_state / channel_names_state.
|
|
|
|
CREATE TABLE IF NOT EXISTS user_profile_state (
|
|
login TEXT PRIMARY KEY,
|
|
first_name TEXT NOT NULL DEFAULT '',
|
|
last_name TEXT NOT NULL DEFAULT '',
|
|
ava_ar TEXT NOT NULL DEFAULT '',
|
|
account_role TEXT,
|
|
shine_status TEXT,
|
|
updated_at_ms BIGINT NOT NULL DEFAULT 0
|
|
);
|
|
|
|
CREATE INDEX IF NOT EXISTS idx_user_profile_state_name
|
|
ON user_profile_state (LOWER(last_name), LOWER(first_name), LOWER(login));
|
|
|
|
ALTER TABLE user_stats_state
|
|
ADD COLUMN IF NOT EXISTS friends_count INTEGER NOT NULL DEFAULT 0 CHECK (friends_count >= 0),
|
|
ADD COLUMN IF NOT EXISTS primary_confirmations_received_count INTEGER NOT NULL DEFAULT 0 CHECK (primary_confirmations_received_count >= 0),
|
|
ADD COLUMN IF NOT EXISTS primary_confirmations_given_count INTEGER NOT NULL DEFAULT 0 CHECK (primary_confirmations_given_count >= 0),
|
|
ADD COLUMN IF NOT EXISTS shine_confirmations_received_count INTEGER NOT NULL DEFAULT 0 CHECK (shine_confirmations_received_count >= 0),
|
|
ADD COLUMN IF NOT EXISTS shine_confirmations_given_count INTEGER NOT NULL DEFAULT 0 CHECK (shine_confirmations_given_count >= 0);
|
|
|
|
ALTER TABLE message_stats
|
|
ADD COLUMN IF NOT EXISTS primary_likes_count INTEGER NOT NULL DEFAULT 0 CHECK (primary_likes_count >= 0),
|
|
ADD COLUMN IF NOT EXISTS shining_likes_count INTEGER NOT NULL DEFAULT 0 CHECK (shining_likes_count >= 0);
|
|
|
|
CREATE OR REPLACE FUNCTION shine_refresh_user_profile(p_login TEXT)
|
|
RETURNS VOID
|
|
LANGUAGE plpgsql
|
|
AS $$
|
|
DECLARE
|
|
v_first_name TEXT := '';
|
|
v_last_name TEXT := '';
|
|
v_ava_ar TEXT := '';
|
|
v_account_role TEXT := NULL;
|
|
v_shine TEXT := NULL;
|
|
v_updated BIGINT := 0;
|
|
BEGIN
|
|
IF p_login IS NULL OR btrim(p_login) = '' THEN RETURN; END IF;
|
|
|
|
SELECT COALESCE(MAX(value) FILTER (WHERE param = 'first_name'), ''),
|
|
COALESCE(MAX(value) FILTER (WHERE param = 'last_name'), ''),
|
|
COALESCE(MAX(value) FILTER (WHERE param = 'ava'), ''),
|
|
MAX(value) FILTER (WHERE param = 'account_role'),
|
|
MAX(value) FILTER (WHERE param = 'shine'),
|
|
COALESCE(MAX(time_ms), 0)
|
|
INTO v_first_name, v_last_name, v_ava_ar, v_account_role, v_shine, v_updated
|
|
FROM users_params
|
|
WHERE LOWER(login) = LOWER(p_login);
|
|
|
|
v_account_role := LOWER(BTRIM(COALESCE(v_account_role, '')));
|
|
IF v_account_role NOT IN ('primary', 'non_voting') THEN v_account_role := NULL; END IF;
|
|
|
|
v_shine := LOWER(BTRIM(COALESCE(v_shine, '')));
|
|
IF v_shine = 'yes' THEN v_shine := 'shining'; END IF; -- legacy compatibility
|
|
IF v_shine NOT IN ('shining', 'unknown', 'not_interested') THEN v_shine := NULL; END IF;
|
|
|
|
INSERT INTO user_profile_state(login, first_name, last_name, ava_ar, account_role, shine_status, updated_at_ms)
|
|
VALUES (p_login, v_first_name, v_last_name, v_ava_ar, v_account_role, v_shine, v_updated)
|
|
ON CONFLICT (login) DO UPDATE SET
|
|
first_name = EXCLUDED.first_name,
|
|
last_name = EXCLUDED.last_name,
|
|
ava_ar = EXCLUDED.ava_ar,
|
|
account_role = EXCLUDED.account_role,
|
|
shine_status = EXCLUDED.shine_status,
|
|
updated_at_ms = EXCLUDED.updated_at_ms;
|
|
END;
|
|
$$;
|
|
|
|
CREATE OR REPLACE FUNCTION shine_is_primary(p_login TEXT)
|
|
RETURNS BOOLEAN
|
|
LANGUAGE sql
|
|
STABLE
|
|
AS $$
|
|
SELECT COALESCE((SELECT account_role = 'primary' FROM user_profile_state WHERE LOWER(login)=LOWER(p_login) LIMIT 1), FALSE)
|
|
$$;
|
|
|
|
CREATE OR REPLACE FUNCTION shine_is_shining(p_login TEXT)
|
|
RETURNS BOOLEAN
|
|
LANGUAGE sql
|
|
STABLE
|
|
AS $$
|
|
SELECT COALESCE((SELECT shine_status = 'shining' FROM user_profile_state WHERE LOWER(login)=LOWER(p_login) LIMIT 1), FALSE)
|
|
$$;
|
|
|
|
CREATE OR REPLACE FUNCTION shine_target_accepts_primary_confirmation(p_login TEXT)
|
|
RETURNS BOOLEAN
|
|
LANGUAGE sql
|
|
STABLE
|
|
AS $$
|
|
SELECT COALESCE((SELECT account_role IS DISTINCT FROM 'non_voting' FROM user_profile_state WHERE LOWER(login)=LOWER(p_login) LIMIT 1), TRUE)
|
|
$$;
|
|
|
|
CREATE OR REPLACE FUNCTION shine_target_accepts_shine_confirmation(p_login TEXT)
|
|
RETURNS BOOLEAN
|
|
LANGUAGE sql
|
|
STABLE
|
|
AS $$
|
|
SELECT COALESCE((SELECT shine_status IS DISTINCT FROM 'not_interested' FROM user_profile_state WHERE LOWER(login)=LOWER(p_login) LIMIT 1), TRUE)
|
|
$$;
|
|
|
|
CREATE OR REPLACE FUNCTION shine_refresh_user_stats(p_login TEXT)
|
|
RETURNS VOID
|
|
LANGUAGE plpgsql
|
|
AS $$
|
|
DECLARE
|
|
v_now BIGINT := CAST(EXTRACT(EPOCH FROM clock_timestamp()) * 1000 AS BIGINT);
|
|
BEGIN
|
|
IF p_login IS NULL OR btrim(p_login) = '' THEN RETURN; END IF;
|
|
|
|
INSERT INTO user_stats_state(login, owned_public_channels_count, following_users_count,
|
|
following_channels_count, close_friends_count, friends_count,
|
|
primary_confirmations_received_count, primary_confirmations_given_count,
|
|
shine_confirmations_received_count, shine_confirmations_given_count, updated_at_ms)
|
|
SELECT p_login,
|
|
(SELECT COUNT(*)::INT FROM channel_names_state cn WHERE LOWER(cn.owner_login)=LOWER(p_login) AND cn.channel_type_code=1),
|
|
0,
|
|
(SELECT COUNT(*)::INT FROM connections_state cs JOIN channel_names_state cn
|
|
ON cn.owner_bch_name=cs.to_bch_name AND cn.channel_root_block_number=cs.to_block_number AND cn.channel_root_block_hash=cs.to_block_hash
|
|
WHERE LOWER(cs.login)=LOWER(p_login) AND cs.rel_type=30 AND cn.channel_type_code=1),
|
|
(SELECT COUNT(DISTINCT LOWER(cs.to_login))::INT FROM connections_state cs WHERE LOWER(cs.login)=LOWER(p_login) AND cs.rel_type=10),
|
|
(SELECT COUNT(DISTINCT LOWER(cs.to_login))::INT FROM connections_state cs
|
|
WHERE LOWER(cs.login)=LOWER(p_login) AND cs.rel_type=14
|
|
AND NOT EXISTS (SELECT 1 FROM connections_state cf WHERE LOWER(cf.login)=LOWER(p_login) AND LOWER(cf.to_login)=LOWER(cs.to_login) AND cf.rel_type=10)),
|
|
(SELECT COUNT(DISTINCT LOWER(cs.login))::INT FROM connections_state cs
|
|
WHERE LOWER(cs.to_login)=LOWER(p_login) AND cs.rel_type=80
|
|
AND shine_is_primary(cs.login) AND shine_target_accepts_primary_confirmation(p_login)),
|
|
(SELECT COUNT(DISTINCT LOWER(cs.to_login))::INT FROM connections_state cs
|
|
WHERE LOWER(cs.login)=LOWER(p_login) AND cs.rel_type=80
|
|
AND shine_is_primary(p_login) AND shine_target_accepts_primary_confirmation(cs.to_login)),
|
|
(SELECT COUNT(DISTINCT LOWER(cs.login))::INT FROM connections_state cs
|
|
WHERE LOWER(cs.to_login)=LOWER(p_login) AND cs.rel_type=70
|
|
AND shine_is_primary(cs.login) AND shine_is_shining(cs.login) AND shine_target_accepts_shine_confirmation(p_login)),
|
|
(SELECT COUNT(DISTINCT LOWER(cs.to_login))::INT FROM connections_state cs
|
|
WHERE LOWER(cs.login)=LOWER(p_login) AND cs.rel_type=70
|
|
AND shine_is_primary(p_login) AND shine_is_shining(p_login) AND shine_target_accepts_shine_confirmation(cs.to_login)),
|
|
v_now
|
|
ON CONFLICT (login) DO UPDATE SET
|
|
owned_public_channels_count=EXCLUDED.owned_public_channels_count,
|
|
following_users_count=0,
|
|
following_channels_count=EXCLUDED.following_channels_count,
|
|
close_friends_count=EXCLUDED.close_friends_count,
|
|
friends_count=EXCLUDED.friends_count,
|
|
primary_confirmations_received_count=EXCLUDED.primary_confirmations_received_count,
|
|
primary_confirmations_given_count=EXCLUDED.primary_confirmations_given_count,
|
|
shine_confirmations_received_count=EXCLUDED.shine_confirmations_received_count,
|
|
shine_confirmations_given_count=EXCLUDED.shine_confirmations_given_count,
|
|
updated_at_ms=EXCLUDED.updated_at_ms;
|
|
END;
|
|
$$;
|
|
|
|
CREATE OR REPLACE FUNCTION shine_refresh_related_user_stats(p_login TEXT)
|
|
RETURNS VOID
|
|
LANGUAGE plpgsql
|
|
AS $$
|
|
DECLARE r RECORD;
|
|
BEGIN
|
|
PERFORM shine_refresh_user_stats(p_login);
|
|
FOR r IN
|
|
SELECT DISTINCT x.login FROM (
|
|
SELECT cs.login FROM connections_state cs WHERE LOWER(cs.to_login)=LOWER(p_login) AND cs.rel_type IN (70,80)
|
|
UNION
|
|
SELECT cs.to_login AS login FROM connections_state cs WHERE LOWER(cs.login)=LOWER(p_login) AND cs.rel_type IN (70,80)
|
|
) x
|
|
LOOP
|
|
PERFORM shine_refresh_user_stats(r.login);
|
|
END LOOP;
|
|
END;
|
|
$$;
|
|
|
|
CREATE OR REPLACE FUNCTION shine_refresh_message_qualified_likes_for_actor(p_login TEXT)
|
|
RETURNS VOID
|
|
LANGUAGE plpgsql
|
|
AS $$
|
|
DECLARE r RECORD;
|
|
BEGIN
|
|
FOR r IN
|
|
SELECT DISTINCT rs.to_login, rs.to_bch_name, rs.to_block_number, rs.to_block_hash
|
|
FROM reactions_state rs
|
|
WHERE LOWER(rs.from_login)=LOWER(p_login) AND rs.reaction_type=1 AND rs.last_sub_type=1
|
|
LOOP
|
|
UPDATE message_stats ms SET
|
|
primary_likes_count=(SELECT COUNT(*)::INT FROM reactions_state x WHERE x.reaction_type=1 AND x.last_sub_type=1
|
|
AND x.to_login=r.to_login AND x.to_bch_name=r.to_bch_name AND x.to_block_number=r.to_block_number AND x.to_block_hash=r.to_block_hash
|
|
AND shine_is_primary(x.from_login)),
|
|
shining_likes_count=(SELECT COUNT(*)::INT FROM reactions_state x WHERE x.reaction_type=1 AND x.last_sub_type=1
|
|
AND x.to_login=r.to_login AND x.to_bch_name=r.to_bch_name AND x.to_block_number=r.to_block_number AND x.to_block_hash=r.to_block_hash
|
|
AND shine_is_primary(x.from_login) AND shine_is_shining(x.from_login))
|
|
WHERE ms.to_login=r.to_login AND ms.to_bch_name=r.to_bch_name AND ms.to_block_number=r.to_block_number AND ms.to_block_hash=r.to_block_hash;
|
|
END LOOP;
|
|
END;
|
|
$$;
|
|
|
|
|
|
CREATE OR REPLACE FUNCTION shine_refresh_channel_follow_stats(p_bch_name TEXT, p_block_number INTEGER, p_block_hash BYTEA)
|
|
RETURNS VOID
|
|
LANGUAGE plpgsql
|
|
AS $$
|
|
DECLARE
|
|
v_owner_login TEXT;
|
|
v_channel_type INTEGER;
|
|
v_count INTEGER := 0;
|
|
v_now BIGINT := CAST(EXTRACT(EPOCH FROM clock_timestamp()) * 1000 AS BIGINT);
|
|
BEGIN
|
|
IF p_bch_name IS NULL OR p_block_number IS NULL OR p_block_hash IS NULL OR p_block_number <= 0 THEN RETURN; END IF;
|
|
|
|
SELECT cn.owner_login, cn.channel_type_code
|
|
INTO v_owner_login, v_channel_type
|
|
FROM channel_names_state cn
|
|
WHERE cn.owner_bch_name=p_bch_name
|
|
AND cn.channel_root_block_number=p_block_number
|
|
AND cn.channel_root_block_hash=p_block_hash
|
|
LIMIT 1;
|
|
|
|
IF v_channel_type IS NULL THEN RETURN; END IF;
|
|
|
|
SELECT COUNT(DISTINCT LOWER(cs.login))::INT
|
|
INTO v_count
|
|
FROM connections_state cs
|
|
WHERE cs.rel_type=30
|
|
AND cs.to_bch_name=p_bch_name
|
|
AND cs.to_block_number=p_block_number
|
|
AND cs.to_block_hash=p_block_hash;
|
|
|
|
INSERT INTO channel_stats_state(owner_bch_name,channel_root_block_number,channel_root_block_hash,owner_login,channel_type_code,subscribers_count,updated_at_ms)
|
|
VALUES(p_bch_name,p_block_number,p_block_hash,COALESCE(v_owner_login,''),v_channel_type,v_count,v_now)
|
|
ON CONFLICT(owner_bch_name,channel_root_block_number,channel_root_block_hash) DO UPDATE SET
|
|
owner_login=EXCLUDED.owner_login,
|
|
channel_type_code=EXCLUDED.channel_type_code,
|
|
subscribers_count=EXCLUDED.subscribers_count,
|
|
updated_at_ms=EXCLUDED.updated_at_ms;
|
|
END;
|
|
$$;
|
|
|
|
-- Replace incremental channel-name counter with idempotent recomputation.
|
|
CREATE OR REPLACE FUNCTION shine_channel_names_state_stats_ai()
|
|
RETURNS TRIGGER
|
|
LANGUAGE plpgsql
|
|
AS $$
|
|
BEGIN
|
|
IF NEW.channel_type_code = 1 THEN
|
|
PERFORM shine_refresh_user_stats(NEW.owner_login);
|
|
END IF;
|
|
RETURN NEW;
|
|
END;
|
|
$$;
|
|
|
|
-- Rebuild connection state without incremental user counters; then recompute affected users.
|
|
CREATE OR REPLACE FUNCTION shine_blocks_connection_state_ai()
|
|
RETURNS TRIGGER
|
|
LANGUAGE plpgsql
|
|
AS $$
|
|
DECLARE
|
|
resolved_login TEXT;
|
|
positive_rel_type INTEGER;
|
|
BEGIN
|
|
IF NEW.msg_type <> 3 THEN RETURN NEW; END IF;
|
|
resolved_login := shine_resolve_login(NEW.to_login, NEW.to_bch_name);
|
|
IF resolved_login IS NULL OR NEW.to_bch_name IS NULL THEN RETURN NEW; END IF;
|
|
|
|
IF NEW.msg_sub_type IN (10,14,20,30,40,50,52,54,60,70,74,80) THEN
|
|
DELETE FROM connections_state WHERE login=NEW.login AND rel_type=NEW.msg_sub_type AND to_login=resolved_login
|
|
AND to_bch_name=NEW.to_bch_name AND to_block_number=COALESCE(NEW.to_block_number,0)
|
|
AND to_block_hash=COALESCE(NEW.to_block_hash,decode(repeat('00',32),'hex'));
|
|
INSERT INTO connections_state(login,rel_type,to_login,to_bch_name,to_block_number,to_block_hash)
|
|
VALUES(NEW.login,NEW.msg_sub_type,resolved_login,NEW.to_bch_name,COALESCE(NEW.to_block_number,0),COALESCE(NEW.to_block_hash,decode(repeat('00',32),'hex')));
|
|
ELSE
|
|
positive_rel_type := CASE NEW.msg_sub_type WHEN 11 THEN 10 WHEN 15 THEN 14 WHEN 21 THEN 20 WHEN 31 THEN 30 WHEN 41 THEN 40
|
|
WHEN 51 THEN 50 WHEN 53 THEN 52 WHEN 55 THEN 54 WHEN 61 THEN 60 WHEN 71 THEN 70 WHEN 75 THEN 74 WHEN 81 THEN 80 ELSE NULL END;
|
|
IF positive_rel_type IS NULL THEN RETURN NEW; END IF;
|
|
DELETE FROM connections_state WHERE login=NEW.login AND rel_type=positive_rel_type AND to_login=resolved_login
|
|
AND to_bch_name=NEW.to_bch_name AND to_block_number=COALESCE(NEW.to_block_number,0)
|
|
AND to_block_hash=COALESCE(NEW.to_block_hash,decode(repeat('00',32),'hex'));
|
|
END IF;
|
|
|
|
PERFORM shine_refresh_user_stats(NEW.login);
|
|
PERFORM shine_refresh_user_stats(resolved_login);
|
|
IF NEW.msg_sub_type IN (30,31) AND NEW.to_block_number IS NOT NULL AND NEW.to_block_number > 0 AND NEW.to_block_hash IS NOT NULL THEN
|
|
PERFORM shine_refresh_channel_follow_stats(NEW.to_bch_name, NEW.to_block_number, NEW.to_block_hash);
|
|
END IF;
|
|
RETURN NEW;
|
|
END;
|
|
$$;
|
|
|
|
CREATE OR REPLACE FUNCTION shine_blocks_message_stats_like_ai()
|
|
RETURNS TRIGGER
|
|
LANGUAGE plpgsql
|
|
AS $$
|
|
DECLARE previous_sub_type INTEGER;
|
|
BEGIN
|
|
IF NEW.msg_type<>2 OR NEW.msg_sub_type NOT IN (1,2) THEN RETURN NEW; END IF;
|
|
IF NEW.to_login IS NULL OR NEW.to_bch_name IS NULL OR NEW.to_block_number IS NULL OR NEW.to_block_hash IS NULL THEN RETURN NEW; END IF;
|
|
|
|
INSERT INTO message_stats(to_login,to_bch_name,to_block_number,to_block_hash,likes_count,primary_likes_count,shining_likes_count,replies_count,edits_count)
|
|
VALUES(NEW.to_login,NEW.to_bch_name,NEW.to_block_number,NEW.to_block_hash,0,0,0,0,0)
|
|
ON CONFLICT(to_login,to_bch_name,to_block_number,to_block_hash) DO NOTHING;
|
|
|
|
SELECT last_sub_type INTO previous_sub_type FROM reactions_state WHERE from_login=NEW.login AND from_bch_name=NEW.bch_name AND reaction_type=1
|
|
AND to_login=NEW.to_login AND to_bch_name=NEW.to_bch_name AND to_block_number=NEW.to_block_number AND to_block_hash=NEW.to_block_hash LIMIT 1;
|
|
|
|
IF NEW.msg_sub_type=1 AND previous_sub_type IS DISTINCT FROM 1 THEN
|
|
UPDATE message_stats SET likes_count=likes_count+1,
|
|
primary_likes_count=primary_likes_count + CASE WHEN shine_is_primary(NEW.login) THEN 1 ELSE 0 END,
|
|
shining_likes_count=shining_likes_count + CASE WHEN shine_is_primary(NEW.login) AND shine_is_shining(NEW.login) THEN 1 ELSE 0 END
|
|
WHERE to_login=NEW.to_login AND to_bch_name=NEW.to_bch_name AND to_block_number=NEW.to_block_number AND to_block_hash=NEW.to_block_hash;
|
|
ELSIF NEW.msg_sub_type=2 AND previous_sub_type=1 THEN
|
|
UPDATE message_stats SET likes_count=GREATEST(0,likes_count-1),
|
|
primary_likes_count=GREATEST(0,primary_likes_count - CASE WHEN shine_is_primary(NEW.login) THEN 1 ELSE 0 END),
|
|
shining_likes_count=GREATEST(0,shining_likes_count - CASE WHEN shine_is_primary(NEW.login) AND shine_is_shining(NEW.login) THEN 1 ELSE 0 END)
|
|
WHERE to_login=NEW.to_login AND to_bch_name=NEW.to_bch_name AND to_block_number=NEW.to_block_number AND to_block_hash=NEW.to_block_hash;
|
|
END IF;
|
|
|
|
INSERT INTO reactions_state(from_login,from_bch_name,reaction_type,to_login,to_bch_name,to_block_number,to_block_hash,last_sub_type)
|
|
VALUES(NEW.login,NEW.bch_name,1,NEW.to_login,NEW.to_bch_name,NEW.to_block_number,NEW.to_block_hash,NEW.msg_sub_type)
|
|
ON CONFLICT(from_login,from_bch_name,reaction_type,to_login,to_bch_name,to_block_number,to_block_hash) DO UPDATE SET last_sub_type=EXCLUDED.last_sub_type;
|
|
RETURN NEW;
|
|
END;
|
|
$$;
|
|
|
|
-- Initial projection/rebuild.
|
|
DO $$ DECLARE r RECORD; BEGIN
|
|
FOR r IN SELECT DISTINCT login FROM users_params LOOP PERFORM shine_refresh_user_profile(r.login); END LOOP;
|
|
END $$;
|
|
DO $$ DECLARE r RECORD; BEGIN
|
|
FOR r IN SELECT login FROM solana_user_pda_current LOOP PERFORM shine_refresh_user_stats(r.login); END LOOP;
|
|
END $$;
|
|
DO $$ DECLARE r RECORD; BEGIN
|
|
FOR r IN SELECT owner_bch_name, channel_root_block_number, channel_root_block_hash FROM channel_names_state WHERE channel_type_code=1 LOOP
|
|
PERFORM shine_refresh_channel_follow_stats(r.owner_bch_name, r.channel_root_block_number, r.channel_root_block_hash);
|
|
END LOOP;
|
|
END $$;
|
|
|
|
UPDATE message_stats ms SET
|
|
primary_likes_count=(SELECT COUNT(*)::INT FROM reactions_state rs WHERE rs.reaction_type=1 AND rs.last_sub_type=1
|
|
AND rs.to_login=ms.to_login AND rs.to_bch_name=ms.to_bch_name AND rs.to_block_number=ms.to_block_number AND rs.to_block_hash=ms.to_block_hash
|
|
AND shine_is_primary(rs.from_login)),
|
|
shining_likes_count=(SELECT COUNT(*)::INT FROM reactions_state rs WHERE rs.reaction_type=1 AND rs.last_sub_type=1
|
|
AND rs.to_login=ms.to_login AND rs.to_bch_name=ms.to_bch_name AND rs.to_block_number=ms.to_block_number AND rs.to_block_hash=ms.to_block_hash
|
|
AND shine_is_primary(rs.from_login) AND shine_is_shining(rs.from_login));
|
|
|
|
INSERT INTO db_schema_version(id,schema_version,updated_at_ms)
|
|
VALUES(1,18,CAST(EXTRACT(EPOCH FROM clock_timestamp())*1000 AS BIGINT))
|
|
ON CONFLICT(id) DO UPDATE SET schema_version=EXCLUDED.schema_version, updated_at_ms=EXCLUDED.updated_at_ms;
|
|
|
|
COMMIT;
|