Edit File: sqlite_changelog.cpython-311.pyc
� 8�gh� � �R � d dl T d dlmZ G d� de� � Z G d� de� � ZdS )� )�*)� JSONFieldc � � e Zd Z e ed� � g�� � Z e� � Z e� � Z e � � Z e � � Z dS )� BaseChangeLogzDEFAULT CURRENT_TIMESTAMP)� constraintsN) �__name__� __module__� __qualname__� DateTimeField�SQL� timestamp� TextField�action�table� IntegerField� primary_keyr �changes� � �z/builddir/build/BUILD/imunify360-venv-2.6.0/opt/imunify360/venv/lib/python3.11/site-packages/playhouse/sqlite_changelog.pyr r sZ � � � � � � � �3�3�/J�+K�+K�*L�M�M�M�I� �Y�[�[�F� �I�K�K�E� �,�.�.�K��i�k�k�G�G�Gr r c �^ � e Zd ZeZdZdZdZd d�Zdd�Z dd�Z d � Z e d � � � Z dd �ZdS )� ChangeLoga� CREATE TRIGGER IF NOT EXISTS %(table)s_changes_%(action)s AFTER %(action)s ON %(table)s BEGIN INSERT INTO %(change_table)s ("action", "table", "primary_key", "changes") SELECT '%(action)s', '%(table)s', %(new_old)s."%(primary_key)s", "changes" FROM ( SELECT json_group_object( col, json_array( case when json_valid("oldval") then json("oldval") else "oldval" end, case when json_valid("newval") then json("newval") else "newval" end) ) AS "changes" FROM ( SELECT json_extract(value, '$[0]') as "col", json_extract(value, '$[1]') as "oldval", json_extract(value, '$[2]') as "newval" FROM json_each(json_array(%(column_array)s)) WHERE "oldval" IS NOT "newval" ) ); END;z3DROP TRIGGER IF EXISTS %(table)s_changes_%(action)s)�INSERT�UPDATE�DELETE� changelogc �" � || _ || _ d S �N)�db� table_name)�selfr r s r �__init__zChangeLog.__init__7 s � ����$����r Nc �, � g }|j j D ]q}|j r� |� |j |v r�|j }|sdnd|z }|sdnd|z } t |t � � r|rd| z } |rd|z }|� d|�d| �d|�d�� � �rd� |� � S ) N�NULLzNEW."%s"zOLD."%s"zjson(%s)z json_array('z', z, �)) �_meta� sorted_fieldsr �name� column_name� isinstancer �append�join) r! �model�use_old�use_new� skip_fields� col_array�field�column�new�olds r �_build_column_arrayz ChangeLog._build_column_array; s� � � � ��[�.� N� N�E�� � ���&�5�:��+D�+D���&�F� '�@�&�&�Z�&�-@�C� '�@�&�&�Z�&�-@�C��%��+�+� 3� �2�*�s�"2�C��2�*�s�"2�C� � � � �6�6�6�3�3�3���� L� M� M� M� M��y�y��#�#�#r c �� � || j v sJ �|dk }|dk }| � ||||� � }| j |j j ||dk rdnd|j j j || j d�z S )Nr r �NEW�OLD)r r �new_oldr � column_array� change_table)�_actionsr6 �templater& r r r) )r! r- r r0 r. r/ �colss r � trigger_sqlzChangeLog.trigger_sqlT s� � ��� �&�&�&�&��H�$���H�$���'�'��w���M�M���}��[�+� � &�(� 2� 2�u�u�� �;�2�>� � �O� -� -� -� -r c �F � || j v sJ �| j |j j |d�z S )N)r r )r= � drop_templater& r )r! r- r s r �drop_trigger_sqlzChangeLog.drop_trigger_sqla s: � ��� �&�&�&�&��!��[�+� �% � % � � r c �j � � t � d� � s G � fd�d� j � � }|� _ � j S )N�_changelog_modelc �. �� e Zd Z G � fd�d� � ZdS )�"ChangeLog.model.<locals>.ChangeLogc �, �� e Zd Z� j Z� j ZdS )�'ChangeLog.model.<locals>.ChangeLog.MetaN)r r r r �databaser �r! s �r �MetarI k s �� � � � � � #�w�H�!%� �J�J�Jr rL N)r r r rL rK s �r r rG j sG �� � � � � �1� 1� 1� 1� 1� 1� 1� 1� 1� 1� 1� 1r r )�hasattr� base_modelrE )r! r s ` r r- zChangeLog.modelg s_ �� ��t� /�0�0� .� 1� 1� 1� 1� 1� 1� 1�D�O� 1� 1� 1� %.�D� !��$�$r Tc �p � | j }|r|� � � t t |||f| j � � � � } |r6| D ]3\ } } | j � | � || � � � � �4| D ]8\ } } | r1| � || |� � } | j � | � � �9d S r ) r- � create_table�list�zipr= r � execute_sqlrC r@ )r! r- r0 �drop�insert�update�deleterP r �actions�_r �enabled�sqls r �installzChangeLog.installr s� � ��J� � � %� � "� "� $� $� $��s�F�F�F�3�T�]�C�C�D�D�� � J� $� J� J� ��6���#�#�D�$9�$9�%��$H�$H�I�I�I�I� &� )� )�O�G�V�� )��&�&�u�f�k�B�B����#�#�C�(�(�(�� )� )r )r r )NTTTTT)r r r r rN r> rB r= r" r6 r@ rC �propertyr- r\ r r r r r s� � � � � � � �J� �H�4 J�M�-�H�%� %� %� %�$� $� $� $�2 -� -� -� -� � � � �%� %� �X�%� BF�7;�)� )� )� )� )� )r r N)�peewee�playhouse.sqlite_extr �Modelr �objectr r r r �<module>rb s� �� � � � � *� *� *� *� *� *�� � � � �E� � � �s)� s)� s)� s)� s)�� s)� s)� s)� s)� s)r
Back to File Manager