gino.dialects package

Submodules

gino.dialects.asyncpg module

class gino.dialects.asyncpg.AsyncEnum(*enums, **kw)[source]

Bases: sqlalchemy.dialects.postgresql.base.ENUM

Construct an ENUM.

Arguments are the same as that of types.Enum, but also including the following parameters.

Parameters:create_type

Defaults to True. Indicates that CREATE TYPE should be emitted, after optionally checking for the presence of the type, when the parent table is being created; and additionally that DROP TYPE is called when the table is dropped. When False, no check will be performed and no CREATE TYPE or DROP TYPE is emitted, unless create() or drop() are called directly. Setting to False is helpful when invoking a creation scheme to a SQL file without access to the actual database - the create() and drop() methods can be used to emit SQL to a target bind.

New in version 0.7.4.

coroutine create_async(bind=None, checkfirst=True)[source]
coroutine drop_async(bind=None, checkfirst=True)[source]
class gino.dialects.asyncpg.AsyncpgCompiler(dialect, statement, column_keys=None, inline=False, **kwargs)[source]

Bases: sqlalchemy.dialects.postgresql.base.PGCompiler

Construct a new SQLCompiler object.

Parameters:
  • dialectDialect to be used
  • statementClauseElement to be compiled
  • column_keys – a list of column names to be compiled into an INSERT or UPDATE statement.
  • inline – whether to generate INSERT statements as “inline”, e.g. not formatted to return any generated defaults
  • kwargs – additional keyword arguments to be consumed by the superclass.
bindtemplate
class gino.dialects.asyncpg.AsyncpgCursor(context, cursor)[source]

Bases: gino.dialects.base.Cursor

coroutine forward(n, *, timeout=<object object>)[source]
coroutine many(n, *, timeout=<object object>)[source]
coroutine next(*, timeout=<object object>)[source]
class gino.dialects.asyncpg.AsyncpgDBAPI[source]

Bases: gino.dialects.base.BaseDBAPI

Error = (<class 'asyncpg.exceptions._base.PostgresError'>, <class 'asyncpg.exceptions._base.InterfaceError'>)
class gino.dialects.asyncpg.AsyncpgDialect(*args, **kwargs)[source]

Bases: sqlalchemy.dialects.postgresql.base.PGDialect, gino.dialects.base.AsyncDialectMixin

colspecs = {<class 'sqlalchemy.sql.sqltypes.Interval'>: <class 'sqlalchemy.dialects.postgresql.base.INTERVAL'>, <class 'sqlalchemy.sql.sqltypes.Enum'>: <class 'gino.dialects.asyncpg.AsyncEnum'>, <class 'sqlalchemy.sql.sqltypes.ARRAY'>: <class 'sqlalchemy.dialects.postgresql.array.ARRAY'>, <class 'sqlalchemy.sql.sqltypes.JSON.JSONPathType'>: <class 'sqlalchemy.dialects.postgresql.json.JSONPathType'>, <class 'sqlalchemy.sql.sqltypes.JSON'>: <class 'sqlalchemy.dialects.postgresql.json.JSON'>, <class 'sqlalchemy.dialects.postgresql.base.ENUM'>: <class 'gino.dialects.asyncpg.AsyncEnum'>}
cursor_cls

alias of DBAPICursor

dbapi_class

alias of AsyncpgDBAPI

driver = 'asyncpg'
execution_ctx_cls

alias of AsyncpgExecutionContext

coroutine get_isolation_level(connection)[source]

Given an asyncpg connection, return its isolation level.

coroutine has_schema(connection, schema)[source]
coroutine has_sequence(connection, sequence_name, schema=None)[source]

Check the existence of a particular sequence in the database.

Given a Connection object and a string sequence_name, return True if the given sequence exists in the database, False otherwise.

coroutine has_table(connection, table_name, schema=None)[source]

Check the existence of a particular table in the database.

Given a Connection object and a string table_name, return True if the given table (possibly within the specified schema) exists in the database, False otherwise.

coroutine has_type(connection, type_name, schema=None)[source]
init_kwargs = {'command_timeout', 'connection_class', 'database', 'host', 'init', 'loop', 'max_cacheable_statement_size', 'max_cached_statement_lifetime', 'max_inactive_connection_lifetime', 'max_queries', 'max_size', 'min_size', 'passfile', 'password', 'port', 'server_settings', 'setup', 'ssl', 'statement_cache_size', 'timeout', 'user'}
coroutine init_pool(url, loop)[source]
on_connect()[source]

return a callable which sets up a newly created DBAPI connection.

This is used to set dialect-wide per-connection options such as isolation modes, unicode modes, etc.

If a callable is returned, it will be assembled into a pool listener that receives the direct DBAPI connection, with all wrappers removed.

If None is returned, no listener will be generated.

coroutine set_isolation_level(connection, level)[source]

Given an asyncpg connection, set its isolation level.

statement_compiler

alias of AsyncpgCompiler

supports_native_decimal = True
transaction(raw_conn, args, kwargs)[source]
class gino.dialects.asyncpg.AsyncpgExecutionContext[source]

Bases: gino.dialects.base.ExecutionContextOverride, sqlalchemy.dialects.postgresql.base.PGExecutionContext

class gino.dialects.asyncpg.AsyncpgIterator(context, iterator)[source]

Bases: object

class gino.dialects.asyncpg.DBAPICursor(dbapi_conn)[source]

Bases: gino.dialects.base.DBAPICursor

coroutine async_execute(query, timeout, args, limit=0, many=False)[source]
description
get_statusmsg()[source]
coroutine prepare(context, clause=None)[source]
class gino.dialects.asyncpg.Pool(url, loop, **kwargs)[source]

Bases: gino.dialects.base.Pool

coroutine acquire(*, timeout=None)[source]
coroutine close()[source]
raw_pool
coroutine release(conn)[source]
class gino.dialects.asyncpg.PreparedStatement(prepared, clause=None)[source]

Bases: gino.dialects.base.PreparedStatement

class gino.dialects.asyncpg.Transaction(tx)[source]

Bases: gino.dialects.base.Transaction

coroutine begin()[source]
coroutine commit()[source]
raw_transaction
coroutine rollback()[source]

gino.dialects.base module

class gino.dialects.base.AsyncDialectMixin[source]

Bases: object

compile(elem, *multiparams, **params)[source]
cursor_cls

alias of DBAPICursor

classmethod dbapi()[source]
dbapi_class

alias of BaseDBAPI

coroutine init_pool(url, loop)[source]
transaction(raw_conn, args, kwargs)[source]
class gino.dialects.base.BaseDBAPI[source]

Bases: object

static Binary(x)[source]
Error

alias of builtins.Exception

paramstyle = 'numeric'
class gino.dialects.base.Cursor[source]

Bases: object

coroutine forward(n, *, timeout=<object object>)[source]
coroutine many(n, *, timeout=<object object>)[source]
coroutine next(*, timeout=<object object>)[source]
class gino.dialects.base.DBAPICursor[source]

Bases: object

coroutine async_execute(query, timeout, args, limit=0, many=False)[source]
description
execute(statement, parameters)[source]
executemany(statement, parameters)[source]
get_statusmsg()[source]
coroutine prepare(context, clause=None)[source]
class gino.dialects.base.ExecutionContextOverride[source]

Bases: object

get_result_processor(type_, colname, coltype)[source]
get_result_proxy()[source]
loader
model
process_rows(rows, return_model=True)[source]
return_model
timeout
class gino.dialects.base.Pool[source]

Bases: object

coroutine acquire(*, timeout=None)[source]
coroutine close()[source]
raw_pool
coroutine release(conn)[source]
class gino.dialects.base.PreparedStatement(clause=None)[source]

Bases: object

coroutine all(*multiparams, **params)[source]
coroutine first(*multiparams, **params)[source]
iterate(*params, **kwargs)[source]
coroutine scalar(*multiparams, **params)[source]
coroutine status(*multiparams, **params)[source]
class gino.dialects.base.Transaction[source]

Bases: object

coroutine begin()[source]
coroutine commit()[source]
raw_transaction
coroutine rollback()[source]

Module contents