diff --git a/sdk/datafactory/Azure.ResourceManager.DataFactory/api/Azure.ResourceManager.DataFactory.netstandard2.0.cs b/sdk/datafactory/Azure.ResourceManager.DataFactory/api/Azure.ResourceManager.DataFactory.netstandard2.0.cs index 9beaf9426c3a..7562a90ba734 100644 --- a/sdk/datafactory/Azure.ResourceManager.DataFactory/api/Azure.ResourceManager.DataFactory.netstandard2.0.cs +++ b/sdk/datafactory/Azure.ResourceManager.DataFactory/api/Azure.ResourceManager.DataFactory.netstandard2.0.cs @@ -200,8 +200,6 @@ public static partial class DataFactoryExtensions public static Azure.Response ConfigureFactoryRepoInformation(this Azure.ResourceManager.Resources.SubscriptionResource subscriptionResource, Azure.Core.AzureLocation locationId, Azure.ResourceManager.DataFactory.Models.FactoryRepoContent content, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } public static System.Threading.Tasks.Task> ConfigureFactoryRepoInformationAsync(this Azure.ResourceManager.Resources.SubscriptionResource subscriptionResource, Azure.Core.AzureLocation locationId, Azure.ResourceManager.DataFactory.Models.FactoryRepoContent content, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } public static Azure.ResourceManager.DataFactory.DataFactoryCollection GetDataFactories(this Azure.ResourceManager.Resources.ResourceGroupResource resourceGroupResource) { throw null; } - public static Azure.Pageable GetDataFactories(this Azure.ResourceManager.Resources.SubscriptionResource subscriptionResource, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } - public static Azure.AsyncPageable GetDataFactoriesAsync(this Azure.ResourceManager.Resources.SubscriptionResource subscriptionResource, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } public static Azure.Response GetDataFactory(this Azure.ResourceManager.Resources.ResourceGroupResource resourceGroupResource, string factoryName, string ifNoneMatch = null, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } public static System.Threading.Tasks.Task> GetDataFactoryAsync(this Azure.ResourceManager.Resources.ResourceGroupResource resourceGroupResource, string factoryName, string ifNoneMatch = null, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } public static Azure.ResourceManager.DataFactory.DataFactoryChangeDataCaptureResource GetDataFactoryChangeDataCaptureResource(this Azure.ResourceManager.ArmClient client, Azure.Core.ResourceIdentifier id) { throw null; } @@ -896,8 +894,6 @@ public partial class MockableDataFactorySubscriptionResource : Azure.ResourceMan protected MockableDataFactorySubscriptionResource() { } public virtual Azure.Response ConfigureFactoryRepoInformation(Azure.Core.AzureLocation locationId, Azure.ResourceManager.DataFactory.Models.FactoryRepoContent content, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } public virtual System.Threading.Tasks.Task> ConfigureFactoryRepoInformationAsync(Azure.Core.AzureLocation locationId, Azure.ResourceManager.DataFactory.Models.FactoryRepoContent content, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } - public virtual Azure.Pageable GetDataFactories(System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } - public virtual Azure.AsyncPageable GetDataFactoriesAsync(System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } public virtual Azure.Response GetFeatureValueExposureControl(Azure.Core.AzureLocation locationId, Azure.ResourceManager.DataFactory.Models.ExposureControlContent content, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } public virtual System.Threading.Tasks.Task> GetFeatureValueExposureControlAsync(Azure.Core.AzureLocation locationId, Azure.ResourceManager.DataFactory.Models.ExposureControlContent content, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) { throw null; } } @@ -9259,7 +9255,8 @@ protected override void JsonModelWriteCore(System.Text.Json.Utf8JsonWriter write } public partial class PostgreSqlV2LinkedService : Azure.ResourceManager.DataFactory.Models.DataFactoryLinkedServiceProperties, System.ClientModel.Primitives.IJsonModel, System.ClientModel.Primitives.IPersistableModel { - public PostgreSqlV2LinkedService(Azure.Core.Expressions.DataFactory.DataFactoryElement server, Azure.Core.Expressions.DataFactory.DataFactoryElement username, Azure.Core.Expressions.DataFactory.DataFactoryElement database, Azure.Core.Expressions.DataFactory.DataFactoryElement sslMode) { } + public PostgreSqlV2LinkedService(Azure.Core.Expressions.DataFactory.DataFactoryElement server, Azure.Core.Expressions.DataFactory.DataFactoryElement username, Azure.Core.Expressions.DataFactory.DataFactoryElement database, Azure.Core.Expressions.DataFactory.DataFactoryElement authenticationType, Azure.Core.Expressions.DataFactory.DataFactoryElement sslMode) { } + public Azure.Core.Expressions.DataFactory.DataFactoryElement AuthenticationType { get { throw null; } set { } } public Azure.Core.Expressions.DataFactory.DataFactoryElement CommandTimeout { get { throw null; } set { } } public Azure.Core.Expressions.DataFactory.DataFactoryElement ConnectionTimeout { get { throw null; } set { } } public Azure.Core.Expressions.DataFactory.DataFactoryElement Database { get { throw null; } set { } } @@ -10112,6 +10109,7 @@ public partial class SalesforceV2Source : Azure.ResourceManager.DataFactory.Mode { public SalesforceV2Source() { } public Azure.Core.Expressions.DataFactory.DataFactoryElement IncludeDeletedObjects { get { throw null; } set { } } + public Azure.Core.Expressions.DataFactory.DataFactoryElement PageSize { get { throw null; } set { } } public Azure.Core.Expressions.DataFactory.DataFactoryElement Query { get { throw null; } set { } } public Azure.Core.Expressions.DataFactory.DataFactoryElement SoqlQuery { get { throw null; } set { } } protected override void JsonModelWriteCore(System.Text.Json.Utf8JsonWriter writer, System.ClientModel.Primitives.ModelReaderWriterOptions options) { } @@ -10845,6 +10843,7 @@ public partial class ServiceNowV2Source : Azure.ResourceManager.DataFactory.Mode { public ServiceNowV2Source() { } public Azure.ResourceManager.DataFactory.Models.DataFactoryExpressionV2 Expression { get { throw null; } set { } } + public Azure.Core.Expressions.DataFactory.DataFactoryElement PageSize { get { throw null; } set { } } protected override void JsonModelWriteCore(System.Text.Json.Utf8JsonWriter writer, System.ClientModel.Primitives.ModelReaderWriterOptions options) { } Azure.ResourceManager.DataFactory.Models.ServiceNowV2Source System.ClientModel.Primitives.IJsonModel.Create(ref System.Text.Json.Utf8JsonReader reader, System.ClientModel.Primitives.ModelReaderWriterOptions options) { throw null; } void System.ClientModel.Primitives.IJsonModel.Write(System.Text.Json.Utf8JsonWriter writer, System.ClientModel.Primitives.ModelReaderWriterOptions options) { } @@ -11180,6 +11179,7 @@ public SnowflakeV2LinkedService(Azure.Core.Expressions.DataFactory.DataFactoryEl public Azure.Core.Expressions.DataFactory.DataFactorySecret ClientSecret { get { throw null; } set { } } public Azure.Core.Expressions.DataFactory.DataFactoryElement Database { get { throw null; } set { } } public string EncryptedCredential { get { throw null; } set { } } + public Azure.Core.Expressions.DataFactory.DataFactoryElement Host { get { throw null; } set { } } public Azure.Core.Expressions.DataFactory.DataFactorySecret Password { get { throw null; } set { } } public Azure.Core.Expressions.DataFactory.DataFactorySecret PrivateKey { get { throw null; } set { } } public Azure.Core.Expressions.DataFactory.DataFactorySecret PrivateKeyPassphrase { get { throw null; } set { } } diff --git a/sdk/datafactory/Azure.ResourceManager.DataFactory/samples/Generated/Samples/Sample_DataFactoryResource.cs b/sdk/datafactory/Azure.ResourceManager.DataFactory/samples/Generated/Samples/Sample_DataFactoryResource.cs index ae608baa3dea..94db6be7f296 100644 --- a/sdk/datafactory/Azure.ResourceManager.DataFactory/samples/Generated/Samples/Sample_DataFactoryResource.cs +++ b/sdk/datafactory/Azure.ResourceManager.DataFactory/samples/Generated/Samples/Sample_DataFactoryResource.cs @@ -18,38 +18,6 @@ namespace Azure.ResourceManager.DataFactory.Samples { public partial class Sample_DataFactoryResource { - // Factories_List - [NUnit.Framework.Test] - [NUnit.Framework.Ignore("Only verifying that the sample builds")] - public async Task GetDataFactories_FactoriesList() - { - // Generated from example definition: specification/datafactory/resource-manager/Microsoft.DataFactory/stable/2018-06-01/examples/Factories_List.json - // this example is just showing the usage of "Factories_List" operation, for the dependent resources, they will have to be created separately. - - // get your azure access token, for more details of how Azure SDK get your access token, please refer to https://learn.microsoft.com/en-us/dotnet/azure/sdk/authentication?tabs=command-line - TokenCredential cred = new DefaultAzureCredential(); - // authenticate your client - ArmClient client = new ArmClient(cred); - - // this example assumes you already have this SubscriptionResource created on azure - // for more information of creating SubscriptionResource, please refer to the document of SubscriptionResource - string subscriptionId = "12345678-1234-1234-1234-12345678abc"; - ResourceIdentifier subscriptionResourceId = SubscriptionResource.CreateResourceIdentifier(subscriptionId); - SubscriptionResource subscriptionResource = client.GetSubscriptionResource(subscriptionResourceId); - - // invoke the operation and iterate over the result - await foreach (DataFactoryResource item in subscriptionResource.GetDataFactoriesAsync()) - { - // the variable item is a resource, you could call other operations on this instance as well - // but just for demo, we get its data from this resource instance - DataFactoryData resourceData = item.Data; - // for demo we just print out the id - Console.WriteLine($"Succeeded on id: {resourceData.Id}"); - } - - Console.WriteLine($"Succeeded"); - } - // Factories_ConfigureFactoryRepo [NUnit.Framework.Test] [NUnit.Framework.Ignore("Only verifying that the sample builds")] diff --git a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Extensions/DataFactoryExtensions.cs b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Extensions/DataFactoryExtensions.cs index 74939b054294..a7fa1adf7f64 100644 --- a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Extensions/DataFactoryExtensions.cs +++ b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Extensions/DataFactoryExtensions.cs @@ -375,78 +375,6 @@ public static Response GetDataFactory(this ResourceGroupRes return GetMockableDataFactoryResourceGroupResource(resourceGroupResource).GetDataFactory(factoryName, ifNoneMatch, cancellationToken); } - /// - /// Lists factories under the specified subscription. - /// - /// - /// Request Path - /// /subscriptions/{subscriptionId}/providers/Microsoft.DataFactory/factories - /// - /// - /// Operation Id - /// Factories_List - /// - /// - /// Default Api Version - /// 2018-06-01 - /// - /// - /// Resource - /// - /// - /// - /// - /// Mocking - /// To mock this method, please mock instead. - /// - /// - /// The instance the method will execute against. - /// The cancellation token to use. - /// is null. - /// An async collection of that may take multiple service requests to iterate over. - public static AsyncPageable GetDataFactoriesAsync(this SubscriptionResource subscriptionResource, CancellationToken cancellationToken = default) - { - Argument.AssertNotNull(subscriptionResource, nameof(subscriptionResource)); - - return GetMockableDataFactorySubscriptionResource(subscriptionResource).GetDataFactoriesAsync(cancellationToken); - } - - /// - /// Lists factories under the specified subscription. - /// - /// - /// Request Path - /// /subscriptions/{subscriptionId}/providers/Microsoft.DataFactory/factories - /// - /// - /// Operation Id - /// Factories_List - /// - /// - /// Default Api Version - /// 2018-06-01 - /// - /// - /// Resource - /// - /// - /// - /// - /// Mocking - /// To mock this method, please mock instead. - /// - /// - /// The instance the method will execute against. - /// The cancellation token to use. - /// is null. - /// A collection of that may take multiple service requests to iterate over. - public static Pageable GetDataFactories(this SubscriptionResource subscriptionResource, CancellationToken cancellationToken = default) - { - Argument.AssertNotNull(subscriptionResource, nameof(subscriptionResource)); - - return GetMockableDataFactorySubscriptionResource(subscriptionResource).GetDataFactories(cancellationToken); - } - /// /// Updates a factory's repo information. /// diff --git a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Extensions/MockableDataFactorySubscriptionResource.cs b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Extensions/MockableDataFactorySubscriptionResource.cs index 26d7b48c8e23..0341ca6af197 100644 --- a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Extensions/MockableDataFactorySubscriptionResource.cs +++ b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Extensions/MockableDataFactorySubscriptionResource.cs @@ -8,7 +8,6 @@ using System; using System.Threading; using System.Threading.Tasks; -using Autorest.CSharp.Core; using Azure.Core; using Azure.Core.Pipeline; using Azure.ResourceManager.DataFactory.Models; @@ -46,66 +45,6 @@ private string GetApiVersionOrNull(ResourceType resourceType) return apiVersion; } - /// - /// Lists factories under the specified subscription. - /// - /// - /// Request Path - /// /subscriptions/{subscriptionId}/providers/Microsoft.DataFactory/factories - /// - /// - /// Operation Id - /// Factories_List - /// - /// - /// Default Api Version - /// 2018-06-01 - /// - /// - /// Resource - /// - /// - /// - /// - /// The cancellation token to use. - /// An async collection of that may take multiple service requests to iterate over. - public virtual AsyncPageable GetDataFactoriesAsync(CancellationToken cancellationToken = default) - { - HttpMessage FirstPageRequest(int? pageSizeHint) => DataFactoryFactoriesRestClient.CreateListRequest(Id.SubscriptionId); - HttpMessage NextPageRequest(int? pageSizeHint, string nextLink) => DataFactoryFactoriesRestClient.CreateListNextPageRequest(nextLink, Id.SubscriptionId); - return GeneratorPageableHelpers.CreateAsyncPageable(FirstPageRequest, NextPageRequest, e => new DataFactoryResource(Client, DataFactoryData.DeserializeDataFactoryData(e)), DataFactoryFactoriesClientDiagnostics, Pipeline, "MockableDataFactorySubscriptionResource.GetDataFactories", "value", "nextLink", cancellationToken); - } - - /// - /// Lists factories under the specified subscription. - /// - /// - /// Request Path - /// /subscriptions/{subscriptionId}/providers/Microsoft.DataFactory/factories - /// - /// - /// Operation Id - /// Factories_List - /// - /// - /// Default Api Version - /// 2018-06-01 - /// - /// - /// Resource - /// - /// - /// - /// - /// The cancellation token to use. - /// A collection of that may take multiple service requests to iterate over. - public virtual Pageable GetDataFactories(CancellationToken cancellationToken = default) - { - HttpMessage FirstPageRequest(int? pageSizeHint) => DataFactoryFactoriesRestClient.CreateListRequest(Id.SubscriptionId); - HttpMessage NextPageRequest(int? pageSizeHint, string nextLink) => DataFactoryFactoriesRestClient.CreateListNextPageRequest(nextLink, Id.SubscriptionId); - return GeneratorPageableHelpers.CreatePageable(FirstPageRequest, NextPageRequest, e => new DataFactoryResource(Client, DataFactoryData.DeserializeDataFactoryData(e)), DataFactoryFactoriesClientDiagnostics, Pipeline, "MockableDataFactorySubscriptionResource.GetDataFactories", "value", "nextLink", cancellationToken); - } - /// /// Updates a factory's repo information. /// diff --git a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/PostgreSqlV2LinkedService.Serialization.cs b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/PostgreSqlV2LinkedService.Serialization.cs index 963813ff62c1..ccaefe8e037d 100644 --- a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/PostgreSqlV2LinkedService.Serialization.cs +++ b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/PostgreSqlV2LinkedService.Serialization.cs @@ -49,6 +49,8 @@ protected override void JsonModelWriteCore(Utf8JsonWriter writer, ModelReaderWri JsonSerializer.Serialize(writer, Username); writer.WritePropertyName("database"u8); JsonSerializer.Serialize(writer, Database); + writer.WritePropertyName("authenticationType"u8); + JsonSerializer.Serialize(writer, AuthenticationType); writer.WritePropertyName("sslMode"u8); JsonSerializer.Serialize(writer, SslMode); if (Optional.IsDefined(Schema)) @@ -166,6 +168,7 @@ internal static PostgreSqlV2LinkedService DeserializePostgreSqlV2LinkedService(J DataFactoryElement port = default; DataFactoryElement username = default; DataFactoryElement database = default; + DataFactoryElement authenticationType = default; DataFactoryElement sslMode = default; DataFactoryElement schema = default; DataFactoryElement pooling = default; @@ -277,6 +280,11 @@ internal static PostgreSqlV2LinkedService DeserializePostgreSqlV2LinkedService(J database = JsonSerializer.Deserialize>(property0.Value.GetRawText()); continue; } + if (property0.NameEquals("authenticationType"u8)) + { + authenticationType = JsonSerializer.Deserialize>(property0.Value.GetRawText()); + continue; + } if (property0.NameEquals("sslMode"u8)) { sslMode = JsonSerializer.Deserialize>(property0.Value.GetRawText()); @@ -422,6 +430,7 @@ internal static PostgreSqlV2LinkedService DeserializePostgreSqlV2LinkedService(J port, username, database, + authenticationType, sslMode, schema, pooling, diff --git a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/PostgreSqlV2LinkedService.cs b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/PostgreSqlV2LinkedService.cs index 9cc6851dfd52..490ee849179d 100644 --- a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/PostgreSqlV2LinkedService.cs +++ b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/PostgreSqlV2LinkedService.cs @@ -18,18 +18,21 @@ public partial class PostgreSqlV2LinkedService : DataFactoryLinkedServicePropert /// Server name for connection. Type: string. /// Username for authentication. Type: string. /// Database name for connection. Type: string. + /// The authentication type to use. Type: string. /// SSL mode for connection. Type: integer. 0: disable, 1:allow, 2: prefer, 3: require, 4: verify-ca, 5: verify-full. Type: integer. - /// , , or is null. - public PostgreSqlV2LinkedService(DataFactoryElement server, DataFactoryElement username, DataFactoryElement database, DataFactoryElement sslMode) + /// , , , or is null. + public PostgreSqlV2LinkedService(DataFactoryElement server, DataFactoryElement username, DataFactoryElement database, DataFactoryElement authenticationType, DataFactoryElement sslMode) { Argument.AssertNotNull(server, nameof(server)); Argument.AssertNotNull(username, nameof(username)); Argument.AssertNotNull(database, nameof(database)); + Argument.AssertNotNull(authenticationType, nameof(authenticationType)); Argument.AssertNotNull(sslMode, nameof(sslMode)); Server = server; Username = username; Database = database; + AuthenticationType = authenticationType; SslMode = sslMode; LinkedServiceType = "PostgreSqlV2"; } @@ -46,6 +49,7 @@ public PostgreSqlV2LinkedService(DataFactoryElement server, DataFactoryE /// The port for the connection. Type: integer. /// Username for authentication. Type: string. /// Database name for connection. Type: string. + /// The authentication type to use. Type: string. /// SSL mode for connection. Type: integer. 0: disable, 1:allow, 2: prefer, 3: require, 4: verify-ca, 5: verify-full. Type: integer. /// Sets the schema search path. Type: string. /// Whether connection pooling should be used. Type: boolean. @@ -61,12 +65,13 @@ public PostgreSqlV2LinkedService(DataFactoryElement server, DataFactoryE /// Gets or sets the .NET encoding that will be used to encode/decode PostgreSQL string data. Type: string. /// The Azure key vault secret reference of password in connection string. Type: string. /// The encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string. - internal PostgreSqlV2LinkedService(string linkedServiceType, string linkedServiceVersion, IntegrationRuntimeReference connectVia, string description, IDictionary parameters, IList annotations, IDictionary additionalProperties, DataFactoryElement server, DataFactoryElement port, DataFactoryElement username, DataFactoryElement database, DataFactoryElement sslMode, DataFactoryElement schema, DataFactoryElement pooling, DataFactoryElement connectionTimeout, DataFactoryElement commandTimeout, DataFactoryElement trustServerCertificate, DataFactoryElement sslCertificate, DataFactoryElement sslKey, DataFactoryElement sslPassword, DataFactoryElement readBufferSize, DataFactoryElement logParameters, DataFactoryElement timezone, DataFactoryElement encoding, DataFactoryKeyVaultSecret password, string encryptedCredential) : base(linkedServiceType, linkedServiceVersion, connectVia, description, parameters, annotations, additionalProperties) + internal PostgreSqlV2LinkedService(string linkedServiceType, string linkedServiceVersion, IntegrationRuntimeReference connectVia, string description, IDictionary parameters, IList annotations, IDictionary additionalProperties, DataFactoryElement server, DataFactoryElement port, DataFactoryElement username, DataFactoryElement database, DataFactoryElement authenticationType, DataFactoryElement sslMode, DataFactoryElement schema, DataFactoryElement pooling, DataFactoryElement connectionTimeout, DataFactoryElement commandTimeout, DataFactoryElement trustServerCertificate, DataFactoryElement sslCertificate, DataFactoryElement sslKey, DataFactoryElement sslPassword, DataFactoryElement readBufferSize, DataFactoryElement logParameters, DataFactoryElement timezone, DataFactoryElement encoding, DataFactoryKeyVaultSecret password, string encryptedCredential) : base(linkedServiceType, linkedServiceVersion, connectVia, description, parameters, annotations, additionalProperties) { Server = server; Port = port; Username = username; Database = database; + AuthenticationType = authenticationType; SslMode = sslMode; Schema = schema; Pooling = pooling; @@ -98,6 +103,8 @@ internal PostgreSqlV2LinkedService() public DataFactoryElement Username { get; set; } /// Database name for connection. Type: string. public DataFactoryElement Database { get; set; } + /// The authentication type to use. Type: string. + public DataFactoryElement AuthenticationType { get; set; } /// SSL mode for connection. Type: integer. 0: disable, 1:allow, 2: prefer, 3: require, 4: verify-ca, 5: verify-full. Type: integer. public DataFactoryElement SslMode { get; set; } /// Sets the schema search path. Type: string. diff --git a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/SalesforceV2Source.Serialization.cs b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/SalesforceV2Source.Serialization.cs index b35d1969531f..e1d3746ab423 100644 --- a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/SalesforceV2Source.Serialization.cs +++ b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/SalesforceV2Source.Serialization.cs @@ -51,6 +51,11 @@ protected override void JsonModelWriteCore(Utf8JsonWriter writer, ModelReaderWri writer.WritePropertyName("includeDeletedObjects"u8); JsonSerializer.Serialize(writer, IncludeDeletedObjects); } + if (Optional.IsDefined(PageSize)) + { + writer.WritePropertyName("pageSize"u8); + JsonSerializer.Serialize(writer, PageSize); + } foreach (var item in AdditionalProperties) { writer.WritePropertyName(item.Key); @@ -88,6 +93,7 @@ internal static SalesforceV2Source DeserializeSalesforceV2Source(JsonElement ele DataFactoryElement soqlQuery = default; DataFactoryElement query = default; DataFactoryElement includeDeletedObjects = default; + DataFactoryElement pageSize = default; DataFactoryElement queryTimeout = default; BinaryData additionalColumns = default; string type = default; @@ -126,6 +132,15 @@ internal static SalesforceV2Source DeserializeSalesforceV2Source(JsonElement ele includeDeletedObjects = JsonSerializer.Deserialize>(property.Value.GetRawText()); continue; } + if (property.NameEquals("pageSize"u8)) + { + if (property.Value.ValueKind == JsonValueKind.Null) + { + continue; + } + pageSize = JsonSerializer.Deserialize>(property.Value.GetRawText()); + continue; + } if (property.NameEquals("queryTimeout"u8)) { if (property.Value.ValueKind == JsonValueKind.Null) @@ -199,7 +214,8 @@ internal static SalesforceV2Source DeserializeSalesforceV2Source(JsonElement ele additionalColumns, soqlQuery, query, - includeDeletedObjects); + includeDeletedObjects, + pageSize); } BinaryData IPersistableModel.Write(ModelReaderWriterOptions options) diff --git a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/SalesforceV2Source.cs b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/SalesforceV2Source.cs index 5b09cb5c1337..cc837f8609f5 100644 --- a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/SalesforceV2Source.cs +++ b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/SalesforceV2Source.cs @@ -32,11 +32,13 @@ public SalesforceV2Source() /// Deprecating, please use 'query' property instead. Type: string (or Expression with resultType string). /// You can only use Salesforce Object Query Language (SOQL) query with limitations. For SOQL limitations, see this article: https://developer.salesforce.com/docs/atlas.en-us.api_asynch.meta/api_asynch/queries.htm#SOQL%20Considerations. If query is not specified, all the data of the Salesforce object specified in ObjectApiName/reportId in dataset will be retrieved. Type: string (or Expression with resultType string). /// This property control whether query result contains Deleted objects. Default is false. Type: boolean (or Expression with resultType boolean). - internal SalesforceV2Source(string copySourceType, DataFactoryElement sourceRetryCount, DataFactoryElement sourceRetryWait, DataFactoryElement maxConcurrentConnections, DataFactoryElement disableMetricsCollection, IDictionary additionalProperties, DataFactoryElement queryTimeout, BinaryData additionalColumns, DataFactoryElement soqlQuery, DataFactoryElement query, DataFactoryElement includeDeletedObjects) : base(copySourceType, sourceRetryCount, sourceRetryWait, maxConcurrentConnections, disableMetricsCollection, additionalProperties, queryTimeout, additionalColumns) + /// Page size for each http request, too large pageSize will caused timeout, default 300,000. Type: integer (or Expression with resultType integer). + internal SalesforceV2Source(string copySourceType, DataFactoryElement sourceRetryCount, DataFactoryElement sourceRetryWait, DataFactoryElement maxConcurrentConnections, DataFactoryElement disableMetricsCollection, IDictionary additionalProperties, DataFactoryElement queryTimeout, BinaryData additionalColumns, DataFactoryElement soqlQuery, DataFactoryElement query, DataFactoryElement includeDeletedObjects, DataFactoryElement pageSize) : base(copySourceType, sourceRetryCount, sourceRetryWait, maxConcurrentConnections, disableMetricsCollection, additionalProperties, queryTimeout, additionalColumns) { SoqlQuery = soqlQuery; Query = query; IncludeDeletedObjects = includeDeletedObjects; + PageSize = pageSize; CopySourceType = copySourceType ?? "SalesforceV2Source"; } @@ -46,5 +48,7 @@ internal SalesforceV2Source(string copySourceType, DataFactoryElement sourc public DataFactoryElement Query { get; set; } /// This property control whether query result contains Deleted objects. Default is false. Type: boolean (or Expression with resultType boolean). public DataFactoryElement IncludeDeletedObjects { get; set; } + /// Page size for each http request, too large pageSize will caused timeout, default 300,000. Type: integer (or Expression with resultType integer). + public DataFactoryElement PageSize { get; set; } } } diff --git a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/ServiceNowV2Source.Serialization.cs b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/ServiceNowV2Source.Serialization.cs index 2d40098816e7..bb09bfbc9067 100644 --- a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/ServiceNowV2Source.Serialization.cs +++ b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/ServiceNowV2Source.Serialization.cs @@ -41,6 +41,11 @@ protected override void JsonModelWriteCore(Utf8JsonWriter writer, ModelReaderWri writer.WritePropertyName("expression"u8); writer.WriteObjectValue(Expression, options); } + if (Optional.IsDefined(PageSize)) + { + writer.WritePropertyName("pageSize"u8); + JsonSerializer.Serialize(writer, PageSize); + } foreach (var item in AdditionalProperties) { writer.WritePropertyName(item.Key); @@ -76,6 +81,7 @@ internal static ServiceNowV2Source DeserializeServiceNowV2Source(JsonElement ele return null; } DataFactoryExpressionV2 expression = default; + DataFactoryElement pageSize = default; DataFactoryElement queryTimeout = default; BinaryData additionalColumns = default; string type = default; @@ -96,6 +102,15 @@ internal static ServiceNowV2Source DeserializeServiceNowV2Source(JsonElement ele expression = DataFactoryExpressionV2.DeserializeDataFactoryExpressionV2(property.Value, options); continue; } + if (property.NameEquals("pageSize"u8)) + { + if (property.Value.ValueKind == JsonValueKind.Null) + { + continue; + } + pageSize = JsonSerializer.Deserialize>(property.Value.GetRawText()); + continue; + } if (property.NameEquals("queryTimeout"u8)) { if (property.Value.ValueKind == JsonValueKind.Null) @@ -167,7 +182,8 @@ internal static ServiceNowV2Source DeserializeServiceNowV2Source(JsonElement ele additionalProperties, queryTimeout, additionalColumns, - expression); + expression, + pageSize); } BinaryData IPersistableModel.Write(ModelReaderWriterOptions options) diff --git a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/ServiceNowV2Source.cs b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/ServiceNowV2Source.cs index 62e0c258de31..3817f061ee6c 100644 --- a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/ServiceNowV2Source.cs +++ b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/ServiceNowV2Source.cs @@ -30,13 +30,17 @@ public ServiceNowV2Source() /// Query timeout. Type: string (or Expression with resultType string), pattern: ((\d+)\.)?(\d\d):(60|([0-5][0-9])):(60|([0-5][0-9])). /// Specifies the additional columns to be added to source data. Type: array of objects(AdditionalColumns) (or Expression with resultType array of objects). /// Expression to filter data from source. - internal ServiceNowV2Source(string copySourceType, DataFactoryElement sourceRetryCount, DataFactoryElement sourceRetryWait, DataFactoryElement maxConcurrentConnections, DataFactoryElement disableMetricsCollection, IDictionary additionalProperties, DataFactoryElement queryTimeout, BinaryData additionalColumns, DataFactoryExpressionV2 expression) : base(copySourceType, sourceRetryCount, sourceRetryWait, maxConcurrentConnections, disableMetricsCollection, additionalProperties, queryTimeout, additionalColumns) + /// Page size of the result. Type: integer (or Expression with resultType integer). + internal ServiceNowV2Source(string copySourceType, DataFactoryElement sourceRetryCount, DataFactoryElement sourceRetryWait, DataFactoryElement maxConcurrentConnections, DataFactoryElement disableMetricsCollection, IDictionary additionalProperties, DataFactoryElement queryTimeout, BinaryData additionalColumns, DataFactoryExpressionV2 expression, DataFactoryElement pageSize) : base(copySourceType, sourceRetryCount, sourceRetryWait, maxConcurrentConnections, disableMetricsCollection, additionalProperties, queryTimeout, additionalColumns) { Expression = expression; + PageSize = pageSize; CopySourceType = copySourceType ?? "ServiceNowV2Source"; } /// Expression to filter data from source. public DataFactoryExpressionV2 Expression { get; set; } + /// Page size of the result. Type: integer (or Expression with resultType integer). + public DataFactoryElement PageSize { get; set; } } } diff --git a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/SnowflakeV2LinkedService.Serialization.cs b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/SnowflakeV2LinkedService.Serialization.cs index 3e0b1987f5d9..04a036cc8523 100644 --- a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/SnowflakeV2LinkedService.Serialization.cs +++ b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/SnowflakeV2LinkedService.Serialization.cs @@ -89,6 +89,11 @@ protected override void JsonModelWriteCore(Utf8JsonWriter writer, ModelReaderWri writer.WritePropertyName("privateKeyPassphrase"u8); JsonSerializer.Serialize(writer, PrivateKeyPassphrase); } + if (Optional.IsDefined(Host)) + { + writer.WritePropertyName("host"u8); + JsonSerializer.Serialize(writer, Host); + } if (Optional.IsDefined(EncryptedCredential)) { writer.WritePropertyName("encryptedCredential"u8); @@ -147,6 +152,7 @@ internal static SnowflakeV2LinkedService DeserializeSnowflakeV2LinkedService(Jso DataFactoryElement scope = default; DataFactorySecret privateKey = default; DataFactorySecret privateKeyPassphrase = default; + DataFactoryElement host = default; string encryptedCredential = default; IDictionary additionalProperties = default; Dictionary additionalPropertiesDictionary = new Dictionary(); @@ -316,6 +322,15 @@ internal static SnowflakeV2LinkedService DeserializeSnowflakeV2LinkedService(Jso privateKeyPassphrase = JsonSerializer.Deserialize(property0.Value.GetRawText()); continue; } + if (property0.NameEquals("host"u8)) + { + if (property0.Value.ValueKind == JsonValueKind.Null) + { + continue; + } + host = JsonSerializer.Deserialize>(property0.Value.GetRawText()); + continue; + } if (property0.NameEquals("encryptedCredential"u8)) { encryptedCredential = property0.Value.GetString(); @@ -347,6 +362,7 @@ internal static SnowflakeV2LinkedService DeserializeSnowflakeV2LinkedService(Jso scope, privateKey, privateKeyPassphrase, + host, encryptedCredential); } diff --git a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/SnowflakeV2LinkedService.cs b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/SnowflakeV2LinkedService.cs index f09175ddf311..7e2365d2318d 100644 --- a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/SnowflakeV2LinkedService.cs +++ b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/Models/SnowflakeV2LinkedService.cs @@ -51,8 +51,9 @@ public SnowflakeV2LinkedService(DataFactoryElement accountIdentifier, Da /// The scope of the application registered in Azure Active Directory for AADServicePrincipal authentication. /// The Azure key vault secret reference of privateKey for KeyPair auth. /// The Azure key vault secret reference of private key password for KeyPair auth with encrypted private key. + /// The host name of the Snowflake account. /// The encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string. - internal SnowflakeV2LinkedService(string linkedServiceType, string linkedServiceVersion, IntegrationRuntimeReference connectVia, string description, IDictionary parameters, IList annotations, IDictionary additionalProperties, DataFactoryElement accountIdentifier, DataFactoryElement user, DataFactorySecret password, DataFactoryElement database, DataFactoryElement warehouse, SnowflakeAuthenticationType? authenticationType, DataFactoryElement clientId, DataFactorySecret clientSecret, DataFactoryElement tenantId, DataFactoryElement scope, DataFactorySecret privateKey, DataFactorySecret privateKeyPassphrase, string encryptedCredential) : base(linkedServiceType, linkedServiceVersion, connectVia, description, parameters, annotations, additionalProperties) + internal SnowflakeV2LinkedService(string linkedServiceType, string linkedServiceVersion, IntegrationRuntimeReference connectVia, string description, IDictionary parameters, IList annotations, IDictionary additionalProperties, DataFactoryElement accountIdentifier, DataFactoryElement user, DataFactorySecret password, DataFactoryElement database, DataFactoryElement warehouse, SnowflakeAuthenticationType? authenticationType, DataFactoryElement clientId, DataFactorySecret clientSecret, DataFactoryElement tenantId, DataFactoryElement scope, DataFactorySecret privateKey, DataFactorySecret privateKeyPassphrase, DataFactoryElement host, string encryptedCredential) : base(linkedServiceType, linkedServiceVersion, connectVia, description, parameters, annotations, additionalProperties) { AccountIdentifier = accountIdentifier; User = user; @@ -66,6 +67,7 @@ internal SnowflakeV2LinkedService(string linkedServiceType, string linkedService Scope = scope; PrivateKey = privateKey; PrivateKeyPassphrase = privateKeyPassphrase; + Host = host; EncryptedCredential = encryptedCredential; LinkedServiceType = linkedServiceType ?? "SnowflakeV2"; } @@ -99,6 +101,8 @@ internal SnowflakeV2LinkedService() public DataFactorySecret PrivateKey { get; set; } /// The Azure key vault secret reference of private key password for KeyPair auth with encrypted private key. public DataFactorySecret PrivateKeyPassphrase { get; set; } + /// The host name of the Snowflake account. + public DataFactoryElement Host { get; set; } /// The encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string. public string EncryptedCredential { get; set; } } diff --git a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/RestOperations/FactoriesRestOperations.cs b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/RestOperations/FactoriesRestOperations.cs index 9c88c32edb6e..59e41ca9077f 100644 --- a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/RestOperations/FactoriesRestOperations.cs +++ b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/Generated/RestOperations/FactoriesRestOperations.cs @@ -36,84 +36,6 @@ public FactoriesRestOperations(HttpPipeline pipeline, string applicationId, Uri _userAgent = new TelemetryDetails(GetType().Assembly, applicationId); } - internal RequestUriBuilder CreateListRequestUri(string subscriptionId) - { - var uri = new RawRequestUriBuilder(); - uri.Reset(_endpoint); - uri.AppendPath("/subscriptions/", false); - uri.AppendPath(subscriptionId, true); - uri.AppendPath("/providers/Microsoft.DataFactory/factories", false); - uri.AppendQuery("api-version", _apiVersion, true); - return uri; - } - - internal HttpMessage CreateListRequest(string subscriptionId) - { - var message = _pipeline.CreateMessage(); - var request = message.Request; - request.Method = RequestMethod.Get; - var uri = new RawRequestUriBuilder(); - uri.Reset(_endpoint); - uri.AppendPath("/subscriptions/", false); - uri.AppendPath(subscriptionId, true); - uri.AppendPath("/providers/Microsoft.DataFactory/factories", false); - uri.AppendQuery("api-version", _apiVersion, true); - request.Uri = uri; - request.Headers.Add("Accept", "application/json"); - _userAgent.Apply(message); - return message; - } - - /// Lists factories under the specified subscription. - /// The subscription identifier. - /// The cancellation token to use. - /// is null. - /// is an empty string, and was expected to be non-empty. - public async Task> ListAsync(string subscriptionId, CancellationToken cancellationToken = default) - { - Argument.AssertNotNullOrEmpty(subscriptionId, nameof(subscriptionId)); - - using var message = CreateListRequest(subscriptionId); - await _pipeline.SendAsync(message, cancellationToken).ConfigureAwait(false); - switch (message.Response.Status) - { - case 200: - { - DataFactoryListResult value = default; - using var document = await JsonDocument.ParseAsync(message.Response.ContentStream, default, cancellationToken).ConfigureAwait(false); - value = DataFactoryListResult.DeserializeDataFactoryListResult(document.RootElement); - return Response.FromValue(value, message.Response); - } - default: - throw new RequestFailedException(message.Response); - } - } - - /// Lists factories under the specified subscription. - /// The subscription identifier. - /// The cancellation token to use. - /// is null. - /// is an empty string, and was expected to be non-empty. - public Response List(string subscriptionId, CancellationToken cancellationToken = default) - { - Argument.AssertNotNullOrEmpty(subscriptionId, nameof(subscriptionId)); - - using var message = CreateListRequest(subscriptionId); - _pipeline.Send(message, cancellationToken); - switch (message.Response.Status) - { - case 200: - { - DataFactoryListResult value = default; - using var document = JsonDocument.Parse(message.Response.ContentStream); - value = DataFactoryListResult.DeserializeDataFactoryListResult(document.RootElement); - return Response.FromValue(value, message.Response); - } - default: - throw new RequestFailedException(message.Response); - } - } - internal RequestUriBuilder CreateConfigureFactoryRepoRequestUri(string subscriptionId, AzureLocation locationId, FactoryRepoContent content) { var uri = new RawRequestUriBuilder(); @@ -890,82 +812,6 @@ public Response GetDataPlaneAccess(strin } } - internal RequestUriBuilder CreateListNextPageRequestUri(string nextLink, string subscriptionId) - { - var uri = new RawRequestUriBuilder(); - uri.Reset(_endpoint); - uri.AppendRawNextLink(nextLink, false); - return uri; - } - - internal HttpMessage CreateListNextPageRequest(string nextLink, string subscriptionId) - { - var message = _pipeline.CreateMessage(); - var request = message.Request; - request.Method = RequestMethod.Get; - var uri = new RawRequestUriBuilder(); - uri.Reset(_endpoint); - uri.AppendRawNextLink(nextLink, false); - request.Uri = uri; - request.Headers.Add("Accept", "application/json"); - _userAgent.Apply(message); - return message; - } - - /// Lists factories under the specified subscription. - /// The URL to the next page of results. - /// The subscription identifier. - /// The cancellation token to use. - /// or is null. - /// is an empty string, and was expected to be non-empty. - public async Task> ListNextPageAsync(string nextLink, string subscriptionId, CancellationToken cancellationToken = default) - { - Argument.AssertNotNull(nextLink, nameof(nextLink)); - Argument.AssertNotNullOrEmpty(subscriptionId, nameof(subscriptionId)); - - using var message = CreateListNextPageRequest(nextLink, subscriptionId); - await _pipeline.SendAsync(message, cancellationToken).ConfigureAwait(false); - switch (message.Response.Status) - { - case 200: - { - DataFactoryListResult value = default; - using var document = await JsonDocument.ParseAsync(message.Response.ContentStream, default, cancellationToken).ConfigureAwait(false); - value = DataFactoryListResult.DeserializeDataFactoryListResult(document.RootElement); - return Response.FromValue(value, message.Response); - } - default: - throw new RequestFailedException(message.Response); - } - } - - /// Lists factories under the specified subscription. - /// The URL to the next page of results. - /// The subscription identifier. - /// The cancellation token to use. - /// or is null. - /// is an empty string, and was expected to be non-empty. - public Response ListNextPage(string nextLink, string subscriptionId, CancellationToken cancellationToken = default) - { - Argument.AssertNotNull(nextLink, nameof(nextLink)); - Argument.AssertNotNullOrEmpty(subscriptionId, nameof(subscriptionId)); - - using var message = CreateListNextPageRequest(nextLink, subscriptionId); - _pipeline.Send(message, cancellationToken); - switch (message.Response.Status) - { - case 200: - { - DataFactoryListResult value = default; - using var document = JsonDocument.Parse(message.Response.ContentStream); - value = DataFactoryListResult.DeserializeDataFactoryListResult(document.RootElement); - return Response.FromValue(value, message.Response); - } - default: - throw new RequestFailedException(message.Response); - } - } - internal RequestUriBuilder CreateListByResourceGroupNextPageRequestUri(string nextLink, string subscriptionId, string resourceGroupName) { var uri = new RawRequestUriBuilder(); diff --git a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/autorest.md b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/autorest.md index 16fe93617a19..7183098c184a 100644 --- a/sdk/datafactory/Azure.ResourceManager.DataFactory/src/autorest.md +++ b/sdk/datafactory/Azure.ResourceManager.DataFactory/src/autorest.md @@ -8,7 +8,7 @@ azure-arm: true csharp: true library-name: DataFactory namespace: Azure.ResourceManager.DataFactory -require: https://github.com/Azure/azure-rest-api-specs/blob/1ad29756bd141a47cac770140105a706d065ae1b/specification/datafactory/resource-manager/readme.md +require: /mnt/vss/_work/1/s/azure-rest-api-specs/specification/datafactory/resource-manager/readme.md output-folder: $(this-folder)/Generated clear-output-folder: true sample-gen: