修复ClickHouse会报Column names not initialized的错误 #2129

Original file line number	Diff line number	Diff line change
Expand Up		@@ -185,14 +185,21 @@ async protected override Task<int> RawExecuteAffrowsAsync(CancellationToken canc
		before = new Aop.CurdBeforeEventArgs(_table.Type, _table, Aop.CurdType.Insert, null, _params);
		_orm.Aop.CurdBeforeHandler?.Invoke(this, before);
		var data = ToDataTable();
	var columns = new string[_table.ColumnsByPosition.Length];
	for (var i = 0; i < columns.Length; i++)
	{
	columns[i] = _table.ColumnsByPosition[i].CsName;
	}
		using (var conn = await _orm.Ado.MasterPool.GetAsync())
		{
		using (var bulkCopyInterface = new ClickHouseBulkCopy(conn.Value as ClickHouseConnection)
		{
		DestinationTableName = data.TableName,
	BatchSize = _source.Count
	BatchSize = _source.Count,
	ColumnNames = columns,
		})
		{
	await bulkCopyInterface.InitAsync();
		await bulkCopyInterface.WriteToServerAsync(data, default);
		}
		}
Expand All		@@ -201,7 +208,7 @@ async protected override Task<int> RawExecuteAffrowsAsync(CancellationToken canc
		catch (Exception ex)
		{
		exception = ex;
	throw ex;
	throw;
		}
		finally
		{
Expand Down

Navigation Menu