weiai/FreeSql
1
0
Fork 0
mirror of https://github.com/dotnetcore/FreeSql.git synced 2026-02-06 16:30:52 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2106 from Im-Kevin/master

Browse Source 
将ClickHouse的驱动从ClickHouse.Client改成ClickHouse.Driver
This commit is contained in:
2881099
2025-09-15 12:23:01 +08:00
committed by GitHub
parent 1c97497490 bcd11639d1
commit 48bc6f9d0e
7 changed files with 17 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
Providers/FreeSql.Provider.ClickHouse/ClickHouseAdo/ClickHouseAdo.cs
View File

@@ -1,4 +1,4 @@
using ClickHouse.Client.ADO;
using ClickHouse.Driver.ADO;
using FreeSql.Internal;
using FreeSql.Internal.CommonProvider;
using FreeSql.Internal.Model;

2
Providers/FreeSql.Provider.ClickHouse/ClickHouseAdo/ClickHouseConnectionPool.cs
View File

@@ -6,7 +6,7 @@ using System.Data;
using System.Data.Common;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using ClickHouse.Client.ADO;
using ClickHouse.Driver.ADO;
namespace FreeSql.ClickHouse
{

2
Providers/FreeSql.Provider.ClickHouse/ClickHouseCodeFirst.cs
View File

@@ -10,7 +10,7 @@ using System.Text.RegularExpressions;
using System.Data.Common;
using System.Reflection;
using FreeSql.Internal.ObjectPool;
using ClickHouse.Client.ADO;
using ClickHouse.Driver.ADO;
using FreeSql.DataAnnotations;
namespace FreeSql.ClickHouse

2
Providers/FreeSql.Provider.ClickHouse/ClickHouseDbFirst.cs
View File

@@ -7,7 +7,7 @@ using System.Data;
using System.Linq;
using System.Text;
using System.Text.RegularExpressions;
using ClickHouse.Client.ADO;
using ClickHouse.Driver.ADO;
namespace FreeSql.ClickHouse
{

4
Providers/FreeSql.Provider.ClickHouse/ClickHouseUtils.cs
View File

@@ -1,13 +1,13 @@
using FreeSql.Internal;
using FreeSql.Internal.Model;
using ClickHouse.Client.ADO;
using ClickHouse.Driver.ADO;
using System;
using System.Collections.Generic;
using System.Data.Common;
using System.Globalization;
using System.Data;
using System.Text.Json;
using ClickHouse.Client.ADO.Parameters;
using ClickHouse.Driver.ADO.Parameters;
using System.Text.RegularExpressions;
using System.Text;

14
Providers/FreeSql.Provider.ClickHouse/Curd/ClickHouseInsert.cs
View File

@@ -1,5 +1,5 @@
using ClickHouse.Client.ADO;
using ClickHouse.Client.Copy;
using ClickHouse.Driver.ADO;
using ClickHouse.Driver.Copy;
using FreeSql.Internal;
using FreeSql.Internal.Model;
using System;
@@ -77,13 +77,19 @@ namespace FreeSql.ClickHouse.Curd
internal async Task<int> InternalBulkCopyAsync()
{
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 = _orm.Ado.MasterPool.Get())
{
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);

2
Providers/FreeSql.Provider.ClickHouse/FreeSql.Provider.ClickHouse.csproj
View File

@@ -33,7 +33,7 @@
</ItemGroup>
<ItemGroup>
<PackageReference Include="ClickHouse.Client" Version="7.13.2" />
<PackageReference Include="ClickHouse.Driver" Version="0.7.20" />
</ItemGroup>
</Project>