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;