如何从cassandra读取文件和写文件到cassandra? [英] how to read file from cassandra and write file to cassandra?
本文介绍了如何从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屋!
查看全文