在 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)。
这需要在 ticks
(C# 类型:long)和 timestamp with time zone
(C# 类型:日期时间)。如果不创建第二个 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); }
}
这没有额外的存储要求(没有额外的字段)。
我在我的应用程序中使用 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)。
这需要在 ticks
(C# 类型:long)和 timestamp with time zone
(C# 类型:日期时间)。如果不创建第二个 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); }
}
这没有额外的存储要求(没有额外的字段)。