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

程序员文章站 2023-10-16 23:03:47

SQLite简易版ORM 首先打开项目，使用nuget搜索sqlite-net,如下图：下载完成后，我们会多出两个文件，SQLite.cs和SQLiteAsync.cs。我们新建一个文件夹SQLiteResources，把这俩文件放进去。然后我们创建两个表实体，如下：接下来我们创建一个SQL ......

sqlite简易版orm

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

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

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

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

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

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)
    {

    }
}

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

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