IT-3448: procedure to simplify listing file downloaders

synapse_data_warehouse/synapse/procs/R2.13.0__add_list_downloaders.sql

@@ -0,0 +1,41 @@
+CREATE OR REPLACE PROCEDURE list_downloaders(start_record_date string, entity_list string)
+RETURNS TABLE (user_id integer, user_name varchar, email varchar, synapse_profile varchar, num_downloads integer, earliest_download_time timestamp, latest_download_time timestamp)
+LANGUAGE SQL
+AS
+declare
+    rs resultset;
+    query_str1 varchar default (
+    'with recursive filetree (parent_id, id, node_type) as (
+    select null as parent_id, id, node_type
+    from node_latest
+    where id in (' || :entity_list || ')
+    union all
+    select fc.parent_id, fc.id, fc.node_type
+    from node_latest fc
+    join filetree ft on ft.id = fc.parent_id   
+    ),');
+    query_str2 varchar default    
+    'download (user_id, timestamp, entity_id) as (
+    select fd.user_id, fd.timestamp, fd.association_object_id as entity_id
+    from filedownload fd
+    join filetree ft on ft.id = fd.association_object_id
+    where fd.association_object_type = ''FileEntity''
+        and ft.node_type = ''file''
+        and fd.record_date >= ''' ||:start_record_date|| '''
+    ),';
+    query_str3 varchar default
+    'download_summary (user_id, c, min_t, max_t) as (
+    select user_id, count(*) as c, min(timestamp) as min_t, max(timestamp) as max_t
+    from download
+    group by user_id
+    )';
+    query_str4 varchar default
+    'select fds.user_id, up.user_name, up.email, concat(\'https://www.synapse.org/#!Profile:\', fds.user_id) as synapse_profile, fds.c as num_downloads, fds.min_t as earliest_download_time, fds.max_t as latest_download_time
+    from download_summary fds
+    join userprofile_latest up on up.id=fds.user_id
+    order by fds.min_t, fds.user_id';
+    query_str varchar default (:query_str1 || :query_str2 || :query_str3 || :query_str4);
+begin
+    rs := (EXECUTE IMMEDIATE :query_str);
+    return table(rs);
+end;