x\c@ sdZddlmZmZddlmZddlmZmZmZddl m Z ddl Z ddl Z ddl ZddljjZddlmZmZmZmZmZddlmZmZmZdd lmZdd lmZdd l m!Z!m"Z"dd l#m$Z$dd l%m&Z&de'fdYZ(de)fdYZ*e+a,dZ-dZ.dZ/e+e+dZ0dZ1e+e2e+dZ3e+e+dZ4e+e+e2e+e+e+dZ5e+e2e+e+e+dZ6e+e2e+e+e+e+dZ7e+de2e+e+e+e+dZ8e+dZ9e9Z:dZ;e+e+e<d Z=d!e$fd"YZ>d#e$fd$YZ?d%e?fd&YZ@id'd(6d)d*6d+d,6d-d.6d/d06d1d26d+d36ZAd4ZBd5ZCd6ZDd7e>fd8YZEd9e?fd:YZFe+e+e+d;ZGdS(<s| Collection of query wrappers / abstractions to both facilitate data retrieval and to reduce dependency on DB-specific API. i(tdivisiontprint_function(tcontextmanager(tdatetdatetimettime(tpartialN(tmaptraise_with_tracebackt string_typest text_typetzip(tis_datetime64tz_dtypet is_dict_liket is_list_like(tDatetimeTZDtype(tisna(t DataFrametSeries(t PandasObject(t to_datetimetSQLAlchemyRequiredcB seZRS((t__name__t __module__(((s,lib/python2.7/site-packages/pandas/io/sql.pyRst DatabaseErrorcB seZRS((RR(((s,lib/python2.7/site-packages/pandas/io/sql.pyR#scC stdkryddl}taddlm}|j}|||dkrddlm}ddlm }||dd}nWqt k rt aqXntrddl}t ||j jSt SdS(Ni(t LooseVersions0.8.2(t BigInteger(tcompilestsqlitec[ sdS(NtINTEGER((ttype_tcompilertkw((s,lib/python2.7/site-packages/pandas/io/sql.pytcompile_big_int_sqlite=s(t_SQLALCHEMY_INSTALLEDtNonet sqlalchemytTruetdistutils.versionRt __version__Rtsqlalchemy.ext.compilerRt ImportErrortFalset isinstancetenginet Connectable(tconR$RtverRRR!((s,lib/python2.7/site-packages/pandas/io/sql.pyt_is_sqlalchemy_connectable-s       cC sN|g}|dk rJt|dr4||g7}qJ|t|g7}n|S(s9Convert SQL and params args to DBAPI2.0 compliant format.tkeysN(R#thasattrtlist(tsqltparamstargs((s,lib/python2.7/site-packages/pandas/io/sql.pyt_convert_paramsJs   cC sL|tks$|dks$|tkr-g}nt|dsH|g}n|S(s3Process parse_dates argument for read_sql functionst__iter__N(R%R#R*R2(t parse_dates((s,lib/python2.7/site-packages/pandas/io/sql.pyt_process_parse_dates_argumentUs $  c C st|tr"t|dd|S|dkrgt|jjtjs^t|jjtj rgd}n|dkrt|dd d |d |St |rt|d t St|dd d|d |SdS(NterrorstignoretstDtdthtmtmstustnstcoercetunittutctformat(R>R?R@RAR=RBRCRD( R+tdictRR#t issubclasstdtypettypetnptfloatingtintegerR R%(tcolRGRH((s,lib/python2.7/site-packages/pandas/io/sql.pyt_handle_date_column`s$   cC st|}xs|jD]e\}}t|s=||kry||}Wntk rdd}nXt|d|||`. .. versionadded:: 0.24.0 Rtreplacetappends '{0}' is not valid for if_existsRhs9'frame' argument should be either a Series or a DataFramet if_existstindext index_labelRmRKtmethodN(RRR( RtRHRcR+Rtto_frameRRotto_sql( R`RkR.RhRRRRmRKRRf((s,lib/python2.7/site-packages/pandas/io/sql.pyRs/  cC st|d|}|j|S(s- Check if DataBase has named table. Parameters ---------- table_name: string Name of SQL table. con: SQLAlchemy connectable(engine/connection) or sqlite3 DBAPI2 connection Using SQLAlchemy makes it possible to use any DB supported by that library. If a DBAPI2 object, only sqlite3 is supported. schema : string, default None Name of SQL schema in database to write to (if database flavor supports this). If None, use default schema (default). Returns ------- boolean Rh(RcR}(RwR.RhRf((s,lib/python2.7/site-packages/pandas/io/sql.pyR}scC sSt|trOyddl}Wntk r8taqOX|j|}|Sn|S(sw Returns a SQLAlchemy engine from a URI (if con is a string) else it just return con without modifying it. iN(R+R R$R)R*R"t create_engine(R.R$((s,lib/python2.7/site-packages/pandas/io/sql.pyRns  cC s`t|}t|r.t|d|d|St|trLtdnt|d|SdS(sm Convenience function to return the correct PandasSQL subclass based on the provided parameters. RhRls.Using URI string without sqlalchemy installed.RbN(RnR0RuR+R R)R|(R.RhRlRb((s,lib/python2.7/site-packages/pandas/io/sql.pyRcs   tSQLTablec B seZdZdedddddddZdZdZdZdZ dZ d Z d Z ddd Z edd Zedddd ZdZdZdZddZdZdZRS(s For mapping Pandas tables to SQL tables. Uses fact that table is reflected by SQLAlchemy to do better type conversions. Also holds various flags needed to avoid having to pass them between functions all the time. Rtpandasc C s||_||_||_||_|j|||_||_||_| |_| |_ |dk r{|j |_ n|jj |j|j|_ |j dkrtdjd|ndS(NsCould not init table '{name}'Rk(Rktpd_sqltprefixR`t _index_nameRRhRR1RKR#t_create_table_setupRxt get_tableRtRH( tselfRktpandas_sql_engineR`RRRRRhR1RK((s,lib/python2.7/site-packages/pandas/io/sql.pyt__init__s         cC s|jj|j|jS(N(RR}RkRh(R((s,lib/python2.7/site-packages/pandas/io/sql.pytexists/scC s2ddlm}t||jj|jjS(Ni(t CreateTable(RpRtstrRxtcompileRt connectable(RR((s,lib/python2.7/site-packages/pandas/io/sql.pyt sql_schema2scC s,|jj|jj|_|jjdS(N(Rxt tometadataRRltcreate(R((s,lib/python2.7/site-packages/pandas/io/sql.pyt_execute_create6scC s|jr|jdkr9tdjd|jq|jdkrn|jj|j|j|jq|jdkrqtdj|jn |jdS(NRsTable '{name}' already exists.RkRRs '{0}' is not valid for if_exists( RRRtRHRkRt drop_tableRhR(R((s,lib/python2.7/site-packages/pandas/io/sql.pyR;s  cC sEg|D]}tt||^q}|j|jj|dS(s3Execute SQL statement inserting data Parameters ---------- conn : sqlalchemy.engine.Engine or sqlalchemy.engine.Connection keys : list of str Column names data_iter : generator of list Each item contains a list of values to be inserted N(RIR RdRxtinsert(RtconnR1t data_itertrowR^((s,lib/python2.7/site-packages/pandas/io/sql.pyt_execute_insertKs (cC sEg|D]}tt||^q}|j|jj|dS(sAlternative to _execute_insert for DBs support multivalue INSERT. Note: multi-value insert is usually faster for analytics DBs and tables containing a few columns but performance degrades quickly with increase of columns. N(RIR RdRxR(RRR1RRR^((s,lib/python2.7/site-packages/pandas/io/sql.pyt_execute_insert_multiYs(c C s|jdk ro|jj}|j|j_y|jdtWqxtk rk}tdj|qxXn |j}t t t |j }t |}dg|}|jj}x|D]}|jr|jr|jj}tj|dd}q4|jjdjt}ntj|jdt}|jrVt|} d|| |d dS|d dSnq|dkrt|jdkrm|S|SnK|dkr|S|dkr| S|dkr| S|dkrtdn|S(Ntskipnai( RtIntegertFloattTexttBooleantDateTimetDatetTimet TIMESTAMPt datetime64Rttimezonet timedelta64slthe 'timedelta' type is not supported, and will be written as integer values (ns frequency) to the database.t stackleveliRNtfloat32t precisionii5ROtint32tbooleanRRtcomplexsComplex datatypes not supported(RKRktlibt infer_dtypeR%tsqlalchemy.typesRRRRRRRRRtdtttzR#tAttributeErrortwarningstwarnt UserWarningRt( RRPRKRRRRRRRRRR((s,lib/python2.7/site-packages/pandas/io/sql.pyR_sD@           cC sddlm}m}m}m}m}m}t||rAtSt||r]t j dSt||r}|j syt St St||rt St||rtSt||rtStS(Ni(RRRRRRR(RRRRRRRR+RRMRKRRRRRR(RtsqltypeRRRRRR((s,lib/python2.7/site-packages/pandas/io/sql.pyRs .  N(RRt__doc__R#R%RRRRRRRRRRRRRRRRR(((s,lib/python2.7/site-packages/pandas/io/sql.pyR s,       )$       2 3t PandasSQLcB s eZdZdZdZRS(s7 Subclasses Should define read_sql and to_sql. cO stddS(NsMPandasSQL must be created with an SQLAlchemy connectable or sqlite connection(Rt(RR6tkwargs((s,lib/python2.7/site-packages/pandas/io/sql.pyRscO stddS(NsMPandasSQL must be created with an SQLAlchemy connectable or sqlite connection(Rt(RR6R((s,lib/python2.7/site-packages/pandas/io/sql.pyRs(RRRRR(((s,lib/python2.7/site-packages/pandas/io/sql.pyRs RucB seZdZdddZedZdZdedddddZ e deddZ deddddZ e Z deddddddZed Zdd Zdd Zdd Zddd ZRS(s This class enables conversion between DataFrame and SQL databases using SQLAlchemy to handle DataBase abstraction. Parameters ---------- engine : SQLAlchemy connectable Connectable to connect with the database. Using SQLAlchemy makes it possible to use any DB supported by that library. schema : string, default None Name of SQL schema in database to write to (if database flavor supports this). If None, use default schema (default). meta : SQLAlchemy MetaData object, default None If provided, this MetaData object is used instead of a newly created. This allows to specify database flavor specific arguments in the MetaData object. cC sD||_|s7ddlm}||jd|}n||_dS(Ni(RgRh(RRpRgRl(RR,RhRlRg((s,lib/python2.7/site-packages/pandas/io/sql.pyRs  cc s;|jj&}t|dr)|Vn|jVWdQXdS(NRd(RtbeginR2(Rttx((s,lib/python2.7/site-packages/pandas/io/sql.pyRscO s|jj||S(s,Simple passthrough to SQLAlchemy connectable(RRd(RR6R((s,lib/python2.7/site-packages/pandas/io/sql.pyRdsc C s=t||d|d|}|jd|d|d|d|S(sRead SQL database table into a DataFrame. Parameters ---------- table_name : string Name of SQL table in database. index_col : string, optional, default: None Column to set as index. coerce_float : boolean, default True Attempts to convert values of non-string, non-numeric objects (like decimal.Decimal) to floating point. This can result in loss of precision. parse_dates : list or dict, default: None - List of column names to parse as dates. - Dict of ``{column_name: format string}`` where format string is strftime compatible in case of parsing string times, or is one of (D, s, ns, ms, us) in case of parsing integer timestamps. - Dict of ``{column_name: arg}``, where the arg corresponds to the keyword arguments of :func:`pandas.to_datetime`. Especially useful with databases without native Datetime support, such as SQLite. columns : list, default: None List of column names to select from SQL table. schema : string, default None Name of SQL schema in database to query (if database flavor supports this). If specified, this overwrites the default schema of the SQL database object. chunksize : int, default None If specified, return an iterator where `chunksize` is the number of rows to include in each chunk. Returns ------- DataFrame See Also -------- pandas.read_sql_table SQLDatabase.read_query RRhRZR9RYRm(RR( RRwR_RZR9RYRhRmRx((s,lib/python2.7/site-packages/pandas/io/sql.pyRvs, c c sJxCtrE|j|}|s"Pqt||d|d|d|VqWdS(s+Return generator through chunked result setR_RZR9N(R%RRa(RRmRYR_RZR9R^((s,lib/python2.7/site-packages/pandas/io/sql.pyRs c C st||}|j|}|j} |dk r[|j||| d|d|d|S|j} t| | d|d|d|} | SdS(sRead SQL query into a DataFrame. Parameters ---------- sql : string SQL query to be executed. index_col : string, optional, default: None Column name to use as index for the returned DataFrame object. coerce_float : boolean, default True Attempt to convert values of non-string, non-numeric objects (like decimal.Decimal) to floating point, useful for SQL result sets. params : list, tuple or dict, optional, default: None List of parameters to pass to execute method. The syntax used to pass parameters is database driver dependent. Check your database driver documentation for which of the five syntax styles, described in PEP 249's paramstyle, is supported. Eg. for psycopg2, uses %(name)s so use params={'name' : 'value'} parse_dates : list or dict, default: None - List of column names to parse as dates. - Dict of ``{column_name: format string}`` where format string is strftime compatible in case of parsing string times, or is one of (D, s, ns, ms, us) in case of parsing integer timestamps. - Dict of ``{column_name: arg dict}``, where the arg dict corresponds to the keyword arguments of :func:`pandas.to_datetime` Especially useful with databases without native Datetime support, such as SQLite. chunksize : int, default None If specified, return an iterator where `chunksize` is the number of rows to include in each chunk. Returns ------- DataFrame See Also -------- read_sql_table : Read SQL database table into a DataFrame. read_sql R_RZR9N(R7RdR1R#RRRa( RR4R_RZR9R5RmR6RRYR^R`((s,lib/python2.7/site-packages/pandas/io/sql.pyRzs*    Rc  sr,t r,fd|Dndk rddlm} m} xMjD]<\} } t| | | s[tdjd| q[q[Wnt ||d|d|d|d |d |d }|j |j |d | |j r|j r|jj}|jj+}|jd |p>|jjd |}WdQX||krdj|}tj|tqndS(s Write records stored in a DataFrame to a SQL database. Parameters ---------- frame : DataFrame name : string Name of SQL table. if_exists : {'fail', 'replace', 'append'}, default 'fail' - fail: If table exists, do nothing. - replace: If table exists, drop it, recreate it, and insert data. - append: If table exists, insert data. Create if does not exist. index : boolean, default True Write DataFrame index as a column. index_label : string or sequence, default None Column label for index column(s). If None is given (default) and `index` is True, then the index names are used. A sequence should be given if the DataFrame uses MultiIndex. schema : string, default None Name of SQL schema in database to write to (if database flavor supports this). If specified, this overwrites the default schema of the SQLDatabase object. chunksize : int, default None If not None, then rows will be written in batches of this size at a time. If None, all rows will be written at once. dtype : single type or dict of column name to SQL type, default None Optional specifying the datatype for columns. The SQL type should be a SQLAlchemy type. If all columns are of the same type, one single value can be used. method : {None', 'multi', callable}, default None Controls the SQL insertion clause used: * None : Uses standard SQL ``INSERT`` clause (one per row). * 'multi': Pass multiple values in a single ``INSERT`` clause. * callable with signature ``(pd_table, conn, keys, data_iter)``. Details and a sample callable implementation can be found in the section :ref:`insert method `. .. versionadded:: 0.24.0 c si|]}|qS(((t.0RU(RK(s,lib/python2.7/site-packages/pandas/io/sql.pys s i(t to_instancet TypeEngines.The type of {column} is not a SQLAlchemy type tcolumnR`RRRRhRKRt connectionNsThe provided table name '{0}' is not found exactly as such in the database after writing the table, possibly due to case sensitivity issues. Consider using lower case table names.(R R#RRRtitemsR+RtRHRRRtisdigittislowerRR,tconnectt table_namesRlRhR R R(RR`RkRRRRhRmRKRRRRPtmy_typeRxR,RRtmsg((RKs,lib/python2.7/site-packages/pandas/io/sql.pyR\s.,        cC s |jjS(N(Rlttables(R((s,lib/python2.7/site-packages/pandas/io/sql.pyR!scC s+|jj|jjj||p'|jjS(N(Rt run_callabletdialectR}RlRh(RRkRh((s,lib/python2.7/site-packages/pandas/io/sql.pyR}s  cC s|p|jj}|r?|jjjdj||g}n|jjj|}ddlm}x2|jD]'}t|j |rnt |j _ qnqnW|S(Nt.i(tNumeric( RlRhR!tgettjoinR$R%RYR+RLR*t asdecimal(RRwRhttblR%R((s,lib/python2.7/site-packages/pandas/io/sql.pyRs'cC sj|p|jj}|j||rf|jjd|gd||j||j|jjndS(NRiRh(RlRhR}RqRtdroptclear(RRwRh((s,lib/python2.7/site-packages/pandas/io/sql.pyRs c C s7t||d|dtd|d|}t|jS(NR`RR1RK(RR*RR(RR`RwR1RKRx((s,lib/python2.7/site-packages/pandas/io/sql.pyt_create_sql_schemas N(RRRR#RRRRdR%Rvt staticmethodRRzRRtpropertyR!R}RRR,(((s,lib/python2.7/site-packages/pandas/io/sql.pyRus*   / :  K   tTEXTtstringtREALRNRRORRtDATERtTIMERRcC sUy%t|jddjd}Wn)tk rPtdjd|nX|S(Nsutf-8tstricts,Cannot convert identifier to UTF-8: '{name}'Rk(R tencodetdecodet UnicodeErrorRtRH(Rktuname((s,lib/python2.7/site-packages/pandas/io/sql.pyt_get_unicode_names % cC sit|}t|s'tdn|jd}|dkrQtdnd|jdddS(Ns$Empty table or column name specifiedsis%SQLite identifier cannot contain NULst"s""(R9RRttfindR(RkR8t nul_index((s,lib/python2.7/site-packages/pandas/io/sql.pyt_get_valid_sqlite_names   svThe spaces in these column names will not be changed. In pandas versions < 0.14, spaces were converted to underscores.t SQLiteTablecB sMeZdZdZdZdZdZdZdZdZ RS(sw Patch the SQLTable for fallback support. Instead of a table variable just use the Create Table statement. cO s<ddl}|jtdtt|j||dS(NicS s |jdS(Ns %H:%M:%S.%f(tstrftime(t_((s,lib/python2.7/site-packages/pandas/io/sql.pyt s(tsqlite3tregister_adapterRtsuperR>R(RR6RRB((s,lib/python2.7/site-packages/pandas/io/sql.pyRs cC stdj|jS(Ns; (RR'Rx(R((s,lib/python2.7/site-packages/pandas/io/sql.pyR scC s=|jj(}x|jD]}|j|qWWdQXdS(N(RRRxRd(RRtstmt((s,lib/python2.7/site-packages/pandas/io/sql.pyRsc C sttt|jj}d}t}|jdk rlg|jdddD]}|jd|^qMng|D]}||^qs}dj |}dj |gt |}dj d||j d|d|} | S( Nt?iit,u.INSERT INTO {table} ({columns}) VALUES ({wld})RxRYtwld( R3RR R`RYR=RR#RR'RRHRk( RRRHtescapeRRtbracketed_namest col_namest wildcardstinsert_statement((s,lib/python2.7/site-packages/pandas/io/sql.pyRMs6 cC s&t|}|j|j|dS(N(R3t executemanyRM(RRR1RR((s,lib/python2.7/site-packages/pandas/io/sql.pyR%s c s|j|j}tjd}g|D]\}}}|^q(}tt|j|rqtjt ddnt g|D]#\}}}|d|^q~}|j dk r0t |j r0t|j s|j g} n |j } djfd| D} |jdjd|jd | nd |jd d j|d g} g|D]\}}} | rb|^qb} t | rdj| }djfd| D} | jdd|jd|d|jd| dn| S(s Return a list of SQL statements that creates a table reflecting the structure of a DataFrame. The first entry will be a CREATE TABLE statement while the rest will be CREATE INDEX statements. s\s+Rit s, c3 s|]}|VqdS(N((RR(RI(s,lib/python2.7/site-packages/pandas/io/sql.pys Bss-CONSTRAINT {tbl}_pk PRIMARY KEY ({cnames_br})R)t cnames_brs CREATE TABLE s ( s, s )R@RGc3 s|]}|VqdS(N((RR(RI(s,lib/python2.7/site-packages/pandas/io/sql.pys Nss CREATE INDEX tix_sON s (t)N(Rt_sql_type_nametreRtanyRtsearchR R t_SAFE_NAMES_WARNINGR=R1R#RRR'RRHRk(RRtpatRUR@Rtcnametctypetcreate_tbl_stmtsR1RPt create_stmtsRtix_colstcnames((RIs,lib/python2.7/site-packages/pandas/io/sql.pyR)s4 "-  + @cC s|jp i}|j|kr)||jStj|dt}|dkritjdtddd}nE|dkr~d}n0|d krd }n|d krtd n|t krd }nt |S( NRRslthe 'timedelta' type is not supported, and will be written as integer values (ns frequency) to the database.RiRORRtemptyR0RsComplex datatypes not supported( RKRkRRR%R R RRtt _SQL_TYPES(RRPRKR((s,lib/python2.7/site-packages/pandas/io/sql.pyRSUs"            ( RRRRRRRMRRRS(((s,lib/python2.7/site-packages/pandas/io/sql.pyR>s     ,R|cB seZdZedZedZdZed e d dZ d e d d d dZ dZ de d d d d d dZd d Zd d Zd d Zd d d ZRS(s Version of SQLDatabase to support SQLite connections (fallback without SQLAlchemy). This should only be used internally. Parameters ---------- con : sqlite connection object cC s||_||_dS(N(RbR.(RR.Rb((s,lib/python2.7/site-packages/pandas/io/sql.pyR~s cc s_|jj}z>y|V|jjWn!tk rK|jjnXWd|jXdS(N(R.tcursortcommitR~trollbacktclose(RRe((s,lib/python2.7/site-packages/pandas/io/sql.pyRs   cO s|jr|j}n|jj}y.|r@|j||n |j||SWntk r}y|jjWn=tk rtdjd|dd|}t|nXtdjd|dd|}t|nXdS(Ns7Execution failed on sql: {sql} {exc} unable to rollbackR4iRrs&Execution failed on sql '{sql}': {exc}( RbR.RaRdR~RcRRHR(RR6RReRrtex((s,lib/python2.7/site-packages/pandas/io/sql.pyRds(      c c suxntrp|j|}t|tkr9t|}n|sM|jPqt||d|d|d|VqWdS(s+Return generator through chunked result setR_RZR9N(R%RRLttupleR3RdRa(RaRmRYR_RZR9R^((s,lib/python2.7/site-packages/pandas/io/sql.pyRs  c C st||}|j|}g|jD]} | d^q(} |dk ro|j||| d|d|d|S|j|} |jt| | d|d|d|} | SdS(NiR_RZR9(R7Rdt descriptionR#Rt_fetchall_as_listRdRa( RR4R_RZR5R9RmR6Ratcol_descRYR^R`((s,lib/python2.7/site-packages/pandas/io/sql.pyRzs    cC s.|j}t|ts*t|}n|S(N(RR+R3(RReR((s,lib/python2.7/site-packages/pandas/io/sql.pyRhs Rc  sr,t r,fd|Dnd k rxMjD]<\} } t| tsEtdjd| d| qEqEWnt||d|d|d|d|d } | j| j || d S( si Write records stored in a DataFrame to a SQL database. Parameters ---------- frame: DataFrame name: string Name of SQL table. if_exists: {'fail', 'replace', 'append'}, default 'fail' fail: If table exists, do nothing. replace: If table exists, drop it, recreate it, and insert data. append: If table exists, insert data. Create if it does not exist. index : boolean, default True Write DataFrame index as a column index_label : string or sequence, default None Column label for index column(s). If None is given (default) and `index` is True, then the index names are used. A sequence should be given if the DataFrame uses MultiIndex. schema : string, default None Ignored parameter included for compatibility with SQLAlchemy version of ``to_sql``. chunksize : int, default None If not None, then rows will be written in batches of this size at a time. If None, all rows will be written at once. dtype : single type or dict of column name to SQL type, default None Optional specifying the datatype for columns. The SQL type should be a string. If all columns are of the same type, one single value can be used. method : {None, 'multi', callable}, default None Controls the SQL insertion clause used: * None : Uses standard SQL ``INSERT`` clause (one per row). * 'multi': Pass multiple values in a single ``INSERT`` clause. * callable with signature ``(pd_table, conn, keys, data_iter)``. Details and a sample callable implementation can be found in the section :ref:`insert method `. .. versionadded:: 0.24.0 c si|]}|qS(((RRU(RK(s,lib/python2.7/site-packages/pandas/io/sql.pys s s {column} ({type!s}) not a stringRRLR`RRRRKN( R R#RR+RRtRHR>RR( RR`RkRRRRhRmRKRRPRRx((RKs,lib/python2.7/site-packages/pandas/io/sql.pyRs+     cC s=d}djd|}t|j||gjdkS(NRFsASELECT name FROM sqlite_master WHERE type='table' AND name={wld};RHi(RHRRdR(RRkRhRHtquery((s,lib/python2.7/site-packages/pandas/io/sql.pyR} s  cC sdS(N(R#(RRwRh((s,lib/python2.7/site-packages/pandas/io/sql.pyRscC s)djdt|}|j|dS(NsDROP TABLE {name}Rk(RHR=Rd(RRkRhtdrop_sql((s,lib/python2.7/site-packages/pandas/io/sql.pyRs c C s7t||d|dtd|d|}t|jS(NR`RR1RK(R>R*RR(RR`RwR1RKRx((s,lib/python2.7/site-packages/pandas/io/sql.pyR, sN(RRRR*RRRRdR-R#R%RRzRhRR}RRR,(((s,lib/python2.7/site-packages/pandas/io/sql.pyR|ss"       8  cC s+td|}|j||d|d|S(s Get the SQL db table schema for the given frame. Parameters ---------- frame : DataFrame name : string name of SQL table keys : string or sequence, default: None columns to use a primary key con: an open SQL database connection object or a SQLAlchemy connectable Using SQLAlchemy makes it possible to use any DB supported by that library, default: None If a DBAPI2 object, only sqlite3 is supported. dtype : dict of column name to SQL type, default None Optional specifying the datatype for columns. The SQL type should be a SQLAlchemy type, or a string for sqlite3 fallback connection. R.R1RK(RcR,(R`RkR1R.RKRf((s,lib/python2.7/site-packages/pandas/io/sql.pyt get_schema&s(HRt __future__RRt contextlibRRRRt functoolsRRTR tnumpyRMtpandas._libs.libt_libsRt pandas.compatRRR R R tpandas.core.dtypes.commonR R Rtpandas.core.dtypes.dtypesRtpandas.core.dtypes.missingRtpandas.core.apiRRtpandas.core.baseRtpandas.core.tools.datetimesRR)RtIOErrorRR#R"R0R7R:RQRXR%RaRdRyR{RRR}t table_existsRnR*RcRRRuR`R9R=RWR>R|Rl(((s,lib/python2.7/site-packages/pandas/io/sql.pytsv   (      H < R >     u