o @&@sdZddlmZddlmZddlmZddlZddlmZddlmZddl Z Gdd d e Z e ej Gd d d ejZdS) 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_basec@s.eZdZdZdZddZe  dddZdS) 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. cCs,|\|_|_|_|_|_}|_t||_dS)z+Constructs a metadata container from a row.N)namecolumnskeystimeoutmodifiedversionbool restricted)selfrowrrE/tmp/google-cloud-sdk/lib/googlecloudsdk/core/cache/metadata_table.py__init__8szMetadata.__init__NcCs"|durt|}|||||||fS)z:Constructs and returns a metadata table row from the args.N)int)clsr r r r r rrrrrRow>sz Metadata.Row)NNNNNNN)__name__ __module__ __qualname____doc__COLUMNSr classmethodrrrrrr"srcs~eZdZdZdfdd ZejddZejd d Zejdd d Z d dZ ddZ  dddZ ddZ dddZZS)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. TrNcs4tt|j||||dd|_||_d|_d|_dS)N)creater r)superrr _metadata _table_class _restricted_tables)rtabler r r r __class__rrrRs  z CacheUsingMetadataTable.__init__cCdSNrrrrrDeleteZzCacheUsingMetadataTable.DeletecCr)r*rr+rrrCommit^r-zCacheUsingMetadataTable.CommitcCr)r*r)rcommitrrrClosebr-zCacheUsingMetadataTable.ClosecCsdS)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 r rrr_ImplementationCreateTablefs z2CacheUsingMetadataTable._ImplementationCreateTablec Csp|durd}|dkrtd|j|||dur|}|dks#||kr/td|j||||dur6|j}|||||j|||||d|d}|jrOd}nP||_| | t j |d}|re|dnd} | rt | } |j dury| j pvd|_ n|j | j krtd |j| j |j | j |j |jdur| j|_d|_|j }|jt j |j|j|j|j|j|j|d 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 r r r rr z,[{}] cache version [{}] does not match [{}].)r r r r r rr)rCacheTableColumnsInvalidformatr CacheTableKeysInvalidr r1r#r"ValidateSelectrrrCacheVersionMismatchr AddRowsr r r) rr rr r r r&rrowsrmetadatarrr _CreateTabletsr      z$CacheUsingMetadataTable._CreateTableFc Cs.||jvrtd|j||j|d}|rU|jsI|dur1||jkr1t d|j|||j|durG||j krGt d|j|||j |S|sUt d|j||j r|j tj|d}|rh|dnd} | rt| } |j|| j| j| j | j| j| jdS|st d|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.r4rr3)r$rCacheTableRestrictedr7r r%getdeletedr r6r r8CacheTableNotFoundr"r:rrr#r r rr?) rr r rr r r r&r=rr>rrrTablesP    zCacheUsingMetadataTable.TablecCs|jddtjddddS)z2Initializes the metadata table and self._metadata. __metadata__Tr2r)rr r r N)rDrrr+rrrInitializeMetadatas  z*CacheUsingMetadataTable.InitializeMetadatacCs$|jtj|dd}dd|DS)aReturns the list of unrestricted table names matching name. Args: name: The table name pattern. None for all unrestricted tables. May contain the * and ? pattern match characters. Returns: The list of unrestricted table names matching name. F)r rcSsg|]}t|jqSr)rr ).0rrrr sz2CacheUsingMetadataTable.Select..)r"r:rr)rr r=rrrr:s zCacheUsingMetadataTable.Select)TrN)T)TFNNNr*)rrrrrabcabstractmethodr,r.r0r1r?rDrFr: __classcell__rrr'rrGs     M 9r)r __future__rrrrIgooglecloudsdk.core.cacherrsixobjectr add_metaclassABCMetaCacherrrrrs      %