C#使用SqlServer作为日志数据库的设计与实现

using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace RH.Iot.DomainModel.RhLogDto
{
 /// 

 /// SqlServer数据库记录日志传输模型
 /// 
 [SugarTable("LogRecord")]
 public class RhLogRecordDtoSqlServer
 {
  /// 

  /// 索引
  /// 
  [SugarColumn(IsPrimaryKey = true, IsIdentity = true)]//主键并且自增 （string不能设置自增）
  public int Id { get; set; }
  /// 

  /// 日期
  /// 
  public string DateTime { get; set; }
  /// 

  /// 日志等级名称
  /// 
  public string LevelName { get; set; }
  /// 

  /// 信息
  /// 
  public string Message { get; set; }
  /// 

  ///异常
  /// 
  public string Exception { get; set; }
  /// 

  /// 无参构造器
  /// 
  public RhLogRecordDtoSqlServer()
  {

  }
  /// 

  /// 有参构造器
  /// 
  public RhLogRecordDtoSqlServer(int Id,string DateTime,string LevelName,string Message,string Exception)
  {
   this.Id = Id;
   this.DateTime = DateTime;
   this.LevelName =LevelName;
   this.Message = Message;
   this.Exception = Exception;

  }
 }
}

CREATE TABLE [dbo].[LogRecord] (
 [Id]  INT   IDENTITY (1, 1) NOT NULL,
 [DateTime] NVARCHAR (20) NULL,
 [LevelName] NCHAR (10)  NULL,
 [Message] NVARCHAR (MAX) NULL,
 [Exception] NVARCHAR (MAX) NULL,
 PRIMARY KEY CLUSTERED ([Id] ASC)
);

using Microsoft.Extensions.Logging;
using RH.Iot.DomainModel.RhLogDto;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace RH.Iot.DbAccess.RhSqlServerDbAccess.RhLogDbAccess
{
 
 /// 

 /// LogDbHelper 数据库日志操作
 /// 使用SqlServer做数据存储
 /// 目前提供异常和普通日志记录
 /// 方法待扩充
 /// 如果遇到数据库连接不上的问题 日志模式回归到txt模式(规划中...)
 /// 
 public class RhLogDbHelper
 {
  /// 

  /// 模型
  /// 
  public RhLogRecordDtoSqlServer rhLogRecordDtoSqlServer;
  /// 

  /// 私有化数据访问器
  /// 
  private RhLogRecordDtoDbAccessSqlServer DbAccess;
  /// 

  /// 构造器注入
  /// 
  /// 提供相应的数据访问类
  public RhLogDbHelper(RhLogRecordDtoDbAccessSqlServer dbAccess)
  {
   DbAccess = dbAccess;
   rhLogRecordDtoSqlServer = new RhLogRecordDtoSqlServer();
  }

  public void LogInfo(string msg) {

   rhLogRecordDtoSqlServer.DateTime = DateTime.Now.ToString();
   rhLogRecordDtoSqlServer.LevelName = "INFO";
   rhLogRecordDtoSqlServer.Message = msg;
   DbAccess.InsertAsync(rhLogRecordDtoSqlServer);

  }

  public void LogError(string msg,Exception ex)
  {
   rhLogRecordDtoSqlServer.DateTime = DateTime.Now.ToString();
   rhLogRecordDtoSqlServer.LevelName = "ERROR";
   rhLogRecordDtoSqlServer.Message = msg;
   rhLogRecordDtoSqlServer.Exception = ex.ToString();
   DbAccess.InsertAsync(rhLogRecordDtoSqlServer);
   

  }
 }
}

 RhLogDbHelper rldh = new RhLogDbHelper(new RhLogRecordDtoDbAccessSqlServer());
   rldh.LogInfo("hhahaha");
   try
   {
    int a = 1;
    int b = a / 0;
   }
   catch (Exception ex)
   {

    rldh.LogError("除法异常",ex);
   }