src/02_Data/Adapters/Data.Adapter.Sqlite/SqliteDbAdapter.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using System;
using System.Data;
using System.Text;
using Dapper;
using Microsoft.Data.Sqlite;
using Mkh.Data.Abstractions.Adapter;
using Mkh.Data.Abstractions.Descriptors;
using Mkh.Utils.Helpers;

namespace Mkh.Data.Adapter.Sqlite;

public class SqliteDbAdapter : DbAdapterAbstract
{
    public SqliteDbAdapter()
    {
        SqlMapper.AddTypeHandler(new GuidTypeHandler());
    }

    public override DbProvider Provider => DbProvider.Sqlite;

    /// <summary>
    /// 左引号
    /// </summary>
    public override char LeftQuote => '[';

    /// <summary>
    /// 右引号
    /// </summary>
    public override char RightQuote => ']';

    /// <summary>
    /// 获取最后新增ID语句
    /// </summary>
    public override string IdentitySql => "SELECT LAST_INSERT_ROWID() ID;";

    public override IDbConnection NewConnection(string connectionString)
    {
        return new SqliteConnection(connectionString);
    }

    public override string GenerateFirstSql(string select, string table, string where, string sort, string groupBy = null, string having = null)
    {
        return GeneratePagingSql(select, table, where, sort, 0, 1, groupBy, having);
    }

    public override string GeneratePagingSql(string select, string table, string where, string sort, int skip, int take, string groupBy = null, string having = null)
    {
        var sqlBuilder = new StringBuilder();
        sqlBuilder.AppendFormat("SELECT {0} FROM {1}", select, table);
        if (where.NotNull())
            sqlBuilder.AppendFormat(" {0}", where);

        if (groupBy.NotNull())
            sqlBuilder.Append(groupBy);

        if (having.NotNull())
            sqlBuilder.Append(having);

        if (sort.NotNull())
            sqlBuilder.AppendFormat("{0}", sort);