如何在使用Dapper的协议缓冲区模型时将c#刻度映射到PostgreSQL时间戳

本文关键字：映射 时间戳 PostgreSQL 模型 Dapper 缓冲区 协议 | 更新日期: 2023-09-27 18:11:43

我在应用程序中使用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数据库中。所有proto2 (Protocol Buffer)消息中的double字段都映射到PostgreSQL中的double字段。时间戳字段uint64 recording_time必须映射到数据库中的timestamp with time zone字段。

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

这需要ticks ( c#类型:long)和timestamp with time zone ( c#类型:DateTime)之间的映射/转换。在不创建第二个类的情况下，实现这一点的最佳方法是什么?

这是我目前如何写对象到数据库:

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方法进行检索

如何在使用Dapper的协议缓冲区模型时将c#刻度映射到PostgreSQL时间戳

我想使用相同的c#类(带有ProtoContract属性)来序列化客户端上的Sample，并且还使用Dapper进行数据库操作(可能带有扩展，例如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); }
}

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

相关文章：