diff --git a/sdk/datafactory/azure-mgmt-datafactory/_meta.json b/sdk/datafactory/azure-mgmt-datafactory/_meta.json index bf776bd01373..90722e0096dc 100644 --- a/sdk/datafactory/azure-mgmt-datafactory/_meta.json +++ b/sdk/datafactory/azure-mgmt-datafactory/_meta.json @@ -1,11 +1,11 @@ { - "commit": "f06cffbda682a8cd225a8b16bc6f000d26d01612", + "commit": "95912092f5f05e0ce2933537fb2eaa5b4270eeae", "repository_url": "https://github.com/Azure/azure-rest-api-specs", "autorest": "3.10.2", "use": [ - "@autorest/python@6.26.4", + "@autorest/python@6.27.4", "@autorest/modelerfour@4.27.0" ], - "autorest_command": "autorest specification/datafactory/resource-manager/readme.md --generate-sample=True --generate-test=True --include-x-ms-examples-original-file=True --python --python-sdks-folder=/mnt/vss/_work/1/azure-sdk-for-python/sdk --use=@autorest/python@6.26.4 --use=@autorest/modelerfour@4.27.0 --version=3.10.2 --version-tolerant=False", + "autorest_command": "autorest specification/datafactory/resource-manager/readme.md --generate-sample=True --generate-test=True --include-x-ms-examples-original-file=True --python --python-sdks-folder=/mnt/vss/_work/1/s/azure-sdk-for-python/sdk --use=@autorest/python@6.27.4 --use=@autorest/modelerfour@4.27.0 --version=3.10.2 --version-tolerant=False", "readme": "specification/datafactory/resource-manager/readme.md" } \ No newline at end of file diff --git a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/_serialization.py b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/_serialization.py index ce17d1798ce7..b24ab2885450 100644 --- a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/_serialization.py +++ b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/_serialization.py @@ -310,7 +310,7 @@ def _create_xml_node(tag, prefix=None, ns=None): return ET.Element(tag) -class Model(object): +class Model: """Mixin for all client request body/response body models to support serialization and deserialization. """ @@ -563,7 +563,7 @@ def _decode_attribute_map_key(key): return key.replace("\\.", ".") -class Serializer(object): # pylint: disable=too-many-public-methods +class Serializer: # pylint: disable=too-many-public-methods """Request object model serializer.""" basic_types = {str: "str", int: "int", bool: "bool", float: "float"} @@ -1441,7 +1441,7 @@ def xml_key_extractor(attr, attr_desc, data): # pylint: disable=unused-argument return children[0] -class Deserializer(object): +class Deserializer: """Response object model deserializer. :param dict classes: Class type dictionary for deserializing complex types. @@ -1683,17 +1683,21 @@ def _instantiate_model(self, response, attrs, additional_properties=None): subtype = getattr(response, "_subtype_map", {}) try: readonly = [ - k for k, v in response._validation.items() if v.get("readonly") # pylint: disable=protected-access + k + for k, v in response._validation.items() # pylint: disable=protected-access # type: ignore + if v.get("readonly") ] const = [ - k for k, v in response._validation.items() if v.get("constant") # pylint: disable=protected-access + k + for k, v in response._validation.items() # pylint: disable=protected-access # type: ignore + if v.get("constant") ] kwargs = {k: v for k, v in attrs.items() if k not in subtype and k not in readonly + const} response_obj = response(**kwargs) for attr in readonly: setattr(response_obj, attr, attrs.get(attr)) if additional_properties: - response_obj.additional_properties = additional_properties + response_obj.additional_properties = additional_properties # type: ignore return response_obj except TypeError as err: msg = "Unable to deserialize {} into model {}. ".format(kwargs, response) # type: ignore diff --git a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/_version.py b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/_version.py index f89ed38360ab..c47f66669f1b 100644 --- a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/_version.py +++ b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/_version.py @@ -6,4 +6,4 @@ # Changes may cause incorrect behavior and will be lost if the code is regenerated. # -------------------------------------------------------------------------- -VERSION = "9.1.0" +VERSION = "1.0.0" diff --git a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/__init__.py b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/__init__.py index ee44f781e28c..f60fdec7deaf 100644 --- a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/__init__.py +++ b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/__init__.py @@ -877,6 +877,7 @@ NotebookReferenceType, ODataAadServicePrincipalCredentialType, ODataAuthenticationType, + OracleAuthenticationType, OraclePartitionOption, OrcCompressionCodec, ParameterType, @@ -1801,6 +1802,7 @@ "NotebookReferenceType", "ODataAadServicePrincipalCredentialType", "ODataAuthenticationType", + "OracleAuthenticationType", "OraclePartitionOption", "OrcCompressionCodec", "ParameterType", diff --git a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_data_factory_management_client_enums.py b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_data_factory_management_client_enums.py index ac24170e4c2a..53651e419e6e 100644 --- a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_data_factory_management_client_enums.py +++ b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_data_factory_management_client_enums.py @@ -620,6 +620,12 @@ class ODataAuthenticationType(str, Enum, metaclass=CaseInsensitiveEnumMeta): MANAGED_SERVICE_IDENTITY = "ManagedServiceIdentity" +class OracleAuthenticationType(str, Enum, metaclass=CaseInsensitiveEnumMeta): + """Authentication type for connecting to the Oracle database. Only used for Version 2.0.""" + + BASIC = "Basic" + + class OraclePartitionOption(str, Enum, metaclass=CaseInsensitiveEnumMeta): """The partition mechanism that will be used for Oracle read in parallel.""" diff --git a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_models_py3.py b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_models_py3.py index c93dd92dc173..d9b8d65c81d5 100644 --- a/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_models_py3.py +++ b/sdk/datafactory/azure-mgmt-datafactory/azure/mgmt/datafactory/models/_models_py3.py @@ -5587,9 +5587,9 @@ class AvroWriteSettings(FormatWriteSettings): :ivar max_rows_per_file: Limit the written file's row count to be smaller than or equal to the specified count. Type: integer (or Expression with resultType integer). :vartype max_rows_per_file: JSON - :ivar file_name_prefix: Specifies the file name pattern - :code:``_:code:``.:code:`` when copy from non-file - based store without partitionOptions. Type: string (or Expression with resultType string). + :ivar file_name_prefix: Specifies the file name pattern :code:``_\\ + :code:``.\\ :code:`` when copy from non-file based store without + partitionOptions. Type: string (or Expression with resultType string). :vartype file_name_prefix: JSON """ @@ -5627,9 +5627,9 @@ def __init__( :keyword max_rows_per_file: Limit the written file's row count to be smaller than or equal to the specified count. Type: integer (or Expression with resultType integer). :paramtype max_rows_per_file: JSON - :keyword file_name_prefix: Specifies the file name pattern - :code:``_:code:``.:code:`` when copy from non-file - based store without partitionOptions. Type: string (or Expression with resultType string). + :keyword file_name_prefix: Specifies the file name pattern :code:``_\\ + :code:``.\\ :code:`` when copy from non-file based store without + partitionOptions. Type: string (or Expression with resultType string). :paramtype file_name_prefix: JSON """ super().__init__(additional_properties=additional_properties, **kwargs) @@ -8575,8 +8575,8 @@ class AzureDataExplorerLinkedService(LinkedService): :ivar annotations: List of tags that can be used for describing the linked service. :vartype annotations: list[JSON] :ivar endpoint: The endpoint of Azure Data Explorer (the engine's endpoint). URL will be in the - format https://:code:``.:code:``.kusto.windows.net. Type: string (or - Expression with resultType string). Required. + format https://\\ :code:``.\\ :code:``.kusto.windows.net. Type: string + (or Expression with resultType string). Required. :vartype endpoint: JSON :ivar service_principal_id: The ID of the service principal used to authenticate against Azure Data Explorer. Type: string (or Expression with resultType string). @@ -8648,8 +8648,8 @@ def __init__( :keyword annotations: List of tags that can be used for describing the linked service. :paramtype annotations: list[JSON] :keyword endpoint: The endpoint of Azure Data Explorer (the engine's endpoint). URL will be in - the format https://:code:``.:code:``.kusto.windows.net. Type: string - (or Expression with resultType string). Required. + the format https://\\ :code:``.\\ :code:``.kusto.windows.net. Type: + string (or Expression with resultType string). Required. :paramtype endpoint: JSON :keyword service_principal_id: The ID of the service principal used to authenticate against Azure Data Explorer. Type: string (or Expression with resultType string). @@ -10566,7 +10566,7 @@ class AzureFunctionLinkedService(LinkedService): :ivar annotations: List of tags that can be used for describing the linked service. :vartype annotations: list[JSON] :ivar function_app_url: The endpoint of the Azure Function App. URL will be in the format - https://:code:``.azurewebsites.net. Type: string (or Expression with resultType + https://\\ :code:``.azurewebsites.net. Type: string (or Expression with resultType string). Required. :vartype function_app_url: JSON :ivar function_key: Function or Host key for Azure Function App. @@ -10637,7 +10637,7 @@ def __init__( :keyword annotations: List of tags that can be used for describing the linked service. :paramtype annotations: list[JSON] :keyword function_app_url: The endpoint of the Azure Function App. URL will be in the format - https://:code:``.azurewebsites.net. Type: string (or Expression with resultType + https://\\ :code:``.azurewebsites.net. Type: string (or Expression with resultType string). Required. :paramtype function_app_url: JSON :keyword function_key: Function or Host key for Azure Function App. @@ -16485,8 +16485,8 @@ class AzureSynapseArtifactsLinkedService(LinkedService): :vartype parameters: dict[str, ~azure.mgmt.datafactory.models.ParameterSpecification] :ivar annotations: List of tags that can be used for describing the linked service. :vartype annotations: list[JSON] - :ivar endpoint: https://:code:``.dev.azuresynapse.net, Azure Synapse Analytics - workspace URL. Type: string (or Expression with resultType string). Required. + :ivar endpoint: https://\\ :code:``.dev.azuresynapse.net, Azure Synapse + Analytics workspace URL. Type: string (or Expression with resultType string). Required. :vartype endpoint: JSON :ivar authentication: Required to specify MSI, if using system assigned managed identity as authentication method. Type: string (or Expression with resultType string). @@ -16543,7 +16543,7 @@ def __init__( :paramtype parameters: dict[str, ~azure.mgmt.datafactory.models.ParameterSpecification] :keyword annotations: List of tags that can be used for describing the linked service. :paramtype annotations: list[JSON] - :keyword endpoint: https://:code:``.dev.azuresynapse.net, Azure Synapse + :keyword endpoint: https://\\ :code:``.dev.azuresynapse.net, Azure Synapse Analytics workspace URL. Type: string (or Expression with resultType string). Required. :paramtype endpoint: JSON :keyword authentication: Required to specify MSI, if using system assigned managed identity as @@ -25271,9 +25271,9 @@ class DelimitedTextWriteSettings(FormatWriteSettings): :ivar max_rows_per_file: Limit the written file's row count to be smaller than or equal to the specified count. Type: integer (or Expression with resultType integer). :vartype max_rows_per_file: JSON - :ivar file_name_prefix: Specifies the file name pattern - :code:``_:code:``.:code:`` when copy from non-file - based store without partitionOptions. Type: string (or Expression with resultType string). + :ivar file_name_prefix: Specifies the file name pattern :code:``_\\ + :code:``.\\ :code:`` when copy from non-file based store without + partitionOptions. Type: string (or Expression with resultType string). :vartype file_name_prefix: JSON """ @@ -25314,9 +25314,9 @@ def __init__( :keyword max_rows_per_file: Limit the written file's row count to be smaller than or equal to the specified count. Type: integer (or Expression with resultType integer). :paramtype max_rows_per_file: JSON - :keyword file_name_prefix: Specifies the file name pattern - :code:``_:code:``.:code:`` when copy from non-file - based store without partitionOptions. Type: string (or Expression with resultType string). + :keyword file_name_prefix: Specifies the file name pattern :code:``_\\ + :code:``.\\ :code:`` when copy from non-file based store without + partitionOptions. Type: string (or Expression with resultType string). :paramtype file_name_prefix: JSON """ super().__init__(additional_properties=additional_properties, **kwargs) @@ -48870,7 +48870,9 @@ def __init__( class OracleLinkedService(LinkedService): - """Oracle database. + """Oracle database. This linked service has supported version property. The Version 1.0 is + scheduled for deprecation while your pipeline will continue to run after EOL but without any + bug fix or new features. All required parameters must be populated in order to send to server. @@ -48890,10 +48892,59 @@ class OracleLinkedService(LinkedService): :ivar annotations: List of tags that can be used for describing the linked service. :vartype annotations: list[JSON] :ivar connection_string: The connection string. Type: string, SecureString or - AzureKeyVaultSecretReference. Required. + AzureKeyVaultSecretReference. Only used for Version 1.0. Required. :vartype connection_string: JSON + :ivar server: The location of Oracle database you want to connect to, the supported forms + include connector descriptor, Easy Connect (Plus) Naming and Oracle Net Services Name (Only + self-hosted IR). Type: string. Only used for Version 2.0. + :vartype server: JSON + :ivar authentication_type: Authentication type for connecting to the Oracle database. Only used + for Version 2.0. "Basic" + :vartype authentication_type: str or ~azure.mgmt.datafactory.models.OracleAuthenticationType + :ivar username: The Oracle database username. Type: string. Only used for Version 2.0. + :vartype username: JSON :ivar password: The Azure key vault secret reference of password in connection string. :vartype password: ~azure.mgmt.datafactory.models.AzureKeyVaultSecretReference + :ivar encryption_client: Specifies the encryption client behavior. Supported values are + accepted, rejected, requested or required, default value is required. Type: string. Only used + for Version 2.0. + :vartype encryption_client: JSON + :ivar encryption_types_client: Specifies the encryption algorithms that client can use. + Supported values are AES128, AES192, AES256, 3DES112, 3DES168, default value is (AES256). Type: + string. Only used for Version 2.0. + :vartype encryption_types_client: JSON + :ivar crypto_checksum_client: Specifies the desired data integrity behavior when this client + connects to a server. Supported values are accepted, rejected, requested or required, default + value is required. Type: string. Only used for Version 2.0. + :vartype crypto_checksum_client: JSON + :ivar crypto_checksum_types_client: Specifies the crypto-checksum algorithms that client can + use. Supported values are SHA1, SHA256, SHA384, SHA512, default value is (SHA512). Type: + string. Only used for Version 2.0. + :vartype crypto_checksum_types_client: JSON + :ivar initial_lob_fetch_size: Specifies the amount that the source initially fetches for LOB + columns, default value is 0. Type: integer. Only used for Version 2.0. + :vartype initial_lob_fetch_size: JSON + :ivar fetch_size: Specifies the number of bytes that the driver allocates to fetch the data in + one database round-trip, default value is 10485760. Type: integer. Only used for Version 2.0. + :vartype fetch_size: JSON + :ivar statement_cache_size: Specifies the number of cursors or statements to be cached for each + database connection, default value is 0. Type: integer. Only used for Version 2.0. + :vartype statement_cache_size: JSON + :ivar initialization_string: Specifies a command that is issued immediately after connecting to + the database to manage session settings. Type: string. Only used for Version 2.0. + :vartype initialization_string: JSON + :ivar enable_bulk_load: Specifies whether to use bulk copy or batch insert when loading data + into the database, default value is true. Type: boolean. Only used for Version 2.0. + :vartype enable_bulk_load: JSON + :ivar support_v1_data_types: Specifies whether to use the Version 1.0 data type mappings. Do + not set this to true unless you want to keep backward compatibility with Version 1.0's data + type mappings, default value is false. Type: boolean. Only used for Version 2.0. + :vartype support_v1_data_types: JSON + :ivar fetch_tswtz_as_timestamp: Specifies whether the driver returns column value with the + TIMESTAMP WITH TIME ZONE data type as DateTime or string. This setting is ignored if + supportV1DataTypes is not true, default value is true. Type: boolean. Only used for Version + 2.0. + :vartype fetch_tswtz_as_timestamp: JSON :ivar encrypted_credential: The encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string. :vartype encrypted_credential: str @@ -48913,11 +48964,25 @@ class OracleLinkedService(LinkedService): "parameters": {"key": "parameters", "type": "{ParameterSpecification}"}, "annotations": {"key": "annotations", "type": "[object]"}, "connection_string": {"key": "typeProperties.connectionString", "type": "object"}, + "server": {"key": "typeProperties.server", "type": "object"}, + "authentication_type": {"key": "typeProperties.authenticationType", "type": "str"}, + "username": {"key": "typeProperties.username", "type": "object"}, "password": {"key": "typeProperties.password", "type": "AzureKeyVaultSecretReference"}, + "encryption_client": {"key": "typeProperties.encryptionClient", "type": "object"}, + "encryption_types_client": {"key": "typeProperties.encryptionTypesClient", "type": "object"}, + "crypto_checksum_client": {"key": "typeProperties.cryptoChecksumClient", "type": "object"}, + "crypto_checksum_types_client": {"key": "typeProperties.cryptoChecksumTypesClient", "type": "object"}, + "initial_lob_fetch_size": {"key": "typeProperties.initialLobFetchSize", "type": "object"}, + "fetch_size": {"key": "typeProperties.fetchSize", "type": "object"}, + "statement_cache_size": {"key": "typeProperties.statementCacheSize", "type": "object"}, + "initialization_string": {"key": "typeProperties.initializationString", "type": "object"}, + "enable_bulk_load": {"key": "typeProperties.enableBulkLoad", "type": "object"}, + "support_v1_data_types": {"key": "typeProperties.supportV1DataTypes", "type": "object"}, + "fetch_tswtz_as_timestamp": {"key": "typeProperties.fetchTswtzAsTimestamp", "type": "object"}, "encrypted_credential": {"key": "typeProperties.encryptedCredential", "type": "str"}, } - def __init__( + def __init__( # pylint: disable=too-many-locals self, *, connection_string: JSON, @@ -48927,7 +48992,21 @@ def __init__( description: Optional[str] = None, parameters: Optional[Dict[str, "_models.ParameterSpecification"]] = None, annotations: Optional[List[JSON]] = None, + server: Optional[JSON] = None, + authentication_type: Optional[Union[str, "_models.OracleAuthenticationType"]] = None, + username: Optional[JSON] = None, password: Optional["_models.AzureKeyVaultSecretReference"] = None, + encryption_client: Optional[JSON] = None, + encryption_types_client: Optional[JSON] = None, + crypto_checksum_client: Optional[JSON] = None, + crypto_checksum_types_client: Optional[JSON] = None, + initial_lob_fetch_size: Optional[JSON] = None, + fetch_size: Optional[JSON] = None, + statement_cache_size: Optional[JSON] = None, + initialization_string: Optional[JSON] = None, + enable_bulk_load: Optional[JSON] = None, + support_v1_data_types: Optional[JSON] = None, + fetch_tswtz_as_timestamp: Optional[JSON] = None, encrypted_credential: Optional[str] = None, **kwargs: Any ) -> None: @@ -48946,10 +49025,60 @@ def __init__( :keyword annotations: List of tags that can be used for describing the linked service. :paramtype annotations: list[JSON] :keyword connection_string: The connection string. Type: string, SecureString or - AzureKeyVaultSecretReference. Required. + AzureKeyVaultSecretReference. Only used for Version 1.0. Required. :paramtype connection_string: JSON + :keyword server: The location of Oracle database you want to connect to, the supported forms + include connector descriptor, Easy Connect (Plus) Naming and Oracle Net Services Name (Only + self-hosted IR). Type: string. Only used for Version 2.0. + :paramtype server: JSON + :keyword authentication_type: Authentication type for connecting to the Oracle database. Only + used for Version 2.0. "Basic" + :paramtype authentication_type: str or ~azure.mgmt.datafactory.models.OracleAuthenticationType + :keyword username: The Oracle database username. Type: string. Only used for Version 2.0. + :paramtype username: JSON :keyword password: The Azure key vault secret reference of password in connection string. :paramtype password: ~azure.mgmt.datafactory.models.AzureKeyVaultSecretReference + :keyword encryption_client: Specifies the encryption client behavior. Supported values are + accepted, rejected, requested or required, default value is required. Type: string. Only used + for Version 2.0. + :paramtype encryption_client: JSON + :keyword encryption_types_client: Specifies the encryption algorithms that client can use. + Supported values are AES128, AES192, AES256, 3DES112, 3DES168, default value is (AES256). Type: + string. Only used for Version 2.0. + :paramtype encryption_types_client: JSON + :keyword crypto_checksum_client: Specifies the desired data integrity behavior when this client + connects to a server. Supported values are accepted, rejected, requested or required, default + value is required. Type: string. Only used for Version 2.0. + :paramtype crypto_checksum_client: JSON + :keyword crypto_checksum_types_client: Specifies the crypto-checksum algorithms that client can + use. Supported values are SHA1, SHA256, SHA384, SHA512, default value is (SHA512). Type: + string. Only used for Version 2.0. + :paramtype crypto_checksum_types_client: JSON + :keyword initial_lob_fetch_size: Specifies the amount that the source initially fetches for LOB + columns, default value is 0. Type: integer. Only used for Version 2.0. + :paramtype initial_lob_fetch_size: JSON + :keyword fetch_size: Specifies the number of bytes that the driver allocates to fetch the data + in one database round-trip, default value is 10485760. Type: integer. Only used for Version + 2.0. + :paramtype fetch_size: JSON + :keyword statement_cache_size: Specifies the number of cursors or statements to be cached for + each database connection, default value is 0. Type: integer. Only used for Version 2.0. + :paramtype statement_cache_size: JSON + :keyword initialization_string: Specifies a command that is issued immediately after connecting + to the database to manage session settings. Type: string. Only used for Version 2.0. + :paramtype initialization_string: JSON + :keyword enable_bulk_load: Specifies whether to use bulk copy or batch insert when loading data + into the database, default value is true. Type: boolean. Only used for Version 2.0. + :paramtype enable_bulk_load: JSON + :keyword support_v1_data_types: Specifies whether to use the Version 1.0 data type mappings. Do + not set this to true unless you want to keep backward compatibility with Version 1.0's data + type mappings, default value is false. Type: boolean. Only used for Version 2.0. + :paramtype support_v1_data_types: JSON + :keyword fetch_tswtz_as_timestamp: Specifies whether the driver returns column value with the + TIMESTAMP WITH TIME ZONE data type as DateTime or string. This setting is ignored if + supportV1DataTypes is not true, default value is true. Type: boolean. Only used for Version + 2.0. + :paramtype fetch_tswtz_as_timestamp: JSON :keyword encrypted_credential: The encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string. :paramtype encrypted_credential: str @@ -48965,7 +49094,21 @@ def __init__( ) self.type: str = "Oracle" self.connection_string = connection_string + self.server = server + self.authentication_type = authentication_type + self.username = username self.password = password + self.encryption_client = encryption_client + self.encryption_types_client = encryption_types_client + self.crypto_checksum_client = crypto_checksum_client + self.crypto_checksum_types_client = crypto_checksum_types_client + self.initial_lob_fetch_size = initial_lob_fetch_size + self.fetch_size = fetch_size + self.statement_cache_size = statement_cache_size + self.initialization_string = initialization_string + self.enable_bulk_load = enable_bulk_load + self.support_v1_data_types = support_v1_data_types + self.fetch_tswtz_as_timestamp = fetch_tswtz_as_timestamp self.encrypted_credential = encrypted_credential @@ -50084,9 +50227,9 @@ class OrcWriteSettings(FormatWriteSettings): :ivar max_rows_per_file: Limit the written file's row count to be smaller than or equal to the specified count. Type: integer (or Expression with resultType integer). :vartype max_rows_per_file: JSON - :ivar file_name_prefix: Specifies the file name pattern - :code:``_:code:``.:code:`` when copy from non-file - based store without partitionOptions. Type: string (or Expression with resultType string). + :ivar file_name_prefix: Specifies the file name pattern :code:``_\\ + :code:``.\\ :code:`` when copy from non-file based store without + partitionOptions. Type: string (or Expression with resultType string). :vartype file_name_prefix: JSON """ @@ -50116,9 +50259,9 @@ def __init__( :keyword max_rows_per_file: Limit the written file's row count to be smaller than or equal to the specified count. Type: integer (or Expression with resultType integer). :paramtype max_rows_per_file: JSON - :keyword file_name_prefix: Specifies the file name pattern - :code:``_:code:``.:code:`` when copy from non-file - based store without partitionOptions. Type: string (or Expression with resultType string). + :keyword file_name_prefix: Specifies the file name pattern :code:``_\\ + :code:``.\\ :code:`` when copy from non-file based store without + partitionOptions. Type: string (or Expression with resultType string). :paramtype file_name_prefix: JSON """ super().__init__(additional_properties=additional_properties, **kwargs) @@ -50638,9 +50781,9 @@ class ParquetWriteSettings(FormatWriteSettings): :ivar max_rows_per_file: Limit the written file's row count to be smaller than or equal to the specified count. Type: integer (or Expression with resultType integer). :vartype max_rows_per_file: JSON - :ivar file_name_prefix: Specifies the file name pattern - :code:``_:code:``.:code:`` when copy from non-file - based store without partitionOptions. Type: string (or Expression with resultType string). + :ivar file_name_prefix: Specifies the file name pattern :code:``_\\ + :code:``.\\ :code:`` when copy from non-file based store without + partitionOptions. Type: string (or Expression with resultType string). :vartype file_name_prefix: JSON """ @@ -50670,9 +50813,9 @@ def __init__( :keyword max_rows_per_file: Limit the written file's row count to be smaller than or equal to the specified count. Type: integer (or Expression with resultType integer). :paramtype max_rows_per_file: JSON - :keyword file_name_prefix: Specifies the file name pattern - :code:``_:code:``.:code:`` when copy from non-file - based store without partitionOptions. Type: string (or Expression with resultType string). + :keyword file_name_prefix: Specifies the file name pattern :code:``_\\ + :code:``.\\ :code:`` when copy from non-file based store without + partitionOptions. Type: string (or Expression with resultType string). :paramtype file_name_prefix: JSON """ super().__init__(additional_properties=additional_properties, **kwargs) @@ -59807,8 +59950,8 @@ class SapOdpLinkedService(LinkedService): :ivar message_server_service: The service name or port number of the Message Server. Type: string (or Expression with resultType string). :vartype message_server_service: JSON - :ivar snc_mode: SNC activation indicator to access the SAP server where the table is located. - Must be either 0 (off) or 1 (on). Type: string (or Expression with resultType string). + :ivar snc_mode: SNC activation flag (Boolean) to access the SAP server where the table is + located. Type: boolean (or Expression with resultType boolean). :vartype snc_mode: JSON :ivar snc_my_name: Initiator's SNC name to access the SAP server where the table is located. Type: string (or Expression with resultType string). @@ -59939,8 +60082,8 @@ def __init__( # pylint: disable=too-many-locals :keyword message_server_service: The service name or port number of the Message Server. Type: string (or Expression with resultType string). :paramtype message_server_service: JSON - :keyword snc_mode: SNC activation indicator to access the SAP server where the table is - located. Must be either 0 (off) or 1 (on). Type: string (or Expression with resultType string). + :keyword snc_mode: SNC activation flag (Boolean) to access the SAP server where the table is + located. Type: boolean (or Expression with resultType boolean). :paramtype snc_mode: JSON :keyword snc_my_name: Initiator's SNC name to access the SAP server where the table is located. Type: string (or Expression with resultType string). @@ -60723,8 +60866,8 @@ class SapTableLinkedService(LinkedService): :ivar message_server_service: The service name or port number of the Message Server. Type: string (or Expression with resultType string). :vartype message_server_service: JSON - :ivar snc_mode: SNC activation indicator to access the SAP server where the table is located. - Must be either 0 (off) or 1 (on). Type: string (or Expression with resultType string). + :ivar snc_mode: SNC activation flag (Boolean) to access the SAP server where the table is + located. Type: boolean (or Expression with resultType boolean). :vartype snc_mode: JSON :ivar snc_my_name: Initiator's SNC name to access the SAP server where the table is located. Type: string (or Expression with resultType string). @@ -60845,8 +60988,8 @@ def __init__( :keyword message_server_service: The service name or port number of the Message Server. Type: string (or Expression with resultType string). :paramtype message_server_service: JSON - :keyword snc_mode: SNC activation indicator to access the SAP server where the table is - located. Must be either 0 (off) or 1 (on). Type: string (or Expression with resultType string). + :keyword snc_mode: SNC activation flag (Boolean) to access the SAP server where the table is + located. Type: boolean (or Expression with resultType boolean). :paramtype snc_mode: JSON :keyword snc_my_name: Initiator's SNC name to access the SAP server where the table is located. Type: string (or Expression with resultType string). @@ -61465,6 +61608,10 @@ class ScriptActivity(ExecutionActivity): :vartype scripts: list[~azure.mgmt.datafactory.models.ScriptActivityScriptBlock] :ivar log_settings: Log settings of script activity. :vartype log_settings: ~azure.mgmt.datafactory.models.ScriptActivityTypePropertiesLogSettings + :ivar return_multistatement_result: Enable to retrieve result sets from multiple SQL statements + and the number of rows affected by the DML statement. Supported connector: SnowflakeV2. Type: + boolean (or Expression with resultType boolean). + :vartype return_multistatement_result: JSON """ _validation = { @@ -61486,6 +61633,7 @@ class ScriptActivity(ExecutionActivity): "script_block_execution_timeout": {"key": "typeProperties.scriptBlockExecutionTimeout", "type": "object"}, "scripts": {"key": "typeProperties.scripts", "type": "[ScriptActivityScriptBlock]"}, "log_settings": {"key": "typeProperties.logSettings", "type": "ScriptActivityTypePropertiesLogSettings"}, + "return_multistatement_result": {"key": "typeProperties.returnMultistatementResult", "type": "object"}, } def __init__( @@ -61503,6 +61651,7 @@ def __init__( script_block_execution_timeout: Optional[JSON] = None, scripts: Optional[List["_models.ScriptActivityScriptBlock"]] = None, log_settings: Optional["_models.ScriptActivityTypePropertiesLogSettings"] = None, + return_multistatement_result: Optional[JSON] = None, **kwargs: Any ) -> None: """ @@ -61536,6 +61685,10 @@ def __init__( :paramtype scripts: list[~azure.mgmt.datafactory.models.ScriptActivityScriptBlock] :keyword log_settings: Log settings of script activity. :paramtype log_settings: ~azure.mgmt.datafactory.models.ScriptActivityTypePropertiesLogSettings + :keyword return_multistatement_result: Enable to retrieve result sets from multiple SQL + statements and the number of rows affected by the DML statement. Supported connector: + SnowflakeV2. Type: boolean (or Expression with resultType boolean). + :paramtype return_multistatement_result: JSON """ super().__init__( additional_properties=additional_properties, @@ -61553,6 +61706,7 @@ def __init__( self.script_block_execution_timeout = script_block_execution_timeout self.scripts = scripts self.log_settings = log_settings + self.return_multistatement_result = return_multistatement_result class ScriptActivityParameter(_serialization.Model): diff --git a/sdk/datafactory/azure-mgmt-datafactory/setup.py b/sdk/datafactory/azure-mgmt-datafactory/setup.py index 570262824209..907fd55998d6 100644 --- a/sdk/datafactory/azure-mgmt-datafactory/setup.py +++ b/sdk/datafactory/azure-mgmt-datafactory/setup.py @@ -22,11 +22,9 @@ # Version extraction inspired from 'requests' with open( - ( - os.path.join(package_folder_path, "version.py") - if os.path.exists(os.path.join(package_folder_path, "version.py")) - else os.path.join(package_folder_path, "_version.py") - ), + os.path.join(package_folder_path, "version.py") + if os.path.exists(os.path.join(package_folder_path, "version.py")) + else os.path.join(package_folder_path, "_version.py"), "r", ) as fd: version = re.search(r'^VERSION\s*=\s*[\'"]([^\'"]*)[\'"]', fd.read(), re.MULTILINE).group(1)