File: //lib/python2.7/site-packages/leapp/utils/audit/contextclone.pyc
�
g��fc @ sn d d l m Z m Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z
d d
� Z d S( i����( t dict_factoryt get_connectionc c sY | j d j d | � | f � } t | _ x% t rQ | j � } | sI Pn | Vq- W~ d S( Ns=
SELECT * FROM {table} WHERE context = ?
t table( t executet formatR t row_factoryt Truet fetchone( t dbR t contextt cursort row( ( sB /usr/lib/python2.7/site-packages/leapp/utils/audit/contextclone.pyt _fetch_table_for_context s c s& t � f d � | p � j � D� � S( Nc 3 s | ] } � | Vq d S( N( ( t .0t name( R ( sB /usr/lib/python2.7/site-packages/leapp/utils/audit/contextclone.pys <genexpr> s ( t tuplet keys( R t fields( ( R sB /usr/lib/python2.7/site-packages/leapp/utils/audit/contextclone.pyt
_row_tuple s c C sd i } xW t | d | � D]C } t | d d � \ } } | j d | | f � } | j | | <q W| S( Nt hostt idt hostnames1 INSERT INTO host (context, hostname) VALUES(?, ?)( R R R t lastrowid( R t
newcontextt
oldcontextt lookupR t row_idR R
( ( sB /usr/lib/python2.7/site-packages/leapp/utils/audit/contextclone.pyt _dup_host s c C sz i } xm t | d | � D]Y } t | d d d d � \ } } } } | j d | | | | | f � }
|
j | | <q W| S( Nt data_sourceR t host_idt actort phasesK INSERT INTO data_source (context, host_id, actor, phase) VALUES(?, ?, ?, ?)( R R R R ( R R R R R R R R R R R
( ( sB /usr/lib/python2.7/site-packages/leapp/utils/audit/contextclone.pyt _dup_data_source s $ c
C s� i } x t | d | � D]k } t | d d d d d d � \ } } } } }
} | j d | | | | | |
| f � } | j | | <q W| S( Nt messageR t data_source_idt stampt topict typet message_data_hashsn INSERT INTO message (context, data_source_id, stamp, topic, type, message_data_hash) VALUES(?, ?, ?, ?, ?, ?)( R R R R (
R R R R R R R R" R# R$ t type_R& R
( ( sB /usr/lib/python2.7/site-packages/leapp/utils/audit/contextclone.pyt _dup_message+ s - c C s� i } x� t | d | � D]� } t | d d d d d d � \ } } } }
} } | d k rh | | } n | j d | | | | |
| | f � }
|
j | | <q W| S( Nt auditR t eventR# R" t
message_idt datasd INSERT INTO audit (context, event, stamp, data_source_id, message_id, data) VALUES(?, ?, ?, ?, ?, ?)( R R t NoneR R ( R R! R R R R R R R* R# R" R+ R, R
( ( sB /usr/lib/python2.7/site-packages/leapp/utils/audit/contextclone.pyt
_dup_audit9 s -
c C sa xZ t | d | � D]F } t | d d d d � \ } } } } | j d | | | | f � q Wd S( Nt entityR t kindR t
metadata_hashsJ INSERT INTO entity (context, kind, name, metadata_hash) VALUES(?, ?, ?, ?)( R R R ( R R R R R R0 R R1 ( ( sB /usr/lib/python2.7/site-packages/leapp/utils/audit/contextclone.pyt _dup_entityI s
$c C se x^ t | d | � D]J } t | d d d d � \ } } } } | j d | | | | | f � q Wd S( Nt dialogR t scopeR, R" sL INSERT INTO dialog (context, scope, data, data_source_id) VALUES(?, ?, ?, ?)( R R R ( R R R R R R R4 R, R" ( ( sB /usr/lib/python2.7/site-packages/leapp/utils/audit/contextclone.pyt _dup_dialogS s
$c C s� t | � �� } t d | d | d | � } t d | d | d | d | � } t d | d | d | d | � } t d | d | d | d | d | � t d | d | d | � t d | d | d | d | � Wd QXd S( NR R R R R R! ( R R R R( R. R2 R5 ( R R t use_dbR R R R! ( ( sB /usr/lib/python2.7/site-packages/leapp/utils/audit/contextclone.pyt
clone_context] s !!%N(
t leapp.utils.auditR R R R R R R( R. R2 R5 R- R7 ( ( ( sB /usr/lib/python2.7/site-packages/leapp/utils/audit/contextclone.pyt <module> s