ds_provider_postgresql_py_lib.utils.dataset_identity
====================================================

.. py:module:: ds_provider_postgresql_py_lib.utils.dataset_identity

.. autoapi-nested-parse::

   **File:** ``dataset_identity.py``
   **Region:** ``ds_provider_postgresql_py_lib/utils/dataset_identity``

   Dataset Identity Helpers

   This module contains identity-column validation helpers used by dataset
   mutation operations.



Functions
---------

.. autoapisummary::

   ds_provider_postgresql_py_lib.utils.dataset_identity.validate_identity_columns
   ds_provider_postgresql_py_lib.utils.dataset_identity.validate_duplicate_identity_rows


Module Contents
---------------

.. py:function:: validate_identity_columns(table: sqlalchemy.Table, identity_columns: collections.abc.Sequence[str], content: pandas.DataFrame) -> None

   Ensure identity columns exist in both input and target table.

   :param table: Reflected SQLAlchemy table.
   :param identity_columns: Identity columns used for matching.
   :param content: Input DataFrame.

   :returns: None

   :raises ValidationError: If identity configuration is invalid.


.. py:function:: validate_duplicate_identity_rows(content: pandas.DataFrame, identity_columns: collections.abc.Sequence[str]) -> None

   Ensure input does not contain duplicate identity values.

   :param content: Input DataFrame.
   :param identity_columns: Identity columns used for matching.

   :returns: None

   :raises ValidationError: If duplicate identity rows are found.