Edit file File name : sqlitestore.pyc Content :� �_^c @@ sO d Z d d l m Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l m Z m Z m Z d d l m Z d d l m Z m Z m Z m Z m Z m Z m Z m Z m Z m Z m Z d d l m Z m Z d d l m Z m Z y d d l m! Z! e! j" Wn e# k r.e$ Z! n Xi Z% e j& e% � Z& e& d d d e! r\d n d d e' �d Z( d Z) d Z* d Z+ d Z, d Z- d Z. d Z/ d Z0 d Z1 d Z2 d Z3 d Z4 d d d d d d d! d" e. g Z5 e$ d# � Z6 d$ � Z7 d% e j8 f d& � � YZ9 e j: d' e; f d( � � Y� Z< e j= e j> � e j: d) e' � d* e; f d+ � � Y� � Z? e j= e j@ � e j: d, e' � d- e; f d. � � Y� � ZA e j= e jB � d/ e; f d0 � � Y� ZC d1 e jD f d2 � � YZE d3 � ZF d4 � ZG d5 � ZH e j= e jI � d6 e; f d7 � � Y� ZJ d8 � ZK d9 � ZL d: � ZM d; � ZN d< � ZO d S(= sm store repository data in SQLite (EXPERIMENTAL) The sqlitestore extension enables the storage of repository data in SQLite. This extension is HIGHLY EXPERIMENTAL. There are NO BACKWARDS COMPATIBILITY GUARANTEES. This means that repositories created with this extension may only be usable with the exact version of this extension/Mercurial that was used. The extension attempts to enforce this in order to prevent repository corruption. In addition, several features are not yet supported or have known bugs: * Only some data is stored in SQLite. Changeset, manifest, and other repository data is not yet stored in SQLite. * Transactions are not robust. If the process is aborted at the right time during transaction close/rollback, the repository could be in an inconsistent state. This problem will diminish once all repository data is tracked by SQLite. * Bundle repositories do not work (the ability to use e.g. `hg -R <bundle-file> log` to automatically overlay a bundle on top of the existing repository). * Various other features don't work. This extension should work for basic clone/pull, update, and commit workflows. Some history rewriting operations may fail due to lack of support for bundle repositories. To use, activate the extension and set the ``storage.new-repo-backend`` config option to ``sqlite`` to enable new repositories to use SQLite for storage. i ( t absolute_importN( t _( t nullidt nullrevt short( t attr( t ancestort dagopt encodingt errort extensionst localrepot mdifft pycompatt registrart utilt verify( t repositoryR ( t hashutilt storageutil( t zstdt storages sqlite.compressiont defaultR t zlibt experimentals ships-with-hg-cores exp-sqlite-001s exp-sqlite-comp-001=zstds exp-sqlite-comp-001=zlibs exp-sqlite-comp-001=nones exp-sqlite-shallow-filesi i i i s� CREATE TABLE delta ( id INTEGER PRIMARY KEY, compression INTEGER NOT NULL, hash BLOB UNIQUE ON CONFLICT ABORT, delta BLOB NOT NULL )sK CREATE TABLE filepath ( id INTEGER PRIMARY KEY, path BLOB NOT NULL )s4 CREATE UNIQUE INDEX filepath_path ON filepath (path)sc CREATE TABLE fileindex ( id INTEGER PRIMARY KEY, pathid INTEGER REFERENCES filepath(id), revnum INTEGER NOT NULL, p1rev INTEGER NOT NULL, p2rev INTEGER NOT NULL, linkrev INTEGER NOT NULL, flags INTEGER NOT NULL, deltaid INTEGER REFERENCES delta(id), deltabaseid INTEGER REFERENCES fileindex(id), node BLOB NOT NULL )sJ CREATE UNIQUE INDEX fileindex_pathrevnum ON fileindex (pathid, revnum)sB CREATE UNIQUE INDEX fileindex_pathnode ON fileindex (pathid, node)s� CREATE VIEW filedata AS SELECT fileindex.id AS id, filepath.id AS pathid, filepath.path AS path, fileindex.revnum AS revnum, fileindex.node AS node, fileindex.p1rev AS p1rev, fileindex.p2rev AS p2rev, fileindex.linkrev AS linkrev, fileindex.flags AS flags, fileindex.deltaid AS deltaid, fileindex.deltabaseid AS deltabaseid FROM filepath, fileindex WHERE fileindex.pathid=filepath.ids PRAGMA user_version=%dc C@ sQ | j d j d d j d g t | � � � t | | g t | j � � � � } g } d } x� | D]� \ } } } | } | t k r� | j | � } nC | t k r� | } n. | t k r� t j | � } n t d | � � | j | � qc W| | k r| | | } n | j � } | j � t j | | � } t | t � sMt | � } n | S( s& Resolve a delta chain for a file node.s WITH RECURSIVE deltachain(deltaid, baseid) AS ( SELECT deltaid, deltabaseid FROM fileindex WHERE pathid=? AND node=? UNION ALL SELECT fileindex.deltaid, deltabaseid FROM fileindex, deltachain WHERE fileindex.id=deltachain.baseid AND deltachain.baseid IS NOT NULL AND fileindex.id NOT IN ({stops}) ) SELECT deltachain.baseid, compression, delta FROM deltachain, delta WHERE delta.id=deltachain.deltaidt stopst ,t ?s unhandled compression type: %dN( t executet formatt joint lent tuplet listt keyst Nonet COMPRESSION_ZSTDt decompresst COMPRESSION_NONEt COMPRESSION_ZLIBR t SQLiteStoreErrort appendt popt reverseR t patchest isinstancet bytes( t dbt pathidt nodet revisioncachet stopridst zstddctxt rest deltast lastdeltabaseidt deltabaseidt compressiont deltat basetextt fulltext( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt resolvedeltachain� s2 % c C@ sU y | j d | | | f � j SWn. t j k rP | j d | f � j � d SXd S( Ns= INSERT INTO delta (compression, hash, delta) VALUES (?, ?, ?)s! SELECT id FROM delta WHERE hash=?i ( R t lastrowidt sqlite3t IntegrityErrort fetchone( R/ R9 t hashR: ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt insertdelta� s R( c B@ s e Z RS( ( t __name__t __module__( ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyR( s t revisionentryc B@ st e Z e j � Z e j � Z e j � Z e j � Z e j � Z e j � Z e j � Z e j � Z e j � Z RS( ( RD RE R t ibt ridt revR1 t p1revt p2revt p1nodet p2nodet linkrevt flags( ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyRF s t slotst sqliterevisiondeltac B@ sz e Z e j � Z e j � Z e j � Z e j � Z e j � Z e j � Z e j � Z e j � Z e j d d � Z RS( R N( RD RE R RG R1 RL RM t basenodeRO t baserevisionsizet revisionR: R# t linknode( ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyRQ s t frozent sqliteproblemc B@ s> e Z e j d d � Z e j d d � Z e j d d � Z RS( R N( RD RE R RG R# t warningR R1 ( ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyRW % s t sqlitefilestorec B@ s� e Z d Z d � Z d � Z d � Z d � Z d � Z d d& d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d& d& d � Z d � Z d � Z e e d � Z d � Z d � Z d � Z d � Z d& e e e j d � Z d � Z d& d d& d � Z! d& e d � Z" d d � Z# d � Z$ d � Z% d! � Z& e e e e e d" � Z' d# � Z( d& d& d$ � Z) d& d d% � Z* RS(' s2 Implements storage for an individual tracked path.c C@ s� | | _ | | _ d | _ i | _ i | _ i | _ t j d � | _ | | _ | d k r� t j d d � | _ t j � | _ n d | _ d | _ | j � d S( Ni R t leveli ( t _dbt _pathR# t _pathidt _revtonodet _nodetorevt _revisionsR t lrucachedictt _revisioncachet _compengineR t ZstdCompressort _cctxt ZstdDecompressort _dctxt _refreshindex( t selfR/ t pathR9 ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt __init__1 s c C@ s� i | _ i | _ i | _ t | j j d | j f � � } | sO d | _ d S| d d | _ | j j d | j f � } x t | � D]� \ } } | \ } } } } } } } | | k r� t t d � � � n | t k r� t } n | j | } | t k rt } n | j | } t d | d | d | d | d | d | d | d | d | � } | | j | <| | j | <| | j | <q� Wd S( Ns$ SELECT id FROM filepath WHERE path=?i sg SELECT id, revnum, node, p1rev, p2rev, linkrev, flags FROM fileindex WHERE pathid=? ORDER BY revnum ASCs1 sqlite database has inconsistent revision numbersRH RI R1 RJ RK RL RM RN RO ( R^ R_ R` R! R[ R R\ R# R] t enumerateR( R R R RF ( Ri R5 t it rowRH RI R1 RJ RK RN RO RL RM t entry( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyRh K sJ c C@ s t | j � S( N( R R` ( Ri ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt __len__� s c C@ s t t j t | j � � � S( N( t iterR t xrangeR R` ( Ri ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt __iter__� s c C@ s | t k r t S| | j k S( N( R t FalseR_ ( Ri R1 ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt hasnode� s i c C@ s" t j t | j � d | d | �S( Nt startt stop( R t iterrevsR R` ( Ri Rv Rw ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt revs� s c C@ sc | t k r t t f S| | j k rF t j | | j t d � � � n | j | } | j | j f S( Ns no node( R R` R t LookupErrorR\ R RL RM ( Ri R1 Ro ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt parents� s ! c C@ sX | t k r t t f S| | j k r4 t | � � n | j | j | } | j | j f S( N( R R^ t IndexErrorR` RJ RK ( Ri RI Ro ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt parentrevs� s c C@ sK | t k r t S| | j k r@ t j | | j t d � � � n | j | S( Ns no node( R R R_ R Rz R\ R ( Ri R1 ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyRI � s !c C@ s9 | t k r t S| | j k r. t | � � n | j | S( N( R R R^ R| ( Ri RI ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyR1 � s c C@ s t j | | | j � S( N( R t fileidlookupR\ ( Ri R1 ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt lookup� s c C@ sI | t k r t S| | j k r. t | � � n | j | j | } | j S( N( R R^ R| R` RN ( Ri RI Ro ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyRN � s c C@ sG | t k r t S| | j k r. t | � � n | j | j | j t @S( N( R Rt R^ R| R` RO t FLAG_CENSORED( Ri RI ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt iscensored� s c C@ sI | j | � } | j | � } t j | j | | � } t j | j | � S( N( RI R t commonancestorsheadsR} R t maplistR1 ( Ri t node1t node2t rev1t rev2t ancestors( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyR� � s c C@ s t j | | j | j � S( N( R t descendantrevsRy R} ( Ri Ry ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt descendants� s c @ s� | d k r. | d k r. t � � s. t g Sn | d k rI � j | � n t } � f d � | pd g D� } t j � j � j d | d | �} g | D] } � j | � ^ q� S( Nc @ s h | ] } � j | � � q S( ( RI ( t .0t n( Ri ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pys <setcomp>� s t startrevt stoprevs( R# R R RI R R t headrevssubsetRy R} R1 ( Ri Rv Rw R� R� Ry RI ( ( Ri s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt heads� s ! c C@ sK | j | � } | j j d | j | | f � } g | D] } | d ^ q7 S( NsZ SELECT node FROM filedata WHERE path=? AND (p1rev=? OR p2rev=?) ORDER BY revnum ASCi ( RI R[ R R\ ( Ri R1 RI R5 Rn ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt children� s c C@ sp | t k r d S| | j k r. t | � � n | j | } | j | � r] t | j | � � St | j | � � S( Ni ( R R^ R| t renamedR t readRT ( Ri RI R1 ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt size s c @ s" | t t f k r d St | t � r7 � j | � } n | � j k rg t j | � j t d � � � n | � j k r� � j | S� f d � � j D� } | s� d | d <n t � j � j | � j | d � j �} � j | j t t B@r� t } n | r � j | | � | � j | <n | S( Nt s no nodec @ s# i | ] } | � j | j � q S( ( R` RH ( R� R� ( Ri ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pys <dictcomp> s i����R4 ( R R R- t intR1 R_ R Rz R\ R Rb R# R= R[ R] Rg R` RO t FLAG_MISSING_P1t FLAG_MISSING_P2Rt t _checkhash( Ri R1 t rawt _verifyhashR3 R< ( ( Ri s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyRT s0 ! c O@ s | j | | � S( N( RT ( Ri t argst kwargs( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt rawdata9 s c C@ s t j | j | � � S( N( R t filtermetadataRT ( Ri R1 ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyR� < s c C@ s t j | | � S( N( R t filerevisioncopied( Ri R1 ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyR� ? s c C@ s t j | | | � S( N( R t filedataequivalent( Ri R1 R< ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt cmpB s c c@ s& | d k r" t j d | � � n g | D] } | t k r) | ^ q) } | sQ d S| j j d d j d g t | � � t | j g | � � } i } xF | D]> \ } } | j j d | j | f � } | j � d | | <q� Wx@ t j | | | t d | j d | d | d | �D] } | VqWd S( Nt nodesR t linears" unhandled value for nodesorder: %ssI SELECT revnum, deltaid FROM fileindex WHERE pathid=? AND node in (%s)R R s9 SELECT revnum from fileindex WHERE pathid=? AND deltaid=?i t deltaparentfnt revisiondatat assumehaveparentrevisionst deltamode( R� R R� N( R# R t ProgrammingErrorR R[ R R R R R] RA R t emitrevisionsRQ t __getitem__( Ri R� t nodesorderR� R� R� R� R5 t deltabasesRI t deltaidR: ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyR� E s4 % c C@ sC | s | j d � r* t j | | � } n | j | | | | | � S( Ns ( t startswithR t packmetat addrevision( Ri t filedatat metat transactionRN t p1t p2( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt addz s c C@ s� | r t t d � � � n | d k } | p? t j | | | � } | ra | j | | | | � n | | j k rt | S| j | | | | | | � } | | j | <| S( Ns flags not supported on revisions( R( R R# R t hashrevisionsha1R� R_ t _addrawrevisionRb ( Ri R� R� RN R� R� R1 RO t cachedeltat validatehash( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyR� � s c @ s3 g } x&| D] \ } } } } } } } d } | t j @rH | t O} n | t j @re t d � � n | r� | t k r� � j | � r� t } | t O} n | t k r� � j | � r� t } | t O} q� n � j | � } | t k rg� j | � rgt j d � } t � j | d t �� } t | � | } | | t j | | � k rgt j � j | � � qgn | t @ r�t j | | � f d � � r�| t O} n | | � } | j | � | � j k r�� j | } | j t @r@| t k r@| | _ � j | | _ | j t M_ � j j d � j | | j | j f � n | j t @r | t k r | | _ � j | | _! | j t M_ � j j d � j | | j | j f � q q n | t k r�t j" d | � } d } n d } | | f } � j$ | | | | | | d | d | �| r | � | � q q W| S( Ni s unhandled revision flags >lllR� c @ s t � j | � � S( N( R R� ( t x( Ri ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt <lambda>� R� s0 UPDATE fileindex SET p1rev=?, flags=? WHERE id=?s0 UPDATE fileindex SET p2rev=?, flags=? WHERE id=?R� t storedeltaRO (% R t REVISION_FLAG_CENSOREDR� R( R Ru R� R� RI R R� t structt calcsizeR R� Rt R t replacediffheaderR t CensoredBaseErrorR\ R t deltaiscensoredR) R` RO RL R_ RJ R[ R RH RM RK t patchR# R� ( Ri R6 t linkmapperR� t addrevisioncbt maybemissingparentsR� R1 R� R� RU t deltabaseR: t wireflagst storeflagst baserevt hlent oldlent newlenRN Ro t textR� ( ( Ri s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt addgroup� sx " R� c C@ sv t j i | d 6d � } t | � t | j | � � k rR t j t d � � � n | j j d | j | j f � j � d } t | j j d | | f � � } x:| D]2} | \ } } } t | j | | i i d d 6d | j �} t j | � j � } | j d k r%| j j | � } t } n[ | j d k rLt j | � } t } n4 | j d k rj| } t } n t j d | j � � t | � t | � k r�| } t } n t | j | | | � } | j j d | | f � q� Wt j | � j � } t | j t | | � } | j | j } | t O} | j j d | | | j | f � | j j d | f � | j � | j j! � d S( Nt censoredR� s5 censor tombstone must be no longer than censored datas( SELECT deltaid FROM fileindex WHERE id=?i sG SELECT id, pathid, node FROM fileindex WHERE deltabaseid=? OR deltaid=?i����R4 R R t nones unhandled compression engine: %ss; UPDATE fileindex SET deltaid=?, deltabaseid=NULL WHERE id=?sS UPDATE fileindex SET flags=?, deltaid=?, deltabaseid=NULL WHERE pathid=? AND node=?s DELETE FROM delta WHERE id=?(" R R� R R� R t AbortR R[ R R` RH RA R! R= R# Rg R t sha1t digestRc Re t compressR$ R R' R& R� RC RO R� R] Rh Rb t clear( Ri t trt censornodet tombstonet censoreddeltaidt rowsRn RH R0 R1 R< t deltahasht deltablobR9 R� t tombstonedeltaidRO ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt censorrevision s\ ! ( c C@ sK t j | t | � d g | j � D] } | j | � ^ q# | j | j � S( Ni ( R t resolvestripinfoR R� RI RN R} ( Ri t minlinkR� ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt getstrippoint] s %c C@ s� t | � s d S| j | � \ } } | t | � k r; d Sx< | j | � D]+ } | j j d | j | j | � f � qK W| j � d S( Ns/ DELETE FROM fileindex WHERE pathid=? AND node=?( R R� Ry R[ R R] R1 Rh ( Ri R� R� RI t _ignored( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt stripf s c C@ s g S( N( ( Ri ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt files} s c @ s� i } | r g | d <n | r, g | d <n | rE t � � | d <n | rq t � f d � � j D� � | d <n | r� d | d <n | S( Nt exclusivefilest sharedfilest revisionscountc 3@ s$ | ] } t � j | � � Vq d S( N( R RT ( R� R1 ( Ri ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pys <genexpr>� s t trackedsizet storedsize( R t sumR_ R# ( Ri R� R� R� R� R� t d( ( Ri s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt storageinfo� s # c c@ s� t � | d <x | D]w } | j | � } y | j | � Wq t k r� } t d t d � t | � | f d | � V| d j | � q Xq Wd S( Nt skipreadR s unpacking %s: %sR1 ( t setR1 RT t ExceptionRW R R R� ( Ri t stateRI R1 t e( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt verifyintegrity� s $c C@ s� | d k r0 | d k r0 | j | � \ } } n | t j | | | � k rO d Sy | j | =Wn t k rp n Xt j | � r� t j | j | | � � n t t d � | j � � d S( Ns integrity check failed on %s( R# R{ R R� Rb t KeyErrort iscensoredtextR t CensoredNodeErrorR\ R( R ( Ri R< R1 R� R� ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyR� � s c C@ s� | j d k r9 | j j d | j f � } | j | _ n | ro | \ } } t | t � r� | j | � } q� nQ | d k s� t � | } | t k r� | } n$ t j | j | j | � � | � } | t k r� d } n | j | j } t j | � j � } | j d k r$| j j | � } t } n[ | j d k rKt j | � } t } n4 | j d k ri| } t } n t j d | j � � t | � t | � k r�| } t } n t | j | | | � } t | � } | t k r�t } n | j | } | t k rt } n | j | } | j j d | j | | | | | | | | f � j } t! d | d | d | d | d | d | d | d | d | � } | | j | <| | j" | <| | j | <| S( Ns& INSERT INTO filepath (path) VALUES (?)R R R� s unhandled compression engine: %ss� INSERT INTO fileindex ( pathid, revnum, node, p1rev, p2rev, linkrev, flags, deltaid, deltabaseid) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)RH RI R1 RJ RK RL RM RN RO (# R] R# R[ R R\ R> R- R� R1 t AssertionErrorR R t textdiffRT RI R` RH R R� R� Rc Re R� R$ R R' R& R R� R RC R R_ RF R^ ( Ri R1 R� R� RN R� R� R� RO R5 R� R: t baseidR� R� R9 R� RI RJ RK RH Ro ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyR� � s� N(+ RD RE t __doc__Rk Rh Rp Rs Ru R# Ry R{ R} RI R1 R RN R� R� R� R� R� R� Rt t TrueRT R� R� R� R� R t CG_DELTAMODE_STDR� R� R� R� R� R� R� R� R� R� R� R� ( ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyRY - s^ = * / \ ] t sqliterepositoryc B@ s) e Z d � Z d � Z e d � � Z RS( c C@ s t S( N( Rt ( Ri ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt cancopy: s c @ sd � j � } t t � � j | | � } | r1 | S� j j d � � f d � } | j d | � | S( Ns BEGIN TRANSACTIONc @ s � j j � d S( N( t _dbconnt commit( R ( Ri ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt committransactionG s t sqlitestore( t currenttransactiont superR� R� R R t addfinalize( Ri R� R� t currentR� R ( ( Ri s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyR� = s c C@ sd t j � j } | j r9 | j d | k r9 | j d Sn t | j j d � � } | | f | _ | S( Ni i s db.sqlite( t threadingt current_threadt identR[ t makedbt svfsR ( Ri t tidR/ ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyR N s ( RD RE R R� t propertyR ( ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyR� 9 s c C@ s� t j t j | � � } t | _ | j d � j � d } | d k rq x t D] } | j | � qM W| j � n$ | t k r� n t j t d � � � | j d � | S( s3 Construct a database handle for a database at path.s PRAGMA user_versioni s( sqlite database has unrecognized versions PRAGMA journal_mode=WAL( R? t connectR t strfromlocalR. t text_factoryR RA t CREATE_SCHEMAR t CURRENT_SCHEMA_VERSIONR R� R ( Rj R/ R5 t statement( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyR _ s c C@ s^ | j t � t r# | j t � n | j t � | j t � | j t � | j t j � d S( N( R� t REQUIREMENTR t REQUIREMENT_ZSTDt REQUIREMENT_ZLIBt REQUIREMENT_NONEt REQUIREMENT_SHALLOW_FILESR t NARROW_REQUIREMENT( t uit supported( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt featuresetupy s c C@ s� | d d k r | | | � Sd | k rA t j t d � � � n d d d h } t | � | } | r� t j t d � d j t | � � � � n d | d <| | | � } | j t � | j d d � } | d k r� t r� t j t d � � � n | d k r| j t � nQ | d k r,| j t � n5 | d k rH| j t � n t j t d � | � � | j d � r�| j t � n | S( Nt backendt sqlitet sharedrepos3 shared repositories not supported with SQLite storet narrowfilest shallowfilestores6 SQLite store does not support repo creation option: %ss , t revlogv1R s sqlite.compressionR sj storage.sqlite.compression set to "zstd" but zstandard compression not available to this Mercurial installR R� sD unknown compression engine defined in storage.sqlite.compression: %s( R R� R R� R t sortedR� R t configR R R R t getR ( t origR t createoptst knownt unsupportedt requirementsR9 ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt newreporequirements� sD t sqlitefilestoragec B@ s e Z d Z d � Z RS( s) Repository file storage backed by SQLite.c C@ s� | d d k r | d } n t | j k r5 d } nE t | j k rM d } n- t | j k re d } n t j t d � � � t | j | | � S( Ni t /i R R R� sE unable to determine what compression engine to use for SQLite storage( R R, R R R R� R RY R ( Ri Rj R9 ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt file� s ( RD RE R� R0 ( ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyR. � s c K@ sI t | k r/ t | k r+ | j t j � n t S| d | d | | � Sd S( s= Produce a type conforming to ``ilocalrepositoryfilestorage``.R, t featuresN( R R R� R t! REPO_FEATURE_SHALLOW_FILE_STORAGER. ( R( R, R1 R� ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt makefilestorage� s c K@ sK t | k r; t | k r7 t r7 t j t d � � � n t S| d | | � S( NsW repository uses zstandard compression, which is not available to this Mercurial installR, ( R R R R R� R R� ( R( R R, R� ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt makemain� s c O@ s | | | | � t | _ d S( N( Rt t warnorphanstorefiles( R( Ri R� R� ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt verifierinit� s c C@ sc t j j t � t j t d t � t j t d t � t j t d t � t j t j d t � d S( NR- R3 R4 Rk ( R t featuresetupfuncsR� R R t wrapfunctionR- R3 R4 R t verifierR6 ( R ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt extsetup s c C@ s t | t � r d | _ n d S( N( R- R� R# R[ ( R t repo( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt reposetup s (P R� t __future__R R? R� R R t mercurial.i18nR t mercurial.nodeR R R t mercurial.thirdpartyR t mercurialR R R R R R R R R R R t mercurial.interfacesR t interfaceutilt mercurial.utilsR R R t __version__t ImportErrorR# t configtablet configitemR� t testedwithR R R R R R R& R$ R' R� R� R� R R= RC t StorageErrorR( t st objectRF t implementert irevisiondeltaRQ t iverifyproblemRW t ifilestorageRY t localrepositoryR� R R R- t ilocalrepositoryfilestorageR. R3 R4 R6 R: R< ( ( ( s5 /usr/lib/python2.7/dist-packages/hgext/sqlitestore.pyt <module>% s� L A � � � & A Save