관리-도구
편집 파일: caching.cpython-38.pyc
U )�e�$ � @ s� d Z ddlZddlmZmZ ddlmZ ddlZddlZddlm Z e� d�Z dZ dd d �Z G d d � d e�ZG d d� de�ZG dd� de�ZG dd� de�ZdS )z0Implementing caching mechanisms for MySQL Fabric� N)�datetime� timedelta)�sha1� )� FabricShardzmyconnpy-fabric�< c C s` |dk rt d��|dkr t| �}||k rP|| d }|| | krF|}q |d }q | �||� dS )z�Similar to bisect.insort_right but for reverse sorted lists This code is similar to the Python code found in Lib/bisect.py. We simply change the comparison from 'less than' to 'greater than'. r zlow must be non-negativeN� r )� ValueError�len�insert)�alistZ new_element�low�high�middle� r �s/opt/hc_python/lib64/python3.8/site-packages/../../../lib/python3.8/site-packages/mysql/connector/fabric/caching.py�insort_right_rev' s r c @ sJ e Zd ZdZddefdd�Zed dd��Zedd� �Z d d � Z d d � Z dS )� CacheEntryz)Base class for MySQL Fabric cache entriesNc C s || _ || _t�� | _|| _d S �N)�version� fabric_uuidr �utcnow� last_updated�_ttl)�selfr r �ttlr r r �__init__? s zCacheEntry.__init__c C s t �dS )�Create hash for indexingN)�NotImplementedError��clsZpart1Zpart2r r r � hash_indexE s zCacheEntry.hash_indexc C s( | j s dS | j t| jd� }t�� |kS )z�Returns True if entry is not valid any longer This property returns True when the entry is not valid any longer. The entry is valid when now > (last updated + ttl), where ttl is in seconds. F)�seconds)r r r r r )r �atimer r r �invalidJ s zCacheEntry.invalidc C s t �� | _dS )zReset the Time to LiveN)r r r �r r r r � reset_ttlW s zCacheEntry.reset_ttlc C s d| _ dS )zInvalidates the cache entryN)r r% r r r � invalidate[ s zCacheEntry.invalidate)N) �__name__� __module__� __qualname__�__doc__� _CACHE_TTLr � classmethodr! �propertyr$ r& r' r r r r r ; s r c sH e Zd ZdZd � fdd� Zdd� Zdd� Zedd d ��Zd d � Z � Z S )�CacheShardTablez&Cache entry for a Fabric sharded tableNc s^ t |t�std��tt| �j||d� i | _|| _g | _g | _ |j rZ|j rZ| � |j |j � d S )Nz-shard argument must be a FabricShard instance�r r ) � isinstancer r �superr/ r � partitioning�_shard�keys� keys_reversed�key�group� add_partition)r �shardr r �� __class__r r r d s � zCacheShardTable.__init__c C s t | j|�S r )�getattrr4 )r �attrr r r � __getattr__q s zCacheShardTable.__getattr__c C s� | j dkrt|�}nz| j dkrfz*d|kr6t�|d�}nt�|d��� }W q� td�|���Y q�X n(| j dkrrn | j dkr~ntd �| j ���d |i| j|< | �� t � | j |� t | j |� d S ) z$Add sharding information for a group�RANGEZRANGE_DATETIME�:z%Y-%m-%d %H:%M:%Sz%Y-%m-%dz0RANGE_DATETIME key could not be parsed, was: {0}Z RANGE_STRING�HASHz Unsupported sharding type {0}r8 N)Z shard_type�intr �strptime�dater �formatr3 r& �bisect� insort_rightr5 r r6 )r r7 r8 r r r r9 t s4 �� � � z CacheShardTable.add_partitionc C s t |�d�|�d� ��� S �r zutf-8�r �encode� hexdigestr r r r r! � s zCacheShardTable.hash_indexc C s dj | j| j| j| jd�S )Nz%{class_}({database}.{table}.{column}))�class_�database�table�column)rF r< rN rO rP r% r r r �__repr__� s �zCacheShardTable.__repr__)NN)N) r( r) r* r+ r r? r9 r- r! rQ � __classcell__r r r; r r/ ` s r/ c s6 e Zd ZdZ� fdd�Zed dd��Zdd� Z� ZS ) � CacheGroupz Cache entry for a Fabric groupc s$ t t| �jd d d� || _|| _d S )Nr0 )r2 rS r � group_name�servers)r rT rU r; r r r � s zCacheGroup.__init__Nc C s t |�d���� S rI rJ r r r r r! � s zCacheGroup.hash_indexc C s dj | j| jd�S )Nz{class_}({group}))rM r8 )rF r< rT r% r r r rQ � s �zCacheGroup.__repr__)N) r( r) r* r+ r r- r! rQ rR r r r; r rS � s rS c @ sV e Zd ZdZefdd�Zdd� Zdd� Zdd d �Zd d � Z d d� Z dd� Z dd� Z dS )� FabricCachezfSingleton class for caching Fabric data Only one instance of this class can exists globally. c C s* || _ i | _i | _t�� | _t�� | _d S r )r � _sharding�_groups� threading�Lock�_FabricCache__sharding_lock�_FabricCache__groups_lock)r r r r r r � s zFabricCache.__init__c C sB | j �2 z | j|= W n tk r( Y n X t�d� W 5 Q R X dS )z Remove cache entry for groupzGroup removed from cacheN)r\ rX �KeyError�_LOGGER�debug�r � entry_hashr r r � remove_group� s zFabricCache.remove_groupc C s8 | j �( z | j|= W n tk r( Y nX W 5 Q R X dS )z Remove cache entry for shardN)r[ rW r] r` r r r �remove_shardtable� s z FabricCache.remove_shardtableNc C sr t �|j|j�}| j�R z | j| }|�|j|j� W n, t k rb t |||d�}|| j|< Y nX W 5 Q R X dS )z Cache information about a shardr0 N) r/ r! rN rO r[ rW r9 r7 r8 r] )r r: r r ra �entryr r r �sharding_cache_table� s �z FabricCache.sharding_cache_tablec C s� t �|�}| j�p z.| j| }||_|�� t�d�||�� W n: t k rz t ||�}|| j|< t�d�||�� Y nX W 5 Q R X dS )z Cache information about a groupz Recaching group {0} with {1}zCaching group {0} with {1}N) rS r! r\ rX rU r& r^ r_ rF r] )r rT rU ra rd r r r � cache_group� s" � �zFabricCache.cache_groupc C s` t �||�}d}z4| j| }|jrBt�d�|�� | �|� W dS W n tk rZ Y dS X |S )z4Search cache for a shard based on database and tableN�{0} invalidated) r/ r! rW r$ r^ r_ rF rc r] )r rN rO ra rd r r r �sharding_search� s zFabricCache.sharding_searchc C s^ t �|�}d}z4| j| }|jr@t�d�|�� | �|� W dS W n tk rX Y dS X |S )z*Search cache for a group based on its nameNrg ) rS r! rX r$ r^ r_ rF rb r] )r rT ra rd r r r � group_search s zFabricCache.group_searchc C s dj | jt| j�t| j�d�S )Nz-{class_}(groups={nrgroups},shards={nrshards}))rM ZnrgroupsZnrshards)rF r< r rX rW r% r r r rQ s �zFabricCache.__repr__)NN) r( r) r* r+ r, r rb rc re rf rh ri rQ r r r r rV � s rV )r N)r+ rG r r �hashlibr �loggingrY � r � getLoggerr^ r, r �objectr r/ rS rV r r r r �<module> s %@