dschick/git_bsmd
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

MaerskData erbt jetzt auch von DatabaseEntityAsync

Browse Source
This commit is contained in:
Daniel Schick 2023-05-09 14:29:59 +02:00
parent 8c38001e42
commit 1f7ada5c58
2 changed files with 5 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
bsmd.database/DBManagerAsync.cs
View File

@ -81,7 +81,7 @@ namespace bsmd.database
MaerskData md = new MaerskData(); MaerskData md = new MaerskData();
md.PrepareLoadCommand(cmd, Message.LoadFilter.BY_CORE, messageCoreId); md.PrepareLoadCommand(cmd, Message.LoadFilter.BY_CORE, messageCoreId);
SqlDataReader reader = await PerformCommandAsync(cmd); SqlDataReader reader = await PerformCommandAsync(cmd);
List<MaerskData> resultList = await md.LoadListAsync(reader); List<MaerskData> resultList = (await md.LoadListAsync(reader)).ConvertAll(x => (MaerskData) x);
MaerskData result = null; MaerskData result = null;
if(resultList.Count > 0) if(resultList.Count > 0)
{ {

22
bsmd.database/MaerskData.cs
View File

@ -19,7 +19,7 @@ namespace bsmd.database
/// we use a generic storage class called "XtraData" that hopefully might be useful in another /// we use a generic storage class called "XtraData" that hopefully might be useful in another
/// future scenario as well /// future scenario as well
/// </summary> /// </summary>
public class MaerskData : DatabaseEntity, IEquatable<MaerskData>, IComparable<MaerskData> public class MaerskData : DatabaseEntityAsync, IEquatable<MaerskData>, IComparable<MaerskData>
{ {
#region Construction #region Construction
@ -124,7 +124,7 @@ namespace bsmd.database
#endregion #endregion
#region abstract DatabaseEntity method implementation #region abstract DatabaseEntityAsync method implementation
public override List<DatabaseEntity> LoadList(IDataReader reader) public override List<DatabaseEntity> LoadList(IDataReader reader)
{ {
@ -138,23 +138,9 @@ namespace bsmd.database
reader.Close(); reader.Close();
} }
return result; return result;
} }
public async Task<List<MaerskData>> LoadListAsync(SqlDataReader reader) protected override DatabaseEntityAsync ReadRowFromReader(IDataReader reader)
{
List<MaerskData> result = new List<MaerskData>();
if (reader != null)
{
while (await reader.ReadAsync())
{
result.Add(ReadRowFromReader(reader));
}
reader.Close();
}
return result;
}
private MaerskData ReadRowFromReader(IDataReader reader)
{ {
MaerskData md = null; MaerskData md = null;
if (reader != null) if (reader != null)