Commit 0b0085ad authored by Massimo Costantini's avatar Massimo Costantini
Browse files

Extracted the transit query

parent 97a3b4e8

IVOA.js

+1 −9
Original line number Diff line number Diff line
@@ -313,15 +313,7 @@ export const datalinkTransitsEndpoint = (req) => async (IO) => { 
  const sourceId = row.source_id;



  // SQL query to fetch transits for a given source_id

  const sql = `

    SELECT a.file_name, c.source_id, a.transit_id, a.ac_win_coord,

           to_char(a.transit_time AT TIME ZONE 'UTC', 'YYYY-MM-DD HH24:MI:SS.US') as transit_time,

           c.did_name, c.key_name

    FROM gaia.astroelementary a

    JOIN gaia.crossmatch c ON a.transit_id = c.transit_id

    WHERE c.source_id = $1;

  `;



  const sql = await readFile("Query/transits.sql")(IO);

  const conn = await connPostgreSQL()(IO);

  const result = await fetchQueryResult(conn, sql, [sourceId])(IO);

  await quitPostgreSQL(conn)(IO);

IVOA.py

+1 −9
Original line number Diff line number Diff line
@@ -342,17 +342,9 @@ def ivoa_transits_endpoint(req) -> Callable[[object], Awaitable[str]]: 
        source_id = row_data.get("source_id")



        # SQL query to fetch transits for a given source_id

        query = """

            SELECT a.file_name, c.source_id, a.transit_id, a.ac_win_coord,

                   to_char(a.transit_time AT TIME ZONE 'UTC', 'YYYY-MM-DD HH24:MI:SS.US') as transit_time,

                   c.did_name, c.key_name

            FROM gaia.astroelementary a

            JOIN gaia.crossmatch c ON a.transit_id = c.transit_id

            WHERE c.source_id = $1;

        """

        query = await read_file("Query/transits.sql")(io)

        conn = await conn_postgresql()(io)

        result_query = await fetch_query_result(conn, query, [int(source_id)])(io)



        await quit_postgresql(conn)(io)



        if result_query["tag"] == "nothing":

Query/transits.sql

0 → 100644
+6 −0
Original line number Diff line number Diff line 
SELECT a.file_name, c.source_id, a.transit_id, a.ac_win_coord,

       to_char(a.transit_time AT TIME ZONE 'UTC', 'YYYY-MM-DD HH24:MI:SS.US') as transit_time,

       c.did_name, c.key_name

FROM gaia.astroelementary a

JOIN gaia.crossmatch c ON a.transit_id = c.transit_id

WHERE c.source_id = $1;