| /dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/storage/databases/main/ |
| H A D | registration.py | 304 self.db_pool.simple_update_txn(
319 await self.db_pool.runInteraction(
652 self.db_pool.simple_insert_txn(
672 await self.db_pool.simple_delete(
902 await self.db_pool.simple_upsert(
919 await self.db_pool.simple_delete(
932 await self.db_pool.simple_delete(
953 await self.db_pool.simple_upsert(
999 await self.db_pool.simple_delete(
1217 self.db_pool.simple_upsert_txn(
[all …]
|
| H A D | group_server.py | 652 await self.db_pool.runInteraction(
761 self.db_pool.simple_update_txn(
775 self.db_pool.simple_insert_txn(
824 await self.db_pool.simple_upsert(
860 await self.db_pool.simple_upsert(
895 await self.db_pool.runInteraction(
1040 await self.db_pool.simple_insert(
1138 await self.db_pool.runInteraction(
1145 await self.db_pool.simple_insert(
1175 await self.db_pool.runInteraction(
[all …]
|
| H A D | events_bg_updates.py | 301 result = await self.db_pool.runInteraction(
377 result = await self.db_pool.runInteraction(
548 self.db_pool.simple_delete_many_txn(
570 await self.db_pool.runInteraction(
622 count = await self.db_pool.runInteraction(
653 await self.db_pool.runInteraction(
827 await self.db_pool.simple_insert_many(
888 await self.db_pool.simple_update(
1036 self.db_pool,
1286 await self.db_pool.execute(
[all …]
|
| H A D | user_directory.py | 125 await self.db_pool.runInteraction(
128 await self.db_pool.simple_insert(
155 await self.db_pool.runInteraction(
468 self.db_pool.simple_upsert_txn(
511 await self.db_pool.runInteraction(
567 await self.db_pool.runInteraction(
610 self.db_pool.simple_delete_txn(
613 self.db_pool.simple_delete_txn(
616 self.db_pool.simple_delete_txn(
631 await self.db_pool.runInteraction(
[all …]
|
| H A D | pusher.py | 202 await self.db_pool.simple_update_one(
245 await self.db_pool.simple_update(
276 await self.db_pool.simple_upsert(
306 self.db_pool.simple_delete_many_txn(
423 self.db_pool.simple_delete_txn(
470 await self.db_pool.simple_upsert(
512 self.db_pool.simple_delete_txn(
521 self.db_pool.simple_insert_txn(
533 await self.db_pool.runInteraction(
555 self.db_pool.simple_delete_txn(
[all …]
|
| H A D | media_repository.py | 319 await self.db_pool.simple_insert(
393 await self.db_pool.simple_insert(
430 await self.db_pool.simple_upsert(
471 await self.db_pool.simple_insert(
521 await self.db_pool.runInteraction(
584 await self.db_pool.simple_upsert(
606 return await self.db_pool.execute(
612 self.db_pool.simple_delete_txn(
617 self.db_pool.simple_delete_txn(
623 await self.db_pool.runInteraction(
[all …]
|
| H A D | devices.py | 502 await self.db_pool.runInteraction(
574 self.db_pool.simple_insert_txn(
847 await self.db_pool.simple_upsert(
857 await self.db_pool.simple_delete(
876 await self.db_pool.runInteraction(
913 self.db_pool.simple_upsert_txn(
1043 await self.db_pool.runInteraction(
1370 await self.db_pool.runInteraction(
1412 self.db_pool.simple_upsert_txn(
1446 self.db_pool.simple_delete_txn(
[all …]
|
| H A D | room.py | 121 await self.db_pool.simple_insert(
654 self.db_pool.simple_upsert_txn(
1531 await self.db_pool.simple_upsert(
1558 await self.db_pool.simple_upsert(
1578 await self.db_pool.simple_update_one(
1605 await self.db_pool.simple_upsert(
1643 await self.db_pool.simple_insert(
1839 await self.db_pool.simple_upsert(
1846 await self.db_pool.runInteraction(
1859 await self.db_pool.simple_delete(
[all …]
|
| H A D | ui_auth.py | 88 await self.db_pool.simple_insert(
150 await self.db_pool.simple_upsert(
196 await self.db_pool.simple_update_one(
216 await self.db_pool.runInteraction(
230 self.db_pool.simple_select_one_txn(
242 self.db_pool.simple_update_one_txn(
280 await self.db_pool.simple_upsert(
313 await self.db_pool.runInteraction(
328 self.db_pool.simple_delete_many_txn(
379 self.db_pool.simple_delete_many_txn(
[all …]
|
| H A D | client_ips.py | 131 await self.db_pool.runWithConnection(f)
132 await self.db_pool.updates._end_background_update(
180 end_last_seen = await self.db_pool.runInteraction(
390 updated = await self.db_pool.runInteraction(
455 await self.db_pool.runInteraction(
481 await self.db_pool.simple_select_list(
528 rows = await self.db_pool.runInteraction(
600 if not self.db_pool.is_running():
606 await self.db_pool.runInteraction(
623 self.db_pool.simple_upsert_txn(
[all …]
|
| H A D | profile.py | 25 profile = await self.db_pool.simple_select_one(
43 return await self.db_pool.simple_select_one_onecol(
61 return await self.db_pool.simple_select_one(
70 await self.db_pool.simple_insert(
77 await self.db_pool.simple_upsert(
87 await self.db_pool.simple_upsert(
97 return await self.db_pool.simple_update(
114 await self.db_pool.simple_delete(
161 return self.db_pool.cursor_to_dict(txn)
163 return await self.db_pool.runInteraction(
[all …]
|
| H A D | transactions.py | 86 await self.db_pool.runInteraction(
106 return await self.db_pool.runInteraction(
151 await self.db_pool.simple_upsert(
225 await self.db_pool.runInteraction(
235 await self.db_pool.runInteraction(
302 self.db_pool.simple_insert_txn(
317 self.db_pool.simple_update_one_txn(
347 await self.db_pool.simple_upsert_many(
357 await self.db_pool.simple_upsert_many(
397 await self.db_pool.simple_upsert(
[all …]
|
| H A D | stats.py | 168 await self.db_pool.runInteraction(
214 await self.db_pool.runInteraction(
227 return await self.db_pool.simple_select_one_onecol(
276 await self.db_pool.simple_upsert(
333 self.db_pool.simple_update_one_txn(
340 await self.db_pool.runInteraction(
370 await self.db_pool.runInteraction(
517 rows = self.db_pool.simple_select_many_txn(
573 ) = await self.db_pool.runInteraction(
767 users = self.db_pool.cursor_to_dict(txn)
[all …]
|
| H A D | deviceinbox.py | 194 return await self.db_pool.runInteraction(
236 count = await self.db_pool.runInteraction(
309 return await self.db_pool.runInteraction(
334 await self.db_pool.runInteraction(
399 return await self.db_pool.runInteraction(
432 self.db_pool.simple_insert_many_txn(
456 await self.db_pool.runInteraction(
489 self.db_pool.simple_insert_txn(
507 await self.db_pool.runInteraction(
571 self.db_pool.simple_insert_many_txn(
[all …]
|
| H A D | state.py | 65 return await self.db_pool.runInteraction(
101 return await self.db_pool.runInteraction(
216 return await self.db_pool.runInteraction(
265 return await self.db_pool.runInteraction(
295 return await self.db_pool.simple_select_one_onecol(
310 rows = await self.db_pool.simple_select_many_batch(
333 rows = await self.db_pool.simple_select_many_batch(
361 self.db_pool.updates.register_background_index_update(
467 rows = self.db_pool.simple_select_many_txn(
479 self.db_pool.simple_delete_many_txn(
[all …]
|
| H A D | search.py | 129 self.db_pool.updates.register_background_update_handler(
141 self.db_pool.updates.register_noop_background_update(
174 rows = self.db_pool.cursor_to_dict(txn)
240 result = await self.db_pool.runInteraction(
245 await self.db_pool.updates._end_background_update(
290 await self.db_pool.updates._end_background_update(
325 await self.db_pool.runInteraction(
461 results = await self.db_pool.execute(
482 count_results = await self.db_pool.execute(
619 results = await self.db_pool.execute(
[all …]
|
| H A D | end_to_end_keys.py | 406 await self.db_pool.runInteraction(
452 await self.db_pool.runInteraction(
494 self.db_pool.simple_upsert_txn(
1034 self.db_pool.simple_upsert_txn(
1056 self.db_pool.simple_delete_txn(
1061 self.db_pool.simple_delete_txn(
1069 self.db_pool.simple_delete_txn(
1074 self.db_pool.simple_delete_txn(
1083 await self.db_pool.runInteraction(
1130 self.db_pool.simple_insert_txn(
[all …]
|
| /dports/net-im/py-matrix-synapse/synapse-1.50.2/tests/storage/ |
| H A D | test_rollback_worker.py | 59 db_pool = self.hs.get_datastore().db_pool
61 db_pool._db_pool.connect(),
62 db_pool.engine,
71 prepare_database(db_conn, db_pool.engine, self.hs.config)
75 db_pool = self.hs.get_datastore().db_pool
77 db_pool._db_pool.connect(),
78 db_pool.engine,
88 prepare_database(db_conn, db_pool.engine, self.hs.config)
95 db_pool = self.hs.get_datastore().db_pool
97 db_pool._db_pool.connect(),
[all …]
|
| H A D | test_base.py | 34 self.db_pool = Mock(spec=["runInteraction"])
44 self.db_pool.runInteraction = runInteraction
61 db._db_pool = self.db_pool
70 self.datastore.db_pool.simple_insert(
84 self.datastore.db_pool.simple_insert(
117 self.datastore.db_pool.simple_select_one(
135 self.datastore.db_pool.simple_select_one(
152 self.datastore.db_pool.simple_select_list(
167 self.datastore.db_pool.simple_update_one(
184 self.datastore.db_pool.simple_update_one(
[all …]
|
| H A D | test__base.py | 27 self.storage.db_pool.runInteraction(
35 self.storage.db_pool.runInteraction(
58 self.storage.db_pool.runInteraction(
60 self.storage.db_pool.simple_upsert_many_txn,
71 self.storage.db_pool.simple_select_list(
85 self.storage.db_pool.runInteraction(
87 self.storage.db_pool.simple_upsert_many_txn,
98 self.storage.db_pool.simple_select_list(
|
| /dports/net-im/py-matrix-synapse/synapse-1.50.2/tests/storage/databases/main/ |
| H A D | test_deviceinbox.py | 42 self.store.db_pool.simple_insert(
53 self.store.db_pool.simple_insert(
66 self.store.db_pool.simple_insert(
76 self.store.db_pool.updates._all_done = False
82 self.store.db_pool.simple_select_onecol(
103 self.store.db_pool.simple_insert(
116 self.store.db_pool.simple_insert(
127 self.store.db_pool.simple_insert(
140 self.store.db_pool.simple_insert(
150 self.store.db_pool.updates._all_done = False
[all …]
|
| /dports/net/kamailio/kamailio-5.4.5/src/lib/srdb1/ |
| H A D | db_pool.c | 33 static struct pool_con* db_pool = 0; variable
50 ptr = db_pool; in pool_get()
70 con->next = db_pool; in pool_insert()
71 db_pool = con; in pool_insert()
102 if (db_pool == con) { in pool_remove()
103 db_pool = db_pool->next; in pool_remove()
105 ptr = db_pool; in pool_remove()
|
| /dports/databases/py-dbutils/DBUtils-2.0/tests/ |
| H A D | test_simple_pooled_pg.py | 32 db_pool = self.my_db_pool(1)
33 db = db_pool.connection()
45 db_pool = self.my_db_pool(1)
46 db = db_pool.connection()
52 db = db_pool.connection()
62 db_pool = self.my_db_pool(2)
63 db1 = db_pool.connection()
66 db2 = db_pool.connection()
74 db1 = db_pool.connection()
85 db_pool = self.my_db_pool(2)
[all …]
|
| /dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/storage/databases/state/ |
| H A D | bg_updates.py | 206 self.db_pool.updates.register_background_update_handler(
213 self.db_pool.updates.register_background_index_update(
235 rows = await self.db_pool.execute(
306 self.db_pool.simple_delete_txn(
312 self.db_pool.simple_insert_txn(
321 self.db_pool.simple_delete_txn(
327 self.db_pool.simple_insert_many_txn(
354 finished, result = await self.db_pool.runInteraction(
359 await self.db_pool.updates._end_background_update(
388 await self.db_pool.runWithConnection(reindex_txn)
[all …]
|
| H A D | store.py | 155 return await self.db_pool.runInteraction(
428 self.db_pool.simple_insert_txn(
454 self.db_pool.simple_insert_txn(
537 await self.db_pool.runInteraction(
581 self.db_pool.simple_delete_txn(
585 self.db_pool.simple_delete_txn(
589 self.db_pool.simple_insert_many_txn(
647 await self.db_pool.runInteraction(
663 self.db_pool.simple_delete_many_txn(
674 self.db_pool.simple_delete_many_txn(
[all …]
|