Home
last modified time | relevance | path

Searched refs:_get_connection (Results 1 – 25 of 109) sorted by relevance

12345

/dports/textproc/py-elasticsearch-dsl/elasticsearch-dsl-7.3.0/elasticsearch_dsl/
H A Dindex.py132 def _get_connection(self, using=None): member in Index
137 connection = property(_get_connection)
279 return self._get_connection(using).indices.create(
284 state = self._get_connection(using).cluster.state(
423 return self._get_connection(using).indices.exists_type(
434 return self._get_connection(using).indices.put_mapping(
445 return self._get_connection(using).indices.get_mapping(
476 return self._get_connection(using).indices.exists_alias(
559 return self._get_connection(using).indices.clear_cache(
589 return self._get_connection(using).indices.get_upgrade(
[all …]
H A Ddocument.py141 def _get_connection(cls, using=None): member in Document
202 es = cls._get_connection(using)
231 es = cls._get_connection(using)
284 es = self._get_connection(using)
410 meta = self._get_connection(using).update(
442 es = self._get_connection(using)
/dports/devel/py-taskflow/taskflow-4.6.3/taskflow/tests/unit/persistence/
H A Dbase.py28 def _get_connection(self): member in PersistenceTestMixin
39 with contextlib.closing(self._get_connection()) as conn:
44 with contextlib.closing(self._get_connection()) as conn:
47 with contextlib.closing(self._get_connection()) as conn:
59 with contextlib.closing(self._get_connection()) as conn:
64 with contextlib.closing(self._get_connection()) as conn:
67 with contextlib.closing(self._get_connection()) as conn:
86 with contextlib.closing(self._get_connection()) as conn:
101 with contextlib.closing(self._get_connection()) as conn:
107 with contextlib.closing(self._get_connection()) as conn:
[all …]
H A Dtest_dir_persistence.py44 def _get_connection(self): member in DirPersistenceTest
54 with contextlib.closing(self._get_connection()) as conn:
80 with contextlib.closing(self._get_connection()) as conn:
91 with contextlib.closing(self._get_connection()) as conn:
H A Dtest_sql_persistence.py105 def _get_connection(self): member in SqlitePersistenceTest
116 with contextlib.closing(self._get_connection()) as conn:
130 def _get_connection(self): member in BackendPersistenceTestMixin
166 with contextlib.closing(self._get_connection()) as conn:
/dports/textproc/py-elasticsearch-dsl6/elasticsearch-dsl-6.4.0/elasticsearch_dsl/
H A Dindex.py117 def _get_connection(self, using=None): member in Index
122 connection = property(_get_connection)
342 return self._get_connection(using).indices.analyze(index=self._name, **kwargs)
351 return self._get_connection(using).indices.refresh(index=self._name, **kwargs)
360 return self._get_connection(using).indices.flush(index=self._name, **kwargs)
369 return self._get_connection(using).indices.get(index=self._name, **kwargs)
378 return self._get_connection(using).indices.open(index=self._name, **kwargs)
387 return self._get_connection(using).indices.close(index=self._name, **kwargs)
396 return self._get_connection(using).indices.delete(index=self._name, **kwargs)
405 return self._get_connection(using).indices.exists(index=self._name, **kwargs)
[all …]
H A Ddocument.py125 def _get_connection(cls, using=None): member in Document
185 es = cls._get_connection(using)
218 es = cls._get_connection(using)
276 es = self._get_connection(using)
397 meta = self._get_connection(using).update(
429 es = self._get_connection(using)
/dports/devel/b2/B2_Command_Line_Tool-1.3.8/b2/account_info/
H A Dsqlite_account_info.py51 with self._get_connection() as conn:
105 def _get_connection(self): member in SqliteAccountInfo
195 with self._get_connection() as conn:
210 with self._get_connection() as conn:
228 with self._get_connection() as conn:
262 with self._get_connection() as conn:
327 with self._get_connection() as conn:
339 with self._get_connection() as conn:
348 with self._get_connection() as conn:
356 with self._get_connection() as conn:
[all …]
/dports/devel/py-b2sdk/b2sdk-1.12.0/b2sdk/account_info/
H A Dsqlite_account_info.py83 with self._get_connection() as conn:
153 def _get_connection(self): member in SqliteAccountInfo
338 with self._get_connection() as conn:
356 with self._get_connection() as conn:
376 with self._get_connection() as conn:
424 with self._get_connection() as conn:
524 with self._get_connection() as conn:
536 with self._get_connection() as conn:
545 with self._get_connection() as conn:
553 with self._get_connection() as conn:
[all …]
/dports/sysutils/py-salt/salt-3004.1/salt/returners/
H A Dcouchbase_return.py105 def _get_connection(): function
136 cb_ = _get_connection()
186 cb_ = _get_connection()
206 cb_ = _get_connection()
230 cb_ = _get_connection()
257 cb_ = _get_connection()
277 cb_ = _get_connection()
298 cb_ = _get_connection()
315 cb_ = _get_connection()
/dports/sysutils/py-salt/salt-3004.1/salt/modules/
H A Dmssql.py57 def _get_connection(**kwargs): function
86 cur = _get_connection(**kwargs).cursor()
169 conn = _get_connection(**kwargs)
201 conn = _get_connection(**kwargs)
272 conn = _get_connection(**kwargs)
299 conn = _get_connection(**kwargs)
391 conn = _get_connection(**kwargs)
420 conn = _get_connection(**kwargs)
518 conn = _get_connection(**kwargs)
550 conn = _get_connection(**kwargs)
/dports/mail/p5-Clamd/Clamd-1.04/lib/
H A DClamd.pm108 my $conn = $self->_get_connection();
217 my $conn = $self->_get_connection();
255 my $conn = $self->_get_connection();
270 my $conn = $self->_get_connection();
278 sub _get_connection { subroutine
/dports/security/p5-File-Scan-ClamAV/File-Scan-ClamAV-1.95/lib/File/Scan/
H A DClamAV.pm138 my $conn = $self->_get_connection || return;
218 my $conn = $self->_get_connection || return;
248 my $conn = $self->_get_connection || return;
263 my $conn = $self->_get_connection || return;
379 my $conn = $self->_get_connection || return;
429 sub _get_connection { subroutine
/dports/databases/py-south/South-1.0.2/south/db/
H A Dsqlite3.py35 … field_default = "'%s'" % field.get_db_prep_save(default, connection=self._get_connection())
64 cursor = self._get_connection().cursor()
66 indexes = self._get_connection().introspection.get_indexes(cursor, table_name)
69 … for column_info in self._get_full_table_description(self._get_connection(), cursor, table_name):
126 cursor = self._get_connection().cursor()
127 …src_fields = [column_info[0] for column_info in self._get_connection().introspection.get_table_des…
128 …dst_fields = [column_info[0] for column_info in self._get_connection().introspection.get_table_des…
167 cursor = self._get_connection().cursor()
H A Dgeneric.py113 connection = self._get_connection()
201 def _get_connection(self): member in DatabaseOperations
217 connection = self._get_connection()
258 return self._get_connection().ops.quote_name(name)
272 cursor = self._get_connection().cursor()
433 return field.db_type(connection=self._get_connection())
668 sql = field.db_type(connection=self._get_connection())
741 if hasattr(self._get_connection().creation, "sql_indexes_for_field"):
780 self._get_connection().ops.deferrable_sql() # Django knows this
828 return truncate_name(name, self._get_connection().ops.max_name_length())
[all …]
H A Dfirebird.py149 sql = field.db_type(connection=self._get_connection())
193 …if field.empty_strings_allowed and self._get_connection().features.interprets_empty_strings_as_nul…
224 if hasattr(self._get_connection().creation, "sql_indexes_for_field"):
227 … for stmt in self._get_connection().creation.sql_indexes_for_field(model, field, no_style()):
/dports/databases/py-aesqlapius/aesqlapius-0.0.9/aesqlapius/drivers/
H A Dasyncpg.py93 async def _get_connection(conn: Union[asyncpg.Connection, asyncpg.pool.Pool], force_transaction: bo… function
113 async with _get_connection(db) as conn:
125 async with _get_connection(db, True) as conn:
137 async with _get_connection(db) as conn:
152 async with _get_connection(db) as conn:
171 async with _get_connection(db) as conn:
/dports/sysutils/ansible2/ansible-2.9.27/lib/ansible/module_utils/network/exos/
H A Dexos.py47 connection = self._get_connection()
50 def _get_connection(self): member in Cli
60 connection = self._get_connection()
71 connection = self._get_connection()
79 conn = self._get_connection()
/dports/sysutils/ansible/ansible-4.7.0/ansible_collections/community/network/plugins/module_utils/network/exos/
H A Dexos.py50 connection = self._get_connection()
53 def _get_connection(self): member in Cli
63 connection = self._get_connection()
74 connection = self._get_connection()
82 conn = self._get_connection()
/dports/sysutils/ansible/ansible-4.7.0/ansible_collections/ansible/netcommon/plugins/module_utils/network/common/rm_base/
H A Dresource_module_base.py54 self._get_connection()
56 def _get_connection(self): member in RmEngineBase
/dports/databases/py-cassandra-driver/cassandra-driver-3.18.0/cassandra/cqlengine/
H A Dnamed.py95 _get_connection = BaseModel._get_connection variable in NamedTable
116 …table_meta = get_cluster(self._get_connection()).metadata.keyspaces[self.keyspace].tables[self.nam…
/dports/sysutils/cluster-glue/Reusable-Cluster-Components-glue--0a7add1d9996/lib/plugins/stonith/external/
H A Dibmrsa-telnet170 def _get_connection(self):
187 self._get_connection()
196 self._get_connection()
205 self._get_connection()
218 self._get_connection()
H A Ddracmc-telnet191 def _get_connection(self):
228 self._get_connection()
238 self._get_connection()
247 self._get_connection()
260 self._get_connection()
/dports/devel/py-celery/celery-4.4.7/celery/backends/
H A Dcassandra.py134 def _get_connection(self, write=False): member in CassandraBackend
199 self._get_connection(write=True)
215 self._get_connection()
/dports/sysutils/ansible2/ansible-2.9.27/lib/ansible/module_utils/network/eos/
H A Deos.py127 self._session_support = self._get_connection().supports_sessions()
130 def _get_connection(self): member in Cli
149 conn = self._get_connection()
162 connection = self._get_connection()
172 conn = self._get_connection()
186 conn = self._get_connection()
200 connection = self._get_connection()

12345