ProPeler
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
opt
/
cpanel-ccs
/
txdav
/
base
/
datastore
/
Filename :
dbapiclient.pyc
back
Copy
� *��ac @ sV d Z d d l m Z d d l m Z d d l m Z d d l Z d d l Z d d l Z y) d d l Z d e j d <d d l Z Wn e k r� d Z n Xd e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d � Z d � Z d � Z d S( sF General utility client code for interfacing with DB-API 2.0 modules. i����( t mapOracleOutputType( t CachingFilePath( t InternalDataStoreErrorNs .AL32UTF8t NLS_LANGt DiagnosticCursorWrapperc B sS e Z d Z d � Z e d � � Z e d � � Z d d � Z d � Z d � Z RS( s\ Diagnostic wrapper around a DB-API 2.0 cursor for debugging connection status. c C s | | _ | | _ d S( N( t realCursort connectionWrapper( t selfR R ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyt __init__? s c C s | j j S( N( R t rowcount( R ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR C s c C s | j j S( N( R t description( R ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR G s c C s* d | f | j _ | j j | | � d S( Ns executing %r( R t stateR t execute( R t sqlt args( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR K s c C s | j j � d S( N( R t close( R ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR T s c C s | j j � } | S( N( R t fetchall( R t results( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR W s ( ( t __name__t __module__t __doc__R t propertyR R R R R ( ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR 9 s t OracleCursorWrapperc B sM e Z d Z d � Z d � Z d � Z d d � Z d d � Z d d � Z RS( sy Wrapper for cx_Oracle DB-API connections which implements fetchall() to read all CLOB objects into strings. c C sU g } xH | j D]= } g } x! | D] } | j t | � � q# W| j | � q W| S( N( R t appendR ( R t accumt rowt newRowt column( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR g s c G s | j j | � S( s� Create a cx_Oracle variable bound to this cursor. (Forwarded in addition to the standard methods so that implementors of L{IDerivedParameter} do not need to be specifically aware of this layer.) ( R t var( R R ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR p s c C s� g } x� | D]� } t | t � r4 | j d � } n t | t � r� t | � d k r� | j t j t | � d � } | j d | � n= t | t j � r� | j t j � } | j d | � n | } | j | � q W| S( Ns utf-8i i i ( t isinstancet strt decodet unicodet lenR t cx_Oraclet NCLOBt setvaluet datetimet TIMESTAMPR ( R R t realArgst argt v( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyt mapArgsy s ! c C s( | j | � } t t | � j | | � S( N( R* t superR R ( R R R R' ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR � s c C s" | j | � } | j j | | � S( N( R* R t callproc( R t nameR R' ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR, � s c C s% | j | � } | j j | | | � S( N( R* R t callfunc( R R- t returnTypeR R' ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR. � s ( ( ( ( R R R R R R* R R, R. ( ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR a s % t DiagnosticConnectionWrapperc B sA e Z d Z e Z d � Z d � Z d � Z d � Z d � Z RS( s` Diagnostic wrapper around a DB-API 2.0 connection for debugging connection status. c C s | | _ | | _ d | _ d S( Ns idle (start)( t realConnectiont labelR ( R R1 R2 ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR � s c C s | j | j j � | � S( N( t wrapperR1 t cursor( R ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR4 � s c C s | j j � d | _ d S( Nt closed( R1 R R ( R ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR � s c C s | j j � d | _ d S( Ns idle (after commit)( R1 t commitR ( R ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR6 � s c C s | j j � d | _ d S( Ns idle (after rollback)( R1 t rollbackR ( R ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR7 � s ( R R R R R3 R R4 R R6 R7 ( ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR0 � s t DBAPIParametersc B s& e Z d Z d d d d e d � Z RS( s Object that holds the parameters needed to configure a DBAPIConnector. Since this varies based on the actual DB module in use, this class abstracts the parameters into separate properties that are then used to create the actual parameters for each module. c K s� | | _ | j j d � rp | j d | _ d | j k r[ | j j d � \ | _ | _ n d | _ d | _ ng | j j d � r� d | _ | j d | _ d | j k r� | j j d � \ | _ | _ q� d | _ n | | _ | | _ | | _ | | _ d S( sO @param endpoint: endpoint string describing the connection @type endpoint: L{str} @param user: user name to connect as @type user: L{str} @param password: password to use @type password: L{str} @param database: database name to connect to @type database: L{str} s unix:i t :s tcp:i N( t endpointt startswitht unixsockett splitt portt Nonet hostt usert passwordt databaset ssl( R R: RA RB RC RD t kwargs( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR � s" ! ! N( R R R R? t FalseR ( ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR8 � s t DBAPIConnectorc B st e Z d Z e Z d � Z d d � Z e d � � Z e d � � Z e d � � Z e d � � Z e d � � Z RS( s` A simple wrapper for DB-API connectors. @ivar dbModule: the DB-API module to use. c O s( | | _ | | _ | | _ | | _ d S( N( t dbModulet connectArgst connectKwt preflight( R RH RK RI RJ ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR � s s <unlabeled>c C sD | j j | j | j � } | j | | � } | j | | j � | S( N( RH t connectRI RJ R3 RK ( R R2 t connectiont w( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyRL � s c K sQ | d k r t j t | � S| d k r8 t j t | � St d j | � � � d S( Nt postgrest oracles Unknown database type: {}( RG t _connectorFor_moduleRO R" R t format( t dbtypeRE ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyt connectorFor s c K sO t t d j | j � d � } | d k rB t d j | � � � n | | | � S( Ns _connectorFor_{}s Unknown DBAPI module: {}( t getattrRG RR R R? R ( t dbmoduleRE t m( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyRQ s c K s\ t | � } d j | � } i } | j rI d j | j | j � | d <n t t t | | � S( s2 Turn properties into pgdb kwargs s4 {0.host}:dbname={0.database}:{0.user}:{0.password}::s {}:{}R@ ( R8 RR R> R@ RG RO t postgresPreflight( RV RE t paramst dsnt dbkwargs( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyt _connectorFor_pgdb s c K s t | � } i | j d 6| j d 6| j d 6} | j rI | j | d <n | j r� | j | d <t | d � } | j � r� | j d j | j r� | j n d � � } | j | d <n | j � s t d j | j � � � q n, | j | d <| j r t | j � | d <n t | t | � S( s4 Turn properties into pg8000 kwargs RA RB RC RD t unix_socks .s.PGSQL.{}t 5432s No such socket file: {}R@ R> ( R8 RA RB RC RD R< R t isdirt childRR R> t patht isSocketR R@ t intRG t pg8000Preflight( RV RE RY R[ t socketFP( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyt _connectorFor_pg8000' s( * c K s d j t | � � } t | � S( s1 Turn properties into DSN string s4 {0.user}/{0.password}@{0.host}:{0.port}/{0.database}( RR R8 t OracleConnector( R RE RZ ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyt _connectorFor_cx_OracleI s ( R R R R0 R3 R RL t staticmethodRT RQ R\ Rf Rh ( ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyRG � s "t OracleConnectionWrapperc B s e Z e Z RS( ( R R R R3 ( ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyRj R s Rg c B s e Z d Z e Z d � Z RS( s A connector for cx_Oracle connections, with some special-cased behavior to make it work more like other DB-API bindings. Note: this is currently necessary to make our usage of twext.enterprise.dal work with cx_Oracle, and should be factored somewhere higher-level. c C s& t t | � j t t | d t �d S( Nt threaded( R+ Rg R R" t oraclePreflightt True( R RZ ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyR b s ( R R R Rj R3 R ( ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyRg W s c K s> | j � } | j d � | j d � | j � | j � d S( s� Pre-flight function for Oracle connections: set the timestamp format to be something closely resembling our default assumption from Postgres. sC alter session set NLS_TIMESTAMP_FORMAT = 'YYYY-MM-DD HH24:MI:SS.FF'sL alter session set NLS_TIMESTAMP_TZ_FORMAT = 'YYYY-MM-DD HH:MI:SS.FF+TZH:TZM'N( R4 R R6 R ( RM RE t c( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyRl g s c K sW | j � } | j d � | j d j | j d d � d � � | j � | j � d S( s� Pre-flight function for PostgreSQL connections: enable standard conforming strings, and set a non-infinite statement timeout. s" set standard_conforming_strings=ons set statement_timeout={}t txnTimeoutSecondsi i� N( R4 R RR t getR6 R ( RM RE Rn ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyRX y s & c s= t | | � d � } d t j j | f | j j t <d t j j | f | j j t j <d � � � f d � | j _ t j j � f | j j d <t j j � f | j j d <t j j � f | j j d <t j j � f | j j d <t j j � f | j j d <t j j � f | j j d <t j j � f | j j d <d S( s� Pre-flight function for pg8000/PostgreSQL connections: setup type mappings in addition to the normal postgres preflight. c S s& t | t � r | j d � St | � S( Ns utf-8( R R t encodeR ( R) ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyt my_text_out� s i� c S s t | | | | !� S( N( R ( t datat offsett length( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyt my_text_recv� s c s t j j � f S( N( RO t coret FC_TEXT( ( Rv ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyt <lambda>� t i i i= i i i� N( RX RO Rw Rx R1 t py_typesR t sixt text_typet default_factoryt FC_BINARYt pg_types( RM RE Rr ( ( Rv s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyRd � s " ( R t twext.enterprise.utilR t twext.python.filepathR t txdav.common.icommondatastoreR R% t pg8000RO R| t ost environR" t ImportErrorR? t objectR R R0 R8 RG Rj Rg Rl RX Rd ( ( ( s3 /opt/cpanel-ccs/txdav/base/datastore/dbapiclient.pyt <module> s, (J 'c