sql_scripts.py

create_database = """
CREATE DATABASE adex_cache
    WITH
    OWNER = postgres
    ENCODING = 'UTF8'
    CONNECTION LIMIT = -1;
"""

drop_table_skyviews = """
   DROP TABLE IF EXISTS public.skyviews;
"""

create_table_skyviews = """
CREATE TABLE public.skyviews
(
    "id" SERIAL,
    "title" character varying(50),
    "observation" character varying(50),
    "beam" integer,
    "ra" double precision,
    "dec" double precision,
    "collection" character varying(50),
    "level" integer,
    "dataproduct_type" character varying(50),
    "dataproduct_subtype" character varying(50),
    "access_url" character varying(255),
    CONSTRAINT skyviews_pkey PRIMARY KEY (id)
);
"""


insert_into_skyviews = """
INSERT INTO public.skyviews
(
    title,
    observation,
    beam,
    ra,
    dec,
    collection,
    level,
    dataproduct_type,
    dataproduct_subtype,
    access_url) 
    VALUES (%s,%s,%s,%s,%s,%s,%s,%s,%s,%s)
"""

# todo: join with api_dataentity table to retrieve the name (which also holds the beam)
select_from_alta = """
SELECT 
"storageRef" as access_url, 
"RA" as ra, dec, 
"dataProductType" as dt, 
"dataProductSubType" as dst, 
"datasetID" as observation 
FROM api_dataproduct
"""