샘플: 일반 가상 테이블 데이터 공급자 플러그 인

시연

이 샘플에서는 Dropbox 파일 공유 서비스에 대한 일반 Microsoft Dataverse 가상 테이블 데이터 공급자 플러그 인 DropboxRetrieveMultiplePlugin에 대한 최소 구현을 보여 줍니다. 사용자 지정 방문자 클래스 QueryExpression의 생성을 통해 을 변환하는 "베어 메탈" 접근 방식을 사용합니다. 검색 기준을 충족하는 파일의 컬렉션을 EntityCollection로 반환합니다.

시작하기

이 샘플을 빌드하려면 먼저 Dropbox.Api 및 Microsoft.CrmSdk.Data NuGet 패키지를 솔루션에 설치해야 합니다. DropboxClient 인스턴스를 만들 때 DropBox 계정이 필요하고 실제 액세스 토큰을 전달합니다.

코드에 다음 using 문을 추가합니다.

using Microsoft.Xrm.Sdk;
using Microsoft.Xrm.Sdk.Query;
using Dropbox.Api;
using Dropbox.Api.Files;

샘플 코드

public class DropBoxExpressionVisitor : QueryExpressionVisitorBase
{
    public string SearchKeyWords { get; private set; }

    public override QueryExpression Visit(QueryExpression query)
    {
        // Very simple visitor that extracts search keywords
        var filter = query.Criteria;
        if (filter.Conditions.Count > 0)
        {
            foreach (ConditionExpression condition in filter.Conditions)
            {
                if (condition.Operator == ConditionOperator.Like && condition.Values.Count > 0)
                {
                    string exprVal = (string)condition.Values[0];

                    if (exprVal.Length > 2)
                    {
                        this.SearchKeyWords += " " + exprVal.Substring(1, exprVal.Length - 2);
                    }
                }
            }
            return query;
        }
    }
}

public class DropboxRetrieveMultiplePlugin : IPlugin
{
    public void Execute(IServiceProvider serviceProvider)
    {
        var context = (IPluginExecutionContext)serviceProvider.GetService(typeof(IPluginExecutionContext));
        var qe = (QueryExpression)context.InputParameters["Query"];
        if (qe != null)
        {
            var visitor = new DropBoxExpressionVisitor();
            qe.Accept(visitor);
            using (var dbx = new DropboxClient(AccessToken))
            {
                if (visitor.SearchKeyWords != string.Empty)
                {
                    var searchCriteria = new SearchArg(string.Empty, visitor.SearchKeyWords);
                    var task = Task.Run(() => this.SearchFile(dbx, searchCriteria));
                    context.OutputParameters["BusinessEntityCollection"] = task.Result;
                }
            }
        }
    }

    public async Task<EntityCollection> SearchFile(DropboxClient dbx, SearchArg arg)
    {
        EntityCollection ec = new EntityCollection();
        var list = await dbx.Files.SearchAsync(arg);
        foreach (var item in list.Matches)
        {
            if (item.Metadata.IsFile)
            {
                Entity e = new Entity("new_dropbox");
                e.Attributes.Add("new_dropboxid", Guid.NewGuid());
                e.Attributes.Add("new_filename", item.Metadata.AsFile.Name);
                e.Attributes.Add("new_filesize", item.Metadata.AsFile.Size);
                e.Attributes.Add("new_modifiedon", item.Metadata.AsFile.ServerModified);
                ec.Entities.Add(e);
            }
        }
        return ec;
    }
}

참고하십시오

가상 테이블 시작
가상 테이블의 API 고려 사항
사용자 지정 가상 테이블 데이터 공급자