Ich habe Cassandras Object Mapper für Java ausprobiert

Ich habe Cassandras Object Mapper für Java ausprobiert

Ein Memo, als ich versuchte, den Beispielcode auszuschneiden und in [Official DataStax Manual] einzufügen (https://github.com/datastax/java-driver/blob/3.x/manual/object_mapper) ..

Annahme

• Ubuntu 17.04
• Cassandra 3.10 --Casandra Driver 3.2.0 auf der Java-Seite

Vorbereitung

Cassandra Seite

1. Installieren Sie Cassandra

   $ wget http://ftp.jaist.ac.jp/pub/apache/cassandra/3.10/apache-cassandra-3.10-bin.tar.gz
   $ tar -zxvf apache-cassandra-3.10-bin.tar.gz
   $ sudo mv apache-cassandra-3.10/ /opt/cassandra
   

2. Starten Sie den Cassandra-Server

   $ /opt/cassandra/bin/cassandra
   

3. Erstellen Sie einen Schlüsselraum (Name: ks)

   $ /opt/cassandra/bin/cqlsh 127.0.0.1 -e "\
   CREATE KEYSPACE ks\
     WITH REPLICATION = { 'class': 'SimpleStrategy', 'replication_factor': 1 };"
   

4. Tabelle erstellen (Name: Benutzer)

   $ /opt/cassandra/bin/cqlsh 127.0.0.1 -e "\
   CREATE TABLE ks.users (\
     user_id uuid,\
     name text,\
     strength int,\
     PRIMARY KEY(user_id, name)\
   );"
   

Java-Seite

• pom.xml

• Fügen Sie Abhängigkeiten für "Cassandra-Treiber-Core" und "Cassandra-Treiber-Mapping" hinzu

   ```xml:pom.xml
   ...
   <dependency>
       <groupId>com.datastax.cassandra</groupId>
       <artifactId>cassandra-driver-core</artifactId>
       <version>3.2.0</version>
   </dependency>
   <dependency>
       <groupId>com.datastax.cassandra</groupId>
       <artifactId>cassandra-driver-mapping</artifactId>
       <version>3.2.0</version>
   </dependency>
   ...
   ```
  

• Quellcode

• Zugeordnete Klasse

   ```User.java
   package sample;
   
   import com.datastax.driver.mapping.annotations.ClusteringColumn;
   import com.datastax.driver.mapping.annotations.Column;
   import com.datastax.driver.mapping.annotations.Param;
   import com.datastax.driver.mapping.annotations.PartitionKey;
   import com.datastax.driver.mapping.annotations.Table;
   import java.util.UUID;
   
   @Table(keyspace = "ks", name = "users",
       readConsistency = "QUORUM",
       writeConsistency = "QUORUM",
       caseSensitiveKeyspace = false,
       caseSensitiveTable = false)
   public class User {
   
     @PartitionKey
     @Column(name = "user_id")
     private UUID userId;
   
     @ClusteringColumn
     private String name;
   
     private int strength;
   
   
     public User(UUID userId, String name, int strength) {
       this.userId = userId;
       this.name = name;
       this.strength = strength;
     }
   }
   ```
  

--Hauptklasse

    ```Main.java
    package sample;

    import com.datastax.driver.core.Cluster;
    import com.datastax.driver.core.Session;
    import com.datastax.driver.mapping.Mapper;
    import com.datastax.driver.mapping.MappingManager;
    import java.util.UUID;

    public class Main {

      public static void main(String[] args) {
        Cluster cluster = null;
        try {
          cluster = Cluster.builder()
              .addContactPoint("127.0.0.1")
              .build();
          Session session = cluster.connect();
          MappingManager manager = new MappingManager(session);
          Mapper<User> mapper = manager.mapper(User.class);

          User u = new User(UUID.randomUUID(), "John Doe", 9999);
          mapper.save(u);

        } finally {
          if (cluster != null) {
            cluster.close();
          }
        }
      }
    }
    ```

Ausführungsergebnis

Überprüfen Sie nach dem Ausführen der obigen Hauptklasse von cqlsh aus, ob Daten eingefügt wurden.

$ /opt/cassandra/bin/cqlsh 127.0.0.1 -e "SELECT * FROM ks.users;"

 user_id                              | name     | strength
--------------------------------------+----------+----------
 e918961b-57c1-4f5d-8c4e-9d08e9ea4e7a | John Doe |     9999

(1 rows)

Referenz

• https://github.com/datastax/java-driver/blob/3.x/manual/README.md
• https://github.com/datastax/java-driver/blob/3.x/manual/object_mapper