> ## Documentation Index
> Fetch the complete documentation index at: https://private-7c7dfe99-vortex-format.mintlify.site/llms.txt
> Use this file to discover all available pages before exploring further.
> عميل C# الرسمي للاتصال بـ ClickHouse عبر بروتوكول TCP الأصلي.
# عميل ClickHouse للغة C# عبر بروتوكول TCP الأصلي
الحالة التجريبية
واجهة برمجة تطبيقات عميل البروتوكول الأصلي تجريبية. وقد تتغير واجهتها العامة في إصدار مستقبلي.
تُصدر واجهات العميل الرئيسي ومصدر البيانات وsession والعمليات، إلى جانب امتدادات حقن التبعيات،
تحذير المصرّف `CHTCP0001`. للإقرار بهذا التحذير أثناء تقييم واجهة برمجة التطبيقات، أضفه
إلى `NoWarn` في ملف مشروعك:
```xml theme={null}
$(NoWarn);CHTCP0001
```
لا تُخفِ التحذير إلا بعد أن تتقبّل احتمال الحاجة إلى تعديل الشيفرة التي تستخدم واجهة برمجة التطبيقات في
إصدار مستقبلي.
إصدارات .NET المدعومة
يدعم العميل الذي يعمل عبر البروتوكول الأصلي إصدارات .NET التالية:
* .NET 8.0
* .NET 9.0
* .NET 10.0
إصدارات ClickHouse المدعومة
يدعم عميل TCP رسميًا أحدث إصدارين من إصدارات الدعم طويل الأمد (LTS)، وأحدث ثلاثة إصدارات من خادم ClickHouse.
التثبيت
يتوفر عميل البروتوكول الأصلي عبر TCP ضمن حزمة `ClickHouse.Driver`. ثبّت الحزمة من NuGet:
```bash theme={null}
dotnet add package ClickHouse.Driver
```
أو باستخدام مدير الحزم NuGet Package Manager:
```bash theme={null}
Install-Package ClickHouse.Driver
```
البدء السريع
```csharp theme={null}
using ClickHouse.Driver.Tcp;
// Create and reuse a client. It is thread-safe and owns a connection pool.
await using var client = new ClickHouseTcpClient(
"Host=my.clickhouse;Port=9000;Username=user");
// Execute a query
object version = await client.ExecuteScalarAsync("SELECT version()");
Console.WriteLine(version);
```
الترحيل من عميل HTTP
واجهة برمجة تطبيقات TCP مستقلة عن `IClickHouseClient`؛ فهي ليست خيارًا لوسيلة النقل في
`ClickHouseClient` أو `ClickHouseConnection`. يمكن إعادة استخدام معظم شيفرات SQL، لكن عليك إنشاء
`ClickHouseTcpClient` وترحيل كل عملية إلى نظيرتها عبر TCP.
الطرق المكافئة
| عميل HTTP | عميل TCP | الفرق المهم |
| - | - | - |
| `new ClickHouseClient(...)` | `new ClickHouseTcpClient(...)` | استخدم `ClickHouseTcpClientOptions` أو سلسلة اتصال TCP مع المنفذ الأصلي، وهو عادةً 9000 دون TLS. أعد استخدام العميل نفسه في جميع العمليات، أيًّا كان نوعه. |
| `ExecuteNonQueryAsync(...)` | `ExecuteAsync(...)` | تكتمل طريقة TCP بمجرد أن يؤكد ClickHouse استلام العبارة، ولا تُرجع عدد الصفوف المتأثرة. |
| `ExecuteScalarAsync(...)` | `ExecuteScalarAsync(...)` | تُرجع كلتاهما القيمة الأولى، أو `null` إذا كانت النتيجة فارغة. وتقرأ طريقة TCP الاستجابة كاملةً قبل الإرجاع حتى يتسنى إعادة استخدام الاتصال. |
| `ExecuteReaderAsync(...)` | `QueryAsync(...)` أو `QueryAsync(...)` أو `StreamAsync(...)` | لا يتوفر `DbDataReader` في TCP. اختر بين صفوف `object[]` مخصصة، أو كائنات POCO مربوطة، أو كتل عمودية مستعارة. |
| `QueryAsync(...)` | `QueryAsync(...)` | يُنشئ TCP ربط POCO ويخزنه مؤقتًا تلقائيًا، دون الحاجة إلى أي استدعاء للتسجيل. استخدم `ClickHouseTcpColumn` و`ClickHouseTcpNotMapped` بدلًا من سمات الربط الخاصة بـ HTTP. |
| `InsertBinaryAsync(table, columns, rows)` | `InsertRowsAsync(sql, rows)` | مرّر `IReadOnlyList` مُجسَّدة، ويجب أن تنتهي عبارة SQL عند `VALUES`. ولا تُرجع طريقة TCP عدد الصفوف المُدرجة. |
| `InsertBinaryAsync(table, rows)` | `InsertRowsAsync(sql, rows)` | لا يتطلب TCP تسجيل POCO، لكن يجب أن يقابل كل عمود مذكور في العبارة خاصيةً عامة متوافقة. |
| — | `InsertAsync(sql, columns)` | استخدم قيم `IColumn` محددة النوع لتجنّب تحويل الصفوف إلى أعمدة وتغليف أنواع القيم (boxing) اللذين تنطوي عليهما عمليات إدراج الصفوف. |
| `PingAsync(...)` | `PingAsync(...)` | يُرجع HTTP القيمة `false` عند فشل الفحص، أما TCP فيكتمل بنجاح عند تلقي `Pong` ويرفع استثناءً فيما عدا ذلك. |
| `ExecuteRawResultAsync(...)`, `InsertRawStreamAsync(...)`, `PostStreamAsync(...)` | لا يوجد مكافئ | استمر في استخدام عميل HTTP للتدفقات الخام والصيغ مثل CSV وJSONEachRow وParquet. |
| `CreateConnection()` أو أنواع ADO.NET | لا يوجد مكافئ | استمر في استخدام عميل HTTP مع ADO.NET وأطر ORM. |
على سبيل المثال، حلقة قارئ HTTP:
```csharp theme={null}
using var reader = await http.ExecuteReaderAsync(
"SELECT id, name FROM events ORDER BY id");
while (reader.Read())
{
Console.WriteLine($"{reader.GetFieldValue(0)}: {reader.GetString(1)}");
}
```
يصبح دفقًا غير متزامن لصفوف TCP:
```csharp theme={null}
await foreach (object[] row in tcp.QueryAsync(
"SELECT id, name FROM events ORDER BY id"))
{
Console.WriteLine($"{row[0]}: {row[1]}");
}
```
الخيارات والمعلمات
لا يمكن استخدام `QueryOptions` و`ClickHouseParameterCollection` الخاصّين بـ HTTP بالتبادل مع نظيريهما في TCP.
انقل القيم إلى `ClickHouseTcpQueryOptions`، حيث تكون الإعدادات سلاسل نصية
وتكون المعلمات جزءًا من كائن الخيارات نفسه:
```csharp theme={null}
var options = new ClickHouseTcpQueryOptions
{
QueryId = "events-by-score",
Settings = new Dictionary
{
["max_execution_time"] = "30",
},
Parameters = new ClickHouseTcpParameterCollection
{
{ "minimum", 18.0 },
},
};
await foreach (object[] row in client.QueryAsync(
"SELECT id, score FROM events WHERE score >= {minimum:Float64}",
options))
{
Console.WriteLine($"{row[0]}: {row[1]}");
}
```
يدعم عميل TCP العناصر النائبة الأصلية في ClickHouse بصيغة `{name:Type}`، لكنه لا يعيد كتابة
العناصر النائبة بنمط ADO.NET مثل `@name`. كما أنه لا يتيح تحديد قاعدة بيانات أو دور أو رمز Bearer أو ترويسة
مخصصة أو محلّل معلمات أو منسّق أو محوّل قراءة على مستوى كل استعلام. راجع [القيود](#limitations) للاطلاع على
الميزات التي لا تزال مقتصرة على HTTP.
دورة حياة الاتصال والنتيجة
كلا العميلين عاليَي المستوى آمن للاستخدام عبر خيوط تنفيذ متعددة، وينبغي إعادة استخدامهما. يحتفظ عميل TCP باتصالات أصلية دائمة
بدلًا من اتصالات HTTP، وينفّذ `IAsyncDisposable`، وينبغي عادةً
التخلّص منه بصورة غير متزامنة عند إيقاف تشغيل التطبيق.
صفوف `QueryAsync` مملوكة للجهة المستدعية. أما كتل `StreamAsync` وأعمدتها فهي مُعارة، ولا تبقى صالحة
إلا خلال التكرار الحالي؛ انسخ أي قيم تحتاج إليها بعد انتهائه. احرص دائمًا على إكمال التعداد أو التخلّص منه
ليعود الاتصال إلى مجمّع الاتصالات. استخدم `OpenSessionAsync` عندما يلزم تنفيذ عدة عمليات
على الاتصال نفسه مع الاحتفاظ بحالة session.
راجع
[المثال الكامل للترحيل من HTTP إلى TCP](https://github.com/ClickHouse/clickhouse-cs/blob/main/examples/Tcp/Core/Tcp_004_MigratingFromHttp.cs)
للاطلاع على استخدام كلا العميلين مع الجدول نفسه.
التهيئة
يمكن تهيئة عميل يستخدم البروتوكول الأصلي عبر TCP بطريقتين:
* **سلسلة الاتصال:** أزواج مفاتيح وقيم تفصل بينها فواصل منقوطة، تحدد نقطة نهاية الخادم،
وبيانات اعتماد المصادقة، وخيارات الاتصال الأخرى.
* **كائن `ClickHouseTcpClientOptions`:** كائن تهيئة محدد الأنواع وغير قابل للتغيير، يُعرَّف في
الشيفرة.
مرّر أيًا منهما إلى مُنشئ `ClickHouseTcpClient`. استخدم
`ClickHouseTcpConnectionStringBuilder` لتحليل سلسلة اتصال أو إنشائها وتحويلها إلى
`ClickHouseTcpClientOptions`.
```csharp theme={null}
var builder = new ClickHouseTcpConnectionStringBuilder
{
Host = "my.clickhouse",
Username = "user",
UseTls = true,
Compression = "zstd",
};
await using var client = new ClickHouseTcpClient(builder.ToOptions());
```
توضح الأقسام التالية الإعدادات المتاحة وقيمها الافتراضية وتأثير كل منها.
إعدادات الاتصال
تُحدَّد قيم خصائص `TimeSpan` في سلسلة الاتصال بالثواني.
| الخاصية | النوع | القيمة الافتراضية | مفتاح سلسلة الاتصال | الوصف |
| - | - | - | - | - |
| Host | `string` | `"localhost"` | `Host` | اسم المضيف لخادم ClickHouse أو عنوان IP الخاص به |
| Port | `int?` | `null` | `Port` | منفذ البروتوكول الأصلي؛ وعند عدم تحديده يُستخدم المنفذ 9000 بدون TLS أو 9440 مع TLS |
| Username | `string` | `"default"` | `Username` | اسم المستخدم للمصادقة |
| Password | `string` | `""` | `Password` | كلمة المرور للمصادقة |
| Database | `string` | `"default"` | `Database` | قاعدة البيانات الافتراضية للعمليات |
| QuotaKey | `string` | `""` | `QuotaKey` | المفتاح المستخدم مع حصة ClickHouse القائمة على مفتاح |
| DialTimeout | `TimeSpan` | 30 ثانية | `DialTimeout` | مهلة إنشاء اتصال المقبس والتفاوض على TLS ومصافحة البروتوكول الأصلي |
| ReadTimeout | `TimeSpan` | 5 دقائق | `ReadTimeout` | الحد الأقصى لمدة كل عملية قراءة من طبقة النقل أثناء تنفيذ العملية؛ وتعطّل القيمة صفر هذه المهلة |
صيغة البيانات والتسلسل
| الخاصية | النوع | القيمة الافتراضية | مفتاح سلسلة الاتصال | الوصف |
| - | - | - | - | - |
| SendJsonAndDynamicSerializationSettings | `bool` | `true` | `SendJsonAndDynamicSerializationSettings` | يطلب تنسيقات wire الخاصة بـ `JSON` و`Dynamic` التي يدعمها العميل. اضبطه على `false` عند استخدام مستخدم للقراءة فقط لا يملك صلاحية تعديل الإعدادات، مع العلم أن قراءة هذين النوعين قد تفشل حينئذٍ. |
| MaxSendBufferBytes | `int` | 1 MiB | `MaxSendBufferBytes` | حدٌّ مرن لبيانات الإدراج المخزنة مؤقتًا. يتحقق العميل من هذا الحد بعد كل عمود، لذا قد يؤدي عمود واحد إلى تجاوز المخزن المؤقت له. |
| Compressor | `IClickHouseCompressor` | `Lz4Compressor.Default` | `Compression` | يضغط الكتل التي يكتبها العميل ويطلب نتائج مضغوطة. تقبل سلاسل الاتصال القيم `lz4` أو `zstd` أو `none`، أما الضاغط المخصص فلا يمكن تعيينه إلا من خلال الخيارات. |
تجميع الاتصالات
ينفّذ الاتصال الواحد عملية واحدة في كل مرة. ويتيح مجمّع الاتصالات تشغيل العمليات بشكل متزامن، مع إعادة استخدام
الاتصالات فيما بينها.
| الخاصية | النوع | القيمة الافتراضية | مفتاح سلسلة الاتصال | الوصف |
| - | - | - | - | - |
| MinPoolSize | `int` | `0` | `MinPoolSize` | عدد الاتصالات التي يُبقيها مجمّع الاتصالات مفتوحة متى أمكن ذلك، بما فيها الاتصالات المستخدمة حاليًا |
| MaxPoolSize | `int` | `20` | `MaxPoolSize` | الحد الأقصى الصارم لعدد الاتصالات المفتوحة والعمليات المتزامنة؛ وتنتظر أي عمليات إضافية إلى أن يتوفر اتصال |
| PoolTimeout | `TimeSpan` | 30 ثانية | `PoolTimeout` | أقصى مدة انتظار للحصول على اتصال عندما يكون مجمّع الاتصالات ممتلئًا؛ أما إنشاء اتصال جديد فيخضع لحد مستقل يحدده `DialTimeout` |
| MaxConnectionLifetime | `TimeSpan` | 30 دقيقة | `MaxConnectionLifetime` | أقصى عمر للاتصال يمكن خلاله إعادة استخدامه؛ وتعطّل القيمة صفر هذا الحد؛ ولا تُقاطَع العمليات الجارية أبدًا |
| IdleTimeout | `TimeSpan` | 5 دقائق | `IdleTimeout` | أقصى مدة يظل خلالها الاتصال غير المستخدم صالحًا لإعادة الاستخدام؛ وتعطّل القيمة صفر هذا الحد |
| SweepInterval | `TimeSpan?` | `null` (مشتقة) | `SweepInterval` | الفاصل الزمني بين عمليات سحب الاتصالات منتهية الصلاحية من الخدمة واستعادة `MinPoolSize`؛ وتُشتق القيمة الافتراضية من حدّي العمر والخمول |
| PoolReusePolicy | `ClickHouseTcpPoolReusePolicy` | `Lifo` | `PoolReusePolicy` | تحدد ما إذا كان سيُختار الاتصال الخامل الأحدث إعادةً إلى المجمّع (`Lifo`) أو الأقدم إعادةً (`Fifo`) |
الأمان
| الخاصية | النوع | القيمة الافتراضية | مفتاح سلسلة الاتصال | الوصف |
| - | - | - | - | - |
| UseTls | `bool` | `false` | `UseTls` | يفعّل TLS قبل مصافحة البروتوكول الأصلي. إذا لم يُحدَّد `Port`، يؤدي تفعيل TLS إلى تغيير المنفذ الافتراضي من 9000 إلى 9440. |
| TlsServerName | `string` | `null` | `TlsServerName` | اسم المضيف المُرسَل عبر SNI والذي يُقارَن بشهادة الخادم؛ عند ضبطه على `null`، تُستخدم قيمة `Host` |
| TlsAllowInvalidCertificates | `bool` | `false` | `TlsAllowInvalidCertificates` | يقبل شهادة لا تجتاز التحقق من صلاحيتها؛ استخدمه للتطوير المحلي فقط |
| TlsCaCertificatePath | `string` | `null` | `TlsCaCertificatePath` | مسار ملف PEM يحتوي على شهادة جذر موثوقة واحدة على الأقل؛ يحل محل مخزن الشهادات الموثوقة لدى المضيف، ولا يمكن استخدامه مع `TlsAllowInvalidCertificates` |
| ConfigureTls | `Action` | `null` | — | يضبط خيارات TLS قبل كل مصافحة، بعد تطبيق خصائص TLS الأخرى؛ ولا يتوفر إلا عبر `ClickHouseTcpClientOptions` |
من دون TLS، تنتقل كلمة المرور وجميع بيانات الاستعلام عبر الشبكة بلا تشفير. أبقِ
`TlsAllowInvalidCertificates` مضبوطًا على `false` خارج بيئات التطوير المحلية.
للبروتوكول الأصلي الآمن نقطة نهاية منفصلة على الخادم، ولا يُفعَّل بترقية الاتصال القائم. يجب على عميل TLS
الاتصال بمنفذ آمن للبروتوكول الأصلي؛ ولا يتحول تلقائيًا إلى اتصال بنص صريح. يُطبَّق `ConfigureTls`
أخيرًا، ويمكنه تجاوز التحقق من صلاحية الشهادة واسم المضيف، لذا راجع دوال رد الاتصال المخصصة
بعناية.
التسجيل وتصحيح الأخطاء
| الخاصية | النوع | القيمة الافتراضية | مفتاح سلسلة الاتصال | الوصف |
| - | - | - | - | - |
| LoggerFactory | `ILoggerFactory` | `null` | — | يوفّر مسجّلات لأحداث دورة حياة الاتصال ومجمّع الاتصالات والعمليات ضمن فئات `ClickHouse.Driver.Tcp.*` |
| IncludeSqlInActivityTags | `bool` | `false` | — | يضيف نص العبارة إلى سمة OpenTelemetry `db.query.text`، مع تقييد طوله وفقًا للقيمة `StatementMaxLength` |
| StatementMaxLength | `int` | `5` | — | الحد الأقصى لعدد محارف العبارة التي تظهر في سجلات تصحيح الأخطاء ووسوم النشاط؛ وإذا كانت قيمته صفرًا أو أقل، يُحذف النص |
يسجّل مسجّل العميل أحداث دورة الحياة والعمليات من جهة العميل. أما حزم سجل الخادم فتُرسل
إلى `ClickHouseTcpQueryCallbacks.OnLog` بدلًا من ذلك. قد يحتوي نص العبارة على بيانات حساسة، لذا لا يُضاف
إلى وسوم النشاط افتراضيًا، ويُقتطع معظمه في سجلات تصحيح الأخطاء.
إعدادات مخصصة
تُطبّق `ClickHouseTcpClientOptions.CustomSettings` إعدادات خادم ClickHouse على كل استعلام وعملية
إدراج. وتحلّ قيم `ClickHouseTcpQueryOptions.Settings` المحددة لكل عملية محلّ القيم المحددة على مستوى العميل إذا كانت
تحمل الاسم نفسه.
```csharp theme={null}
var options = new ClickHouseTcpClientOptions
{
Host = "my.clickhouse",
CustomSettings = new Dictionary
{
["max_threads"] = "4",
},
};
```
في سلسلة الاتصال، أضف البادئة `set_` إلى بداية كل إعداد من إعدادات الخادم:
```text theme={null}
Host=my.clickhouse;set_max_threads=4;set_max_memory_usage=10000000000
```
لا تُضف البادئة `set_` عند إضافة إعداد إلى `CustomSettings` أو إلى
`Settings` الخاصة بكل عملية.
ClickHouseTcpQueryOptions
تحدّد `ClickHouseTcpQueryOptions` إعدادات خاصة بكل عملية. جميع الخصائص اختيارية.
| الخاصية | النوع | القيمة الافتراضية | الوصف |
| - | - | - | - |
| QueryId | `string` | `null` | معرّف يُستخدم في `system.query_log` والسجلات ووحدات التتبّع span؛ إذا كانت قيمته `null` أو فارغة، يُنشأ GUID جديد لكل عملية |
| Settings | `IReadOnlyDictionary` | `null` | إعدادات الخادم الخاصة بهذه العملية؛ وتكون لقيمها الأولوية على القيم المطابقة في `CustomSettings` على مستوى العميل |
| Parameters | `ClickHouseTcpParameterCollection` | `null` | القيم المرتبطة بالعناصر النائبة `{name:Type}` في عبارة SQL |
| Callbacks | `ClickHouseTcpQueryCallbacks` | `null` | دوال الاستدعاء الراجعة المتزامنة للتقدّم، ومعلومات ملف التعريف، وسجلات الخادم، وأحداث ملف التعريف، والمجاميع، والقيم القصوى |
```csharp theme={null}
var queryOptions = new ClickHouseTcpQueryOptions
{
QueryId = $"report-{Guid.NewGuid():N}",
Settings = new Dictionary
{
["max_threads"] = "4",
},
};
object count = await client.ExecuteScalarAsync(
"SELECT count() FROM numbers(1000)",
queryOptions);
```
ClickHouseTcpInsertOptions
يوسّع `ClickHouseTcpInsertOptions` الصنف `ClickHouseTcpQueryOptions` بإعدادات خاصة بعمليات الإدراج باستخدام كتل
Native. كما تتوفر فيه جميع خصائص خيارات الاستعلام.
| الخاصية | النوع | القيمة الافتراضية | الوصف |
| - | - | - | - |
| MaxRowsPerBlock | `int?` | `50,000` | الحد الأقصى لعدد الصفوف في كل كتلة مُرسَلة عبر الشبكة؛ وعند تعيين القيمة `null` تُكتب عملية الإدراج بأكملها ككتلة واحدة. كما تقلّل القيم الأصغر من الذاكرة المؤقتة التي تستهلكها عمليات الإدراج القائمة على الصفوف وعمليات إدراج POCO. |
| DeduplicationToken | `string` | `null` | يحدّد دفعة واحدة بعينها لإزالة تكرار الإدراج على جانب الخادم. استخدم الرمز نفسه في كل إعادة محاولة لتلك الدفعة، ورمزًا مختلفًا لكل دفعة جديدة. |
```csharp theme={null}
var insertOptions = new ClickHouseTcpInsertOptions
{
MaxRowsPerBlock = 10_000,
DeduplicationToken = batchContentHash,
};
await client.InsertRowsAsync(
"INSERT INTO events (id, name) VALUES",
rows,
insertOptions);
```
ClickHouseTcpClient
`ClickHouseTcpClient` هي واجهة برمجة التطبيقات عالية المستوى لبروتوكول TCP الأصلي. تنفّذ عبارات SQL واستعلامات
تُرجع قيمة مفردة، وتُتيح النتائج على شكل كتل منظّمة حسب الأعمدة أو صفوف أو كائنات POCO، وتُدرج بيانات منظّمة حسب الأعمدة أو الصفوف،
وتفتح sessions مرتبطة باتصال ثابت.
يمكن استخدام هذا العميل بأمان من خيوط تنفيذ متعددة، وله مجمّع اتصالات خاص به. أنشئ عميلًا واحدًا لكل نقطة نهاية، وشاركه
بين أجزاء التطبيق، وتخلّص منه عند إيقاف التشغيل. يمكن تنفيذ العمليات بالتزامن حتى الحدّ
`MaxPoolSize`؛ أما العمليات الإضافية فتنتظر توفر اتصال لمدة لا تتجاوز `PoolTimeout`.
إنشاء عميل
أنشئ عميلًا من سلسلة اتصال أو من `ClickHouseTcpClientOptions`. راجع
[التهيئة](#configuration) لمعرفة الإعدادات المتاحة.
باستخدام سلسلة اتصال:
```csharp theme={null}
using ClickHouse.Driver.Tcp;
await using var client = new ClickHouseTcpClient(
"Host=localhost;Port=9000;Username=default");
```
باستخدام خيارات ذات أنواع محددة بوضوح:
```csharp theme={null}
var options = new ClickHouseTcpClientOptions
{
Host = "my.clickhouse",
Username = "user",
UseTls = true,
MaxPoolSize = 20,
};
await using var client = new ClickHouseTcpClient(options);
```
يُفضَّل تحرير موارد العميل بطريقة غير متزامنة. يؤدي ذلك إلى إغلاق الاتصالات غير النشطة والانتظار مدةً تصل إلى
`PoolTimeout` حتى تكتمل العمليات الجارية، ثم إيقاف ما لم يكتمل منها.
حقن التبعيات
تسجّل `AddClickHouseTcpDataSource` مصدر بيانات واحدًا يُعاد استخدام مثيله، وتوفّر عميله المشترك عبر
`IClickHouseTcpClient` و`IClickHouseTcpOperations`:
```csharp theme={null}
using ClickHouse.Driver.Tcp;
using Microsoft.Extensions.DependencyInjection;
services.AddClickHouseTcpDataSource(
"Host=my.clickhouse;UseTls=true;Username=user");
public sealed class ReportService(IClickHouseTcpClient client)
{
public async Task