如何在Cassandra中存储与读取字节数组（或图片）数据

你的代码存在3个直接导致读写失败的问题，对应修复方式如下：

• 列名不匹配：建表时定义的blob列名为data，读取逻辑中却尝试获取名为picture的列，自然无法拿到存储的二进制数据，这是最核心的报错原因。
• 冗余语法+安全风险：id是表的主键，按主键查询不需要添加ALLOW FILTERING；直接拼接SQL字符串存在注入隐患，生产环境必须使用预编译语句。
• 流处理注意事项：Image.FromStream要求传入的内存流在图片生命周期内保持可访问，部分场景下会因为流被提前释放导致图片加载失败，可以额外设置useEmbeddedColorManagement、validateImageData参数规避。

可直接运行的参考代码 #

建表语句（原有语句逻辑正确，只需保证后续代码列名和表结构一致即可） #

CREATE TABLE tb (id int PRIMARY KEY, data blob);

字节数组写入逻辑 #

// 提前预编译语句，提升重复执行效率
var prepareInsert = DataConnection.Ins.session.Prepare("INSERT INTO tb (id, data) VALUES (?, ?)");
// 传入目标id和待存储的字节数组即可完成写入
var bindInsert = prepareInsert.Bind(targetId, imageByteArray);
DataConnection.Ins.session.Execute(bindInsert);

修复后的图片读取逻辑 #

public Image ConvertImgFromByte(int id)
{
    var prepareSelect = DataConnection.Ins.session.Prepare("SELECT data FROM tb WHERE id = ?");
    var bindSelect = prepareSelect.Bind(id);
    var resultRow = DataConnection.Ins.session.Execute(bindSelect).FirstOrDefault();
    if (resultRow == null) return null;
    
    // 列名必须和表结构完全一致，此处取data列
    byte[] fileBytes = resultRow.GetValue<byte[]>("data");
    if (fileBytes == null || fileBytes.Length == 0) return null;

    using (var ms = new MemoryStream(fileBytes))
    {
        return Image.FromStream(ms, false, false);
    }
}

额外注意事项 #

• 如果要将列名改为picture，不要直接修改读取代码的列名，需要先执行DDL调整表结构：ALTER TABLE tb ADD picture blob; 写入时同步更新列名即可。
• Cassandra单条记录的blob字段建议不超过1MB，大尺寸二进制文件建议分块存储，避免影响集群查询性能。
• 非必要不使用ALLOW FILTERING，该语法会触发全表扫描，在数据量较大的集群中会直接导致查询超时。

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