``` ### 实体类特性 > `TableEntity` | Attribute | Use | Description | | ------------------------------------------------------------------------------ | -------- | -------------------------------------------------------------- | | `Sean.Core.DbRepository.CodeFirstAttribute` | Class | 标记为CodeFirst的类 | | **`System.ComponentModel.DataAnnotations.Schema.TableAttribute`** | Class | 设置表名 | | `Sean.Core.DbRepository.SequenceAttribute` | Property | 设置序列号名称
（生成自增Id） | | **`System.ComponentModel.DataAnnotations.KeyAttribute`** | Property | 标记为主键字段 | | **`System.ComponentModel.DataAnnotations.Schema.DatabaseGeneratedAttribute`** | Property | 设置数据库生成字段值的方式
（通常和`KeyAttribute`一起使用） | | **`System.ComponentModel.DataAnnotations.Schema.ColumnAttribute`** | Property | 设置字段名 | | `System.ComponentModel.DescriptionAttribute` | Property | 设置字段描述 | | `Sean.Core.DbRepository.NumericAttribute` | Property | 设置数值字段的位数和精度 | | `System.ComponentModel.DataAnnotations.MaxLengthAttribute` | Property | 设置字段的最大长度 | | `System.ComponentModel.DataAnnotations.RequiredAttribute` | Property | 设置字段不允许为空 | | `System.ComponentModel.DefaultValueAttribute` | Property | 设置字段默认值 | | **`System.ComponentModel.DataAnnotations.Schema.NotMappedAttribute`** | Property | 标记为为忽略字段 | | ~~`System.ComponentModel.DataAnnotations.Schema.ForeignKeyAttribute`~~ | Property | 标记为外键字段（***暂不支持***） | ### 增删改查 > CRUD: `IBaseRepository` ```csharp // 新增数据： _testRepository.Add(entity); // 批量新增数据： _testRepository.Add(entities); // 新增或更新数据： _testRepository.AddOrUpdate(entity); // 批量新增或更新数据： _testRepository.AddOrUpdate(entities); // 删除数据：过滤条件默认为实体的主键字段 _testRepository.Delete(entity); // 删除数据：自定义过滤条件 _testRepository.Delete(entity => entity.UserId == 10001 && entity.Status != 0); // 删除全部数据： _testRepository.Delete(entity => true); // 删除全部数据： _testRepository.DeleteAll(); // 更新数据：更新全部字段，过滤条件默认为实体的主键字段 _testRepository.Update(entity); // 更新数据：更新部分字段，过滤条件默认为实体的主键字段 _testRepository.Update(entity, fieldExpression: entity => new { entity.Status, entity.UpdateTime }); // 更新数据：更新全部字段，自定义过滤条件 _testRepository.Update(entity, whereExpression: entity => entity.UserId == 10001 && entity.Status != 0); // 更新数据：更新部分字段，自定义过滤条件 _testRepository.Update(entity, fieldExpression: entity => new { entity.Status, entity.UpdateTime }, whereExpression: entity => entity.UserId == 10001 && entity.Status != 0); // 批量更新数据：更新全部字段，过滤条件默认为实体的主键字段 _testRepository.Update(entities); // 批量更新数据：更新部分字段，过滤条件默认为实体的主键字段 _testRepository.Update(entities, fieldExpression: entity => new { entity.Status, entity.UpdateTime }); // 数值字段递增： _testRepository.Increment(10.0M, fieldExpression: entity => entity.AccountBalance, whereExpression: entity => entity.Id == 10001); // 数值字段递减： _testRepository.Decrement(10.0M, fieldExpression: entity => entity.AccountBalance, whereExpression: entity => entity.Id == 10001); // 查询数据：分页 + 排序 int pageNumber = 1;// 当前页号（最小值为1） int pageSize = 10;// 页大小 OrderByCondition orderBy = OrderByConditionBuilder.Build(OrderByType.Asc, entity => entity.CreateTime); orderBy.Next = OrderByConditionBuilder.Build(OrderByType.Asc, entity => entity.Id); List queryResult = _testRepository.Query(entity => entity.UserId == 10001, orderBy, pageNumber, pageSize)?.ToList(); // 查询单个数据： TestEntity getResult = _testRepository.Get(entity => entity.Id == 2); // 统计数量： int countResult = _testRepository.Count(entity => entity.UserId == 10001); // 数据是否存在： bool exists = _testRepository.Exists(entity => entity.UserId == 10001); // 更多使用示例在单元测试中：Sean.Core.DbRepository.Test.TableRepositoryTest ``` > 表达式树：`Expression> whereExpression` ```csharp // 常量 entity => entity.UserId == 10001L // 变量 entity => entity.UserId == _model.UserId // bool entity => entity.IsVip // bool entity => !entity.IsVip // && entity => entity.UserId == _model.UserId && entity.AccountBalance < accountBalance // || entity => entity.UserId == _model.UserId || entity.AccountBalance >= accountBalance // StartsWith entity => entity.UserId == _model.UserId && entity.Remark.StartsWith("测试") // 更多使用示例在单元测试中：Sean.Core.DbRepository.Test.WhereExpressionTest ``` > 表达式树：`Expression> fieldExpression` ```csharp // 单个字段： entity => entity.Status // 多个字段（匿名类型）： entity => new { entity.Status, entity.UpdateTime } // 更多使用示例在单元测试中：Sean.Core.DbRepository.Test.FieldExpressionTest ``` ## ❓ 常见问题 > `OleDb`和`ODBC`的区别？ 1. `OleDb`是Microsoft开发的一种数据库连接技术，它是面向对象的，可以连接多种类型的数据库，包括`Access`、`Excel`、`SQL Server`等等。OleDb使用COM接口连接数据库，因此只能在Windows平台上使用。 2. `ODBC`是一种通用的数据库连接技术，它可以连接多种类型的数据库，包括`Access`、`Excel`、`SQL Server`等等。ODBC使用标准的API连接数据库，因此可以在多个平台上使用，包括Windows、Linux、Unix等等。 > 怎么解决`SQLite`数据库并发读写导致的锁库问题（database is locked）？ ``` 问：为什么SQLite并发读写容易出现锁库问题？答：SQLite使用文件级锁定来管理对数据库的并发访问。这意味着在同一时间，只有一个写操作可以进行，而多个读操作可以并发进行。 SQLite数据库的WAL模式是一种日志机制，它可以减少写入操作时的锁冲突，从而提高并发性能。有以下2种方式启用WAL模式： ``` 方式1：在连接字符串中添加：journal mode=Wal ```csharp using System.Data.SQLite; // 数据库连接字符串 var connStringBuilder = new SQLiteConnectionStringBuilder { DataSource = @".\test.db", Pooling = true, BusyTimeout = 30000, JournalMode = SQLiteJournalModeEnum.Wal }; var connString = connStringBuilder.ConnectionString;// data source=.\test.db;pooling=True;busytimeout=30000;journal mode=Wal ``` 方式2：通过执行SQL命令来设置WAL模式： ```sql -- 查看 SQLite 数据库日志模式： PRAGMA journal_mode; -- 设置 SQLite 数据库日志模式： PRAGMA journal_mode = 'wal'; -- 查看 WAL 文件中未被同步的页面数： PRAGMA wal_checkpoint; ``` - 需要注意的是，如果在多个线程或进程中对同一个数据库文件进行写入，且没有适当的同步机制，那么即使使用WAL模式，也可能会出现锁库的情况。使用WAL模式，读和写可以完全地并发执行，不会互相阻塞（但是写之间仍然不能并发）。为了解决并发写入问题，需要增加如下配置（同步锁机制）： ```csharp DbContextConfiguration.Configure(options => { #if UseSqlite options.SynchronousWriteOptions.Enable = true;// 启用同步写入模式：解决多线程并发写入导致的锁库问题 options.SynchronousWriteOptions.LockTimeout = 30000;// 同步写入锁等待超时时间（单位：毫秒），默认值：10000 options.SynchronousWriteOptions.OnLockTakenFailed = lockTimeout => { Console.WriteLine($"######获取同步写入锁失败({lockTimeout}ms)"); return true;// 返回true：继续执行（仍然可能会发生锁库问题）。返回false：不再继续执行，直接返回默认值 }; #endif }); ```