diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlMILinkedService.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlMILinkedService.cs
new file mode 100644
index 0000000000000..9c2188e310855
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlMILinkedService.cs
@@ -0,0 +1,142 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Microsoft.Rest;
+ using Microsoft.Rest.Serialization;
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// Azure SQL Managed Instance linked service.
+ ///
+ [Newtonsoft.Json.JsonObject("AzureSqlMI")]
+ [Rest.Serialization.JsonTransformation]
+ public partial class AzureSqlMILinkedService : LinkedService
+ {
+ ///
+ /// Initializes a new instance of the AzureSqlMILinkedService class.
+ ///
+ public AzureSqlMILinkedService()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the AzureSqlMILinkedService class.
+ ///
+ /// The connection string. Type: string,
+ /// SecureString or AzureKeyVaultSecretReference.
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// The integration runtime reference.
+ /// Linked service description.
+ /// Parameters for linked service.
+ /// List of tags that can be used for
+ /// describing the linked service.
+ /// The Azure key vault secret reference of
+ /// password in connection string.
+ /// The ID of the service principal
+ /// used to authenticate against Azure SQL Managed Instance. Type:
+ /// string (or Expression with resultType string).
+ /// The key of the service principal
+ /// used to authenticate against Azure SQL Managed Instance.
+ /// The name or ID of the tenant to which the
+ /// service principal belongs. Type: string (or Expression with
+ /// resultType string).
+ /// The encrypted credential used for
+ /// authentication. Credentials are encrypted using the integration
+ /// runtime credential manager. Type: string (or Expression with
+ /// resultType string).
+ public AzureSqlMILinkedService(object connectionString, IDictionary additionalProperties = default(IDictionary), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary parameters = default(IDictionary), IList annotations = default(IList), AzureKeyVaultSecretReference password = default(AzureKeyVaultSecretReference), object servicePrincipalId = default(object), SecretBase servicePrincipalKey = default(SecretBase), object tenant = default(object), object encryptedCredential = default(object))
+ : base(additionalProperties, connectVia, description, parameters, annotations)
+ {
+ ConnectionString = connectionString;
+ Password = password;
+ ServicePrincipalId = servicePrincipalId;
+ ServicePrincipalKey = servicePrincipalKey;
+ Tenant = tenant;
+ EncryptedCredential = encryptedCredential;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the connection string. Type: string, SecureString or
+ /// AzureKeyVaultSecretReference.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.connectionString")]
+ public object ConnectionString { get; set; }
+
+ ///
+ /// Gets or sets the Azure key vault secret reference of password in
+ /// connection string.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.password")]
+ public AzureKeyVaultSecretReference Password { get; set; }
+
+ ///
+ /// Gets or sets the ID of the service principal used to authenticate
+ /// against Azure SQL Managed Instance. Type: string (or Expression
+ /// with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.servicePrincipalId")]
+ public object ServicePrincipalId { get; set; }
+
+ ///
+ /// Gets or sets the key of the service principal used to authenticate
+ /// against Azure SQL Managed Instance.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.servicePrincipalKey")]
+ public SecretBase ServicePrincipalKey { get; set; }
+
+ ///
+ /// Gets or sets the name or ID of the tenant to which the service
+ /// principal belongs. Type: string (or Expression with resultType
+ /// string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.tenant")]
+ public object Tenant { get; set; }
+
+ ///
+ /// Gets or sets the encrypted credential used for authentication.
+ /// Credentials are encrypted using the integration runtime credential
+ /// manager. Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.encryptedCredential")]
+ public object EncryptedCredential { get; set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public override void Validate()
+ {
+ base.Validate();
+ if (ConnectionString == null)
+ {
+ throw new ValidationException(ValidationRules.CannotBeNull, "ConnectionString");
+ }
+ if (Password != null)
+ {
+ Password.Validate();
+ }
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlMITableDataset.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlMITableDataset.cs
new file mode 100644
index 0000000000000..c98b4cf7dd9c1
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/AzureSqlMITableDataset.cs
@@ -0,0 +1,108 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Microsoft.Rest;
+ using Microsoft.Rest.Serialization;
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// The Azure SQL Managed Instance dataset.
+ ///
+ [Newtonsoft.Json.JsonObject("AzureSqlMITable")]
+ [Rest.Serialization.JsonTransformation]
+ public partial class AzureSqlMITableDataset : Dataset
+ {
+ ///
+ /// Initializes a new instance of the AzureSqlMITableDataset class.
+ ///
+ public AzureSqlMITableDataset()
+ {
+ LinkedServiceName = new LinkedServiceReference();
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the AzureSqlMITableDataset class.
+ ///
+ /// Linked service reference.
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Dataset description.
+ /// Columns that define the structure of the
+ /// dataset. Type: array (or Expression with resultType array),
+ /// itemType: DatasetDataElement.
+ /// Columns that define the physical type schema
+ /// of the dataset. Type: array (or Expression with resultType array),
+ /// itemType: DatasetSchemaDataElement.
+ /// Parameters for dataset.
+ /// List of tags that can be used for
+ /// describing the Dataset.
+ /// The folder that this Dataset is in. If not
+ /// specified, Dataset will appear at the root level.
+ /// This property will be retired. Please
+ /// consider using schema + table properties instead.
+ /// The schema name of the
+ /// Azure SQL Managed Instance. Type: string (or Expression with
+ /// resultType string).
+ /// The table name of the Azure SQL Managed
+ /// Instance dataset. Type: string (or Expression with resultType
+ /// string).
+ public AzureSqlMITableDataset(LinkedServiceReference linkedServiceName, IDictionary additionalProperties = default(IDictionary), string description = default(string), object structure = default(object), object schema = default(object), IDictionary parameters = default(IDictionary), IList annotations = default(IList), DatasetFolder folder = default(DatasetFolder), object tableName = default(object), object azureSqlMITableDatasetSchema = default(object), object table = default(object))
+ : base(linkedServiceName, additionalProperties, description, structure, schema, parameters, annotations, folder)
+ {
+ TableName = tableName;
+ AzureSqlMITableDatasetSchema = azureSqlMITableDatasetSchema;
+ Table = table;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets this property will be retired. Please consider using
+ /// schema + table properties instead.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.tableName")]
+ public object TableName { get; set; }
+
+ ///
+ /// Gets or sets the schema name of the Azure SQL Managed Instance.
+ /// Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.schema")]
+ public object AzureSqlMITableDatasetSchema { get; set; }
+
+ ///
+ /// Gets or sets the table name of the Azure SQL Managed Instance
+ /// dataset. Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.table")]
+ public object Table { get; set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public override void Validate()
+ {
+ base.Validate();
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/BinaryDataset.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/BinaryDataset.cs
new file mode 100644
index 0000000000000..196ed56fcf7ae
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/BinaryDataset.cs
@@ -0,0 +1,102 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Microsoft.Rest;
+ using Microsoft.Rest.Serialization;
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// Binary dataset.
+ ///
+ [Newtonsoft.Json.JsonObject("Binary")]
+ [Rest.Serialization.JsonTransformation]
+ public partial class BinaryDataset : Dataset
+ {
+ ///
+ /// Initializes a new instance of the BinaryDataset class.
+ ///
+ public BinaryDataset()
+ {
+ LinkedServiceName = new LinkedServiceReference();
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the BinaryDataset class.
+ ///
+ /// Linked service reference.
+ /// The location of the Binary storage.
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Dataset description.
+ /// Columns that define the structure of the
+ /// dataset. Type: array (or Expression with resultType array),
+ /// itemType: DatasetDataElement.
+ /// Columns that define the physical type schema
+ /// of the dataset. Type: array (or Expression with resultType array),
+ /// itemType: DatasetSchemaDataElement.
+ /// Parameters for dataset.
+ /// List of tags that can be used for
+ /// describing the Dataset.
+ /// The folder that this Dataset is in. If not
+ /// specified, Dataset will appear at the root level.
+ /// The data compression method used for the
+ /// binary dataset.
+ public BinaryDataset(LinkedServiceReference linkedServiceName, DatasetLocation location, IDictionary additionalProperties = default(IDictionary), string description = default(string), object structure = default(object), object schema = default(object), IDictionary parameters = default(IDictionary), IList annotations = default(IList), DatasetFolder folder = default(DatasetFolder), DatasetCompression compression = default(DatasetCompression))
+ : base(linkedServiceName, additionalProperties, description, structure, schema, parameters, annotations, folder)
+ {
+ Location = location;
+ Compression = compression;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the location of the Binary storage.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.location")]
+ public DatasetLocation Location { get; set; }
+
+ ///
+ /// Gets or sets the data compression method used for the binary
+ /// dataset.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.compression")]
+ public DatasetCompression Compression { get; set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public override void Validate()
+ {
+ base.Validate();
+ if (Location == null)
+ {
+ throw new ValidationException(ValidationRules.CannotBeNull, "Location");
+ }
+ if (Location != null)
+ {
+ Location.Validate();
+ }
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/BinarySink.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/BinarySink.cs
new file mode 100644
index 0000000000000..46e9928c924c7
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/BinarySink.cs
@@ -0,0 +1,82 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// A copy activity Binary sink.
+ ///
+ public partial class BinarySink : CopySink
+ {
+ ///
+ /// Initializes a new instance of the BinarySink class.
+ ///
+ public BinarySink()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the BinarySink class.
+ ///
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Write batch size. Type: integer (or
+ /// Expression with resultType integer), minimum: 0.
+ /// Write batch timeout. Type: string
+ /// (or Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// Sink retry count. Type: integer (or
+ /// Expression with resultType integer).
+ /// Sink retry wait. Type: string (or
+ /// Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// The maximum concurrent
+ /// connection count for the sink data store. Type: integer (or
+ /// Expression with resultType integer).
+ /// Binary store settings.
+ public BinarySink(IDictionary additionalProperties = default(IDictionary), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), StoreReadSettings storeSettings = default(StoreReadSettings))
+ : base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections)
+ {
+ StoreSettings = storeSettings;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets binary store settings.
+ ///
+ [JsonProperty(PropertyName = "storeSettings")]
+ public StoreReadSettings StoreSettings { get; set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public virtual void Validate()
+ {
+ if (StoreSettings != null)
+ {
+ StoreSettings.Validate();
+ }
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/BinarySource.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/BinarySource.cs
new file mode 100644
index 0000000000000..f93dd77321f3f
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/BinarySource.cs
@@ -0,0 +1,77 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// A copy activity Binary source.
+ ///
+ public partial class BinarySource : CopySource
+ {
+ ///
+ /// Initializes a new instance of the BinarySource class.
+ ///
+ public BinarySource()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the BinarySource class.
+ ///
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Source retry count. Type: integer
+ /// (or Expression with resultType integer).
+ /// Source retry wait. Type: string (or
+ /// Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// The maximum concurrent
+ /// connection count for the source data store. Type: integer (or
+ /// Expression with resultType integer).
+ /// Binary store settings.
+ public BinarySource(IDictionary additionalProperties = default(IDictionary), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), StoreReadSettings storeSettings = default(StoreReadSettings))
+ : base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections)
+ {
+ StoreSettings = storeSettings;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets binary store settings.
+ ///
+ [JsonProperty(PropertyName = "storeSettings")]
+ public StoreReadSettings StoreSettings { get; set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public virtual void Validate()
+ {
+ if (StoreSettings != null)
+ {
+ StoreSettings.Validate();
+ }
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/CommonDataServiceForAppsEntityDataset.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/CommonDataServiceForAppsEntityDataset.cs
new file mode 100644
index 0000000000000..8325649af1fd0
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/CommonDataServiceForAppsEntityDataset.cs
@@ -0,0 +1,88 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Microsoft.Rest;
+ using Microsoft.Rest.Serialization;
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// The Common Data Service for Apps entity dataset.
+ ///
+ [Newtonsoft.Json.JsonObject("CommonDataServiceForAppsEntity")]
+ [Rest.Serialization.JsonTransformation]
+ public partial class CommonDataServiceForAppsEntityDataset : Dataset
+ {
+ ///
+ /// Initializes a new instance of the
+ /// CommonDataServiceForAppsEntityDataset class.
+ ///
+ public CommonDataServiceForAppsEntityDataset()
+ {
+ LinkedServiceName = new LinkedServiceReference();
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the
+ /// CommonDataServiceForAppsEntityDataset class.
+ ///
+ /// Linked service reference.
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Dataset description.
+ /// Columns that define the structure of the
+ /// dataset. Type: array (or Expression with resultType array),
+ /// itemType: DatasetDataElement.
+ /// Columns that define the physical type schema
+ /// of the dataset. Type: array (or Expression with resultType array),
+ /// itemType: DatasetSchemaDataElement.
+ /// Parameters for dataset.
+ /// List of tags that can be used for
+ /// describing the Dataset.
+ /// The folder that this Dataset is in. If not
+ /// specified, Dataset will appear at the root level.
+ /// The logical name of the entity. Type:
+ /// string (or Expression with resultType string).
+ public CommonDataServiceForAppsEntityDataset(LinkedServiceReference linkedServiceName, IDictionary additionalProperties = default(IDictionary), string description = default(string), object structure = default(object), object schema = default(object), IDictionary parameters = default(IDictionary), IList annotations = default(IList), DatasetFolder folder = default(DatasetFolder), object entityName = default(object))
+ : base(linkedServiceName, additionalProperties, description, structure, schema, parameters, annotations, folder)
+ {
+ EntityName = entityName;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the logical name of the entity. Type: string (or
+ /// Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.entityName")]
+ public object EntityName { get; set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public override void Validate()
+ {
+ base.Validate();
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/CommonDataServiceForAppsLinkedService.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/CommonDataServiceForAppsLinkedService.cs
new file mode 100644
index 0000000000000..75a317ca35c88
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/CommonDataServiceForAppsLinkedService.cs
@@ -0,0 +1,204 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Microsoft.Rest;
+ using Microsoft.Rest.Serialization;
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// Common Data Service for Apps linked service.
+ ///
+ [Newtonsoft.Json.JsonObject("CommonDataServiceForApps")]
+ [Rest.Serialization.JsonTransformation]
+ public partial class CommonDataServiceForAppsLinkedService : LinkedService
+ {
+ ///
+ /// Initializes a new instance of the
+ /// CommonDataServiceForAppsLinkedService class.
+ ///
+ public CommonDataServiceForAppsLinkedService()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the
+ /// CommonDataServiceForAppsLinkedService class.
+ ///
+ /// The deployment type of the Common Data
+ /// Service for Apps instance. 'Online' for Common Data Service for
+ /// Apps Online and 'OnPremisesWithIfd' for Common Data Service for
+ /// Apps on-premises with Ifd. Type: string (or Expression with
+ /// resultType string). Possible values include: 'Online',
+ /// 'OnPremisesWithIfd'
+ /// The authentication type to connect
+ /// to Common Data Service for Apps server. 'Office365' for online
+ /// scenario, 'Ifd' for on-premises with Ifd scenario. Type: string (or
+ /// Expression with resultType string). Possible values include:
+ /// 'Office365', 'Ifd'
+ /// User name to access the Common Data Service
+ /// for Apps instance. Type: string (or Expression with resultType
+ /// string).
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// The integration runtime reference.
+ /// Linked service description.
+ /// Parameters for linked service.
+ /// List of tags that can be used for
+ /// describing the linked service.
+ /// The host name of the on-premises Common Data
+ /// Service for Apps server. The property is required for on-prem and
+ /// not allowed for online. Type: string (or Expression with resultType
+ /// string).
+ /// The port of on-premises Common Data Service for
+ /// Apps server. The property is required for on-prem and not allowed
+ /// for online. Default is 443. Type: integer (or Expression with
+ /// resultType integer), minimum: 0.
+ /// The URL to the Microsoft Common Data
+ /// Service for Apps server. The property is required for on-line and
+ /// not allowed for on-prem. Type: string (or Expression with
+ /// resultType string).
+ /// The organization name of the Common
+ /// Data Service for Apps instance. The property is required for
+ /// on-prem and required for online when there are more than one Common
+ /// Data Service for Apps instances associated with the user. Type:
+ /// string (or Expression with resultType string).
+ /// Password to access the Common Data Service
+ /// for Apps instance.
+ /// The encrypted credential used for
+ /// authentication. Credentials are encrypted using the integration
+ /// runtime credential manager. Type: string (or Expression with
+ /// resultType string).
+ public CommonDataServiceForAppsLinkedService(string deploymentType, string authenticationType, object username, IDictionary additionalProperties = default(IDictionary), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary parameters = default(IDictionary), IList annotations = default(IList), object hostName = default(object), object port = default(object), object serviceUri = default(object), object organizationName = default(object), SecretBase password = default(SecretBase), object encryptedCredential = default(object))
+ : base(additionalProperties, connectVia, description, parameters, annotations)
+ {
+ DeploymentType = deploymentType;
+ HostName = hostName;
+ Port = port;
+ ServiceUri = serviceUri;
+ OrganizationName = organizationName;
+ AuthenticationType = authenticationType;
+ Username = username;
+ Password = password;
+ EncryptedCredential = encryptedCredential;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the deployment type of the Common Data Service for
+ /// Apps instance. 'Online' for Common Data Service for Apps Online and
+ /// 'OnPremisesWithIfd' for Common Data Service for Apps on-premises
+ /// with Ifd. Type: string (or Expression with resultType string).
+ /// Possible values include: 'Online', 'OnPremisesWithIfd'
+ ///
+ [JsonProperty(PropertyName = "typeProperties.deploymentType")]
+ public string DeploymentType { get; set; }
+
+ ///
+ /// Gets or sets the host name of the on-premises Common Data Service
+ /// for Apps server. The property is required for on-prem and not
+ /// allowed for online. Type: string (or Expression with resultType
+ /// string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.hostName")]
+ public object HostName { get; set; }
+
+ ///
+ /// Gets or sets the port of on-premises Common Data Service for Apps
+ /// server. The property is required for on-prem and not allowed for
+ /// online. Default is 443. Type: integer (or Expression with
+ /// resultType integer), minimum: 0.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.port")]
+ public object Port { get; set; }
+
+ ///
+ /// Gets or sets the URL to the Microsoft Common Data Service for Apps
+ /// server. The property is required for on-line and not allowed for
+ /// on-prem. Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.serviceUri")]
+ public object ServiceUri { get; set; }
+
+ ///
+ /// Gets or sets the organization name of the Common Data Service for
+ /// Apps instance. The property is required for on-prem and required
+ /// for online when there are more than one Common Data Service for
+ /// Apps instances associated with the user. Type: string (or
+ /// Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.organizationName")]
+ public object OrganizationName { get; set; }
+
+ ///
+ /// Gets or sets the authentication type to connect to Common Data
+ /// Service for Apps server. 'Office365' for online scenario, 'Ifd' for
+ /// on-premises with Ifd scenario. Type: string (or Expression with
+ /// resultType string). Possible values include: 'Office365', 'Ifd'
+ ///
+ [JsonProperty(PropertyName = "typeProperties.authenticationType")]
+ public string AuthenticationType { get; set; }
+
+ ///
+ /// Gets or sets user name to access the Common Data Service for Apps
+ /// instance. Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.username")]
+ public object Username { get; set; }
+
+ ///
+ /// Gets or sets password to access the Common Data Service for Apps
+ /// instance.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.password")]
+ public SecretBase Password { get; set; }
+
+ ///
+ /// Gets or sets the encrypted credential used for authentication.
+ /// Credentials are encrypted using the integration runtime credential
+ /// manager. Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.encryptedCredential")]
+ public object EncryptedCredential { get; set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public override void Validate()
+ {
+ base.Validate();
+ if (DeploymentType == null)
+ {
+ throw new ValidationException(ValidationRules.CannotBeNull, "DeploymentType");
+ }
+ if (AuthenticationType == null)
+ {
+ throw new ValidationException(ValidationRules.CannotBeNull, "AuthenticationType");
+ }
+ if (Username == null)
+ {
+ throw new ValidationException(ValidationRules.CannotBeNull, "Username");
+ }
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/CommonDataServiceForAppsSink.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/CommonDataServiceForAppsSink.cs
new file mode 100644
index 0000000000000..3d2ecc7c8606a
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/CommonDataServiceForAppsSink.cs
@@ -0,0 +1,89 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// A copy activity Common Data Service for Apps sink.
+ ///
+ public partial class CommonDataServiceForAppsSink : CopySink
+ {
+ ///
+ /// Initializes a new instance of the CommonDataServiceForAppsSink
+ /// class.
+ ///
+ public CommonDataServiceForAppsSink()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the CommonDataServiceForAppsSink
+ /// class.
+ ///
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Write batch size. Type: integer (or
+ /// Expression with resultType integer), minimum: 0.
+ /// Write batch timeout. Type: string
+ /// (or Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// Sink retry count. Type: integer (or
+ /// Expression with resultType integer).
+ /// Sink retry wait. Type: string (or
+ /// Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// The maximum concurrent
+ /// connection count for the sink data store. Type: integer (or
+ /// Expression with resultType integer).
+ /// The flag indicating whether to
+ /// ignore null values from input dataset (except key fields) during
+ /// write operation. Default is false. Type: boolean (or Expression
+ /// with resultType boolean).
+ public CommonDataServiceForAppsSink(IDictionary additionalProperties = default(IDictionary), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object ignoreNullValues = default(object))
+ : base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections)
+ {
+ IgnoreNullValues = ignoreNullValues;
+ CustomInit();
+ }
+ ///
+ /// Static constructor for CommonDataServiceForAppsSink class.
+ ///
+ static CommonDataServiceForAppsSink()
+ {
+ WriteBehavior = "Upsert";
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the flag indicating whether to ignore null values from
+ /// input dataset (except key fields) during write operation. Default
+ /// is false. Type: boolean (or Expression with resultType boolean).
+ ///
+ [JsonProperty(PropertyName = "ignoreNullValues")]
+ public object IgnoreNullValues { get; set; }
+
+ ///
+ /// The write behavior for the operation.
+ ///
+ [JsonProperty(PropertyName = "writeBehavior")]
+ public static string WriteBehavior { get; private set; }
+
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/CommonDataServiceForAppsSource.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/CommonDataServiceForAppsSource.cs
new file mode 100644
index 0000000000000..62918054e7cae
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/CommonDataServiceForAppsSource.cs
@@ -0,0 +1,71 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// A copy activity Common Data Service for Apps source.
+ ///
+ public partial class CommonDataServiceForAppsSource : CopySource
+ {
+ ///
+ /// Initializes a new instance of the CommonDataServiceForAppsSource
+ /// class.
+ ///
+ public CommonDataServiceForAppsSource()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the CommonDataServiceForAppsSource
+ /// class.
+ ///
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Source retry count. Type: integer
+ /// (or Expression with resultType integer).
+ /// Source retry wait. Type: string (or
+ /// Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// The maximum concurrent
+ /// connection count for the source data store. Type: integer (or
+ /// Expression with resultType integer).
+ /// FetchXML is a proprietary query language that
+ /// is used in Microsoft Common Data Service for Apps (online &
+ /// on-premises). Type: string (or Expression with resultType
+ /// string).
+ public CommonDataServiceForAppsSource(IDictionary additionalProperties = default(IDictionary), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object query = default(object))
+ : base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections)
+ {
+ Query = query;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets fetchXML is a proprietary query language that is used
+ /// in Microsoft Common Data Service for Apps (online &
+ /// on-premises). Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "query")]
+ public object Query { get; set; }
+
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsAuthenticationType.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsAuthenticationType.cs
new file mode 100644
index 0000000000000..614215a7b1b45
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsAuthenticationType.cs
@@ -0,0 +1,22 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+
+ ///
+ /// Defines values for DynamicsAuthenticationType.
+ ///
+ public static class DynamicsAuthenticationType
+ {
+ public const string Office365 = "Office365";
+ public const string Ifd = "Ifd";
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsCrmEntityDataset.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsCrmEntityDataset.cs
new file mode 100644
index 0000000000000..3c5eade344487
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsCrmEntityDataset.cs
@@ -0,0 +1,86 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Microsoft.Rest;
+ using Microsoft.Rest.Serialization;
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// The Dynamics CRM entity dataset.
+ ///
+ [Newtonsoft.Json.JsonObject("DynamicsCrmEntity")]
+ [Rest.Serialization.JsonTransformation]
+ public partial class DynamicsCrmEntityDataset : Dataset
+ {
+ ///
+ /// Initializes a new instance of the DynamicsCrmEntityDataset class.
+ ///
+ public DynamicsCrmEntityDataset()
+ {
+ LinkedServiceName = new LinkedServiceReference();
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the DynamicsCrmEntityDataset class.
+ ///
+ /// Linked service reference.
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Dataset description.
+ /// Columns that define the structure of the
+ /// dataset. Type: array (or Expression with resultType array),
+ /// itemType: DatasetDataElement.
+ /// Columns that define the physical type schema
+ /// of the dataset. Type: array (or Expression with resultType array),
+ /// itemType: DatasetSchemaDataElement.
+ /// Parameters for dataset.
+ /// List of tags that can be used for
+ /// describing the Dataset.
+ /// The folder that this Dataset is in. If not
+ /// specified, Dataset will appear at the root level.
+ /// The logical name of the entity. Type:
+ /// string (or Expression with resultType string).
+ public DynamicsCrmEntityDataset(LinkedServiceReference linkedServiceName, IDictionary additionalProperties = default(IDictionary), string description = default(string), object structure = default(object), object schema = default(object), IDictionary parameters = default(IDictionary), IList annotations = default(IList), DatasetFolder folder = default(DatasetFolder), object entityName = default(object))
+ : base(linkedServiceName, additionalProperties, description, structure, schema, parameters, annotations, folder)
+ {
+ EntityName = entityName;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the logical name of the entity. Type: string (or
+ /// Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.entityName")]
+ public object EntityName { get; set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public override void Validate()
+ {
+ base.Validate();
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsCrmLinkedService.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsCrmLinkedService.cs
new file mode 100644
index 0000000000000..259839e75d2d2
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsCrmLinkedService.cs
@@ -0,0 +1,198 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Microsoft.Rest;
+ using Microsoft.Rest.Serialization;
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// Dynamics CRM linked service.
+ ///
+ [Newtonsoft.Json.JsonObject("DynamicsCrm")]
+ [Rest.Serialization.JsonTransformation]
+ public partial class DynamicsCrmLinkedService : LinkedService
+ {
+ ///
+ /// Initializes a new instance of the DynamicsCrmLinkedService class.
+ ///
+ public DynamicsCrmLinkedService()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the DynamicsCrmLinkedService class.
+ ///
+ /// The deployment type of the Dynamics
+ /// CRM instance. 'Online' for Dynamics CRM Online and
+ /// 'OnPremisesWithIfd' for Dynamics CRM on-premises with Ifd. Type:
+ /// string (or Expression with resultType string). Possible values
+ /// include: 'Online', 'OnPremisesWithIfd'
+ /// The authentication type to connect
+ /// to Dynamics CRM server. 'Office365' for online scenario, 'Ifd' for
+ /// on-premises with Ifd scenario. Type: string (or Expression with
+ /// resultType string). Possible values include: 'Office365',
+ /// 'Ifd'
+ /// User name to access the Dynamics CRM
+ /// instance. Type: string (or Expression with resultType
+ /// string).
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// The integration runtime reference.
+ /// Linked service description.
+ /// Parameters for linked service.
+ /// List of tags that can be used for
+ /// describing the linked service.
+ /// The host name of the on-premises Dynamics
+ /// CRM server. The property is required for on-prem and not allowed
+ /// for online. Type: string (or Expression with resultType
+ /// string).
+ /// The port of on-premises Dynamics CRM server. The
+ /// property is required for on-prem and not allowed for online.
+ /// Default is 443. Type: integer (or Expression with resultType
+ /// integer), minimum: 0.
+ /// The URL to the Microsoft Dynamics CRM
+ /// server. The property is required for on-line and not allowed for
+ /// on-prem. Type: string (or Expression with resultType
+ /// string).
+ /// The organization name of the
+ /// Dynamics CRM instance. The property is required for on-prem and
+ /// required for online when there are more than one Dynamics CRM
+ /// instances associated with the user. Type: string (or Expression
+ /// with resultType string).
+ /// Password to access the Dynamics CRM
+ /// instance.
+ /// The encrypted credential used for
+ /// authentication. Credentials are encrypted using the integration
+ /// runtime credential manager. Type: string (or Expression with
+ /// resultType string).
+ public DynamicsCrmLinkedService(string deploymentType, string authenticationType, object username, IDictionary additionalProperties = default(IDictionary), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary parameters = default(IDictionary), IList annotations = default(IList), object hostName = default(object), object port = default(object), object serviceUri = default(object), object organizationName = default(object), SecretBase password = default(SecretBase), object encryptedCredential = default(object))
+ : base(additionalProperties, connectVia, description, parameters, annotations)
+ {
+ DeploymentType = deploymentType;
+ HostName = hostName;
+ Port = port;
+ ServiceUri = serviceUri;
+ OrganizationName = organizationName;
+ AuthenticationType = authenticationType;
+ Username = username;
+ Password = password;
+ EncryptedCredential = encryptedCredential;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the deployment type of the Dynamics CRM instance.
+ /// 'Online' for Dynamics CRM Online and 'OnPremisesWithIfd' for
+ /// Dynamics CRM on-premises with Ifd. Type: string (or Expression with
+ /// resultType string). Possible values include: 'Online',
+ /// 'OnPremisesWithIfd'
+ ///
+ [JsonProperty(PropertyName = "typeProperties.deploymentType")]
+ public string DeploymentType { get; set; }
+
+ ///
+ /// Gets or sets the host name of the on-premises Dynamics CRM server.
+ /// The property is required for on-prem and not allowed for online.
+ /// Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.hostName")]
+ public object HostName { get; set; }
+
+ ///
+ /// Gets or sets the port of on-premises Dynamics CRM server. The
+ /// property is required for on-prem and not allowed for online.
+ /// Default is 443. Type: integer (or Expression with resultType
+ /// integer), minimum: 0.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.port")]
+ public object Port { get; set; }
+
+ ///
+ /// Gets or sets the URL to the Microsoft Dynamics CRM server. The
+ /// property is required for on-line and not allowed for on-prem. Type:
+ /// string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.serviceUri")]
+ public object ServiceUri { get; set; }
+
+ ///
+ /// Gets or sets the organization name of the Dynamics CRM instance.
+ /// The property is required for on-prem and required for online when
+ /// there are more than one Dynamics CRM instances associated with the
+ /// user. Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.organizationName")]
+ public object OrganizationName { get; set; }
+
+ ///
+ /// Gets or sets the authentication type to connect to Dynamics CRM
+ /// server. 'Office365' for online scenario, 'Ifd' for on-premises with
+ /// Ifd scenario. Type: string (or Expression with resultType string).
+ /// Possible values include: 'Office365', 'Ifd'
+ ///
+ [JsonProperty(PropertyName = "typeProperties.authenticationType")]
+ public string AuthenticationType { get; set; }
+
+ ///
+ /// Gets or sets user name to access the Dynamics CRM instance. Type:
+ /// string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.username")]
+ public object Username { get; set; }
+
+ ///
+ /// Gets or sets password to access the Dynamics CRM instance.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.password")]
+ public SecretBase Password { get; set; }
+
+ ///
+ /// Gets or sets the encrypted credential used for authentication.
+ /// Credentials are encrypted using the integration runtime credential
+ /// manager. Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.encryptedCredential")]
+ public object EncryptedCredential { get; set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public override void Validate()
+ {
+ base.Validate();
+ if (DeploymentType == null)
+ {
+ throw new ValidationException(ValidationRules.CannotBeNull, "DeploymentType");
+ }
+ if (AuthenticationType == null)
+ {
+ throw new ValidationException(ValidationRules.CannotBeNull, "AuthenticationType");
+ }
+ if (Username == null)
+ {
+ throw new ValidationException(ValidationRules.CannotBeNull, "Username");
+ }
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsCrmSink.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsCrmSink.cs
new file mode 100644
index 0000000000000..25a45867354d6
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsCrmSink.cs
@@ -0,0 +1,87 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// A copy activity Dynamics CRM sink.
+ ///
+ public partial class DynamicsCrmSink : CopySink
+ {
+ ///
+ /// Initializes a new instance of the DynamicsCrmSink class.
+ ///
+ public DynamicsCrmSink()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the DynamicsCrmSink class.
+ ///
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Write batch size. Type: integer (or
+ /// Expression with resultType integer), minimum: 0.
+ /// Write batch timeout. Type: string
+ /// (or Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// Sink retry count. Type: integer (or
+ /// Expression with resultType integer).
+ /// Sink retry wait. Type: string (or
+ /// Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// The maximum concurrent
+ /// connection count for the sink data store. Type: integer (or
+ /// Expression with resultType integer).
+ /// The flag indicating whether to
+ /// ignore null values from input dataset (except key fields) during
+ /// write operation. Default is false. Type: boolean (or Expression
+ /// with resultType boolean).
+ public DynamicsCrmSink(IDictionary additionalProperties = default(IDictionary), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object ignoreNullValues = default(object))
+ : base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections)
+ {
+ IgnoreNullValues = ignoreNullValues;
+ CustomInit();
+ }
+ ///
+ /// Static constructor for DynamicsCrmSink class.
+ ///
+ static DynamicsCrmSink()
+ {
+ WriteBehavior = "Upsert";
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the flag indicating whether to ignore null values from
+ /// input dataset (except key fields) during write operation. Default
+ /// is false. Type: boolean (or Expression with resultType boolean).
+ ///
+ [JsonProperty(PropertyName = "ignoreNullValues")]
+ public object IgnoreNullValues { get; set; }
+
+ ///
+ /// The write behavior for the operation.
+ ///
+ [JsonProperty(PropertyName = "writeBehavior")]
+ public static string WriteBehavior { get; private set; }
+
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsCrmSource.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsCrmSource.cs
new file mode 100644
index 0000000000000..0417c432bde78
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsCrmSource.cs
@@ -0,0 +1,68 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// A copy activity Dynamics CRM source.
+ ///
+ public partial class DynamicsCrmSource : CopySource
+ {
+ ///
+ /// Initializes a new instance of the DynamicsCrmSource class.
+ ///
+ public DynamicsCrmSource()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the DynamicsCrmSource class.
+ ///
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Source retry count. Type: integer
+ /// (or Expression with resultType integer).
+ /// Source retry wait. Type: string (or
+ /// Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// The maximum concurrent
+ /// connection count for the source data store. Type: integer (or
+ /// Expression with resultType integer).
+ /// FetchXML is a proprietary query language that
+ /// is used in Microsoft Dynamics CRM (online & on-premises). Type:
+ /// string (or Expression with resultType string).
+ public DynamicsCrmSource(IDictionary additionalProperties = default(IDictionary), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object query = default(object))
+ : base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections)
+ {
+ Query = query;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets fetchXML is a proprietary query language that is used
+ /// in Microsoft Dynamics CRM (online & on-premises). Type:
+ /// string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "query")]
+ public object Query { get; set; }
+
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsDeploymentType.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsDeploymentType.cs
new file mode 100644
index 0000000000000..393579fc62e76
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/DynamicsDeploymentType.cs
@@ -0,0 +1,22 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+
+ ///
+ /// Defines values for DynamicsDeploymentType.
+ ///
+ public static class DynamicsDeploymentType
+ {
+ public const string Online = "Online";
+ public const string OnPremisesWithIfd = "OnPremisesWithIfd";
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/ExecuteSSISPackageActivity.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/ExecuteSSISPackageActivity.cs
index ddf955ce1518c..0071592429259 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/ExecuteSSISPackageActivity.cs
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/ExecuteSSISPackageActivity.cs
@@ -67,7 +67,9 @@ public ExecuteSSISPackageActivity()
/// connection managers to execute the SSIS package.
/// The property overrides to execute
/// the SSIS package.
- public ExecuteSSISPackageActivity(string name, SSISPackageLocation packageLocation, IntegrationRuntimeReference connectVia, IDictionary additionalProperties = default(IDictionary), string description = default(string), IList dependsOn = default(IList), IList userProperties = default(IList), LinkedServiceReference linkedServiceName = default(LinkedServiceReference), ActivityPolicy policy = default(ActivityPolicy), object runtime = default(object), object loggingLevel = default(object), object environmentPath = default(object), SSISExecutionCredential executionCredential = default(SSISExecutionCredential), IDictionary projectParameters = default(IDictionary), IDictionary packageParameters = default(IDictionary), IDictionary> projectConnectionManagers = default(IDictionary>), IDictionary> packageConnectionManagers = default(IDictionary>), IDictionary propertyOverrides = default(IDictionary))
+ /// SSIS package execution log
+ /// location.
+ public ExecuteSSISPackageActivity(string name, SSISPackageLocation packageLocation, IntegrationRuntimeReference connectVia, IDictionary additionalProperties = default(IDictionary), string description = default(string), IList dependsOn = default(IList), IList userProperties = default(IList), LinkedServiceReference linkedServiceName = default(LinkedServiceReference), ActivityPolicy policy = default(ActivityPolicy), object runtime = default(object), object loggingLevel = default(object), object environmentPath = default(object), SSISExecutionCredential executionCredential = default(SSISExecutionCredential), IDictionary projectParameters = default(IDictionary), IDictionary packageParameters = default(IDictionary), IDictionary> projectConnectionManagers = default(IDictionary>), IDictionary> packageConnectionManagers = default(IDictionary>), IDictionary propertyOverrides = default(IDictionary), SSISLogLocation logLocation = default(SSISLogLocation))
: base(name, additionalProperties, description, dependsOn, userProperties, linkedServiceName, policy)
{
PackageLocation = packageLocation;
@@ -81,6 +83,7 @@ public ExecuteSSISPackageActivity()
ProjectConnectionManagers = projectConnectionManagers;
PackageConnectionManagers = packageConnectionManagers;
PropertyOverrides = propertyOverrides;
+ LogLocation = logLocation;
CustomInit();
}
@@ -163,6 +166,12 @@ public ExecuteSSISPackageActivity()
[JsonProperty(PropertyName = "typeProperties.propertyOverrides")]
public IDictionary PropertyOverrides { get; set; }
+ ///
+ /// Gets or sets SSIS package execution log location.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.logLocation")]
+ public SSISLogLocation LogLocation { get; set; }
+
///
/// Validate the object.
///
@@ -254,6 +263,10 @@ public override void Validate()
}
}
}
+ if (LogLocation != null)
+ {
+ LogLocation.Validate();
+ }
}
}
}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/InformixLinkedService.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/InformixLinkedService.cs
new file mode 100644
index 0000000000000..c278c502e4541
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/InformixLinkedService.cs
@@ -0,0 +1,138 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Microsoft.Rest;
+ using Microsoft.Rest.Serialization;
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// Informix linked service.
+ ///
+ [Newtonsoft.Json.JsonObject("Informix")]
+ [Rest.Serialization.JsonTransformation]
+ public partial class InformixLinkedService : LinkedService
+ {
+ ///
+ /// Initializes a new instance of the InformixLinkedService class.
+ ///
+ public InformixLinkedService()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the InformixLinkedService class.
+ ///
+ /// The non-access credential portion of
+ /// the connection string as well as an optional encrypted credential.
+ /// Type: string, SecureString or AzureKeyVaultSecretReference.
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// The integration runtime reference.
+ /// Linked service description.
+ /// Parameters for linked service.
+ /// List of tags that can be used for
+ /// describing the linked service.
+ /// Type of authentication used to
+ /// connect to the Informix as ODBC data store. Possible values are:
+ /// Anonymous and Basic. Type: string (or Expression with resultType
+ /// string).
+ /// The access credential portion of the
+ /// connection string specified in driver-specific property-value
+ /// format.
+ /// User name for Basic authentication. Type:
+ /// string (or Expression with resultType string).
+ /// Password for Basic authentication.
+ /// The encrypted credential used for
+ /// authentication. Credentials are encrypted using the integration
+ /// runtime credential manager. Type: string (or Expression with
+ /// resultType string).
+ public InformixLinkedService(object connectionString, IDictionary additionalProperties = default(IDictionary), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary parameters = default(IDictionary), IList annotations = default(IList), object authenticationType = default(object), SecretBase credential = default(SecretBase), object userName = default(object), SecretBase password = default(SecretBase), object encryptedCredential = default(object))
+ : base(additionalProperties, connectVia, description, parameters, annotations)
+ {
+ ConnectionString = connectionString;
+ AuthenticationType = authenticationType;
+ Credential = credential;
+ UserName = userName;
+ Password = password;
+ EncryptedCredential = encryptedCredential;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the non-access credential portion of the connection
+ /// string as well as an optional encrypted credential. Type: string,
+ /// SecureString or AzureKeyVaultSecretReference.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.connectionString")]
+ public object ConnectionString { get; set; }
+
+ ///
+ /// Gets or sets type of authentication used to connect to the Informix
+ /// as ODBC data store. Possible values are: Anonymous and Basic. Type:
+ /// string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.authenticationType")]
+ public object AuthenticationType { get; set; }
+
+ ///
+ /// Gets or sets the access credential portion of the connection string
+ /// specified in driver-specific property-value format.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.credential")]
+ public SecretBase Credential { get; set; }
+
+ ///
+ /// Gets or sets user name for Basic authentication. Type: string (or
+ /// Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.userName")]
+ public object UserName { get; set; }
+
+ ///
+ /// Gets or sets password for Basic authentication.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.password")]
+ public SecretBase Password { get; set; }
+
+ ///
+ /// Gets or sets the encrypted credential used for authentication.
+ /// Credentials are encrypted using the integration runtime credential
+ /// manager. Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.encryptedCredential")]
+ public object EncryptedCredential { get; set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public override void Validate()
+ {
+ base.Validate();
+ if (ConnectionString == null)
+ {
+ throw new ValidationException(ValidationRules.CannotBeNull, "ConnectionString");
+ }
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/InformixSink.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/InformixSink.cs
new file mode 100644
index 0000000000000..0ceb858146c65
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/InformixSink.cs
@@ -0,0 +1,71 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// A copy activity Informix sink.
+ ///
+ public partial class InformixSink : CopySink
+ {
+ ///
+ /// Initializes a new instance of the InformixSink class.
+ ///
+ public InformixSink()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the InformixSink class.
+ ///
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Write batch size. Type: integer (or
+ /// Expression with resultType integer), minimum: 0.
+ /// Write batch timeout. Type: string
+ /// (or Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// Sink retry count. Type: integer (or
+ /// Expression with resultType integer).
+ /// Sink retry wait. Type: string (or
+ /// Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// The maximum concurrent
+ /// connection count for the sink data store. Type: integer (or
+ /// Expression with resultType integer).
+ /// A query to execute before starting the
+ /// copy. Type: string (or Expression with resultType string).
+ public InformixSink(IDictionary additionalProperties = default(IDictionary), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object preCopyScript = default(object))
+ : base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections)
+ {
+ PreCopyScript = preCopyScript;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets a query to execute before starting the copy. Type:
+ /// string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "preCopyScript")]
+ public object PreCopyScript { get; set; }
+
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/InformixSource.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/InformixSource.cs
new file mode 100644
index 0000000000000..d99d756697519
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/InformixSource.cs
@@ -0,0 +1,66 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// A copy activity source for Informix.
+ ///
+ public partial class InformixSource : CopySource
+ {
+ ///
+ /// Initializes a new instance of the InformixSource class.
+ ///
+ public InformixSource()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the InformixSource class.
+ ///
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Source retry count. Type: integer
+ /// (or Expression with resultType integer).
+ /// Source retry wait. Type: string (or
+ /// Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// The maximum concurrent
+ /// connection count for the source data store. Type: integer (or
+ /// Expression with resultType integer).
+ /// Database query. Type: string (or Expression
+ /// with resultType string).
+ public InformixSource(IDictionary additionalProperties = default(IDictionary), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object query = default(object))
+ : base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections)
+ {
+ Query = query;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets database query. Type: string (or Expression with
+ /// resultType string).
+ ///
+ [JsonProperty(PropertyName = "query")]
+ public object Query { get; set; }
+
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/InformixTableDataset.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/InformixTableDataset.cs
new file mode 100644
index 0000000000000..9c340ee55b3ca
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/InformixTableDataset.cs
@@ -0,0 +1,86 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Microsoft.Rest;
+ using Microsoft.Rest.Serialization;
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// The Informix table dataset.
+ ///
+ [Newtonsoft.Json.JsonObject("InformixTable")]
+ [Rest.Serialization.JsonTransformation]
+ public partial class InformixTableDataset : Dataset
+ {
+ ///
+ /// Initializes a new instance of the InformixTableDataset class.
+ ///
+ public InformixTableDataset()
+ {
+ LinkedServiceName = new LinkedServiceReference();
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the InformixTableDataset class.
+ ///
+ /// Linked service reference.
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Dataset description.
+ /// Columns that define the structure of the
+ /// dataset. Type: array (or Expression with resultType array),
+ /// itemType: DatasetDataElement.
+ /// Columns that define the physical type schema
+ /// of the dataset. Type: array (or Expression with resultType array),
+ /// itemType: DatasetSchemaDataElement.
+ /// Parameters for dataset.
+ /// List of tags that can be used for
+ /// describing the Dataset.
+ /// The folder that this Dataset is in. If not
+ /// specified, Dataset will appear at the root level.
+ /// The Informix table name. Type: string (or
+ /// Expression with resultType string).
+ public InformixTableDataset(LinkedServiceReference linkedServiceName, IDictionary additionalProperties = default(IDictionary), string description = default(string), object structure = default(object), object schema = default(object), IDictionary parameters = default(IDictionary), IList annotations = default(IList), DatasetFolder folder = default(DatasetFolder), object tableName = default(object))
+ : base(linkedServiceName, additionalProperties, description, structure, schema, parameters, annotations, folder)
+ {
+ TableName = tableName;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the Informix table name. Type: string (or Expression
+ /// with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.tableName")]
+ public object TableName { get; set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public override void Validate()
+ {
+ base.Validate();
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MicrosoftAccessLinkedService.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MicrosoftAccessLinkedService.cs
new file mode 100644
index 0000000000000..a8e2d871318a4
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MicrosoftAccessLinkedService.cs
@@ -0,0 +1,140 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Microsoft.Rest;
+ using Microsoft.Rest.Serialization;
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// Microsoft Access linked service.
+ ///
+ [Newtonsoft.Json.JsonObject("MicrosoftAccess")]
+ [Rest.Serialization.JsonTransformation]
+ public partial class MicrosoftAccessLinkedService : LinkedService
+ {
+ ///
+ /// Initializes a new instance of the MicrosoftAccessLinkedService
+ /// class.
+ ///
+ public MicrosoftAccessLinkedService()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the MicrosoftAccessLinkedService
+ /// class.
+ ///
+ /// The non-access credential portion of
+ /// the connection string as well as an optional encrypted credential.
+ /// Type: string, SecureString or AzureKeyVaultSecretReference.
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// The integration runtime reference.
+ /// Linked service description.
+ /// Parameters for linked service.
+ /// List of tags that can be used for
+ /// describing the linked service.
+ /// Type of authentication used to
+ /// connect to the Microsoft Access as ODBC data store. Possible values
+ /// are: Anonymous and Basic. Type: string (or Expression with
+ /// resultType string).
+ /// The access credential portion of the
+ /// connection string specified in driver-specific property-value
+ /// format.
+ /// User name for Basic authentication. Type:
+ /// string (or Expression with resultType string).
+ /// Password for Basic authentication.
+ /// The encrypted credential used for
+ /// authentication. Credentials are encrypted using the integration
+ /// runtime credential manager. Type: string (or Expression with
+ /// resultType string).
+ public MicrosoftAccessLinkedService(object connectionString, IDictionary additionalProperties = default(IDictionary), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary parameters = default(IDictionary), IList annotations = default(IList), object authenticationType = default(object), SecretBase credential = default(SecretBase), object userName = default(object), SecretBase password = default(SecretBase), object encryptedCredential = default(object))
+ : base(additionalProperties, connectVia, description, parameters, annotations)
+ {
+ ConnectionString = connectionString;
+ AuthenticationType = authenticationType;
+ Credential = credential;
+ UserName = userName;
+ Password = password;
+ EncryptedCredential = encryptedCredential;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the non-access credential portion of the connection
+ /// string as well as an optional encrypted credential. Type: string,
+ /// SecureString or AzureKeyVaultSecretReference.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.connectionString")]
+ public object ConnectionString { get; set; }
+
+ ///
+ /// Gets or sets type of authentication used to connect to the
+ /// Microsoft Access as ODBC data store. Possible values are: Anonymous
+ /// and Basic. Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.authenticationType")]
+ public object AuthenticationType { get; set; }
+
+ ///
+ /// Gets or sets the access credential portion of the connection string
+ /// specified in driver-specific property-value format.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.credential")]
+ public SecretBase Credential { get; set; }
+
+ ///
+ /// Gets or sets user name for Basic authentication. Type: string (or
+ /// Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.userName")]
+ public object UserName { get; set; }
+
+ ///
+ /// Gets or sets password for Basic authentication.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.password")]
+ public SecretBase Password { get; set; }
+
+ ///
+ /// Gets or sets the encrypted credential used for authentication.
+ /// Credentials are encrypted using the integration runtime credential
+ /// manager. Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.encryptedCredential")]
+ public object EncryptedCredential { get; set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public override void Validate()
+ {
+ base.Validate();
+ if (ConnectionString == null)
+ {
+ throw new ValidationException(ValidationRules.CannotBeNull, "ConnectionString");
+ }
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MicrosoftAccessSink.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MicrosoftAccessSink.cs
new file mode 100644
index 0000000000000..899d6f038b430
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MicrosoftAccessSink.cs
@@ -0,0 +1,71 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// A copy activity Microsoft Access sink.
+ ///
+ public partial class MicrosoftAccessSink : CopySink
+ {
+ ///
+ /// Initializes a new instance of the MicrosoftAccessSink class.
+ ///
+ public MicrosoftAccessSink()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the MicrosoftAccessSink class.
+ ///
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Write batch size. Type: integer (or
+ /// Expression with resultType integer), minimum: 0.
+ /// Write batch timeout. Type: string
+ /// (or Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// Sink retry count. Type: integer (or
+ /// Expression with resultType integer).
+ /// Sink retry wait. Type: string (or
+ /// Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// The maximum concurrent
+ /// connection count for the sink data store. Type: integer (or
+ /// Expression with resultType integer).
+ /// A query to execute before starting the
+ /// copy. Type: string (or Expression with resultType string).
+ public MicrosoftAccessSink(IDictionary additionalProperties = default(IDictionary), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object preCopyScript = default(object))
+ : base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections)
+ {
+ PreCopyScript = preCopyScript;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets a query to execute before starting the copy. Type:
+ /// string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "preCopyScript")]
+ public object PreCopyScript { get; set; }
+
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MicrosoftAccessSource.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MicrosoftAccessSource.cs
new file mode 100644
index 0000000000000..aaeb0e9efc35a
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MicrosoftAccessSource.cs
@@ -0,0 +1,66 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// A copy activity source for Microsoft Access.
+ ///
+ public partial class MicrosoftAccessSource : CopySource
+ {
+ ///
+ /// Initializes a new instance of the MicrosoftAccessSource class.
+ ///
+ public MicrosoftAccessSource()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the MicrosoftAccessSource class.
+ ///
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Source retry count. Type: integer
+ /// (or Expression with resultType integer).
+ /// Source retry wait. Type: string (or
+ /// Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// The maximum concurrent
+ /// connection count for the source data store. Type: integer (or
+ /// Expression with resultType integer).
+ /// Database query. Type: string (or Expression
+ /// with resultType string).
+ public MicrosoftAccessSource(IDictionary additionalProperties = default(IDictionary), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object query = default(object))
+ : base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections)
+ {
+ Query = query;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets database query. Type: string (or Expression with
+ /// resultType string).
+ ///
+ [JsonProperty(PropertyName = "query")]
+ public object Query { get; set; }
+
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MicrosoftAccessTableDataset.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MicrosoftAccessTableDataset.cs
new file mode 100644
index 0000000000000..474f6818939d5
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/MicrosoftAccessTableDataset.cs
@@ -0,0 +1,88 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Microsoft.Rest;
+ using Microsoft.Rest.Serialization;
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// The Microsoft Access table dataset.
+ ///
+ [Newtonsoft.Json.JsonObject("MicrosoftAccessTable")]
+ [Rest.Serialization.JsonTransformation]
+ public partial class MicrosoftAccessTableDataset : Dataset
+ {
+ ///
+ /// Initializes a new instance of the MicrosoftAccessTableDataset
+ /// class.
+ ///
+ public MicrosoftAccessTableDataset()
+ {
+ LinkedServiceName = new LinkedServiceReference();
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the MicrosoftAccessTableDataset
+ /// class.
+ ///
+ /// Linked service reference.
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Dataset description.
+ /// Columns that define the structure of the
+ /// dataset. Type: array (or Expression with resultType array),
+ /// itemType: DatasetDataElement.
+ /// Columns that define the physical type schema
+ /// of the dataset. Type: array (or Expression with resultType array),
+ /// itemType: DatasetSchemaDataElement.
+ /// Parameters for dataset.
+ /// List of tags that can be used for
+ /// describing the Dataset.
+ /// The folder that this Dataset is in. If not
+ /// specified, Dataset will appear at the root level.
+ /// The Microsoft Access table name. Type:
+ /// string (or Expression with resultType string).
+ public MicrosoftAccessTableDataset(LinkedServiceReference linkedServiceName, IDictionary additionalProperties = default(IDictionary), string description = default(string), object structure = default(object), object schema = default(object), IDictionary parameters = default(IDictionary), IList annotations = default(IList), DatasetFolder folder = default(DatasetFolder), object tableName = default(object))
+ : base(linkedServiceName, additionalProperties, description, structure, schema, parameters, annotations, folder)
+ {
+ TableName = tableName;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the Microsoft Access table name. Type: string (or
+ /// Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.tableName")]
+ public object TableName { get; set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public override void Validate()
+ {
+ base.Validate();
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SSISAccessCredential.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SSISAccessCredential.cs
new file mode 100644
index 0000000000000..79818e92cc1ef
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SSISAccessCredential.cs
@@ -0,0 +1,93 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Microsoft.Rest;
+ using Newtonsoft.Json;
+ using System.Linq;
+
+ ///
+ /// SSIS access credential.
+ ///
+ public partial class SSISAccessCredential
+ {
+ ///
+ /// Initializes a new instance of the SSISAccessCredential class.
+ ///
+ public SSISAccessCredential()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the SSISAccessCredential class.
+ ///
+ /// Domain for windows authentication.
+ /// UseName for windows authentication.
+ /// Password for windows authentication.
+ public SSISAccessCredential(object domain, object userName, SecureString password)
+ {
+ Domain = domain;
+ UserName = userName;
+ Password = password;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets domain for windows authentication.
+ ///
+ [JsonProperty(PropertyName = "domain")]
+ public object Domain { get; set; }
+
+ ///
+ /// Gets or sets useName for windows authentication.
+ ///
+ [JsonProperty(PropertyName = "userName")]
+ public object UserName { get; set; }
+
+ ///
+ /// Gets or sets password for windows authentication.
+ ///
+ [JsonProperty(PropertyName = "password")]
+ public SecureString Password { get; set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public virtual void Validate()
+ {
+ if (Domain == null)
+ {
+ throw new ValidationException(ValidationRules.CannotBeNull, "Domain");
+ }
+ if (UserName == null)
+ {
+ throw new ValidationException(ValidationRules.CannotBeNull, "UserName");
+ }
+ if (Password == null)
+ {
+ throw new ValidationException(ValidationRules.CannotBeNull, "Password");
+ }
+ if (Password != null)
+ {
+ Password.Validate();
+ }
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SSISLogLocation.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SSISLogLocation.cs
new file mode 100644
index 0000000000000..39c5ad5cb5afc
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SSISLogLocation.cs
@@ -0,0 +1,109 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Microsoft.Rest;
+ using Microsoft.Rest.Serialization;
+ using Newtonsoft.Json;
+ using System.Linq;
+
+ ///
+ /// SSIS package execution log location
+ ///
+ [Rest.Serialization.JsonTransformation]
+ public partial class SSISLogLocation
+ {
+ ///
+ /// Initializes a new instance of the SSISLogLocation class.
+ ///
+ public SSISLogLocation()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the SSISLogLocation class.
+ ///
+ /// The SSIS package execution log path. Type:
+ /// string (or Expression with resultType string).
+ /// The package execution log access
+ /// credential.
+ /// Specifies the interval to refresh
+ /// log. The default interval is 5 minutes. Type: string (or Expression
+ /// with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ public SSISLogLocation(object logPath, SSISAccessCredential accessCredential = default(SSISAccessCredential), object logRefreshInterval = default(object))
+ {
+ LogPath = logPath;
+ AccessCredential = accessCredential;
+ LogRefreshInterval = logRefreshInterval;
+ CustomInit();
+ }
+ ///
+ /// Static constructor for SSISLogLocation class.
+ ///
+ static SSISLogLocation()
+ {
+ Type = "File";
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the SSIS package execution log path. Type: string (or
+ /// Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "logPath")]
+ public object LogPath { get; set; }
+
+ ///
+ /// Gets or sets the package execution log access credential.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.accessCredential")]
+ public SSISAccessCredential AccessCredential { get; set; }
+
+ ///
+ /// Gets or sets specifies the interval to refresh log. The default
+ /// interval is 5 minutes. Type: string (or Expression with resultType
+ /// string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.logRefreshInterval")]
+ public object LogRefreshInterval { get; set; }
+
+ ///
+ /// The type of SSIS log location.
+ ///
+ [JsonProperty(PropertyName = "type")]
+ public static string Type { get; private set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public virtual void Validate()
+ {
+ if (LogPath == null)
+ {
+ throw new ValidationException(ValidationRules.CannotBeNull, "LogPath");
+ }
+ if (AccessCredential != null)
+ {
+ AccessCredential.Validate();
+ }
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SalesforceServiceCloudLinkedService.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SalesforceServiceCloudLinkedService.cs
new file mode 100644
index 0000000000000..6146660aedd0e
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SalesforceServiceCloudLinkedService.cs
@@ -0,0 +1,142 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Microsoft.Rest;
+ using Microsoft.Rest.Serialization;
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// Linked service for Salesforce Service Cloud.
+ ///
+ [Newtonsoft.Json.JsonObject("SalesforceServiceCloud")]
+ [Rest.Serialization.JsonTransformation]
+ public partial class SalesforceServiceCloudLinkedService : LinkedService
+ {
+ ///
+ /// Initializes a new instance of the
+ /// SalesforceServiceCloudLinkedService class.
+ ///
+ public SalesforceServiceCloudLinkedService()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the
+ /// SalesforceServiceCloudLinkedService class.
+ ///
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// The integration runtime reference.
+ /// Linked service description.
+ /// Parameters for linked service.
+ /// List of tags that can be used for
+ /// describing the linked service.
+ /// The URL of Salesforce Service Cloud
+ /// instance. Default is 'https://login.salesforce.com'. To copy data
+ /// from sandbox, specify 'https://test.salesforce.com'. To copy data
+ /// from custom domain, specify, for example,
+ /// 'https://[domain].my.salesforce.com'. Type: string (or Expression
+ /// with resultType string).
+ /// The username for Basic authentication of the
+ /// Salesforce instance. Type: string (or Expression with resultType
+ /// string).
+ /// The password for Basic authentication of the
+ /// Salesforce instance.
+ /// The security token is required to
+ /// remotely access Salesforce instance.
+ /// Extended properties appended to
+ /// the connection string. Type: string (or Expression with resultType
+ /// string).
+ /// The encrypted credential used for
+ /// authentication. Credentials are encrypted using the integration
+ /// runtime credential manager. Type: string (or Expression with
+ /// resultType string).
+ public SalesforceServiceCloudLinkedService(IDictionary additionalProperties = default(IDictionary), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary parameters = default(IDictionary), IList annotations = default(IList), object environmentUrl = default(object), object username = default(object), SecretBase password = default(SecretBase), SecretBase securityToken = default(SecretBase), object extendedProperties = default(object), object encryptedCredential = default(object))
+ : base(additionalProperties, connectVia, description, parameters, annotations)
+ {
+ EnvironmentUrl = environmentUrl;
+ Username = username;
+ Password = password;
+ SecurityToken = securityToken;
+ ExtendedProperties = extendedProperties;
+ EncryptedCredential = encryptedCredential;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the URL of Salesforce Service Cloud instance. Default
+ /// is 'https://login.salesforce.com'. To copy data from sandbox,
+ /// specify 'https://test.salesforce.com'. To copy data from custom
+ /// domain, specify, for example, 'https://[domain].my.salesforce.com'.
+ /// Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.environmentUrl")]
+ public object EnvironmentUrl { get; set; }
+
+ ///
+ /// Gets or sets the username for Basic authentication of the
+ /// Salesforce instance. Type: string (or Expression with resultType
+ /// string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.username")]
+ public object Username { get; set; }
+
+ ///
+ /// Gets or sets the password for Basic authentication of the
+ /// Salesforce instance.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.password")]
+ public SecretBase Password { get; set; }
+
+ ///
+ /// Gets or sets the security token is required to remotely access
+ /// Salesforce instance.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.securityToken")]
+ public SecretBase SecurityToken { get; set; }
+
+ ///
+ /// Gets or sets extended properties appended to the connection string.
+ /// Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.extendedProperties")]
+ public object ExtendedProperties { get; set; }
+
+ ///
+ /// Gets or sets the encrypted credential used for authentication.
+ /// Credentials are encrypted using the integration runtime credential
+ /// manager. Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.encryptedCredential")]
+ public object EncryptedCredential { get; set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public override void Validate()
+ {
+ base.Validate();
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SalesforceServiceCloudObjectDataset.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SalesforceServiceCloudObjectDataset.cs
new file mode 100644
index 0000000000000..9b5749e9939f1
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SalesforceServiceCloudObjectDataset.cs
@@ -0,0 +1,88 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Microsoft.Rest;
+ using Microsoft.Rest.Serialization;
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// The Salesforce Service Cloud object dataset.
+ ///
+ [Newtonsoft.Json.JsonObject("SalesforceServiceCloudObject")]
+ [Rest.Serialization.JsonTransformation]
+ public partial class SalesforceServiceCloudObjectDataset : Dataset
+ {
+ ///
+ /// Initializes a new instance of the
+ /// SalesforceServiceCloudObjectDataset class.
+ ///
+ public SalesforceServiceCloudObjectDataset()
+ {
+ LinkedServiceName = new LinkedServiceReference();
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the
+ /// SalesforceServiceCloudObjectDataset class.
+ ///
+ /// Linked service reference.
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Dataset description.
+ /// Columns that define the structure of the
+ /// dataset. Type: array (or Expression with resultType array),
+ /// itemType: DatasetDataElement.
+ /// Columns that define the physical type schema
+ /// of the dataset. Type: array (or Expression with resultType array),
+ /// itemType: DatasetSchemaDataElement.
+ /// Parameters for dataset.
+ /// List of tags that can be used for
+ /// describing the Dataset.
+ /// The folder that this Dataset is in. If not
+ /// specified, Dataset will appear at the root level.
+ /// The Salesforce Service Cloud object API
+ /// name. Type: string (or Expression with resultType string).
+ public SalesforceServiceCloudObjectDataset(LinkedServiceReference linkedServiceName, IDictionary additionalProperties = default(IDictionary), string description = default(string), object structure = default(object), object schema = default(object), IDictionary parameters = default(IDictionary), IList annotations = default(IList), DatasetFolder folder = default(DatasetFolder), object objectApiName = default(object))
+ : base(linkedServiceName, additionalProperties, description, structure, schema, parameters, annotations, folder)
+ {
+ ObjectApiName = objectApiName;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the Salesforce Service Cloud object API name. Type:
+ /// string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.objectApiName")]
+ public object ObjectApiName { get; set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public override void Validate()
+ {
+ base.Validate();
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SalesforceServiceCloudSink.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SalesforceServiceCloudSink.cs
new file mode 100644
index 0000000000000..a260bddc659ce
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SalesforceServiceCloudSink.cs
@@ -0,0 +1,108 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// A copy activity Salesforce Service Cloud sink.
+ ///
+ public partial class SalesforceServiceCloudSink : CopySink
+ {
+ ///
+ /// Initializes a new instance of the SalesforceServiceCloudSink class.
+ ///
+ public SalesforceServiceCloudSink()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the SalesforceServiceCloudSink class.
+ ///
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Write batch size. Type: integer (or
+ /// Expression with resultType integer), minimum: 0.
+ /// Write batch timeout. Type: string
+ /// (or Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// Sink retry count. Type: integer (or
+ /// Expression with resultType integer).
+ /// Sink retry wait. Type: string (or
+ /// Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// The maximum concurrent
+ /// connection count for the sink data store. Type: integer (or
+ /// Expression with resultType integer).
+ /// The write behavior for the operation.
+ /// Default is Insert. Possible values include: 'Insert',
+ /// 'Upsert'
+ /// The name of the external ID field
+ /// for upsert operation. Default value is 'Id' column. Type: string
+ /// (or Expression with resultType string).
+ /// The flag indicating whether or not
+ /// to ignore null values from input dataset (except key fields) during
+ /// write operation. Default value is false. If set it to true, it
+ /// means ADF will leave the data in the destination object unchanged
+ /// when doing upsert/update operation and insert defined default value
+ /// when doing insert operation, versus ADF will update the data in the
+ /// destination object to NULL when doing upsert/update operation and
+ /// insert NULL value when doing insert operation. Type: boolean (or
+ /// Expression with resultType boolean).
+ public SalesforceServiceCloudSink(IDictionary additionalProperties = default(IDictionary), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), string writeBehavior = default(string), object externalIdFieldName = default(object), object ignoreNullValues = default(object))
+ : base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections)
+ {
+ WriteBehavior = writeBehavior;
+ ExternalIdFieldName = externalIdFieldName;
+ IgnoreNullValues = ignoreNullValues;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the write behavior for the operation. Default is
+ /// Insert. Possible values include: 'Insert', 'Upsert'
+ ///
+ [JsonProperty(PropertyName = "writeBehavior")]
+ public string WriteBehavior { get; set; }
+
+ ///
+ /// Gets or sets the name of the external ID field for upsert
+ /// operation. Default value is 'Id' column. Type: string (or
+ /// Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "externalIdFieldName")]
+ public object ExternalIdFieldName { get; set; }
+
+ ///
+ /// Gets or sets the flag indicating whether or not to ignore null
+ /// values from input dataset (except key fields) during write
+ /// operation. Default value is false. If set it to true, it means ADF
+ /// will leave the data in the destination object unchanged when doing
+ /// upsert/update operation and insert defined default value when doing
+ /// insert operation, versus ADF will update the data in the
+ /// destination object to NULL when doing upsert/update operation and
+ /// insert NULL value when doing insert operation. Type: boolean (or
+ /// Expression with resultType boolean).
+ ///
+ [JsonProperty(PropertyName = "ignoreNullValues")]
+ public object IgnoreNullValues { get; set; }
+
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SalesforceServiceCloudSource.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SalesforceServiceCloudSource.cs
new file mode 100644
index 0000000000000..5c5b32584e0a3
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SalesforceServiceCloudSource.cs
@@ -0,0 +1,79 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// A copy activity Salesforce Service Cloud source.
+ ///
+ public partial class SalesforceServiceCloudSource : CopySource
+ {
+ ///
+ /// Initializes a new instance of the SalesforceServiceCloudSource
+ /// class.
+ ///
+ public SalesforceServiceCloudSource()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the SalesforceServiceCloudSource
+ /// class.
+ ///
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Source retry count. Type: integer
+ /// (or Expression with resultType integer).
+ /// Source retry wait. Type: string (or
+ /// Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// The maximum concurrent
+ /// connection count for the source data store. Type: integer (or
+ /// Expression with resultType integer).
+ /// Database query. Type: string (or Expression
+ /// with resultType string).
+ /// The read behavior for the operation.
+ /// Default is Query. Possible values include: 'Query',
+ /// 'QueryAll'
+ public SalesforceServiceCloudSource(IDictionary additionalProperties = default(IDictionary), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object query = default(object), string readBehavior = default(string))
+ : base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections)
+ {
+ Query = query;
+ ReadBehavior = readBehavior;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets database query. Type: string (or Expression with
+ /// resultType string).
+ ///
+ [JsonProperty(PropertyName = "query")]
+ public object Query { get; set; }
+
+ ///
+ /// Gets or sets the read behavior for the operation. Default is Query.
+ /// Possible values include: 'Query', 'QueryAll'
+ ///
+ [JsonProperty(PropertyName = "readBehavior")]
+ public string ReadBehavior { get; set; }
+
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlMISink.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlMISink.cs
new file mode 100644
index 0000000000000..5044366f301ff
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlMISink.cs
@@ -0,0 +1,112 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// A copy activity Azure SQL Managed Instance sink.
+ ///
+ public partial class SqlMISink : CopySink
+ {
+ ///
+ /// Initializes a new instance of the SqlMISink class.
+ ///
+ public SqlMISink()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the SqlMISink class.
+ ///
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Write batch size. Type: integer (or
+ /// Expression with resultType integer), minimum: 0.
+ /// Write batch timeout. Type: string
+ /// (or Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// Sink retry count. Type: integer (or
+ /// Expression with resultType integer).
+ /// Sink retry wait. Type: string (or
+ /// Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// The maximum concurrent
+ /// connection count for the sink data store. Type: integer (or
+ /// Expression with resultType integer).
+ /// SQL writer stored
+ /// procedure name. Type: string (or Expression with resultType
+ /// string).
+ /// SQL writer table type. Type:
+ /// string (or Expression with resultType string).
+ /// SQL pre-copy script. Type: string (or
+ /// Expression with resultType string).
+ /// SQL stored procedure
+ /// parameters.
+ /// The stored
+ /// procedure parameter name of the table type. Type: string (or
+ /// Expression with resultType string).
+ public SqlMISink(IDictionary additionalProperties = default(IDictionary), object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object maxConcurrentConnections = default(object), object sqlWriterStoredProcedureName = default(object), object sqlWriterTableType = default(object), object preCopyScript = default(object), IDictionary storedProcedureParameters = default(IDictionary), object storedProcedureTableTypeParameterName = default(object))
+ : base(additionalProperties, writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait, maxConcurrentConnections)
+ {
+ SqlWriterStoredProcedureName = sqlWriterStoredProcedureName;
+ SqlWriterTableType = sqlWriterTableType;
+ PreCopyScript = preCopyScript;
+ StoredProcedureParameters = storedProcedureParameters;
+ StoredProcedureTableTypeParameterName = storedProcedureTableTypeParameterName;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets SQL writer stored procedure name. Type: string (or
+ /// Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "sqlWriterStoredProcedureName")]
+ public object SqlWriterStoredProcedureName { get; set; }
+
+ ///
+ /// Gets or sets SQL writer table type. Type: string (or Expression
+ /// with resultType string).
+ ///
+ [JsonProperty(PropertyName = "sqlWriterTableType")]
+ public object SqlWriterTableType { get; set; }
+
+ ///
+ /// Gets or sets SQL pre-copy script. Type: string (or Expression with
+ /// resultType string).
+ ///
+ [JsonProperty(PropertyName = "preCopyScript")]
+ public object PreCopyScript { get; set; }
+
+ ///
+ /// Gets or sets SQL stored procedure parameters.
+ ///
+ [JsonProperty(PropertyName = "storedProcedureParameters")]
+ public IDictionary StoredProcedureParameters { get; set; }
+
+ ///
+ /// Gets or sets the stored procedure parameter name of the table type.
+ /// Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "storedProcedureTableTypeParameterName")]
+ public object StoredProcedureTableTypeParameterName { get; set; }
+
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlMISource.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlMISource.cs
new file mode 100644
index 0000000000000..4cd48599b4c57
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SqlMISource.cs
@@ -0,0 +1,100 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// A copy activity Azure SQL Managed Instance source.
+ ///
+ public partial class SqlMISource : CopySource
+ {
+ ///
+ /// Initializes a new instance of the SqlMISource class.
+ ///
+ public SqlMISource()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the SqlMISource class.
+ ///
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Source retry count. Type: integer
+ /// (or Expression with resultType integer).
+ /// Source retry wait. Type: string (or
+ /// Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// The maximum concurrent
+ /// connection count for the source data store. Type: integer (or
+ /// Expression with resultType integer).
+ /// SQL reader query. Type: string (or
+ /// Expression with resultType string).
+ /// Name of the stored
+ /// procedure for a Azure SQL Managed Instance source. This cannot be
+ /// used at the same time as SqlReaderQuery. Type: string (or
+ /// Expression with resultType string).
+ /// Value and type setting for
+ /// stored procedure parameters. Example: "{Parameter1: {value: "1",
+ /// type: "int"}}".
+ /// Which additional types to
+ /// produce.
+ public SqlMISource(IDictionary additionalProperties = default(IDictionary), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object sqlReaderQuery = default(object), object sqlReaderStoredProcedureName = default(object), IDictionary storedProcedureParameters = default(IDictionary), object produceAdditionalTypes = default(object))
+ : base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections)
+ {
+ SqlReaderQuery = sqlReaderQuery;
+ SqlReaderStoredProcedureName = sqlReaderStoredProcedureName;
+ StoredProcedureParameters = storedProcedureParameters;
+ ProduceAdditionalTypes = produceAdditionalTypes;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets SQL reader query. Type: string (or Expression with
+ /// resultType string).
+ ///
+ [JsonProperty(PropertyName = "sqlReaderQuery")]
+ public object SqlReaderQuery { get; set; }
+
+ ///
+ /// Gets or sets name of the stored procedure for a Azure SQL Managed
+ /// Instance source. This cannot be used at the same time as
+ /// SqlReaderQuery. Type: string (or Expression with resultType
+ /// string).
+ ///
+ [JsonProperty(PropertyName = "sqlReaderStoredProcedureName")]
+ public object SqlReaderStoredProcedureName { get; set; }
+
+ ///
+ /// Gets or sets value and type setting for stored procedure
+ /// parameters. Example: "{Parameter1: {value: "1", type: "int"}}".
+ ///
+ [JsonProperty(PropertyName = "storedProcedureParameters")]
+ public IDictionary StoredProcedureParameters { get; set; }
+
+ ///
+ /// Gets or sets which additional types to produce.
+ ///
+ [JsonProperty(PropertyName = "produceAdditionalTypes")]
+ public object ProduceAdditionalTypes { get; set; }
+
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SsisPackageLocation.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SsisPackageLocation.cs
index 0ca3385efe226..b15e46801a6df 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SsisPackageLocation.cs
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SsisPackageLocation.cs
@@ -11,12 +11,14 @@
namespace Microsoft.Azure.Management.DataFactory.Models
{
using Microsoft.Rest;
+ using Microsoft.Rest.Serialization;
using Newtonsoft.Json;
using System.Linq;
///
/// SSIS package location.
///
+ [Rest.Serialization.JsonTransformation]
public partial class SSISPackageLocation
{
///
@@ -32,9 +34,21 @@ public SSISPackageLocation()
///
/// The SSIS package path. Type: string (or
/// Expression with resultType string).
- public SSISPackageLocation(object packagePath)
+ /// The type of SSIS package location. Possible
+ /// values include: 'SSISDB', 'File'
+ /// Password of the package.
+ /// The package access
+ /// credential.
+ /// The configuration file of the
+ /// package execution. Type: string (or Expression with resultType
+ /// string).
+ public SSISPackageLocation(object packagePath, string type = default(string), SecureString packagePassword = default(SecureString), SSISAccessCredential accessCredential = default(SSISAccessCredential), object configurationPath = default(object))
{
PackagePath = packagePath;
+ Type = type;
+ PackagePassword = packagePassword;
+ AccessCredential = accessCredential;
+ ConfigurationPath = configurationPath;
CustomInit();
}
@@ -50,6 +64,32 @@ public SSISPackageLocation(object packagePath)
[JsonProperty(PropertyName = "packagePath")]
public object PackagePath { get; set; }
+ ///
+ /// Gets or sets the type of SSIS package location. Possible values
+ /// include: 'SSISDB', 'File'
+ ///
+ [JsonProperty(PropertyName = "type")]
+ public string Type { get; set; }
+
+ ///
+ /// Gets or sets password of the package.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.packagePassword")]
+ public SecureString PackagePassword { get; set; }
+
+ ///
+ /// Gets or sets the package access credential.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.accessCredential")]
+ public SSISAccessCredential AccessCredential { get; set; }
+
+ ///
+ /// Gets or sets the configuration file of the package execution. Type:
+ /// string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.configurationPath")]
+ public object ConfigurationPath { get; set; }
+
///
/// Validate the object.
///
@@ -62,6 +102,14 @@ public virtual void Validate()
{
throw new ValidationException(ValidationRules.CannotBeNull, "PackagePath");
}
+ if (PackagePassword != null)
+ {
+ PackagePassword.Validate();
+ }
+ if (AccessCredential != null)
+ {
+ AccessCredential.Validate();
+ }
}
}
}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SsisPackageLocationType.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SsisPackageLocationType.cs
new file mode 100644
index 0000000000000..ad8eb8fdd96c9
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/SsisPackageLocationType.cs
@@ -0,0 +1,22 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+
+ ///
+ /// Defines values for SsisPackageLocationType.
+ ///
+ public static class SsisPackageLocationType
+ {
+ public const string SSISDB = "SSISDB";
+ public const string File = "File";
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/TeradataLinkedService.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/TeradataLinkedService.cs
index 728a2672dcd5d..2e23330ead572 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/TeradataLinkedService.cs
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/TeradataLinkedService.cs
@@ -35,8 +35,6 @@ public TeradataLinkedService()
///
/// Initializes a new instance of the TeradataLinkedService class.
///
- /// Server name for connection. Type: string (or
- /// Expression with resultType string).
/// Unmatched properties from the
/// message are deserialized this collection
/// The integration runtime reference.
@@ -44,6 +42,10 @@ public TeradataLinkedService()
/// Parameters for linked service.
/// List of tags that can be used for
/// describing the linked service.
+ /// Teradata ODBC connection string.
+ /// Type: string, SecureString or AzureKeyVaultSecretReference.
+ /// Server name for connection. Type: string (or
+ /// Expression with resultType string).
/// AuthenticationType to be used for
/// connection. Possible values include: 'Basic', 'Windows'
/// Username for authentication. Type: string
@@ -53,9 +55,10 @@ public TeradataLinkedService()
/// authentication. Credentials are encrypted using the integration
/// runtime credential manager. Type: string (or Expression with
/// resultType string).
- public TeradataLinkedService(object server, IDictionary additionalProperties = default(IDictionary), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary parameters = default(IDictionary), IList annotations = default(IList), string authenticationType = default(string), object username = default(object), SecretBase password = default(SecretBase), object encryptedCredential = default(object))
+ public TeradataLinkedService(IDictionary additionalProperties = default(IDictionary), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), IDictionary parameters = default(IDictionary), IList annotations = default(IList), object connectionString = default(object), object server = default(object), string authenticationType = default(string), object username = default(object), SecretBase password = default(SecretBase), object encryptedCredential = default(object))
: base(additionalProperties, connectVia, description, parameters, annotations)
{
+ ConnectionString = connectionString;
Server = server;
AuthenticationType = authenticationType;
Username = username;
@@ -69,6 +72,13 @@ public TeradataLinkedService()
///
partial void CustomInit();
+ ///
+ /// Gets or sets teradata ODBC connection string. Type: string,
+ /// SecureString or AzureKeyVaultSecretReference.
+ ///
+ [JsonProperty(PropertyName = "typeProperties.connectionString")]
+ public object ConnectionString { get; set; }
+
///
/// Gets or sets server name for connection. Type: string (or
/// Expression with resultType string).
@@ -113,10 +123,6 @@ public TeradataLinkedService()
public override void Validate()
{
base.Validate();
- if (Server == null)
- {
- throw new ValidationException(ValidationRules.CannotBeNull, "Server");
- }
}
}
}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/TeradataPartitionOption.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/TeradataPartitionOption.cs
new file mode 100644
index 0000000000000..5522a89a5d790
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/TeradataPartitionOption.cs
@@ -0,0 +1,23 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+
+ ///
+ /// Defines values for TeradataPartitionOption.
+ ///
+ public static class TeradataPartitionOption
+ {
+ public const string None = "None";
+ public const string Hash = "Hash";
+ public const string DynamicRange = "DynamicRange";
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/TeradataPartitionSettings.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/TeradataPartitionSettings.cs
new file mode 100644
index 0000000000000..d1240a3941eb3
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/TeradataPartitionSettings.cs
@@ -0,0 +1,81 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Newtonsoft.Json;
+ using System.Linq;
+
+ ///
+ /// The settings that will be leveraged for teradata source partitioning.
+ ///
+ public partial class TeradataPartitionSettings
+ {
+ ///
+ /// Initializes a new instance of the TeradataPartitionSettings class.
+ ///
+ public TeradataPartitionSettings()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the TeradataPartitionSettings class.
+ ///
+ /// The name of the column that will
+ /// be used for proceeding range or hash partitioning. Type: string (or
+ /// Expression with resultType string).
+ /// The maximum value of column
+ /// specified in partitionColumnName that will be used for proceeding
+ /// range partitioning. Type: string (or Expression with resultType
+ /// string).
+ /// The minimum value of column
+ /// specified in partitionColumnName that will be used for proceeding
+ /// range partitioning. Type: string (or Expression with resultType
+ /// string).
+ public TeradataPartitionSettings(object partitionColumnName = default(object), object partitionUpperBound = default(object), object partitionLowerBound = default(object))
+ {
+ PartitionColumnName = partitionColumnName;
+ PartitionUpperBound = partitionUpperBound;
+ PartitionLowerBound = partitionLowerBound;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the name of the column that will be used for
+ /// proceeding range or hash partitioning. Type: string (or Expression
+ /// with resultType string).
+ ///
+ [JsonProperty(PropertyName = "partitionColumnName")]
+ public object PartitionColumnName { get; set; }
+
+ ///
+ /// Gets or sets the maximum value of column specified in
+ /// partitionColumnName that will be used for proceeding range
+ /// partitioning. Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "partitionUpperBound")]
+ public object PartitionUpperBound { get; set; }
+
+ ///
+ /// Gets or sets the minimum value of column specified in
+ /// partitionColumnName that will be used for proceeding range
+ /// partitioning. Type: string (or Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "partitionLowerBound")]
+ public object PartitionLowerBound { get; set; }
+
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/TeradataSource.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/TeradataSource.cs
new file mode 100644
index 0000000000000..ee7d9bd77d322
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/TeradataSource.cs
@@ -0,0 +1,88 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// A copy activity Teradata source.
+ ///
+ public partial class TeradataSource : CopySource
+ {
+ ///
+ /// Initializes a new instance of the TeradataSource class.
+ ///
+ public TeradataSource()
+ {
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the TeradataSource class.
+ ///
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Source retry count. Type: integer
+ /// (or Expression with resultType integer).
+ /// Source retry wait. Type: string (or
+ /// Expression with resultType string), pattern:
+ /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).
+ /// The maximum concurrent
+ /// connection count for the source data store. Type: integer (or
+ /// Expression with resultType integer).
+ /// Teradata query. Type: string (or Expression
+ /// with resultType string).
+ /// The partition mechanism that will be
+ /// used for teradata read in parallel. Possible values include:
+ /// 'None', 'Hash', 'DynamicRange'
+ /// The settings that will be leveraged
+ /// for teradata source partitioning.
+ public TeradataSource(IDictionary additionalProperties = default(IDictionary), object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object query = default(object), string partitionOption = default(string), TeradataPartitionSettings partitionSettings = default(TeradataPartitionSettings))
+ : base(additionalProperties, sourceRetryCount, sourceRetryWait, maxConcurrentConnections)
+ {
+ Query = query;
+ PartitionOption = partitionOption;
+ PartitionSettings = partitionSettings;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets teradata query. Type: string (or Expression with
+ /// resultType string).
+ ///
+ [JsonProperty(PropertyName = "query")]
+ public object Query { get; set; }
+
+ ///
+ /// Gets or sets the partition mechanism that will be used for teradata
+ /// read in parallel. Possible values include: 'None', 'Hash',
+ /// 'DynamicRange'
+ ///
+ [JsonProperty(PropertyName = "partitionOption")]
+ public string PartitionOption { get; set; }
+
+ ///
+ /// Gets or sets the settings that will be leveraged for teradata
+ /// source partitioning.
+ ///
+ [JsonProperty(PropertyName = "partitionSettings")]
+ public TeradataPartitionSettings PartitionSettings { get; set; }
+
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/TeradataTableDataset.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/TeradataTableDataset.cs
new file mode 100644
index 0000000000000..b89d0b37f4eba
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/Models/TeradataTableDataset.cs
@@ -0,0 +1,96 @@
+//
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for
+// license information.
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+ using Microsoft.Rest;
+ using Microsoft.Rest.Serialization;
+ using Newtonsoft.Json;
+ using System.Collections;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ ///
+ /// The Teradata database dataset.
+ ///
+ [Newtonsoft.Json.JsonObject("TeradataTable")]
+ [Rest.Serialization.JsonTransformation]
+ public partial class TeradataTableDataset : Dataset
+ {
+ ///
+ /// Initializes a new instance of the TeradataTableDataset class.
+ ///
+ public TeradataTableDataset()
+ {
+ LinkedServiceName = new LinkedServiceReference();
+ CustomInit();
+ }
+
+ ///
+ /// Initializes a new instance of the TeradataTableDataset class.
+ ///
+ /// Linked service reference.
+ /// Unmatched properties from the
+ /// message are deserialized this collection
+ /// Dataset description.
+ /// Columns that define the structure of the
+ /// dataset. Type: array (or Expression with resultType array),
+ /// itemType: DatasetDataElement.
+ /// Columns that define the physical type schema
+ /// of the dataset. Type: array (or Expression with resultType array),
+ /// itemType: DatasetSchemaDataElement.
+ /// Parameters for dataset.
+ /// List of tags that can be used for
+ /// describing the Dataset.
+ /// The folder that this Dataset is in. If not
+ /// specified, Dataset will appear at the root level.
+ /// The database name of Teradata. Type: string
+ /// (or Expression with resultType string).
+ /// The table name of Teradata. Type: string (or
+ /// Expression with resultType string).
+ public TeradataTableDataset(LinkedServiceReference linkedServiceName, IDictionary additionalProperties = default(IDictionary), string description = default(string), object structure = default(object), object schema = default(object), IDictionary parameters = default(IDictionary), IList annotations = default(IList), DatasetFolder folder = default(DatasetFolder), object database = default(object), object table = default(object))
+ : base(linkedServiceName, additionalProperties, description, structure, schema, parameters, annotations, folder)
+ {
+ Database = database;
+ Table = table;
+ CustomInit();
+ }
+
+ ///
+ /// An initialization method that performs custom operations like setting defaults
+ ///
+ partial void CustomInit();
+
+ ///
+ /// Gets or sets the database name of Teradata. Type: string (or
+ /// Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.database")]
+ public object Database { get; set; }
+
+ ///
+ /// Gets or sets the table name of Teradata. Type: string (or
+ /// Expression with resultType string).
+ ///
+ [JsonProperty(PropertyName = "typeProperties.table")]
+ public object Table { get; set; }
+
+ ///
+ /// Validate the object.
+ ///
+ ///
+ /// Thrown if validation fails
+ ///
+ public override void Validate()
+ {
+ base.Validate();
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/SdkInfo_DataFactoryManagementClient.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/SdkInfo_DataFactoryManagementClient.cs
new file mode 100644
index 0000000000000..afb3bebe6aa97
--- /dev/null
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Generated/SdkInfo_DataFactoryManagementClient.cs
@@ -0,0 +1,40 @@
+
+//
+// Code generated by Microsoft (R) AutoRest Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is
+// regenerated.
+//
+
+namespace Microsoft.Azure.Management.DataFactory
+{
+ using System;
+ using System.Collections.Generic;
+ using System.Linq;
+
+ internal static partial class SdkInfo
+ {
+ public static IEnumerable> ApiInfo_DataFactoryManagementClient
+ {
+ get
+ {
+ return new Tuple[]
+ {
+ new Tuple("DataFactory", "ActivityRuns", "2018-06-01"),
+ new Tuple("DataFactory", "Datasets", "2018-06-01"),
+ new Tuple("DataFactory", "ExposureControl", "2018-06-01"),
+ new Tuple("DataFactory", "Factories", "2018-06-01"),
+ new Tuple("DataFactory", "IntegrationRuntimeNodes", "2018-06-01"),
+ new Tuple("DataFactory", "IntegrationRuntimeObjectMetadata", "2018-06-01"),
+ new Tuple("DataFactory", "IntegrationRuntimes", "2018-06-01"),
+ new Tuple("DataFactory", "LinkedServices", "2018-06-01"),
+ new Tuple("DataFactory", "Operations", "2018-06-01"),
+ new Tuple("DataFactory", "PipelineRuns", "2018-06-01"),
+ new Tuple("DataFactory", "Pipelines", "2018-06-01"),
+ new Tuple("DataFactory", "RerunTriggers", "2018-06-01"),
+ new Tuple("DataFactory", "TriggerRuns", "2018-06-01"),
+ new Tuple("DataFactory", "Triggers", "2018-06-01"),
+ }.AsEnumerable();
+ }
+ }
+ }
+}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Microsoft.Azure.Management.DataFactory.csproj b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Microsoft.Azure.Management.DataFactory.csproj
index f9f18bea88588..54546b7ab60fe 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Microsoft.Azure.Management.DataFactory.csproj
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Microsoft.Azure.Management.DataFactory.csproj
@@ -5,11 +5,15 @@
Microsoft.Azure.Management.DataFactory
Azure Data Factory V2 is the data integration platform that goes beyond Azure Data Factory V1's orchestration and batch-processing of time-series data, with a general purpose app model supporting modern data warehousing patterns and scenarios, lift-and-shift SSIS, and data-driven SaaS applications. Compose and manage reliable and secure data integration workflows at scale. Use native ADF data connectors and Integration Runtimes to move and transform cloud and on-premises data that can be unstructured, semi-structured, and structured with Hadoop, Azure Data Lake, Spark, SQL Server, Cosmos DB and many other data platforms.
- 4.0.1
+ 4.1.0
Microsoft.Azure.Management.DataFactory
Microsoft Azure resource management;Data Factory;ADF;
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Properties/AssemblyInfo.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Properties/AssemblyInfo.cs
index 968cbddb96512..a510e37c15996 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Properties/AssemblyInfo.cs
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/Properties/AssemblyInfo.cs
@@ -6,8 +6,8 @@
[assembly: AssemblyTitle("Microsoft Azure Data Factory Management Library")]
[assembly: AssemblyDescription("Provides management functionality for Microsoft Azure Data Factory Resources.")]
-[assembly: AssemblyVersion("4.0.0.0")]
-[assembly: AssemblyFileVersion("4.0.1.0")]
+[assembly: AssemblyVersion("4.1.0.0")]
+[assembly: AssemblyFileVersion("4.1.0.0")]
[assembly: AssemblyConfiguration("")]
[assembly: AssemblyCompany("Microsoft")]
[assembly: AssemblyProduct("Microsoft Azure .NET SDK")]
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/changelog.md b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/changelog.md
index c92e9a7227d56..0e44cf042348e 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/changelog.md
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/src/changelog.md
@@ -2,7 +2,15 @@
## Current version
### Feature Additions
- - Added CopyTranslator.cs and TabularTranslator.cs to Extensions folder.
+
+## Version 4.1.0
+### Feature Additions
+### Breaking Changes
+- Fixed missing types CopyTranslator and TabularTranslator.
+- Added support in Copy for MicrosoftAccessTable, InformixTable, SalesforceServiceCloudObject, AzureSqlMITable, DynamicsCrmEntity, CommonDataServiceForAppsEntity, TeradataTable, Binary, which inhcludes their Dataset, Linked Service, CopySource, and CopySink types
+- Added TeradataTable CopySource support
+- Added logLocation property to ExecuteSSISPackageActivity
+- Added SSIS File system support by expanding SSISPackageLocation to support SSISDB and File location types
## Version 4.0.0
### Feature Additions
@@ -12,7 +20,7 @@
- Added support for parameterization to a number of properties
- The table name is not required anymore for AzureSqlTable, AzureSqlDWTable, SqlServerTable
- Added a new property dataProxyProperties to Integration Runtime
-- Added new SapTable Linked Services type
+- Added new SapTable Linked Services type
- Added types for Read and Write Connector settings in activities - AzureBlobStorageReadSettings, AzureBlobFSReadSettings, AzureDataLakeStoreReadSettings, AmazonS3ReadSettings, FileServerReadSettings, FtpReadSettings, SftpReadSettings, HttpReadSettings, HdfsReadSettings,
AzureBlobStorageWriteSettings, AzureBlobFSWriteSettings, AzureDataLakeStoreWriteSettings, FileServerWriteSettings, FormatReadSettings, DelimitedTextReadSettings, FormatWriteSettings, DelimitedTextWriteSettings
- Added new Copy sources - SapTableSource, SqlServerSource, AzureSqlSource
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/tests/JsonSamples/DatasetJsonSamples.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/tests/JsonSamples/DatasetJsonSamples.cs
index 36b8812d1f03c..2abd2ba812c57 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/tests/JsonSamples/DatasetJsonSamples.cs
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/tests/JsonSamples/DatasetJsonSamples.cs
@@ -82,6 +82,27 @@ public class DatasetJsonSamples : JsonSampleCollection
}
}
}
+";
+
+ [JsonSample]
+ public const string AzureSqlMITable = @"
+{
+ name: ""AzureSqlMITable"",
+ properties:
+ {
+ type: ""AzureSqlMITable"",
+ linkedServiceName:
+ {
+ referenceName : ""ls"",
+ type : ""LinkedServiceReference""
+ },
+ typeProperties:
+ {
+ schema: ""dbo"",
+ table: ""test""
+ }
+ }
+}
";
[JsonSample]
@@ -439,6 +460,25 @@ public class DatasetJsonSamples : JsonSampleCollection
}
}
}
+";
+ [JsonSample]
+ public const string SalesforceServiceCloudDataset = @"
+{
+ name: ""SalesforceServiceCloudDataset"",
+ properties:
+ {
+ type: ""SalesforceServiceCloudObject"",
+ typeProperties:
+ {
+ objectApiName: ""fakeObjectApiName""
+ },
+ linkedServiceName:
+ {
+ referenceName: ""SalesforceServiceCloudLinkedService"",
+ type: ""LinkedServiceReference""
+ }
+ }
+}
";
[JsonSample]
public const string BlobTableWithJsonArray = @"
@@ -1007,5 +1047,115 @@ public class DatasetJsonSamples : JsonSampleCollection
}
}
}";
+
+ [JsonSample]
+ public const string BinaryDataset = @"
+{
+ ""name"": ""BinaryDataset"",
+ ""properties"": {
+ ""type"": ""Binary"",
+ ""linkedServiceName"": {
+ ""referenceName"": ""AzureBlobStorageLinkedService"",
+ ""type"": ""LinkedServiceReference""
+ },
+ ""typeProperties"": {
+ ""location"": {
+ ""type"": ""AzureBlobStorageLocation"",
+ ""container"": ""ContainerName"",
+ ""folderPath"": ""dataflow/test/input"",
+ ""fileName"": ""data.parquet""
+ },
+ ""compression"": {
+ ""type"": ""Deflate"",
+ ""level"": ""Fastest""
+ }
+ }
+ }
+}";
+
+ [JsonSample]
+ public const string TeradataDataset = @"
+{
+ ""name"": ""TeradataDataset"",
+ ""properties"": {
+ ""type"": ""TeradataTable"",
+ ""linkedServiceName"": {
+ ""referenceName"": ""TeradataOdbcLinkedService"",
+ ""type"": ""LinkedServiceReference""
+ },
+ ""typeProperties"": {
+ ""database"": ""AdventureWorksDW2012"",
+ ""table"": ""DimAccount""
+ }
+ }
+}";
+
+ [JsonSample]
+ public const string DynamicsCrmEntity = @"
+{
+ ""name"": ""DynamicsCrmEntity"",
+ ""properties"": {
+ ""type"": ""DynamicsCrmEntity"",
+ ""typeProperties"": {
+ ""entityName"": ""test""
+ },
+ ""linkedServiceName"": {
+ ""referenceName"": ""exampleLinkedService"",
+ ""type"": ""LinkedServiceReference""
+ }
+ }
+}
+";
+
+ [JsonSample]
+ public const string CommonDataServiceForAppsEntity = @"
+{
+ ""name"": ""CommonDataServiceForAppsEntity"",
+ ""properties"": {
+ ""type"": ""CommonDataServiceForAppsEntity"",
+ ""typeProperties"": {
+ ""entityName"": ""test""
+ },
+ ""linkedServiceName"": {
+ ""referenceName"": ""exampleLinkedService"",
+ ""type"": ""LinkedServiceReference""
+ }
+ }
+}
+";
+
+ [JsonSample]
+ public const string InformixTable = @"
+{
+ ""name"": ""InformixTable"",
+ ""properties"": {
+ ""type"": ""InformixTable"",
+ ""typeProperties"": {
+ ""tableName"": ""test""
+ },
+ ""linkedServiceName"": {
+ ""referenceName"": ""exampleLinkedService"",
+ ""type"": ""LinkedServiceReference""
+ }
+ }
+}
+";
+
+ [JsonSample]
+ public const string MicrosoftAccessTable = @"
+{
+ ""name"": ""MicrosoftAccessTable"",
+ ""properties"": {
+ ""type"": ""MicrosoftAccessTable"",
+ ""typeProperties"": {
+ ""tableName"": ""test""
+ },
+ ""linkedServiceName"": {
+ ""referenceName"": ""exampleLinkedService"",
+ ""type"": ""LinkedServiceReference""
+ }
+ }
+}
+";
}
}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/tests/JsonSamples/LinkedServiceJsonSamples.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/tests/JsonSamples/LinkedServiceJsonSamples.cs
index e993995730ed4..c0070f04809c1 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/tests/JsonSamples/LinkedServiceJsonSamples.cs
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/tests/JsonSamples/LinkedServiceJsonSamples.cs
@@ -138,6 +138,29 @@ public class LinkedServiceJsonSamples : JsonSampleCollection
}
";
[JsonSample]
- public const string ForeachPipeline= @"
+ public const string ForeachPipeline = @"
{
""name"": ""MyForeachPipeline"",
""properties"": {
@@ -4089,5 +4089,296 @@ public class PipelineJsonSamples : JsonSampleCollection
]
}
}";
+
+ [JsonSample]
+ public const string CopyActivity_Binary_Binary = @"{
+ ""name"": ""MyPipeline"",
+ ""properties"": {
+ ""activities"": [
+ {
+ ""type"": ""Copy"",
+ ""typeProperties"": {
+ ""source"": {
+ ""type"": ""BinarySource"",
+ ""storeSettings"": {
+ ""type"": ""AzureDataLakeStoreReadSetting"",
+ ""recursive"": true,
+ ""enablePartitionDiscovery"": true
+ }
+ },
+ ""sink"": {
+ ""type"": ""BinarySink"",
+ ""storeSettings"": {
+ ""type"": ""AzureDataLakeStoreWriteSetting"",
+ ""maxConcurrentConnections"": 3,
+ ""copyBehavior"": ""PreserveHierarchy""
+ }
+ }
+ },
+ ""inputs"": [
+ {
+ ""referenceName"": ""exampleDataset"",
+ ""type"": ""DatasetReference""
+ }
+ ],
+ ""outputs"": [
+ {
+ ""referenceName"": ""exampleDataset"",
+ ""type"": ""DatasetReference""
+ }
+ ],
+ }
+ ]
+ }
+}";
+ [JsonSample]
+ public const string CopyActivity_Teradata_Binary = @"{
+ ""name"": ""MyPipeline"",
+ ""properties"": {
+ ""activities"": [
+ {
+ ""type"": ""Copy"",
+ ""typeProperties"": {
+ ""source"": {
+ ""type"": ""TeradataSource"",
+ ""partitionOption"": ""DynamicRange"",
+ ""partitionSettings"": {
+ ""partitionColumnName"": ""EmployeeKey"",
+ ""partitionUpperBound"": ""1"",
+ ""partitionLowerBound"": ""500""
+ }
+ },
+ ""sink"": {
+ ""type"": ""BinarySink"",
+ ""storeSettings"": {
+ ""type"": ""AzureDataLakeStoreWriteSetting"",
+ ""maxConcurrentConnections"": 3,
+ ""copyBehavior"": ""PreserveHierarchy""
+ }
+ }
+ },
+ ""inputs"": [
+ {
+ ""referenceName"": ""TeradataDataset"",
+ ""type"": ""DatasetReference""
+ }
+ ],
+ ""outputs"": [
+ {
+ ""referenceName"": ""exampleDataset"",
+ ""type"": ""DatasetReference""
+ }
+ ],
+ }
+ ]
+ }
+}";
+ [JsonSample]
+ public const string CopyActivity_SqlMI_SqlMI = @"{
+ ""name"": ""MyPipeline"",
+ ""properties"": {
+ ""activities"": [
+ {
+ ""type"": ""Copy"",
+ ""typeProperties"": {
+ ""source"": {
+ ""type"": ""SqlMISource"",
+ ""sqlReaderQuery"": ""select * from my_table""
+ },
+ ""sink"": {
+ ""type"": ""SqlMISink"",
+ ""sqlWriterTableType"": ""MarketingType"",
+ ""sqlWriterStoredProcedureName"": ""spOverwriteMarketing"",
+ ""storedProcedureParameters"": {
+ ""category"": {
+ ""value"": ""ProductA""
+ }
+ }
+ }
+ },
+ ""inputs"": [
+ {
+ ""referenceName"": ""SourceDataset"",
+ ""type"": ""DatasetReference""
+ }
+ ],
+ ""outputs"": [
+ {
+ ""referenceName"": ""SinkDataset"",
+ ""type"": ""DatasetReference""
+ }
+ ]
+ }
+ ]
+ }
+}";
+ [JsonSample]
+ public const string CopyActivity_SalesforceServiceCloud_SalesforceServiceCloud = @"{
+ ""name"": ""MyPipeline"",
+ ""properties"": {
+ ""activities"": [
+ {
+ ""type"": ""Copy"",
+ ""typeProperties"": {
+ ""source"": {
+ ""type"": ""SalesforceServiceCloudSource"",
+ ""query"": ""select * from my_table"",
+ ""readBehavior"": ""QueryAll""
+ },
+ ""sink"": {
+ ""type"": ""SalesforceServiceCloudSink"",
+ ""writeBehavior"": ""Upsert""
+ }
+ },
+ ""inputs"": [
+ {
+ ""referenceName"": ""SourceDataset"",
+ ""type"": ""DatasetReference""
+ }
+ ],
+ ""outputs"": [
+ {
+ ""referenceName"": ""SinkDataset"",
+ ""type"": ""DatasetReference""
+ }
+ ]
+ }
+ ]
+ }
+}";
+ [JsonSample]
+ public const string CopyActivity_DynamicsCrm_DynamicsCrm = @"{
+ ""name"": ""MyPipeline"",
+ ""properties"": {
+ ""activities"": [
+ {
+ ""type"": ""Copy"",
+ ""typeProperties"": {
+ ""source"": {
+ ""type"": ""DynamicsCrmSource"",
+ ""query"": ""FetchXML""
+ },
+ ""sink"": {
+ ""type"": ""DynamicsCrmSink"",
+ ""writeBehavior"": ""Upsert"",
+ ""writeBatchSize"": 5000,
+ ""ignoreNullValues"": true
+ }
+ },
+ ""inputs"": [
+ {
+ ""referenceName"": ""SourceDataset"",
+ ""type"": ""DatasetReference""
+ }
+ ],
+ ""outputs"": [
+ {
+ ""referenceName"": ""SinkDataset"",
+ ""type"": ""DatasetReference""
+ }
+ ]
+ }
+ ]
+ }
+}";
+ [JsonSample]
+ public const string CopyActivity_CommonDataServiceForApps_CommonDataServiceForApps = @"{
+ ""name"": ""MyPipeline"",
+ ""properties"": {
+ ""activities"": [
+ {
+ ""type"": ""Copy"",
+ ""typeProperties"": {
+ ""source"": {
+ ""type"": ""CommonDataServiceForAppsSource"",
+ ""query"": ""FetchXML""
+ },
+ ""sink"": {
+ ""type"": ""CommonDataServiceForAppsSink"",
+ ""writeBehavior"": ""Upsert"",
+ ""writeBatchSize"": 5000,
+ ""ignoreNullValues"": true
+ }
+ },
+ ""inputs"": [
+ {
+ ""referenceName"": ""SourceDataset"",
+ ""type"": ""DatasetReference""
+ }
+ ],
+ ""outputs"": [
+ {
+ ""referenceName"": ""SinkDataset"",
+ ""type"": ""DatasetReference""
+ }
+ ]
+ }
+ ]
+ }
+}";
+ [JsonSample]
+ public const string CopyActivity_Informix_Informix = @"{
+ ""name"": ""MyPipeline"",
+ ""properties"": {
+ ""activities"": [
+ {
+ ""type"": ""Copy"",
+ ""typeProperties"": {
+ ""source"": {
+ ""type"": ""InformixSource"",
+ ""query"": ""fake_query""
+ },
+ ""sink"": {
+ ""type"": ""InformixSink""
+ }
+ },
+ ""inputs"": [
+ {
+ ""referenceName"": ""SourceDataset"",
+ ""type"": ""DatasetReference""
+ }
+ ],
+ ""outputs"": [
+ {
+ ""referenceName"": ""SinkDataset"",
+ ""type"": ""DatasetReference""
+ }
+ ]
+ }
+ ]
+ }
+}";
+ [JsonSample]
+ public const string CopyActivity_MicrosoftAccess_MicrosoftAccess = @"{
+ ""name"": ""MyPipeline"",
+ ""properties"": {
+ ""activities"": [
+ {
+ ""type"": ""Copy"",
+ ""typeProperties"": {
+ ""source"": {
+ ""type"": ""MicrosoftAccessSource"",
+ ""query"": ""fake_query""
+ },
+ ""sink"": {
+ ""type"": ""MicrosoftAccessSink""
+ }
+ },
+ ""inputs"": [
+ {
+ ""referenceName"": ""SourceDataset"",
+ ""type"": ""DatasetReference""
+ }
+ ],
+ ""outputs"": [
+ {
+ ""referenceName"": ""SinkDataset"",
+ ""type"": ""DatasetReference""
+ }
+ ]
+ }
+ ]
+ }
+}";
}
}
diff --git a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/tests/UnitTests/ActivityTests.cs b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/tests/UnitTests/ActivityTests.cs
index 681244e6bf566..4aa8e2c921760 100644
--- a/sdk/datafactory/Microsoft.Azure.Management.DataFactory/tests/UnitTests/ActivityTests.cs
+++ b/sdk/datafactory/Microsoft.Azure.Management.DataFactory/tests/UnitTests/ActivityTests.cs
@@ -86,6 +86,7 @@ public void ExecuteSsisPackageActivity_SDKSample()
packageCMs["MyOledbCM"]["passWord"] = new SSISExecutionParameter() { Value = new SecureString() { Value = "123" } };
var propertyOverrides = new Dictionary();
propertyOverrides["\\package.dtsx\\maxparralcount"] = new SSISPropertyOverride() { Value = 3, IsSensitive = false };
+ var accessCredential = new SSISAccessCredential() { UserName = "user", Domain = "domain", Password = new SecureString() { Value = "123" } };
ExecuteSSISPackageActivity activity = new ExecuteSSISPackageActivity
{
Name = triggeredPipelineName,
@@ -95,7 +96,11 @@ public void ExecuteSsisPackageActivity_SDKSample()
EnvironmentPath = "./test",
PackageLocation = new SSISPackageLocation
{
- PackagePath = "myfolder/myproject/mypackage.dtsx"
+ Type = "File",
+ PackagePath = "\\\\Host\\share\\mypackage.dtsx",
+ ConfigurationPath = "\\\\Host\\share\\config.dtsConfig",
+ AccessCredential = accessCredential,
+ PackagePassword = new SecureString() { Value = "123" }
},
ConnectVia = new IntegrationRuntimeReference
{
@@ -105,7 +110,13 @@ public void ExecuteSsisPackageActivity_SDKSample()
PackageParameters = packageParameters,
ProjectConnectionManagers = projectCMs,
PackageConnectionManagers = packageCMs,
- PropertyOverrides = propertyOverrides
+ PropertyOverrides = propertyOverrides,
+ LogLocation = new SSISLogLocation()
+ {
+ LogPath = "\\\\Host\\share\\log",
+ AccessCredential = accessCredential,
+ LogRefreshInterval = "00:01:00"
+ }
};
var handler = new RecordedDelegatingHandler();
var client = this.CreateWorkflowClient(handler);