Submit
Path:
~
/
/
opt
/
alt
/
python37
/
lib64
/
python3.7
/
site-packages
/
sqlalchemy
/
dialects
/
postgresql
/
__pycache__
/
File Content:
hstore.cpython-37.pyc
B ��4]�0 � @ s� d dl Z ddlmZ ddlmZ ddlmZ ddlmZ ddl m Z dd l m Z d Z e je j Ze jd ed d d �Ze jded d d �Ze jded d d �Ze jded d d �Ze jded d d �Ze jded d d �ZG dd� dejejej�Zeed< G dd� de j �Z G dd� de j �Z G dd� de j �Z G dd � d e j �Z G d d � d e j �Z!G d d � d e j �Z"G d!d"� d"e j �Z#G d#d$� d$e j �Z$e �%d%e j&�Z'e �%d&e j&�Z(d'd(� Z)d)d*� Z*d+d,� Z+dS )-� N� )�ARRAY)� ischema_names� )�types)�util)� functions)� operators)�HSTORE�hstorez->T)Z precedenceZnatural_self_precedentZeager_grouping�?z?&z?|z@>z<@c @ sX e Zd ZdZd ZdZe�� Zd dd�Z G dd� dej j ej j �Z e Z dd � Zd d � ZdS ) r at Represent the PostgreSQL HSTORE type. The :class:`.HSTORE` type stores dictionaries containing strings, e.g.:: data_table = Table('data_table', metadata, Column('id', Integer, primary_key=True), Column('data', HSTORE) ) with engine.connect() as conn: conn.execute( data_table.insert(), data = {"key1": "value1", "key2": "value2"} ) :class:`.HSTORE` provides for a wide range of operations, including: * Index operations:: data_table.c.data['some key'] == 'some value' * Containment operations:: data_table.c.data.has_key('some key') data_table.c.data.has_all(['one', 'two', 'three']) * Concatenation:: data_table.c.data + {"k1": "v1"} For a full list of special methods see :class:`.HSTORE.comparator_factory`. For usage with the SQLAlchemy ORM, it may be desirable to combine the usage of :class:`.HSTORE` with :class:`.MutableDict` dictionary now part of the :mod:`sqlalchemy.ext.mutable` extension. This extension will allow "in-place" changes to the dictionary, e.g. addition of new keys or replacement/removal of existing keys to/from the current dictionary, to produce events which will be detected by the unit of work:: from sqlalchemy.ext.mutable import MutableDict class MyClass(Base): __tablename__ = 'data_table' id = Column(Integer, primary_key=True) data = Column(MutableDict.as_mutable(HSTORE)) my_object = session.query(MyClass).one() # in-place mutation, requires Mutable extension # in order for the ORM to detect my_object.data['some_key'] = 'some value' session.commit() When the :mod:`sqlalchemy.ext.mutable` extension is not used, the ORM will not be alerted to any changes to the contents of an existing dictionary, unless that dictionary value is re-assigned to the HSTORE-attribute itself, thus generating a change event. .. seealso:: :class:`.hstore` - render the PostgreSQL ``hstore()`` function. FNc C s |dk r|| _ dS )z�Construct a new :class:`.HSTORE`. :param text_type: the type that should be used for indexed values. Defaults to :class:`.types.Text`. .. versionadded:: 1.1.0 N)� text_type)�selfr � r �X/opt/alt/python37/lib64/python3.7/site-packages/sqlalchemy/dialects/postgresql/hstore.py�__init__� s zHSTORE.__init__c @ sx e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Zd S ) zHSTORE.Comparatorz2Define comparison operations for :class:`.HSTORE`.c C s | j t|tjd�S )zvBoolean expression. Test for presence of a key. Note that the key may be a SQLA expression. )� result_type)�operate�HAS_KEY�sqltypes�Boolean)r �otherr r r �has_key� s zHSTORE.Comparator.has_keyc C s | j t|tjd�S )zHBoolean expression. Test for presence of all keys in jsonb )r )r �HAS_ALLr r )r r r r r �has_all� s zHSTORE.Comparator.has_allc C s | j t|tjd�S )zGBoolean expression. Test for presence of any key in jsonb )r )r �HAS_ANYr r )r r r r r �has_any� s zHSTORE.Comparator.has_anyc K s | j t|tjd�S )z�Boolean expression. Test if keys (or array) are a superset of/contained the keys of the argument jsonb expression. )r )r �CONTAINSr r )r r �kwargsr r r �contains� s zHSTORE.Comparator.containsc C s | j t|tjd�S )z|Boolean expression. Test if keys are a proper subset of the keys of the argument jsonb expression. )r )r � CONTAINED_BYr r )r r r r r � contained_by� s z HSTORE.Comparator.contained_byc C s t || jjfS )N)�GETITEM�typer )r �indexr r r �_setup_getitem� s z HSTORE.Comparator._setup_getitemc C s t | j|�S )z�Boolean expression. Test for presence of a non-NULL value for the key. Note that the key may be a SQLA expression. )�_HStoreDefinedFunction�expr)r �keyr r r �defined� s zHSTORE.Comparator.definedc C s t |t�rt|�}t| j|�S )z�HStore expression. Returns the contents of this hstore with the given key deleted. Note that the key may be a SQLA expression. )� isinstance�dict�_serialize_hstore�_HStoreDeleteFunctionr' )r r( r r r �delete� s zHSTORE.Comparator.deletec C s t | j|�S )zdHStore expression. Returns a subset of an hstore defined by array of keys. )�_HStoreSliceFunctionr' )r �arrayr r r �slice� s zHSTORE.Comparator.slicec C s t | j�S )z.Text array expression. Returns array of keys.)�_HStoreKeysFunctionr' )r r r r �keys� s zHSTORE.Comparator.keysc C s t | j�S )z0Text array expression. Returns array of values.)�_HStoreValsFunctionr' )r r r r �vals� s zHSTORE.Comparator.valsc C s t | j�S )z^Text array expression. Returns array of alternating keys and values. )�_HStoreArrayFunctionr' )r r r r r0 � s zHSTORE.Comparator.arrayc C s t | j�S )z<Text array expression. Returns array of [key, value] pairs.)�_HStoreMatrixFunctionr' )r r r r �matrix� s zHSTORE.Comparator.matrixN)�__name__� __module__� __qualname__�__doc__r r r r r! r% r) r. r1 r3 r5 r0 r8 r r r r � Comparator� s r= c s& t jr|j� � fdd�}ndd� }|S )Nc s t | t�rt| ��� �S | S d S )N)r* r+ r, �encode)�value)�encodingr r �process� s z&HSTORE.bind_processor.<locals>.processc S s t | t�rt| �S | S d S )N)r* r+ r, )r? r r r rA � s )r �py2kr@ )r �dialectrA r )r@ r �bind_processor� s zHSTORE.bind_processorc s& t jr|j� � fdd�}ndd� }|S )Nc s | d k rt | �� ��S | S d S )N)� _parse_hstore�decode)r? )r@ r r rA � s z(HSTORE.result_processor.<locals>.processc S s | d k rt | �S | S d S )N)rE )r? r r r rA s )r rB r@ )r rC ZcoltyperA r )r@ r �result_processor� s zHSTORE.result_processor)N)r9 r: r; r< Z__visit_name__Zhashabler �Textr r � Indexabler= � ConcatenableZcomparator_factoryrD rG r r r r r A s E Kr r c @ s e Zd ZdZeZd ZdS )r a_ Construct an hstore value within a SQL expression using the PostgreSQL ``hstore()`` function. The :class:`.hstore` function accepts one or two arguments as described in the PostgreSQL documentation. E.g.:: from sqlalchemy.dialects.postgresql import array, hstore select([hstore('key1', 'value1')]) select([ hstore( array(['key1', 'key2', 'key3']), array(['value1', 'value2', 'value3']) ) ]) .. seealso:: :class:`.HSTORE` - the PostgreSQL ``HSTORE`` datatype. N)r9 r: r; r< r r# �namer r r r r s c @ s e Zd ZejZdZdS )r& r) N)r9 r: r; r r r# rK r r r r r& 0 s r& c @ s e Zd ZeZdZdS )r- r. N)r9 r: r; r r# rK r r r r r- 5 s r- c @ s e Zd ZeZdZdS )r/ r1 N)r9 r: r; r r# rK r r r r r/ : s r/ c @ s e Zd Zeej�ZdZdS )r2 ZakeysN)r9 r: r; r r rH r# rK r r r r r2 ? s r2 c @ s e Zd Zeej�ZdZdS )r4 ZavalsN)r9 r: r; r r rH r# rK r r r r r4 D s r4 c @ s e Zd Zeej�ZdZdS )r6 Zhstore_to_arrayN)r9 r: r; r r rH r# rK r r r r r6 I s r6 c @ s e Zd Zeej�ZdZdS )r7 Zhstore_to_matrixN)r9 r: r; r r rH r# rK r r r r r7 N s r7 z� ( "(?P<key> (\\ . | [^"])* )" # Quoted key ) [ ]* => [ ]* # Pair operator, optional adjoining whitespace ( (?P<value_null> NULL ) # NULL value | "(?P<value> (\\ . | [^"])* )" # Quoted value ) z [ ]* , [ ]* c C s� d}t | �}| t|| d d�t||�� }| t||�t|| d |�� }t |�|krhd|dd� }t |�|kr�|dd� d }d|||f S )z format an unmarshalling error.� r r z[...]N���z5After %r, could not parse residual at position %d: %r)�len�max�min)� hstore_str�posZctxZhslenZ parsed_tailZresidualr r r � _parse_errorq s rS c C s� i }d}t �| �}x�|dk r�|�d��dd��dd�}|�d�rFd}n|�d ��dd��dd�}|||< ||�� 7 }t�| |d� �}|dk r�||�� 7 }t �| |d� �}qW |t| �kr�tt| |���|S ) a� Parse an hstore from its literal string representation. Attempts to approximate PG's hstore input parsing rules as closely as possible. Although currently this is not strictly necessary, since the current implementation of hstore's output syntax is stricter than what it accepts as input, the documentation makes no guarantees that will always be the case. r Nr( z\"�"z\\�\Z value_nullr? ) �HSTORE_PAIR_RE�match�group�replace�end�HSTORE_DELIMITER_RErN � ValueErrorrS )rQ �resultrR Z pair_matchr( r? Z delim_matchr r r rE � s& rE c s$ dd� � d� � fdd�| �� D ��S )zxSerialize a dictionary into an hstore literal. Keys and values must both be strings (except None for values). c S sL |dkr| d krdS t | tj�r8d| �dd��dd� S td| |f ��d S ) Nr? ZNULLz"%s"rU z\\rT z\"z"%r in %s position is not a string.)r* r Z string_typesrY r\ )�sZpositionr r r �esc� s z _serialize_hstore.<locals>.escz, c 3 s* | ]"\}}d � |d�� |d�f V qdS )z%s=>%sr( r? Nr )�.0�k�v)r_ r r � <genexpr>� s z$_serialize_hstore.<locals>.<genexpr>)�join�items)�valr )r_ r r, � s r, ),�rer0 r �baser � r r r Zsqlr Zsqlfuncr �__all__Z _PRECEDENCEZjson_getitem_opZidx_precedenceZ custom_opr" r r r r r rI rJ Z TypeEnginer ZGenericFunctionr r& r- r/ r2 r4 r6 r7 �compile�VERBOSErV r[ rS rE r, r r r r �<module> st O *
Edit
Rename
Chmod
Delete
FILE
FOLDER
Name
Size
Permission
Action
__init__.cpython-37.opt-1.pyc
2106 bytes
0644
__init__.cpython-37.pyc
2106 bytes
0644
array.cpython-37.opt-1.pyc
10782 bytes
0644
array.cpython-37.pyc
10824 bytes
0644
base.cpython-37.opt-1.pyc
104036 bytes
0644
base.cpython-37.pyc
104036 bytes
0644
dml.cpython-37.opt-1.pyc
6598 bytes
0644
dml.cpython-37.pyc
6598 bytes
0644
ext.cpython-37.opt-1.pyc
6781 bytes
0644
ext.cpython-37.pyc
6781 bytes
0644
hstore.cpython-37.opt-1.pyc
12591 bytes
0644
hstore.cpython-37.pyc
12591 bytes
0644
json.cpython-37.opt-1.pyc
10006 bytes
0644
json.cpython-37.pyc
10124 bytes
0644
pg8000.cpython-37.opt-1.pyc
10639 bytes
0644
pg8000.cpython-37.pyc
10639 bytes
0644
psycopg2.cpython-37.opt-1.pyc
27061 bytes
0644
psycopg2.cpython-37.pyc
27061 bytes
0644
psycopg2cffi.cpython-37.opt-1.pyc
1734 bytes
0644
psycopg2cffi.cpython-37.pyc
1734 bytes
0644
pygresql.cpython-37.opt-1.pyc
7990 bytes
0644
pygresql.cpython-37.pyc
7990 bytes
0644
pypostgresql.cpython-37.opt-1.pyc
3331 bytes
0644
pypostgresql.cpython-37.pyc
3331 bytes
0644
ranges.cpython-37.opt-1.pyc
5857 bytes
0644
ranges.cpython-37.pyc
5857 bytes
0644
zxjdbc.cpython-37.opt-1.pyc
1920 bytes
0644
zxjdbc.cpython-37.pyc
1920 bytes
0644
N4ST4R_ID | Naxtarrr
