Skip to content

Commit

Permalink
[Automation] Generate Fluent Lite from datafactory#package-2018-06 (#…
Browse files Browse the repository at this point in the history 
…39784)

* [Automation] Generate Fluent Lite from datafactory#package-2018-06

* Update SsisEnvironmentTests.java

* Update SsisPackageTests.java

* Delete failure test case SsisEnvironmentTests

* Delete failure test case SsisPackageTests

---------

Co-authored-by: Hong Li(MSFT) <74638143+v-hongli1@users.noreply.github.com>
  • Loading branch information
@azure-sdk @v-hongli1
azure-sdk and v-hongli1 committed Apr 18, 2024
1 parent 00c4cb9 commit c00a62e
Show file tree
Hide file tree
Showing 1,819 changed files with 35,090 additions and 22,952 deletions.
2,207 changes: 2,203 additions & 4 deletions sdk/datafactory/azure-resourcemanager-datafactory/CHANGELOG.md
View file

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion sdk/datafactory/azure-resourcemanager-datafactory/README.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ Various documentation is available to help you get started
<dependency>
<groupId>com.azure.resourcemanager</groupId>
<artifactId>azure-resourcemanager-datafactory</artifactId>
<version>1.0.0-beta.27</version>
<version>1.0.0-beta.28</version>
</dependency>
```
[//]: # ({x-version-update-end})
Expand Down
1,164 changes: 595 additions & 569 deletions sdk/datafactory/azure-resourcemanager-datafactory/SAMPLE.md
View file

Large diffs are not rendered by default.

12 changes: 6 additions & 6 deletions sdk/datafactory/azure-resourcemanager-datafactory/pom.xml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -82,6 +82,12 @@
<version>5.9.3</version> <!-- {x-version-update;org.junit.jupiter:junit-jupiter-engine;external_dependency} -->
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-simple</artifactId>
<version>1.7.36</version> <!-- {x-version-update;org.slf4j:slf4j-simple;external_dependency} -->
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.mockito</groupId>
<artifactId>mockito-core</artifactId>
Expand All @@ -100,12 +106,6 @@
<version>1.14.12</version> <!-- {x-version-update;testdep_net.bytebuddy:byte-buddy-agent;external_dependency} -->
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-simple</artifactId>
<version>1.7.36</version> <!-- {x-version-update;org.slf4j:slf4j-simple;external_dependency} -->
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.azure.resourcemanager</groupId>
<artifactId>azure-resourcemanager-storage</artifactId>
Expand Down
40 changes: 26 additions & 14 deletions ...r-datafactory/src/main/java/com/azure/resourcemanager/datafactory/DataFactoryManager.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -11,8 +11,8 @@
import com.azure.core.http.HttpPipelinePosition;
import com.azure.core.http.policy.AddDatePolicy;
import com.azure.core.http.policy.AddHeadersFromContextPolicy;
import com.azure.core.http.policy.HttpLogOptions;
import com.azure.core.http.policy.HttpLoggingPolicy;
import com.azure.core.http.policy.HttpLogOptions;
import com.azure.core.http.policy.HttpPipelinePolicy;
import com.azure.core.http.policy.HttpPolicyProviders;
import com.azure.core.http.policy.RequestIdPolicy;
Expand Down Expand Up @@ -43,8 +43,8 @@
import com.azure.resourcemanager.datafactory.implementation.OperationsImpl;
import com.azure.resourcemanager.datafactory.implementation.PipelineRunsImpl;
import com.azure.resourcemanager.datafactory.implementation.PipelinesImpl;
import com.azure.resourcemanager.datafactory.implementation.PrivateEndPointConnectionsImpl;
import com.azure.resourcemanager.datafactory.implementation.PrivateEndpointConnectionOperationsImpl;
import com.azure.resourcemanager.datafactory.implementation.PrivateEndPointConnectionsImpl;
import com.azure.resourcemanager.datafactory.implementation.PrivateLinkResourcesImpl;
import com.azure.resourcemanager.datafactory.implementation.TriggerRunsImpl;
import com.azure.resourcemanager.datafactory.implementation.TriggersImpl;
Expand All @@ -66,8 +66,8 @@
import com.azure.resourcemanager.datafactory.models.Operations;
import com.azure.resourcemanager.datafactory.models.PipelineRuns;
import com.azure.resourcemanager.datafactory.models.Pipelines;
import com.azure.resourcemanager.datafactory.models.PrivateEndPointConnections;
import com.azure.resourcemanager.datafactory.models.PrivateEndpointConnectionOperations;
import com.azure.resourcemanager.datafactory.models.PrivateEndPointConnections;
import com.azure.resourcemanager.datafactory.models.PrivateLinkResources;
import com.azure.resourcemanager.datafactory.models.TriggerRuns;
import com.azure.resourcemanager.datafactory.models.Triggers;
Expand Down Expand Up @@ -136,8 +136,10 @@ private DataFactoryManager(HttpPipeline httpPipeline, AzureProfile profile, Dura
Objects.requireNonNull(httpPipeline, "'httpPipeline' cannot be null.");
Objects.requireNonNull(profile, "'profile' cannot be null.");
this.clientObject = new DataFactoryManagementClientBuilder().pipeline(httpPipeline)
.endpoint(profile.getEnvironment().getResourceManagerEndpoint()).subscriptionId(profile.getSubscriptionId())
.defaultPollInterval(defaultPollInterval).buildClient();
.endpoint(profile.getEnvironment().getResourceManagerEndpoint())
.subscriptionId(profile.getSubscriptionId())
.defaultPollInterval(defaultPollInterval)
.buildClient();
}

/**
Expand Down Expand Up @@ -288,12 +290,19 @@ public DataFactoryManager authenticate(TokenCredential credential, AzureProfile
Objects.requireNonNull(profile, "'profile' cannot be null.");

StringBuilder userAgentBuilder = new StringBuilder();
userAgentBuilder.append("azsdk-java").append("-").append("com.azure.resourcemanager.datafactory")
.append("/").append("1.0.0-beta.27");
userAgentBuilder.append("azsdk-java")
.append("-")
.append("com.azure.resourcemanager.datafactory")
.append("/")
.append("1.0.0-beta.28");
if (!Configuration.getGlobalConfiguration().get("AZURE_TELEMETRY_DISABLED", false)) {
userAgentBuilder.append(" (").append(Configuration.getGlobalConfiguration().get("java.version"))
.append("; ").append(Configuration.getGlobalConfiguration().get("os.name")).append("; ")
.append(Configuration.getGlobalConfiguration().get("os.version")).append("; auto-generated)");
userAgentBuilder.append(" (")
.append(Configuration.getGlobalConfiguration().get("java.version"))
.append("; ")
.append(Configuration.getGlobalConfiguration().get("os.name"))
.append("; ")
.append(Configuration.getGlobalConfiguration().get("os.version"))
.append("; auto-generated)");
} else {
userAgentBuilder.append(" (auto-generated)");
}
Expand All @@ -312,18 +321,21 @@ public DataFactoryManager authenticate(TokenCredential credential, AzureProfile
policies.add(new UserAgentPolicy(userAgentBuilder.toString()));
policies.add(new AddHeadersFromContextPolicy());
policies.add(new RequestIdPolicy());
policies.addAll(this.policies.stream().filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_CALL)
policies.addAll(this.policies.stream()
.filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_CALL)
.collect(Collectors.toList()));
HttpPolicyProviders.addBeforeRetryPolicies(policies);
policies.add(retryPolicy);
policies.add(new AddDatePolicy());
policies.add(new ArmChallengeAuthenticationPolicy(credential, scopes.toArray(new String[0])));
policies.addAll(this.policies.stream()
.filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_RETRY).collect(Collectors.toList()));
.filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_RETRY)
.collect(Collectors.toList()));
HttpPolicyProviders.addAfterRetryPolicies(policies);
policies.add(new HttpLoggingPolicy(httpLogOptions));
HttpPipeline httpPipeline = new HttpPipelineBuilder().httpClient(httpClient)
.policies(policies.toArray(new HttpPipelinePolicy[0])).build();
.policies(policies.toArray(new HttpPipelinePolicy[0]))
.build();
return new DataFactoryManager(httpPipeline, profile, defaultPollInterval);
}
}
Expand Down Expand Up @@ -537,7 +549,7 @@ public ManagedPrivateEndpoints managedPrivateEndpoints() {
}

/**
* Gets the resource collection API of CredentialOperations. It manages ManagedIdentityCredentialResource.
* Gets the resource collection API of CredentialOperations.
*
* @return Resource collection API of CredentialOperations.
*/
Expand Down
20 changes: 9 additions & 11 deletions ...rc/main/java/com/azure/resourcemanager/datafactory/fluent/CredentialOperationsClient.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@
import com.azure.core.http.rest.PagedIterable;
import com.azure.core.http.rest.Response;
import com.azure.core.util.Context;
import com.azure.resourcemanager.datafactory.fluent.models.ManagedIdentityCredentialResourceInner;
import com.azure.resourcemanager.datafactory.fluent.models.CredentialResourceInner;

/**
* An instance of this class provides access to all the operations defined in CredentialOperationsClient.
Expand All @@ -26,7 +26,7 @@ public interface CredentialOperationsClient {
* @return a list of credential resources as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable<ManagedIdentityCredentialResourceInner> listByFactory(String resourceGroupName, String factoryName);
PagedIterable<CredentialResourceInner> listByFactory(String resourceGroupName, String factoryName);

/**
* List credentials.
Expand All @@ -40,8 +40,7 @@ public interface CredentialOperationsClient {
* @return a list of credential resources as paginated response with {@link PagedIterable}.
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
PagedIterable<ManagedIdentityCredentialResourceInner> listByFactory(String resourceGroupName, String factoryName,
Context context);
PagedIterable<CredentialResourceInner> listByFactory(String resourceGroupName, String factoryName, Context context);

/**
* Creates or updates a credential.
Expand All @@ -59,9 +58,8 @@ PagedIterable<ManagedIdentityCredentialResourceInner> listByFactory(String resou
* @return credential resource type along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response<ManagedIdentityCredentialResourceInner> createOrUpdateWithResponse(String resourceGroupName,
String factoryName, String credentialName, ManagedIdentityCredentialResourceInner credential, String ifMatch,
Context context);
Response<CredentialResourceInner> createOrUpdateWithResponse(String resourceGroupName, String factoryName,
String credentialName, CredentialResourceInner credential, String ifMatch, Context context);

/**
* Creates or updates a credential.
Expand All @@ -76,8 +74,8 @@ Response<ManagedIdentityCredentialResourceInner> createOrUpdateWithResponse(Stri
* @return credential resource type.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
ManagedIdentityCredentialResourceInner createOrUpdate(String resourceGroupName, String factoryName,
String credentialName, ManagedIdentityCredentialResourceInner credential);
CredentialResourceInner createOrUpdate(String resourceGroupName, String factoryName, String credentialName,
CredentialResourceInner credential);

/**
* Gets a credential.
Expand All @@ -94,7 +92,7 @@ ManagedIdentityCredentialResourceInner createOrUpdate(String resourceGroupName,
* @return a credential along with {@link Response}.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
Response<ManagedIdentityCredentialResourceInner> getWithResponse(String resourceGroupName, String factoryName,
Response<CredentialResourceInner> getWithResponse(String resourceGroupName, String factoryName,
String credentialName, String ifNoneMatch, Context context);

/**
Expand All @@ -109,7 +107,7 @@ Response<ManagedIdentityCredentialResourceInner> getWithResponse(String resource
* @return a credential.
*/
@ServiceMethod(returns = ReturnType.SINGLE)
ManagedIdentityCredentialResourceInner get(String resourceGroupName, String factoryName, String credentialName);
CredentialResourceInner get(String resourceGroupName, String factoryName, String credentialName);

/**
* Deletes a credential.
Expand Down
3 changes: 1 addition & 2 deletions ...m/azure/resourcemanager/datafactory/fluent/PrivateEndpointConnectionOperationsClient.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -12,8 +12,7 @@
import com.azure.resourcemanager.datafactory.models.PrivateLinkConnectionApprovalRequestResource;

/**
* An instance of this class provides access to all the operations defined in
* PrivateEndpointConnectionOperationsClient.
* An instance of this class provides access to all the operations defined in PrivateEndpointConnectionOperationsClient.
*/
public interface PrivateEndpointConnectionOperationsClient {
/**
Expand Down
13 changes: 7 additions & 6 deletions ...a/com/azure/resourcemanager/datafactory/fluent/models/ActivityRunsQueryResponseInner.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -54,8 +54,8 @@ public ActivityRunsQueryResponseInner withValue(List<ActivityRun> value) {
}

/**
* Get the continuationToken property: The continuation token for getting the next page of results, if any
* remaining results exist, null otherwise.
* Get the continuationToken property: The continuation token for getting the next page of results, if any remaining
* results exist, null otherwise.
*
* @return the continuationToken value.
*/
Expand All @@ -64,8 +64,8 @@ public String continuationToken() {
}

/**
* Set the continuationToken property: The continuation token for getting the next page of results, if any
* remaining results exist, null otherwise.
* Set the continuationToken property: The continuation token for getting the next page of results, if any remaining
* results exist, null otherwise.
*
* @param continuationToken the continuationToken value to set.
* @return the ActivityRunsQueryResponseInner object itself.
Expand All @@ -82,8 +82,9 @@ public ActivityRunsQueryResponseInner withContinuationToken(String continuationT
*/
public void validate() {
if (value() == null) {
throw LOGGER.logExceptionAsError(new IllegalArgumentException(
"Missing required property value in model ActivityRunsQueryResponseInner"));
throw LOGGER.atError()
.log(new IllegalArgumentException(
"Missing required property value in model ActivityRunsQueryResponseInner"));
} else {
value().forEach(e -> e.validate());
}
Expand Down
45 changes: 23 additions & 22 deletions ...azure/resourcemanager/datafactory/fluent/models/AmazonMwsLinkedServiceTypeProperties.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,8 +21,7 @@ public final class AmazonMwsLinkedServiceTypeProperties {
private Object endpoint;

/*
* The Amazon Marketplace ID you want to retrieve data from. To retrieve data from multiple Marketplace IDs,
* separate them with a comma (,). (i.e. A2EUQ1WTGCTBG2)
* The Amazon Marketplace ID you want to retrieve data from. To retrieve data from multiple Marketplace IDs, separate them with a comma (,). (i.e. A2EUQ1WTGCTBG2)
*/
@JsonProperty(value = "marketplaceID", required = true)
private Object marketplaceId;
Expand Down Expand Up @@ -58,8 +57,7 @@ public final class AmazonMwsLinkedServiceTypeProperties {
private Object useEncryptedEndpoints;

/*
* Specifies whether to require the host name in the server's certificate to match the host name of the server when
* connecting over SSL. The default value is true.
* Specifies whether to require the host name in the server's certificate to match the host name of the server when connecting over SSL. The default value is true.
*/
@JsonProperty(value = "useHostVerification")
private Object useHostVerification;
Expand All @@ -71,8 +69,7 @@ public final class AmazonMwsLinkedServiceTypeProperties {
private Object usePeerVerification;

/*
* The encrypted credential used for authentication. Credentials are encrypted using the integration runtime
* credential manager. Type: string.
* The encrypted credential used for authentication. Credentials are encrypted using the integration runtime credential manager. Type: string.
*/
@JsonProperty(value = "encryptedCredential")
private String encryptedCredential;
Expand Down Expand Up @@ -250,8 +247,8 @@ public AmazonMwsLinkedServiceTypeProperties withUseHostVerification(Object useHo
}

/**
* Get the usePeerVerification property: Specifies whether to verify the identity of the server when connecting
* over SSL. The default value is true.
* Get the usePeerVerification property: Specifies whether to verify the identity of the server when connecting over
* SSL. The default value is true.
*
* @return the usePeerVerification value.
*/
Expand All @@ -260,8 +257,8 @@ public Object usePeerVerification() {
}

/**
* Set the usePeerVerification property: Specifies whether to verify the identity of the server when connecting
* over SSL. The default value is true.
* Set the usePeerVerification property: Specifies whether to verify the identity of the server when connecting over
* SSL. The default value is true.
*
* @param usePeerVerification the usePeerVerification value to set.
* @return the AmazonMwsLinkedServiceTypeProperties object itself.
Expand All @@ -272,8 +269,8 @@ public AmazonMwsLinkedServiceTypeProperties withUsePeerVerification(Object usePe
}

/**
* Get the encryptedCredential property: The encrypted credential used for authentication. Credentials are
* encrypted using the integration runtime credential manager. Type: string.
* Get the encryptedCredential property: The encrypted credential used for authentication. Credentials are encrypted
* using the integration runtime credential manager. Type: string.
*
* @return the encryptedCredential value.
*/
Expand All @@ -282,8 +279,8 @@ public String encryptedCredential() {
}

/**
* Set the encryptedCredential property: The encrypted credential used for authentication. Credentials are
* encrypted using the integration runtime credential manager. Type: string.
* Set the encryptedCredential property: The encrypted credential used for authentication. Credentials are encrypted
* using the integration runtime credential manager. Type: string.
*
* @param encryptedCredential the encryptedCredential value to set.
* @return the AmazonMwsLinkedServiceTypeProperties object itself.
Expand All @@ -300,23 +297,27 @@ public AmazonMwsLinkedServiceTypeProperties withEncryptedCredential(String encry
*/
public void validate() {
if (endpoint() == null) {
throw LOGGER.logExceptionAsError(new IllegalArgumentException(
"Missing required property endpoint in model AmazonMwsLinkedServiceTypeProperties"));
throw LOGGER.atError()
.log(new IllegalArgumentException(
"Missing required property endpoint in model AmazonMwsLinkedServiceTypeProperties"));
}
if (marketplaceId() == null) {
throw LOGGER.logExceptionAsError(new IllegalArgumentException(
"Missing required property marketplaceId in model AmazonMwsLinkedServiceTypeProperties"));
throw LOGGER.atError()
.log(new IllegalArgumentException(
"Missing required property marketplaceId in model AmazonMwsLinkedServiceTypeProperties"));
}
if (sellerId() == null) {
throw LOGGER.logExceptionAsError(new IllegalArgumentException(
"Missing required property sellerId in model AmazonMwsLinkedServiceTypeProperties"));
throw LOGGER.atError()
.log(new IllegalArgumentException(
"Missing required property sellerId in model AmazonMwsLinkedServiceTypeProperties"));
}
if (mwsAuthToken() != null) {
mwsAuthToken().validate();
}
if (accessKeyId() == null) {
throw LOGGER.logExceptionAsError(new IllegalArgumentException(
"Missing required property accessKeyId in model AmazonMwsLinkedServiceTypeProperties"));
throw LOGGER.atError()
.log(new IllegalArgumentException(
"Missing required property accessKeyId in model AmazonMwsLinkedServiceTypeProperties"));
}
if (secretKey() != null) {
secretKey().validate();
Expand Down

0 comments on commit c00a62e

Please sign in to comment.