Oracle FetchData<T>() - GEt BFILE as byte[]

Author: abhinavminhas

QueryDB.Core.Tests/Entities.cs

@@ -159,7 +159,7 @@ public class Orders
             }
             public class DataTypes
             {
-                public string BFile_Column { get; set; }
+                public byte[] BFile_Column { get; set; }
                 public byte[] Blob_Column { get; set; }
                 public string Char_Column { get; set; }
                 public string Clob_Column { get; set; }

QueryDB.Core.Tests/TestBase.cs

@@ -97,5 +97,10 @@ protected string GetBase64Content(string filePath)
             string base64Content = Convert.ToBase64String(fileBytes);
             return base64Content;
         }
+
+        internal static string ConvertByteArrayToBase64(byte[] data)
+        {
+            return Convert.ToBase64String(data);
+        }
     }
 }

QueryDB/Oracle/Adapter.cs

@@ -48,7 +48,7 @@ internal List<DataDictionary> FetchData(string selectSql, OracleConnection conne
                     {
                         string key = upperCaseKeys ? reader.GetName(i).ToUpper() : reader.GetName(i);
                         if (Utils.IsBFileColumn(reader, i))
-                            addRow.ReferenceData.Add(key, Utils.GetBFileContent(reader, i));
+                            addRow.ReferenceData.Add(key, Utils.GetBFileBase64Content(reader, i));
                         else if (reader.GetValue(i) is byte[] value)
                             addRow.ReferenceData.Add(key, Convert.ToBase64String(value));
                         else
@@ -81,7 +81,7 @@ internal List<DataDictionary> FetchData(string selectSql, OracleConnection conne
                         if ((strict || Utils.ColumnExists(reader, prop.Name)) && !reader.IsDBNull(reader.GetOrdinal(prop.Name)))
                         {
                             if (Utils.IsBFileColumn(reader, prop.Name))
-                                prop.SetValue(addObjectRow, Utils.GetBFileContent(reader, prop.Name));
+                                prop.SetValue(addObjectRow, Utils.GetBFileByteContent(reader, prop.Name));
                             else
                                 prop.SetValue(addObjectRow, reader[prop.Name]);
                         }   

QueryDB/Resources/Utils.cs

@@ -68,7 +68,7 @@ internal static bool IsBFileColumn(OracleDataReader reader, string columnName)
         /// <param name="reader">The Oracle data reader containing the BFILE column.</param>
         /// <param name="columnIndex">The index of the BFILE column to read.</param>
         /// <returns>Returns the BFILE content as a Base64-encoded string, or an empty string if the BFILE is null.</returns>
-        internal static string GetBFileContent(OracleDataReader reader, int columnIndex)
+        internal static string GetBFileBase64Content(OracleDataReader reader, int columnIndex)
         {
             string content = string.Empty;
             var bFile = reader.GetOracleBFile(columnIndex);
@@ -96,7 +96,7 @@ internal static string GetBFileContent(OracleDataReader reader, int columnIndex)
         /// <param name="reader">The Oracle data reader containing the BFILE column.</param>
         /// <param name="columnName">The name of the BFILE column to read.</param>
         /// <returns>Returns the BFILE content as a Base64-encoded string, or an empty string if the BFILE is null or the column does not exist.</returns>
-        internal static string GetBFileContent(OracleDataReader reader, string columnName)
+        internal static string GetBFileBase64Content(OracleDataReader reader, string columnName)
         {
             string content = string.Empty;
             try
@@ -126,5 +126,40 @@ internal static string GetBFileContent(OracleDataReader reader, string columnNam
             return content;
         }
 
+        /// <summary>
+        /// Retrieves the content of a BFILE column from an Oracle data reader as a byte array, using the column name.
+        /// </summary>
+        /// <param name="reader">The Oracle data reader containing the BFILE column.</param>
+        /// <param name="columnName">The name of the BFILE column to read.</param>
+        /// <returns>Returns the BFILE content as a byte array, or <c>null</c> if the BFILE is null or the column does not exist.</returns>
+        internal static byte[] GetBFileByteContent(OracleDataReader reader, string columnName)
+        {
+            byte[] buffer = null;
+            try
+            {
+                int columnIndex = reader.GetOrdinal(columnName);
+                var bFile = reader.GetOracleBFile(columnIndex);
+                if (bFile != null && !reader.IsDBNull(columnIndex))
+                {
+                    bFile.OpenFile();
+                    buffer = new byte[bFile.Length];
+                    int bytesReadTotal = 0;
+                    while (bytesReadTotal < buffer.Length)
+                    {
+                        int bytesRead = bFile.Read(buffer, bytesReadTotal, buffer.Length - bytesReadTotal);
+                        if (bytesRead == 0)
+                            break;
+                        bytesReadTotal += bytesRead;
+                    }
+                    bFile.Close();
+                }
+            }
+            catch (IndexOutOfRangeException)
+            {
+                return buffer;
+            }
+            return buffer;
+        }
+
     }
 }