在cassandra中持久化一个zip文件并读回它

// 创建Cassandra表
CREATE TABLE files (
    id UUID PRIMARY KEY,
    filename text,
    filetype text,
    filesize int,
    filedata blob
);

// 持久化zip文件到Cassandra
public void persistZipFile(String filename, byte[] fileData) {
    UUID fileId = UUID.randomUUID();
    String fileType = "zip";
    int fileSize = fileData.length;

    // 将zip文件元数据和内容插入到Cassandra表中
    String insertQuery = "INSERT INTO files (id, filename, filetype, filesize, filedata) VALUES (?, ?, ?, ?, ?)";
    PreparedStatement statement = session.prepare(insertQuery);
    BoundStatement boundStatement = new BoundStatement(statement);
    session.execute(boundStatement.bind(fileId, filename, fileType, fileSize, ByteBuffer.wrap(fileData)));
}

// 从Cassandra读取zip文件
public byte[] readZipFile(String filename) {
    // 查询Cassandra表获取zip文件的元数据和内容
    String selectQuery = "SELECT filedata FROM files WHERE filename = ?";
    PreparedStatement statement = session.prepare(selectQuery);
    BoundStatement boundStatement = new BoundStatement(statement);
    ResultSet resultSet = session.execute(boundStatement.bind(filename));

    // 提取字节数组并返回
    Row row = resultSet.one();
    ByteBuffer fileDataBuffer = row.getByteBuffer("filedata");
    byte[] fileData = new byte[fileDataBuffer.remaining()];
    fileDataBuffer.get(fileData);

    return fileData;
}