Öğretici: Azure Cosmos DB'de Cassandra için API tablosuna örnek verileri yükleme

ŞUNLAR IÇIN GEÇERLIDIR: Cassandra

Geliştirici olarak anahtar/değer çiftleri kullanan uygulamalarınız olabilir. Anahtar/değer verilerini depolamak ve yönetmek için Azure Cosmos DB'de Cassandra hesabı için API kullanabilirsiniz. Bu öğreticide, Java uygulaması kullanarak Azure Cosmos DB'de Cassandra hesabı için API'deki bir tabloya örnek kullanıcı verilerinin nasıl yüklenip yüklendiği gösterilmektedir. Java uygulaması Java sürücüsünü kullanır ve kullanıcı kimliği, kullanıcı adı ve kullanıcı şehri gibi kullanıcı verilerini yükler.

Bu öğretici aşağıdaki görevleri kapsar:

• Cassandra tablosuna veri yükleme
• Uygulamayı çalıştırma

Azure aboneliğiniz yoksa başlamadan önce ücretsiz bir hesap oluşturun.

Önkoşullar

• Bu makale çok bölümlü bir öğreticiye aittir. Bu belgeyi kullanmaya başlamadan önce Cassandra hesabı, anahtar alanı ve tablo için API'yi oluşturduğunuzdan emin olun.

Tabloya veri yükleme

Cassandra için API tablonuza veri yüklemek için aşağıdaki adımları kullanın:

1. "src\main\java\com\azure\cosmosdb\cassandra" klasörünün altında "UserRepository.java" dosyasını açın ve user_id, user_name ve user_bcity alanlarını tabloya eklemek için kodu ekleyin:

   /**
   * Insert a row into user table
   *
   * @param id   user_id
   * @param name user_name
   * @param city user_bcity
   */
   public void insertUser(PreparedStatement statement, int id, String name, String city) {
        BoundStatement boundStatement = new BoundStatement(statement);
        session.execute(boundStatement.bind(id, name, city));
   }
   
   /**
   * Create a PrepareStatement to insert a row to user table
   *
   * @return PreparedStatement
   */
   public PreparedStatement prepareInsertStatement() {
      final String insertStatement = "INSERT INTO  uprofile.user (user_id, user_name , user_bcity) VALUES (?,?,?)";
   return session.prepare(insertStatement);
   }
   

2. "src\main\java\com\azure\cosmosdb\cassandra" klasörünün altında "UserProfile.java" dosyasını açın. Bu sınıf, daha önce tanımladığınız createKeyspace ve createTable yöntemlerini çağıran main yöntemini içerir. Şimdi Cassandra için API tablosuna örnek veriler eklemek için aşağıdaki kodu ekleyin.

   //Insert rows into user table
   PreparedStatement preparedStatement = repository.prepareInsertStatement();
     repository.insertUser(preparedStatement, 1, "JohnH", "Seattle");
     repository.insertUser(preparedStatement, 2, "EricK", "Spokane");
     repository.insertUser(preparedStatement, 3, "MatthewP", "Tacoma");
     repository.insertUser(preparedStatement, 4, "DavidA", "Renton");
     repository.insertUser(preparedStatement, 5, "PeterS", "Everett");
   

Uygulamayı çalıştırma

Bir komut istemi veya terminal penceresi açın ve klasör yolunu projeyi oluşturduğunuz yerle değiştirin. Hedef klasör içinde cosmosdb-cassandra-examples.jar dosyasını oluşturmak için "mvn clean install" komutunu çalıştırın ve uygulamayı çalıştırın.

cd "cassandra-demo"

mvn clean install

java -cp target/cosmosdb-cassandra-examples.jar com.azure.cosmosdb.cassandra.examples.UserProfile

Artık kullanıcı bilgilerinin tabloya eklendiğini doğrulamak için Azure portalda Veri Gezgini'ni açabilirsiniz.

Sonraki adımlar

Bu öğreticide, Azure Cosmos DB'de Cassandra hesabı için bir API'ye örnek verileri yüklemeyi öğrendiniz. Şimdi bir sonraki makaleye geçebilirsiniz:

Cassandra hesabı için API'den veri sorgulama