/
opt
/
alt
/
python27
/
lib64
/
python2.7
/
site-packages
/
sqlalchemy
/
dialects
/
sqlite
/
up file
home
� 1��fc @ s d 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 d l m Z d d l m Z d d d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d d d � � YZ d e f d � � YZ d e f d � � YZ e Z d S( sZ .. dialect:: sqlite+aiosqlite :name: aiosqlite :dbapi: aiosqlite :connectstring: sqlite+aiosqlite:///file_path :url: https://pypi.org/project/aiosqlite/ The aiosqlite dialect provides support for the SQLAlchemy asyncio interface running on top of pysqlite. aiosqlite is a wrapper around pysqlite that uses a background thread for each connection. It does not actually use non-blocking IO, as SQLite databases are not socket-based. However it does provide a working asyncio interface that's useful for testing and prototyping purposes. Using a special asyncio mediation layer, the aiosqlite dialect is usable as the backend for the :ref:`SQLAlchemy asyncio <asyncio_toplevel>` extension package. This dialect should normally be used only with the :func:`_asyncio.create_async_engine` engine creation function:: from sqlalchemy.ext.asyncio import create_async_engine engine = create_async_engine("sqlite+aiosqlite:///filename") The URL passes through all arguments to the ``pysqlite`` driver, so all connection arguments are the same as they are for that of :ref:`pysqlite`. .. _aiosqlite_udfs: User-Defined Functions ---------------------- aiosqlite extends pysqlite to support async, so we can create our own user-defined functions (UDFs) in Python and use them directly in SQLite queries as described here: :ref:`pysqlite_udfs`. i ( t SQLiteExecutionContext( t SQLiteDialect_pysqlitei ( t pool( t util( t AdaptedConnection( t await_fallback( t await_onlyt AsyncAdapt_aiosqlite_cursorc B sk e Z d Z e Z d � Z d � Z d d � Z d � Z d � Z d � Z d � Z d d � Z d � Z RS( t _adapt_connectiont _connectiont descriptiont await_t _rowst arraysizet rowcountt lastrowidc C sI | | _ | j | _ | j | _ d | _ d | _ d | _ g | _ d S( Ni i����( R R R R R t NoneR R ( t selft adapt_connection( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyt __init__G s c C s g | j (d S( N( R ( R ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyt closeP s c C s y� | j | j j � � } | d k r@ | j | j | � � n | j | j | | � � | j r� | j | _ d | _ | _ | j s� | j | j � � | _ q� n! d | _ | j | _ | j | _ | j s� | j | j � � n | | _ Wn# t k r} | j j | � n Xd S( Ni����( R R t cursorR t executeR R R t server_sidet fetchallR R t _cursort ExceptionR t _handle_exception( R t operationt parametersR t error( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR S s$ c C s� yi | j | j j � � } | j | j | | � � d | _ | j | _ | j | _ | j | j � � Wn# t k r� } | j j | � n Xd S( N( R R R t executemanyR R R R R R R R ( R R t seq_of_parametersR R ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR n s c G s d S( N( ( R t inputsizes( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyt setinputsizesy s c c s% x | j r | j j d � Vq Wd S( Ni ( R t pop( R ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyt __iter__| s c C s! | j r | j j d � Sd Sd S( Ni ( R R# R ( R ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyt fetchone� s c C s= | d k r | j } n | j d | !} | j | | j (| S( Ni ( R R R ( R t sizet retval( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyt fetchmany� s c C s | j } g | j (| S( N( R ( R R' ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR � s ( R R R R R R R R N( t __name__t __module__t __slots__t FalseR R R R R R R" R$ R% R( R ( ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR 9 s$ t AsyncAdapt_aiosqlite_ss_cursorc B sD e Z d Z e Z d � Z d � Z d � Z d d � Z d � Z RS( R c O s t � j | | � d | _ d S( N( t superR R R ( R t argt kw( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR � s c C s5 | j d k r1 | j | j j � � d | _ n d S( N( R R R R ( R ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR � s c C s | j | j j � � S( N( R R R% ( R ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR% � s c C s4 | d k r | j } n | j | j j d | � � S( NR& ( R R R R R( ( R R& ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR( � s c C s | j | j j � � S( N( R R R ( R ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR � s N( R) R* R+ t TrueR R R R% R R( R ( ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR- � s t AsyncAdapt_aiosqlite_connectionc B s� e Z e e � Z d Z d � Z e d � � Z e j d � � Z d � Z e d � Z d � Z d � Z d � Z d � Z d � Z RS( t dbapiR c C s | | _ | | _ d S( N( R3 R ( R R3 t connection( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR � s c C s | j j S( N( R t isolation_level( R ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR5 � s c C s7 y | | j _ Wn t k r2 } | j | � n Xd S( N( R R5 R R ( R t valueR ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR5 � s c O sG y | j | j j | | � � Wn t k rB } | j | � n Xd S( N( R R t create_functionR R ( R t argsR0 R ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR7 � s c C s | r t | � St | � Sd S( N( R- R ( R R ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR � s c O s | j | j j | | � � S( N( R R R ( R R8 R0 ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR � s c C sA y | j | j j � � Wn t k r< } | j | � n Xd S( N( R R t rollbackR R ( R R ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR9 � s c C sA y | j | j j � � Wn t k r< } | j | � n Xd S( N( R R t commitR R ( R R ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR: � s c C sA y | j | j j � � Wn t k r< } | j | � n Xd S( N( R R R R R ( R R ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR � s c C sQ t | t � rG | j d d k rG t j | j j j d � d | �n | � d S( Ni s no active connectiont from_( t isinstancet ValueErrorR8 R t raise_R3 t sqlitet OperationalError( R R ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR � s ( R3 R ( R) R* t staticmethodR R R+ R t propertyR5 t setterR7 R, R R R9 R: R R ( ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR2 � s t' AsyncAdaptFallback_aiosqlite_connectionc B s e Z d Z e e � Z RS( ( ( R) R* R+ RA R R ( ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyRD � s t AsyncAdapt_aiosqlite_dbapic B s# e Z d � Z d � Z d � Z RS( c C s) | | _ | | _ d | _ | j � d S( Nt qmark( t aiosqliteR? t paramstylet _init_dbapi_attributes( R RG R? ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR � s c C s� x* d D]" } t | | t | j | � � q Wx* d D]" } t | | t | j | � � q4 Wx* d D]" } t | | t | j | � � qa Wd S( Nt DatabaseErrort Errort IntegrityErrort NotSupportedErrorR@ t ProgrammingErrort sqlite_versiont sqlite_version_infot PARSE_COLNAMESt PARSE_DECLTYPESt Binary( RJ RK RL RM R@ RN RO RP ( RQ RR ( RS ( t setattrt getattrRG R? ( R t name( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyRI � s c O ss | j d t � } t | d <| j j | | � } t | _ t j | � r\ t | t | � � St | t | � � Sd S( Nt async_fallbackt check_same_thread( R# R, RG t connectR1 t daemonR t asboolRD R R2 R ( R R/ R0 RW R4 ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyRY s ( R) R* R RI RY ( ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyRE � s t SQLiteExecutionContext_aiosqlitec B s e Z d � Z RS( c C s | j j d t � S( NR ( t _dbapi_connectionR R1 ( R ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyt create_server_side_cursor0 s ( R) R* R^ ( ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR\ / s t SQLiteDialect_aiosqlitec B sV e Z d Z e Z e Z e Z e Z e d � � Z e d � � Z d � Z d � Z RS( RG c C s t t d � t d � � S( NRG t sqlite3( RE t __import__( t cls( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR3 > s c C s! | j | � r t j St j Sd S( N( t _is_url_file_dbR t NullPoolt StaticPool( Rb t url( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyt get_pool_classD s c C sA t | | j j � r+ d t | � k r+ t St � j | | | � S( Ns no active connection( R< R3 R@ t strR1 R. t is_disconnect( R t eR4 R ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyRi K s c C s | j S( N( R ( R R4 ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyt get_driver_connectionS s ( R) R* t driverR1 t supports_statement_cachet is_asynct supports_server_side_cursorsR\ t execution_ctx_clst classmethodR3 Rg Ri Rk ( ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyR_ 4 s N( ( ( t __doc__t baseR t pysqliteR t R R t engineR t util.concurrencyR R R R- R2 RD RE R\ R_ t dialect( ( ( sW /opt/alt/python27/lib64/python2.7/site-packages/sqlalchemy/dialects/sqlite/aiosqlite.pyt <module>. s [A:#