SqlMISink Class

public final class SqlMISink
extends CopySink

A copy activity Azure SQL Managed Instance sink.

Constructor Summary

Constructor Description
SqlMISink()

Creates an instance of SqlMISink class.

Method Summary

Modifier and Type Method and Description
static SqlMISink fromJson(JsonReader jsonReader)

Reads an instance of SqlMISink from the JsonReader.

Object preCopyScript()

Get the preCopyScript property: SQL pre-copy script.

Object sqlWriterStoredProcedureName()

Get the sqlWriterStoredProcedureName property: SQL writer stored procedure name.

Object sqlWriterTableType()

Get the sqlWriterTableType property: SQL writer table type.

Object sqlWriterUseTableLock()

Get the sqlWriterUseTableLock property: Whether to use table lock during bulk copy.

Object storedProcedureParameters()

Get the storedProcedureParameters property: SQL stored procedure parameters.

Object storedProcedureTableTypeParameterName()

Get the storedProcedureTableTypeParameterName property: The stored procedure parameter name of the table type.

Object tableOption()

Get the tableOption property: The option to handle sink table, such as autoCreate.

JsonWriter toJson(JsonWriter jsonWriter)
String type()

Get the type property: Copy sink type.

SqlUpsertSettings upsertSettings()

Get the upsertSettings property: SQL upsert settings.

void validate()

Validates the instance.

SqlMISink withDisableMetricsCollection(Object disableMetricsCollection)

Set the disableMetricsCollection property: If true, disable data store metrics collection.

SqlMISink withMaxConcurrentConnections(Object maxConcurrentConnections)

Set the maxConcurrentConnections property: The maximum concurrent connection count for the sink data store.

SqlMISink withPreCopyScript(Object preCopyScript)

Set the preCopyScript property: SQL pre-copy script.

SqlMISink withSinkRetryCount(Object sinkRetryCount)

Set the sinkRetryCount property: Sink retry count.

SqlMISink withSinkRetryWait(Object sinkRetryWait)

Set the sinkRetryWait property: Sink retry wait.

SqlMISink withSqlWriterStoredProcedureName(Object sqlWriterStoredProcedureName)

Set the sqlWriterStoredProcedureName property: SQL writer stored procedure name.

SqlMISink withSqlWriterTableType(Object sqlWriterTableType)

Set the sqlWriterTableType property: SQL writer table type.

SqlMISink withSqlWriterUseTableLock(Object sqlWriterUseTableLock)

Set the sqlWriterUseTableLock property: Whether to use table lock during bulk copy.

SqlMISink withStoredProcedureParameters(Object storedProcedureParameters)

Set the storedProcedureParameters property: SQL stored procedure parameters.

SqlMISink withStoredProcedureTableTypeParameterName(Object storedProcedureTableTypeParameterName)

Set the storedProcedureTableTypeParameterName property: The stored procedure parameter name of the table type.

SqlMISink withTableOption(Object tableOption)

Set the tableOption property: The option to handle sink table, such as autoCreate.

SqlMISink withUpsertSettings(SqlUpsertSettings upsertSettings)

Set the upsertSettings property: SQL upsert settings.

SqlMISink withWriteBatchSize(Object writeBatchSize)

Set the writeBatchSize property: Write batch size.

SqlMISink withWriteBatchTimeout(Object writeBatchTimeout)

Set the writeBatchTimeout property: Write batch timeout.

SqlMISink withWriteBehavior(Object writeBehavior)

Set the writeBehavior property: White behavior when copying data into azure SQL MI.

Object writeBehavior()

Get the writeBehavior property: White behavior when copying data into azure SQL MI.

Methods inherited from CopySink

Methods inherited from java.lang.Object

Constructor Details

SqlMISink

public SqlMISink()

Creates an instance of SqlMISink class.

Method Details

fromJson

public static SqlMISink fromJson(JsonReader jsonReader)

Reads an instance of SqlMISink from the JsonReader.

Parameters:

jsonReader - The JsonReader being read.

Returns:

An instance of SqlMISink if the JsonReader was pointing to an instance of it, or null if it was pointing to JSON null.

Throws:

IOException

- If an error occurs while reading the SqlMISink.

preCopyScript

public Object preCopyScript()

Get the preCopyScript property: SQL pre-copy script. Type: string (or Expression with resultType string).

Returns:

the preCopyScript value.

sqlWriterStoredProcedureName

public Object sqlWriterStoredProcedureName()

Get the sqlWriterStoredProcedureName property: SQL writer stored procedure name. Type: string (or Expression with resultType string).

Returns:

the sqlWriterStoredProcedureName value.

sqlWriterTableType

public Object sqlWriterTableType()

Get the sqlWriterTableType property: SQL writer table type. Type: string (or Expression with resultType string).

Returns:

the sqlWriterTableType value.

sqlWriterUseTableLock

public Object sqlWriterUseTableLock()

Get the sqlWriterUseTableLock property: Whether to use table lock during bulk copy. Type: boolean (or Expression with resultType boolean).

Returns:

the sqlWriterUseTableLock value.

storedProcedureParameters

public Object storedProcedureParameters()

Get the storedProcedureParameters property: SQL stored procedure parameters.

Returns:

the storedProcedureParameters value.

storedProcedureTableTypeParameterName

public Object storedProcedureTableTypeParameterName()

Get the storedProcedureTableTypeParameterName property: The stored procedure parameter name of the table type. Type: string (or Expression with resultType string).

Returns:

the storedProcedureTableTypeParameterName value.

tableOption

public Object tableOption()

Get the tableOption property: The option to handle sink table, such as autoCreate. For now only 'autoCreate' value is supported. Type: string (or Expression with resultType string).

Returns:

the tableOption value.

toJson

public JsonWriter toJson(JsonWriter jsonWriter)

Overrides:

SqlMISink.toJson(JsonWriter jsonWriter)

Parameters:

jsonWriter

Throws:

type

public String type()

Get the type property: Copy sink type.

Overrides:

SqlMISink.type()

Returns:

the type value.

upsertSettings

public SqlUpsertSettings upsertSettings()

Get the upsertSettings property: SQL upsert settings.

Returns:

the upsertSettings value.

validate

public void validate()

Validates the instance.

Overrides:

SqlMISink.validate()

withDisableMetricsCollection

public SqlMISink withDisableMetricsCollection(Object disableMetricsCollection)

Set the disableMetricsCollection property: If true, disable data store metrics collection. Default is false. Type: boolean (or Expression with resultType boolean).

Overrides:

SqlMISink.withDisableMetricsCollection(Object disableMetricsCollection)

Parameters:

disableMetricsCollection

withMaxConcurrentConnections

public SqlMISink withMaxConcurrentConnections(Object maxConcurrentConnections)

Set the maxConcurrentConnections property: The maximum concurrent connection count for the sink data store. Type: integer (or Expression with resultType integer).

Overrides:

SqlMISink.withMaxConcurrentConnections(Object maxConcurrentConnections)

Parameters:

maxConcurrentConnections

withPreCopyScript

public SqlMISink withPreCopyScript(Object preCopyScript)

Set the preCopyScript property: SQL pre-copy script. Type: string (or Expression with resultType string).

Parameters:

preCopyScript - the preCopyScript value to set.

Returns:

the SqlMISink object itself.

withSinkRetryCount

public SqlMISink withSinkRetryCount(Object sinkRetryCount)

Set the sinkRetryCount property: Sink retry count. Type: integer (or Expression with resultType integer).

Overrides:

SqlMISink.withSinkRetryCount(Object sinkRetryCount)

Parameters:

sinkRetryCount

withSinkRetryWait

public SqlMISink withSinkRetryWait(Object sinkRetryWait)

Set the sinkRetryWait property: Sink retry wait. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).

Overrides:

SqlMISink.withSinkRetryWait(Object sinkRetryWait)

Parameters:

sinkRetryWait

withSqlWriterStoredProcedureName

public SqlMISink withSqlWriterStoredProcedureName(Object sqlWriterStoredProcedureName)

Set the sqlWriterStoredProcedureName property: SQL writer stored procedure name. Type: string (or Expression with resultType string).

Parameters:

sqlWriterStoredProcedureName - the sqlWriterStoredProcedureName value to set.

Returns:

the SqlMISink object itself.

withSqlWriterTableType

public SqlMISink withSqlWriterTableType(Object sqlWriterTableType)

Set the sqlWriterTableType property: SQL writer table type. Type: string (or Expression with resultType string).

Parameters:

sqlWriterTableType - the sqlWriterTableType value to set.

Returns:

the SqlMISink object itself.

withSqlWriterUseTableLock

public SqlMISink withSqlWriterUseTableLock(Object sqlWriterUseTableLock)

Set the sqlWriterUseTableLock property: Whether to use table lock during bulk copy. Type: boolean (or Expression with resultType boolean).

Parameters:

sqlWriterUseTableLock - the sqlWriterUseTableLock value to set.

Returns:

the SqlMISink object itself.

withStoredProcedureParameters

public SqlMISink withStoredProcedureParameters(Object storedProcedureParameters)

Set the storedProcedureParameters property: SQL stored procedure parameters.

Parameters:

storedProcedureParameters - the storedProcedureParameters value to set.

Returns:

the SqlMISink object itself.

withStoredProcedureTableTypeParameterName

public SqlMISink withStoredProcedureTableTypeParameterName(Object storedProcedureTableTypeParameterName)

Set the storedProcedureTableTypeParameterName property: The stored procedure parameter name of the table type. Type: string (or Expression with resultType string).

Parameters:

storedProcedureTableTypeParameterName - the storedProcedureTableTypeParameterName value to set.

Returns:

the SqlMISink object itself.

withTableOption

public SqlMISink withTableOption(Object tableOption)

Set the tableOption property: The option to handle sink table, such as autoCreate. For now only 'autoCreate' value is supported. Type: string (or Expression with resultType string).

Parameters:

tableOption - the tableOption value to set.

Returns:

the SqlMISink object itself.

withUpsertSettings

public SqlMISink withUpsertSettings(SqlUpsertSettings upsertSettings)

Set the upsertSettings property: SQL upsert settings.

Parameters:

upsertSettings - the upsertSettings value to set.

Returns:

the SqlMISink object itself.

withWriteBatchSize

public SqlMISink withWriteBatchSize(Object writeBatchSize)

Set the writeBatchSize property: Write batch size. Type: integer (or Expression with resultType integer), minimum: 0.

Overrides:

SqlMISink.withWriteBatchSize(Object writeBatchSize)

Parameters:

writeBatchSize

withWriteBatchTimeout

public SqlMISink withWriteBatchTimeout(Object writeBatchTimeout)

Set the writeBatchTimeout property: Write batch timeout. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).

Overrides:

SqlMISink.withWriteBatchTimeout(Object writeBatchTimeout)

Parameters:

writeBatchTimeout

withWriteBehavior

public SqlMISink withWriteBehavior(Object writeBehavior)

Set the writeBehavior property: White behavior when copying data into azure SQL MI. Type: string (or Expression with resultType string).

Parameters:

writeBehavior - the writeBehavior value to set.

Returns:

the SqlMISink object itself.

writeBehavior

public Object writeBehavior()

Get the writeBehavior property: White behavior when copying data into azure SQL MI. Type: string (or Expression with resultType string).

Returns:

the writeBehavior value.

Applies to