qh ASrSSKrSSKrSSKJr SSKJr SSKJr Sr "SS\5r "S S \ 5r "S S \ 5r "S S\ 5r g)a. This module contains C{L{OpenIDStore}} implementations that use various SQL databases to back them. Example of how to initialize a store database:: python -c 'from openid.store import sqlstore; import pysqlite2.dbapi2;' 'sqlstore.SQLiteStore(pysqlite2.dbapi2.connect("cstore.db")).createTables()' N) Association) OpenIDStore)noncec^U4Sjn[TS5(aTRSSUl[TS5(aTRUlU$![a N0f=f)Nc2>UR"TU/UQ70UD6$N)_callInTransaction)selfargskwargsfuncs G/var/www/html/env/lib/python3.13/site-packages/openid/store/sqlstore.pywrapped_inTxn..wrappeds &&tTCDCFCC__name____doc__)hasattrr TypeErrorr)r rs` r_inTxnrscDtZ   #}}QR0G tY,, N    sA AAc\rSrSrSrSrSrSSjrSrSr S r S r S r S r S r\"\5rSr\"\5rSSjr\"\5rSr\"\5rSr\"\5rSr\"\5rSr\"\5rSrg)SQLStore"a@ This is the parent class for the SQL stores, which contains the logic common to all of the SQL stores. The table names used are determined by the class variables C{L{associations_table}} and C{L{nonces_table}}. To change the name of the tables used, pass new table names into the constructor. To create the tables with the proper schema, see the C{L{createTables}} method. This class shouldn't be used directly. Use one of its subclasses instead, as those contain the code necessary to use a specific database. All methods other than C{L{__init__}} and C{L{createTables}} should be considered implementation details. @cvar associations_table: This is the default name of the table to keep associations in @cvar nonces_table: This is the default name of the table to keep nonces in. @sort: __init__, createTables oid_associations oid_noncesNcXlSUl0UlU=(d URU=(d URS.UlSUl[URS5(a,[URS5(aURUl[URS5(a[URS5(d [S5eg)a( This creates a new SQLStore instance. It requires an established database connection be given to it, and it allows overriding the default table names. @param conn: This must be an established connection to a database of the correct type for the SQLStore subclass you're using. @type conn: A python database API compatible connection object. @param associations_table: This is an optional parameter to specify the name of the table used for storing associations. The default value is specified in C{L{SQLStore.associations_table}}. @type associations_table: C{str} @param nonces_table: This is an optional parameter to specify the name of the table used for storing nonces. The default value is specified in C{L{SQLStore.nonces_table}}. @type nonces_table: C{str} N) associationsnoncesi`TIntegrityErrorOperationalErrorzDError using database connection module (Maybe it can't be imported?)) conncur_statement_cacheassociations_table nonces_table _table_names max_nonce_ager exceptions RuntimeError)r r"r%r&s r__init__SQLStore.__init__Ds:  ".I$2I2I"7d&7&7 ) DII/ 0 0 #566"iiDO)9::);<< ?@ @=rcU$)zKConvert a blob as returned by the SQL engine into a str object. str -> strr blobs r blobDecodeSQLStore.blobDecodevs  rcU$)zUConvert a str object into the necessary object for storing in the database as a blob.r.r ss r blobEncodeSQLStore.blobEncode|s rcURU$![a, [X5nX R-nX RU'Us$f=fr)r$KeyErrorgetattrr')r sql_namesqls r_getSQLSQLStore._getSQLsR ((2 2 $)C $$ $C.1 ! !( +J  s3AAcURU5nSn[[XB55nURR X55 g)NcF[U[5(a [U5$U$r) isinstancestr)args runicode_to_str)SQLStore._execSQL..unicode_to_strs#s##3x r)r=listmapr#execute)r r;r r<rDstr_argss r_execSQLSQLStore._execSQLs8ll8$   N12 'rcr^^USSS:XaUSSS-mUU4Sjn[TX5 U$[SU<S35e)Ndb__sqlc*>TR"T/UQ76$r)rJ)r r r;s rr "SQLStore.__getattr__..funcs}}X555rz Attribute z not found)setattrAttributeError)r attrr r;s` @r __getattr__SQLStore.__getattr__sG 8u ABx&(H 6 D$ %K T!DE ErcURR5 URR5UlU"U0UD6nURR 5 SUlURR 5 U$!URR 5 SUlf=f! URR5 e=f)zExecute the given function inside of a transaction, with an open cursor. If no exception is raised, the transaction is comitted, otherwise it is rolled back.N)r"rollbackcursorr#closecommit)r r r r rets rr SQLStore._callInTransactions  yy'')DH D+F+  II       II   s"B(B!B(#B%%B((CcDUR5 UR5 g)z This method creates the database tables necessary for this store to work. It should not be called if the tables already exist. N)db_create_noncedb_create_assocr s rtxn_createTablesSQLStore.txn_createTabless  rcUnURXRURUR5URUR UR 5 g)zASet the association for the server URL. Association -> NoneType N) db_set_assochandler6secretissuedlifetime assoc_type)r server_url associationas rtxn_storeAssociationSQLStore.txn_storeAssociations@  *hh//!((3QXXqzz,, (rcUbURX5 OURU5 URR5n[ U5S:Xag/nUHwn[ U5nUR US5US'[U6nURS:XaURXR5 MZURURU45 My U(aUR5 USS$g)zrGet the most recent association that has been set for this server URL and handle. str -> NoneType or Association Nr) db_get_assoc db_get_assocsr#fetchalllenrFr1r expiresIntxn_removeAssociationrfappendrhsort)r rkrfrowsrvaluesassocs rtxn_getAssociationSQLStore.txn_getAssociations     j 1   z *xx  " t9>Lf OOF1I6q #V,??a'..z<<H ''u(=>!!##B'**rcVURX5 URRS:$)zRemove the association for the given server URL and handle, returning whether the association existed at all. (str, str) -> bool r)db_remove_assocr#rowcount)r rkrfs rrxSQLStore.txn_removeAssociations' Z0xx  1$$rc[U[R"5- 5[R:agUR XU5 g!UR R a gf=f)z]Return whether this nonce is present, and if it is, then remove it from the set. str -> boolFT)abstimerSKEW db_add_noncer)r )r rk timestampsalts r txn_useNonceSQLStore.txn_useNonces[ y499;& '%** 4    jT :  --  sA A&%A&cUR[[R"55[R- 5 UR R $r)db_clean_nonceintrrrr#rras rtxn_cleanupNoncesSQLStore.txn_cleanupNoncess4 C ,uzz9:xx   rcUR[[R"555 URR$r)db_clean_assocrrr#rras rtxn_cleanupAssociations SQLStore.txn_cleanupAssociationss+ C ,-xx   r)r$r'r"r#r)r()NNr)r __module__ __qualname____firstlineno__rr%r&r+r1r6r=rJrUr rbr createTablesrnstoreAssociationr~getAssociationrxremoveAssociationruseNoncer cleanupNoncesrcleanupAssociations__static_attributes__r.rrrr"s<,L0@d  ( F,*+L(23>./N%45"l#H!,-M!!!89rrcZ^\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rU4SjrSrU=r$) SQLiteStorei"z This is an SQLite-based specialization of C{L{SQLStore}}. To create an instance, see C{L{SQLStore.__init__}}. To create the tables it will use, see C{L{SQLStore.createTables}}. All other methods are implementation details. z CREATE TABLE %(nonces)s ( server_url VARCHAR, timestamp INTEGER, salt CHAR(40), UNIQUE(server_url, timestamp, salt) ); a CREATE TABLE %(associations)s ( server_url VARCHAR(2047), handle VARCHAR(255), secret BLOB(128), issued INTEGER, lifetime INTEGER, assoc_type VARCHAR(64), PRIMARY KEY (server_url, handle) ); z}INSERT OR REPLACE INTO %(associations)s (server_url, handle, secret, issued, lifetime, assoc_type) VALUES (?, ?, ?, ?, ?, ?);z_SELECT handle, secret, issued, lifetime, assoc_type FROM %(associations)s WHERE server_url = ?;znSELECT handle, secret, issued, lifetime, assoc_type FROM %(associations)s WHERE server_url = ? AND handle = ?;zDSELECT server_url FROM %(associations)s WHERE issued + lifetime < ?;zADELETE FROM %(associations)s WHERE server_url = ? AND handle = ?;z9DELETE FROM %(associations)s WHERE issued + lifetime < ?;z(INSERT INTO %(nonces)s VALUES (?, ?, ?);z+DELETE FROM %(nonces)s WHERE timestamp < ?;c[U5$r) memoryviewr4s rr6SQLiteStore.blobEncodeXs !}rc>[[U] "U0UD6$!URRa0n[ R "S[U55(aSnAgeSnAff=f)Nz^columns .* are not unique$F)superrrr)r!rematchrB)r r r why __class__s rrSQLiteStore.useNonce[sU d4dEfE E// xx5s3x@@  sA!%AAA!r.)rrrrrcreate_nonce_sqlcreate_assoc_sql set_assoc_sqlget_assocs_sql get_assoc_sqlget_expired_sqlremove_assoc_sqlclean_assoc_sql add_nonce_sqlclean_nonce_sqlr6rr __classcell__)rs@rrr"sc 2MDN ELO?RO>MCO  rrcf\rSrSrSrSSKrSrSr Sr Sr S r S r S rS rS rSrSrg!\a SrN!f=f) MySQLStoreiha This is a MySQL-based specialization of C{L{SQLStore}}. Uses InnoDB tables for transaction support. To create an instance, see C{L{SQLStore.__init__}}. To create the tables it will use, see C{L{SQLStore.createTables}}. All other methods are implementation details. rNz CREATE TABLE %(nonces)s ( server_url BLOB NOT NULL, timestamp INTEGER NOT NULL, salt CHAR(40) NOT NULL, PRIMARY KEY (server_url(255), timestamp, salt) ) ENGINE=InnoDB; aG CREATE TABLE %(associations)s ( server_url BLOB NOT NULL, handle VARCHAR(255) NOT NULL, secret BLOB NOT NULL, issued INTEGER NOT NULL, lifetime INTEGER NOT NULL, assoc_type VARCHAR(64) NOT NULL, PRIMARY KEY (server_url(255), handle) ) ENGINE=InnoDB; zDREPLACE INTO %(associations)s VALUES (%%s, %%s, %%s, %%s, %%s, %%s);aSELECT handle, secret, issued, lifetime, assoc_type FROM %(associations)s WHERE server_url = %%s;FSELECT server_url FROM %(associations)s WHERE issued + lifetime < %%s;rSELECT handle, secret, issued, lifetime, assoc_type FROM %(associations)s WHERE server_url = %%s AND handle = %%s;EDELETE FROM %(associations)s WHERE server_url = %%s AND handle = %%s;;DELETE FROM %(associations)s WHERE issued + lifetime < %%s;.INSERT INTO %(nonces)s VALUES (%%s, %%s, %%s);-DELETE FROM %(nonces)s WHERE timestamp < %%s;r.)rrrrrMySQLdbr) ImportErrorrrrrrrrrrrrr.rrrrhss $ >MGNNO JCTODMEOY  s %00rc\rSrSrSrSSKrSr Sr Sr Sr S rS rS rS rS rSrSrSrSrSrSrSrg!\a SSKJr \R5 NBf=f)PostgreSQLStoreiz This is a PostgreSQL-based specialization of C{L{SQLStore}}. To create an instance, see C{L{SQLStore.__init__}}. To create the tables it will use, see C{L{SQLStore.createTables}}. All other methods are implementation details. rN)compatz CREATE TABLE %(nonces)s ( server_url VARCHAR(2047) NOT NULL, timestamp INTEGER NOT NULL, salt CHAR(40) NOT NULL, PRIMARY KEY (server_url, timestamp, salt) ); a CREATE TABLE %(associations)s ( server_url VARCHAR(2047) NOT NULL, handle VARCHAR(255) NOT NULL, secret BYTEA NOT NULL, issued INTEGER NOT NULL, lifetime INTEGER NOT NULL, assoc_type VARCHAR(64) NOT NULL, PRIMARY KEY (server_url, handle), CONSTRAINT secret_length_constraint CHECK (LENGTH(secret) <= 128) ); cURX5nURR5n[U5(aUR X4XVX5$UR XX4XV5$)z Set an association. This is implemented as a method because REPLACE INTO is not supported by PostgreSQL (and is not standard SQL). )rsr#rurvdb_update_assoc db_new_assoc) r rkrfrgrhrirjresultr{s rrePostgreSQLStore.db_set_assocse"":6xx  " t99''(2< < $$Z%-; ;rzCINSERT INTO %(associations)s VALUES (%%s, %%s, %%s, %%s, %%s, %%s);zUPDATE %(associations)s SET secret = %%s, issued = %%s, lifetime = %%s, assoc_type = %%s WHERE server_url = %%s AND handle = %%s;rrrrrrrcSSKJn U"U5$)Nr)Binary)psycopg2r)r r0rs rr6PostgreSQLStore.blobEncodes#d|rc"UR5$r)tobytesr/s rr1PostgreSQLStore.blobDecodes||~rr.)rrrrrrr psycopg2cffirregisterr)rrre new_assoc_sqlupdate_assoc_sqlrrrrrrrr6r1rr.rrrrs J ;&>MCGNNO JCTODMEO Y 's2AAr)rrropenid.associationropenid.store.interfacer openid.storerrrrrrr.rrrs[ *.  }:{}:@C(CL:F:FzYhYr