如何使用C#将IBM DB2 BLOB字段中存储的多张图片导出到本地磁盘

核心原因 #

你当前的代码是将整个BLOB字段的所有字节直接写入单个图片文件，而该BLOB是多张图片的字节拼接内容，不符合单张图片的文件格式规范，所以导出后无法打开。

实现思路 #

需要先识别不同图片格式的魔数（文件头/文件尾标记），将BLOB的完整字节数组按图片边界拆分后分别导出：

• JPG格式：头标记 0xFF 0xD8，尾标记 0xFF 0xD9
• PNG格式：头标记 0x89 0x50 0x4E 0x47 0x0D 0x0A 0x1A 0x0A，尾标记 0x49 0x45 0x4E 0x44 0xAE 0x42 0x60 0x82

完整代码实现 #

第一步：读取BLOB为完整字节数组 #

修改原有读库逻辑，先把整个BLOB内容读取到内存的字节数组中：

private byte[] ReadFullBLOB(DB2Connection conn, DB2Transaction trans)
{
    try
    {
        List<byte> fullBlob = new List<byte>();
        long currentIndex = 0;
        int bufferSize = 1024 * 1024; // 1MB缓存，可根据实际调整
        byte[] buffer = new byte[bufferSize];
        long bytesReturned;

        using (DB2Command cmd = conn.CreateCommand())
        {
            cmd.CommandText = "SELECT ATTR0102500126 FROM JCR.ICMUT01278001 WHERE COMPKEY = 'N21E26B04900FC6B1F00000'";
            cmd.Transaction = trans;
            using (var reader = cmd.ExecuteReader(CommandBehavior.SequentialAccess))
            {
                if (reader.Read())
                {
                    do
                    {
                        bytesReturned = reader.GetBytes(0, currentIndex, buffer, 0, bufferSize);
                        if (bytesReturned == 0) break;
                        fullBlob.AddRange(buffer.Take((int)bytesReturned));
                        currentIndex += bytesReturned;
                    } while (bytesReturned == bufferSize);
                }
            }
        }
        return fullBlob.ToArray();
    }
    catch (Exception e)
    {
        Console.WriteLine(e.Message);
        return null;
    }
}

第二步：拆分字节数组导出多张图片 #

这里以拆分JPG格式为例，其他格式可参照增加魔数判断逻辑：

private void ExportMultiImagesFromBlob(byte[] blobBytes, string saveDir = @"D:\MyBLOB")
{
    if (!Directory.Exists(saveDir)) Directory.CreateDirectory(saveDir);
    
    int imgIndex = 0;
    int startPos = -1;
    
    // JPG魔数
    byte[] jpgHeader = new byte[] { 0xFF, 0xD8 };
    byte[] jpgFooter = new byte[] { 0xFF, 0xD9 };

    for (int i = 0; i < blobBytes.Length - 1; i++)
    {
        // 匹配图片头
        if (startPos == -1 && blobBytes[i] == jpgHeader[0] && blobBytes[i+1] == jpgHeader[1])
        {
            startPos = i;
        }
        // 匹配图片尾
        else if (startPos != -1 && blobBytes[i] == jpgFooter[0] && blobBytes[i+1] == jpgFooter[1])
        {
            int imgLength = i + 2 - startPos;
            byte[] imgBytes = new byte[imgLength];
            Array.Copy(blobBytes, startPos, imgBytes, 0, imgLength);
            
            // 写入单张图片
            string imgPath = Path.Combine(saveDir, $"image_{imgIndex++}.jpg");
            File.WriteAllBytes(imgPath, imgBytes);
            
            startPos = -1;
        }
    }
}

第三步：调用示例 #

// 读取BLOB
byte[] blob = ReadFullBLOB(conn, trans);
if(blob != null)
{
    // 拆分导出多图
    ExportMultiImagesFromBlob(blob);
}

注意事项 #

• 如果BLOB包含多种格式图片，可在拆分逻辑中增加PNG、GIF等对应魔数的匹配规则
• 若BLOB体积超过1GB，建议改为流式拆分，避免内存占用过高
• 部分特殊场景下BLOB可能在图片之间插入了自定义分隔符，可结合业务存BLOB时的规则调整拆分逻辑

内容的提问来源于stack exchange，提问作者Kid1412