@&dZddlmZddlmZddlmZddlZddlmZddlmZddl Z Gdd e Z e jejGd d ejZy) zA persistent cache metadata table implementation layer. Used by persistent cache implementations that maintain a metadata table to keep track of cache tables. )absolute_import)division)unicode_literalsN) exceptions)persistent_cache_basec0eZdZdZdZdZe ddZy)Metadataa@Metadata table row container. This object encapsulates the persistent metadata table row layout. Attributes: name: The table name. columns: The number of columns in the table. Must be >= 1. keys: The number of columns, starting from 0, that form the primary row key. Must be 1 <= keys <= columns. The primary key is used to differentiate rows in the AddRows and DeleteRows methods. timeout: A float number of seconds. Tables older than (modified+timeout) are invalid. 0 means no timeout. modified: Table modify Now() (time.time()) value. 0 for expired tables. restricted: True if Table is restricted. version: A caller defined version string that must match the version string stored when the persistent object was created. '' for all but the metadata table itself. ct|\|_|_|_|_|_}|_t ||_y)z+Constructs a metadata container from a row.N)namecolumnskeystimeoutmodifiedversionbool restricted)selfrowrs /lib/googlecloudsdk/core/cache/metadata_table.py__init__zMetadata.__init__8s3"%TY dit}:&DONc.| t|}|||||||fS)z:Constructs and returns a metadata table row from the args.)int)clsr r rrrrrs rRowz Metadata.Row>s(z?j '4(J HHr)NNNNNNN)__name__ __module__ __qualname____doc__COLUMNSr classmethodrrrr r "s/& '' ;?26IIrr ceZdZdZd fd Zej dZej dZej d dZ dZ dZ d dZ d Z dd ZxZS)CacheUsingMetadataTablea A persistent cache metadata table implementation layer. Attributes: _metadata: A table containing a row for each table. _table_class: The cache Table class. _restricted: The set of restricted table names. _tables: The map of open table objects. cltt| ||||d|_||_d|_d|_y)N)createrr)superr%r _metadata _table_class _restricted_tables)rtabler r'rr __class__s rrz CacheUsingMetadataTable.__init__Rs? !41 VWg2?DNDDDLrcyNr#rs rDeletezCacheUsingMetadataTable.DeleteZrcyr0r#r1s rCommitzCacheUsingMetadataTable.Commit^r3rcyr0r#)rcommits rClosezCacheUsingMetadataTable.Closebr3rcy)aZImplementation layer _CreateTable. The cache implementation object can override this method to do implementation specific table initialization. Args: name: The table name. columns: The number of columns in each row. keys: The number of columns, left to right, that are primary keys. 0 for all columns. Nr#)rr r rs r_ImplementationCreateTablez2CacheUsingMetadataTable._ImplementationCreateTablefs rc |d}|dkr0tjdj|j||||}|dks||kDr1tjdj|j|||| |j }|j ||||j|||||d|}|jrd}n||_|j|jtj|}|r|dnd} | rt| } |j| jxsd|_ ns|j| jk7rZtjd j|j| j|j| j|j|j | j |_d|_|j}|jj!tj|j|j"|j$|j |j|j&| g|S) aCreates and returns a table object for name. NOTE: This code is conditioned on self._metadata. If self._metadata is None then we are initializing/updating the metadata table. The table name is relaxed, in particular '_' is allowed in the table name. This avoids user table name conflicts. Finally, self._metadata is set and the metadata table row is updated to reflect any changes in the default timeout. Args: name: The table name. restricted: Return a restricted table object. columns: The number of columns in each row. keys: The number of columns, left to right, that are primary keys. 0 for all columns. timeout: The number of seconds after last modification when the table becomes invalid. 0 for no timeout. Raises: CacheTableNameInvalid: If name is invalid. Returns: A table object for name. Nz/[{}] table [{}] column count [{}] must be >= 1.z>[{}] table [{}] primary key count [{}] must be >= 1 and <= {}.rr r rrrrr z,[{}] cache version [{}] does not match [{}].)r r rrrrr)rCacheTableColumnsInvalidformatr CacheTableKeysInvalidrr:r*r)ValidateSelectr rrCacheVersionMismatchrAddRowsr rr) rr rr rrr-rrowsrmetadatas r _CreateTablez$CacheUsingMetadataTable._CreateTablets0g{  / / ; B Biiw ( )) | d ax4'>  , , J 6$))T4 1 33 g##D'48   d#'&-#'&-'()3  5E ~~gdn nn \\(,,D,1 2dDGc C= << !))/R$, \\X-- -//<CC))X--t||= . . << !))$,en gNNHLL ZZ ZZ ##) Lrc <||jvr/tjdj|j||j j |d}|r|js|J||jk7r;tjdj|j|||j|J||jk7r;tjdj|j|||j|S|s/tjdj|j||jr|jjtj!|}|r|dnd} | r_t| } |j#|| j| j| j| j$| j&| j(S|s/tjdj|j||j+|||||S) aReturns the Table object for existing table name. Args: name: The table name. create: If True creates the table if it does not exist. restricted: Return a restricted table object. columns: The number of columns in each row. keys: The number of columns, left to right, that are primary keys. 0 for all columns. timeout: The number of seconds after last modification when the table becomes invalid. 0 for no timeout. If None then the default cache timeout is assumed. Raises: CacheTableNameInvalid: name is not a valid table name. CacheTableNotFound: If the table does not exist. Returns: A Table object for name. z$[{}] cache table [{}] is restricted.Nz>[{}] cache table [{}] columns [{}] does not match existing {}.z;[{}] cache table [{}] keys [{}] does not match existing {}.z [{}] cache table [{}] not found.r>rr=)r+rCacheTableRestrictedrAr r,getdeletedr r@rrBCacheTableNotFoundr)rDr rr*rrrrI) rr r'rr rrr-rGrrHs rTablezCacheUsingMetadataTable.Tables, t  + + 0 7 7 4 H JJ LL  T4 (E ]]  7emm#;33Nvdiiw >@ @   200KvdiitUZZ8: : ++ . 5 5dii FH H ~~ ^^ " "8<> 4E!J KD*. /$3HSM  $ // /sA)TrN)T)TFNNNr0)rrrr rabcabstractmethodr2r5r8r:rIrOrRrD __classcell__)r.s@rr%r%Gs        KZKO7Gr" 0rr%)r __future__rrrrTgooglecloudsdk.core.cacherrsixobjectr add_metaclassABCMetaCacher%r#rrr^sf  '' 0; "Iv"IJ3;;B0399B0 B0r