当原始数据来自SQL查询(在本例中为LINQ)或通过OLEDB(两者上存在相同问题)时,我在转换日期时间时遇到问题。
我正在使用NodaTime,但是问题是我似乎需要通过System.DateTime才能到达Noda Instant,此时引入了错误。
源数据中数据的时区始终是已知的,在大多数情况下是 UTC。 但是,由于某种原因,代码将其解释为本地系统时间(我猜),因为当我调用ToUniversalTime()
时,它将时间戳移动了一个小时。
将数据库日期时间对象转换为 NodaTime Instant 而不承担任何系统时间干预风险的最佳方法是什么?
由于我知道源数据的时区,我需要将其转换为正确的即时,而无需系统在后台应用假定的时区。
示例 OleDb 代码:
var cmd = String.Format("SELECT [{0}] AS EquipRef, [{1}] AS MeasureTimeStamp, [{2}] AS MeasureValue FROM [{3}]", equipRefColumn, timeStampColumn, columnName, tableName);
var dataTable = new DataTable(tableName);
using (var adapter = new OleDbDataAdapter(cmd, conn)) {
adapter.Fill(dataTable);
}
var dataContainer = new DataContainer();
dataContainer.Data.Add(tableName, new List<Row>());
foreach (DataRow row in dataTable.Rows) {
var timeStamp = Instant.FromDateTimeUtc(((DateTime)row["MeasureTimeStamp"]).ToUniversalTime());
dataContainer.Data[tableName].Add(new Row() {ColumnName = columnName,EquipRef = row["EquipRef"].ToString(), TimeStamp = timeStamp, Value = row["MeasureValue"]});
}
示例 LINQ to SQL 代码:
var db = new RawDataStoreDataContext(new SqlConnection(ConnectionString));
var tables = db.Tables_Get(SourceDataLinkId);
var equipRefs = db.EquipRefs_Get(SourceDataLinkId);
foreach (var table in tables) {
foreach (var equipRef in equipRefs) {
var rawData = db.RawData_FetchByTableAndEquip(equipRef.EquipRef, table.TableName, SourceDataLinkId);
var dataContainer = new DataContainer();
dataContainer.Data = new Dictionary<string, List<Row>>();
dataContainer.Data.Add(table.TableName,new List<Row>());
foreach (var row in rawData) {
var timeStamp = Instant.FromDateTimeUtc(row.TimeStamp.ToUniversalTime());
dataContainer.Data[table.TableName].Add(new Row() {ColumnName = row.ColumnName,EquipRef = equipRef.EquipRef,TimeStamp = timeStamp,Value = row.Value});
}
dataTarget.Stage(dataContainer);
}
}
代替ToUniversalTime
,使用 DateTime.SpecifyKind
并传递DateTimeKind.Utc
。
在 OLEDB 代码中:
var timeStamp = Instant.FromDateTimeUtc(DateTime.SpecifyKind((DateTime)row["MeasureTimeStamp"], DateTimeKind.Utc));
在您的 L2S 代码中:
var timeStamp = Instant.FromDateTimeUtc(DateTime.SpecifyKind(row.TimeStamp, DateTimeKind.Utc));