1. Genel Bakış
Google Cloud Spanner, performanstan ve yüksek kullanılabilirlikten ödün vermeden ACID işlemleri ve SQL semantiği sağlayan, tümüyle yönetilen, yatay olarak ölçeklenebilir, küresel olarak dağıtılmış bir ilişkisel veritabanı hizmetidir.
Bu laboratuvarda, Cloud Spanner örneği oluşturmayı öğreneceksiniz. Oyunlardaki skor tablosu için kullanılabilecek bir veritabanı ve şema oluşturma adımlarını inceleyeceksiniz. Oyuncu bilgilerini depolamak için bir Oyuncular tablosu ve oyuncu puanlarını depolamak için bir Puanlar tablosu oluşturarak başlayacaksınız.
Ardından, tabloları örnek verilerle doldurursunuz. Ardından, bazı İlk On örnek sorgularını çalıştırarak laboratuvarı tamamlayacak ve kaynakları boşaltmak için örneği sileceksiniz.
Neler öğreneceksiniz?
- Cloud Spanner örneği oluşturma
- Veritabanı ve tablolar oluşturma
- Commit zaman damgası sütunu nasıl kullanılır?
- Zaman damgalarıyla Cloud Spanner veritabanı tablonuza veri yükleme
- Cloud Spanner veritabanınızı sorgulama
- Cloud Spanner örneğinizi nasıl sileceğiniz açıklanır.
Gerekenler
Bu eğitimi nasıl kullanacaksınız?
Google Cloud Platform deneyiminizi nasıl değerlendirirsiniz?
2. Kurulum ve Gereksinimler
Yönlendirmesiz ortam kurulumu
Google Hesabınız (Gmail veya Google Apps) yoksa hesap oluşturmanız gerekir. Google Cloud Platform Console'da ( console.cloud.google.com) oturum açın ve yeni bir proje oluşturun.
Önceden oluşturduğunuz bir projeniz varsa konsolun sol üst kısmındaki proje seçimi açılır menüsünü tıklayın:
ve yeni bir proje oluşturmak için açılan iletişim kutusunda "YENİ PROJE" düğmesini tıklayın:
Henüz bir projeniz yoksa ilk projenizi oluşturmak için aşağıdaki gibi bir iletişim kutusu görürsünüz:
Sonraki proje oluşturma iletişim kutusunda yeni projenizin ayrıntılarını girebilirsiniz:
Tüm Google Cloud projelerinde benzersiz bir ad olan proje kimliğini unutmayın (Yukarıdaki ad zaten alınmış olduğundan sizin için çalışmayacaktır). Bu codelab'in ilerleyen kısımlarında PROJECT_ID olarak adlandırılacaktır.
Ardından, henüz yapmadıysanız Google Cloud kaynaklarını kullanmak için Developers Console'da faturalandırmayı etkinleştirmeniz ve Cloud Spanner API'yi etkinleştirmeniz gerekir.
Bu codelab'i tamamlamak size birkaç dolardan fazla maliyet getirmemelidir. Ancak daha fazla kaynak kullanmaya veya kaynakları çalışır durumda bırakmaya karar verirseniz maliyet artabilir (bu belgenin sonundaki "temizleme" bölümüne bakın). Google Cloud Spanner fiyatlandırması burada belgelenmiştir.
Google Cloud Platform'un yeni kullanıcıları, bu codelab'i tamamen ücretsiz hale getirecek 300 ABD doları değerinde ücretsiz deneme sürümünden yararlanabilir.
Google Cloud Shell Kurulumu
Google Cloud ve Spanner, dizüstü bilgisayarınızdan uzaktan çalıştırılabilir ancak bu codelab'de Cloud'da çalışan bir komut satırı ortamı olan Google Cloud Shell'i kullanacağız.
Bu Debian tabanlı sanal makine, ihtiyaç duyacağınız tüm geliştirme araçlarını içerir. 5 GB boyutunda kalıcı bir ana dizin bulunur ve Google Cloud'da çalışır. Bu sayede ağ performansı ve kimlik doğrulama önemli ölçüde güçlenir. Bu nedenle, bu codelab için ihtiyacınız olan tek şey bir tarayıcıdır (Chromebook'ta da çalışır).
- Cloud Shell'i Cloud Console'dan etkinleştirmek için Cloud Shell'i etkinleştir 'i
tıklamanız yeterlidir (ortamın sağlanması ve bağlantının kurulması yalnızca birkaç saniye sürer).
Cloud Shell'e bağlandıktan sonra kimliğinizin doğrulandığını ve projenin, PROJECT_ID'nize ayarlandığını görürsünüz.
gcloud auth list
Komut çıkışı
Credentialed accounts: - <myaccount>@<mydomain>.com (active)
gcloud config list project
Komut çıkışı
[core] project = <PROJECT_ID>
Herhangi bir nedenle proje ayarlanmamışsa şu komutu verin:
gcloud config set project <PROJECT_ID>
PROJECT_ID cihazınızı mı arıyorsunuz? Kurulum adımlarında hangi kimliği kullandığınızı kontrol edin veya Cloud Console kontrol panelinde arayın:
Cloud Shell, gelecekteki komutları çalıştırırken faydalı olabilecek bazı ortam değişkenlerini de varsayılan olarak ayarlar.
echo $GOOGLE_CLOUD_PROJECT
Komut çıkışı
<PROJECT_ID>
- Son olarak, varsayılan alt bölgeyi ve proje yapılandırmasını ayarlayın.
gcloud config set compute/zone us-central1-f
Çeşitli bölgeler arasından seçim yapabilirsiniz. Daha fazla bilgi için Bölgeler ve Alt Bölgeler başlıklı makaleyi inceleyin.
Özet
Bu adımda ortamınızı ayarlarsınız.
Sıradaki
Ardından, Cloud Spanner örneği oluşturacaksınız.
3. Cloud Spanner örneği oluşturma
Bu adımda, bu codelab için Cloud Spanner örneğimizi kuruyoruz. Sol üstteki hamburger menüsünde 
Spanner girişini arayın 
veya "/" tuşuna basıp "Spanner" yazarak Spanner'ı arayın.
Ardından 
simgesini tıklayın ve örneğiniz için cloudspanner-leaderboard örnek adını girerek, bir yapılandırma seçerek (bölgesel bir örnek seçin) ve düğüm sayısını ayarlayarak formu doldurun. Bu codelab için yalnızca 1 düğüme ihtiyacımız olacak. Üretim örnekleri için ve Cloud Spanner HDS'sine uygun olmak üzere Cloud Spanner örneğinizde 3 veya daha fazla düğüm çalıştırmanız gerekir.
Son olarak "Oluştur"u tıkladığınızda saniyeler içinde Cloud Spanner örneğini kullanmaya başlayabilirsiniz.
Bir sonraki adımda, yeni örneğimizde veritabanı ve şema oluşturmak için Java istemci kitaplığını kullanacağız.
4. Veritabanı ve şema oluşturma
Bu adımda örnek veritabanımızı ve şemamızı oluşturacağız.
Oyuncu bilgileri için bir Oyuncular tablosu ve oyuncu puanlarını depolamak için bir Puanlar tablosu olmak üzere iki tablo oluşturmak için Java istemci kitaplığını kullanalım. Bunu yapmak için Cloud Shell'de Java konsol uygulaması oluşturma adımlarını inceleyeceğiz.
Öncelikle Cloud Shell'de aşağıdaki komutu yazarak bu codelab'in örnek kodunu GitHub'dan klonlayın:
git clone https://github.com/GoogleCloudPlatform/java-docs-samples.git
Ardından, uygulamanızı oluşturacağınız "applications" dizinine geçin.
cd java-docs-samples/spanner/leaderboard
Bu codelab için gereken tüm kod, codelab'de ilerlerken referans olarak kullanabileceğiniz, java-docs-samples/spanner/leaderboard/complete dizininde Leaderboard adlı çalıştırılabilir bir C# uygulaması olarak bulunur. Yeni bir dizin oluşturup skor tablosu uygulamasının bir kopyasını aşamalar halinde oluşturacağız.
Uygulama için "codelab" adlı yeni bir dizin oluşturun ve aşağıdaki komutla dizini değiştirin:
mkdir codelab && cd $_
Aşağıdaki Maven (mvn) komutunu kullanarak "Leaderboard" adlı yeni bir temel Java uygulaması oluşturun:
mvn -B archetype:generate -DarchetypeGroupId=org.apache.maven.archetypes -DgroupId=com.google.codelabs -DartifactId=leaderboard -DarchetypeVersion=1.4
Bu komut, iki temel dosyadan oluşan basit bir konsol uygulaması oluşturur: Maven uygulama yapılandırma dosyası pom.xml ve Java uygulama dosyası App.java.
Ardından, dizini yeni oluşturulan skor tablosu diziniyle değiştirin ve içeriğini listeleyin:
cd leaderboard && ls
pom.xml dosyası ve src dizini listelenmiş olmalıdır:
pom.xml src
Şimdi de App.java dosyasını düzenleyerek bu konsol uygulamasını güncelleyelim. Bu işlemle, iki tablodan (Oyuncular ve Skorlar) oluşan bir skor tablosu oluşturmak için Java Spanner istemci kitaplığı kullanılır. Bunu doğrudan Cloud Shell Düzenleyici'de yapabilirsiniz:
Aşağıda vurgulanan simgeyi tıklayarak Cloud Shell Düzenleyici'yi açın:
Liderlik tablosu klasöründeki pom.xml dosyasını açın. java-docs-samples\ spanner\leaderboard\codelab\leaderboard klasöründe bulunan pom.xml dosyasını açın.Bu dosya, uygulamamızı tüm bağımlılıklarımızla birlikte bir JAR olarak oluşturmak için Maven derleme sistemini yapılandırır.
Mevcut </properties> öğesinin hemen altına aşağıdaki 1 yeni bağımlılık yönetimi bölümünü ekleyin:
<dependencyManagement>
<dependencies>
<dependency>
<groupId>com.google.cloud</groupId>
<artifactId>google-cloud-bom</artifactId>
<version>0.83.0-alpha</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
Ayrıca, mevcut <dependencies> bölümüne 1 yeni bağımlılık ekleyin. Bu bağımlılık, Cloud Spanner Java istemci kitaplığını uygulamaya ekler.
<dependency>
<!-- Version auto-managed by BOM -->
<groupId>com.google.cloud</groupId>
<artifactId>google-cloud-spanner</artifactId>
</dependency>
Ardından, pom.xml dosyasının mevcut <build> bölümünü aşağıdaki <build> bölümüyle değiştirin:
<build>
<plugins>
<plugin>
<artifactId>maven-assembly-plugin</artifactId>
<version>2.5.5</version>
<configuration>
<finalName>leaderboard</finalName>
<descriptorRefs>
<descriptorRef>jar-with-dependencies</descriptorRef>
</descriptorRefs>
<archive>
<manifest>
<mainClass>com.google.codelabs.App</mainClass>
</manifest>
</archive>
<appendAssemblyId>false</appendAssemblyId>
<attach>false</attach>
</configuration>
<executions>
<execution>
<id>make-assembly</id>
<phase>package</phase>
<goals>
<goal>single</goal>
</goals>
</execution>
</executions>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-failsafe-plugin</artifactId>
<version>3.0.0-M3</version>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-surefire-plugin</artifactId>
<version>3.0.0-M3</version>
<configuration>
<useSystemClassLoader>false</useSystemClassLoader>
</configuration>
</plugin>
</plugins>
</build>
Cloud Shell Düzenleyici'nin"Dosya" menüsünde "Kaydet"i seçerek veya klavyedeki "Ctrl" ve "S" tuşlarına birlikte basarak pom.xml dosyasında yaptığınız değişiklikleri kaydedin.
Ardından, App.java klasöründeki Cloud Shell Düzenleyici'de src/main/java/com/google/codelabs/ dosyasını açın. Aşağıdaki Java kodunu App.java dosyasına yapıştırarak dosyanın mevcut kodunu leaderboard veritabanını, Players ve Scores tablolarını oluşturmak için gereken kodla değiştirin:
package com.google.codelabs;
import com.google.api.gax.longrunning.OperationFuture;
import com.google.cloud.spanner.Database;
import com.google.cloud.spanner.DatabaseAdminClient;
import com.google.cloud.spanner.DatabaseClient;
import com.google.cloud.spanner.DatabaseId;
import com.google.cloud.spanner.Spanner;
import com.google.cloud.spanner.SpannerException;
import com.google.cloud.spanner.SpannerExceptionFactory;
import com.google.cloud.spanner.SpannerOptions;
import com.google.spanner.admin.database.v1.CreateDatabaseMetadata;
import java.util.Arrays;
import java.util.concurrent.ExecutionException;
/**
* Example code for using the Cloud Spanner API with the Google Cloud Java client library
* to create a simple leaderboard.
*
* This example demonstrates:
*
* <p>
*
* <ul>
* <li>Creating a Cloud Spanner database.
* </ul>
*/
public class App {
static void create(DatabaseAdminClient dbAdminClient, DatabaseId db) {
OperationFuture<Database, CreateDatabaseMetadata> op =
dbAdminClient.createDatabase(
db.getInstanceId().getInstance(),
db.getDatabase(),
Arrays.asList(
"CREATE TABLE Players(\n"
+ " PlayerId INT64 NOT NULL,\n"
+ " PlayerName STRING(2048) NOT NULL\n"
+ ") PRIMARY KEY(PlayerId)",
"CREATE TABLE Scores(\n"
+ " PlayerId INT64 NOT NULL,\n"
+ " Score INT64 NOT NULL,\n"
+ " Timestamp TIMESTAMP NOT NULL\n"
+ " OPTIONS(allow_commit_timestamp=true)\n"
+ ") PRIMARY KEY(PlayerId, Timestamp),\n"
+ "INTERLEAVE IN PARENT Players ON DELETE NO ACTION"));
try {
// Initiate the request which returns an OperationFuture.
Database dbOperation = op.get();
System.out.println("Created database [" + dbOperation.getId() + "]");
} catch (ExecutionException e) {
// If the operation failed during execution, expose the cause.
throw (SpannerException) e.getCause();
} catch (InterruptedException e) {
// Throw when a thread is waiting, sleeping, or otherwise occupied,
// and the thread is interrupted, either before or during the activity.
throw SpannerExceptionFactory.propagateInterrupt(e);
}
}
static void printUsageAndExit() {
System.out.println("Leaderboard 1.0.0");
System.out.println("Usage:");
System.out.println(" java -jar leaderboard.jar "
+ "<command> <instance_id> <database_id> [command_option]");
System.out.println("");
System.out.println("Examples:");
System.out.println(" java -jar leaderboard.jar create my-instance example-db");
System.out.println(" - Create a sample Cloud Spanner database along with "
+ "sample tables in your project.\n");
System.exit(1);
}
public static void main(String[] args) throws Exception {
if (!(args.length == 3 || args.length == 4)) {
printUsageAndExit();
}
SpannerOptions options = SpannerOptions.newBuilder().build();
Spanner spanner = options.getService();
try {
String command = args[0];
DatabaseId db = DatabaseId.of(options.getProjectId(), args[1], args[2]);
DatabaseClient dbClient = spanner.getDatabaseClient(db);
DatabaseAdminClient dbAdminClient = spanner.getDatabaseAdminClient();
switch (command) {
case "create":
create(dbAdminClient, db);
break;
default:
printUsageAndExit();
}
} finally {
spanner.close();
}
System.out.println("Closed client");
}
}
Cloud Shell Düzenleyici'nin"Dosya" menüsünden "Kaydet"i seçerek App.java dosyasında yaptığınız değişiklikleri kaydedin.
create komutunu etkinleştirmek için kodu ekledikten sonra App.java dosyanızın nasıl görünmesi gerektiğine dair bir örnek görmek için java-docs-samples/spanner/leaderboard/step4/src dizinindeki App.java dosyasını kullanabilirsiniz.
Uygulamanızı oluşturmak için pom.xml dosyanızın bulunduğu dizinde mvn package komutunu çalıştırın:
mvn package
Java jar dosyanız başarıyla oluşturulduktan sonra aşağıdaki komutu girerek ortaya çıkan uygulamayı Cloud Shell'de çalıştırın:
java -jar target/leaderboard.jar
Aşağıdakine benzer bir çıkış alırsınız:
Leaderboard 1.0.0
Usage:
java -jar leaderboard.jar <command> <instance_id> <database_id> [command_option]
Examples:
java -jar leaderboard.jar create my-instance example-db
- Create a sample Cloud Spanner database along with sample tables in your project.
Bu yanıttan, Leaderboard uygulamasının şu anda olası bir komuta sahip olduğunu görüyoruz: create. create komutunun beklenen bağımsız değişkenlerinin örnek kimliği ve veritabanı kimliği olduğunu görüyoruz.
Şimdi aşağıdaki komutu çalıştırın.
java -jar target/leaderboard.jar create cloudspanner-leaderboard leaderboard
Birkaç saniye sonra aşağıdaki gibi bir yanıt görmeniz gerekir:
Created database [projects/your-project/instances/cloudspanner-leaderboard/databases/leaderboard]
Cloud Console'un Cloud Spanner bölümünde, yeni veritabanınız ve tablolarınız sol taraftaki menüde görünür.
Bir sonraki adımda, uygulamanızı yeni veritabanınıza bazı veriler yükleyecek şekilde güncelleyeceğiz.
5. Verileri Yükle
Şimdi Players ve Scores olmak üzere iki tablo içeren leaderboard adlı bir veritabanımız var. Şimdi de Java istemci kitaplığını kullanarak Players tablomuzu oyuncularla, Scores tablomuzu ise her oyuncu için rastgele puanlarla dolduralım.
Henüz açık değilse aşağıdaki simgeyi tıklayarak Cloud Shell Düzenleyici'yi açın:
Ardından, App.java dosyasını Cloud Shell Düzenleyici'de düzenleyerek Players tablosuna 100 oyuncu eklemek için kullanılabilecek bir insert komutu ekleyin veya Players tablosundaki her oyuncu için Scores tablosuna 4 rastgele puan eklemek için kullanılabilecek bir komut ekleyin.
Öncelikle uygulama dosyasının üst kısmındaki imports bölümünü güncelleyin. Bu bölümdeki mevcut bilgileri aşağıdaki gibi görünecek şekilde değiştirin:
package com.google.codelabs;
import static com.google.cloud.spanner.TransactionRunner.TransactionCallable;
import com.google.api.gax.longrunning.OperationFuture;
import com.google.cloud.spanner.Database;
import com.google.cloud.spanner.DatabaseAdminClient;
import com.google.cloud.spanner.DatabaseClient;
import com.google.cloud.spanner.DatabaseId;
import com.google.cloud.spanner.Mutation;
import com.google.cloud.spanner.ResultSet;
import com.google.cloud.spanner.Spanner;
import com.google.cloud.spanner.SpannerException;
import com.google.cloud.spanner.SpannerExceptionFactory;
import com.google.cloud.spanner.SpannerOptions;
import com.google.cloud.spanner.Statement;
import com.google.cloud.spanner.TransactionContext;
import com.google.spanner.admin.database.v1.CreateDatabaseMetadata;
import java.time.Instant;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.time.ZoneOffset;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Random;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ThreadLocalRandom;
Ardından, aşağıdaki insert, insertPlayers ve insertScores yöntemlerini mevcut create() yönteminin altına ve mevcut printUsageAndExit() yönteminin üstüne ekleyin:
static void insert(DatabaseClient dbClient, String insertType) {
try {
insertType = insertType.toLowerCase();
} catch (Exception e) {
// Invalid input received, set insertType to empty string.
insertType = "";
}
if (insertType.equals("players")) {
// Insert players.
insertPlayers(dbClient);
} else if (insertType.equals("scores")) {
// Insert scores.
insertScores(dbClient);
} else {
// Invalid input.
System.out.println("Invalid value for 'type of insert'. "
+ "Specify a valid value: 'players' or 'scores'.");
System.exit(1);
}
}
static void insertPlayers(DatabaseClient dbClient) {
dbClient
.readWriteTransaction()
.run(
new TransactionCallable<Void>() {
@Override
public Void run(TransactionContext transaction) throws Exception {
// Get the number of players.
String sql = "SELECT Count(PlayerId) as PlayerCount FROM Players";
ResultSet resultSet = transaction.executeQuery(Statement.of(sql));
long numberOfPlayers = 0;
if (resultSet.next()) {
numberOfPlayers = resultSet.getLong("PlayerCount");
}
// Insert 100 player records into the Players table.
List<Statement> stmts = new ArrayList<Statement>();
long randomId;
for (int x = 1; x <= 100; x++) {
numberOfPlayers++;
randomId = (long) Math.floor(Math.random() * 9_000_000_000L) + 1_000_000_000L;
Statement statement =
Statement
.newBuilder(
"INSERT INTO Players (PlayerId, PlayerName) "
+ "VALUES (@PlayerId, @PlayerName) ")
.bind("PlayerId")
.to(randomId)
.bind("PlayerName")
.to("Player " + numberOfPlayers)
.build();
stmts.add(statement);
}
transaction.batchUpdate(stmts);
return null;
}
});
System.out.println("Done inserting player records...");
}
static void insertScores(DatabaseClient dbClient) {
boolean playerRecordsFound = false;
ResultSet resultSet =
dbClient
.singleUse()
.executeQuery(Statement.of("SELECT * FROM Players"));
while (resultSet.next()) {
playerRecordsFound = true;
final long playerId = resultSet.getLong("PlayerId");
dbClient
.readWriteTransaction()
.run(
new TransactionCallable<Void>() {
@Override
public Void run(TransactionContext transaction) throws Exception {
// Initialize objects for random Score and random Timestamp.
LocalDate endDate = LocalDate.now();
long end = endDate.toEpochDay();
int startYear = endDate.getYear() - 2;
int startMonth = endDate.getMonthValue();
int startDay = endDate.getDayOfMonth();
LocalDate startDate = LocalDate.of(startYear, startMonth, startDay);
long start = startDate.toEpochDay();
Random r = new Random();
List<Statement> stmts = new ArrayList<Statement>();
// Insert 4 score records into the Scores table
// for each player in the Players table.
for (int x = 1; x <= 4; x++) {
// Generate random score between 1,000,000 and 1,000
long randomScore = r.nextInt(1000000 - 1000) + 1000;
// Get random day within the past two years.
long randomDay = ThreadLocalRandom.current().nextLong(start, end);
LocalDate randomDayDate = LocalDate.ofEpochDay(randomDay);
LocalTime randomTime = LocalTime.of(
r.nextInt(23), r.nextInt(59), r.nextInt(59), r.nextInt(9999));
LocalDateTime randomDate = LocalDateTime.of(randomDayDate, randomTime);
Instant randomInstant = randomDate.toInstant(ZoneOffset.UTC);
Statement statement =
Statement
.newBuilder(
"INSERT INTO Scores (PlayerId, Score, Timestamp) "
+ "VALUES (@PlayerId, @Score, @Timestamp) ")
.bind("PlayerId")
.to(playerId)
.bind("Score")
.to(randomScore)
.bind("Timestamp")
.to(randomInstant.toString())
.build();
stmts.add(statement);
}
transaction.batchUpdate(stmts);
return null;
}
});
}
if (!playerRecordsFound) {
System.out.println("Parameter 'scores' is invalid since "
+ "no player records currently exist. First insert players "
+ "then insert scores.");
System.exit(1);
} else {
System.out.println("Done inserting score records...");
}
}
Ardından, insert komutunun çalışır hâle gelmesi için aşağıdaki kodu uygulamanızın switch (command) ifadesindeki "main" yöntemine ekleyin :
case "insert":
String insertType;
try {
insertType = args[3];
} catch (ArrayIndexOutOfBoundsException exception) {
insertType = "";
}
insert(dbClient, insertType);
break;
İşlemi tamamladığınızda switch (command) ifadesi aşağıdaki gibi görünmelidir:
switch (command) {
case "create":
create(dbAdminClient, db);
break;
case "insert":
String insertType;
try {
insertType = args[3];
} catch (ArrayIndexOutOfBoundsException exception) {
insertType = "";
}
insert(dbClient, insertType);
break;
default:
printUsageAndExit();
}
Uygulamanıza "ekleme" işlevini ekleme işlemini tamamlamak için son adım olarak printUsageAndExit() yöntemine "ekleme" komutuyla ilgili yardım metni eklemeniz gerekir. Ekleme komutu için yardım metni eklemek üzere printUsageAndExit() yöntemine aşağıdaki kod satırlarını ekleyin:
System.out.println(" java -jar leaderboard.jar insert my-instance example-db players");
System.out.println(" - Insert 100 sample Player records into the database.\n");
System.out.println(" java -jar leaderboard.jar insert my-instance example-db scores");
System.out.println(" - Insert sample score data into Scores sample Cloud Spanner "
+ "database table.\n");
Cloud Shell Düzenleyici'nin"Dosya" menüsünden "Kaydet"i seçerek App.java dosyasında yaptığınız değişiklikleri kaydedin.
insert komutunu etkinleştirmek için kodu ekledikten sonra App.java dosyanızın nasıl görünmesi gerektiğine dair bir örnek görmek için java-docs-samples/spanner/leaderboard/step5/src dizinindeki App.java dosyasını kullanabilirsiniz.
Şimdi yeni insert komutunun uygulamanın olası komutlar listesine dahil edildiğini doğrulamak için uygulamayı yeniden oluşturup çalıştıralım.
Uygulamanızı oluşturmak için pom.xml dosyanızın bulunduğu dizinde mvn package komutunu çalıştırın:
mvn package
Java jar dosyanız başarıyla oluşturulduktan sonra aşağıdaki komutu çalıştırın:
java -jar target/leaderboard.jar
insert komutunun artık uygulamanın varsayılan çıkışına dahil edildiğini görmeniz gerekir:
Leaderboard 1.0.0
Usage:
java -jar leaderboard.jar <command> <instance_id> <database_id> [command_option]
Examples:
java -jar leaderboard.jar create my-instance example-db
- Create a sample Cloud Spanner database along with sample tables in your project.
java -jar leaderboard.jar insert my-instance example-db players
- Insert 100 sample Player records into the database.
java -jar leaderboard.jar insert my-instance example-db scores
- Insert sample score data into Scores sample Cloud Spanner database table.
Yanıtı incelediğinizde, örnek kimliği ve veritabanı kimliğine ek olarak "oyuncular" veya "puanlar" değerini alabilen başka bir bağımsız değişken olduğunu görebilirsiniz.
Şimdi, insert komutunu çağırırken kullandığımız aynı bağımsız değişken değerleriyle insert komutunu çalıştıralım ve ek "ekleme türü" bağımsız değişkeni olarak "players"ı ekleyelim.create
java -jar target/leaderboard.jar insert cloudspanner-leaderboard leaderboard players
Birkaç saniye sonra aşağıdaki gibi bir yanıt görmeniz gerekir:
Done inserting player records...
Şimdi de Java istemci kitaplığını kullanarak Scores tablomuzu, Players tablosundaki her oyuncu için zaman damgalarıyla birlikte dört rastgele puanla dolduralım.
Scores tablosunun Timestamp sütunu, daha önce create komutunu çalıştırdığımızda yürütülen aşağıdaki SQL ifadesiyle "commit timestamp" sütunu olarak tanımlandı:
CREATE TABLE Scores(
PlayerId INT64 NOT NULL,
Score INT64 NOT NULL,
Timestamp TIMESTAMP NOT NULL OPTIONS(allow_commit_timestamp=true)
) PRIMARY KEY(PlayerId, Timestamp),
INTERLEAVE IN PARENT Players ON DELETE NO ACTION
OPTIONS(allow_commit_timestamp=true) özelliğine dikkat edin. Bu, Timestamp sütununu "commit timestamp" sütunu yapar ve belirli bir tablo satırında INSERT ve UPDATE işlemleri için tam işlem zaman damgasıyla otomatik olarak doldurulmasını sağlar.
Geçmişte bir değere sahip bir zaman damgası eklediğiniz sürece "commit timestamp" sütununa kendi zaman damgası değerlerinizi de ekleyebilirsiniz. Bu codelab'in amacı doğrultusunda bu işlemi yapacağız.
Şimdi, insert komutunu çağırırken kullandığımız aynı bağımsız değişken değerleriyle insert komutunu çalıştıralım ve ek "ekleme türü" bağımsız değişkeni olarak "puanlar"ı ekleyelim.create
java -jar target/leaderboard.jar insert cloudspanner-leaderboard leaderboard scores
Birkaç saniye sonra aşağıdaki gibi bir yanıt görmeniz gerekir:
Done inserting score records...
insert, "ekleme türü" scores olarak belirtilerek çalıştırıldığında, geçmişte gerçekleşen bir tarih-saat ile rastgele oluşturulmuş bir zaman damgası eklemek için aşağıdaki kod snippet'lerini kullanan insertScores yöntemi çağrılır:
LocalDate endDate = LocalDate.now();
long end = endDate.toEpochDay();
int startYear = endDate.getYear() - 2;
int startMonth = endDate.getMonthValue();
int startDay = endDate.getDayOfMonth();
LocalDate startDate = LocalDate.of(startYear, startMonth, startDay);
long start = startDate.toEpochDay();
...
long randomDay = ThreadLocalRandom.current().nextLong(start, end);
LocalDate randomDayDate = LocalDate.ofEpochDay(randomDay);
LocalTime randomTime = LocalTime.of(
r.nextInt(23), r.nextInt(59), r.nextInt(59), r.nextInt(9999));
LocalDateTime randomDate = LocalDateTime.of(randomDayDate, randomTime);
Instant randomInstant = randomDate.toInstant(ZoneOffset.UTC);
...
.bind("Timestamp")
.to(randomInstant.toString())
Timestamp sütununu, "Ekle" işleminin tam olarak gerçekleştiği zaman damgasıyla otomatik olarak doldurmak için bunun yerine aşağıdaki kod snippet'inde olduğu gibi Value.COMMIT_TIMESTAMP Java sabitini ekleyebilirsiniz:
.bind("Timestamp")
.to(Value.COMMIT_TIMESTAMP)
Veri yükleme işlemini tamamladığımıza göre, yeni tablolarımıza yazdığımız değerleri doğrulayalım. Önce leaderboard veritabanını, ardından Players tablosunu seçin. Data sekmesini tıklayın. Tablonun PlayerId ve PlayerName sütunlarında verilerinizin olduğunu görmelisiniz.
Ardından, Scores tablosunu tıklayıp Data sekmesini seçerek Puanlar tablosunda da veri olup olmadığını doğrulayalım. Tablonun PlayerId, Timestamp ve Score sütunlarında verilerinizin olduğunu görmelisiniz.
Tebrikler! Oyun skor tablosu oluşturmak için kullanabileceğimiz bazı sorguları çalıştırmak üzere uygulamamızı güncelleyelim.
6. Skor tablosu sorguları çalıştırma
Veritabanımızı ayarlayıp tablolarımıza bilgi yüklediğimize göre şimdi bu verileri kullanarak bir skor tablosu oluşturalım. Bunu yapmak için aşağıdaki dört soruyu yanıtlamamız gerekiyor:
- Tüm zamanların "En İyi On" oyuncusu kimlerdir?
- Yılın "En İyi On" oyuncusu kimler?
- Ayın "En İyi On" Oyuncusu kimler?
- Haftanın "En İyi On" oyuncusu kimler?
Bu soruları yanıtlayacak SQL sorgularını çalıştırmak için uygulamamızı güncelleyelim.
Soruları yanıtlamak için sorguları çalıştırmanın bir yolunu sağlayacak bir query komutu ekleyeceğiz. Bu komut, skor tablomuz için gereken bilgileri üretecek.
Uygulamayı query komutunu ekleyecek şekilde güncellemek için Cloud Shell Düzenleyici'de App.java dosyasını düzenleyin. query komutu iki query yöntemden oluşur. Bunlardan biri yalnızca DatabaseClient bağımsız değişkenini alır, diğeri ise sonuçların saat cinsinden belirtilen bir zaman aralığına göre filtrelenmesini kolaylaştırmak için ek bir timespan bağımsız değişkenini alır.
Aşağıdaki iki query yöntemini mevcut insertScores() yönteminin altına ve mevcut printUsageAndExit() yönteminin üstüne ekleyin:
static void query(DatabaseClient dbClient) {
String scoreDate;
String score;
ResultSet resultSet =
dbClient
.singleUse()
.executeQuery(
Statement.of(
"SELECT p.PlayerId, p.PlayerName, s.Score, s.Timestamp "
+ "FROM Players p "
+ "JOIN Scores s ON p.PlayerId = s.PlayerId "
+ "ORDER BY s.Score DESC LIMIT 10"));
while (resultSet.next()) {
scoreDate = String.valueOf(resultSet.getTimestamp("Timestamp"));
score = String.format("%,d", resultSet.getLong("Score"));
System.out.printf(
"PlayerId: %d PlayerName: %s Score: %s Timestamp: %s\n",
resultSet.getLong("PlayerId"), resultSet.getString("PlayerName"), score,
scoreDate.substring(0,10));
}
}
static void query(DatabaseClient dbClient, int timespan) {
String scoreDate;
String score;
Statement statement =
Statement
.newBuilder(
"SELECT p.PlayerId, p.PlayerName, s.Score, s.Timestamp "
+ "FROM Players p "
+ "JOIN Scores s ON p.PlayerId = s.PlayerId "
+ "WHERE s.Timestamp > "
+ "TIMESTAMP_SUB(CURRENT_TIMESTAMP(), "
+ " INTERVAL @Timespan HOUR) "
+ "ORDER BY s.Score DESC LIMIT 10")
.bind("Timespan")
.to(timespan)
.build();
ResultSet resultSet =
dbClient
.singleUse()
.executeQuery(statement);
while (resultSet.next()) {
scoreDate = String.valueOf(resultSet.getTimestamp("Timestamp"));
score = String.format("%,d", resultSet.getLong("Score"));
System.out.printf(
"PlayerId: %d PlayerName: %s Score: %s Timestamp: %s\n",
resultSet.getLong("PlayerId"), resultSet.getString("PlayerName"), score,
scoreDate.substring(0,10));
}
}
Ardından, query komutunun çalışır hâle gelmesi için uygulamanızın "main" yöntemindeki switch(command) ifadesine aşağıdaki kodu ekleyin:
case "query":
if (args.length == 4) {
int timespan = 0;
try {
timespan = Integer.parseInt(args[3]);
} catch (NumberFormatException e) {
System.err.println("query command's 'timespan' parameter must be a valid integer.");
System.exit(1);
}
query(dbClient, timespan);
} else {
query(dbClient);
}
break;
Uygulamanıza "sorgu" işlevini eklemeyi tamamlamak için son adım olarak printUsageAndExit() yöntemine "sorgu" komutuyla ilgili yardım metni ekleyin. printUsageAndExit()Sorgu komutu için yardım metni eklemek üzere aşağıdaki kod satırlarını yönteme ekleyin:
System.out.println(" java -jar leaderboard.jar query my-instance example-db");
System.out.println(" - Query players with top ten scores of all time.\n");
System.out.println(" java -jar leaderboard.jar query my-instance example-db 168");
System.out.println(" - Query players with top ten scores within a timespan "
+ "specified in hours.\n");
Cloud Shell Düzenleyici'nin"Dosya" menüsünden "Kaydet"i seçerek App.java dosyasında yaptığınız değişiklikleri kaydedin.
query komutunu etkinleştirmek için kodu ekledikten sonra App.java dosyanızın nasıl görünmesi gerektiğine dair bir örnek görmek için dotnet-docs-samples/applications/leaderboard/step6/src dizinindeki App.java dosyasını kullanabilirsiniz.
Uygulamanızı oluşturmak için pom.xml dosyanızın bulunduğu dizinde mvn package komutunu çalıştırın:
mvn package
Şimdi uygulamayı çalıştırarak yeni query komutunun uygulamanın olası komutlar listesine dahil edildiğini doğrulayalım. Aşağıdaki komutu çalıştırın:
java -jar target/leaderboard.jar
query komutunun artık uygulamanın varsayılan çıkışına yeni bir komut seçeneği olarak eklendiğini görmeniz gerekir:
Leaderboard 1.0.0
Usage:
java -jar leaderboard.jar <command> <instance_id> <database_id> [command_option]
Examples:
java -jar leaderboard.jar create my-instance example-db
- Create a sample Cloud Spanner database along with sample tables in your project.
java -jar leaderboard.jar insert my-instance example-db players
- Insert 100 sample Player records into the database.
java -jar leaderboard.jar insert my-instance example-db scores
- Insert sample score data into Scores sample Cloud Spanner database table.
java -jar leaderboard.jar query my-instance example-db
- Query players with top ten scores of all time.
java -jar leaderboard.jar query my-instance example-db 168
- Query players with top ten scores within a timespan specified in hours.
Yanıtı incelediğinizde, query komutunun örnek kimliği ve veritabanı kimliği bağımsız değişkenlerine ek olarak, kayıtları Scores tablosunun Timestamp sütunundaki değerlerine göre filtrelemek için kullanılacak isteğe bağlı bir zaman aralığını saat cinsinden belirtmemize olanak tanıdığını görebilirsiniz. Zaman aralığı bağımsız değişkeni isteğe bağlı olduğundan, zaman aralığı bağımsız değişkeni dahil edilmezse kayıtlar zaman damgalarına göre filtrelenmez. Bu nedenle, tüm zamanların "En İyi On" oyuncusunun listesini almak için query komutunu "zaman aralığı" değeri olmadan kullanabiliriz.
query komutunu, create komutunu çalıştırırken kullandığımız bağımsız değişken değerlerini kullanarak "timespan" belirtmeden çalıştıralım.
java -jar target/leaderboard.jar query cloudspanner-leaderboard leaderboard
Aşağıdaki gibi, tüm zamanların "En İyi On" oyuncusunu içeren bir yanıt görmelisiniz:
PlayerId: 4018687297 PlayerName: Player 83 Score: 999,618 Timestamp: 2017-07-01
PlayerId: 4018687297 PlayerName: Player 83 Score: 998,956 Timestamp: 2017-09-02
PlayerId: 4285713246 PlayerName: Player 51 Score: 998,648 Timestamp: 2017-12-01
PlayerId: 5267931774 PlayerName: Player 49 Score: 997,733 Timestamp: 2017-11-09
PlayerId: 1981654448 PlayerName: Player 35 Score: 997,480 Timestamp: 2018-12-06
PlayerId: 4953940705 PlayerName: Player 87 Score: 995,184 Timestamp: 2018-09-14
PlayerId: 2456736905 PlayerName: Player 84 Score: 992,881 Timestamp: 2017-04-14
PlayerId: 8234617611 PlayerName: Player 19 Score: 992,399 Timestamp: 2017-12-27
PlayerId: 1788051688 PlayerName: Player 76 Score: 992,265 Timestamp: 2018-11-22
PlayerId: 7127686505 PlayerName: Player 97 Score: 992,038 Timestamp: 2017-12-02
Şimdi de bir yılın saat sayısına (8.760) eşit bir "zaman aralığı" belirterek yılın "En İyi On" oyuncusunu sorgulamak için gerekli bağımsız değişkenlerle query komutunu çalıştıralım.
java -jar target/leaderboard.jar query cloudspanner-leaderboard leaderboard 8760
Aşağıdaki gibi, yılın "En İyi On" oyuncusunu içeren bir yanıt görürsünüz:
PlayerId: 1981654448 PlayerName: Player 35 Score: 997,480 Timestamp: 2018-12-06
PlayerId: 4953940705 PlayerName: Player 87 Score: 995,184 Timestamp: 2018-09-14
PlayerId: 1788051688 PlayerName: Player 76 Score: 992,265 Timestamp: 2018-11-22
PlayerId: 6862349579 PlayerName: Player 30 Score: 990,877 Timestamp: 2018-09-14
PlayerId: 5529627211 PlayerName: Player 16 Score: 989,142 Timestamp: 2018-03-30
PlayerId: 9743904155 PlayerName: Player 1 Score: 988,765 Timestamp: 2018-05-30
PlayerId: 6809119884 PlayerName: Player 7 Score: 986,673 Timestamp: 2018-05-16
PlayerId: 2132710638 PlayerName: Player 54 Score: 983,108 Timestamp: 2018-09-11
PlayerId: 2320093590 PlayerName: Player 79 Score: 981,373 Timestamp: 2018-05-07
PlayerId: 9554181430 PlayerName: Player 80 Score: 981,087 Timestamp: 2018-06-21
Şimdi de bir ayın saat sayısına (730) eşit bir "zaman aralığı" belirterek ayın "En İyi On" oyuncusunu sorgulamak için query komutunu çalıştıralım.
java -jar target/leaderboard.jar query cloudspanner-leaderboard leaderboard 730
Aşağıdaki gibi, ayın "En İyi On" oyuncusunu içeren bir yanıt görürsünüz:
PlayerId: 3869829195 PlayerName: Player 69 Score: 949,686 Timestamp: 2019-02-19
PlayerId: 7448359883 PlayerName: Player 20 Score: 938,998 Timestamp: 2019-02-07
PlayerId: 1981654448 PlayerName: Player 35 Score: 929,003 Timestamp: 2019-02-22
PlayerId: 9336678658 PlayerName: Player 44 Score: 914,106 Timestamp: 2019-01-27
PlayerId: 6968576389 PlayerName: Player 40 Score: 898,041 Timestamp: 2019-02-21
PlayerId: 5529627211 PlayerName: Player 16 Score: 896,433 Timestamp: 2019-01-29
PlayerId: 9395039625 PlayerName: Player 59 Score: 879,495 Timestamp: 2019-02-09
PlayerId: 2094604854 PlayerName: Player 39 Score: 860,434 Timestamp: 2019-02-01
PlayerId: 9395039625 PlayerName: Player 59 Score: 849,955 Timestamp: 2019-02-21
PlayerId: 4285713246 PlayerName: Player 51 Score: 805,654 Timestamp: 2019-02-02
Şimdi de haftanın "En İyi On" oyuncusunu sorgulamak için query komutunu çalıştıralım. Bunu yaparken bir haftadaki saat sayısına (168) eşit bir "zaman aralığı" belirteceğiz.
java -jar target/leaderboard.jar query cloudspanner-leaderboard leaderboard 168
Aşağıdaki gibi, haftanın "En İyi On" oyuncusunu içeren bir yanıt görürsünüz:
PlayerId: 3869829195 PlayerName: Player 69 Score: 949,686 Timestamp: 2019-02-19
PlayerId: 1981654448 PlayerName: Player 35 Score: 929,003 Timestamp: 2019-02-22
PlayerId: 6968576389 PlayerName: Player 40 Score: 898,041 Timestamp: 2019-02-21
PlayerId: 9395039625 PlayerName: Player 59 Score: 849,955 Timestamp: 2019-02-21
PlayerId: 5954045812 PlayerName: Player 8 Score: 795,639 Timestamp: 2019-02-22
PlayerId: 3889939638 PlayerName: Player 71 Score: 775,252 Timestamp: 2019-02-21
PlayerId: 5529627211 PlayerName: Player 16 Score: 604,695 Timestamp: 2019-02-19
PlayerId: 9006728426 PlayerName: Player 3 Score: 457,208 Timestamp: 2019-02-22
PlayerId: 8289497066 PlayerName: Player 58 Score: 227,697 Timestamp: 2019-02-20
PlayerId: 8065482904 PlayerName: Player 99 Score: 198,429 Timestamp: 2019-02-24
Harika!
Artık kayıt ekledikçe Cloud Spanner, veritabanınızı ihtiyacınız olan boyuta göre ölçeklendirir. Veritabanınız ne kadar büyürse büyüsün, Cloud Spanner ve Truetime teknolojisi sayesinde oyununuzun skor tablosu doğru bir şekilde ölçeklenmeye devam edebilir.
7. Temizleme
Spanner ile oynayarak eğlendikten sonra, değerli kaynakları ve parayı korumak için oyun alanımızı temizlememiz gerekir. Neyse ki bu kolay bir adım. Cloud Console'un Cloud Spanner bölümüne gidip "Setup a Cloud Spanner Instance" (Cloud Spanner örneği oluşturma) adlı codelab adımında oluşturduğumuz örneği silmeniz yeterli.
8. Tebrikler!
İşlediğimiz konular:
- Liderlik tablosu için Google Cloud Spanner örnekleri, veritabanları ve tablo şeması
- Java konsol uygulaması oluşturma
- Java istemci kitaplığını kullanarak Spanner veritabanı ve tabloları oluşturma
- Java istemci kitaplığını kullanarak Spanner veritabanına veri yükleme
- Spanner commit zaman damgalarını ve Java istemci kitaplığını kullanarak verilerinizdeki "En İyi On" sonuçlarını sorgulama
Sonraki Adımlar:
- Spanner CAP Teknik Belgesi'ni okuyun.
- Şema tasarımı ve sorgu ile ilgili en iyi uygulamalar hakkında bilgi edinin.
- Cloud Spanner işleme zaman damgaları hakkında daha fazla bilgi edinin.
Görüşlerinizi bizimle paylaşın
- Lütfen birkaç dakikanızı ayırarak çok kısa anketimizi doldurun.