Skip to content

Commit e0ceef9

Browse files
Jingshu918Jingshu918
authored
[DataFactory]Supported Snowflake V2 in ADF (#24172)
1 parent 7290cd7 commit e0ceef9

20 files changed

+852
-57
lines changed

‎src/DataFactory/DataFactory.Management.Sdk/Generated/Models/AzureFunctionActivity.cs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -66,15 +66,15 @@ public AzureFunctionActivity()
6666

6767
/// <param name="headers">Represents the headers that will be sent to the request. For example, to
6868
/// set the language and type on a request: &#34;headers&#34; : { &#34;Accept-Language&#34;:
69-
/// &#34;en-us&#34;, &#34;Content-Type&#34;: &#34;application/json&#34; }. Type: dictionary (or
70-
/// Expression with resultType dictionary).
69+
/// &#34;en-us&#34;, &#34;Content-Type&#34;: &#34;application/json&#34; }. Type: string (or Expression
70+
/// with resultType string).
7171
/// </param>
7272

7373
/// <param name="body">Represents the payload that will be sent to the endpoint. Required for
7474
/// POST/PUT method, not allowed for GET method Type: string (or Expression
7575
/// with resultType string).
7676
/// </param>
77-
public AzureFunctionActivity(string name, string method, object functionName, System.Collections.Generic.IDictionary<string, object> additionalProperties = default(System.Collections.Generic.IDictionary<string, object>), string description = default(string), string state = default(string), string onInactiveMarkAs = default(string), System.Collections.Generic.IList<ActivityDependency> dependsOn = default(System.Collections.Generic.IList<ActivityDependency>), System.Collections.Generic.IList<UserProperty> userProperties = default(System.Collections.Generic.IList<UserProperty>), LinkedServiceReference linkedServiceName = default(LinkedServiceReference), ActivityPolicy policy = default(ActivityPolicy), object headers = default(object), object body = default(object))
77+
public AzureFunctionActivity(string name, string method, object functionName, System.Collections.Generic.IDictionary<string, object> additionalProperties = default(System.Collections.Generic.IDictionary<string, object>), string description = default(string), string state = default(string), string onInactiveMarkAs = default(string), System.Collections.Generic.IList<ActivityDependency> dependsOn = default(System.Collections.Generic.IList<ActivityDependency>), System.Collections.Generic.IList<UserProperty> userProperties = default(System.Collections.Generic.IList<UserProperty>), LinkedServiceReference linkedServiceName = default(LinkedServiceReference), ActivityPolicy policy = default(ActivityPolicy), System.Collections.Generic.IDictionary<string, string> headers = default(System.Collections.Generic.IDictionary<string, string>), object body = default(object))
7878

7979
: base(name, additionalProperties, description, state, onInactiveMarkAs, dependsOn, userProperties, linkedServiceName, policy)
8080
{
@@ -108,10 +108,10 @@ public AzureFunctionActivity()
108108
/// Gets or sets represents the headers that will be sent to the request. For
109109
/// example, to set the language and type on a request: &#34;headers&#34; : {
110110
/// &#34;Accept-Language&#34;: &#34;en-us&#34;, &#34;Content-Type&#34;: &#34;application/json&#34; }. Type:
111-
/// dictionary (or Expression with resultType dictionary).
111+
/// string (or Expression with resultType string).
112112
/// </summary>
113113
[Newtonsoft.Json.JsonProperty(PropertyName = "typeProperties.headers")]
114-
public object Headers {get; set; }
114+
public System.Collections.Generic.IDictionary<string, string> Headers {get; set; }
115115

116116
/// <summary>
117117
/// Gets or sets represents the payload that will be sent to the endpoint.

‎src/DataFactory/DataFactory.Management.Sdk/Generated/Models/AzureFunctionActivityTypeProperties.cs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -34,15 +34,15 @@ public AzureFunctionActivityTypeProperties()
3434

3535
/// <param name="headers">Represents the headers that will be sent to the request. For example, to
3636
/// set the language and type on a request: &#34;headers&#34; : { &#34;Accept-Language&#34;:
37-
/// &#34;en-us&#34;, &#34;Content-Type&#34;: &#34;application/json&#34; }. Type: dictionary (or
38-
/// Expression with resultType dictionary).
37+
/// &#34;en-us&#34;, &#34;Content-Type&#34;: &#34;application/json&#34; }. Type: string (or Expression
38+
/// with resultType string).
3939
/// </param>
4040

4141
/// <param name="body">Represents the payload that will be sent to the endpoint. Required for
4242
/// POST/PUT method, not allowed for GET method Type: string (or Expression
4343
/// with resultType string).
4444
/// </param>
45-
public AzureFunctionActivityTypeProperties(string method, object functionName, object headers = default(object), object body = default(object))
45+
public AzureFunctionActivityTypeProperties(string method, object functionName, System.Collections.Generic.IDictionary<string, string> headers = default(System.Collections.Generic.IDictionary<string, string>), object body = default(object))
4646

4747
{
4848
this.Method = method;
@@ -75,10 +75,10 @@ public AzureFunctionActivityTypeProperties()
7575
/// Gets or sets represents the headers that will be sent to the request. For
7676
/// example, to set the language and type on a request: &#34;headers&#34; : {
7777
/// &#34;Accept-Language&#34;: &#34;en-us&#34;, &#34;Content-Type&#34;: &#34;application/json&#34; }. Type:
78-
/// dictionary (or Expression with resultType dictionary).
78+
/// string (or Expression with resultType string).
7979
/// </summary>
8080
[Newtonsoft.Json.JsonProperty(PropertyName = "headers")]
81-
public object Headers {get; set; }
81+
public System.Collections.Generic.IDictionary<string, string> Headers {get; set; }
8282

8383
/// <summary>
8484
/// Gets or sets represents the payload that will be sent to the endpoint.

‎src/DataFactory/DataFactory.Management.Sdk/Generated/Models/SalesforceServiceCloudV2LinkedService.cs

Lines changed: 15 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,10 @@ public SalesforceServiceCloudV2LinkedService()
4747
/// resultType string).
4848
/// </param>
4949

50+
/// <param name="authenticationType">The authentication type to be used to connect to the Salesforce. Currently,
51+
/// we only support OAuth2ClientCredentials, it is also the default value
52+
/// </param>
53+
5054
/// <param name="clientId">The client Id for OAuth 2.0 Client Credentials Flow authentication of the
5155
/// Salesforce instance. Type: string (or Expression with resultType string).
5256
/// </param>
@@ -63,11 +67,12 @@ public SalesforceServiceCloudV2LinkedService()
6367
/// <param name="encryptedCredential">The encrypted credential used for authentication. Credentials are encrypted
6468
/// using the integration runtime credential manager. Type: string.
6569
/// </param>
66-
public SalesforceServiceCloudV2LinkedService(System.Collections.Generic.IDictionary<string, object> additionalProperties = default(System.Collections.Generic.IDictionary<string, object>), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), System.Collections.Generic.IDictionary<string, ParameterSpecification> parameters = default(System.Collections.Generic.IDictionary<string, ParameterSpecification>), System.Collections.Generic.IList<object> annotations = default(System.Collections.Generic.IList<object>), object environmentUrl = default(object), object clientId = default(object), SecretBase clientSecret = default(SecretBase), object apiVersion = default(object), string encryptedCredential = default(string))
70+
public SalesforceServiceCloudV2LinkedService(System.Collections.Generic.IDictionary<string, object> additionalProperties = default(System.Collections.Generic.IDictionary<string, object>), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), System.Collections.Generic.IDictionary<string, ParameterSpecification> parameters = default(System.Collections.Generic.IDictionary<string, ParameterSpecification>), System.Collections.Generic.IList<object> annotations = default(System.Collections.Generic.IList<object>), object environmentUrl = default(object), object authenticationType = default(object), object clientId = default(object), SecretBase clientSecret = default(SecretBase), object apiVersion = default(object), string encryptedCredential = default(string))
6771

6872
: base(additionalProperties, connectVia, description, parameters, annotations)
6973
{
7074
this.EnvironmentUrl = environmentUrl;
75+
this.AuthenticationType = authenticationType;
7176
this.ClientId = clientId;
7277
this.ClientSecret = clientSecret;
7378
this.ApiVersion = apiVersion;
@@ -89,6 +94,14 @@ public SalesforceServiceCloudV2LinkedService()
8994
[Newtonsoft.Json.JsonProperty(PropertyName = "typeProperties.environmentUrl")]
9095
public object EnvironmentUrl {get; set; }
9196

97+
/// <summary>
98+
/// Gets or sets the authentication type to be used to connect to the
99+
/// Salesforce. Currently, we only support OAuth2ClientCredentials, it is also
100+
/// the default value
101+
/// </summary>
102+
[Newtonsoft.Json.JsonProperty(PropertyName = "typeProperties.authenticationType")]
103+
public object AuthenticationType {get; set; }
104+
92105
/// <summary>
93106
/// Gets or sets the client Id for OAuth 2.0 Client Credentials Flow
94107
/// authentication of the Salesforce instance. Type: string (or Expression with
@@ -133,6 +146,7 @@ public override void Validate()
133146

134147

135148

149+
136150
}
137151
}
138152
}

‎src/DataFactory/DataFactory.Management.Sdk/Generated/Models/SalesforceServiceCloudV2LinkedServiceTypeProperties.cs

Lines changed: 14 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,10 @@ public SalesforceServiceCloudV2LinkedServiceTypeProperties()
2929
/// resultType string).
3030
/// </param>
3131

32+
/// <param name="authenticationType">The authentication type to be used to connect to the Salesforce. Currently,
33+
/// we only support OAuth2ClientCredentials, it is also the default value
34+
/// </param>
35+
3236
/// <param name="clientId">The client Id for OAuth 2.0 Client Credentials Flow authentication of the
3337
/// Salesforce instance. Type: string (or Expression with resultType string).
3438
/// </param>
@@ -45,10 +49,11 @@ public SalesforceServiceCloudV2LinkedServiceTypeProperties()
4549
/// <param name="encryptedCredential">The encrypted credential used for authentication. Credentials are encrypted
4650
/// using the integration runtime credential manager. Type: string.
4751
/// </param>
48-
public SalesforceServiceCloudV2LinkedServiceTypeProperties(object environmentUrl = default(object), object clientId = default(object), SecretBase clientSecret = default(SecretBase), object apiVersion = default(object), string encryptedCredential = default(string))
52+
public SalesforceServiceCloudV2LinkedServiceTypeProperties(object environmentUrl = default(object), object authenticationType = default(object), object clientId = default(object), SecretBase clientSecret = default(SecretBase), object apiVersion = default(object), string encryptedCredential = default(string))
4953

5054
{
5155
this.EnvironmentUrl = environmentUrl;
56+
this.AuthenticationType = authenticationType;
5257
this.ClientId = clientId;
5358
this.ClientSecret = clientSecret;
5459
this.ApiVersion = apiVersion;
@@ -70,6 +75,14 @@ public SalesforceServiceCloudV2LinkedServiceTypeProperties()
7075
[Newtonsoft.Json.JsonProperty(PropertyName = "environmentUrl")]
7176
public object EnvironmentUrl {get; set; }
7277

78+
/// <summary>
79+
/// Gets or sets the authentication type to be used to connect to the
80+
/// Salesforce. Currently, we only support OAuth2ClientCredentials, it is also
81+
/// the default value
82+
/// </summary>
83+
[Newtonsoft.Json.JsonProperty(PropertyName = "authenticationType")]
84+
public object AuthenticationType {get; set; }
85+
7386
/// <summary>
7487
/// Gets or sets the client Id for OAuth 2.0 Client Credentials Flow
7588
/// authentication of the Salesforce instance. Type: string (or Expression with

‎src/DataFactory/DataFactory.Management.Sdk/Generated/Models/SalesforceServiceCloudV2Source.cs

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -43,20 +43,20 @@ public SalesforceServiceCloudV2Source()
4343
/// <param name="soqlQuery">Database query. Type: string (or Expression with resultType string).
4444
/// </param>
4545

46-
/// <param name="readBehavior">The read behavior for the operation. Default is query. Allowed values:
47-
/// query/queryAll. Type: string (or Expression with resultType string).
46+
/// <param name="includeDeletedObjects">This property control whether query result contains Deleted objects.
47+
/// Default is false. Type: boolean (or Expression with resultType boolean).
4848
/// </param>
4949

5050
/// <param name="additionalColumns">Specifies the additional columns to be added to source data. Type: array of
5151
/// objects(AdditionalColumns) (or Expression with resultType array of
5252
/// objects).
5353
/// </param>
54-
public SalesforceServiceCloudV2Source(object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object disableMetricsCollection = default(object), object soqlQuery = default(object), object readBehavior = default(object), object additionalColumns = default(object))
54+
public SalesforceServiceCloudV2Source(object sourceRetryCount = default(object), object sourceRetryWait = default(object), object maxConcurrentConnections = default(object), object disableMetricsCollection = default(object), object soqlQuery = default(object), object includeDeletedObjects = default(object), object additionalColumns = default(object))
5555

5656
: base(sourceRetryCount, sourceRetryWait, maxConcurrentConnections, disableMetricsCollection)
5757
{
5858
this.SoqlQuery = soqlQuery;
59-
this.ReadBehavior = readBehavior;
59+
this.IncludeDeletedObjects = includeDeletedObjects;
6060
this.AdditionalColumns = additionalColumns;
6161
CustomInit();
6262
}
@@ -75,12 +75,12 @@ public SalesforceServiceCloudV2Source()
7575
public object SoqlQuery {get; set; }
7676

7777
/// <summary>
78-
/// Gets or sets the read behavior for the operation. Default is query. Allowed
79-
/// values: query/queryAll. Type: string (or Expression with resultType
80-
/// string).
78+
/// Gets or sets this property control whether query result contains Deleted
79+
/// objects. Default is false. Type: boolean (or Expression with resultType
80+
/// boolean).
8181
/// </summary>
82-
[Newtonsoft.Json.JsonProperty(PropertyName = "readBehavior")]
83-
public object ReadBehavior {get; set; }
82+
[Newtonsoft.Json.JsonProperty(PropertyName = "includeDeletedObjects")]
83+
public object IncludeDeletedObjects {get; set; }
8484

8585
/// <summary>
8686
/// Gets or sets specifies the additional columns to be added to source data.

‎src/DataFactory/DataFactory.Management.Sdk/Generated/Models/SalesforceV2LinkedService.cs

Lines changed: 15 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,10 @@ public SalesforceV2LinkedService()
4747
/// resultType string).
4848
/// </param>
4949

50+
/// <param name="authenticationType">The authentication type to be used to connect to the Salesforce. Currently,
51+
/// we only support OAuth2ClientCredentials, it is also the default value
52+
/// </param>
53+
5054
/// <param name="clientId">The client Id for OAuth 2.0 Client Credentials Flow authentication of the
5155
/// Salesforce instance. Type: string (or Expression with resultType string).
5256
/// </param>
@@ -63,11 +67,12 @@ public SalesforceV2LinkedService()
6367
/// <param name="encryptedCredential">The encrypted credential used for authentication. Credentials are encrypted
6468
/// using the integration runtime credential manager. Type: string.
6569
/// </param>
66-
public SalesforceV2LinkedService(System.Collections.Generic.IDictionary<string, object> additionalProperties = default(System.Collections.Generic.IDictionary<string, object>), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), System.Collections.Generic.IDictionary<string, ParameterSpecification> parameters = default(System.Collections.Generic.IDictionary<string, ParameterSpecification>), System.Collections.Generic.IList<object> annotations = default(System.Collections.Generic.IList<object>), object environmentUrl = default(object), object clientId = default(object), SecretBase clientSecret = default(SecretBase), object apiVersion = default(object), string encryptedCredential = default(string))
70+
public SalesforceV2LinkedService(System.Collections.Generic.IDictionary<string, object> additionalProperties = default(System.Collections.Generic.IDictionary<string, object>), IntegrationRuntimeReference connectVia = default(IntegrationRuntimeReference), string description = default(string), System.Collections.Generic.IDictionary<string, ParameterSpecification> parameters = default(System.Collections.Generic.IDictionary<string, ParameterSpecification>), System.Collections.Generic.IList<object> annotations = default(System.Collections.Generic.IList<object>), object environmentUrl = default(object), object authenticationType = default(object), object clientId = default(object), SecretBase clientSecret = default(SecretBase), object apiVersion = default(object), string encryptedCredential = default(string))
6771

6872
: base(additionalProperties, connectVia, description, parameters, annotations)
6973
{
7074
this.EnvironmentUrl = environmentUrl;
75+
this.AuthenticationType = authenticationType;
7176
this.ClientId = clientId;
7277
this.ClientSecret = clientSecret;
7378
this.ApiVersion = apiVersion;
@@ -89,6 +94,14 @@ public SalesforceV2LinkedService()
8994
[Newtonsoft.Json.JsonProperty(PropertyName = "typeProperties.environmentUrl")]
9095
public object EnvironmentUrl {get; set; }
9196

97+
/// <summary>
98+
/// Gets or sets the authentication type to be used to connect to the
99+
/// Salesforce. Currently, we only support OAuth2ClientCredentials, it is also
100+
/// the default value
101+
/// </summary>
102+
[Newtonsoft.Json.JsonProperty(PropertyName = "typeProperties.authenticationType")]
103+
public object AuthenticationType {get; set; }
104+
92105
/// <summary>
93106
/// Gets or sets the client Id for OAuth 2.0 Client Credentials Flow
94107
/// authentication of the Salesforce instance. Type: string (or Expression with
@@ -133,6 +146,7 @@ public override void Validate()
133146

134147

135148

149+
136150
}
137151
}
138152
}

0 commit comments

Comments
 (0)