在C#中为Dapper创建动态类型

c# dapper

我有一个应用程序,我正在保存未知的结构化数据。所以,我们假设在数据库中有一个名为Foo的表,它看起来像这样:

CREATE TABLE [dbo].[Foo]
(
    [Id] INT NOT NULL PRIMARY KEY IDENTITY, 
    [DataId] INT NOT NULL, 
    [Bar] VARCHAR(50) NOT NULL, 
    CONSTRAINT [FK_Foo_Data] FOREIGN KEY ([DataId]) REFERENCES [Data]([Id])
)

Foo与一个名为Data的表相关,该表将存储记录数据的提供程序以及记录的日期和时间,并且假设该表如下所示:

CREATE TABLE [dbo].[Data]
(
    [Id] INT NOT NULL PRIMARY KEY IDENTITY, 
    [ProviderId] INT NOT NULL, 
    [RecordDateTime] DATETIME NOT NULL, 
    CONSTRAINT [FK_Data_Provider] FOREIGN KEY ([ProviderId]) REFERENCES [Provider]([Id])
)

好的,现在让我们假设提供者(我不知道它提供的数据)有一个名为Foo的类,如下所示:

[Serializable]
public class Foo : ISerializable
{
    private string bar;

    public string Bar
    {
        get { return bar; }
        set { bar = value; }
    }

    public Foo()
    {
        Bar = "Hello World!";
    }

    public Foo(SerializationInfo info, StreamingContext context)
    {
        this.bar = info.GetString("Bar");
    } 

    public void GetObjectData(SerializationInfo info, StreamingContext context)
    {
        info.AddValue("Bar", bar);
    }
}

因此,当提供程序向我发送一个Foo实例时,我将询问它并确定应该插入数据库中的哪个表,并假设代码块如下所示:

this.connection.Open();

try
{
    var parameters = new
        {
            ProviderId = registeredProvidersIdBySession[providerKey.ToString()],
            RecordDateTime = DateTime.Now,
        };

    var id = connection.Query<int>("INSERT INTO Data (ProviderId, RecordDateTime) VALUES (@ProviderId, @RecordDateTime); SELECT CAST(SCOPE_IDENTITY() as INT)", parameters).Single();

    var t = data.GetType();
    var fields = t.GetProperties(BindingFlags.Public | BindingFlags.Instance);

    var tableName = string.Format("[{0}]", t.Name);
    var fieldList = string.Join(", ", fields.Select(p => string.Format("[{0}]", p.Name)).ToArray());

    var valueList = fields.Select(p => string.Format("@{0}", p.Name)).ToList();
    valueList.Insert(0, "@DataId");

    var values = new Dictionary<string, object>();
    values.Add("@DataId", id);
    foreach (var propertyInfo in fields)
    {
        values.Add(string.Format("@{0}", propertyInfo.Name), propertyInfo.GetValue(data, null));
    }

    return connection.Execute(string.Format(
        "INSERT INTO {0} ({1}) VALUES ({2})",
            tableName,
            fieldList,
            string.Join(", ", valueList.ToArray())), values);
}
finally
{
    this.connection.Close();
}

现在你可以看到,我从传递给我的对象的Type中获取tableName 。在我们的例子中,那是Foo 。此外,我正在收集要用反射插入的字段列表。然而,相处中的障碍是Dapper需要将一个对象发送给它以获取参数值。现在,如果我不需要在类型上提供DataId属性,我只能传递给我的对象,但是我需要DataId属性,所以我可以正确地关联日志。

我在问什么?

  1. 我是否必须创建动态类型或者Dapper可以做其他事情来帮助?
  2. 如果我将不得不创建一个动态类型,是否比使用TypeBuilder更直接?我以前做过,可以再做一次,但是男人很痛苦。
  3. 如果我将不得不使用TypeBuilder我会对你的例子感兴趣,因为你可能知道比我更有效的方法。如果你有一些想法,请举一个例子。

免责声明

在上面的代码示例中,您看到我尝试传入Dictionary<string, object>而不是Dapper不接受。我几乎知道它不会因为我已经查看了源代码,但我只是希望我错过了一些东西。

谢谢大家!

一般承认的答案

在Dapper中有一个BuiltIn类型来传递参数,这些属性仅在运行时是已知的:检查类DynamicParameters 。它用作:

var p = new DynamicParameters();
p.Add("@a", 11);
p.Add("@b", dbType: DbType.Int32, direction: ParameterDirection.Output);
p.Add("@c", dbType: DbType.Int32, direction: ParameterDirection.ReturnValue);

然后作为参数对象传递给Execute方法。它通常与SP一起使用(因此您也可以将其用于读取输出值),但没有理由阻止它使用常规的SELECT / INSERT / UPDATE查询。


热门答案

我知道你问过小巧玲珑但......

Sauce DB实际上很好地处理了这种情况。有几种方法可以做到。下面是一些说明它的示例代码。注意:您可以覆盖表名的查找方式,并且有一些方法可以让您根据需要检索已解析的表名。

免责声明:我写了SauceDB

public class Foo
{
    public int ID { get; set; }
    publi string Name { get; set; }
}

public class Bar
{
    public int ID { get; set; }
    publi string Name { get; set; }
}

public class  MainClass
{
    IDataStore _dstore;
    public void Main()
    {
        _dstore = new SqlServerDataStore("my_connection_string")//create data store

        InsertObject(new Foo());
        InsertObject(new Bar());
    }

    public void InsertObject(object o)
    {
        //this will assume the table it belongs to is the type name + an s
            //you can override the table name behavior as well
        _dstore.InsertObject(o);
    }
}

http://sauce.codeplex.com/



许可下: CC-BY-SA with attribution
不隶属于 Stack Overflow
这个KB合法吗? 是的,了解原因
许可下: CC-BY-SA with attribution
不隶属于 Stack Overflow
这个KB合法吗? 是的,了解原因