[DataFactory] Support Oracle V2 app model

src/datafactory/HISTORY.rst

@@ -2,6 +2,9 @@
 
 Release History
 ===============
+1.0.4
+* Support Oracle V2 in Azure Data Factory
+
 1.0.3
 * Enhanced Swagger to support Vertica V2 integration in Azure Data Factory
 * Added Managed Identity (MI) authentication support for Azure Files

src/datafactory/azext_datafactory/manual/version.py

@@ -8,4 +8,4 @@
 # regenerated.
 # --------------------------------------------------------------------------
 
-VERSION = "1.0.3"
+VERSION = "1.0.4"

src/datafactory/azext_datafactory/vendored_sdks/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

src/datafactory/azext_datafactory/vendored_sdks/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 = "9.2.0"

src/datafactory/azext_datafactory/vendored_sdks/datafactory/models/__init__.py

@@ -110,6 +110,7 @@
     AzureMySqlTableDataset,
     AzurePostgreSqlLinkedService,
     AzurePostgreSqlSink,
+    AzurePostgreSqlSinkUpsertSettings,
     AzurePostgreSqlSource,
     AzurePostgreSqlTableDataset,
     AzureQueueSink,
@@ -744,8 +745,10 @@
     TarGZipReadSettings,
     TarReadSettings,
     TeamDeskLinkedService,
+    TeradataImportCommand,
     TeradataLinkedService,
     TeradataPartitionSettings,
+    TeradataSink,
     TeradataSource,
     TeradataTableDataset,
     TextFormat,
@@ -811,6 +814,7 @@
     AmazonRdsForSqlAuthenticationType,
     AvroCompressionCodec,
     AzureFunctionActivityMethod,
+    AzurePostgreSqlWriteMethodEnum,
     AzureSearchIndexWriteBehaviorType,
     AzureSqlDWAuthenticationType,
     AzureSqlDatabaseAuthenticationType,
@@ -847,6 +851,7 @@
     GoogleAdWordsAuthenticationType,
     GoogleBigQueryAuthenticationType,
     GoogleBigQueryV2AuthenticationType,
+    GreenplumAuthenticationType,
     HBaseAuthenticationType,
     HDInsightActivityDebugInfoOption,
     HdiNodeTypes,
@@ -877,6 +882,7 @@
     NotebookReferenceType,
     ODataAadServicePrincipalCredentialType,
     ODataAuthenticationType,
+    OracleAuthenticationType,
     OraclePartitionOption,
     OrcCompressionCodec,
     ParameterType,
@@ -931,6 +937,7 @@
     TriggerRuntimeState,
     TumblingWindowFrequency,
     Type,
+    ValueType,
     VariableType,
     WebActivityMethod,
     WebAuthenticationType,
@@ -1037,6 +1044,7 @@
     "AzureMySqlTableDataset",
     "AzurePostgreSqlLinkedService",
     "AzurePostgreSqlSink",
+    "AzurePostgreSqlSinkUpsertSettings",
     "AzurePostgreSqlSource",
     "AzurePostgreSqlTableDataset",
     "AzureQueueSink",
@@ -1671,8 +1679,10 @@
     "TarGZipReadSettings",
     "TarReadSettings",
     "TeamDeskLinkedService",
+    "TeradataImportCommand",
     "TeradataLinkedService",
     "TeradataPartitionSettings",
+    "TeradataSink",
     "TeradataSource",
     "TeradataTableDataset",
     "TextFormat",
@@ -1735,6 +1745,7 @@
     "AmazonRdsForSqlAuthenticationType",
     "AvroCompressionCodec",
     "AzureFunctionActivityMethod",
+    "AzurePostgreSqlWriteMethodEnum",
     "AzureSearchIndexWriteBehaviorType",
     "AzureSqlDWAuthenticationType",
     "AzureSqlDatabaseAuthenticationType",
@@ -1771,6 +1782,7 @@
     "GoogleAdWordsAuthenticationType",
     "GoogleBigQueryAuthenticationType",
     "GoogleBigQueryV2AuthenticationType",
+    "GreenplumAuthenticationType",
     "HBaseAuthenticationType",
     "HDInsightActivityDebugInfoOption",
     "HdiNodeTypes",
@@ -1801,6 +1813,7 @@
     "NotebookReferenceType",
     "ODataAadServicePrincipalCredentialType",
     "ODataAuthenticationType",
+    "OracleAuthenticationType",
     "OraclePartitionOption",
     "OrcCompressionCodec",
     "ParameterType",
@@ -1855,6 +1868,7 @@
     "TriggerRuntimeState",
     "TumblingWindowFrequency",
     "Type",
+    "ValueType",
     "VariableType",
     "WebActivityMethod",
     "WebAuthenticationType",

src/datafactory/azext_datafactory/vendored_sdks/datafactory/models/_data_factory_management_client_enums.py

@@ -67,6 +67,14 @@ class AzureFunctionActivityMethod(str, Enum, metaclass=CaseInsensitiveEnumMeta):
     TRACE = "TRACE"
 
 
+class AzurePostgreSqlWriteMethodEnum(str, Enum, metaclass=CaseInsensitiveEnumMeta):
+    """The write behavior for the operation. Default is Bulk Insert."""
+
+    BULK_INSERT = "BulkInsert"
+    COPY_COMMAND = "CopyCommand"
+    UPSERT = "Upsert"
+
+
 class AzureSearchIndexWriteBehaviorType(str, Enum, metaclass=CaseInsensitiveEnumMeta):
     """Specify the write behavior when upserting documents into Azure Search Index."""
 
@@ -377,6 +385,12 @@ class GoogleBigQueryV2AuthenticationType(str, Enum, metaclass=CaseInsensitiveEnu
     USER_AUTHENTICATION = "UserAuthentication"
 
 
+class GreenplumAuthenticationType(str, Enum, metaclass=CaseInsensitiveEnumMeta):
+    """The authentication type to use. Type: string. Only used for V2."""
+
+    BASIC = "Basic"
+
+
 class HBaseAuthenticationType(str, Enum, metaclass=CaseInsensitiveEnumMeta):
     """The authentication mechanism to use to connect to the HBase server."""
 
@@ -620,6 +634,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."""
 
@@ -1083,6 +1103,13 @@ class Type(str, Enum, metaclass=CaseInsensitiveEnumMeta):
     LINKED_SERVICE_REFERENCE = "LinkedServiceReference"
 
 
+class ValueType(str, Enum, metaclass=CaseInsensitiveEnumMeta):
+    """Type of value copied from source."""
+
+    ACTUAL = "actual"
+    DISPLAY = "display"
+
+
 class VariableType(str, Enum, metaclass=CaseInsensitiveEnumMeta):
     """Variable type."""