Oracle FetchData<T>() - Get BFILE as Base64 string

Author: abhinavminhas

QueryDB.Core.Tests/Entities.cs

@@ -159,7 +159,7 @@ public class Orders
             }
             public class DataTypes
             {
-                public byte[] BFile_Column { get; set; }
+                public string 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/OracleTests.cs

@@ -236,7 +236,7 @@ public void Test_Oracle_FetchData_Entity_DataTypes_Check()
             Assert.IsTrue(data.Count == 1);
             var dataType = data.FirstOrDefault();
             Console.WriteLine(dataType.BFile_Column);
-            Assert.IsTrue(dataType.BFile_Column is byte[] && dataType.BFile_Column == null);
+            Assert.AreEqual(GetBase64Content(Environment.CurrentDirectory + "/SeedData/oracle.sql"), dataType.BFile_Column);
             Assert.IsTrue(dataType.Blob_Column is byte[] && dataType.Blob_Column != null);
             Assert.AreEqual("A", dataType.Char_Column);
             Assert.AreEqual("Sample CLOB data", dataType.Clob_Column);
@@ -257,7 +257,8 @@ public void Test_Oracle_FetchData_Entity_DataTypes_Check()
             Assert.AreEqual("Sample VARCHAR data", dataType.Varchar_Column);
             Assert.AreEqual("Sample VARCHAR2 data", dataType.Varchar2_Column);
         }
-         [TestMethod]
+
+        [TestMethod]
         [TestCategory(DB_TESTS), TestCategory(ORACLE_TESTS)]
         public void Test_Oracle_FetchData_Entity_DataTypes_Strict_Check()
         {

QueryDB/Oracle/Adapter.cs

@@ -79,7 +79,12 @@ internal List<DataDictionary> FetchData(string selectSql, OracleConnection conne
                     foreach (var prop in typeof(T).GetProperties())
                     {
                         if ((strict || Utils.ColumnExists(reader, prop.Name)) && !reader.IsDBNull(reader.GetOrdinal(prop.Name)))
-                            prop.SetValue(addObjectRow, reader[prop.Name]);
+                        {
+                            if (Utils.IsBFileColumn(reader, prop.Name))
+                                prop.SetValue(addObjectRow, Utils.GetBFileContent(reader, prop.Name));
+                            else
+                                prop.SetValue(addObjectRow, reader[prop.Name]);
+                        }   
                     }
                     dataList.Add(addObjectRow);
                 }

QueryDB/Resources/Utils.cs

@@ -34,21 +34,40 @@ internal static bool ColumnExists(IDataReader reader, string columnName)
         /// <param name="reader">The Oracle data reader containing the column.</param>
         /// <param name="columnIndex">The index of the column to check.</param>
         /// <returns>Returns <c>true</c> if the column is of type "BFILE"; otherwise, <c>false</c>.</returns>
-
         internal static bool IsBFileColumn(OracleDataReader reader, int columnIndex)
         {
             const string BFILE_COLUMN = "BFILE";
             string columnType = reader.GetDataTypeName(columnIndex);
             return columnType.Equals(BFILE_COLUMN, StringComparison.OrdinalIgnoreCase);
         }
 
+        /// <summary>
+        /// Determines if a specified column in an Oracle data reader, identified by its column name, is of type "BFILE".
+        /// </summary>
+        /// <param name="reader">The Oracle data reader containing the column.</param>
+        /// <param name="columnName">The name of the column to check.</param>
+        /// <returns>Returns <c>true</c> if the column is of type "BFILE"; otherwise, <c>false</c>. Returns <c>false</c> if the column does not exist.</returns>
+        internal static bool IsBFileColumn(OracleDataReader reader, string columnName)
+        {
+            const string BFILE_COLUMN = "BFILE";
+            try
+            {
+                int columnIndex = reader.GetOrdinal(columnName);
+                string columnType = reader.GetDataTypeName(columnIndex);
+                return columnType.Equals(BFILE_COLUMN, StringComparison.OrdinalIgnoreCase);
+            }
+            catch (IndexOutOfRangeException)
+            {
+                return false;
+            }
+        }
+
         /// <summary>
         /// Retrieves the content of a BFILE column from an Oracle data reader as a Base64-encoded string.
         /// </summary>
         /// <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)
         {
             string content = string.Empty;
@@ -70,5 +89,42 @@ internal static string GetBFileContent(OracleDataReader reader, int columnIndex)
             }
             return content;
         }
+
+        /// <summary>
+        /// Retrieves the content of a BFILE column from an Oracle data reader as a Base64-encoded string, 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 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)
+        {
+            string content = string.Empty;
+            try
+            {
+                int columnIndex = reader.GetOrdinal(columnName);
+                var bFile = reader.GetOracleBFile(columnIndex);
+                if (bFile != null)
+                {
+                    bFile.OpenFile();
+                    byte[] 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;
+                    }
+                    content = Convert.ToBase64String(buffer);
+                    bFile.Close();
+                }
+            }
+            catch (IndexOutOfRangeException)
+            {
+                return content;
+            }
+            return content;
+        }
+
     }
 }