Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/__pycache__/schema.cpython-39.pyc
Ðазад
a ]�h,� � @ s d Z ddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z ddlmZmZ ddlmZmZmZmZmZmZ z ddlZW n ey� dZY n0 eeeeeegad ZG d d � d ej �Z d d � Z G dd� de �Z G dd� d�Z!dS )a� Backends -------- NDB stores all the records in an SQL database. By default it uses the SQLite3 module, which is a part of the Python stdlib, so no extra packages are required:: # SQLite3 -- simple in-memory DB ndb = NDB() # SQLite3 -- same as above with explicit arguments ndb = NDB(db_provider='sqlite3', db_spec=':memory:') # SQLite3 -- file DB ndb = NDB(db_provider='sqlite3', db_spec='test.db') It is also possible to use a PostgreSQL database via psycopg2 module:: # PostgreSQL -- local DB ndb = NDB(db_provider='psycopg2', db_spec={'dbname': 'test'}) # PostgreSQL -- remote DB ndb = NDB(db_provider='psycopg2', db_spec={'dbname': 'test', 'host': 'db1.example.com'}) Database backup --------------- Built-in database backup is implemented now only for SQLite3 backend. For the PostgresSQL backend you have to use external utilities like `pg_dump`:: # create an NDB instance ndb = NDB() # the defaults: db_provider='sqlite3', db_spec=':memory:' ... # dump the DB to a file ndb.backup('backup.db') SQL schema ---------- By default NDB deletes the data from the DB upon exit. In order to preserve the data, use `NDB(db_cleanup=False, ...)` Here is an example schema (may be changed with releases):: List of relations Schema | Name | Type | Owner --------+------------------+-------+------- public | addresses | table | root public | af_bridge_fdb | table | root public | af_bridge_ifs | table | root public | af_bridge_vlans | table | root public | enc_mpls | table | root public | ifinfo_bond | table | root public | ifinfo_bridge | table | root public | ifinfo_gre | table | root public | ifinfo_gretap | table | root public | ifinfo_ip6gre | table | root public | ifinfo_ip6gretap | table | root public | ifinfo_ip6tnl | table | root public | ifinfo_ipip | table | root public | ifinfo_ipvlan | table | root public | ifinfo_macvlan | table | root public | ifinfo_macvtap | table | root public | ifinfo_sit | table | root public | ifinfo_tun | table | root public | ifinfo_vlan | table | root public | ifinfo_vrf | table | root public | ifinfo_vti | table | root public | ifinfo_vti6 | table | root public | ifinfo_vxlan | table | root public | interfaces | table | root public | metrics | table | root public | neighbours | table | root public | netns | table | root public | nh | table | root public | p2p | table | root public | routes | table | root public | rules | table | root public | sources | table | root public | sources_options | table | root (33 rows) rtnl=# select f_index, f_ifla_ifname from interfaces; f_index | f_ifla_ifname ---------+--------------- 1 | lo 2 | eth0 28 | ip_vti0 31 | ip6tnl0 32 | ip6_vti0 36445 | br0 11434 | dummy0 3 | eth1 (8 rows) rtnl=# select f_index, f_ifla_br_stp_state from ifinfo_bridge; f_index | f_ifla_br_stp_state ---------+--------------------- 36445 | 0 (1 row) Database upgrade ---------------- There is no DB schema upgrade from release to release. All the data stored in the DB is being fetched from the OS in the runtime, thus no persistence required. If you're using a PostgreSQL DB or a file based SQLite, simply drop all the tables from the DB, and NDB will create them from scratch on startup. � N)� OrderedDict)�partial)�config)� basestring�uuid32� )�address� interface� neighbour�netns�route�rule� c @ s e Zd ZdZdZdd� ZdS )� DBProvider�sqlite3�psycopg2c C s t | �|kS �N��str)�self�r� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/pyroute2/ndb/schema.py�__eq__� s zDBProvider.__eq__N)�__name__� __module__� __qualname__r r r r r r r r � s r c s$ t � t�r� fdd�}|S d� _� S )Nc s � | _ | S r )�publish)�m��fr r �decorate� s zpublish.<locals>.decorateT)� isinstancer r )r r! r r r r � s r c @ sh e Zd Zdd� Zed�dd� �Zed�dd� �Zed �d d � �Zed d � �Zedd� �Z edd� �Z dS )�DBDictc C s || _ || _d S r )�schema�table)r r$ r% r r r �__init__� s zDBDict.__init__�getc C sL | j �d| j� d| j j� d�|f�D ]\}t�|� S td|� d���d S )Nz! SELECT f_value FROM � WHERE f_key = � zkey z not found)r$ �fetchr% �plch�json�loads�KeyError)r �key�recordr r r � __getitem__� s ��� zDBDict.__getitem__�setc C s@ | |= | j �d| j� d| j j� d| j j� d�|t�|�f� d S )Nz INSERT INTO z VALUES (z, z) )r$ �executer% r+ r, �dumps�r r/ �valuer r r � __setitem__� s ��� �zDBDict.__setitem__�delc C s( | j �d| j� d| j j� d�|f� d S )Nz DELETE FROM r( r) )r$ r3 r% r+ �r r/ r r r � __delitem__� s ���zDBDict.__delitem__c c s& | j �d| j� ��D ] \}|V qd S )NzSELECT f_key FROM )r$ r* r% r9 r r r �keys� s z DBDict.keysc c s2 | j �d| j� ��D ]\}}|t�|�fV qd S )NzSELECT f_key, f_value FROM �r$ r* r% r, r- r5 r r r �items� s � z DBDict.itemsc c s, | j �d| j� ��D ]\}t�|�V qd S )NzSELECT f_value FROM r< )r r6 r r r �values� s z DBDict.valuesN) r r r r& r r1 r7 r: r; r= r> r r r r r# � s r# c @ s� e Zd ZdZdZdZdZe� Zi Z i Z i Z dd� Z dd� Z dd� Zdd � Zed d � �Zd d � Zedd� �Zedd� �Zedd� �Zed,dd��Zdd� Zedd� �Zdd � Zd d � Zed d � �Zed!d"� �Z ed#d$� �Z ed%d&� �Z d-d'd(�Z d.d*d+�Z dS )/�DBSchemaNc C s> || _ t| d�| _i | _d | _d | _|| _i | _i | _i | _ |d | _ |d | _ t D ]\}|j d D ].\}}|�� | j|< |j| j|< |j| j|< qb|j d D ]\}}|| j|< q�qT| �|� t D ]h}|j d } | �� D ]P\} } g } | D ]4} t| t��r | �t| j| �� q�| �t| | �� q�| | j | < q�q�t�� | _ | _ d S )Nr Z rtnl_debug�provider�specs�classes� event_map) �sourcesr# r �stats� connection�cursor�log� snapshots� key_defaultsrC �rtnl_logr@ �plugins�init�as_dict�spec�index�indices� foreign_keysrB �initdbr= r" r �appendr � load_netlink�time�gctime�ctime)r r rD rC Z log_channel�plugin�namerO �clsZemap�etypeZehndl�handlers�hr r r r& � s: zDBSchema.__init__c C s" | j d ur| �� |d tjkrDt�|d �| _ d| _| j �d� n4|d tjkrptjf i |d ��| _ d| _ntd��| j � � | _ i | _ | j � � D ].}| � || j | | j| �| j |< | �|� q�| �d� | �d� | �d � | �d � | �d � | �d � |�� D ]\}}|| j|< �qd S ) Nr@ rO �?zPRAGMA foreign_keys = ON�%szDB provider not supportedzP DROP TABLE IF EXISTS sources_options zH DROP TABLE IF EXISTS sources z1 DROP TABLE IF EXISTS config zi CREATE TABLE config (f_key TEXT PRIMARY KEY, f_value TEXT NOT NULL) z� CREATE TABLE IF NOT EXISTS sources (f_target TEXT PRIMARY KEY, f_kind TEXT NOT NULL) a� CREATE TABLE IF NOT EXISTS sources_options (f_target TEXT NOT NULL, f_name TEXT NOT NULL, f_type TEXT NOT NULL, f_value TEXT NOT NULL, FOREIGN KEY (f_target) REFERENCES sources(f_target) ON UPDATE CASCADE ON DELETE CASCADE) )rF �closer r �connectr+ r3 r � TypeErrorrG �compiledrO r; � compile_specrQ � create_tabler= r )r r r% r/ r6 r r r rS # sJ � ������ zDBSchema.initdbc s� � j | }� j � }|d |d d d� }|d |d dd� }|d |d dd� } d| } dd� |D �} � fd d�|D �} d d� | D �} � �fd d�| D �}� jgt| � }||| | d �| �d �|�d �| �d �| �d �|�d� S )N�names���� all_names� � norm_names��target�tflagsc S s g | ] }d | �qS �zf_%sr ��.0�xr r r � <listcomp>o � z'DBSchema.merge_spec.<locals>.<listcomp>c s g | ]}d |� j f �qS �� f_%s = %s�r+ rp �r r r rs p rt c S s g | ] }d | �qS ro r rp r r r rs q rt c s g | ]}d �|� j f �qS �z %s.%s = %srw rp �r �table2r r rs r rt �,� AND ) rg ri rk �idx�fnames�plchs�fset�knames�fidx)rd r+ �len�join)r Ztable1r{ r% � schema_idxZspec1Zspec2rg ri rk r~ �f_names�f_set�f_idx� f_idx_matchr� r rz r � merge_spech s* �zDBSchema.merge_specc s< g }ddg}ddg}�j ���}|D ]n}|�|d � |�|d � |� t|�dkr~|d d� D ] } t� j�} t� | | �� q`|�� �|d �� q$dd� |D �} �fdd�|D �} �jgt| � } d| }d d� |D �}� fd d�|D �}��fd d�|D �}|||||d � | �d � | �d � | �d � |�d � |�� j d� S )Nrm rn rh r c S s g | ] }d | �qS ro r rp r r r rs � rt z)DBSchema.compile_spec.<locals>.<listcomp>c s g | ]}d |� j f �qS ru rw rp rx r r rs � rt rl c S s g | ] }d | �qS ro r rp r r r rs � rt c s g | ]}� � |��qS r )�nla2namerp )�iclassr r rs � rt c s g | ]}d �|� j f �qS ry rw rp )r r% r r rs � rt r| r} ) rg ri rk r~ �norm_idxr r� r� r� r� �lookup_fallbacks) rB r' rT r� �dictZnla_map�getattrr� r+ r� r� )r r% Z schema_namesr� rg ri rk ZbclassrZ �step�imapr� r� r� r~ r� r� r� r )r� r r% r re � s@ �zDBSchema.compile_specc C s� | � d| j |f� | � d| j |f� | � d| j| jf ||f� |�� D ]B\}}t|t�rbdnd}| � d| j| j| j| jf ||||f� qLdS )z6 A temprorary method, to be moved out z] DELETE FROM sources_options WHERE f_target = %s zU DELETE FROM sources WHERE f_target = %s zd INSERT INTO sources (f_target, f_kind) VALUES (%s, %s) �intr z� INSERT INTO sources_options (f_target, f_name, f_type, f_value) VALUES (%s, %s, %s, %s) N)r3 r+ r= r" r� )r rm �kindrO r/ r6 Zvtyper r r � add_nl_source� s4 ���� ��� �zDBSchema.add_nl_sourcec O s� z�z|t t�D ]^}z | jj|i |�� W q|W q tjtjfyh } z | j�d| � W Y d }~q d }~0 0 q t d||f ��W n t y� � Y n0 W | j � � n | j � � 0 | jS )Nr` zDB execute error: %s %s) �range� MAX_ATTEMPTSrG r3 r ZInterfaceError�OperationalErrorrH �debug� ExceptionrF �commit)r �argv�kwarg�_�er r r r3 � s zDBSchema.executec O s | j |i |��D ] }| S d S r )r* )r r� r� �rowr r r �fetchone s zDBSchema.fetchonec o s8 | j |i |�� | j�� }|s"d S |D ] }|V q&qd S r )r3 rG Z fetchmany)r r� r� Zrow_setr� r r r r* s zDBSchema.fetchc C s@ t jdkr6| jtjkr6t�|�}| j�|� |�� nt � �d S )N)� � ) �sys� version_infor@ r r rb rF �backupra �NotImplementedError)r rO Zbackup_connectionr r r r� ' s zDBSchema.backup�stdoutc C s� d}|dv rt t|�}nt|t�r0t|d�}d}z�| j�� D ]�}|�d| � | �d| �D ](}|�d� dd � |D ��� |�d � q\| j r<|�d | � | �d | �D ](}|�d� d d � |D ��� |�d � q�q<W |r�|� � n|r�|� � 0 d S )NF)r� �stderr�wTz table %s zSELECT * FROM %s� c S s g | ] }t |��qS r r rp r r r rs < rt z#DBSchema.export.<locals>.<listcomp>� z table %s_log zSELECT * FROM %s_logc S s g | ] }t |��qS r r rp r r r rs A rt ) r� r� r" r �openrO r; �writer3 r� rK ra )r r ra r% r0 r r r �export0 s* �zDBSchema.exportc C s. | j d dkr | �� | j�� | j�� d S )NrO z:memory:)r �purge_snapshotsrF r� ra rx r r r ra G s zDBSchema.closec C s | j �� d S r )rF r� rx r r r r� N s zDBSchema.commitc C s� ddg}g }i | j |< | j| �� D ]l}|d d |d f}|�d| � |�d| � |d �� �d�r~d| j | |d < q$d| j | |d < q$|| jv �r(| j| D ]~}d d �|d � d |d d �|d �f f}|�d| � t|d �dkr�d|d d�|d �f }| � d||d f � q�d �|�}d||f }| � |� d �ddgdd� | j | D � �}d|||f }| � |� | j �r�g d�| }d �|�}| � d||f � d S )N�f_target TEXT NOT NULLz"f_tflags BIGINT NOT NULL DEFAULT 0r rh r zf_%s %sZTEXT� z(%s)r| �fieldsz%s(%s)�parentZ parent_fieldszAFOREIGN KEY %s REFERENCES %s ON UPDATE CASCADE ON DELETE CASCADE z uidx_%s_%sr� z*CREATE UNIQUE INDEX IF NOT EXISTS %s ON %sz"CREATE TABLE IF NOT EXISTS %s (%s)�f_targetZf_tflagsc S s g | ] }d | �qS ro r rp r r r rs � rt z)DBSchema.create_table.<locals>.<listcomp>z3CREATE UNIQUE INDEX IF NOT EXISTS %s_idx ON %s (%s))zf_tstamp BIGINT NOT NULLr� zf_event INTEGER NOT NULLz&CREATE TABLE IF NOT EXISTS %s_log (%s)) rJ rO r= rT �strip� startswithrR r� r� r3 rQ rK ) r r% �reqr� �fieldr/ rO ZidxnamerP r r r rf R sh ��� � �� ��� � �zDBSchema.create_tablec C s. | j D ]"}| �d|| j| jf ||f� qd S )Nz| UPDATE %s SET f_tflags = %s WHERE f_target = %s �rO r3 r+ )r rm �markr% r r r r� � s ��z DBSchema.markc C s( | j D ] }| �d|| jf |f� qd S )NzV DELETE FROM %s WHERE f_target = %s r� )r rm r% r r r �flush� s ��zDBSchema.flushc C s8 t � }|� }|j}| j|j }g }g } |D ]F} |�d| | jf � | |v rZ| �|| � q*| �|�|�| ��� q*| �d|jd� |�f | �� � d } |� |� | j D ]H} | j �d| |f � | �d| || f � | �d| || | jf |g� q�|� | � | j D ]2} | �d| || jf | g� || jd | |f < �q d S ) Nrv zs SELECT f_tflags FROM %s WHERE %s r} r zcreate snapshot %s_%sz� CREATE TABLE IF NOT EXISTS %s_%s AS SELECT * FROM %s WHERE f_tflags IS NULL z� INSERT INTO %s_%s SELECT * FROM %s WHERE f_tflags = %s zR UPDATE %s_%s SET f_tflags = %s z%s_%s)r r/ rQ r% rT r+ r' r� r3 r� r� Z mark_tflagsrO rH r� rI ) r ZctxidZweak_refr� �uuid�objZobj_kr~ � conditionsr> r/ rn r% r r r � save_deps� sT ��� �� �� ��zDBSchema.save_depsc C s� t | j�D ]�}tt�D ]z}zR| jtjkr8| �d| � n| jtjkrR| �d| � | j � � | j|= W q W q tj y� t � t�� � Y q0 qtd��q d S )N� DROP TABLE %szDROP TABLE %s CASCADEzDB snapshot error)�tuplerI r� r� r@ r r r3 r rF r� r� rV �sleep�randomr� )r r% r� r r r r� s zDBSchema.purge_snapshotsc c s� g }g }| j | }| j| }|�� D ]P\}}||d vrB|�|�}||d vrVtd��|�d|| jf � |�|� q$d|d�|�f } | �| |�D ] } t t | j| d | ��V q�d S )Nri zfield name not foundrv zSELECT * FROM %s WHERE %sr} ) rB rd r= Zname2nlar. rT r+ r� r* r� �zip) r r% rO r� r> r[ Zcspecr/ r6 r� r0 r r r r' s z DBSchema.getc C s� | j | d }d�g d�dd� |D � �}d�| jgt|�d �}tt�� d �||�di ��d d �g}|D ]f} |�| �p�|�| �} | d u r�| | j|p�| v r�| j | | } t | t t t tf�r�t�| �} |�| � qn| �d |||f |� d S ) Nrg r| )Zf_tstampr� Zf_eventc S s g | ] }d | �qS ro r rp r r r rs 9 rt z(DBSchema.log_netlink.<locals>.<listcomp>r� i� �header�typer z#INSERT INTO %s_log (%s) VALUES (%s))rd r� r+ r� r� rV r' �get_attrrQ rJ r" r� �listr� r2 r, r4 rT r3 ) r r% rm �event�ctableZfkeysr� Zpchr> r� r6 r r r � log_netlink3 s( �� �zDBSchema.log_netlinkFc C sL | j r| �||||� d|d v r4|d d | j|< t�� | j tjkr�t�� | _t| j� � �D ]f\}}|� d u r`| j|= z| � d| � W q` t y� } z | j � d||f � W Y d }~q`d }~0 0 q`| � d| j tt�� �f� |d �dd�d �r�d | j g} |g} | j| D ]p} | �d | | jf � |�| ��pB|�| �} | d u �r\| j| | } t| ttttf��rzt�| �} | �| � �q| � d |d �| �f | � �n�|dg} |dg} | j | }i }| j | � � D �]H\}}|}t |�d k�rf|d d� |v�r>|d d� D ] }|�|�}|d u �r �q.�q |||d d� < ||d d� }|d u �rf| �d � �q�|�|d �} | d u �r�|�|d �} | d u �r�|d | j | d v �r�| j| |d } |d �|d | f� t| ttttf��r�t�| �} |d |d v �r| �| � | �| � �q�z�| j t j!k�rh| � d||d |d |d |d |d f | | | � n�| j t j"k�r�| � d||d f | ��#� d }|dk�r�| � d||d |d f | � n"| � d||d |d f | | � nt$� �W nZ t �yF } z@|�r|�| j � d|||f � | j �%dt&�'� � W Y d }~n d }~0 0 d S ) NrE r� r� z failed to remove table %s: %sz-DELETE FROM routes WHERE (f_gc_mark + 5) < %sr� r rj z f_target = %srv zDELETE FROM %s WHERE %sr} r rh r~ �attrszJINSERT INTO %s (%s) VALUES (%s) ON CONFLICT (%s) DO UPDATE SET %s WHERE %sr r� r� r� r� zn SELECT count(*) FROM %s WHERE %s zk INSERT INTO %s (%s) VALUES (%s) ze UPDATE %s SET %s WHERE %s zload_netlink: %s %s %szload_netlink: %s)(rK r� rE rV rW r Z gc_timeoutr� rI r= r3 r� rH r� r+ r� r' rQ rT r� rJ r" r� r� r2 r, r4 r� rd rO r� r@ r r r r� r� �error� traceback� format_exc)r r% rm r� r� � propagaterZ Zwrefr� r� r> r/ r6 Zivaluesrd �nodes�fnameZftype�nodeZsteg�countr r r rU M s� � � �� " �� �� ��� ���� �zDBSchema.load_netlink)r� )N)NF)!r r r rF rC rJ rI r rO rB rQ rR r& rS r� re r r� r3 r� r* r� r� ra r� rf r� r� r� r� r' r� rU r r r r r? � sL 1ES * T K r? )"�__doc__�enumr, r� r r� rV r� � collectionsr � functoolsr Zpyroute2r Zpyroute2.commonr r �objectsr r r r r r r � ImportErrorrL r� �Enumr r r� r# r? r r r r �<module> s, w 8
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка