//使用System.Data.SQLite進(jìn)行SQLite數(shù)據(jù)庫操作
using System.Data.SQLite;

public class DeviceLog
{
    public int Id { get; set; }
    public string DeviceId { get; set; }
    public DateTime LogTime { get; set; }
    public double Value { get; set; }
    // 添加索引的常用查詢字段
    [Indexed] 
    public string LogType { get; set; }
}

// 慢如蝸牛的寫法
foreach (var log in logs)
{
    command.CommandText = $"INSERT INTO Logs VALUES ('{log.DeviceId}', {log.Value})";
    command.ExecuteNonQuery();
}

// 閃電插入（10萬條/3秒）
using (var transaction = connection.BeginTransaction())
{
    var command = new SQLiteCommand(
        "INSERT INTO Logs (DeviceId, Value) VALUES (@devId, @val)", 
        connection, 
        transaction);
        
    var param1 = new SQLiteParameter("@devId");
    var param2 = new SQLiteParameter("@val");
    command.Parameters.Add(param1);
    command.Parameters.Add(param2);

    foreach (var log in logs)
    {
        param1.Value = log.DeviceId;
        param2.Value = log.Value;
        command.ExecuteNonQuery();
    }
    transaction.Commit();
}

public List<DeviceLog> GetPagedLogs(int pageIndex, int pageSize)
{
    return connection.Query<DeviceLog>(@"
        SELECT * FROM Logs 
        ORDER BY LogTime DESC 
        LIMIT @PageSize 
        OFFSET @Offset",
        new { 
            PageSize = pageSize, 
            Offset = pageIndex * pageSize 
        }).ToList();
}

public async Task BulkInsertAsync(List<DeviceLog> logs)
{
    await using var conn = new SQLiteConnection(connectionString);
    await conn.OpenAsync();
    
    // 異步版本的事務(wù)操作
    await using var transaction = await conn.BeginTransactionAsync();
    // ...批量插入邏輯（同上）
    await transaction.CommitAsync();
}

// 在App啟動時初始化連接池
SQLiteConnectionPool.Configure(
    maxPoolSize: 10, 
    idleTimeout: TimeSpan.FromMinutes(5));

var tableName = $"Logs_{DateTime.Now:yyyyMM}";
ExecuteNonQuery($"CREATE TABLE IF NOT EXISTS {tableName} (...);");

// 查詢時強制分頁
command.CommandText = "SELECT * FROM BigTable LIMIT 5000"; 

// 每月執(zhí)行一次數(shù)據(jù)庫整理
ExecuteNonQuery("VACUUM; ANALYZE;");