Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -825,6 +825,26 @@ public class DatasetJsonSamples : JsonSampleCollection<DatasetJsonSamples>
}
}
}
";

[JsonSample]
public const string SapEccResourceDataset = @"
{
name: ""SapEccResourceDataset"",
properties:
{
type: ""SapEccResource"",
linkedServiceName:
{
referenceName : ""ls"",
type : ""LinkedServiceReference""
},
typeProperties:
{
path: ""dd04tentitySet""
}
}
}
";
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -3148,5 +3148,55 @@ public class PipelineJsonSamples : JsonSampleCollection<PipelineJsonSamples>
]
}
}";

[JsonSample(version: "Copy")]
public const string CopySapEccToAdls = @"
{
name: ""MyPipelineName"",
properties:
{
description : ""Copy from SAP ECC to Azure Data Lake Store"",
activities:
[
{
type: ""Copy"",
name: ""TestActivity"",
description: ""Test activity description"",
typeProperties:
{
source:
{
type: ""SapEccSource"",
query: ""$top=1""
},
sink:
{
type: ""AzureDataLakeStoreSink"",
copyBehavior: ""FlattenHierarchy""
}
},
inputs:
[
{
referenceName: ""InputSapEcc"", type: ""DatasetReference""
}
],
outputs:
[
{
referenceName: ""OutputAdlsDA"", type: ""DatasetReference""
}
],
linkedServiceName: { referenceName: ""MyLinkedServiceName"", type: ""LinkedServiceReference"" },
policy:
{
retry: 3,
timeout: ""00:00:05"",
}
}
]
}
}
";
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,114 @@
// <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>
/// Linked service for SAP ERP Central Component(SAP ECC).
/// </summary>
[Newtonsoft.Json.JsonObject("SapEcc")]
[Rest.Serialization.JsonTransformation]
public partial class SapEccLinkedService : LinkedService
{
/// <summary>
/// Initializes a new instance of the SapEccLinkedService class.
/// </summary>
public SapEccLinkedService()
{
CustomInit();
}

/// <summary>
/// Initializes a new instance of the SapEccLinkedService class.
/// </summary>
/// <param name="url">The URL of SAP ECC OData API. For example,
/// '[https://hostname:port/sap/opu/odata/sap/servicename/]'. Type:
/// string (or Expression with resultType string).</param>
/// <param name="additionalProperties">Unmatched properties from the
/// message are deserialized this collection</param>
/// <param name="connectVia">The integration runtime reference.</param>
/// <param name="description">Linked service description.</param>
/// <param name="username">The username for Basic authentication. Type:
/// string (or Expression with resultType string).</param>
/// <param name="password">The password for Basic
/// authentication.</param>
/// <param name="encryptedCredential">The encrypted credential used for
/// authentication. Credentials are encrypted using the integration
/// runtime credential manager. Either encryptedCredential or
/// username/password must be provided. Type: string (or Expression
/// with resultType string).</param>
public SapEccLinkedService(string url, IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), string username = default(string), SecretBase password = default(SecretBase), string encryptedCredential = default(string))
: base(additionalProperties, connectVia, description)
{
Url = url;
Username = username;
Password = password;
EncryptedCredential = encryptedCredential;
CustomInit();
}

/// <summary>
/// An initialization method that performs custom operations like setting defaults
/// </summary>
partial void CustomInit();

/// <summary>
/// Gets or sets the URL of SAP ECC OData API. For example,
/// '[https://hostname:port/sap/opu/odata/sap/servicename/]'. Type:
/// string (or Expression with resultType string).
/// </summary>
[JsonProperty(PropertyName = "typeProperties.url")]
public string Url { get; set; }

/// <summary>
/// Gets or sets the username for Basic authentication. Type: string
/// (or Expression with resultType string).
/// </summary>
[JsonProperty(PropertyName = "typeProperties.username")]
public string Username { get; set; }

/// <summary>
/// Gets or sets the password for Basic authentication.
/// </summary>
[JsonProperty(PropertyName = "typeProperties.password")]
public SecretBase Password { get; set; }

/// <summary>
/// Gets or sets the encrypted credential used for authentication.
/// Credentials are encrypted using the integration runtime credential
/// manager. Either encryptedCredential or username/password must be
/// provided. Type: string (or Expression with resultType string).
/// </summary>
[JsonProperty(PropertyName = "typeProperties.encryptedCredential")]
public string EncryptedCredential { get; set; }

/// <summary>
/// Validate the object.
/// </summary>
/// <exception cref="ValidationException">
/// Thrown if validation fails
/// </exception>
public override void Validate()
{
base.Validate();
if (Url == null)
{
throw new ValidationException(ValidationRules.CannotBeNull, "Url");
}
}
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,83 @@
// <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 path of the SAP ECC OData entity.
/// </summary>
[Newtonsoft.Json.JsonObject("SapEccResource")]
[Rest.Serialization.JsonTransformation]
public partial class SapEccResourceDataset : Dataset
{
/// <summary>
/// Initializes a new instance of the SapEccResourceDataset class.
/// </summary>
public SapEccResourceDataset()
{
LinkedServiceName = new LinkedServiceReference();
CustomInit();
}

/// <summary>
/// Initializes a new instance of the SapEccResourceDataset class.
/// </summary>
/// <param name="linkedServiceName">Linked service reference.</param>
/// <param name="path">The path of the SAP ECC OData entity. Type:
/// string (or Expression with resultType string).</param>
/// <param name="additionalProperties">Unmatched properties from the
/// message are deserialized this collection</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>
public SapEccResourceDataset(LinkedServiceReference linkedServiceName, string path, IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), string description = default(string), object structure = default(object), IDictionary<string, ParameterSpecification> parameters = default(IDictionary<string, ParameterSpecification>))
: base(linkedServiceName, additionalProperties, description, structure, parameters)
{
Path = path;
CustomInit();
}

/// <summary>
/// An initialization method that performs custom operations like setting defaults
/// </summary>
partial void CustomInit();

/// <summary>
/// Gets or sets the path of the SAP ECC OData entity. Type: string (or
/// Expression with resultType string).
/// </summary>
[JsonProperty(PropertyName = "typeProperties.path")]
public string Path { get; set; }

/// <summary>
/// Validate the object.
/// </summary>
/// <exception cref="ValidationException">
/// Thrown if validation fails
/// </exception>
public override void Validate()
{
base.Validate();
if (Path == null)
{
throw new ValidationException(ValidationRules.CannotBeNull, "Path");
}
}
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,63 @@
// <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.Collections;
using System.Collections.Generic;
using System.Linq;

/// <summary>
/// A copy activity source for SAP ECC source.
/// </summary>
public partial class SapEccSource : CopySource
{
/// <summary>
/// Initializes a new instance of the SapEccSource class.
/// </summary>
public SapEccSource()
{
CustomInit();
}

/// <summary>
/// Initializes a new instance of the SapEccSource class.
/// </summary>
/// <param name="additionalProperties">Unmatched properties from the
/// message are deserialized this collection</param>
/// <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">SAP ECC OData query. For example, "$top=1".
/// Type: string (or Expression with resultType string).</param>
public SapEccSource(IDictionary<string, object> additionalProperties = default(IDictionary<string, object>), object sourceRetryCount = default(object), object sourceRetryWait = default(object), string query = default(string))
: base(additionalProperties, sourceRetryCount, sourceRetryWait)
{
Query = query;
CustomInit();
}

/// <summary>
/// An initialization method that performs custom operations like setting defaults
/// </summary>
partial void CustomInit();

/// <summary>
/// Gets or sets SAP ECC OData query. For example, "$top=1". Type:
/// string (or Expression with resultType string).
/// </summary>
[JsonProperty(PropertyName = "query")]
public string Query { get; set; }

}
}
5 changes: 5 additions & 0 deletions src/SDKs/DataFactory/Management.DataFactory/changelog.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,10 @@
# Changelog for the Azure Data Factory V2 .NET SDK

## Version 0.6.0-preview

### Feature Additions
* Add SAP ECC Source

## Version 0.5.0-preview

### Feature Additions
Expand Down