MCPcopy Create free account

hub / github.com/MagicStack/asyncpg / functions

Functions868 in github.com/MagicStack/asyncpg

↓ 251 callersMethodexecute
Execute an SQL command (or commands). Pool performs this operation using one of its connections. Other than that, it behaves identic
asyncpg/pool.py:577
↓ 163 callersMethodfetchval
(self, query)
tests/test_pool.py:497
↓ 103 callersMethodget
(self, query, *, promote=True)
asyncpg/connection.py:2532
↓ 93 callersMethodclose
Attempt to gracefully close all connections in the pool. Wait until all pool connections are released, close them and shut down the p
asyncpg/pool.py:939
↓ 84 callersMethodfetchrow
Run a query and return the first row. Pool performs this operation using one of its connections. Other than that, it behaves identic
asyncpg/pool.py:650
↓ 75 callersMethodacquire
Acquire a database connection from the pool. :param float timeout: A timeout for acquiring a Connection. :return: An instance of :cla
asyncpg/pool.py:852
↓ 73 callersMethodfetch
Run a query and return the results as a list of :class:`Record`. Pool performs this operation using one of its connections. Other than
asyncpg/pool.py:613
↓ 70 callersMethodprepare
Create a *prepared statement* for the specified query. :param str query: Text of the query to create a prepared statement for.
asyncpg/connection.py:606
↓ 61 callersMethodcreate_pool
(self, **kwargs)
tests/test_pool.py:1074
↓ 57 callersMethodconnect
(*args, **kwargs)
tests/test_pool.py:144
↓ 57 callersMethodtransaction
Create a :class:`~transaction.Transaction` object. Refer to `PostgreSQL documentation`_ on the meaning of transaction parameters.
asyncpg/connection.py:279
↓ 35 callersMethodcursor
Return a *cursor factory* for the specified query. :param args: Query arguments. :param int prefetch: The num
asyncpg/connection.py:567
↓ 26 callersMethodis_closed
Return ``True`` if the connection is closed, ``False`` otherwise. :return bool: ``True`` if the connection is closed, ``False``
asyncpg/connection.py:1494
↓ 23 callersMethodis_in_transaction
Return True if Connection is currently inside a transaction. :return bool: True if inside transaction, False otherwise. .. versionad
asyncpg/connection.py:305
↓ 22 callersMethod_prepare
( self, query, *, name: typing.Union[str, bool, None] = None, timeout=
asyncpg/connection.py:645
↓ 22 callersMethodrelease
Release a database connection back to the pool. :param Connection connection: A :class:`~asyncpg.connection.Connection` object to
asyncpg/pool.py:901
↓ 20 callersMethodexecutemany
Execute an SQL *command* for each sequence of arguments in *args*. Pool performs this operation using one of its connections. Other than
asyncpg/pool.py:594
↓ 20 callersMethodrun_testcase
(self, testcase)
tests/test_connect.py:1131
↓ 19 callersMethodset_type_codec
Set an encoder/decoder pair for the specified data type. :param typename: Name of the data type the codec is for. :param
asyncpg/connection.py:1262
↓ 18 callersMethodadd_hba_entry
Add a record to pg_hba.conf.
asyncpg/cluster.py:383
↓ 17 callersMethodterminate
Terminate all connections in the pool.
asyncpg/pool.py:990
↓ 15 callersMethodrun
(N, meth)
tests/test_pool.py:582
↓ 14 callersMethodassertRunUnder
(self, delta)
asyncpg/_testbase/__init__.py:143
↓ 14 callersMethodget_status
(self)
asyncpg/cluster.py:100
↓ 13 callersMethod_check_open
(self)
asyncpg/connection.py:1603
↓ 13 callersMethod_check_statements_are_not_closed
(self, statements)
tests/test_cache_invalidation.py:22
↓ 13 callersMethodclear
(self)
asyncpg/connection.py:2572
↓ 13 callersMethodstart
Start the cluster.
asyncpg/cluster.py:167
↓ 12 callersMethod_check_statements_are_closed
(self, statements)
tests/test_cache_invalidation.py:26
↓ 12 callersMethod_get_cached_statements
(self, connection=None)
tests/test_cache_invalidation.py:17
↓ 12 callersMethodget_settings
Return connection settings. :return: :class:`~asyncpg.ConnectionSettings`.
asyncpg/connection.py:272
↓ 11 callersMethodcopy_from_query
Copy the results of a query to a file or file-like object. Pool performs this operation using one of its connections. Other than tha
asyncpg/pool.py:728
↓ 10 callersFunction_timezone
(offset)
tests/test_codecs.py:23
↓ 10 callersMethodget_connection_spec
(self)
asyncpg/cluster.py:321
↓ 8 callersMethod_check_ready
(self)
asyncpg/cursor.py:105
↓ 8 callersMethod_try_connect
(self, **kwargs)
tests/test_connect.py:228
↓ 8 callersMethodclose
(self)
asyncpg/_testbase/fuzzer.py:165
↓ 8 callersMethodcopy_to_table
Copy data to the specified table. Pool performs this operation using one of its connections. Other than that, it behaves identically
asyncpg/pool.py:770
↓ 8 callersMethodfrom_callable
(cls, cb: typing.Callable[..., None])
asyncpg/connection.py:2627
↓ 7 callersMethod_test_works
(self, **conn_args)
tests/test_connect.py:2086
↓ 7 callersMethodadd_listener
Add a listener for Postgres notifications. :param str channel: Channel to listen on. :param callable callback: A callabl
asyncpg/connection.py:139
↓ 7 callersMethodreset
(con)
tests/test_pool.py:162
↓ 6 callersMethodadd_log_listener
Add a listener for Postgres log messages. It will be called when asyncronous NoticeResponse is received from the connection. Possibl
asyncpg/connection.py:175
↓ 6 callersMethodcheckref
(self, *objs)
tests/test_record.py:36
↓ 6 callersMethodget_attributes
Return a description of relation attributes (columns). :return: A tuple of :class:`asyncpg.types.Attribute`. Example::
asyncpg/prepared_stmt.py:79
↓ 6 callersMethodget_connection_spec
(cls, kwargs={})
asyncpg/_testbase/__init__.py:347
↓ 6 callersMethodget_pg_version
(self)
asyncpg/cluster.py:91
↓ 6 callersMethodget_server_pid
Return the PID of the Postgres server the connection is bound to.
asyncpg/connection.py:252
↓ 6 callersFunctionmock_dot_postgresql
(*, ca=True, crl=False, client=False, protected=False)
tests/test_connect.py:60
↓ 6 callersMethodnew_cluster
(cls, ClusterCls, *, cluster_kwargs={}, initdb_options={})
asyncpg/_testbase/__init__.py:313
↓ 6 callersMethodreload
Reload server configuration.
asyncpg/cluster.py:262
↓ 6 callersMethodrollback
Exit the transaction or savepoint block and rollback changes.
asyncpg/transaction.py:222
↓ 6 callersMethodset_builtin_type_codec
Set a builtin codec for the specified scalar data type. This method has two uses. The first is to register a builtin codec for an ex
asyncpg/connection.py:1444
↓ 6 callersMethodstart_cluster
(cls, cluster, *, server_settings={})
asyncpg/_testbase/__init__.py:320
↓ 5 callersMethod_drop_local_statement_cache
(self)
asyncpg/connection.py:1792
↓ 5 callersMethod_execute
( self, query, args, limit, timeout, *, return_status=
asyncpg/connection.py:1861
↓ 5 callersMethod_find_pg_binary
(self, binary)
asyncpg/cluster.py:591
↓ 5 callersMethod_get_statement
( self, query, timeout, *, named: typing.Union[str, bool, None] = Fals
asyncpg/connection.py:403
↓ 5 callersMethodget_cluster_connection_spec
(cls, cluster, kwargs={})
asyncpg/_testbase/__init__.py:504
↓ 5 callersMethodget_max_size
Return the maximum allowed number of connections in this pool. .. versionadded:: 0.25.0
asyncpg/pool.py:499
↓ 5 callersMethodget_server_version
Return the version of the connected PostgreSQL server. The returned value is a named tuple similar to that in ``sys.version_info``:
asyncpg/connection.py:256
↓ 5 callersMethoditer_statements
(self)
asyncpg/connection.py:2569
↓ 5 callersMethodlower
(self)
asyncpg/types.py:107
↓ 5 callersMethodremove_listener
Remove a listening callback on the specified channel.
asyncpg/connection.py:161
↓ 5 callersMethodreset_type_codec
Reset *typename* codec to the default implementation. :param typename: Name of the data type the codec is for. :param sc
asyncpg/connection.py:1424
↓ 4 callersMethod__execute
( self, query, args, limit, timeout, *, return_status=
asyncpg/connection.py:1940
↓ 4 callersFunction_accept_in_hot_standby
If the server didn't report "in_hot_standby" at startup, we must determine the state by checking "SELECT pg_catalog.pg_is_in_recovery()".
asyncpg/connect_utils.py:1150
↓ 4 callersMethod_check_init
(self)
asyncpg/pool.py:1009
↓ 4 callersMethod_clear_entry_callback
(self, entry)
asyncpg/connection.py:2606
↓ 4 callersFunction_dot_postgresql_path
(filename)
asyncpg/connect_utils.py:267
↓ 4 callersMethod_get_unique_id
(self, prefix)
asyncpg/connection.py:1607
↓ 4 callersMethod_maybe_gc_stmt
(self, stmt)
asyncpg/connection.py:1622
↓ 4 callersFunction_parse_hostlist
(hostlist, port, *, unquote=False)
asyncpg/connect_utils.py:190
↓ 4 callersMethodassertLoopErrorHandlerCalled
(self, msg_re: str)
asyncpg/_testbase/__init__.py:156
↓ 4 callersMethodconnect
(self)
asyncpg/pool.py:147
↓ 4 callersMethodconnect
(cls, **kwargs)
asyncpg/_testbase/__init__.py:360
↓ 4 callersMethodcopy_records_to_table
Copy a list of records to the specified table using binary COPY. Pool performs this operation using one of its connections. Other than
asyncpg/pool.py:823
↓ 4 callersMethodfetchmany
Run a query for each sequence of arguments in *args* and return the results as a list of :class:`Record`. Pool performs this operatio
asyncpg/pool.py:667
↓ 4 callersMethodforward
r"""Skip over the next *n* rows. :param float timeout: Optional timeout value in seconds. :return: A number of rows actually skipped
asyncpg/cursor.py:304
↓ 4 callersMethodget_idle_size
Return the current number of idle connections in this pool. .. versionadded:: 0.25.0
asyncpg/pool.py:506
↓ 4 callersMethodget_server_settings
(cls)
tests/test_connect.py:424
↓ 4 callersMethodis_closing
Return ``True`` if the pool is closing or is closed. .. versionadded:: 0.28.0
asyncpg/pool.py:478
↓ 4 callersMethodreset_hba
Remove all records from pg_hba.conf.
asyncpg/cluster.py:367
↓ 4 callersMethodrestore_connectivity
(self)
asyncpg/_testbase/fuzzer.py:133
↓ 4 callersMethodtrigger_connectivity_loss
(self)
asyncpg/_testbase/fuzzer.py:126
↓ 4 callersMethodtrust_local_connections
(self)
asyncpg/cluster.py:418
↓ 4 callersMethodupper
(self)
asyncpg/types.py:119
↓ 3 callersMethod__bind_execute
(self, args, limit, timeout)
asyncpg/prepared_stmt.py:267
↓ 3 callersFunction__connect_addr
( params, retry, addr, loop, config, connection_class, record_class, params_in
asyncpg/connect_utils.py:1066
↓ 3 callersMethod__do_execute
(self, executor)
asyncpg/prepared_stmt.py:254
↓ 3 callersMethod__init__
(self, msg, *, detail=None, hint=None)
asyncpg/exceptions/_base.py:211
↓ 3 callersFunction_create_future
(loop)
asyncpg/connect_utils.py:1307
↓ 3 callersMethod_do_execute
( self, query, executor, timeout, retry=True, *, ignor
asyncpg/connection.py:2002
↓ 3 callersMethod_exec
(self, n, timeout)
asyncpg/cursor.py:149
↓ 3 callersMethod_format_copy_opts
(self, *, format=None, oids=None, freeze=None, delimiter=None, null=None, header=Non
asyncpg/connection.py:1142
↓ 3 callersFunction_get_connected_host
(con)
tests/test_connect.py:2375
↓ 3 callersMethod_introspect_type
(self, typename, schema)
asyncpg/connection.py:547
↓ 3 callersFunction_is_asyncpg_class
(cls)
asyncpg/exceptions/_base.py:21
↓ 3 callersMethod_maybe_cancel_inactive_callback
(self)
asyncpg/pool.py:285
↓ 3 callersFunction_parse_tls_version
(tls_version)
asyncpg/connect_utils.py:254
next →1–100 of 868, ranked by callers