Skip to content
Snippets Groups Projects
Commit d5e21b61 authored by Andrzej Lisak's avatar Andrzej Lisak
Browse files

[ABW]: it turns out old code actually did track ineffective (post-payout)... 

[ABW]: it turns out old code actually did track ineffective (post-payout) votes - changed upsert query to reflect that
parent 6c68b549
No related branches found
No related tags found
4 merge requests!456Release candidate v1 24,!230Setup monitoring with pghero,!135Enable postgres monitoring on CI server,!68Fixed result of inaccurate assumption
Hide whitespace changes
Inline Side-by-side
hive/indexer/votes.py
+ 22
− 28
View file @ d5e21b61
...@@ -90,34 +90,28 @@ class Votes: ...@@ -90,34 +90,28 @@ class Votes:
cls.inside_flush = True cls.inside_flush = True
if cls._votes_data: if cls._votes_data:
sql = """ sql = """
INSERT INTO hive_votes INSERT INTO hive_votes
(post_id, voter_id, author_id, permlink_id, weight, rshares, vote_percent, last_update) (post_id, voter_id, author_id, permlink_id, weight, rshares, vote_percent, last_update)
select data_source.post_id, data_source.voter_id, data_source.author_id, data_source.permlink_id, data_source.weight, data_source.rshares, data_source.vote_percent, data_source.last_update SELECT hp.id as post_id, ha_v.id as voter_id, ha_a.id as author_id, hpd_p.id as permlink_id, t.weight, t.rshares, t.vote_percent, t.last_update
from FROM
( (
SELECT hp.id as post_id, ha_v.id as voter_id, ha_a.id as author_id, hpd_p.id as permlink_id, t.weight, t.rshares, t.vote_percent, t.last_update VALUES
from -- voter, author, permlink, weight, rshares, vote_percent, last_update
( {}
VALUES ) AS T(voter, author, permlink, weight, rshares, vote_percent, last_update)
-- voter, author, permlink, weight, rshares, vote_percent, last_update INNER JOIN hive_accounts ha_v ON ha_v.name = t.voter
{} INNER JOIN hive_accounts ha_a ON ha_a.name = t.author
) AS T(voter, author, permlink, weight, rshares, vote_percent, last_update) INNER JOIN hive_permlink_data hpd_p ON hpd_p.permlink = t.permlink
INNER JOIN hive_accounts ha_v ON ha_v.name = t.voter INNER JOIN hive_posts hp ON hp.author_id = ha_a.id AND hp.permlink_id = hpd_p.id
INNER JOIN hive_accounts ha_a ON ha_a.name = t.author ON CONFLICT ON CONSTRAINT hive_votes_ux1 DO
INNER JOIN hive_permlink_data hpd_p ON hpd_p.permlink = t.permlink UPDATE
INNER JOIN hive_posts hp ON hp.author_id = ha_a.id AND hp.permlink_id = hpd_p.id SET
WHERE NOT hp.is_paidout weight = (CASE (SELECT hp.is_paidout FROM hive_posts hp WHERE hp.id = EXCLUDED.id) WHEN true THEN hive_votes.weight ELSE EXCLUDED.weight END),
) as data_source(post_id, voter_id, author_id, permlink_id, weight, rshares, vote_percent, last_update) rshares = (CASE (SELECT hp.is_paidout FROM hive_posts hp WHERE hp.id = EXCLUDED.id) WHEN true THEN hive_votes.rshares ELSE EXCLUDED.rshares END),
ON CONFLICT ON CONSTRAINT hive_votes_ux1 DO vote_percent = EXCLUDED.vote_percent,
UPDATE last_update = EXCLUDED.last_update,
SET num_changes = hive_votes.num_changes + 1
weight = EXCLUDED.weight, """
rshares = EXCLUDED.rshares,
vote_percent = EXCLUDED.vote_percent,
last_update = EXCLUDED.last_update,
num_changes = hive_votes.num_changes + 1
WHERE hive_votes.voter_id = EXCLUDED.voter_id and hive_votes.author_id = EXCLUDED.author_id and hive_votes.permlink_id = EXCLUDED.permlink_id;
"""
values = [] values = []
values_limit = 1000 values_limit = 1000
......
tests_api @ 779f69cf
Compare 113cb05c...779f69cf
Subproject commit 113cb05cc2dc35fe6e6e149fc3ecb8ae286d4cc4 Subproject commit 779f69cf2171b2dd6259cb6fc300cd3bea737edc
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment