اتصال به دیتابیس ClickHouse در برنامه‌های NET.

dotnet add package ClickHouse.Client

{
"Logging": {
  "LogLevel": {
    "Default": "Information",
    "Microsoft.AspNetCore": "Warning"
  }
},

"AllowedHosts": "*",

 "ClickHouse": {
  "Host": "rainier.liara.cloud",
  "Port": "33273",
  "Database": "default",
  "Username": "root",
  "Password": "x4y2LJvdFyG5wVO87VbXDrpg"
}
}

using ClickHouse.Client.ADO;

namespace ClickHouseDemo.Services;

public class ClickHouseService
{
  private readonly string _connectionString;


  public ClickHouseService(IConfiguration configuration)
  {
      _connectionString =
          $"Host={configuration["ClickHouse:Host"]};" +
          $"Port={configuration["ClickHouse:Port"]};" +
          $"Database={configuration["ClickHouse:Database"]};" +
          $"Username={configuration["ClickHouse:Username"]};" +
          $"Password={configuration["ClickHouse:Password"]};";
  }


  public async Task<object?> TestConnection()
  {
      await using var connection =
          new ClickHouseConnection(_connectionString);

      await connection.OpenAsync();


      await using var command =
          connection.CreateCommand();


      command.CommandText = "SELECT 1";


      return await command.ExecuteScalarAsync();
  }
}

using ClickHouseDemo.Services;


var builder = WebApplication.CreateBuilder(args);


builder.Services.AddControllers();

builder.Services.AddSingleton<ClickHouseService>();


var app = builder.Build();


app.MapControllers();


app.Run();

using Microsoft.AspNetCore.Mvc;
using ClickHouseDemo.Services;


namespace ClickHouseDemo.Controllers;


[ApiController]
[Route("api/clickhouse")]
public class ClickHouseController : ControllerBase
{

  private readonly ClickHouseService _clickhouse;


  public ClickHouseController(
      ClickHouseService clickhouse
  )
  {
      _clickhouse = clickhouse;
  }



  [HttpGet("test")]
  public async Task<IActionResult> Test()
  {
      try
      {
          var result =
              await _clickhouse.TestConnection();


          return Ok(new
          {
              success = true,
              message = "ClickHouse connection successful",
              result
          });

      }
      catch(Exception ex)
      {
          return StatusCode(500, new
          {
              success = false,
              message = "ClickHouse connection failed",
              error = ex.Message
          });
      }
  }
}