net core天馬行空系列-各大資料庫快速批量插入數據方法彙總

来源:https://www.cnblogs.com/hezp/archive/2022/07/28/16519431.html
-Advertisement-
Play Games

1.前言 hi，大家好，我是三合。我是怎麼想起寫一篇關於資料庫快速批量插入的博客的呢？事情起源於我們工作中的一個需求，簡單來說，就是有一個定時任務，從資料庫里獲取大量數據，在應用層面經過處理後再把結果批量插入回到資料庫里。這個任務每十分鐘執行一次，但是有的時候數據量太大，迴圈插入資料庫的時候會超時， ...


1.前言

hi，大家好，我是三合。我是怎麼想起寫一篇關於資料庫快速批量插入的博客的呢？事情起源於我們工作中的一個需求，簡單來說，就是有一個定時任務，從資料庫里獲取大量數據，在應用層面經過處理後再把結果批量插入回到資料庫里。這個任務每十分鐘執行一次，但是有的時候數據量太大，迴圈插入資料庫的時候會超時，導致任務失敗，所以這個時候我就開始研究怎麼快速批量插入資料庫，因為我們用的資料庫是Oracle，所以我首先研究了Oracle的快速批量插入，後面我一想那其他類型的資料庫肯定也有這樣的需求，於是我在找了很多資料，並且反覆實驗後，終於完美解決了mysql,sqlServer以及Oracle的快速批量插入，sqlite自身不支持，所以沒有sqlite，特地整理成這篇文章，分享給大家。

2.測試前準備

添加一個具有絕大多數類型屬性的實體類，用來完整測驗批量插入效果,該實體類用於mysql和sqlserver的測試。

public class NullableTable
{
    [DatabaseGenerated(DatabaseGeneratedOption.Identity)]
    [Key]
    public int Id { get; set; }
    [Description("Int2")]
    public int? Int2 { get; set; }
    [Description("Long2")]
    public long? Long2 { get; set; }

    public float? Float2 { get; set; }
    public double? Double2 { get; set; }

    public decimal? Decimal2 { get; set; }

    [DecimalPrecision(20,4)]
    public decimal? Decimal3 { get; set; }

    public Guid? Guid2 { get; set; }

    public short? Short2 { get; set; }

    public DateTime? DateTime2 { get; set; }

    public bool? Bool2 { get; set; }

    public TimeSpan? TimeSpan2 { get; set; }

    public byte? Byte2 { get; set; }


    [StringLength(100)]
    public string String2 { get; set; }
    public string String3 { get; set; }

    public Enum2? Enum2 { get; set; }

    [Column("TestInt3")]
    [Description("Int2")]
    public int? Int3 { get; set; }
}

 public enum Enum2
    {
        x,
        y
    }

因為oracle資料庫我們習慣於表名和欄位名大寫，所以oracle的測試實體類定義如下：

[Table("NULLABLETABLE")]
[Description("NullableTable")]
public class NullableTable
{
    [DatabaseGenerated(DatabaseGeneratedOption.Identity)]
    [Key]
    [Column("ID")]
    public int Id { get; set; }
    [Description("Int2")]
    [Column("INT2")]
    public int? Int2 { get; set; }
    [Description("Long2")]
    [Column("LONG2")]
    public long? Long2 { get; set; }
    [Column("FLOAT2")]
    public float? Float2 { get; set; }
    [Column("DOUBLE2")]
    public double? Double2 { get; set; }
    [Column("DECIMAL2")]
    public decimal? Decimal2 { get; set; }
    [Column("DECIMAL3")]
    [DecimalPrecision(20,4)]
    public decimal? Decimal3 { get; set; }
    [Column("GUID2")]
    public Guid? Guid2 { get; set; }
    [Column("SHORT2")]
    public short? Short2 { get; set; }
    [Column("DATETIME2")]
    public DateTime? DateTime2 { get; set; }
    [Column("BOOL2")]
    public bool? Bool2 { get; set; }
    [Column("TIMESPAN2")]
    public TimeSpan? TimeSpan2 { get; set; }
    [Column("BYTE2")]
    public byte? Byte2 { get; set; }

    [Column("STRING2")]
    [StringLength(100)]
    public string String2 { get; set; }
    [Column("STRING3")]
    public string String3 { get; set; }
    [Column("ENUM2")]
    public Enum2? Enum2 { get; set; }

    [Column("TESTINT3")]
    [Description("Int2")]
    public int? Int3 { get; set; }
}

實驗我們採用的是code first，先利用SummerBoot框架的可用於依賴註入的，資料庫表和c#實體類互相轉換的介面實現功能從實體類生成相應的資料庫表，本次實驗批量插入2w條數據來對比時間，定義一個列表，用迴圈的方式給這個列表添加2w條數據。

var nullableTableList3 = new List<NullableTable>();
var now = DateTime.Now;
for (int i = 0; i < 20000; i++)
{
    var a = new NullableTable()
    {
        Int2 = 2,
        Bool2 = true,
        Byte2 = 1,
        DateTime2 = now,
        Decimal2 = 1m,
        Decimal3 = 1.1m,
        Double2 = 1.1,
        Float2 = (float)1.1,
        Guid2 = Guid.NewGuid(),
        Id = 0,
        Short2 = 1,
        TimeSpan2 = TimeSpan.FromHours(1),
        String2 = "sb",
        String3 = "sb",
        Long2 = 2,
        Enum2 = Model.Enum2.y,
        Int3 = 4
    };
    nullableTableList3.Add(a);
}

資料庫驅動上的選擇是這樣的，sqlserver採用微軟官方驅動System.Data.SqlClient，oracle採用官方驅動Oracle.ManagedDataAccess.Core，mysql採用社區驅動MySqlConnector（為啥mysql不採用官方的驅動呢？因為官方的驅動封裝的太差了，社區的驅動支持列名映射，同時項目里官方驅動和社區驅動可以共存）。
同時快速批量插入均支持非同步同步，這裡僅演示同步，非同步的實現基本一樣。

3.sqlserver快速批量插入

sqlserver官方提供的批量插入方式是SqlBulkCopy，參數為一個dataTable對象，原生的批量插入代碼如下,採用StopWatch類進行計時,測試前都會用DELETE from NullableTable 語句清空表，測試里迴圈跑5次，獲取總時間後除以5獲取平均值，合計插入10w條數據。

var sw = new Stopwatch();
sw.Start();
for (int i = 0; i < 5; i++)
{
  using (var dbConnection = new SqlConnection(connectionString))
  {
      dbConnection.Open();

      SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(dbConnection, SqlBulkCopyOptions.KeepIdentity,
          null);
      sqlBulkCopy.BatchSize = 20000;
      sqlBulkCopy.DestinationTableName = "NullableTable";
      //針對列名做一下映射
      sqlBulkCopy.ColumnMappings.Add("Int2", "Int2");
      sqlBulkCopy.ColumnMappings.Add("Bool2", "Bool2");
      sqlBulkCopy.ColumnMappings.Add("Byte2", "Byte2");
      sqlBulkCopy.ColumnMappings.Add("DateTime2", "DateTime2");
      sqlBulkCopy.ColumnMappings.Add("Decimal2", "Decimal2");
      sqlBulkCopy.ColumnMappings.Add("Decimal3", "Decimal3");
      sqlBulkCopy.ColumnMappings.Add("Double2", "Double2");
      sqlBulkCopy.ColumnMappings.Add("Float2", "Float2");
      sqlBulkCopy.ColumnMappings.Add("Guid2", "Guid2");
      sqlBulkCopy.ColumnMappings.Add("Short2", "Short2");
      sqlBulkCopy.ColumnMappings.Add("TimeSpan2", "TimeSpan2");

      sqlBulkCopy.ColumnMappings.Add("String2", "String2");
      sqlBulkCopy.ColumnMappings.Add("String3", "String3");
      sqlBulkCopy.ColumnMappings.Add("Long2", "Long2");
      sqlBulkCopy.ColumnMappings.Add("Enum2", "Enum2");
      sqlBulkCopy.ColumnMappings.Add("Int3", "TestInt3");
      //將實體類列表轉換成dataTable
      var table = nullableTableList3.ToDataTable();
      sqlBulkCopy.WriteToServer(table);
  }

}
sw.Stop();            
var totalTime= sw.ElapsedMilliseconds;
var avgValue = totalTime / 5;

實驗結果如下，sql server中：
採用快速批量插入10w條數據，時間合計1858毫秒，平均插入2w條數據僅需371毫秒。
採用insert into語句，迴圈插入10w條數據，時間合計457606毫秒，平均插入2w條數據需91521毫秒。

4.實體類列表轉dataTable的擴展方法

這裡有一個實體類列表轉dataTable的擴展方法，採用的是表達式樹+構建委托的方式，性能不錯，大家可以參考，代碼實現如下。

public static ConcurrentDictionary<string, object> CacheDictionary = new ConcurrentDictionary<string, object>();
/// <summary>
/// 構建一個object數據轉換成一維數組數據的委托
/// </summary>
/// <param name="objType"></param>
/// <param name="propertyInfos"></param>
/// <returns></returns>
public static Func<T, object[]> BuildObjectGetValuesDelegate<T>(List<PropertyInfo> propertyInfos) where T : class
{
    var objParameter = Expression.Parameter(typeof(T), "model");
    var selectExpressions = propertyInfos.Select(it => BuildObjectGetValueExpression(objParameter, it));
    var arrayExpression = Expression.NewArrayInit(typeof(object), selectExpressions);
    var result = Expression.Lambda<Func<T, object[]>>(arrayExpression, objParameter).Compile();
    return result;
}


/// <summary>
/// 構建對象獲取單個值得
/// </summary>
/// <param name="modelExpression"></param>
/// <param name="propertyInfo"></param>
/// <returns></returns>
public static Expression BuildObjectGetValueExpression(ParameterExpression modelExpression, PropertyInfo propertyInfo)
{
    var propertyExpression = Expression.Property(modelExpression, propertyInfo);
    var convertExpression = Expression.Convert(propertyExpression, typeof(object));
    return convertExpression;
}

public static DataTable ToDataTable<T>(this IEnumerable<T> source, List<PropertyInfo> propertyInfos = null,bool useColumnAttribute=false) where T : class
{
    var table = new DataTable("template");
    if (propertyInfos == null || propertyInfos.Count == 0)
    {
        propertyInfos = typeof(T).GetProperties().Where(it => it.CanRead).ToList();
    }
    foreach (var propertyInfo in propertyInfos)
    {
        var columnName=useColumnAttribute?(propertyInfo.GetCustomAttribute<ColumnAttribute>()?.Name?? propertyInfo.Name) : propertyInfo.Name;
        table.Columns.Add(columnName, ChangeType(propertyInfo.PropertyType));
    }

    Func<T, object[]> func;
    var key = typeof(T).FullName + propertyInfos.Select(it => it.Name).ToList().StringJoin();
    if (CacheDictionary.TryGetValue(key, out var cacheFunc))
    {
        func = (Func<T, object[]>)cacheFunc;
    }
    else
    {
        func = BuildObjectGetValuesDelegate<T>(propertyInfos);
        CacheDictionary.TryAdd(key, func);
    }

    foreach (var model in source)
    {
        var rowData = func(model);
        table.Rows.Add(rowData);
    }

    return table;
}

private static Type ChangeType(Type type)
{
    if (type.IsNullable())
    {
        type = Nullable.GetUnderlyingType(type);
    }

    return type;
}

5.oracle快速批量插入

oracle官方提供的批量插入方式是ArrayBindCount，即數組批量插入，原生的批量插入代碼如下，計時方式與sqlserver相同

var total = 20000;
var sw = new Stopwatch();
sw.Start();
for (int i = 0; i < 5; i++)
{
    var connection = new OracleConnection(connectionString);
    connection.Open();
    int?[] Int2 = new int?[total];
    bool[] Bool2 = new bool[total];
    byte[] Byte2 = new byte[total];
    DateTime[] DateTime2 = new DateTime[total];
    decimal?[] Decimal2 = new decimal?[total];
    decimal[] Decimal3 = new decimal[total];
    double[] Double2 = new double[total];
    float[] Float2 = new float[total];
    Guid?[] Guid2 = new Guid?[total];
    short[] Short2 = new short[total];
    TimeSpan[] TimeSpan2 = new TimeSpan[total];
    string[] String2 = new string[total];
    string[] String3 = new string[total];
    long[] Long2 = new long[total];
    Enum2[] Enum2 = new Enum2[total];

    for (int j = 0; j < total; j++)
    {
        Int2[j] = 2;
        Bool2[j] = true;
        Byte2[j] = 1;
        DateTime2[j] = now;
        Decimal2[j] = 1m;
        Decimal3[j] = 1.1m;
        Double2[j] = 1.1;
        Float2[j] = (float) 1.1;
        Guid2[j] = Guid.NewGuid();
        Short2[j] = 1;
        TimeSpan2[j] = TimeSpan.FromHours(1);
        String2[j] = "sb";
        String3[j] = "sb";
        Long2[j] = 2;
        Enum2[j] = Model.Enum2.y;
    }

    var c = (int) Model.Enum2.y;
    OracleParameter pInt2 = new OracleParameter();
    pInt2.OracleDbType = OracleDbType.Int32;
    pInt2.Value = Int2;

    OracleParameter pBool2 = new OracleParameter();
    pBool2.OracleDbType = OracleDbType.Byte;
    pBool2.Value = Bool2;

    OracleParameter pByte2 = new OracleParameter();
    pByte2.OracleDbType = OracleDbType.Byte;
    pByte2.Value = Byte2;

    OracleParameter pDateTime2 = new OracleParameter();
    pDateTime2.OracleDbType = OracleDbType.TimeStamp;
    pDateTime2.Value = DateTime2;

    OracleParameter pDecimal2 = new OracleParameter();
    pDecimal2.OracleDbType = OracleDbType.Decimal;
    pDecimal2.Value = Decimal2;

    OracleParameter pDecimal3 = new OracleParameter();
    pDecimal3.OracleDbType = OracleDbType.Decimal;
    pDecimal3.Value = Decimal3;

    OracleParameter pDouble2 = new OracleParameter();
    pDouble2.OracleDbType = OracleDbType.Double;
    pDouble2.Value = Double2;

    OracleParameter pFloat2 = new OracleParameter();
    pFloat2.OracleDbType = OracleDbType.BinaryFloat;
    pFloat2.Value = Float2;


    OracleParameter pGuid2 = new OracleParameter();
    pGuid2.OracleDbType = OracleDbType.Raw;
    pGuid2.Value = Guid2;

    OracleParameter pShort2 = new OracleParameter();
    pShort2.OracleDbType = OracleDbType.Int16;
    pShort2.Value = Short2;

    OracleParameter pTimeSpan2 = new OracleParameter();
    pTimeSpan2.OracleDbType = OracleDbType.IntervalDS;
    pTimeSpan2.Value = TimeSpan2;

    OracleParameter pString2 = new OracleParameter();
    pString2.OracleDbType = OracleDbType.Varchar2;
    pString2.Value = String2;

    OracleParameter pString3 = new OracleParameter();
    pString3.OracleDbType = OracleDbType.Varchar2;
    pString3.Value = String3;


    OracleParameter pLong2 = new OracleParameter();
    pLong2.OracleDbType = OracleDbType.Long;
    pLong2.Value = Long2;

    OracleParameter pEnum2 = new OracleParameter();
    pEnum2.OracleDbType = OracleDbType.Byte;
    pEnum2.Value = Enum2;
    // create command and set properties
    OracleCommand cmd = connection.CreateCommand();
    cmd.CommandText =
        "INSERT INTO NULLABLETABLE (INT2, LONG2, FLOAT2, DOUBLE2, DECIMAL2, DECIMAL3, GUID2, SHORT2, DATETIME2, BOOL2, TIMESPAN2, BYTE2, STRING2, STRING3,ENUM2) VALUES(:1,:2,:3,:4,:5,:6,:7,:8,:9,:10,:11,:12,:13,:14,:15)";
    cmd.ArrayBindCount = total;
    cmd.Parameters.Add(pInt2);
    cmd.Parameters.Add(pLong2);
    cmd.Parameters.Add(pFloat2);
    cmd.Parameters.Add(pDouble2);
    cmd.Parameters.Add(pDecimal2);
    cmd.Parameters.Add(pDecimal3);
    cmd.Parameters.Add(pGuid2);
    cmd.Parameters.Add(pShort2);
    cmd.Parameters.Add(pDateTime2);
    cmd.Parameters.Add(pBool2);
    cmd.Parameters.Add(pTimeSpan2);
    cmd.Parameters.Add(pByte2);
    cmd.Parameters.Add(pString2);
    cmd.Parameters.Add(pString3);
    cmd.Parameters.Add(pEnum2);
    cmd.ExecuteNonQuery();
}
sw.Stop();

var totalTime = sw.ElapsedMilliseconds;
var avgValue = totalTime / 5;

實驗結果如下，oracle中：
採用快速批量插入10w條數據，時間合計2323毫秒，平均插入2w條數據僅需464毫秒。
採用insert into語句，迴圈插入10w條數據，時間合計462837毫秒，平均插入2w條數據僅需92567毫秒。

6.mysql快速批量插入

mysql社區驅動MySqlConnector提供的批量插入方式是SqlBulkCopy，基於mysql自身的文件上傳機制進行批量插入，參數為一個dataTable對象，原生的批量插入代碼如下,計時方式與sqlserver相同,同時，mysql的連接字元串里要添加";AllowLoadLocalInfile=true"，即連接字元串的形式應該是"Server= ;Database=;User ID=;Password=;AllowLoadLocalInfile=true"，同時在mysql資料庫上執行"set global local_infile=1"開啟批量上傳

var sw = new Stopwatch();
sw.Start();
for (int j = 0; j < 5; j++)
{
    using (var dbConnection = new MySqlConnection(connectionString))
    {
        dbConnection.Open();

        MySqlBulkCopy sqlBulkCopy = new MySqlBulkCopy(dbConnection, null);
        sqlBulkCopy.DestinationTableName = "NullableTable";
        var propertys = typeof(NullableTable).GetProperties()
            .Where(it => it.CanRead && it.GetCustomAttribute<NotMappedAttribute>() == null).ToList();

        for (int i = 0; i < propertys.Count; i++)
        {
            var property = propertys[i];
            var columnName = property.GetCustomAttribute<ColumnAttribute>()?.Name ?? property.Name;

            if (property.PropertyType.GetUnderlyingType() == typeof(Guid))
            {
                sqlBulkCopy.ColumnMappings.Add(new MySqlBulkCopyColumnMapping(i, "@tmp",
                    $"{columnName} =unhex(@tmp)"));
            }
            else
            {
                sqlBulkCopy.ColumnMappings.Add(new MySqlBulkCopyColumnMapping(i, columnName));
            }
        }

        var table = nullableTableList3.ToDataTable();

        SbUtil.ReplaceDataTableColumnType<Guid, byte[]>(table, guid1 => guid1.ToByteArray());
        var c = sqlBulkCopy.WriteToServer(table);
    }
}

sw.Stop();

var totalTime = sw.ElapsedMilliseconds;
var avgValue = totalTime / 5;

實驗結果如下，mysql中：
採用快速批量插入10w條數據，時間合計2350毫秒，平均插入2w條數據僅需470毫秒。
採用insert into語句，迴圈插入10w條數據，時間合計414700毫秒，平均插入2w條數據需82940毫秒。

在mysql中c#的guid對應的mysql欄位類型為varbinary(16)，所以table里的guid要轉換為位元組數組，否則插入資料庫後，guid的值就會變成亂碼,位元組數組傳遞到mysql服務端後利用unhex函數進行解析，即可正常保存guid類型。 將table里guid的值轉為位元組數組的方法-SbUtil.ReplaceDataTableColumnType的代碼實現如下：

/// <summary>
/// 替換dataTable里的列類型
/// </summary>
/// <param name="dt"></param>
public  static void ReplaceDataTableColumnType<OldType,NewType>(DataTable dt,Func<OldType, NewType> replaceFunc)
{
    var needUpdateColumnIndexList = new List<int>();
    var needUpdateColumnNameList = new List<string>();
    
    for (int i = 0; i < dt.Columns.Count; i++)
    {
        var column = dt.Columns[i];
        if (column.DataType.GetUnderlyingType() == typeof(OldType))
        {
            needUpdateColumnIndexList.Add(i);
            needUpdateColumnNameList.Add(column.ColumnName);
          
        }
    }

    if (needUpdateColumnIndexList.Count == 0)
    {
        return;
    }

    var nameMapping = new Dictionary<string, string>();
    for (int i = 0; i < needUpdateColumnIndexList.Count; i++)
    {
        var oldColumnName = needUpdateColumnNameList[i];
        var newColumnName = Guid.NewGuid().ToString("N");
        nameMapping.Add(newColumnName, oldColumnName);
      
        dt.Columns.Add(newColumnName, typeof(byte[])).SetOrdinal(needUpdateColumnIndexList[i]);
        for (int j = 0; j < dt.Rows.Count; j++)
        {
            var c = (dt.Rows[j][oldColumnName]);
            dt.Rows[j][newColumnName] = replaceFunc((OldType)(dt.Rows[j][oldColumnName]));
        }
        dt.Columns.Remove(oldColumnName);
    }
    
    for (int i = 0; i < dt.Columns.Count; i++)
    {
        var columnName = dt.Columns[i].ColumnName;
        if (nameMapping.ContainsKey(columnName))
        {
            dt.Columns[i].ColumnName = nameMapping[columnName];
        }
    }

}

7.SummerBoot對各資料庫快速批量插入的封裝

基於以上各種資料庫對於快速批量插入的原生寫法過於複雜難記，SummerBoot對其進行了封裝，在聲明式編程的理念下，封裝後僅需3步即可快速批量插入，這裡以sqlserver舉例。

7.1在StartUp.cs中添加summerBoot的服務支持

services.AddSummerBoot();
services.AddSummerBootRepository(it =>
{
    it.DbConnectionType = typeof(SqlConnection);
    it.ConnectionString = connectionString;
});

7.2添加倉儲介面

[AutoRepository]
public interface INullableTableRepository : IBaseRepository<NullableTable>
{
    
}

7.3註入倉儲介面後直接調用FastBatchInsert方法

var sw = new Stopwatch();
sw.Start();
for (int i = 0; i < 5; i++)
{
    nullableTableRepository.FastBatchInsert(nullableTableList3);
}
sw.Stop();
  
var totalTime= sw.ElapsedMilliseconds;
var avgValue = totalTime / 5;

實驗結果如下，sql server中：
採用SummerBoot統一封裝後快速批量插入10w條數據，時間合計3926（原生快速批量寫法1858）毫秒，平均插入2w條數據僅需785(原生快速批量寫法371)毫秒。從對比可以看出，經過SummerBoot封裝後，快速批量插入所花費的時間有所增加，但是對於這麼大數據量而言，這點多消耗的時間和節省的開發量對比，不值一提。

寫在最後

SummerBoot是一款聲明式編程框架，專註於”做什麼”而不是”如何去做”，更多用法，可參考SummerBoot文檔，也可以加入QQ群:799648362反饋建議。同時各位看官，如果你覺得這篇文章還不錯的話，請幫忙一鍵三連哦(推薦+關註+github star)


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 【Python編程基礎練習】 Python編程基礎練習100題學習記錄第一期（1~10）
    1.此為GitHub項目的學習記錄，記錄著我的思考，代碼基本都有註釋。 2.可以作為Python初學者鞏固基礎的絕佳練習，原題有些不妥的地方我也做了一些修正。 3.建議大家進行Python編程時使用英語，工作時基本用英語。 4.6~17題為level1難度，18-22題為level3難度，其餘都為l ...
  • [數據結構-線性表1.1] 數組 （.NET源碼學習）
    [數據結構-線性表1.1] 數組（.NET源碼學習） 數組，一種數據類型（在絕大數語言中不是基本數據類型）且為引用類型，在記憶體中以連續的記憶體單元進行分配，所以其大小在創建對象後為定值，不可更改。 一．記憶體分配 對於兩種不同數據類型而言，其記憶體分配方式是不同的。值類型直接在棧（C#中稱為堆棧Stack ...
  • C#併發編程-1 併發編程概述
    一 併發編程簡介 1.1 關於併發和並行 併發和並行的概念： 併發：(Concurrent)，在某個時間段內，如果有多個任務執行，即有多個線程在操作時，如果系統只有一個CPU,則不能真正同時進行一個以上的線程， 它只能把CPU運行時間劃分成若幹個時間段,再將時間段分配給各個線程執行，在一個時間段的線 ...
  • WPF開發之ScreenCut截圖改變大小
    前言 接著上周寫的截圖控制項繼續更新 縮放操作。 1.WPF實現截屏「仿微信」 2.WPF 實現截屏控制項之移動（二）「仿微信」 正文 實現拉伸放大或縮小縮放操作需在矩形四個方向繪製8個Thumb，這裡有兩種方式 1）可以自行在XAML中硬編寫8個Thumb 2）使用裝飾器Adorner 本章使用了第二 ...
  • ASP.NET Web 應用 Docker踩坑歷程——續
    ASP.NET Web 應用 Docker踩坑歷程發表後，也開始使用Docker了，然而發佈的過程比較痛苦，經常發生下圖的事情： 據說是nuget包還原時發生錯誤 百度了半天也找不到解決的方法，而發生的概率有相當高，很是無語。 仔細看了自動生成的Dockerfile FROM mcr.microso ...
  • asp.net接收API Post Json數據為空要註意的事項
    今天在處理一個接收API通過Post方式傳送Json數據的方法時，碰到接收的Json數據一直是空的問題。最好找了好久才解決，現在把需要的問題列出來。 1. 在一般處理程式中，需要設置 context.Request.InputStream.Position = 0; 剛開始設置了這個，但後面還是為空 ...
  • .NET的求複雜類型集合的差集、交集、並集
    前言 如標題所述，在ASP.NET應用程式開發中，兩個集合做比較時 我們使用微軟IEnumerable封裝的 Except/Intersect/Union 取 差集/交集/並集 方法是非常的方便的； 但以上對於不太熟悉的小伙伴來講，在遇到求包含引用類型(不包含string)集合時就非常的苦惱； 下麵 ...
  • SkiaSharp 之 WPF 自繪 拖曳小球（案例版）
    WPF的拖曳效果，基本配置一下，就可以了，但是自繪的話，就得自己控制，按鍵點擊，按鍵移動和按鍵鬆開的事件，與其配合達到目的。 ...
一周排行
    -Advertisement-
    Play Games
  • C#自增運算符詳解：++i與i++的區別及應用場景
    概述：在C#中，++i和i++都是自增運算符，其中++i先增加值再返回，而i++先返回值再增加。應用場景根據需求選擇，首碼適合先增後用，尾碼適合先用後增。詳細示例提供清晰的代碼演示這兩者的操作時機和實際應用。 在C#中，++i 和 i++ 都是自增運算符，但它們在操作上有細微的差異，主要體現在操作的 ...
  • Taurus.MVC 性能壓力測試（ap 壓測 和 linux 下wrk 壓測）：.NET 版本
    上次發佈了：Taurus.MVC 性能壓力測試（ap 壓測 和 linux 下wrk 壓測）：.NET Core 版本，今天計劃準備壓測一下 .NET 版本，來測試並記錄一下 Taurus.MVC 框架在 .NET 版本的性能，以便後續持續優化改進。 為了方便對比，本文章的電腦環境和測試思路，儘量和... ...
  • 一文讀懂.NET WebAPI中FromRoute、FromQuery、FromBody的關鍵角色與用法
    .NET WebAPI作為一種構建RESTful服務的強大工具，為開發者提供了便捷的方式來定義、處理HTTP請求並返迴響應。在設計API介面時，正確地接收和解析客戶端發送的數據至關重要。.NET WebAPI提供了一系列特性，如[FromRoute]、[FromQuery]和[FromBody]，用 ...
  • WPF/C#實現圖像濾鏡優化方案：打造炫目視覺體驗！
    原因：我之所以想做這個項目，是因為在之前查找關於C#/WPF相關資料時，我發現講解圖像濾鏡的資源非常稀缺。此外，我註意到許多現有的開源庫主要基於CPU進行圖像渲染。這種方式在處理大量圖像時，會導致CPU的渲染負擔過重。因此，我將在下文中介紹如何通過GPU渲染來有效實現圖像的各種濾鏡效果。 生成的效果 ...
  • Bogus 實戰：使用 Bogus 和 EFCore 生成模擬數據和種子數據【完整教程】
    引言 上一章我們介紹了在xUnit單元測試中用xUnit.DependencyInject來使用依賴註入，上一章我們的Sample.Repository倉儲層有一個批量註入的介面沒有做單元測試，今天用這個示例來演示一下如何用Bogus創建模擬數據 ，和 EFCore 的種子數據生成 Bogus 的優 ...
  • WPF隨筆收錄-實時繪製心率曲線
    一、前言 在自己的項目中，涉及到實時心率曲線的繪製，項目上的曲線繪製，一般很難找到能直接用的第三方庫，而且有些還是定製化的功能，所以還是自己繪製比較方便。很多人一聽到自己畫就害怕，感覺很難，今天就分享一個完整的實時心率數據繪製心率曲線圖的例子；之前的博客也分享給DrawingVisual繪製曲線的方 ...
  • wpf程式修改啟動入口註意事項
    如果你在自定義的 Main 方法中直接使用 App 類並啟動應用程式，但發現 App.xaml 中定義的資源沒有被正確載入，那麼問題可能在於如何正確配置 App.xaml 與你的 App 類的交互。 確保 App.xaml 文件中的 x:Class 屬性正確指向你的 App 類。這樣，當你創建 Ap ...
  • 記一次 .NET某爐膛鍋爐檢測系統 崩潰分析
    一：背景 1. 講故事 上個月有個朋友在微信上找到我，說他們的軟體在客戶那邊隔幾天就要崩潰一次，一直都沒有找到原因，讓我幫忙看下怎麼回事，確實工控類的軟體環境複雜難搞，朋友手上有一個崩潰的dump，剛好丟給我來分析一下。 二：WinDbg分析 1. 程式為什麼會崩潰 windbg 有一個厲害之處在於 ...
  • 一個.NET內置依賴註入的小型強化版
    前言 .NET生態中有許多依賴註入容器。在大多數情況下，微軟提供的內置容器在易用性和性能方面都非常優秀。外加ASP.NET Core預設使用內置容器，使用很方便。 但是筆者在使用中一直有一個頭疼的問題：服務工廠無法提供請求的服務類型相關的信息。這在一般情況下並沒有影響，但是內置容器支持註冊開放泛型服 ...
  • WPF隨筆收錄-DataGrid固定右側列
    一、前言 在項目開發過程中，DataGrid是經常使用到的一個數據展示控制項，而通常表格的最後一列是作為操作列存在，比如會有編輯、刪除等功能按鈕。但WPF的原始DataGrid中，預設只支持固定左側列，這跟大家習慣性操作列放最後不符，今天就來介紹一種簡單的方式實現固定右側列。（這裡的實現方式參考的大佬 ...
所有分類