Update Array(uint8)/ byte[]

This commit is contained in:
sunkaixuan 2025-06-22 13:31:27 +08:00
parent d281857b55
commit bd17e7c9df
2 changed files with 15 additions and 0 deletions

View File

@ -166,7 +166,18 @@ namespace SqlSugar.ClickHouse
} }
else else
{ {
var isByteArray = false;
if (param.Value is byte[] bs)
{
isByteArray = true;
param.Value = bs.Select(it=>Convert.ToInt32(it));
}
sql = sql.Replace(param.ParameterName, this.Context.Utilities.SerializeObject(param.Value).Replace("\"","'")); sql = sql.Replace(param.ParameterName, this.Context.Utilities.SerializeObject(param.Value).Replace("\"","'"));
if (isByteArray)
{
param.Value = DBNull.Value;
param.DbType = System.Data.DbType.String;
}
} }
} }
else if (dbTypeString == "DateTime" && param.Value == DBNull.Value) else if (dbTypeString == "DateTime" && param.Value == DBNull.Value)

View File

@ -36,6 +36,10 @@ namespace SqlSugar.ClickHouse
var dbTypeName2 = dbTypeName.TrimStart('_'); var dbTypeName2 = dbTypeName.TrimStart('_');
return MappingTypes.Where(it => it.Value.ToString().ToLower() == dbTypeName2 || it.Key.ToLower() == dbTypeName2).Select(it => it.Value + "[]").First(); return MappingTypes.Where(it => it.Value.ToString().ToLower() == dbTypeName2 || it.Key.ToLower() == dbTypeName2).Select(it => it.Value + "[]").First();
} }
if (dbTypeName == "array")
{
return "object";
}
Check.ThrowNotSupportedException(string.Format(" \"{0}\" Type NotSupported, DbBindProvider.GetPropertyTypeName error.", dbTypeName)); Check.ThrowNotSupportedException(string.Format(" \"{0}\" Type NotSupported, DbBindProvider.GetPropertyTypeName error.", dbTypeName));
return String.Empty; return String.Empty;
} }