Skip to content

Commit 02f6d7e

Browse files
committed
Implemented vector column support for import into ClickHouse
1 parent 0a302b2 commit 02f6d7e

3 files changed

Lines changed: 2 additions & 1 deletion

File tree

src/DatabaseBenchmark/Databases/ClickHouse/ClickHouseNoParametersBuilder.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@ public override string Append(object value, ColumnType type, bool array) =>
1111
{
1212
DateTime dateTimeValue => Quote(dateTimeValue.ToSortableString()), //TODO: Make format customizable
1313
IEnumerable<object> arrayValue => $"[{string.Join(", ", arrayValue.Select(x => Append(x, type, false)))}]",
14+
Array arrayValue => $"[{string.Join(", ", arrayValue.Cast<object>().Select(x => Append(x, type, false)))}]",
1415
_ => base.Append(value, type, array)
1516
};
1617

src/DatabaseBenchmark/Databases/ClickHouse/ClickHouseTableBuilder.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@ protected override string BuildColumnType(Column column)
4141
ColumnType.String => "String",
4242
ColumnType.Text => "String",
4343
ColumnType.DateTime => "DateTime64",
44+
ColumnType.Vector => "Array(Float32)",
4445
_ => throw new InputArgumentException($"Unknown column type \"{column.Type}\"")
4546
};
4647

src/DatabaseBenchmark/Databases/ClickHouse/ClickHouseTableOptions.cs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
using DatabaseBenchmark.Common;
2-
using DatabaseBenchmark.Core;
32

43
namespace DatabaseBenchmark.Databases.ClickHouse
54
{

0 commit comments

Comments
 (0)