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

[ Date: 2025-12-04 00:04:36 - 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 "6d59fc82f808209524d479af084700bf" on "genasis5".lims."genasish" using btree (_airbyte_emitted_at);

[ Date: 2025-12-04 00:04:36 - 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-12-04 02:45:41 - 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-12-04 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-12-04 02:45:53 - 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-12-04 01:01:53 - Database: genasis5 - 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-12-04 02:45:15 - 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-12-04 01:01:16 - 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-12-04 02:45:29 - Database: genasis4 - 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-12-04 01:01:29 - Database: genasis4 - User: postgres - Remote: 127.0.0.1 - Application: pg_dump ]

/* {"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 );