H`Tc@s dZddlmZmZddlZddlmZddlmZddlm Z m Z m Z m Z m Z mZmZd ejfd YZd efd YZd e fdYZde fdYZde fdYZde fdYZeZdS(s .. dialect:: postgresql+pg8000 :name: pg8000 :dbapi: pg8000 :connectstring: postgresql+pg8000://user:password@host:port/dbname[?key=value&key=value...] :url: https://pythonhosted.org/pg8000/ Unicode ------- When communicating with the server, pg8000 **always uses the server-side character set**. SQLAlchemy has no ability to modify what character set pg8000 chooses to use, and additionally SQLAlchemy does no unicode conversion of any kind with the pg8000 backend. The origin of the client encoding setting is ultimately the CLIENT_ENCODING setting in postgresql.conf. It is not necessary, though is also harmless, to pass the "encoding" parameter to :func:`.create_engine` when using pg8000. .. _pg8000_isolation_level: pg8000 Transaction Isolation Level ------------------------------------- The pg8000 dialect offers the same isolation level settings as that of the :ref:`psycopg2 ` dialect: * ``READ COMMITTED`` * ``READ UNCOMMITTED`` * ``REPEATABLE READ`` * ``SERIALIZABLE`` * ``AUTOCOMMIT`` .. versionadded:: 0.9.5 support for AUTOCOMMIT isolation level when using pg8000. .. seealso:: :ref:`postgresql_isolation_level` :ref:`psycopg2_isolation_level` i(tutiltexciN(t processors(ttypesi(t PGDialectt PGCompilertPGIdentifierPreparertPGExecutionContextt_DECIMAL_TYPESt _FLOAT_TYPESt _INT_TYPESt _PGNumericcBseZdZRS(cCs|jr]|tkr+tjtj|jS|tksC|tkrGdSt j d|nB|tkrmdS|tks|tkrtj St j d|dS(NsUnknown PG numeric type: %d( t asdecimalR Rtto_decimal_processor_factorytdecimaltDecimalt_effective_decimal_return_scaleRR tNoneRtInvalidRequestErrortto_float(tselftdialecttcoltype((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pytresult_processor@s   (t__name__t __module__R(((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR ?st_PGNumericNoBindcBseZdZRS(cCsdS(N(R(RR((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pytbind_processorWs(RRR(((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyRVstPGExecutionContext_pg8000cBseZRS((RR(((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR[stPGCompiler_pg8000cBseZdZdZRS(cKs*|j|j|d|j|j|S(Ns %% (tprocesstlefttright(Rtbinarytoperatortkw((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pytvisit_mod_binary`scCs,d|krtjdn|jddS(Ns%%s^The SQLAlchemy postgresql dialect now automatically escapes '%' in text() expressions to '%%'.t%(Rtwarntreplace(Rttext((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pytpost_process_textds (RRR$R)(((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR_s tPGIdentifierPreparer_pg8000cBseZdZRS(cCs(|j|j|j}|jddS(NR%s%%(R't escape_quotetescape_to_quote(Rtvalue((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt_escape_identifierms(RRR.(((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR*lstPGDialect_pg8000cBseZdZeZeZdZeZeZ e Z e Z dZejejieej6eej6ZdZedZdZdZdZdZd Zee d Z!ee d Z"d Z#RS( tpg8000tformatt use_encodingcCs|jrUt|jdrUtg|jjjdD]}t|^q4|_n d|_|jdk|_tt |j |dS( Nt __version__t.icii i(icicic(ii i( tdbapithasattrttupleR3tsplittintt_dbapi_versiontsupports_sane_multi_rowcounttsuperR/t initialize(Rt connectiontx((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR=s4 cCs tdS(NR0(t __import__(tcls((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR5scCsO|jdd}d|kr5t|d|dtcursor((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt is_disconnectscCs|jdd}t|dr-|j}n|dkrEt|_nz||jkrt|_|j}|jd||jd|j n+t j d||j dj |jfdS( Nt_t R>t AUTOCOMMITs=SET SESSION CHARACTERISTICS AS TRANSACTION ISOLATION LEVEL %stCOMMITsZInvalid value '%s' for isolation_level. Valid isolation levels for %s are %s or AUTOCOMMITs, (R'R6R>tTruet autocommitt_isolation_lookuptFalseRMtexecutetcloseRt ArgumentErrortnametjoin(RR>tlevelRM((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pytset_isolation_levels        cCs(d|fGH|jjd|dfdS(Nsbegin twophaseit(R>t tpc_begin(RR>txid((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pytdo_begin_twophases cCsd|fGH|jjdS(Nsprepare twophase(R>t tpc_prepare(RR>R`((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pytdo_prepare_twophases cCs|jjd|dfdS(NiR^(R>t tpc_rollback(RR>R`t is_preparedtrecover((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pytdo_rollback_twophasescCs|jjd|dfdS(NiR^(R>t tpc_commit(RR>R`ReRf((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pytdo_commit_twophasescCs$g|jjD]}|d^qS(Ni(R>t tpc_recover(RR>trow((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pytdo_recover_twophases($RRtdriverRStsupports_unicode_statementstsupports_unicode_bindstdefault_paramstyleR;Rtexecution_ctx_clsRtstatement_compilerR*tpreparertdescription_encodingRt update_copyRtcolspecsRtsqltypestNumericR tFloatR=t classmethodR5RJRNR]RaRcRVRgRiRl(((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyR/rs0       (t__doc__R^RRRRRRwtbaseRRRRRR R RxR RRRR*R/R(((sk/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/dialects/postgresql/pg8000.pyt5s 4 Y