在 Dapper 中使用 Protocol Buffer 模型时如何将 C# ticks 映射到 PostgreSQL 时间戳?

How to map C# ticks to PostgreSQL timestamp when using a Protocol Buffer model with Dapper?

我在我的应用程序中使用 protobuf-net 将记录的数据从远程站点发送到服务器。有多种数据类型 - 其中之一的示例消息如下:

message Sample {
    required int64 recording_time = 1; // UTC Timestamp in Ticks
    required double x_position = 2;
    required double y_position = 3;
    required double x_velocity = 4;
    required double y_velocity = 5;
}

在服务器上,对象存储在 PostgreSQL 数据库中。 Protocol Buffer (proto2) 消息中的所有 double 字段都映射到 PostgreSQL 中的 double 字段。时间戳字段 uint64 recording_time 必须映射到数据库中的 timestamp with time zone 字段。

我想使用相同的 C# class(具有 ProtoContract 属性)在客户端上序列化 Sample,并使用 Dapper 进行数据库操作(可能带有扩展名,例如 FastCRUD)。

这需要在 ticksC# 类型:long)和 timestamp with time zoneC# 类型:日期时间)。如果不创建第二个 class?

,最好的实现方法是什么?

这是我目前将对象写入数据库的方式:

string sql = "COPY samples (recording_time, x_position, y_position, x_velocity, y_velocity) FROM STDIN (FORMAT BINARY)";
using (var writer = conn.BeginBinaryImport(sql))
{
    foreach (Sample sample in sampleList)
    {
        writer.StartRow();

        writer.Write(new DateTime(sample.RecordingTime, DateTimeKind.UTC), NpgsqlTypes.NpgsqlDbType.TimestampTZ);

        writer.Write(sample.X_Position, NpgsqlTypes.NpgsqlDbType.Double);
        writer.Write(sample.Y_Position, NpgsqlTypes.NpgsqlDbType.Double);
        writer.Write(sample.X_Velocity, NpgsqlTypes.NpgsqlDbType.Double);
        writer.Write(sample.Y_Velocity, NpgsqlTypes.NpgsqlDbType.Double);

    }
}

这就是我想要写入数据库的方式:

foreach (Sample sample in sampleList)
{
    conn.Insert<Sample>(sample);
}

并使用对应的Query方法进行检索。

I want to use the same C# class (with ProtoContract attribute) to serialize Sample on the client, and also with Dapper for database operations (perhaps with an extension, e.g. FastCRUD).

就我个人而言,我认为这就是问题所在 - 试图用同一个对象做两件截然不同的事情。然而!这不一定是不可能的。特别要注意的是,protobuf-net 很乐意与私有成员一起工作。所以一种选择可能是:

public WhateverYouNeedForTheDatabase Foo { get; set; }

[ProtoMember(someNumber)]
private WhateverYouNeedForTheSerializer FooSerialized {
    get { return FromX(Foo); }
    set { Foo = ToX(value); }
}

可以用dapper做类似的事情,但不太方便。特别是,在您的情况下:

public DateTime RecordingTime { get; set; }

[ProtoMember(1)]
private long RecordingTimeSerialized {
    get { return DateTimeToUnixTime(RecordingTime); }
    set { RecordingTime = UnixTimeToDateTime(value); }
}

这没有额外的存储要求(没有额外的字段)。