U
|
¸ý°d1 ã @ s d dl Z ddlmZ ddlmZ ddlmZ ddlm Z dZ
|
e j e j Z e jd e d
|
d
|
d Ze jd e d
|
d
|
d Ze jd e d
|
d
|
d Ze jde d
|
d
|
d Ze jde d
|
d
|
d Ze jde d
|
d
|
d ZG dd dejejejZG dd dejZG dd dejZG dd dejZ G dd dejZ G dd d ejZ G d d d ejZ G d d d ejZ G d!d" d"ejZ!e "d#e j#¡Z$e "d$e j#¡Z%d%d& Z&d'd( Z'd)d* Z(dS )+é Né )ÚARRAYé )Útypes)Ú functions)Ú operators)ÚHSTOREÚhstorez->T)Ú
|
precedenceZnatural_self_precedentZeager_groupingú?z?&z?|z@>z<@c @ sX e Zd ZdZd ZdZe ¡ Zd ddZ G dd dej
|
j ej j Z e Z dd Zd
|
d ZdS ) r a% 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`.
|
|
.. container:: topic
|
|
**Detecting Changes in HSTORE columns when using the ORM**
|
|
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`.
|
|
N)Ú text_type)Úselfr © r ú\d:\z\workplace\vscode\pyvenv\venv\Lib\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|tjdS )zvBoolean expression. Test for presence of a key. Note that the
|
key may be a SQLA expression.
|
©Z result_type)ÚoperateÚHAS_KEYÚsqltypesÚBoolean©r Úotherr r r Úhas_key s zHSTORE.Comparator.has_keyc C s | j t|tjdS )z;Boolean expression. Test for presence of all keys in jsonbr )r ÚHAS_ALLr r r r r r Úhas_all¥ s zHSTORE.Comparator.has_allc C s | j t|tjdS )z:Boolean expression. Test for presence of any key in jsonbr )r ÚHAS_ANYr r r r r r Úhas_any© s zHSTORE.Comparator.has_anyc K s | j t|tjdS )zòBoolean expression. Test if keys (or array) are a superset
|
of/contained the keys of the argument jsonb expression.
|
|
kwargs may be ignored by this operator but are required for API
|
conformance.
|
r )r ÚCONTAINSr r )r r Úkwargsr r r Úcontains s zHSTORE.Comparator.containsc C s | j t|tjdS )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 Ú 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 )zBoolean 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 |trt|}t| j|S )zHStore 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 Ú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 | jS )z.Text array expression. Returns array of keys.)Ú_HStoreKeysFunctionr( ©r r r r ÚkeysÕ s zHSTORE.Comparator.keysc C s
|
t | jS )z0Text array expression. Returns array of values.)Ú_HStoreValsFunctionr( r5 r r r ÚvalsÙ s zHSTORE.Comparator.valsc C s
|
t | jS )z^Text array expression. Returns array of alternating keys and
|
values.
|
)Ú_HStoreArrayFunctionr( r5 r r r r2 Ý s zHSTORE.Comparator.arrayc C s
|
t | jS )z<Text array expression. Returns array of [key, value] pairs.)Ú_HStoreMatrixFunctionr( r5 r r r Úmatrixã s zHSTORE.Comparator.matrixN)Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r r r r r! r& r+ r0 r3 r6 r8 r2 r; r r r r Ú
|
Comparator s r@ c C s dd }|S )Nc S s t | trt| S | S d S r" )r, r- r. ©Úvaluer r r Úprocessê s
|
z&HSTORE.bind_processor.<locals>.processr )r ÚdialectrC r r r Úbind_processoré s zHSTORE.bind_processorc C s dd }|S )Nc S s | d k rt | S | S d S r" )Ú _parse_hstorerA r r r rC ó s z(HSTORE.result_processor.<locals>.processr )r rD ZcoltyperC r r r Úresult_processorò s zHSTORE.result_processor)N)r< r= r> r? Z__visit_name__Zhashabler ÚTextr r Ú Indexabler@ Ú ConcatenableZcomparator_factoryrE rG r r r r r A s J
|
|
|
ÿM r c @ s e Zd ZdZeZd ZdZdS )r aG 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.
|
|
TN)r< r= r> r? r r$ ÚnameÚ inherit_cacher r r r r ü s r c @ s e Zd ZejZdZdZdS )r' r+ TN)r< r= r> r r r$ rK rL r r r r r' s r' c @ s e Zd ZeZdZdZdS )r/ r0 TN©r< r= r> r r$ rK rL r r r r r/ ! s r/ c @ s e Zd ZeZdZdZdS )r1 r3 TNrM r r r r r1 ' s r1 c @ s e Zd ZeejZdZdZdS )r4 ZakeysTN© r< r= r> r r rH r$ rK rL r r r r r4 - s
|
r4 c @ s e Zd ZeejZdZdZdS )r7 ZavalsTNrN r r r r r7 3 s
|
r7 c @ s e Zd ZeejZdZdZdS )r9 Zhstore_to_arrayTNrN r r r r r9 9 s
|
r9 c @ s e Zd ZeejZdZdZdS )r: Zhstore_to_matrixTNrN r r r r r: ? s
|
r: 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 dt||
}| 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ÚposÚctxZhslenZ parsed_tailZresidualr r r Ú _parse_errorc s ýrW c C sÊ i }d}t | ¡}|dk r¬| d¡ dd¡ dd¡}| d¡rDd}n| d ¡ dd¡ dd¡}|||< || ¡ 7 }t | |d
¡}|dk r|| ¡ 7 }t | |d
¡}q|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
|
value_nullrB ) ÚHSTORE_PAIR_REÚmatchÚgroupÚreplaceÚendÚHSTORE_DELIMITER_RErQ Ú
|
ValueErrorrW )rT ÚresultrU Z
|
pair_matchr* rB Z delim_matchr r r rF x s0
|
|
|
ÿ þÿ rF 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 sJ |dkr| d krdS t | tr6d| dd¡ dd¡ S td| |f d S ) NrB ÚNULLz"%s"r[ rZ rY rX z"%r in %s position is not a string.)r, Ústrr_ rb )ÚsÚpositionr r r Úesc¨ s
|
|
ÿz _serialize_hstore.<locals>.escz, c 3 s* | ]"\}}d |d |df V qdS )z%s=>%sr* rB Nr )Ú.0ÚkÚv©rh r r Ú <genexpr>² s z$_serialize_hstore.<locals>.<genexpr>)ÚjoinÚitems)Úvalr rl r r. ¢ s
|
ÿr. ))Úrer2 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/ r1 r4 r7 r9 r: ÚcompileÚVERBOSEr\ ra rW rF r. r r r r Ú<module>
|
s~ üüüüüü <
|
õü*
|
