snowflake.core.schema.SchemaResource¶

class snowflake.core.schema.SchemaResource(name: str, collection: SchemaCollection)¶

Bases: DatabaseObjectReferenceMixin[SchemaCollection]

Represents a reference to a Snowflake schema.

With this schema reference, you can create, update, and fetch information about schemas, as well as perform certain unique actions on them.

Attributes

alerts¶

The AlertCollection of all alerts contained in this schema.

Examples

Getting all alerts in my_schema:

>>> my_db.schemas["my_schema"].alerts

Copy

cortex_search_services¶

The CortexSearchServiceCollection of all cortex services contained in this schema.

Examples

Getting all cortex search services in my_schema:

>>> my_db.schemas["my_schema"].cortex_search_service

Copy

database¶

The DatabaseResource this reference belongs to.

dynamic_tables¶

The DynamicTableCollection of all dynamic tables contained in this schema.

Examples

Getting all dynamic tables in my_schema:

>>> my_db.schemas["my_schema"].dynamic_tables

Copy

event_tables¶

The EventCollection of all events contained in this schema.

Examples

Getting all events in my_schema:

>>> my_db.schemas["my_schema"].events

Copy

functions¶

The FunctionCollection of all functions contained in this schema.

Examples

Getting all functions in my_schema:

>>> my_db.schemas["my_schema"].functions

Copy

iceberg_tables¶

The IcebergTableCollection of all dynamic tables contained in this schema.

Examples

Getting all Iceberg tables in my_schema:

>>> my_db.schemas["my_schema"].iceberg_tables

Copy

image_repositories¶

The ImageRepositoryCollection of all image repositories in this schema.

Examples

Getting all image repositories in my_schema:

>>> my_db.schemas["my_schema"].image_repositories

Copy

notebooks¶

The NotebookCollection of all notebooks contained in this schema.

Examples

Getting all notebooks in my_schema:

>>> my_db.schemas["my_schema"].notebooks

Copy

pipes¶

The PipesCollection of all pipes in this schema.

Examples

Getting all pipes in my_schema:

>>> my_db.schemas["my_schema"].pipes

Copy

procedures¶

Returns the ProcedureCollection that represents the visible procedures.

Examples

Getting a specific procedure resource:

>>> root = Root(session)
>>> procedure = root.databases["my_db"].schemas["my_schema"].procedures["my_procedure"]

Copy

qualified_name¶

Return the qualified name of the object this reference points to.

root¶

The Root object this reference belongs to.

services¶

The ServiceCollection of all services contained in this schema.

Examples

Getting all services in my_schema:

>>> my_db.schemas["my_schema"].services

Copy

stages¶

The StageCollection of all stages contained in this schema.

Examples

Getting all stages in my_schema:

>>> my_db.schemas["my_schema"].stages

Copy

streams¶

The StreamCollection of all streams contained in this schema.

Examples

Getting all streams in my_schema:

>>> my_db.schemas["my_schema"].streams

Copy

tables¶

The TableCollection of all tables contained in this schema.

Examples

Getting all tables in my_schema:

>>> my_db.schemas["my_schema"].tables

Copy

tasks¶

The TaskCollection of all tasks contained in this schema.

Examples

Getting all tasks in my_schema:

>>> my_db.schemas["my_schema"].tasks

Copy

user_defined_functions¶

The UserDefinedFunctionCollection of all user defined functions contained in this schema.

Examples

Get all user defined functions in my_schema:

>>> my_db.schemas["my_schema"].user_defined_functions

Copy

views¶

The ViewCollection of all views contained in this schema.

Examples

Getting all views in my_schema:

>>> my_db.schemas["my_schema"].views

Copy

Methods

create_or_alter(schema: SchemaModel) → SchemaResource¶

Create, or alter-in-place a schema in Snowflake.

Parameters:

schema (SchemaResource) – An instance of Schema, the definition of schema we should create.

Examples

Create a schema from a reference:

>>> my_db.schemas["my_new_schema"].create_or_alter(Schema("my_new_schema"))

Copy

create_or_alter_async(schema: SchemaModel) → PollingOperation[SchemaResource]¶

An asynchronous version of create_or_alter().

Refer to PollingOperation for more information on asynchronous execution and the return type.

create_or_update(schema: SchemaModel) → SchemaResource¶

The create_or_update() method is deprecated; use create_or_alter() instead.

Create, or update-in-place a schema in Snowflake.

schema: SchemaResource

An instance of Schema, the definition of schema we should create.

Create a schema from a reference:

>>> my_db.schemas["my_new_schema"].create_or_update(Schema("my_new_schema"))

Copy

delete(if_exists: bool | None = None) → None¶

The delete() method is deprecated; use drop() instead.

Delete this schema.

if_exists: bool, optional

Check the existence of this schema before dropping it. Default is None, which is equivalent to False.

Deleting a schema using its reference, erroring if it doesn’t exist:

>>> schema_reference.delete()

Copy

Deleting a schema using its reference, if it exists:

>>> schema_reference.delete(if_exists=True)

Copy

drop(if_exists: bool | None = None) → None¶

Drop this schema.

Parameters:

if_exists (bool, optional) – Check the existence of this schema before dropping it. Default is None, which is equivalent to False.

Examples

Dropping a schema using its reference, erroring if it doesn’t exist:

>>> schema_reference.drop()

Copy

Dropping a schema using its reference, if it exists:

>>> schema_reference.drop(if_exists=True)

Copy

drop_async(if_exists: bool | None = None) → PollingOperation[None]¶

An asynchronous version of drop().

Refer to PollingOperation for more information on asynchronous execution and the return type.

fetch() → SchemaModel¶

Fetch the details of a schema.

Examples

Fetching a reference to a schema to print its name and whether it’s our current one.

>>> my_schema = my_db.schemas["my_schema"].fetch()
>>> print(my_schema.name, my_schema.is_current)

Copy

fetch_async() → PollingOperation[SchemaModel]¶

An asynchronous version of fetch().

Refer to PollingOperation for more information on asynchronous execution and the return type.

undrop() → None¶

Undrop this previously dropped schema if it hasn’t been purged yet.

Examples

Undropping a schema using its reference:

>>> schema_reference.drop()
>>> schema_reference.undrop()

Copy

undrop_async() → PollingOperation[None]¶

An asynchronous version of undrop().

Refer to PollingOperation for more information on asynchronous execution and the return type.