注入 TableName 作为参数以更新和插入 ServiceStack Ormlite 中的 GenericEntity

我有 3 个结构相同的表，因此我使用 ServiceStack 创建了以下实体

public class GenericEntity
{
    [Alias("COL_A")]
    public string ColumnA { get; set; }
}

为了检索结果，我使用以下代码行。在其中我传递了诸如“TableAU”/“Table”之类的表名称，以便我可以提取适当的结果

db.Select<GenericEntity>(w => w.Where(whereExperssion).OrderBy(o => o.ColumnA).From("TableA"));

对于删除我使用以下代码

 db.Delete<GenericEntity>(w => w.Where(q => q.ColumnA == "A").From("TableA"));

使用 From() 我可以传递 SELECT 和 DELETE 操作的表名称。是否有类似的插入和更新方法？下面是我用于更新和插入的代码片段

Insert

db.Insert(new GenericEntity() {});

Update

db.Update<GenericEntity>(new GenericEntity { ColumnA = "ModifiedData"},p => p.ColumnA == "OriginalData");

正如您希望对多个 API 执行此操作一样，我已经添加了一个测试展示如何通过使用您自己的自定义扩展方法扩展 OrmLite 的 API 来实现所需的行为，这些扩展方法在运行时修改 OrmLite 的表元数据以添加允许在运行时指定表名称的新 API，即：

var tableName = "TableA"'
db.DropAndCreateTable<GenericEntity>(tableName);

db.Insert(tableName, new GenericEntity { Id = 1, ColumnA = "A" });

var rows = db.Select<GenericEntity>(tableName, q =>
    q.Where(x => x.ColumnA == "A"));

rows.PrintDump();

db.Update(tableName, new GenericEntity { ColumnA = "B" },
    where: q => q.ColumnA == "A");

rows = db.Select<GenericEntity>(tableName, q => 
    q.Where(x => x.ColumnA == "B"));

rows.PrintDump();

使用这些扩展方法：

public static class GenericTableExtensions 
{
    static object ExecWithAlias<T>(string table, Func<object> fn)
    {
        var modelDef = typeof(T).GetModelMetadata();
        lock (modelDef) {
            var hold = modelDef.Alias;
            try {
                modelDef.Alias = table;
                return fn();
            }
            finally {
                modelDef.Alias = hold;
            }
        }
    }

    public static void DropAndCreateTable<T>(this IDbConnection db, string table) {
        ExecWithAlias<T>(table, () => { db.DropAndCreateTable<T>(); return null; });
    }

    public static long Insert<T>(this IDbConnection db, string table, T obj, bool selectIdentity = false) {
        return (long)ExecWithAlias<T>(table, () => db.Insert(obj, selectIdentity));
    }

    public static List<T> Select<T>(this IDbConnection db, string table, Func<SqlExpression<T>, SqlExpression<T>> expression) {
        return (List<T>)ExecWithAlias<T>(table, () => db.Select(expression));
    }

    public static int Update<T>(this IDbConnection db, string table, T item, Expression<Func<T, bool>> where) {
        return (int)ExecWithAlias<T>(table, () => db.Update(item, where));
    }
}

以这种方式添加您自己的扩展方法允许您使用自己惯用的 API 来扩展 OrmLite，因为 OrmLite 本身只是 ADO.NET 上的一套扩展方法IDbConnection.