J KK2NN5) &    8!< Y  sD4F G/GGc\rSrSr%Sr\S-\S'\S\RS\ 4Sj5r SS\ S\4S jjr SS jr SS jrS \RSS4S jrS\RSS4SjrS\\R4SjrSrg)r<NCHECK_SAME_THREADr)rct[R"[R"U55R S5$)Nr )base64 b64encoderdumpsdecode)clsr)s r-r CollectionPersistence.encode_key?s' S 1299'BBrforce_disable_check_same_threadc>[U5 [U5[- UlURRR SSS9 UR cZUSLaU[R"S5nURS5R5SnUS:gURlSSS5 U(aSURl[R"[UR5UR S 9Ul UR5 g!,(df  Nn=f) zk Create or load a collection from the local storage. Args: location: path to the collection directory. T)exist_okparentsNFz:memory:zNselect * from pragma_compile_options where compile_options like 'THREADSAFE=%'rz THREADSAFE=1)check_same_thread)r.rr rparentmkdirr1rrrfetchone __class__rstorage _ensure_table)selfrr:tmp_conn threadsafes r-__init__CollectionPersistence.__init__Cs h'X)::  ""D$"?  ! ! ).MQV.V, &--d(*Q 4>3O0- +/4DNN ,  "44  '-,s /7D Dc8URR5 g)N)rCr)rEs r-rCollectionPersistence.closees r9cURR5nURS5 URR5 g)Nr )rCrrr)rErs r-rD#CollectionPersistence._ensure_tablehs1$$&\] r9pointcURUR5n[R"U5nURR 5nUR SU[R"U545 URR5 g)zI Persist a point in the local storage. Args: point: point to persist z+INSERT OR REPLACE INTO points VALUES (?, ?)N) ridrr5rCrrrrr)rErNr)r*rs r-persistCollectionPersistence.persistmsk ooehh' U#$$& 9u%   r9point_idcURU5nURR5nURSU45 URR 5 g)zV Delete a point from the local storage. Args: point_id: id of the point to delete zDELETE FROM points WHERE id = ?N)rrCrrr)rErSr)rs r-deleteCollectionPersistence.deletesJ ooh'$$& - F  r9c## URR5nURS5 UR5Hn[R "US5v M g7f)zG Load a point from the local storage. Returns: point: loaded point zSELECT point FROM pointsrN)rCrrfetchallrr)rErrows r-loadCollectionPersistence.loadsJ $$&12??$C,,s1v& &%sAA!)rrC)FrN)__name__ __module__ __qualname____firstlineno__r1bool__annotations__ classmethodrExtendedPointIdrrrHrrD PointStructrQrUrrZ__static_attributes__r9r-rr<s%)td{)CV33CCC  t D V//D* v55 $  'hv112 'r9rcSSKnUR5n[U5n[R"S/SQSS0S9nUR U5 UR 5H nXC:Xde O A[U5nUR 5H nXC:Xde O URUR5 URUR5 UR 5HnS5e SSS5 g!,(df  g=f)Nr)g?g@g@a)rPvectorpayloadzShould not load anything) tempfileTemporaryDirectoryrrrerQrZrUrP)rmtmpdir persistencerN loaded_point_s r-test_persistencerss  $ $ &&+F3 ""a#qRE"',,.L( (( / +F3 ',,.L( (( / 588$588$!!#A 44 45$! ' & &s CC// C=r\)r3rr"rrpathlibrtypingrqdrant_client.httprr r rr.rrsrgr9r-rwsO  %%$*C*D*Z]']'@5r9