Replace deprecated Gradle/ScalarDB features

microservice-transaction-sample/client/build.gradle

@@ -10,10 +10,15 @@ dependencies {
 }
 
 application {
-    mainClassName = 'sample.client.Client'
+    mainClass = 'sample.client.Client'
 }
 
-archivesBaseName = "sample-order-service"
+base {
+    archivesName = "sample-order-service"
+}
 
-sourceCompatibility = 1.8
-targetCompatibility = 1.8
+java {
+    toolchain {
+        languageVersion = JavaLanguageVersion.of(8)
+    }
+}

microservice-transaction-sample/customer-service/build.gradle

@@ -14,7 +14,7 @@ dependencies {
 }
 
 application {
-    mainClassName = 'sample.customer.CustomerServiceServer'
+    mainClass = 'sample.customer.CustomerServiceServer'
 }
 
 task copyFilesToDockerBuildContextDir(type: Copy) {
@@ -47,7 +47,12 @@ installDist {
     duplicatesStrategy DuplicatesStrategy.EXCLUDE
 }
 
-archivesBaseName = "sample-customer-service"
+base {
+    archivesName = "sample-customer-service"
+}
 
-sourceCompatibility = 1.8
-targetCompatibility = 1.8
+java {
+    toolchain {
+        languageVersion = JavaLanguageVersion.of(8)
+    }
+}

microservice-transaction-sample/customer-service/src/main/java/sample/customer/model/Customer.java

@@ -1,8 +1,9 @@
 package sample.customer.model;
 
 import com.scalar.db.api.Get;
-import com.scalar.db.api.Put;
+import com.scalar.db.api.Insert;
 import com.scalar.db.api.TransactionCrudOperable;
+import com.scalar.db.api.Update;
 import com.scalar.db.exception.transaction.CrudException;
 import com.scalar.db.io.Key;
 import java.util.Optional;
@@ -30,8 +31,8 @@ public Customer(int id, String name, int creditLimit, int creditTotal) {
   public static void put(
       TransactionCrudOperable transaction, int id, String name, int creditLimit, int creditTotal)
       throws CrudException {
-    transaction.put(
-        Put.newBuilder()
+    transaction.insert(
+        Insert.newBuilder()
             .namespace(NAMESPACE)
             .table(TABLE)
             .partitionKey(Key.ofInt(COL_CUSTOMER_ID, id))
@@ -43,8 +44,8 @@ public static void put(
 
   public static void updateCreditTotal(TransactionCrudOperable transaction, int id, int creditTotal)
       throws CrudException {
-    transaction.put(
-        Put.newBuilder()
+    transaction.update(
+        Update.newBuilder()
             .namespace(NAMESPACE)
             .table(TABLE)
             .partitionKey(Key.ofInt(COL_CUSTOMER_ID, id))

microservice-transaction-sample/order-service/build.gradle

@@ -14,7 +14,7 @@ dependencies {
 }
 
 application {
-    mainClassName = 'sample.order.OrderServiceServer'
+    mainClass = 'sample.order.OrderServiceServer'
 }
 
 task copyFilesToDockerBuildContextDir(type: Copy) {
@@ -47,7 +47,12 @@ installDist {
     duplicatesStrategy DuplicatesStrategy.EXCLUDE
 }
 
-archivesBaseName = "sample-order-service"
+base {
+    archivesName = "sample-order-service"
+}
 
-sourceCompatibility = 1.8
-targetCompatibility = 1.8
+java {
+    toolchain {
+        languageVersion = JavaLanguageVersion.of(8)
+    }
+}

microservice-transaction-sample/order-service/src/main/java/sample/order/model/Item.java

@@ -1,7 +1,7 @@
 package sample.order.model;
 
 import com.scalar.db.api.Get;
-import com.scalar.db.api.Put;
+import com.scalar.db.api.Insert;
 import com.scalar.db.api.TransactionCrudOperable;
 import com.scalar.db.exception.transaction.CrudException;
 import com.scalar.db.io.Key;
@@ -27,8 +27,8 @@ public Item(int id, String name, int price) {
 
   public static void put(TransactionCrudOperable transaction, int id, String name, int price)
       throws CrudException {
-    transaction.put(
-        Put.newBuilder()
+    transaction.insert(
+        Insert.newBuilder()
             .namespace(NAMESPACE)
             .table(TABLE)
             .partitionKey(Key.ofInt(COL_ITEM_ID, id))

microservice-transaction-sample/order-service/src/main/java/sample/order/model/Order.java

@@ -1,7 +1,7 @@
 package sample.order.model;
 
 import com.scalar.db.api.Get;
-import com.scalar.db.api.Put;
+import com.scalar.db.api.Insert;
 import com.scalar.db.api.Result;
 import com.scalar.db.api.Scan;
 import com.scalar.db.api.Scan.Ordering;
@@ -33,8 +33,8 @@ public Order(String id, int customerId, long timestamp) {
   public static void put(
       TransactionCrudOperable transaction, String id, int customerId, long timestamp)
       throws CrudException {
-    transaction.put(
-        Put.newBuilder()
+    transaction.insert(
+        Insert.newBuilder()
             .namespace(NAMESPACE)
             .table(TABLE)
             .partitionKey(Key.ofInt(COL_CUSTOMER_ID, customerId))

microservice-transaction-sample/order-service/src/main/java/sample/order/model/Statement.java

@@ -1,6 +1,6 @@
 package sample.order.model;
 
-import com.scalar.db.api.Put;
+import com.scalar.db.api.Insert;
 import com.scalar.db.api.Scan;
 import com.scalar.db.api.TransactionCrudOperable;
 import com.scalar.db.exception.transaction.CrudException;
@@ -28,8 +28,8 @@ public Statement(String orderId, int itemId, int count) {
 
   public static void put(TransactionCrudOperable transaction, String orderId, int itemId, int count)
       throws CrudException {
-    transaction.put(
-        Put.newBuilder()
+    transaction.insert(
+        Insert.newBuilder()
             .namespace(NAMESPACE)
             .table(TABLE)
             .partitionKey(Key.ofText(COL_ORDER_ID, orderId))

microservice-transaction-sample/rpc/build.gradle

@@ -1,7 +1,7 @@
 plugins {
     id 'java'
     id 'java-library-distribution'
-    id 'com.google.protobuf' version '0.9.1'
+    id 'com.google.protobuf' version '0.9.4'
 }
 
 dependencies {
@@ -20,16 +20,40 @@ protobuf {
     generateProtoTasks {
         all()*.plugins { grpc {} }
     }
-    generatedFilesBaseDir = "$projectDir/src"
 }
 
-archivesBaseName = "sample-rpc"
+base {
+    archivesName = "sample-rpc"
+}
+
+// Task copyGeneratedProtoToSrc copies the generated .java files into src directory
+task copyGeneratedProtoToSrc(type: Copy) {
+    description 'Copies generated Protocol Buffer classes to src/main/java/sample/rpc'
+    dependsOn generateProto
+    from "$buildDir/generated/source/proto/main/java/sample/rpc"
+    into "$projectDir/src/main/java/sample/rpc"
+    duplicatesStrategy = DuplicatesStrategy.INCLUDE
+}
+
+// Task deleteBuildMainJava deletes the generated .java files in build directory
+task deleteBuildMainJava(type: Delete) {
+    dependsOn copyGeneratedProtoToSrc
+    delete fileTree(dir: "$buildDir/generated/source/proto/main/java/sample/rpc")
+}
 
 // The processResources task needs to depend on the generateProto task because it uses the output
 // of the the generateProto task
 processResources {
     dependsOn generateProto
 }
 
-sourceCompatibility = 1.8
-targetCompatibility = 1.8
+// Task deleteBuildMainJava needs to depend on deleteBuildMainJava to avoid duplicate class error
+tasks.named("compileJava").configure {
+    dependsOn deleteBuildMainJava
+}
+
+java {
+    toolchain {
+        languageVersion = JavaLanguageVersion.of(8)
+    }
+}

multi-storage-transaction-sample/build.gradle

@@ -16,10 +16,15 @@ dependencies {
 }
 
 application {
-    mainClassName = 'sample.command.SampleCommand'
+    mainClass = 'sample.command.SampleCommand'
 }
 
-archivesBaseName = "sample"
+base {
+    archivesName = "sample"
+}
 
-sourceCompatibility = 1.8
-targetCompatibility = 1.8
+java {
+    toolchain {
+        languageVersion = JavaLanguageVersion.of(8)
+    }
+}

multi-storage-transaction-sample/src/main/java/sample/Sample.java

@@ -3,9 +3,10 @@
 import com.scalar.db.api.DistributedTransaction;
 import com.scalar.db.api.DistributedTransactionManager;
 import com.scalar.db.api.Get;
-import com.scalar.db.api.Put;
+import com.scalar.db.api.Insert;
 import com.scalar.db.api.Result;
 import com.scalar.db.api.Scan;
+import com.scalar.db.api.Update;
 import com.scalar.db.exception.transaction.TransactionException;
 import com.scalar.db.io.Key;
 import com.scalar.db.service.TransactionFactory;
@@ -62,8 +63,8 @@ private void loadCustomerIfNotExists(
                 .partitionKey(Key.ofInt("customer_id", customerId))
                 .build());
     if (!customer.isPresent()) {
-      transaction.put(
-          Put.newBuilder()
+      transaction.insert(
+          Insert.newBuilder()
               .namespace("customer")
               .table("customers")
               .partitionKey(Key.ofInt("customer_id", customerId))
@@ -85,8 +86,8 @@ private void loadItemIfNotExists(
                 .partitionKey(Key.ofInt("item_id", itemId))
                 .build());
     if (!item.isPresent()) {
-      transaction.put(
-          Put.newBuilder()
+      transaction.insert(
+          Insert.newBuilder()
               .namespace("order")
               .table("items")
               .partitionKey(Key.ofInt("item_id", itemId))
@@ -146,9 +147,9 @@ public String placeOrder(int customerId, int[] itemIds, int[] itemCounts)
       // Start a transaction
       transaction = manager.start();
 
-      // Put the order info into the orders table
-      transaction.put(
-          Put.newBuilder()
+      // Insert the order info into the orders table
+      transaction.insert(
+          Insert.newBuilder()
               .namespace("order")
               .table("orders")
               .partitionKey(Key.ofInt("customer_id", customerId))
@@ -161,9 +162,9 @@ public String placeOrder(int customerId, int[] itemIds, int[] itemCounts)
         int itemId = itemIds[i];
         int count = itemCounts[i];
 
-        // Put the order statement into the statements table
-        transaction.put(
-            Put.newBuilder()
+        // Insert the order statement into the statements table
+        transaction.insert(
+            Insert.newBuilder()
                 .namespace("order")
                 .table("statements")
                 .partitionKey(Key.ofText("order_id", orderId))
@@ -206,8 +207,8 @@ public String placeOrder(int customerId, int[] itemIds, int[] itemCounts)
       }
 
       // Update credit_total for the customer
-      transaction.put(
-          Put.newBuilder()
+      transaction.update(
+          Update.newBuilder()
               .namespace("customer")
               .table("customers")
               .partitionKey(Key.ofInt("customer_id", customerId))
@@ -389,8 +390,8 @@ public void repayment(int customerId, int amount) throws TransactionException {
       }
 
       // Reduce credit_total for the customer
-      transaction.put(
-          Put.newBuilder()
+      transaction.update(
+          Update.newBuilder()
               .namespace("customer")
               .table("customers")
               .partitionKey(Key.ofInt("customer_id", customerId))

scalardb-kotlin-sample/build.gradle.kts

@@ -1,7 +1,7 @@
 import org.jetbrains.kotlin.gradle.tasks.KotlinCompile
 
 plugins {
-    kotlin("jvm") version "1.8.21"
+    kotlin("jvm") version "2.0.21"
     application
 }
 
@@ -21,13 +21,8 @@ tasks.test {
     useJUnitPlatform()
 }
 
-tasks.withType<KotlinCompile> {
-    kotlinOptions.jvmTarget = "1.8"
-}
-
-java {
-    sourceCompatibility = JavaVersion.VERSION_1_8
-    targetCompatibility = JavaVersion.VERSION_1_8
+kotlin {
+    jvmToolchain(8)
 }
 
 application {

scalardb-kotlin-sample/src/main/kotlin/sample/ElectronicMoney.kt

@@ -2,7 +2,8 @@ package sample
 
 import com.scalar.db.api.DistributedTransactionManager
 import com.scalar.db.api.Get
-import com.scalar.db.api.Put
+import com.scalar.db.api.Update
+import com.scalar.db.api.Upsert
 import com.scalar.db.exception.transaction.TransactionException
 import com.scalar.db.io.Key
 import com.scalar.db.service.TransactionFactory
@@ -43,13 +44,13 @@ class ElectronicMoney(scalarDBProperties: String) {
             }
 
             // Update the balance
-            val put = Put.newBuilder()
+            val upsert = Upsert.newBuilder()
                 .namespace(NAMESPACE)
                 .table(TABLENAME)
                 .partitionKey(Key.ofText(ID, id))
                 .intValue(BALANCE, balance)
                 .build()
-            tx.put(put)
+            tx.upsert(upsert)
 
             // Commit the transaction (records are automatically recovered in case of failure)
             tx.commit()
@@ -86,20 +87,20 @@ class ElectronicMoney(scalarDBProperties: String) {
             }
 
             // Update the balances
-            val fromPut = Put.newBuilder()
+            val fromUpdate = Update.newBuilder()
                 .namespace(NAMESPACE)
                 .table(TABLENAME)
                 .partitionKey(Key.ofText(ID, fromId))
                 .intValue(BALANCE, newFromBalance)
                 .build()
-            val toPut = Put.newBuilder()
+            val toUpdate = Update.newBuilder()
                 .namespace(NAMESPACE)
                 .table(TABLENAME)
                 .partitionKey(Key.ofText(ID, toId))
                 .intValue(BALANCE, newToBalance)
                 .build()
-            tx.put(fromPut)
-            tx.put(toPut)
+            tx.update(fromUpdate)
+            tx.update(toUpdate)
 
             // Commit the transaction (records are automatically recovered in case of failure)
             tx.commit()