FreeSql中使用SQLite数据库的事务处理注意事项

SQLite事务特性与FreeSql的UnitOfWork

在使用FreeSql框架操作SQLite数据库时，开发者可能会遇到"database is locked"的错误提示。这个问题通常发生在尝试在事务内部执行表结构迁移操作时。SQLite作为一种轻量级数据库，其事务处理机制与其他数据库有所不同，需要特别注意。

问题根源分析

SQLite采用单一写入器/多读取器模型，这意味着同一时间只能有一个写入操作。当开启事务后，整个数据库文件会被锁定。如果在事务内部尝试执行表结构迁移这类需要修改数据库结构的操作，就会导致锁冲突。

解决方案

正确的做法是在开启事务之前，预先完成所有表结构迁移工作。FreeSql提供了SyncStructure方法来实现这一点：

// 创建FreeSql实例
var fsql = new FreeSql.FreeSqlBuilder()
        .UseConnectionString(FreeSql.DataType.Sqlite, "Data Source=Demo.db")
        .UseAutoSyncStructure(true)
        .Build();

// 在事务开始前同步表结构
fsql.CodeFirst.SyncStructure(typeof(Company), typeof(Person));

// 开始事务操作
var uow = fsql.CreateUnitOfWork();
// ...其他事务操作

最佳实践建议

1. 预迁移策略：在应用启动时完成所有表结构迁移，而不是在事务内部动态迁移。

2. 事务粒度控制：SQLite的事务应尽量保持简短，避免长时间持有锁。

3. 连接管理：考虑使用连接池优化SQLite连接性能。

4. 错误处理：实现适当的重试机制处理可能的锁冲突。

代码示例

以下是一个完整的SQLite事务处理示例：

public class Program
{
    public static async Task Main()
    {
        var fsql = new FreeSql.FreeSqlBuilder()
                .UseConnectionString(FreeSql.DataType.Sqlite, "Data Source=Demo.db")
                .UseAutoSyncStructure(true)
                .Build();

        // 预先同步表结构
        fsql.CodeFirst.SyncStructure<Company>();
        fsql.CodeFirst.SyncStructure<Person>();

        try
        {
            using (var uow = fsql.CreateUnitOfWork())
            {
                var company = new Company { Name = "示例公司" };
                company.Id = await uow.Orm.Insert(company).ExecuteIdentityAsync();
                
                var person = new Person { 
                    Name = "张三", 
                    CompanyId = company.Id 
                };
                await uow.Orm.Insert(person).ExecuteIdentityAsync();
                
                uow.Commit();
                Console.WriteLine("事务提交成功");
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine($"事务处理失败: {ex.Message}");
        }
    }
}

public class Company
{
    [Column(IsIdentity = true)]
    public long Id { get; set; }
    public string Name { get; set; }
}

public class Person
{
    [Column(IsIdentity = true)]
    public long Id { get; set; }
    public long CompanyId { get; set; }
    public string Name { get; set; }
}

通过遵循这些实践，开发者可以避免SQLite在FreeSql中的事务处理问题，确保应用程序的稳定运行。