Update mysql bulkcopy

This commit is contained in:
sunkaixuan
2022-09-30 22:26:06 +08:00
parent 74989f2270
commit fa339a4133
2 changed files with 15 additions and 2 deletions

View File

@@ -57,8 +57,13 @@ namespace SqlSugar
}
);
var dt = new DataTable();
List<string> uInt64TypeName = new List<string>();
foreach (DataColumn item in tempDataTable.Columns)
{
if (item.DataType == typeof(UInt64))
{
uInt64TypeName.Add(item.ColumnName);
}
dt.Columns.Add(item.ColumnName, item.DataType);
}
dt.TableName = GetTableName();
@@ -82,7 +87,8 @@ namespace SqlSugar
var value = ValueConverter(column, PropertyCallAdapterProvider<T>.GetInstance(column.PropertyName).InvokeGet(item));
if (isMySql && column.UnderType == UtilConstants.BoolType)
{
if (value.ObjToBool() == false)
if (value.ObjToBool() == false&& uInt64TypeName.Any(z=>z.EqualCase(column.DbColumnName)))
{
value = DBNull.Value;
}

View File

@@ -170,7 +170,14 @@ namespace SqlSugar
}
else if (colum.DataType == typeof(bool))
{
sb.Append(row[colum].ObjToBool() ? 1 : 0);
if (row[colum] == DBNull.Value)
{
sb.Append("NULL");
}
else
{
sb.Append(row[colum].ObjToBool() ? 1 : 0);
}
}
else if (colum.DataType == UtilConstants.DateType&& row[colum] != null && row[colum] != DBNull.Value)
{