从Java应用程序获取数据到Cassandra 2的最快方法是什么？

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了从Java应用程序获取数据到Cassandra 2的最快方法是什么？，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1057字，纯文字阅读大概需要2分钟。

内容图文

我已经尝试过DataStax Java驱动程序,它似乎是插入数据的最快方法是组成一个内联所有参数的CQL字符串.

这个循环在我的测试集群上需要2500ms左右：

PreparedStatement ps = session.prepare("INSERT INTO perf_test.wibble (id, info) VALUES (?, ?)")
for (int i = 0; i < 1000; i++) session.execute(ps.bind("" + i, "aa" + i));

参数内联的相同循环大约是1300ms.如果有很多参数会变得更糟.我知道我可以使用批处理同时插入所有行但这不是此测试的目的.我也尝试使用session.execute(cql,params),它更快但仍然不匹配内联值.

编写CQL字符串当然既方便又简单,但有更快的方法吗？

解决方法:

您可以做两件事来提高性能.首先是在驱动程序中使用executeAsynch函数而不是执行.

第二件事是使用batch statement而不是循环(我知道你提到它不是测试的目的,但是当涉及带循环的插入时,批处理就是你想要的).

PreparedStatement ps = session.prepare("INSERT INTO messages (user_id, msg_id, title, body) " +
                                       "VALUES (?, ?, ?, ?)");
BatchStatement batch = new BatchStatement();
batch.add(ps.bind(uid, mid1, title1, body1));
batch.add(ps.bind(uid, mid2, title2, body2));
batch.add(ps.bind(uid, mid3, title3, body3));
session.execute(batch);

内容总结

以上是互联网集市为您收集整理的从Java应用程序获取数据到Cassandra 2的最快方法是什么？全部内容，希望文章能够帮你解决从Java应用程序获取数据到Cassandra 2的最快方法是什么？所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端