Öğ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 BIR API'deki bir tabloya örnek kullanıcı verilerinin nasıl yüklenecekleri 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 belgeyle 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:
"src\main\java\com\azure\cosmosdb\cassandra" klasörünün altındaki "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); }
"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 tablosu için API'ye ö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örde cosmosdb-cassandra-examples.jar dosyasını oluşturmak ve uygulamayı çalıştırmak için "mvn clean install" komutunu ç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 veri yüklemeyi öğrendiniz. Şimdi bir sonraki makaleye geçebilirsiniz:
Geri Bildirim
https://aka.ms/ContentUserFeedback.
Çok yakında: 2024 boyunca, içerik için geri bildirim mekanizması olarak GitHub Sorunları’nı kullanımdan kaldıracak ve yeni bir geri bildirim sistemiyle değiştireceğiz. Daha fazla bilgi için bkz.Gönderin ve geri bildirimi görüntüleyin