首页 / JAVA / Cassandra数据库Java訪问

Cassandra数据库Java訪问

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Cassandra数据库Java訪问，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2349字，纯文字阅读大概需要4分钟。

内容图文

针对的时Cassandra 2.0 数据库

Java本地client訪问Cassandra，首先建立Javaproject，使用Maven进行管理。

引入依赖：

<dependency>
    <groupId>com.datastax.cassandra</groupId>
    <artifactId>cassandra-driver-core</artifactId>
    <version>2.1.0</version>
</dependency>

1. 类似Elasticsearch的方式，如今client构建一个集群对象： 
Cluster cluster = Cluster.builder()
                .addContactPoint("your ip")
                .build();
        Metadata metadata = cluster.getMetadata();
        System.out.printf("Connected to cluster: %s\n",
                metadata.getClusterName());
        for (Host host : metadata.getAllHosts()) {
            System.out.printf("Datatacenter: %s; Host: %s; Rack: %s\n",
                    host.getDatacenter(), host.getAddress(), host.getRack());
        }

2. 通过一个Session对象。实现对Cassandra的全部增删改查。 
Session session = cluster.connect();


3. 通过Session对象实现全部的DML等操作。 （PS：在对 Cassandra 进行操作之前，建议先了解 Cassandra 的架构以及数据组织形式）

a. 我们首先建立一个Schema：

<pre name="code" class="java">ResultSet results = session.execute("SELECT * FROM simplex.playlists ");

        System.out.println(String.format("%-30s\t%-20s\t%-20s\n%s", "title", "album", "artist",
                "-------------------------------+-----------------------+--------------------"));
        for (Row row : results) {
            System.out.println(String.format("%-30s\t%-20s\t%-20s", row.getString("title"),
                    row.getString("album"), row.getString("artist")));
        }
        System.out.println();

session.execute("CREATE KEYSPACE simplex WITH replication " + "= {‘class‘:‘SimpleStrategy‘, ‘replication_factor‘:3};"); b.建立一个Table： 
session.execute(
                "CREATE TABLE simplex.songs (" +
                        "id uuid PRIMARY KEY," +
                        "title text," +
                        "album text," +
                        "artist text," +
                        "tags set<text>," +
                        "data blob" +
                        ");");
c. 插入数据： 
session.execute(
                "INSERT INTO simplex.songs (id, title, album, artist, tags) " +
                        "VALUES (" +
                        "756716f7-2e54-4715-9f00-91dcbea6cf50," +
                        "‘La Petite Tonkinoise‘," +
                        "‘Bye Bye Blackbird‘," +
                        "‘Joséphine Baker‘," +
                        "{‘jazz‘, ‘2013‘})" +
                        ";");
d. 查询数据： 
ResultSet results = session.execute("SELECT * FROM simplex.playlists ");

        System.out.println(String.format("%-30s\t%-20s\t%-20s\n%s", "title", "album", "artist",
                "-------------------------------+-----------------------+--------------------"));
        for (Row row : results) {
            System.out.println(String.format("%-30s\t%-20s\t%-20s", row.getString("title"),
                    row.getString("album"), row.getString("artist")));
        }
        System.out.println();


原文：http://www.cnblogs.com/lxjshuju/p/6837304.html

内容总结

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

内容备注

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

内容手机端

扫描二维码推送至手机访问。

本文链接：https://www.qyyshop.com/info/1147179.html

来源：【匿名】