Asp.Net Core Api İle Graphql Projesi Oluşturmak

Bu yazı dizimiz de Asp.Net Core Api teması kullanarak graphql ile sql server veritabanina nasıl bağlantı kurabileceğimizi göreceğiz.
Kaynak Kodlara aşağıdaki repodan ulaşabilirsiniz.
GitHub - cagdaskarademir/aspnetcore-graphql-dapper-sqlkata-sqlserver: Tutorial Asp.Net Core 3.1 + GraphQLApi + Sql Server
GitHub
​
Makalenin Amacı
.Net Core Web Api ve GraphQL kullanarak SQL Server veritabanında select  işlemlerinin nasıl yapılacağını tecrübe edineceğiz. 
Bilmeniz veya Öğrenmeniz Gereken Terimler
Aşağıdaki terimler hakkında bilgi sahibi olmalısınız.
1..Net Core Web Api Nedir?
2..Net Core Web Api Projesi Nasıl Oluşturulur?
3.GraphQL Nedir? 
4.ObjectGraphType Nedir? 
5.Dapper Nedir?
6.SqlKata Nedir?
Kullanılan Yan Teknolojiler
Orm tool olarak Dapper altyapısı kullanılarak hızlı bir şekilde sql kodu yazabileceğimiz SqlKata Query Generater kütüphanesini kullanacağız.
SqlKata kütüphanesine https://sqlkata.com/ linki üzerinden erişebilirsiniz. 
Dökümantasyon ve örnekler için https://sqlkata.com/docs adresini ziyaret etmenizi öneririm.
Katmanların Oluşturulması
Web Projesinin Oluşturulması
asp.net web api projesi oluşturuyoruz.‌
Web Projemize aşağıdaki kütüphaneleri ekliyoruz.
<PackageReference Include="GraphQL" Version="2.4.0" />
Entity Projesinin Oluşturulması
Tablo setlerimizi yöneteceğimiz Entity katmanını oluşturuyoruz.
Referans Projesi olarak aşağıdaki projeyi ekliyoruz.
<ProjectReference Include="..\CK.Tutorial.GraphQlApi.Common\CK.Tutorial.GraphQlApi.Common.csproj" />
Common Katmanının Oluşturulması
‌Tüm katmanlarda kullanacağımız enum, const ve helper sınıfları için Common katmanını oluşturuyoruz.
Projemize Newtonsoft.Json kütüphanesini ekliyoruz.
 <PackageReference Include="Newtonsoft.Json" Version="12.0.2" />
Business Katmanının Oluşturulması
İş süreçlerini kontrol edebileceğimiz Business katmanını oluşturuyoruz.
Model Katmanının Oluşturulması
Verilerimizi transfer edeceğimiz Model katmanını oluşturuyoruz.
Referans Projesi olarak aşağıdaki projeyi ekliyoruz.
<ProjectReference Include="..\CK.Tutorial.GraphQlApi.Common\CK.Tutorial.GraphQlApi.Common.csproj" />
Repository Katmanının Oluşturulması
Veritabanı işlemlerini yönetebildiğimiz data katmanımız olan Repository katmanını oluşturuyoruz.
Repository katmanına aşağıdaki referansları ekleyin.
<PackageReference Include="System.Data.SqlClient" Version="4.7.0" />
<PackageReference Include="SqlKata" Version="1.1.7" />
<PackageReference Include="SqlKata.Execution" Version="1.1.7" />
Referans projesini olarak aşağıdaki kütüphaneleri ekliyoruz.
CK.Tutorial.GraphQlApi.Repository.csproj
<ProjectReference Include="..\CK.Tutorial.GraphQlApi.Common\CK.Tutorial.GraphQlApi.Common.csproj" />
<ProjectReference Include="..\CK.Tutorial.GraphQlApi.Entity\CK.Tutorial.GraphQlApi.Entity.csproj" />
<ProjectReference Include="..\CK.Tutorial.GraphQlApi.Model\CK.Tutorial.GraphQlApi.Model.csproj" />
Common Layer
Extension Dosyalarının Oluşturulması
Array değişkenlerimize yardımcı olması için aşağıdaki extension'ı yazıyoruz.
using System.Linq;
​
namespace CK.Tutorial.GraphQlApi.Common.Extension
{
    public static class ArrayExtension
    {
        public static bool AnyItem(this string[] value)
        {
            return value != null && value.Any();
        }
    }
}
Primitive değişkenlerimize yardımcı olmak için aşağıdaki extension'ı yazıyoruz.
using System;
​
namespace CK.Tutorial.GraphQlApi.Common.Extension
{
    public static class PrimitiveExtension
    {
        public static bool IsNotNullOrEmpty(this string value)
        {
            return !string.IsNullOrEmpty(value);
        }
​
        public static bool IsNotNull(this bool? value)
        {
            return value != null;
        }
        
        public static bool IsTrue(this bool? value)
        {
            return value != null && value == true;
        }
        
        public static byte ConvertToByte(this bool? value)
        {
            if (value ==null )
            {
                throw new ArgumentException("Boolean Item must be convertible");
            }
​
            return (byte) (value.Value ? 1 : 0);
        }
    }
}
Common Model Dosyalarının Oluşturulması
Kullanıcılardan parametrik olarak alacağımız veriler için base request sınıfı oluşturuyoruz.
namespace CK.Tutorial.GraphQlApi.Common.Model
{
    public class RequestBase
    {
        public int DefaultPage { get; } = 1;
        public int DefaultPageSize { get; } = 10;
        public string[] Columns { get; set; }
        public int? PageSize { get; set; }
        public int? Page { get; set; }
    }
}
GraphQL için aşağıdaki model dosyamızı oluşturuyoruz.
using System.Text;
​
namespace CK.Tutorial.GraphQlApi.Common.Model
{
    public class GraphQlQuery
    {
        public string OperationName { get; set; }
        public string NamedQuery { get; set; }
        public string Query { get; set; }
        public string Variables { get; set; }
​
        public override string ToString()
        {
            var builder = new StringBuilder();
            builder.AppendLine();
            if (!string.IsNullOrWhiteSpace(OperationName)) builder.AppendLine(quot;OperationName = {OperationName}");
            if (!string.IsNullOrWhiteSpace(NamedQuery)) builder.AppendLine(quot;NamedQuery = {NamedQuery}");
            if (!string.IsNullOrWhiteSpace(Query)) builder.AppendLine(quot;Query = {Query}");
            if (!string.IsNullOrWhiteSpace(Variables)) builder.AppendLine(quot;Variables = {Variables}");
​
            return builder.ToString();
        }
    }
}
Entity Katmanı
Company Entity
namespace CK.Tutorial.GraphQlApi.Entity
{
    public class Company
    {
        public int Id { get; set; }
        public string Name { get; set; }
        public bool IsActive { get; set; }
    }
}
Product Entity
using CK.Tutorial.GraphQlApi.Common.Enum;
​
namespace CK.Tutorial.GraphQlApi.Entity
{
    public class Product
    {
        public int Id { get; set; }
        public int CompanyId { get; set; }
        public string Name { get; set; }
        public string Description { get; set; }
        public int ProductTypeId { get; set; }
        public Status Status { get; set; }
    }
}
Model Katmanı
Search Company Database Transfer Object 
Kullanıcıdan aldığımız verileri alt katmanlara aşağıdaki veri deseniyle göndereceğiz.
using CK.Tutorial.GraphQlApi.Common.Model;
​
namespace CK.Tutorial.GraphQlApi.Model.Request
{
    public class SearchCompany : RequestBase
    {
        public int? Id { get; set; }
        public string Name { get; set; }
        public bool? IsActive { get; set; }
    }
}
Repository Katmanı
‌IRepositoryBase Interface Oluşturulması
Repository sınıflarımız için generic base bir Interface tanımlıyoruz.
IRepository.cs
‌using SqlKata.Execution;
​
namespace CK.Tutorial.GraphQlApi.Repository
{
    public interface IRepositoryBase<TEntity>
    {
        QueryFactory QueryFactory { get; }
    }
}
RepositoryBase Sınıfının Oluşturulması
Oluşturacağımız Entity Repository'leri için RepositoryBase sınıfını, IRepositoryBase interface'i üzerinden oluşturuyoruz.
RepositoryBase.cs
using SqlKata.Execution;
​
namespace CK.Tutorial.GraphQlApi.Repository
{
    public class RepositoryBase<TEntity> : IRepositoryBase<TEntity>
    {
        public RepositoryBase(QueryFactory queryFactory)
        {
            QueryFactory = queryFactory;
        }
​
        public QueryFactory QueryFactory { get; set; }
    }
}
‌ICompanyRepository Interface Oluşturulması
ICompanyRepository.cs
using System.Collections.Generic;
using System.Threading.Tasks;
using CK.Tutorial.GraphQlApi.Entity;
using CK.Tutorial.GraphQlApi.Model.Request;
using SqlKata.Execution;
​
namespace CK.Tutorial.GraphQlApi.Repository
{
    public interface ICompanyRepository
    {
        Task<IEnumerable<Company>> GetCompanies(SearchCompany request);
        Task<Company> GetCompany(SearchCompany request);
    }
}
CompanyRepository Sınıfının Oluşturulması
CompanyRepository.cs
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using CK.Tutorial.GraphQlApi.Common.Extension;
using CK.Tutorial.GraphQlApi.Entity;
using CK.Tutorial.GraphQlApi.Model.Request;
using SqlKata.Execution;
​
namespace CK.Tutorial.GraphQlApi.Repository
{
    public class CompanyRepository : RepositoryBase<Company>, ICompanyRepository
    {
        private readonly QueryFactory _queryFactory;
        private const string TableName = "Company";
​
        public CompanyRepository(QueryFactory queryFactory) : base(queryFactory)
        {
            _queryFactory = queryFactory;
        }
​
        public async Task<IEnumerable<Company>> GetCompanies(SearchCompany request)
        {
            var query = _queryFactory
                .Query(TableName)
                .When(request.Columns.AnyItem(),
                    q => q.Select(request.Columns))
                .When(request.IsActive.IsNotNull(), q => q.Where("IsActive", request.IsActive.ConvertToByte()))
                .OrderBy("Id")
                .ForPage(request.Page ?? request.DefaultPage, request.PageSize ?? request.DefaultPageSize)
                .GetAsync<Company>();
​
            return await query.ConfigureAwait(false);
        }
​
        public async Task<Company> GetCompany(SearchCompany request)
        {
            var query = _queryFactory
                .Query(TableName)
                .When(request.Columns.AnyItem(),
                    q => q.Select(request.Columns))
                .When(request.Id.HasValue, q => q.Where("Id", request.Id))
                .When(request.Name.IsNotNullOrEmpty(), q => q.WhereContains("Name", request.Name))
                .When(request.IsActive.IsNotNull(), q => q.Where("IsActive", request.IsActive.ConvertToByte()))
                .OrderBy("Id")
                .FirstOrDefaultAsync<Company>();
​
            return await query.ConfigureAwait(false);
        }
    }
}
​
Business Katmanı
‌Company Entity'sinin iş süreçlerini yazmak için ICompanyService adında bir interface oluşturuyoruz. 
Şimdilik iki tane metod yazacağız. 
ICompanyService Oluşturulması
ICompanyService.cs
using System.Collections.Generic;
using System.Threading.Tasks;
using CK.Tutorial.GraphQlApi.Entity;
using CK.Tutorial.GraphQlApi.Model.Request;
using SqlKata.Execution;
​
namespace CK.Tutorial.GraphQlApi.Business
{
    public interface ICompanyService
    {
        Task<IEnumerable<Company>> GetCompanies(SearchCompany request);
        Task<Company> GetCompany(SearchCompany request);
    }
}
CompanyService Sınıfının Oluşturulması
ICompanyService üzerinden CompanyService adında yeni bir sınıf oluşturuyoruz.
CompanyService.cs
using System.Collections.Generic;
using System.Threading.Tasks;
using CK.Tutorial.GraphQlApi.Entity;
using CK.Tutorial.GraphQlApi.Model.Request;
using CK.Tutorial.GraphQlApi.Repository;
​
namespace CK.Tutorial.GraphQlApi.Business
{
    public class CompanyService : ICompanyService
    {
        private readonly ICompanyRepository _companyRepository;
​
        public CompanyService(ICompanyRepository companyRepository)
        {
            _companyRepository = companyRepository;
        }
        
        public Task<IEnumerable<Company>> GetCompanies(SearchCompany request)
        {
            return _companyRepository.GetCompanies(request);
        }
​
        public Task<Company> GetCompany(SearchCompany request)
        {
            return _companyRepository.GetCompany(request);
        }
    }
}
Web - Graphql Katmanı
GraphQL Schema adını verdiğimiz referans bir root sınıfından oluşur. 
Schema sınıfına Resolver bir tane QUERY referans gösterilir..
Query dosyaları ise GraphType'lardan beslenerek dinamik sorgular oluşturacağımız bir yapı kurmamızı sağlar.
Kısacası Schema > Query > GraphTypes olarak tanımlayabiliriz.
Retail adında bir tane Root Schema sınıfımızı aşağıdaki gibi tanımlıyoruz.
RetailSchema sınıfının TutorialQuery adında bir sorgulama sınıfını çözümlediğini bildiriyoruz.
Schema Sınıfının Oluşturulması
RetailSchema.cs
using CK.Tutorial.GraphQlApi.Web.Query;
using GraphQL;
​
namespace CK.Tutorial.GraphQlApi.Web.Schema
{
    public class RetailSchema : GraphQL.Types.Schema
    {
        public RetailSchema(IDependencyResolver resolver) : base(resolver)
        {
            Query = resolver.Resolve<TutorialQuery>();
        }
    }
}
Company Graph Type Sınıfının Oluşturulması
Entity sınıflarımızın field alanlarını kullanarak graphql için sorgulanabilir tipler oluşturuyoruz.
Aşağıdaki örneğimizde Company Entity dosyasımızı referans göstermiş ve field alanları için Type tanımlamalarını yapmış olduğumuzu göreceksiniz. 
Örneğin Name alanı için ikinci parametre olan IsNullable alanını True vererek, bu field için null alabilen bir field düzenlemiş olduk. Diğer override parametrelerini kullanarak TYPE tipinide değiştirmeniz veya belirtmeniz mümkündür.
CompanyGraphType.cs
using System;
using CK.Tutorial.GraphQlApi.Business;
using CK.Tutorial.GraphQlApi.Entity;
using GraphQL.Types;
​
namespace CK.Tutorial.GraphQlApi.Web.Types
{
    public class CompanyGraphType : ObjectGraphType<Company>
    {
        public CompanyGraphType()
        {
            Name = "Company";
            Field(x => x.Id).Description("Şirket Benzersiz No");
            Field(x => x.Name, true).Description("Şirket Adı");
            Field(x => x.IsActive, true).Description("Şirket Aktif mi?");
        }
    }
}
TutorialQuery Sınıfının Oluşturulması
Bu örneğimizde 2 tane sorgulama endpoint'i oluşturacağız.
Birinci endpoint; "company" adını verdiğimiz, CompanyGraphType kullanarak sorgu yapabileceğimiz, 
companyId
companyName
isActive
parametrelerinden oluşan ve return type değeri COMPANY entity sınıfımızdır.  
İkinci endpoint; "companies" adını verdiğimiz ve return tipi List<Company> olan sınıfımızdır.
TutorialQuery.cs
using System.Collections.Generic;
using CK.Tutorial.GraphQlApi.Business;
using CK.Tutorial.GraphQlApi.Model.Request;
using CK.Tutorial.GraphQlApi.Web.Extensions;
using CK.Tutorial.GraphQlApi.Web.Types;
using GraphQL.Types;
​
namespace CK.Tutorial.GraphQlApi.Web.Query
{
    public class TutorialQuery : ObjectGraphType
    {
        public TutorialQuery(ICompanyService companyService)
        {
            #region Company
​
            Field<CompanyGraphType>(
                name: "company",
                arguments: new QueryArguments(new List<QueryArgument>
                {
                    new QueryArgument<IntGraphType>
                    {
                        Name = "companyId"
                    },
                    new QueryArgument<StringGraphType>
                    {
                        Name = "companyName"
                    },
                    new QueryArgument<BooleanGraphType>
                    {
                        Name = "isActive"
                    }
                }),
                resolve: delegate (ResolveFieldContext<object> context)
                {
                    var columns = context.GetMainSelectedFields();
​
                    var companyId = context.GetArgument<int?>("companyId");
                    var companyName = context.GetArgument<string>("companyName");
                    var isActive = context.GetArgument<bool?>("isActive");
​
                    var request = new SearchCompany
                    {
                        Id = companyId,
                        Name = companyName,
                        IsActive = isActive,
                        Columns = columns
                    };
                    return companyService.GetCompany(request);
                });
​
            Field<ListGraphType<CompanyGraphType>>(
                "companies",
                arguments: new QueryArguments(new List<QueryArgument>
                {
                    new QueryArgument<ListGraphType<IntGraphType>>
                    {
                        Name = "companyIds"
                    },
                    new QueryArgument<ListGraphType<StringGraphType>>
                    {
                        Name = "companyNames"
                    },
                     new QueryArgument<BooleanGraphType>
                    {
                        Name = "isActive"
                    },
                    new QueryArgument<IntGraphType>
                    {
                        Name = "page"
                    },
                    new QueryArgument<IntGraphType>
                    {
                        Name = "pageSize"
                    }
                }),
                resolve: delegate (ResolveFieldContext<object> context)
                {
                    var columns = context.GetMainSelectedFields();
                    var companyIds = context.GetArgument<int?[]>("companyIds");
                    var companyNames = context.GetArgument<string[]>("companyNames");
                    var isActive = context.GetArgument<bool?>("isActive");
​
                    var page = context.GetArgument<int?>("page");
                    var pageSize = context.GetArgument<int?>("pageSize");
​
                    var request = new SearchCompanies()
                    {
                        Ids = companyIds,
                        Names = companyNames,
                        IsActive = isActive,
                        Page = page,
                        PageSize = pageSize,
                        Columns = columns
                    };
                    return companyService.GetCompanies(request);
                });
​
            #endregion
        }
    }
}
Build & Run & Test
Create Database
Öncelikle yeni bir SQL SERVER veritabanı açmalısınız.
Sonrasında database klasörü içerisinde yer alan create-table.sql dosyasını çalıştırmalısınız.
create-table.sql
-- auto-generated definition
create table Company
(
    Id       int identity
        constraint Company_pk
            primary key nonclustered,
    Name     nvarchar(200) not null,
    IsActive bit default 1 not null
)
go
​
create unique index Company_Id_uindex
    on Company (Id)
go
​
​
Sizlerin projeyi test edebilmesi için; database klasörünün içerisinde yer alan bulk-data.sql dosyasını oluşturdum, bu dosyayı çalıştırabilirsiniz. 
Projenin AppSettings dosyasını kendi connectionString değerlerinize göre güncellemesiniz.
appsettings.json
{
  "Logging": {
    "LogLevel": {
      "Default": "Information",
      "Microsoft": "Warning",
      "Microsoft.Hosting.Lifetime": "Information"
    }
  },
  "AllowedHosts": "*",
  "ConnectionStrings": {
    "SqlServerDatabaseConnection": "Server=localhost;Database=GraphQLSample;User Id=sa;Password=Aa123456;"
  }
}
​
DotNet Restore & Build & Run
Aşağıdaki komutları çalıştırıp projeyi ayağa kaldırabilirsiniz.
dotnet restore
dotnet build
dotnet run
UI PlayGround 
Tarayıcınızdan https://localhost:5001/ui/playground adresine gitmek istediğinizde; sorgularınızı test edebileceğiniz bir arayüze erişebilmeniz gerekmektedir.
Hello GraphQL For .Net
Aşağıdaki sorguyu yazdığınızda çıktısını almalısınız.
query {
  company(companyId:5) {
    id
    name
    isActive
  }
}
​