Skip to content

Commit 5e52a12

Browse files
committed
CQ - Use IsDBNullAsync for async
1 parent 545721a commit 5e52a12

File tree

5 files changed

+6
-6
lines changed

5 files changed

+6
-6
lines changed

QueryDB/MSSQL/Adapter.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -305,7 +305,7 @@ internal async Task<List<DataDictionary>> FetchDataAsync(string selectSql, SqlCo
305305
var addObjectRow = new T();
306306
foreach (var prop in typeof(T).GetProperties())
307307
{
308-
if ((strict || Utils.ColumnExists(reader, prop.Name)) && !reader.IsDBNull(reader.GetOrdinal(prop.Name)))
308+
if ((strict || Utils.ColumnExists(reader, prop.Name)) && !await reader.IsDBNullAsync(reader.GetOrdinal(prop.Name)))
309309
prop.SetValue(addObjectRow, reader[prop.Name]);
310310
}
311311
dataList.Add(addObjectRow);

QueryDB/MySQL/Adapter.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -304,7 +304,7 @@ internal async Task<List<DataDictionary>> FetchDataAsync(string selectSql, MySql
304304
var addObjectRow = new T();
305305
foreach (var prop in typeof(T).GetProperties())
306306
{
307-
if ((strict || Utils.ColumnExists(reader, prop.Name)) && !reader.IsDBNull(reader.GetOrdinal(prop.Name)))
307+
if ((strict || Utils.ColumnExists(reader, prop.Name)) && !await reader.IsDBNullAsync(reader.GetOrdinal(prop.Name)))
308308
prop.SetValue(addObjectRow, reader[prop.Name]);
309309
}
310310
dataList.Add(addObjectRow);

QueryDB/Oracle/Adapter.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -314,7 +314,7 @@ internal async Task<List<DataDictionary>> FetchDataAsync(string selectSql, Oracl
314314
var addObjectRow = new T();
315315
foreach (var prop in typeof(T).GetProperties())
316316
{
317-
if ((strict || Utils.ColumnExists(reader, prop.Name)) && !reader.IsDBNull(reader.GetOrdinal(prop.Name)))
317+
if ((strict || Utils.ColumnExists(reader, prop.Name)) && !await reader.IsDBNullAsync(reader.GetOrdinal(prop.Name)))
318318
{
319319
if (Utils.IsBFileColumn(reader, prop.Name))
320320
prop.SetValue(addObjectRow, await Utils.GetBFileByteContentAsync(reader, prop.Name));

QueryDB/PostgreSQL/Adapter.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -305,7 +305,7 @@ internal async Task<List<DataDictionary>> FetchDataAsync(string selectSql, Npgsq
305305
var addObjectRow = new T();
306306
foreach (var prop in typeof(T).GetProperties())
307307
{
308-
if ((strict || Utils.ColumnExists(reader, prop.Name)) && !reader.IsDBNull(reader.GetOrdinal(prop.Name)))
308+
if ((strict || Utils.ColumnExists(reader, prop.Name)) && !await reader.IsDBNullAsync(reader.GetOrdinal(prop.Name)))
309309
prop.SetValue(addObjectRow, reader[prop.Name]);
310310
}
311311
dataList.Add(addObjectRow);

QueryDB/Resources/Utils.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ internal static async Task<string> GetBFileBase64ContentAsync(OracleDataReader r
9999
{
100100
string content = string.Empty;
101101
var bFile = reader.GetOracleBFile(columnIndex);
102-
if (bFile != null && !reader.IsDBNull(columnIndex))
102+
if (bFile != null && !await reader.IsDBNullAsync(columnIndex))
103103
{
104104
bFile.OpenFile();
105105
byte[] buffer = new byte[bFile.Length];
@@ -156,7 +156,7 @@ internal static async Task<byte[]> GetBFileByteContentAsync(OracleDataReader rea
156156
byte[] buffer = null;
157157
int columnIndex = reader.GetOrdinal(columnName);
158158
var bFile = reader.GetOracleBFile(columnIndex);
159-
if (bFile != null && !reader.IsDBNull(columnIndex))
159+
if (bFile != null && !await reader.IsDBNullAsync(columnIndex))
160160
{
161161
bFile.OpenFile();
162162
buffer = new byte[bFile.Length];

0 commit comments

Comments
 (0)