Introduced `condenser_get_account_reputations` SQL function

hive/db/schema.py

@@ -590,7 +590,8 @@ def setup(db):
       "condenser_get_names_by_followers.sql",
       "condenser_get_names_by_following.sql",
       "condenser_get_names_by_reblogged.sql",
-      "condenser_get_discussions_by_comments.sql"
+      "condenser_get_discussions_by_comments.sql",
+      "condenser_get_account_reputations.sql"
 
     ]
     from os.path import dirname, realpath

hive/db/sql_scripts/condenser_get_account_reputations.sql

+DROP FUNCTION IF EXISTS condenser_get_account_reputations;
+
+CREATE OR REPLACE FUNCTION condenser_get_account_reputations(
+  in _account_lower_bound VARCHAR,
+  in _without_lower_bound BOOLEAN,
+  in _limit INTEGER
+)
+RETURNS TABLE
+(
+    name hive_accounts.name%TYPE,
+    reputation hive_accounts.reputation%TYPE
+)
+AS
+$function$
+DECLARE
+
+BEGIN
+
+    RETURN QUERY SELECT
+      ha.name, ha.reputation
+    FROM hive_accounts ha
+    WHERE _without_lower_bound OR ( ha.name >= _account_lower_bound )
+    ORDER BY name
+    LIMIT _limit;
+
+END
+$function$
+language plpgsql STABLE;

hive/server/condenser_api/methods.py

@@ -92,15 +92,8 @@ async def get_account_reputations(context, account_lower_bound: str = None, limi
 async def _get_account_reputations_impl(db, fat_node_style, account_lower_bound, limit):
     """Enumerate account reputations."""
     limit = valid_limit(limit, 1000, None)
-    seek = ''
-    if account_lower_bound:
-        seek = "WHERE name >= :start"
-
-    sql = """SELECT name, reputation
-              FROM hive_accounts %s
-           ORDER BY name
-              LIMIT :limit""" % seek
 
+    sql = "SELECT * FROM condenser_get_account_reputations( '{}', {}, {} )".format( account_lower_bound, account_lower_bound is None, limit )
     rows = await db.query_all(sql, start=account_lower_bound, limit=limit)
     if fat_node_style:
         return [dict(account=r[0], reputation=r[1]) for r in rows]