C#使用sqlite-net搭建简易的ORM

SQLite简易版ORM

首先打开项目，使用nuget搜索sqlite-net,如下图：

下载完成后，我们会多出两个文件，SQLite.cs和SQLiteAsync.cs。

我们新建一个文件夹SQLiteResources，把这俩文件放进去。

然后我们创建两个表实体，如下：

public class Valuation

{

    [PrimaryKey, AutoIncrement]

    public int Id { get; set; }

    [Indexed("ValuationStockId2",1)] //索引，注意，该索引在表创建时，会创建，如果索引改名，旧索引依然存在，并未被删除

    public int StockId { get; set; }

    public DateTime Time { get; set; }

    public decimal Price { get; set; }

}

public class Stock

{

　　[PrimaryKey, AutoIncrement]

　　public int Id { get; set; }

　　public string Symbol { get; set; }

}

接下来我们创建一个SQLiteHelper，用来管理Sqlite数据库，如下：

public class SQLiteHelper

{

    public string connstr = Path.Combine(Environment.CurrentDirectory, "User.db");//没有数据库会创建数据库

    public SQLiteConnection db;

    public SQLiteHelper()

    {

        db = new SQLiteConnection(connstr);

        db.CreateTable<Stock>();//表已存在不会重复创建

        db.CreateTable<Valuation>();

    }

    public int Add<T>(T model)

    {

       return db.Insert(model);

    }

    public int Update<T>(T model)

    {

        return db.Update(model);

    }

    public int Delete<T>(T model)

    {

        return db.Update(model);

    }

    public List<T> Query<T>(string sql) where T : new()

    {

        return db.Query<T>(sql);

    }

    public int Execute(string sql)

    {

        return db.Execute(sql);

    }

}

到此，我们的简易版ORM就搭建好了，下面让我们一起试用下这个ORM。

首先我们添加一个项目，SqliteTestConsole。

然后在Main函数中写上测试代码如下：

static void Main(string[] args)

{

    SQLiteHelper sqliteHelper = new SQLiteHelper();

    var list = sqliteHelper.Query<Stock>("select * from Stock");

    sqliteHelper.Add(new Valuation() { Price = 100, StockId = 1, Time = DateTime.Now });

    var list2 = sqliteHelper.Query<Valuation>("select *  from Valuation");

    var list3 = sqliteHelper.Query<Valuation>("select *   from Valuation INDEXED BY ValuationStockId2 WHERE StockId > 2");//使用索引ValuationStockId2查询

    try

    {

        sqliteHelper.Execute("drop index ValuationStockId");//删除索引，因为该索引已被删除，所以抛异常

    }

    catch (Exception ex)

    {

    }

}

然后运行调试，会抛出异常如下：