lsm/SqlSugar
1
0
Fork 0
mirror of https://gitee.com/dotnetchina/SqlSugar.git synced 2025-04-05 17:37:58 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update TDengine

Browse Source
This commit is contained in:
sunkaixuan 2023-09-07 16:47:32 +08:00
parent 08fed0fda6
commit 4efd60a536
4 changed files with 44 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Src/Asp.NetCore2/SqlSugar.TDengineCore/SqlSugar.TDengineCore.csproj
View File

@ -6,7 +6,7 @@
</PropertyGroup>
<ItemGroup>
<PackageReference Include="TDengine.Ado.Data" Version="1.6.10" />
<PackageReference Include="TDengine.Ado.Data" Version="1.6.13" />
</ItemGroup>
<ItemGroup>

13
Src/Asp.NetCore2/SqlSugar.TDengineCore/TDengine/DbMaintenance/TDengineDbMaintenance.cs
View File

@ -225,8 +225,17 @@ namespace SqlSugar.TDengine
public override bool CreateDatabase(string databaseName,string databaseDirectory = null)
{
var db=this.Context.CopyNew();
db.Ado.Connection.ChangeDatabase("");
db.Ado.ExecuteCommand(string.Format(CreateDataBaseSql,databaseName));
db.Ado.Connection.ChangeDatabase("");
var sql = CreateDataBaseSql;
if (this.Context.CurrentConnectionConfig.ConnectionString.ToLower().Contains("config_us"))
{
sql += " PRECISION 'us'";
}
else if (this.Context.CurrentConnectionConfig.ConnectionString.ToLower().Contains("config_ns"))
{
sql += " PRECISION 'ns'";
}
db.Ado.ExecuteCommand(string.Format(sql, databaseName));
return true;
}
public override List<string> GetIndexList(string tableName)

4
Src/Asp.NetCore2/SqlSugar.TDengineCore/TDengine/TDengineProvider.cs
View File

@ -101,6 +101,10 @@ namespace SqlSugar.TDengine
{
sqlParameter.IsMicrosecond= true;
}
else if (parameter.CustomDbType?.Equals(typeof(Date19))==true)
{
sqlParameter.IsNanosecond = true;
}
result[i]=sqlParameter;
i++;
}

28
Src/Asp.NetCore2/SqlSugar.TDengineCore/Tools/DateTime19.cs Normal file
View File

@ -0,0 +1,28 @@
using System;
using System.Collections.Generic;
using System.Data;
using System.Text;
namespace SqlSugar
{
internal enum Date19
{
time=19
}
public class DateTime19: ISugarDataConverter
{
public SugarParameter ParameterConverter<T>(object columnValue, int columnIndex)
{
var name = "@Common" + columnIndex;
Type undertype = SqlSugar.UtilMethods.GetUnderType(typeof(T));//获取没有nullable的枚举类型
return new SugarParameter(name, columnValue, undertype) { CustomDbType= typeof(Date19) };
}
public T QueryConverter<T>(IDataRecord dr, int i)
{
var value = dr.GetValue(i);
return (T)UtilMethods.ChangeType2(value, typeof(T));
}
}
}