Skip to content

Commit bd33efd

Browse files
authored
Merge pull request #32 from oxford-pharmacoepi/Dev_mk1
Adding TABLESPACES to HES_APC Scripts
2 parents 1e2e4ed + ba127dd commit bd33efd

3 files changed

+14
-15
lines changed

sql_scripts/4f_hesapc_map_tbl_chunk.sql

+8-9
Original file line numberDiff line numberDiff line change
@@ -4,22 +4,22 @@ CREATE SCHEMA IF NOT EXISTS {CHUNK_SCHEMA};
44
--------------------------------
55
DROP TABLE IF EXISTS {CHUNK_SCHEMA}.chunk_person;
66

7-
CREATE TABLE {CHUNK_SCHEMA}.chunk_person AS
7+
CREATE TABLE {CHUNK_SCHEMA}.chunk_person TABLESPACE pg_default AS
88
select (floor((row_number() over (order by person_id)-1)/{CHUNK_SIZE}) + 1)::int as chunk_id,
99
person_id
1010
FROM {TARGET_SCHEMA}.person
1111
order by chunk_id, person_id;
1212

13-
ALTER TABLE {CHUNK_SCHEMA}.chunk_person ADD CONSTRAINT pk_chunk_person PRIMARY KEY (chunk_id, person_id);
14-
CREATE UNIQUE INDEX idx_chunk_person_id ON {CHUNK_SCHEMA}.chunk_person (chunk_id, person_id ASC);
13+
ALTER TABLE {CHUNK_SCHEMA}.chunk_person ADD CONSTRAINT pk_chunk_person PRIMARY KEY (chunk_id, person_id) USING INDEX TABLESPACE pg_default;
14+
CREATE UNIQUE INDEX idx_chunk_person_id ON {CHUNK_SCHEMA}.chunk_person (chunk_id, person_id ASC) TABLESPACE pg_default;
1515
CLUSTER {CHUNK_SCHEMA}.chunk_person USING idx_chunk_person_id;
1616

1717
--------------------------------
1818
-- CHUNK
1919
--------------------------------
2020
DROP TABLE IF EXISTS {CHUNK_SCHEMA}.chunk;
2121

22-
CREATE TABLE {CHUNK_SCHEMA}.chunk AS
22+
CREATE TABLE {CHUNK_SCHEMA}.chunk TABLESPACE pg_default AS
2323
SELECT distinct chunk_id,
2424
null::varchar(20) as stem_source_tbl,
2525
null::varchar(20) as stem_tbl,
@@ -28,10 +28,10 @@ SELECT distinct chunk_id,
2828
0::smallint as completed
2929
FROM {CHUNK_SCHEMA}.chunk_person;
3030

31-
ALTER TABLE {CHUNK_SCHEMA}.chunk ADD CONSTRAINT pk_chunk PRIMARY KEY (chunk_id);
32-
CREATE UNIQUE INDEX idx_chunk_id ON {CHUNK_SCHEMA}.chunk (chunk_id ASC);
31+
ALTER TABLE {CHUNK_SCHEMA}.chunk ADD CONSTRAINT pk_chunk PRIMARY KEY (chunk_id) USING INDEX TABLESPACE pg_default;
32+
CREATE UNIQUE INDEX idx_chunk_id ON {CHUNK_SCHEMA}.chunk (chunk_id ASC) TABLESPACE pg_default;
3333
CLUSTER {CHUNK_SCHEMA}.chunk USING idx_chunk_id;
34-
CREATE INDEX idx_chunk_completed ON {CHUNK_SCHEMA}.chunk (completed);
34+
CREATE INDEX idx_chunk_completed ON {CHUNK_SCHEMA}.chunk (completed) TABLESPACE pg_default;
3535

3636
--------------------------------
3737
-- _RECORDS
@@ -42,8 +42,7 @@ create table {TARGET_SCHEMA}._records (
4242
{TARGET_SCHEMA}_records bigint DEFAULT 0,
4343
{TARGET_SCHEMA}_nok_records bigint DEFAULT 0,
4444
total_records bigint DEFAULT 0
45-
);
46-
45+
) TABLESPACE pg_default;
4746

4847
--------------------------------
4948
-- DROP TABLES CREATED BY CHUNKING

sql_scripts/4g_hesapc_map_tbl_stem_source.sql

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
--insert into temp table from hes_diagnosis_epi
2-
CREATE TABLE {CHUNK_SCHEMA}.stem_source_{CHUNK_ID} (LIKE {TARGET_SCHEMA}.STEM_SOURCE);
2+
CREATE TABLE {CHUNK_SCHEMA}.stem_source_{CHUNK_ID} (LIKE {TARGET_SCHEMA}.STEM_SOURCE) TABLESPACE pg_default;
33

44
WITH cte0 as (
55
select person_id
@@ -182,7 +182,7 @@ inner join {TARGET_SCHEMA}.visit_detail as t3 on t1.person_id = t3.person_id and
182182
LEFT JOIN cte3 AS t4 ON t1.person_id = t4.person_id and t1.visit_detail_source_value = t4.visit_detail_source_value
183183
WHERE t3.visit_detail_concept_id = 9201; --Only visit records coming from hes_episodes
184184

185-
create index idx_stem_source_{CHUNK_ID} on {CHUNK_SCHEMA}.stem_source_{CHUNK_ID} (source_concept_id);
185+
create index idx_stem_source_{CHUNK_ID} on {CHUNK_SCHEMA}.stem_source_{CHUNK_ID} (source_concept_id) TABLESPACE pg_default;
186186

187187
-----------------------------------------
188188
-- UPDATE CHUNK

sql_scripts/4h_hesapc_map_tbl_stem.sql

+4-4
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
--drop index if exists {TARGET_SCHEMA}.idx_procedure_visit_id; -- NOT SURE WHERE THE PROCEDURE_OCCURRENCE TABLE IS USED ??
88
--
99

10-
CREATE TABLE {CHUNK_SCHEMA}.stem_{CHUNK_ID} (LIKE {TARGET_SCHEMA}.STEM);
10+
CREATE TABLE {CHUNK_SCHEMA}.stem_{CHUNK_ID} (LIKE {TARGET_SCHEMA}.STEM) TABLESPACE pg_default;
1111

1212
--insert into stem from stem_source, this is the vocab mapping portion
1313
with t as (
@@ -64,9 +64,9 @@ insert into {CHUNK_SCHEMA}.stem_{CHUNK_ID} (domain_id, person_id, visit_occurren
6464
anatomic_site_source_value, disease_status_source_value, modifier_concept_id, stem_source_table, stem_source_id)
6565
select * from t;
6666

67-
ALTER TABLE {CHUNK_SCHEMA}.stem_{CHUNK_ID} ADD CONSTRAINT pk_stem_{CHUNK_ID} PRIMARY KEY (id);
68-
create index idx_stem_domain_id_{CHUNK_ID} on {CHUNK_SCHEMA}.stem_{CHUNK_ID} (domain_id, visit_occurrence_id);
69-
create index idx_stem_unit_source_value_{CHUNK_ID} on {CHUNK_SCHEMA}.stem_{CHUNK_ID} (unit_source_value);
67+
ALTER TABLE {CHUNK_SCHEMA}.stem_{CHUNK_ID} ADD CONSTRAINT pk_stem_{CHUNK_ID} PRIMARY KEY (id) USING INDEX TABLESPACE pg_default;
68+
create index idx_stem_domain_id_{CHUNK_ID} on {CHUNK_SCHEMA}.stem_{CHUNK_ID} (domain_id, visit_occurrence_id) TABLESPACE pg_default;
69+
create index idx_stem_unit_source_value_{CHUNK_ID} on {CHUNK_SCHEMA}.stem_{CHUNK_ID} (unit_source_value) TABLESPACE pg_default;
7070

7171

7272
-----------------------------------------

0 commit comments

Comments
 (0)