B
    \&                 @   s6  d dl mZ ddlmZ ddlmZ ddlmZ ddlmZ ddl	m
Z
 d	Ze
je
j Ze
jd
edddZe
jdedddZe
jdedddZe
jdedddZe
jdedddZe
jdedddZe
jdedddZG dd dejjZeeejj< G dd dejZeeej< eed< G dd deZeed< dS )    )absolute_import   )colspecs)ischema_names   )types)util)	operators)JSONJSONBz->>T)Z
precedenceZnatural_self_precedentZeager_groupingz#>>?z?&z?|z@>z<@c               @   s   e Zd Zdd Zdd ZdS )JSONPathTypec                s   |  |  fdd}|S )Nc                s>   t | tjjstdd | D }dd| }  r: | } | S )Nc             S   s   g | ]}t |qS  )r   	text_type).0elemr   r   Blib/python3.7/site-packages/sqlalchemy/dialects/postgresql/json.py
<listcomp>M   s    z@JSONPathType.bind_processor.<locals>.process.<locals>.<listcomp>z{%s}z, )
isinstancer   collections_abcSequenceAssertionErrorjoin)valuetokens)
super_procr   r   processK   s    z,JSONPathType.bind_processor.<locals>.process)Zstring_bind_processor)selfdialectr   r   )r   r   bind_processorH   s    
zJSONPathType.bind_processorc                s   |  |  fdd}|S )Nc                s>   t | tjjstdd | D }dd| }  r: | } | S )Nc             S   s   g | ]}t |qS r   )r   r   )r   r   r   r   r   r   Z   s    zCJSONPathType.literal_processor.<locals>.process.<locals>.<listcomp>z{%s}z, )r   r   r   r   r   r   )r   r   )r   r   r   r   X   s    z/JSONPathType.literal_processor.<locals>.process)Zstring_literal_processor)r   r   r   r   )r   r   literal_processorU   s    
zJSONPathType.literal_processorN)__name__
__module____qualname__r   r    r   r   r   r   r   G   s   r   c                   sB   e Zd ZdZe Zd fdd	ZG dd dejj	Z	e	Z
  ZS )	r
   a 	  Represent the PostgreSQL JSON type.

    This type is a specialization of the Core-level :class:`.types.JSON`
    type.   Be sure to read the documentation for :class:`.types.JSON` for
    important tips regarding treatment of NULL values and ORM use.

    .. versionchanged:: 1.1 :class:`.postgresql.JSON` is now a PostgreSQL-
       specific specialization of the new :class:`.types.JSON` type.

    The operators provided by the PostgreSQL version of :class:`.JSON`
    include:

    * Index operations (the ``->`` operator)::

        data_table.c.data['some key']

        data_table.c.data[5]


    * Index operations returning text (the ``->>`` operator)::

        data_table.c.data['some key'].astext == 'some value'

    * Index operations with CAST
      (equivalent to ``CAST(col ->> ['some key'] AS <type>)``)::

        data_table.c.data['some key'].astext.cast(Integer) == 5

    * Path index operations (the ``#>`` operator)::

        data_table.c.data[('key_1', 'key_2', 5, ..., 'key_n')]

    * Path index operations returning text (the ``#>>`` operator)::

        data_table.c.data[('key_1', 'key_2', 5, ..., 'key_n')].astext == 'some value'

    .. versionchanged:: 1.1  The :meth:`.ColumnElement.cast` operator on
       JSON objects now requires that the :attr:`.JSON.Comparator.astext`
       modifier be called explicitly, if the cast works only from a textual
       string.

    Index operations return an expression object whose type defaults to
    :class:`.JSON` by default, so that further JSON-oriented instructions
    may be called upon the result type.

    Custom serializers and deserializers are specified at the dialect level,
    that is using :func:`.create_engine`.  The reason for this is that when
    using psycopg2, the DBAPI only allows serializers at the per-cursor
    or per-connection level.   E.g.::

        engine = create_engine("postgresql://scott:tiger@localhost/test",
                                json_serializer=my_serialize_fn,
                                json_deserializer=my_deserialize_fn
                        )

    When using the psycopg2 dialect, the json_deserializer is registered
    against the database using ``psycopg2.extras.register_default_json``.

    .. seealso::

        :class:`.types.JSON` - Core level JSON type

        :class:`.JSONB`

    FNc                s$   t t| j|d |dk	r || _dS )a   Construct a :class:`.JSON` type.

        :param none_as_null: if True, persist the value ``None`` as a
         SQL NULL value, not the JSON encoding of ``null``.   Note that
         when this flag is False, the :func:`.null` construct can still
         be used to persist a NULL value::

             from sqlalchemy import null
             conn.execute(table.insert(), data=null())

         .. versionchanged:: 0.9.8 - Added ``none_as_null``, and :func:`.null`
            is now supported in order to persist a NULL value.

         .. seealso::

              :attr:`.JSON.NULL`

        :param astext_type: the type to use for the
         :attr:`.JSON.Comparator.astext`
         accessor on indexed attributes.  Defaults to :class:`.types.Text`.

         .. versionadded:: 1.1

         )none_as_nullN)superr
   __init__astext_type)r   r$   r'   )	__class__r   r   r&      s    zJSON.__init__c               @   s   e Zd ZdZedd ZdS )zJSON.Comparatorz0Define comparison operations for :class:`.JSON`.c             C   sP   t | jjjtjjr0| jjjt	| jj| jj
dS | jjjt| jj| jj
dS dS )a  On an indexed expression, use the "astext" (e.g. "->>")
            conversion when rendered in SQL.

            E.g.::

                select([data_table.c.data['some key'].astext])

            .. seealso::

                :meth:`.ColumnElement.cast`

            )result_typeN)r   exprrighttypesqltypesr
   r   leftoperateJSONPATH_ASTEXTr'   ASTEXT)r   r   r   r   astext   s    zJSON.Comparator.astextN)r!   r"   r#   __doc__propertyr2   r   r   r   r   
Comparator   s   r5   )FN)r!   r"   r#   r3   r-   ZTextr'   r&   r
   r5   comparator_factory__classcell__r   r   )r(   r   r
   f   s
   Ar
   Zjsonc               @   s*   e Zd ZdZd ZG dd dejZeZdS )r   a_  Represent the PostgreSQL JSONB type.

    The :class:`.JSONB` type stores arbitrary JSONB format data, e.g.::

        data_table = Table('data_table', metadata,
            Column('id', Integer, primary_key=True),
            Column('data', JSONB)
        )

        with engine.connect() as conn:
            conn.execute(
                data_table.insert(),
                data = {"key1": "value1", "key2": "value2"}
            )

    The :class:`.JSONB` type includes all operations provided by
    :class:`.JSON`, including the same behaviors for indexing operations.
    It also adds additional operators specific to JSONB, including
    :meth:`.JSONB.Comparator.has_key`, :meth:`.JSONB.Comparator.has_all`,
    :meth:`.JSONB.Comparator.has_any`, :meth:`.JSONB.Comparator.contains`,
    and :meth:`.JSONB.Comparator.contained_by`.

    Like the :class:`.JSON` type, the :class:`.JSONB` type does not detect
    in-place changes when used with the ORM, unless the
    :mod:`sqlalchemy.ext.mutable` extension is used.

    Custom serializers and deserializers
    are shared with the :class:`.JSON` class, using the ``json_serializer``
    and ``json_deserializer`` keyword arguments.  These must be specified
    at the dialect level using :func:`.create_engine`.  When using
    psycopg2, the serializers are associated with the jsonb type using
    ``psycopg2.extras.register_default_jsonb`` on a per-connection basis,
    in the same way that ``psycopg2.extras.register_default_json`` is used
    to register these handlers with the json type.

    .. versionadded:: 0.9.7

    .. seealso::

        :class:`.JSON`

    c               @   s8   e Zd ZdZdd Zdd Zdd Zdd	 Zd
d ZdS )zJSONB.Comparatorz0Define comparison operations for :class:`.JSON`.c             C   s   | j t|tjdS )zvBoolean expression.  Test for presence of a key.  Note that the
            key may be a SQLA expression.
            )r)   )r/   HAS_KEYr-   Boolean)r   otherr   r   r   has_key  s    zJSONB.Comparator.has_keyc             C   s   | j t|tjdS )zHBoolean expression.  Test for presence of all keys in jsonb
            )r)   )r/   HAS_ALLr-   r9   )r   r:   r   r   r   has_all#  s    zJSONB.Comparator.has_allc             C   s   | j t|tjdS )zGBoolean expression.  Test for presence of any key in jsonb
            )r)   )r/   HAS_ANYr-   r9   )r   r:   r   r   r   has_any(  s    zJSONB.Comparator.has_anyc             K   s   | j t|tjdS )zBoolean expression.  Test if keys (or array) are a superset
            of/contained the keys of the argument jsonb expression.
            )r)   )r/   CONTAINSr-   r9   )r   r:   kwargsr   r   r   contains-  s    zJSONB.Comparator.containsc             C   s   | j t|tjdS )z|Boolean expression.  Test if keys are a proper subset of the
            keys of the argument jsonb expression.
            )r)   )r/   CONTAINED_BYr-   r9   )r   r:   r   r   r   contained_by3  s    zJSONB.Comparator.contained_byN)	r!   r"   r#   r3   r;   r=   r?   rB   rD   r   r   r   r   r5     s   r5   N)r!   r"   r#   r3   Z__visit_name__r
   r5   r6   r   r   r   r   r      s   *!r   ZjsonbN)Z
__future__r   baser   r    r   r-   r   Zsqlr	   __all__Z_PRECEDENCEZjson_getitem_opZidx_precedenceZ	custom_opr1   r0   r8   r<   r>   r@   rC   r
   r   r   r   r   r   r   <module>   sd    
R