SDK changes and test samples for AzureMySql connector, including linkedservice, dataset and source.

src/SDKs/DataFactory/DataFactory.Tests/JsonSamples/DatasetJsonSamples.cs

@@ -401,6 +401,25 @@ public class DatasetJsonSamples : JsonSampleCollection<DatasetJsonSamples>
         }
     }
 }
+";
+        [JsonSample]
+        public const string AzureMySqlTable = @"
+{
+    name: ""AzureMySqlTable"",
+    properties:
+    {
+        type: ""AzureMySqlTable"",
+        linkedServiceName: 
+        {  
+            referenceName : ""ls"",
+            type : ""LinkedServiceReference""
+        },
+        typeProperties:
+        {            
+            tableName: ""$EncryptedString$MyEncryptedTableName""
+        }
+    }
+}
 ";
     }
 }

src/SDKs/DataFactory/DataFactory.Tests/JsonSamples/LinkedServiceJsonSamples.cs

@@ -810,5 +810,21 @@ public class LinkedServiceJsonSamples : JsonSampleCollection<LinkedServiceJsonSa
         }
     }
 }";
+
+        [JsonSample]
+        public const string AzureMySqlLinkedService = @"
+{
+    name: ""LinkedService-AzureMySQLDB"",
+    properties:
+    {
+        type: ""AzureMySql"",
+        typeProperties: {
+            connectionString: {
+                value : ""fakeConnString"",
+                type : ""SecureString""
+            }
+        }
+    }
+}";
     }
 }

src/SDKs/DataFactory/DataFactory.Tests/JsonSamples/PipelineJsonSamples.cs

@@ -2055,5 +2055,39 @@ public class PipelineJsonSamples : JsonSampleCollection<PipelineJsonSamples>
   }
 }";
 
+        [JsonSample(version: "Copy")]
+        public const string CopyAzureMySqlToBlob = @"{
+    name: ""AzureMySqlToBlobPipeline"",
+    properties: {
+        activities: [
+            {
+                name: ""CopyFromAzureMySqlToBlob"",
+                type: ""Copy"",
+                inputs: [
+                    {
+                        referenceName: ""AzureMySQLDataset"", type: ""DatasetReference""
+                    }
+                ],
+                outputs: [
+                    {
+                        referenceName: ""AzureBlobOut"", type: ""DatasetReference""
+                    }
+                ],
+                policy: {
+                },
+                typeProperties: {
+                    source: {
+                        type: ""AzureMySqlSource"",
+                        query:""select * from azuremysqltable""
+                    },
+                    sink: {
+                        type: ""BlobSink""
+                    }
+                }
+            }
+        ]
+    }
+}
+";
     }
 }

src/SDKs/DataFactory/Management.DataFactory/Generated/Models/AzureMySqlLinkedService.cs

@@ -0,0 +1,90 @@
+// <auto-generated>
+// 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.
+// </auto-generated>
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+    using Microsoft.Rest;
+    using Microsoft.Rest.Serialization;
+    using Newtonsoft.Json;
+    using System.Linq;
+
+    /// <summary>
+    /// Azure MySQL database linked service.
+    /// </summary>
+    [Newtonsoft.Json.JsonObject("AzureMySql")]
+    [Rest.Serialization.JsonTransformation]
+    public partial class AzureMySqlLinkedService : LinkedService
+    {
+        /// <summary>
+        /// Initializes a new instance of the AzureMySqlLinkedService class.
+        /// </summary>
+        public AzureMySqlLinkedService()
+        {
+            ConnectionString = new SecureString();
+            CustomInit();
+        }
+
+        /// <summary>
+        /// Initializes a new instance of the AzureMySqlLinkedService class.
+        /// </summary>
+        /// <param name="connectionString">The connection string.</param>
+        /// <param name="connectVia">The integration runtime reference.</param>
+        /// <param name="description">Linked service description.</param>
+        /// <param name="encryptedCredential">The encrypted credential used for
+        /// authentication. Credentials are encrypted using the integration
+        /// runtime credential manager. Type: string (or Expression with
+        /// resultType string).</param>
+        public AzureMySqlLinkedService(SecureString connectionString, IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), object encryptedCredential = default(object))
+            : base(connectVia, description)
+        {
+            ConnectionString = connectionString;
+            EncryptedCredential = encryptedCredential;
+            CustomInit();
+        }
+
+        /// <summary>
+        /// An initialization method that performs custom operations like setting defaults
+        /// </summary>
+        partial void CustomInit();
+
+        /// <summary>
+        /// Gets or sets the connection string.
+        /// </summary>
+        [JsonProperty(PropertyName = "typeProperties.connectionString")]
+        public SecureString ConnectionString { get; set; }
+
+        /// <summary>
+        /// 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).
+        /// </summary>
+        [JsonProperty(PropertyName = "typeProperties.encryptedCredential")]
+        public object EncryptedCredential { get; set; }
+
+        /// <summary>
+        /// Validate the object.
+        /// </summary>
+        /// <exception cref="ValidationException">
+        /// Thrown if validation fails
+        /// </exception>
+        public override void Validate()
+        {
+            base.Validate();
+            if (ConnectionString == null)
+            {
+                throw new ValidationException(ValidationRules.CannotBeNull, "ConnectionString");
+            }
+            if (ConnectionString != null)
+            {
+                ConnectionString.Validate();
+            }
+        }
+    }
+}

src/SDKs/DataFactory/Management.DataFactory/Generated/Models/AzureMySqlSource.cs

@@ -0,0 +1,59 @@
+// <auto-generated>
+// 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.
+// </auto-generated>
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+    using Newtonsoft.Json;
+    using System.Linq;
+
+    /// <summary>
+    /// A copy activity Azure MySQL source.
+    /// </summary>
+    public partial class AzureMySqlSource : CopySource
+    {
+        /// <summary>
+        /// Initializes a new instance of the AzureMySqlSource class.
+        /// </summary>
+        public AzureMySqlSource()
+        {
+            CustomInit();
+        }
+
+        /// <summary>
+        /// Initializes a new instance of the AzureMySqlSource class.
+        /// </summary>
+        /// <param name="sourceRetryCount">Source retry count. Type: integer
+        /// (or Expression with resultType integer).</param>
+        /// <param name="sourceRetryWait">Source retry wait. Type: string (or
+        /// Expression with resultType string), pattern:
+        /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).</param>
+        /// <param name="query">Database query. Type: string (or Expression
+        /// with resultType string).</param>
+        public AzureMySqlSource(object sourceRetryCount = default(object), object sourceRetryWait = default(object), object query = default(object))
+            : base(sourceRetryCount, sourceRetryWait)
+        {
+            Query = query;
+            CustomInit();
+        }
+
+        /// <summary>
+        /// An initialization method that performs custom operations like setting defaults
+        /// </summary>
+        partial void CustomInit();
+
+        /// <summary>
+        /// Gets or sets database query. Type: string (or Expression with
+        /// resultType string).
+        /// </summary>
+        [JsonProperty(PropertyName = "query")]
+        public object Query { get; set; }
+
+    }
+}

src/SDKs/DataFactory/Management.DataFactory/Generated/Models/AzureMySqlTableDataset.cs

@@ -0,0 +1,77 @@
+// <auto-generated>
+// 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.
+// </auto-generated>
+
+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;
+
+    /// <summary>
+    /// The Azure MySQL database dataset.
+    /// </summary>
+    [Newtonsoft.Json.JsonObject("AzureMySqlTable")]
+    [Rest.Serialization.JsonTransformation]
+    public partial class AzureMySqlTableDataset : Dataset
+    {
+        /// <summary>
+        /// Initializes a new instance of the AzureMySqlTableDataset class.
+        /// </summary>
+        public AzureMySqlTableDataset()
+        {
+            LinkedServiceName = new LinkedServiceReference();
+            CustomInit();
+        }
+
+        /// <summary>
+        /// Initializes a new instance of the AzureMySqlTableDataset class.
+        /// </summary>
+        /// <param name="linkedServiceName">Linked service reference.</param>
+        /// <param name="description">Dataset description.</param>
+        /// <param name="structure">Columns that define the structure of the
+        /// dataset. Type: array (or Expression with resultType array),
+        /// itemType: DatasetDataElement.</param>
+        /// <param name="parameters">Parameters for dataset.</param>
+        /// <param name="tableName">The Azure MySQL database table name. Type:
+        /// string (or Expression with resultType string).</param>
+        public AzureMySqlTableDataset(LinkedServiceReference linkedServiceName, string description = default(string), object structure = default(object), IDictionary<string, ParameterSpecification> parameters = default(IDictionary<string, ParameterSpecification>), object tableName = default(object))
+            : base(linkedServiceName, description, structure, parameters)
+        {
+            TableName = tableName;
+            CustomInit();
+        }
+
+        /// <summary>
+        /// An initialization method that performs custom operations like setting defaults
+        /// </summary>
+        partial void CustomInit();
+
+        /// <summary>
+        /// Gets or sets the Azure MySQL database table name. Type: string (or
+        /// Expression with resultType string).
+        /// </summary>
+        [JsonProperty(PropertyName = "typeProperties.tableName")]
+        public object TableName { get; set; }
+
+        /// <summary>
+        /// Validate the object.
+        /// </summary>
+        /// <exception cref="ValidationException">
+        /// Thrown if validation fails
+        /// </exception>
+        public override void Validate()
+        {
+            base.Validate();
+        }
+    }
+}

src/SDKs/DataFactory/Management.DataFactory/Generated/Models/DynamicsSink.cs

@@ -0,0 +1,80 @@
+// <auto-generated>
+// 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.
+// </auto-generated>
+
+namespace Microsoft.Azure.Management.DataFactory.Models
+{
+    using Newtonsoft.Json;
+    using System.Linq;
+
+    /// <summary>
+    /// A copy activity Dynamics sink.
+    /// </summary>
+    public partial class DynamicsSink : CopySink
+    {
+        /// <summary>
+        /// Initializes a new instance of the DynamicsSink class.
+        /// </summary>
+        public DynamicsSink()
+        {
+            CustomInit();
+        }
+
+        /// <summary>
+        /// Initializes a new instance of the DynamicsSink class.
+        /// </summary>
+        /// <param name="writeBatchSize">Write batch size. Type: integer (or
+        /// Expression with resultType integer), minimum: 0.</param>
+        /// <param name="writeBatchTimeout">Write batch timeout. Type: string
+        /// (or Expression with resultType string), pattern:
+        /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).</param>
+        /// <param name="sinkRetryCount">Sink retry count. Type: integer (or
+        /// Expression with resultType integer).</param>
+        /// <param name="sinkRetryWait">Sink retry wait. Type: string (or
+        /// Expression with resultType string), pattern:
+        /// ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])).</param>
+        /// <param name="ignoreNullValues">The flag indicating whether ignore
+        /// null values from input dataset (except key fields) during write
+        /// operation. Default is false. Type: boolean (or Expression with
+        /// resultType boolean).</param>
+        public DynamicsSink(object writeBatchSize = default(object), object writeBatchTimeout = default(object), object sinkRetryCount = default(object), object sinkRetryWait = default(object), object ignoreNullValues = default(object))
+            : base(writeBatchSize, writeBatchTimeout, sinkRetryCount, sinkRetryWait)
+        {
+            IgnoreNullValues = ignoreNullValues;
+            CustomInit();
+        }
+        /// <summary>
+        /// Static constructor for DynamicsSink class.
+        /// </summary>
+        static DynamicsSink()
+        {
+            WriteBehavior = "Upsert";
+        }
+
+        /// <summary>
+        /// An initialization method that performs custom operations like setting defaults
+        /// </summary>
+        partial void CustomInit();
+
+        /// <summary>
+        /// Gets or sets the flag indicating whether ignore null values from
+        /// input dataset (except key fields) during write operation. Default
+        /// is false. Type: boolean (or Expression with resultType boolean).
+        /// </summary>
+        [JsonProperty(PropertyName = "ignoreNullValues")]
+        public object IgnoreNullValues { get; set; }
+
+        /// <summary>
+        /// The write behavior for the operation.
+        /// </summary>
+        [JsonProperty(PropertyName = "writeBehavior")]
+        public static string WriteBehavior { get; private set; }
+
+    }
+}