< Summary

Class:Azure.Analytics.Synapse.Artifacts.DatasetRestClient
Assembly:Azure.Analytics.Synapse.Artifacts
File(s):C:\Git\azure-sdk-for-net\sdk\synapse\Azure.Analytics.Synapse.Artifacts\src\Generated\DatasetRestClient.cs
Covered lines:0
Uncovered lines:163
Coverable lines:163
Total lines:394
Line coverage:0% (0 of 163)
Covered branches:0
Total branches:56
Branch coverage:0% (0 of 56)

Metrics

MethodCyclomatic complexity Line coverage Branch coverage
.ctor(...)-0%0%
CreateGetDatasetsByWorkspaceRequest()-0%100%
GetDatasetsByWorkspaceAsync()-0%0%
GetDatasetsByWorkspace(...)-0%0%
CreateCreateOrUpdateDatasetRequest(...)-0%0%
CreateOrUpdateDatasetAsync()-0%0%
CreateOrUpdateDataset(...)-0%0%
CreateGetDatasetRequest(...)-0%0%
GetDatasetAsync()-0%0%
GetDataset(...)-0%0%
CreateDeleteDatasetRequest(...)-0%100%
DeleteDatasetAsync()-0%0%
DeleteDataset(...)-0%0%
CreateGetDatasetsByWorkspaceNextPageRequest(...)-0%100%
GetDatasetsByWorkspaceNextPageAsync()-0%0%
GetDatasetsByWorkspaceNextPage(...)-0%0%

File(s)

C:\Git\azure-sdk-for-net\sdk\synapse\Azure.Analytics.Synapse.Artifacts\src\Generated\DatasetRestClient.cs

#LineLine coverage
 1// Copyright (c) Microsoft Corporation. All rights reserved.
 2// Licensed under the MIT License.
 3
 4// <auto-generated/>
 5
 6#nullable disable
 7
 8using System;
 9using System.Text.Json;
 10using System.Threading;
 11using System.Threading.Tasks;
 12using Azure;
 13using Azure.Analytics.Synapse.Artifacts.Models;
 14using Azure.Core;
 15using Azure.Core.Pipeline;
 16
 17namespace Azure.Analytics.Synapse.Artifacts
 18{
 19    internal partial class DatasetRestClient
 20    {
 21        private string endpoint;
 22        private string apiVersion;
 23        private ClientDiagnostics _clientDiagnostics;
 24        private HttpPipeline _pipeline;
 25
 26        /// <summary> Initializes a new instance of DatasetRestClient. </summary>
 27        /// <param name="clientDiagnostics"> The handler for diagnostic messaging in the client. </param>
 28        /// <param name="pipeline"> The HTTP pipeline for sending and receiving REST requests and responses. </param>
 29        /// <param name="endpoint"> The workspace development endpoint, for example https://myworkspace.dev.azuresynapse
 30        /// <param name="apiVersion"> Api Version. </param>
 31        /// <exception cref="ArgumentNullException"> <paramref name="endpoint"/> or <paramref name="apiVersion"/> is nul
 032        public DatasetRestClient(ClientDiagnostics clientDiagnostics, HttpPipeline pipeline, string endpoint, string api
 33        {
 034            if (endpoint == null)
 35            {
 036                throw new ArgumentNullException(nameof(endpoint));
 37            }
 038            if (apiVersion == null)
 39            {
 040                throw new ArgumentNullException(nameof(apiVersion));
 41            }
 42
 043            this.endpoint = endpoint;
 044            this.apiVersion = apiVersion;
 045            _clientDiagnostics = clientDiagnostics;
 046            _pipeline = pipeline;
 047        }
 48
 49        internal HttpMessage CreateGetDatasetsByWorkspaceRequest()
 50        {
 051            var message = _pipeline.CreateMessage();
 052            var request = message.Request;
 053            request.Method = RequestMethod.Get;
 054            var uri = new RawRequestUriBuilder();
 055            uri.AppendRaw(endpoint, false);
 056            uri.AppendPath("/datasets", false);
 057            uri.AppendQuery("api-version", apiVersion, true);
 058            request.Uri = uri;
 059            return message;
 60        }
 61
 62        /// <summary> Lists datasets. </summary>
 63        /// <param name="cancellationToken"> The cancellation token to use. </param>
 64        public async Task<Response<DatasetListResponse>> GetDatasetsByWorkspaceAsync(CancellationToken cancellationToken
 65        {
 066            using var message = CreateGetDatasetsByWorkspaceRequest();
 067            await _pipeline.SendAsync(message, cancellationToken).ConfigureAwait(false);
 068            switch (message.Response.Status)
 69            {
 70                case 200:
 71                    {
 72                        DatasetListResponse value = default;
 073                        using var document = await JsonDocument.ParseAsync(message.Response.ContentStream, default, canc
 074                        value = DatasetListResponse.DeserializeDatasetListResponse(document.RootElement);
 075                        return Response.FromValue(value, message.Response);
 76                    }
 77                default:
 078                    throw await _clientDiagnostics.CreateRequestFailedExceptionAsync(message.Response).ConfigureAwait(fa
 79            }
 080        }
 81
 82        /// <summary> Lists datasets. </summary>
 83        /// <param name="cancellationToken"> The cancellation token to use. </param>
 84        public Response<DatasetListResponse> GetDatasetsByWorkspace(CancellationToken cancellationToken = default)
 85        {
 086            using var message = CreateGetDatasetsByWorkspaceRequest();
 087            _pipeline.Send(message, cancellationToken);
 088            switch (message.Response.Status)
 89            {
 90                case 200:
 91                    {
 92                        DatasetListResponse value = default;
 093                        using var document = JsonDocument.Parse(message.Response.ContentStream);
 094                        value = DatasetListResponse.DeserializeDatasetListResponse(document.RootElement);
 095                        return Response.FromValue(value, message.Response);
 96                    }
 97                default:
 098                    throw _clientDiagnostics.CreateRequestFailedException(message.Response);
 99            }
 0100        }
 101
 102        internal HttpMessage CreateCreateOrUpdateDatasetRequest(string datasetName, DatasetResource dataset, string ifMa
 103        {
 0104            var message = _pipeline.CreateMessage();
 0105            var request = message.Request;
 0106            request.Method = RequestMethod.Put;
 0107            var uri = new RawRequestUriBuilder();
 0108            uri.AppendRaw(endpoint, false);
 0109            uri.AppendPath("/datasets/", false);
 0110            uri.AppendPath(datasetName, true);
 0111            uri.AppendQuery("api-version", apiVersion, true);
 0112            request.Uri = uri;
 0113            if (ifMatch != null)
 114            {
 0115                request.Headers.Add("If-Match", ifMatch);
 116            }
 0117            request.Headers.Add("Content-Type", "application/json");
 0118            var content = new Utf8JsonRequestContent();
 0119            content.JsonWriter.WriteObjectValue(dataset);
 0120            request.Content = content;
 0121            return message;
 122        }
 123
 124        /// <summary> Creates or updates a dataset. </summary>
 125        /// <param name="datasetName"> The dataset name. </param>
 126        /// <param name="dataset"> Dataset resource definition. </param>
 127        /// <param name="ifMatch"> ETag of the dataset entity.  Should only be specified for update, for which it should
 128        /// <param name="cancellationToken"> The cancellation token to use. </param>
 129        /// <exception cref="ArgumentNullException"> <paramref name="datasetName"/> or <paramref name="dataset"/> is nul
 130        public async Task<Response<DatasetResource>> CreateOrUpdateDatasetAsync(string datasetName, DatasetResource data
 131        {
 0132            if (datasetName == null)
 133            {
 0134                throw new ArgumentNullException(nameof(datasetName));
 135            }
 0136            if (dataset == null)
 137            {
 0138                throw new ArgumentNullException(nameof(dataset));
 139            }
 140
 0141            using var message = CreateCreateOrUpdateDatasetRequest(datasetName, dataset, ifMatch);
 0142            await _pipeline.SendAsync(message, cancellationToken).ConfigureAwait(false);
 0143            switch (message.Response.Status)
 144            {
 145                case 200:
 146                    {
 147                        DatasetResource value = default;
 0148                        using var document = await JsonDocument.ParseAsync(message.Response.ContentStream, default, canc
 0149                        value = DatasetResource.DeserializeDatasetResource(document.RootElement);
 0150                        return Response.FromValue(value, message.Response);
 151                    }
 152                default:
 0153                    throw await _clientDiagnostics.CreateRequestFailedExceptionAsync(message.Response).ConfigureAwait(fa
 154            }
 0155        }
 156
 157        /// <summary> Creates or updates a dataset. </summary>
 158        /// <param name="datasetName"> The dataset name. </param>
 159        /// <param name="dataset"> Dataset resource definition. </param>
 160        /// <param name="ifMatch"> ETag of the dataset entity.  Should only be specified for update, for which it should
 161        /// <param name="cancellationToken"> The cancellation token to use. </param>
 162        /// <exception cref="ArgumentNullException"> <paramref name="datasetName"/> or <paramref name="dataset"/> is nul
 163        public Response<DatasetResource> CreateOrUpdateDataset(string datasetName, DatasetResource dataset, string ifMat
 164        {
 0165            if (datasetName == null)
 166            {
 0167                throw new ArgumentNullException(nameof(datasetName));
 168            }
 0169            if (dataset == null)
 170            {
 0171                throw new ArgumentNullException(nameof(dataset));
 172            }
 173
 0174            using var message = CreateCreateOrUpdateDatasetRequest(datasetName, dataset, ifMatch);
 0175            _pipeline.Send(message, cancellationToken);
 0176            switch (message.Response.Status)
 177            {
 178                case 200:
 179                    {
 180                        DatasetResource value = default;
 0181                        using var document = JsonDocument.Parse(message.Response.ContentStream);
 0182                        value = DatasetResource.DeserializeDatasetResource(document.RootElement);
 0183                        return Response.FromValue(value, message.Response);
 184                    }
 185                default:
 0186                    throw _clientDiagnostics.CreateRequestFailedException(message.Response);
 187            }
 0188        }
 189
 190        internal HttpMessage CreateGetDatasetRequest(string datasetName, string ifNoneMatch)
 191        {
 0192            var message = _pipeline.CreateMessage();
 0193            var request = message.Request;
 0194            request.Method = RequestMethod.Get;
 0195            var uri = new RawRequestUriBuilder();
 0196            uri.AppendRaw(endpoint, false);
 0197            uri.AppendPath("/datasets/", false);
 0198            uri.AppendPath(datasetName, true);
 0199            uri.AppendQuery("api-version", apiVersion, true);
 0200            request.Uri = uri;
 0201            if (ifNoneMatch != null)
 202            {
 0203                request.Headers.Add("If-None-Match", ifNoneMatch);
 204            }
 0205            return message;
 206        }
 207
 208        /// <summary> Gets a dataset. </summary>
 209        /// <param name="datasetName"> The dataset name. </param>
 210        /// <param name="ifNoneMatch"> ETag of the dataset entity. Should only be specified for get. If the ETag matches
 211        /// <param name="cancellationToken"> The cancellation token to use. </param>
 212        /// <exception cref="ArgumentNullException"> <paramref name="datasetName"/> is null. </exception>
 213        public async Task<Response<DatasetResource>> GetDatasetAsync(string datasetName, string ifNoneMatch = null, Canc
 214        {
 0215            if (datasetName == null)
 216            {
 0217                throw new ArgumentNullException(nameof(datasetName));
 218            }
 219
 0220            using var message = CreateGetDatasetRequest(datasetName, ifNoneMatch);
 0221            await _pipeline.SendAsync(message, cancellationToken).ConfigureAwait(false);
 0222            switch (message.Response.Status)
 223            {
 224                case 200:
 225                    {
 226                        DatasetResource value = default;
 0227                        using var document = await JsonDocument.ParseAsync(message.Response.ContentStream, default, canc
 0228                        value = DatasetResource.DeserializeDatasetResource(document.RootElement);
 0229                        return Response.FromValue(value, message.Response);
 230                    }
 231                case 304:
 0232                    return Response.FromValue<DatasetResource>(null, message.Response);
 233                default:
 0234                    throw await _clientDiagnostics.CreateRequestFailedExceptionAsync(message.Response).ConfigureAwait(fa
 235            }
 0236        }
 237
 238        /// <summary> Gets a dataset. </summary>
 239        /// <param name="datasetName"> The dataset name. </param>
 240        /// <param name="ifNoneMatch"> ETag of the dataset entity. Should only be specified for get. If the ETag matches
 241        /// <param name="cancellationToken"> The cancellation token to use. </param>
 242        /// <exception cref="ArgumentNullException"> <paramref name="datasetName"/> is null. </exception>
 243        public Response<DatasetResource> GetDataset(string datasetName, string ifNoneMatch = null, CancellationToken can
 244        {
 0245            if (datasetName == null)
 246            {
 0247                throw new ArgumentNullException(nameof(datasetName));
 248            }
 249
 0250            using var message = CreateGetDatasetRequest(datasetName, ifNoneMatch);
 0251            _pipeline.Send(message, cancellationToken);
 0252            switch (message.Response.Status)
 253            {
 254                case 200:
 255                    {
 256                        DatasetResource value = default;
 0257                        using var document = JsonDocument.Parse(message.Response.ContentStream);
 0258                        value = DatasetResource.DeserializeDatasetResource(document.RootElement);
 0259                        return Response.FromValue(value, message.Response);
 260                    }
 261                case 304:
 0262                    return Response.FromValue<DatasetResource>(null, message.Response);
 263                default:
 0264                    throw _clientDiagnostics.CreateRequestFailedException(message.Response);
 265            }
 0266        }
 267
 268        internal HttpMessage CreateDeleteDatasetRequest(string datasetName)
 269        {
 0270            var message = _pipeline.CreateMessage();
 0271            var request = message.Request;
 0272            request.Method = RequestMethod.Delete;
 0273            var uri = new RawRequestUriBuilder();
 0274            uri.AppendRaw(endpoint, false);
 0275            uri.AppendPath("/datasets/", false);
 0276            uri.AppendPath(datasetName, true);
 0277            uri.AppendQuery("api-version", apiVersion, true);
 0278            request.Uri = uri;
 0279            return message;
 280        }
 281
 282        /// <summary> Deletes a dataset. </summary>
 283        /// <param name="datasetName"> The dataset name. </param>
 284        /// <param name="cancellationToken"> The cancellation token to use. </param>
 285        /// <exception cref="ArgumentNullException"> <paramref name="datasetName"/> is null. </exception>
 286        public async Task<Response> DeleteDatasetAsync(string datasetName, CancellationToken cancellationToken = default
 287        {
 0288            if (datasetName == null)
 289            {
 0290                throw new ArgumentNullException(nameof(datasetName));
 291            }
 292
 0293            using var message = CreateDeleteDatasetRequest(datasetName);
 0294            await _pipeline.SendAsync(message, cancellationToken).ConfigureAwait(false);
 0295            switch (message.Response.Status)
 296            {
 297                case 200:
 298                case 204:
 0299                    return message.Response;
 300                default:
 0301                    throw await _clientDiagnostics.CreateRequestFailedExceptionAsync(message.Response).ConfigureAwait(fa
 302            }
 0303        }
 304
 305        /// <summary> Deletes a dataset. </summary>
 306        /// <param name="datasetName"> The dataset name. </param>
 307        /// <param name="cancellationToken"> The cancellation token to use. </param>
 308        /// <exception cref="ArgumentNullException"> <paramref name="datasetName"/> is null. </exception>
 309        public Response DeleteDataset(string datasetName, CancellationToken cancellationToken = default)
 310        {
 0311            if (datasetName == null)
 312            {
 0313                throw new ArgumentNullException(nameof(datasetName));
 314            }
 315
 0316            using var message = CreateDeleteDatasetRequest(datasetName);
 0317            _pipeline.Send(message, cancellationToken);
 0318            switch (message.Response.Status)
 319            {
 320                case 200:
 321                case 204:
 0322                    return message.Response;
 323                default:
 0324                    throw _clientDiagnostics.CreateRequestFailedException(message.Response);
 325            }
 0326        }
 327
 328        internal HttpMessage CreateGetDatasetsByWorkspaceNextPageRequest(string nextLink)
 329        {
 0330            var message = _pipeline.CreateMessage();
 0331            var request = message.Request;
 0332            request.Method = RequestMethod.Get;
 0333            var uri = new RawRequestUriBuilder();
 0334            uri.AppendRaw(endpoint, false);
 0335            uri.AppendRawNextLink(nextLink, false);
 0336            request.Uri = uri;
 0337            return message;
 338        }
 339
 340        /// <summary> Lists datasets. </summary>
 341        /// <param name="nextLink"> The URL to the next page of results. </param>
 342        /// <param name="cancellationToken"> The cancellation token to use. </param>
 343        /// <exception cref="ArgumentNullException"> <paramref name="nextLink"/> is null. </exception>
 344        public async Task<Response<DatasetListResponse>> GetDatasetsByWorkspaceNextPageAsync(string nextLink, Cancellati
 345        {
 0346            if (nextLink == null)
 347            {
 0348                throw new ArgumentNullException(nameof(nextLink));
 349            }
 350
 0351            using var message = CreateGetDatasetsByWorkspaceNextPageRequest(nextLink);
 0352            await _pipeline.SendAsync(message, cancellationToken).ConfigureAwait(false);
 0353            switch (message.Response.Status)
 354            {
 355                case 200:
 356                    {
 357                        DatasetListResponse value = default;
 0358                        using var document = await JsonDocument.ParseAsync(message.Response.ContentStream, default, canc
 0359                        value = DatasetListResponse.DeserializeDatasetListResponse(document.RootElement);
 0360                        return Response.FromValue(value, message.Response);
 361                    }
 362                default:
 0363                    throw await _clientDiagnostics.CreateRequestFailedExceptionAsync(message.Response).ConfigureAwait(fa
 364            }
 0365        }
 366
 367        /// <summary> Lists datasets. </summary>
 368        /// <param name="nextLink"> The URL to the next page of results. </param>
 369        /// <param name="cancellationToken"> The cancellation token to use. </param>
 370        /// <exception cref="ArgumentNullException"> <paramref name="nextLink"/> is null. </exception>
 371        public Response<DatasetListResponse> GetDatasetsByWorkspaceNextPage(string nextLink, CancellationToken cancellat
 372        {
 0373            if (nextLink == null)
 374            {
 0375                throw new ArgumentNullException(nameof(nextLink));
 376            }
 377
 0378            using var message = CreateGetDatasetsByWorkspaceNextPageRequest(nextLink);
 0379            _pipeline.Send(message, cancellationToken);
 0380            switch (message.Response.Status)
 381            {
 382                case 200:
 383                    {
 384                        DatasetListResponse value = default;
 0385                        using var document = JsonDocument.Parse(message.Response.ContentStream);
 0386                        value = DatasetListResponse.DeserializeDatasetListResponse(document.RootElement);
 0387                        return Response.FromValue(value, message.Response);
 388                    }
 389                default:
 0390                    throw _clientDiagnostics.CreateRequestFailedException(message.Response);
 391            }
 0392        }
 393    }
 394}
Generated by: ReportGenerator 4.6.4.0
8/12/2020 - 3:46:39 PM
GitHub | www.palmmedia.de

Methods/Properties

.ctor(...)
CreateGetDatasetsByWorkspaceRequest()
GetDatasetsByWorkspaceAsync()
GetDatasetsByWorkspace(...)
CreateCreateOrUpdateDatasetRequest(...)
CreateOrUpdateDatasetAsync()
CreateOrUpdateDataset(...)
CreateGetDatasetRequest(...)
GetDatasetAsync()
GetDataset(...)
CreateDeleteDatasetRequest(...)
DeleteDatasetAsync()
DeleteDataset(...)
CreateGetDatasetsByWorkspaceNextPageRequest(...)
GetDatasetsByWorkspaceNextPageAsync()
GetDatasetsByWorkspaceNextPage(...)