perf: use virtual threads

.github/workflows/integration-emulator.yaml

@@ -12,6 +12,10 @@ env:
 jobs:
   integration-test-emulator:
     runs-on: ubuntu-latest
+    strategy:
+      fail-fast: false
+      matrix:
+        java: [11, 21]
     # Add a PostgreSQL Docker container and the emulator.
     services:
       postgres:
@@ -40,7 +44,7 @@ jobs:
         uses: actions/setup-java@v4
         with:
           distribution: zulu
-          java-version: 17
+          java-version: ${{matrix.java}}
       - run: java -version
       - name: Setup Go
         uses: actions/setup-go@v5
@@ -65,7 +69,7 @@ jobs:
         run: |
           psql -h /pg -U postgres -c "CREATE DATABASE pgadapter"
       - name: Run integration tests
-        run: mvn verify -B -Dclirr.skip=true -DskipUnits=true -DskipITs=false
+        run: mvn clean verify -B -Dclirr.skip=true -DskipUnits=true -DskipITs=false
         env:
           POSTGRES_HOST: /pg
           POSTGRES_PORT: 5432

.github/workflows/integration.yaml

@@ -76,12 +76,6 @@ jobs:
         run: |
           echo "EXCLUDED_INTEGRATION_TESTS=SlowTest" >> $GITHUB_ENV
       - uses: actions/checkout@v4
-      - name: Setup Java
-        uses: actions/setup-java@v4
-        with:
-          distribution: zulu
-          java-version: 17
-      - run: java -version
       - name: Setup Go
         uses: actions/setup-go@v5
         with:
@@ -104,6 +98,20 @@ jobs:
       - name: Create PostgreSQL test database
         run: |
           psql -h /pg -U postgres -c "CREATE DATABASE pgadapter"
+      - name: Setup Java 11
+        uses: actions/setup-java@v4
+        with:
+          distribution: zulu
+          java-version: 11
+      - run: java -version
+      - name: Run unit tests without virtual threads
+        run: mvn test -B
+      - name: Setup Java 21
+        uses: actions/setup-java@v4
+        with:
+          distribution: zulu
+          java-version: 21
+      - run: java -version
       - name: Run unit tests
         run: mvn test -B -Ptest-all
       - name: Auth

.github/workflows/units.yaml

@@ -9,7 +9,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        java: [8, 11, 17]
+        java: [8, 11, 17, 21]
     steps:
       - uses: actions/checkout@v4
       - uses: actions/setup-java@v4
@@ -40,7 +40,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        java: [8, 11, 17]
+        java: [8, 11, 17, 21]
     steps:
       - uses: actions/checkout@v4
       - uses: actions/setup-java@v4
@@ -56,7 +56,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        java: [8, 11, 17]
+        java: [8, 11, 17, 21]
     steps:
       - uses: actions/checkout@v4
       - uses: actions/setup-java@v4

benchmarks/client-comparisons/.gitignore

@@ -0,0 +1 @@
+tpcc-log.log

benchmarks/client-comparisons/README.md

@@ -0,0 +1,65 @@
+# TPC-C Benchmark Application for PGAdapter and Cloud Spanner
+
+This application implements the standard TPC-C benchmark and runs it against PGAdapter and a Cloud
+Spanner database. It is a Java Spring Boot application. See [src/main/resources/application.properties](src/main/resources/application.properties)
+for a full list of configuration options.
+
+## Running
+
+The application automatically starts PGAdapter together with the benchmark application. Supply the
+Cloud Spanner database and your credentials using the below command. The `tpcc.benchmark-threads`
+argument determines the number of threads that will execute test transactions in parallel.
+
+```shell
+mvn spring-boot:run -Dspring-boot.run.arguments="
+   --tpcc.benchmark-threads=8
+   --spanner.project=my-project
+   --spanner.instance=my-instance
+   --spanner.database=my-database
+   --pgadapter.credentials=/path/to/credentials.json
+   "
+```
+
+
+Load data:
+
+```shell
+mvn spring-boot:run -Dspring-boot.run.arguments="
+  --tpcc.benchmark-duration=PT600s
+  --tpcc.warehouses=10
+  --tpcc.benchmark-threads=1
+  --tpcc.load-data=true
+  --tpcc.truncate-before-load=false
+  --tpcc.run-benchmark=false
+  --tpcc.use-read-only-transactions=false
+  --tpcc.lock-scanned-ranges=false
+  --spanner.project=appdev-soda-spanner-staging
+  --spanner.instance=knut-test-ycsb
+  --spanner.database=tpcc2
+  --pgadapter.credentials=/home/loite/appdev-soda-spanner-staging.json
+  --pgadapter.disable-internal-retries=false
+  "
+```
+
+
+Run benchmark:
+
+```shell
+mvn spring-boot:run -Dspring-boot.run.arguments="
+  --tpcc.benchmark-duration=PT600s
+  --tpcc.warehouses=10
+  --tpcc.benchmark-threads=1
+  --tpcc.load-data=false
+  --tpcc.truncate-before-load=false
+  --tpcc.run-benchmark=true
+  --tpcc.use-read-only-transactions=true
+  --tpcc.lock-scanned-ranges=false
+  --spanner.project=appdev-soda-spanner-staging
+  --spanner.instance=knut-test-ycsb
+  --spanner.database=tpcc2
+  --pgadapter.enable-open-telemetry=true
+  --pgadatper.open-telemetry-sample-ratio=1.0
+  --pgadapter.credentials=/home/loite/appdev-soda-spanner-staging.json
+  --pgadapter.disable-internal-retries=true
+  "
+```

benchmarks/client-comparisons/pom.xml

@@ -0,0 +1,85 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+  <parent>
+    <groupId>org.springframework.boot</groupId>
+    <artifactId>spring-boot-starter-parent</artifactId>
+    <version>3.1.5</version>
+    <relativePath/> <!-- lookup parent from repository -->
+  </parent>
+  <groupId>com.google.cloud.spanner</groupId>
+  <artifactId>pgadapter-client-benchmarks</artifactId>
+  <version>0.0.1-SNAPSHOT</version>
+  <name>PGAdapter Client Benchmarks</name>
+  <description>Various Benchmarks for PGAdapter and other Cloud Spanner clients</description>
+  <properties>
+    <java.version>17</java.version>
+  </properties>
+  <dependencies>
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter</artifactId>
+    </dependency>
+    <!-- Add the PostgreSQL JDBC driver -->
+    <dependency>
+      <groupId>org.postgresql</groupId>
+      <artifactId>postgresql</artifactId>
+      <version>42.7.1</version>
+    </dependency>
+    <!-- Add the Cloud Spanner JDBC driver -->
+    <dependency>
+      <groupId>com.google.cloud</groupId>
+      <artifactId>google-cloud-spanner-jdbc</artifactId>
+      <version>2.15.0</version>
+    </dependency>
+    <!-- Add PGAdapter as a dependency, so we can start it in-process -->
+    <dependency>
+      <groupId>com.google.cloud</groupId>
+      <artifactId>google-cloud-spanner</artifactId>
+      <version>6.56.1-SNAPSHOT</version>
+    </dependency>
+    <dependency>
+      <groupId>com.google.cloud</groupId>
+      <artifactId>google-cloud-spanner-pgadapter</artifactId>
+      <version>0.27.2-SNAPSHOT</version>
+    </dependency>
+    <dependency>
+      <groupId>io.opentelemetry</groupId>
+      <artifactId>opentelemetry-sdk-extension-autoconfigure-spi</artifactId>
+      <version>1.33.0</version>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.commons</groupId>
+      <artifactId>commons-lang3</artifactId>
+      <version>3.14.0</version>
+    </dependency>
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-configuration-processor</artifactId>
+      <optional>true</optional>
+    </dependency>
+  </dependencies>
+
+  <build>
+    <plugins>
+      <plugin>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-maven-plugin</artifactId>
+      </plugin>
+      <plugin>
+        <groupId>com.spotify.fmt</groupId>
+        <artifactId>fmt-maven-plugin</artifactId>
+        <version>2.21.1</version>
+        <executions>
+          <execution>
+            <goals>
+              <goal>format</goal>
+            </goals>
+          </execution>
+        </executions>
+      </plugin>
+    </plugins>
+  </build>
+
+</project>