class SQLAzureFederationsSynchronizer extends AbstractSchemaSynchronizer (View source)

SQL Azure Schema Synchronizer.

Will iterate over all shards when performing schema operations. This is done by partitioning the passed schema into subschemas for the federation and the global database and then applying the operations step by step using the {see \Doctrine\DBAL\Schema\Synchronizer\SingleDatabaseSynchronizer}.

Constants

FEDERATION_TABLE_FEDERATED

FEDERATION_DISTRIBUTION_NAME

Properties

protected Connection $conn from AbstractSchemaSynchronizer

Methods

__construct(Connection $conn, SQLAzureShardManager $shardManager, SchemaSynchronizer|null $sync = null)

No description

processSqlSafely(array $sql)

No description

processSql(array $sql)

No description

string[]
getCreateSchema(Schema $createSchema)

Gets the SQL statements that can be executed to create the schema.

string[]
getUpdateSchema(Schema $toSchema, $noDrops = false)

Gets the SQL Statements to update given schema with the underlying db.

string[]
getDropSchema(Schema $dropSchema)

Gets the SQL Statements to drop the given schema from underlying db.

void
createSchema(Schema $createSchema)

Creates the Schema.

void
updateSchema(Schema $toSchema, $noDrops = false)

Updates the Schema to new schema version.

void
dropSchema(Schema $dropSchema)

Drops the given database schema from the underlying db.

string[]
getDropAllSchema()

Gets the SQL statements to drop all schema assets from underlying db.

void
dropAllSchema()

Drops all assets from the underlying db.

Details

__construct(Connection $conn, SQLAzureShardManager $shardManager, SchemaSynchronizer|null $sync = null)

Parameters

Connection $conn
SQLAzureShardManager $shardManager
SchemaSynchronizer|null $sync

protected processSqlSafely(array $sql)

Parameters

array $sql

protected processSql(array $sql)

Parameters

array $sql

string[] getCreateSchema(Schema $createSchema)

Gets the SQL statements that can be executed to create the schema.

Parameters

Schema $createSchema

Return Value

string[]

string[] getUpdateSchema(Schema $toSchema, $noDrops = false)

Gets the SQL Statements to update given schema with the underlying db.

Parameters

Schema $toSchema
$noDrops

Return Value

string[]

string[] getDropSchema(Schema $dropSchema)

Gets the SQL Statements to drop the given schema from underlying db.

Parameters

Schema $dropSchema

Return Value

string[]

void createSchema(Schema $createSchema)

Creates the Schema.

Parameters

Schema $createSchema

Return Value

void

void updateSchema(Schema $toSchema, $noDrops = false)

Updates the Schema to new schema version.

Parameters

Schema $toSchema
$noDrops

Return Value

void

void dropSchema(Schema $dropSchema)

Drops the given database schema from the underlying db.

Parameters

Schema $dropSchema

Return Value

void

string[] getDropAllSchema()

Gets the SQL statements to drop all schema assets from underlying db.

Return Value

string[]

void dropAllSchema()

Drops all assets from the underlying db.

Return Value

void