σ H`ΎTc@@sβddlmZddlZddlmZddlmZddlm Z ddlm Z dd l m Z dd lm Z dZ d e jfd„ƒYZd ejfd„ƒYZeed key``. Modifiers are then available for typing behavior, including :meth:`.JSONElement.cast` and :attr:`.JSONElement.astext`. cC@sΌ||_|dkrft|dƒr]t|tjƒ r]d}ddjd„|Dƒƒ}qfd}n||_t|ddƒ}|j |||ƒ}t t |ƒj |||d |ƒdS( Nt__iter__s#>s{%s}s, cs@s|]}tj|ƒVqdS(N(Rt text_type(t.0telem((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pys +ss->t precedenceittype_( t_astexttNonethasattrt isinstanceRt string_typestjoint_json_opstringRt_check_literaltsuperRt__init__(tselftlefttrighttastexttopstringt result_typetoperator((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyR#s    c C@sI|jr |St|j|jdtd|jddtjdtƒƒSdS(sκConvert this :class:`.JSONElement` to use the 'astext' operator when evaluated. E.g.:: select([data_table.c.data['some key'].astext]) .. seealso:: :meth:`.JSONElement.cast` RRt>Rtconvert_unicodeN(RRRRtTrueRtsqltypestString(R((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyR5s   cC@s-|js|jj|ƒStj||ƒSdS(sConvert this :class:`.JSONElement` to apply both the 'astext' operator as well as an explicit type cast when evaulated. E.g.:: select([data_table.c.data['some key'].cast(Integer)]) .. seealso:: :attr:`.JSONElement.astext` N(RRtcastR(RR((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyR&Ns N( t__name__t __module__t__doc__tFalseRRtpropertyRR&(((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyRs  cB@sNeZdZdZed„Zdejjfd„ƒYZ d„Z d„Z RS(s‡ Represent the Postgresql JSON type. The :class:`.JSON` type stores arbitrary JSON format data, e.g.:: data_table = Table('data_table', metadata, Column('id', Integer, primary_key=True), Column('data', JSON) ) with engine.connect() as conn: conn.execute( data_table.insert(), data = {"key1": "value1", "key2": "value2"} ) :class:`.JSON` provides several operations: * Index operations:: data_table.c.data['some key'] * Index operations returning text (required for text comparison):: data_table.c.data['some key'].astext == 'some value' * Index operations with a built-in CAST call:: data_table.c.data['some key'].cast(Integer) == 5 * Path index operations:: data_table.c.data[('key_1', 'key_2', ..., 'key_n')] * Path index operations returning text (required for text comparison):: data_table.c.data[('key_1', 'key_2', ..., 'key_n')].astext == \ 'some value' Index operations return an instance of :class:`.JSONElement`, which represents an expression such as ``column -> index``. This element then defines methods such as :attr:`.JSONElement.astext` and :meth:`.JSONElement.cast` for setting up type behavior. The :class:`.JSON` type, when used with the SQLAlchemy ORM, does not detect in-place mutations to the structure. In order to detect these, the :mod:`sqlalchemy.ext.mutable` extension must be used. This extension will allow "in-place" changes to the datastructure to produce events which will be detected by the unit of work. See the example at :class:`.HSTORE` for a simple example involving a dictionary. 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``. .. versionadded:: 0.9 RcC@s ||_dS(sConstruct 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. N(t none_as_null(RR,((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyR§stcomparator_factorycB@s eZdZd„Zd„ZRS(s0Define comparison operations for :class:`.JSON`.cC@st|j|ƒS(sGet the value at a given key.(Rtexpr(Rtother((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyt __getitem__»scC@sGt|tƒr.|jdkr.|tjfSntjjj|||ƒS(Ns->(RRRR$tTextt Concatenablet Comparatort_adapt_expression(Rtoptother_comparator((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyR4ΐs  (R'R(R)R0R4(((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyR-Έs c@sR|jptj‰tjr<|j‰‡‡‡fd†}n‡‡fd†}|S(Nc@s>t|tjƒs'|dkr+ˆjr+dSˆ|ƒjˆƒS(N(RRtNullRR,tencode(tvalue(tencodingRtjson_serializer(si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pytprocessΜsc@s5t|tjƒs'|dkr+ˆjr+dSˆ|ƒS(N(RRR7RR,(R9(RR;(si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyR<Σs(t_json_serializertjsontdumpsRtpy2kR:(RtdialectR<((R:RR;si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pytbind_processorΗs   c@sL|jptj‰tjr9|j‰‡‡fd†}n‡fd†}|S(Nc@s#|dkrdSˆ|jˆƒƒS(N(Rtdecode(R9(tjson_deserializerR:(si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyR<ΰs c@s|dkrdSˆ|ƒS(N(R(R9(RD(si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyR<εs (t_json_deserializerR>tloadsRR@R:(RRAtcoltypeR<((R:RDsi/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pytresult_processorΫs   ( R'R(R)t__visit_name__R*RR$R2R3R-RBRH(((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyRas B  R>cB@s6eZdZdZeZdejjfd„ƒYZ RS(sŽ 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"} ) :class:`.JSONB` provides several operations: * Index operations:: data_table.c.data['some key'] * Index operations returning text (required for text comparison):: data_table.c.data['some key'].astext == 'some value' * Index operations with a built-in CAST call:: data_table.c.data['some key'].cast(Integer) == 5 * Path index operations:: data_table.c.data[('key_1', 'key_2', ..., 'key_n')] * Path index operations returning text (required for text comparison):: data_table.c.data[('key_1', 'key_2', ..., 'key_n')].astext == \ 'some value' Index operations return an instance of :class:`.JSONElement`, which represents an expression such as ``column -> index``. This element then defines methods such as :attr:`.JSONElement.astext` and :meth:`.JSONElement.cast` for setting up type behavior. The :class:`.JSON` type, when used with the SQLAlchemy ORM, does not detect in-place mutations to the structure. In order to detect these, the :mod:`sqlalchemy.ext.mutable` extension must be used. This extension will allow "in-place" changes to the datastructure to produce events which will be detected by the unit of work. See the example at :class:`.HSTORE` for a simple example involving a dictionary. 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``. .. versionadded:: 0.9.7 R R-cB@sMeZdZd„Zd„Zd„Zd„Zd„Zd„Zd„Z RS(s0Define comparison operations for :class:`.JSON`.cC@st|j|ƒS(sGet the value at a given key.(RR.(RR/((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyR09scC@sct|tƒrJ|jdkr+|tjfS|jdkrJ|tjfSntjjj|||ƒS(Nt?s?&s?|s@>s<@s->(RJs?&s?|s@>s<@( RRRR$tBooleanR1R2R3R4(RR5R6((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyR4>s  cC@s|jjdƒ|ƒS(svBoolean expression. Test for presence of a key. Note that the key may be a SQLA expression. RJ(R.R5(RR/((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pythas_keyIscC@s|jjdƒ|ƒS(sHBoolean expression. Test for presence of all keys in jsonb s?&(R.R5(RR/((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pythas_allOscC@s|jjdƒ|ƒS(sGBoolean expression. Test for presence of any key in jsonb s?|(R.R5(RR/((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pythas_anyTscK@s|jjdƒ|ƒS(sŒBoolean expression. Test if keys (or array) are a superset of/contained the keys of the argument jsonb expression. s@>(R.R5(RR/tkwargs((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pytcontainsYscC@s|jjdƒ|ƒS(s|Boolean expression. Test if keys are a proper subset of the keys of the argument jsonb expression. s<@(R.R5(RR/((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyt contained_by_s( R'R(R)R0R4RLRMRNRPRQ(((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyR-6s     ( R'R(R)RIR*thashableR$R2R3R-(((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyR οsBtjsonb(sJSONs JSONElementsJSONB(t __future__RR>tbaseRtRR$t sql.operatorsRRRRt__all__tBinaryExpressionRt TypeEngineRR (((si/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/json.pyts L‹ v