/* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "node_id": "model.airbyte_utils.genasish"} */ create index if not exists "ac605722d1448a59682518c1149f95ca" on "genasis5".lims."genasish" using btree (_airbyte_emitted_at);

[ Date: 2025-11-27 00:05:27 - Database: genasis5 - User: genadmin_user - Remote: 10.16.50.5 - Application: dbt ]

/* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "node_id": "model.airbyte_utils.genasish"} */ create index if not exists "ac605722d1448a59682518c1149f95ca" on "genasis5".lims."genasish" using btree (_airbyte_emitted_at);

[ Date: 2025-11-27 00:05:27 - Database: genasis5 - User: genadmin_user - Remote: 10.16.50.5 - Application: dbt ]

COPY core.value (id, sample_id, analysis_method_id, prepare_method_id, transformation_method_id, import_batch_id, value_xml, unit_id, original_unit_id, value_origin_type_id, recalc_id, parameter_id, acl_group_id, acl_owner_id, pghist_user_id, is_archived, updated_at, value, loq, lod) TO stdout;

[ Date: 2025-11-27 02:45:58 - Database: genasis4 - User: postgres - Remote: 127.0.0.1 - Application: pg_dump ]

COPY core.value (id, sample_id, analysis_method_id, prepare_method_id, transformation_method_id, import_batch_id, value_xml, unit_id, original_unit_id, value_origin_type_id, recalc_id, parameter_id, acl_group_id, acl_owner_id, pghist_user_id, is_archived, updated_at, value, loq, lod) TO stdout;

[ Date: 2025-11-27 01:01:42 - Database: genasis4 - User: postgres - Remote: 127.0.0.1 - Application: pg_dump ]

COPY core.value (id, sample_id, analysis_method_id, prepare_method_id, transformation_method_id, import_batch_id, unit_id, original_unit_id, value_origin_type_id, parameter_id, updated_at, value, loq, lod, created_at, created_by, updated_by, recalc_type) TO stdout;

[ Date: 2025-11-27 01:01:54 - Database: genasis5 - User: postgres - Remote: 127.0.0.1 - Application: pg_dump ]

COPY core.value (id, sample_id, analysis_method_id, prepare_method_id, transformation_method_id, import_batch_id, unit_id, original_unit_id, value_origin_type_id, parameter_id, updated_at, value, loq, lod, created_at, created_by, updated_by, recalc_type) TO stdout;

[ Date: 2025-11-27 02:46:12 - Database: genasis5 - User: postgres - Remote: 127.0.0.1 - Application: pg_dump ]

COPY core.import_buffer (id, order_no, "row", pghist_user_id, is_archived, valid_result_type_id, resource_id) TO stdout;

[ Date: 2025-11-27 02:45:45 - Database: genasis4 - User: postgres - Remote: 127.0.0.1 - Application: pg_dump ]

COPY air_sensor.data (id, document_context_id, date, inquire_household_id, temp, rh, co2, pm25, pm10, pm1, tvocs, ach, inquire_sensor_id) TO stdout;

[ Date: 2025-11-27 02:45:27 - Database: data_extractor - User: postgres - Remote: 127.0.0.1 - Application: pg_dump ]

COPY air_sensor.data (id, document_context_id, date, inquire_household_id, temp, rh, co2, pm25, pm10, pm1, tvocs, ach, inquire_sensor_id) TO stdout;

[ Date: 2025-11-27 01:01:17 - Database: data_extractor - User: postgres - Remote: 127.0.0.1 - Application: pg_dump ]

COPY core.import_buffer (id, order_no, "row", pghist_user_id, is_archived, valid_result_type_id, resource_id) TO stdout;

[ Date: 2025-11-27 01:01:30 - Database: genasis4 - User: postgres - Remote: 127.0.0.1 - Application: pg_dump ]

with import_data as ( SELECT id, rank() OVER (ORDER BY id ASC) AS row, sampling_start_year, sampling_start_month, sampling_start_day, sampling_end_year, sampling_end_month, sampling_end_day, sampling_method_code FROM core.import_buffer WHERE resource_id = '3299' ), import_data_reduced as ( SELECT id, row, sampling_start_year, sampling_start_month, sampling_start_day FROM import_data WHERE (sampling_end_year IS NULL AND (sampling_method_code NOT ILIKE 'AIR_%' OR sampling_method_code NOT ILIKE 'WAT_PASIVNI_%')) OR (sampling_end_month IS NULL AND (sampling_method_code NOT ILIKE 'AIR_%' OR sampling_method_code NOT ILIKE 'WAT_PASIVNI_%')) OR (sampling_end_day IS NULL AND (sampling_method_code NOT ILIKE 'AIR_%' OR sampling_method_code NOT ILIKE 'WAT_PASIVNI_%')) ), lims_data as ( SELECT ib.id, gh.vzorekid, gh.parametrid FROM core.import_buffer ib LEFT JOIN lims.import_control ic ON (ib.import_batch_id = ic.import_batch_id) LEFT JOIN lims.genasisv gv ON (gv.zakazka = genasisv_zakazka AND gv.rok = genasisv_rok) LEFT JOIN lims.genasish gh ON (gv."ID" = gh.vzorekid) WHERE ib.resource_id = '3299' AND ib.parameter_code = gh.parametrid AND ib.code_tmp_sample = gh.vzorekid ), import_data_clear as ( SELECT idr.id as import_buffer_id, idr.row, vzorekid, parametrid, sampling_start_year, sampling_start_month, sampling_start_day FROM import_data_reduced idr LEFT JOIN lims_data ON (idr.id = lims_data.id)) UPDATE core.import_buffer ib SET sampling_end_year = imc.sampling_start_year, sampling_end_month = imc.sampling_start_month, sampling_end_day = imc.sampling_start_day FROM import_data_clear imc WHERE ib.id = imc.import_buffer_id RETURNING imc.row, imc.vzorekid, imc.parametrid;

[ Date: 2025-11-27 04:30:29 - Database: genasis5 - User: genadmin_user - Remote: 147.251.71.20 - Application: [unknown] - Bind query: yes ]

/* {"app": "dbt", "dbt_version": "1.0.0", "profile_name": "normalize", "target_name": "prod", "node_id": "model.airbyte_utils.genasish"} */ create table "genasis5".lims."genasish__dbt_tmp" as ( with __dbt__cte__genasish_ab1 as ( -- SQL model to parse JSON blob stored in a single column and extract into separated field columns as described by the JSON Schema -- depends_on: "genasis5".lims._airbyte_raw_genasish select jsonb_extract_path_text(_airbyte_data, 'STANOVIL' ) as stanovil, jsonb_extract_path_text(_airbyte_data, 'VZOREKID' ) as vzorekid, jsonb_extract_path_text(_airbyte_data, 'PARAMETRID' ) as parametrid, jsonb_extract_path_text(_airbyte_data, 'ANALYSISMETHODID' ) as analysismethodid, jsonb_extract_path_text(_airbyte_data, 'NEJISTOTA' ) as nejistota, jsonb_extract_path_text(_airbyte_data, 'DATUMSTAN' ) as datumstan, jsonb_extract_path_text(_airbyte_data, 'HODNOTA' ) as hodnota, jsonb_extract_path_text(_airbyte_data, 'PRIZNAK' ) as priznak, jsonb_extract_path_text(_airbyte_data, 'JEDNOTKA' ) as jednotka, jsonb_extract_path_text(_airbyte_data, 'LOQ' ) as loq, _airbyte_ab_id, _airbyte_emitted_at, now() as _airbyte_normalized_at from "genasis5".lims._airbyte_raw_genasish as table_alias -- genasish where 1 = 1), __dbt__cte__genasish_ab2 as ( -- SQL model to cast each column to its adequate SQL type converted from the JSON schema type -- depends_on: __dbt__cte__genasish_ab1 select cast(stanovil as text ) as stanovil, cast(vzorekid as float ) as vzorekid, cast(parametrid as text ) as parametrid, cast(analysismethodid as text ) as analysismethodid, cast(nejistota as text ) as nejistota, cast(datumstan as text ) as datumstan, cast(hodnota as float ) as hodnota, cast(priznak as text ) as priznak, cast(jednotka as text ) as jednotka, cast(loq as float ) as loq, _airbyte_ab_id, _airbyte_emitted_at, now() as _airbyte_normalized_at from __dbt__cte__genasish_ab1 -- genasish where 1 = 1), __dbt__cte__genasish_ab3 as ( -- SQL model to build a hash column based on the values of this record -- depends_on: __dbt__cte__genasish_ab2 select md5(cast(coalesce(cast(stanovil as text), '') || '-' || coalesce(cast(vzorekid as text), '') || '-' || coalesce(cast(parametrid as text), '') || '-' || coalesce(cast(analysismethodid as text), '') || '-' || coalesce(cast(nejistota as text), '') || '-' || coalesce(cast(datumstan as text), '') || '-' || coalesce(cast(hodnota as text), '') || '-' || coalesce(cast(priznak as text), '') || '-' || coalesce(cast(jednotka as text), '') || '-' || coalesce(cast(loq as text), '') as text) ) as _airbyte_genasish_hashid, tmp.* from __dbt__cte__genasish_ab2 tmp -- genasish where 1 = 1) -- Final base SQL model -- depends_on: __dbt__cte__genasish_ab3 select stanovil, vzorekid, parametrid, analysismethodid, nejistota, datumstan, hodnota, priznak, jednotka, loq, _airbyte_ab_id, _airbyte_emitted_at, now() as _airbyte_normalized_at, _airbyte_genasish_hashid from __dbt__cte__genasish_ab3 -- genasish from "genasis5".lims._airbyte_raw_genasish where 1 = 1 );