如何从cassandra读取文件和写文件到cassandra? [英] how to read file from cassandra and write file to cassandra?

查看:493
本文介绍了如何从cassandra读取文件和写文件到cassandra?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我不知道到google的关键字。



我是datastax的新用户。



我想我可以插入文件到cassandra EASILY我想我不需要写文件到cassandra像这样:

  out = new FileOutputStream (new File(C:/test.txt)); 
out.write(java java java\r\\\
.getBytes());


解决方案

使用Datastax驱动程序:



插入:

  ByteBuffer fileByteBuffer = ByteBuffer.wrap(readFileToByteArray(filename)); 
语句insertFile = QueryBuilder.insertInto(files).value(filename,filename).value(file,fileByteBuffer);
session.execute(insertFile);阅读:

 

code>语句readFile = QueryBuilder.select(file).from(files).where(QueryBuilder.eq(filename,filename));
row fileRow = session.execute(readFile).one();
if(fileRow!= null){
ByteBuffer fileBytes = fileRow.getBytes(file);
文件f = convertToFile(fileBytes);
}


I don't know what keywords to google.

I 'm new to datastax.

I guess I can insert file into cassandra EASILY And I guess I need not write file to cassandra like this :

  out = new FileOutputStream(new File("C:/test.txt"));   
  out.write("java java java\r\n".getBytes()); 

解决方案

Using the Datastax driver:

Insert:

    ByteBuffer fileByteBuffer = ByteBuffer.wrap( readFileToByteArray( filename ) );
    Statement insertFile = QueryBuilder.insertInto( "files" ).value( "filename", filename ).value( "file", fileByteBuffer );
    session.execute( insertFile );

Read:

    Statement readFile = QueryBuilder.select( "file" ).from( "files" ).where( QueryBuilder.eq( "filename", filename ) );
    Row fileRow = session.execute( readFile ).one();
    if ( fileRow != null ) {
        ByteBuffer fileBytes = fileRow.getBytes( "file" );
        File f = convertToFile( fileBytes );
    }

这篇关于如何从cassandra读取文件和写文件到cassandra?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!

查看全文
登录 关闭
扫码关注1秒登录
发送“验证码”获取 | 15天全站免登陆