feat(bigtable): add view_parameters support to BoundStatement

java-bigtable/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/sql/BoundStatement.java

@@ -48,20 +48,29 @@
  * paramName, Type value) for the appropriate type. For example:
  *
  * <pre>{@code
- * BoundStatementt boundStatement = preparedStatement.bind()
+ * BoundStatement boundStatement = preparedStatement.bind()
  *     .setBytesParam("qualifier", ByteString.copyFromUtf8("test"))
  *     .setBytesParam("key", ByteString.copyFromUtf8("testKey"))
  *     .build();
  * }</pre>
+ *
+ * <p>View parameters can also be specified on the statement using {@link
+ * Builder#setStringViewParameter(String, String)} or {@link Builder#setStringViewParameters(Map)}.
+ * This map provides the runtime values returned by the VIEW_PARAMETERS() function calls.
  */
 public class BoundStatement {
 
   private final PreparedStatementImpl preparedStatement;
   private final Map<String, Value> params;
+  private final Map<String, Value> viewParameters;
 
-  private BoundStatement(PreparedStatementImpl preparedStatement, Map<String, Value> params) {
+  private BoundStatement(
+      PreparedStatementImpl preparedStatement,
+      Map<String, Value> params,
+      Map<String, Value> viewParameters) {
     this.preparedStatement = preparedStatement;
     this.params = params;
+    this.viewParameters = viewParameters;
   }
 
   /**
@@ -78,6 +87,7 @@ public static class Builder {
     private final PreparedStatementImpl preparedStatement;
     private final Map<String, SqlType<?>> paramTypes;
     private final Map<String, Value> params;
+    private final Map<String, Value> viewParameters;
 
     /**
      * Creates a builder from a {@link PreparedStatement}
@@ -90,6 +100,7 @@ public Builder(PreparedStatementImpl preparedStatement, Map<String, SqlType<?>>
       this.preparedStatement = preparedStatement;
       this.paramTypes = paramTypes;
       this.params = new HashMap<>();
+      this.viewParameters = new HashMap<>();
     }
 
     /** Builds a {@link BoundStatement} from the builder */
@@ -101,7 +112,29 @@ public BoundStatement build() {
               "Attempting to build BoundStatement without binding parameter: " + paramName);
         }
       }
-      return new BoundStatement(preparedStatement, ImmutableMap.copyOf(params));
+      return new BoundStatement(
+          preparedStatement, ImmutableMap.copyOf(params), ImmutableMap.copyOf(viewParameters));
+    }
+
+    /**
+     * Sets a view parameter with the name {@code paramName} and the String typed value {@code
+     * value}. This map provides the runtime values returned by the VIEW_PARAMETERS() function
+     * calls.
+     */
+    public Builder setStringViewParameter(String paramName, @Nullable String value) {
+      Preconditions.checkNotNull(paramName, "paramName cannot be null");
+      viewParameters.put(paramName, stringParamOf(value));
+      return this;
+    }
+
+    /**
+     * Sets String typed view parameters from a map. This map provides the runtime values returned
+     * by the VIEW_PARAMETERS() function calls.
+     */
+    public Builder setStringViewParameters(Map<String, String> viewParameters) {
+      Preconditions.checkNotNull(viewParameters, "viewParameters cannot be null");
+      viewParameters.forEach(this::setStringViewParameter);
+      return this;
     }
 
     /**
@@ -372,7 +405,8 @@ public ExecuteQueryRequest toProto(
                     requestContext.getProjectId(), requestContext.getInstanceId()))
             .setAppProfileId(requestContext.getAppProfileId())
             .setPreparedQuery(preparedQuery)
-            .putAllParams(params);
+            .putAllParams(params)
+            .putAllViewParameters(viewParameters);
 
     if (resumeToken != null) {
       requestBuilder.setResumeToken(resumeToken);

java-bigtable/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/models/sql/BoundStatementTest.java

@@ -869,4 +869,73 @@ public void builderValidatesAllParamsAreSet() {
     assertThat(e.getMessage())
         .contains("Attempting to build BoundStatement without binding parameter: bytesParam");
   }
+
+  @Test
+  public void statementWithStringViewParameters() {
+    Value stringVal = Value.newBuilder().setType(stringType()).setStringValue("alice").build();
+    Value locationVal = Value.newBuilder().setType(stringType()).setStringValue("us-east1").build();
+
+    BoundStatement s =
+        boundStatementBuilder()
+            .setStringViewParameter("user_id", "alice")
+            .setStringViewParameter("location", "us-east1")
+            .build();
+
+    assertThat(s.toProto(EXPECTED_PREPARED_QUERY, REQUEST_CONTEXT, NO_RESUME_TOKEN))
+        .isEqualTo(
+            ExecuteQueryRequest.newBuilder()
+                .setPreparedQuery(EXPECTED_PREPARED_QUERY)
+                .setInstanceName(EXPECTED_INSTANCE_NAME)
+                .setAppProfileId(EXPECTED_APP_PROFILE)
+                .putViewParameters("user_id", stringVal)
+                .putViewParameters("location", locationVal)
+                .build());
+  }
+
+  @Test
+  public void statementWithStringViewParametersMap() {
+    Value stringVal = Value.newBuilder().setType(stringType()).setStringValue("alice").build();
+    Value locationVal = Value.newBuilder().setType(stringType()).setStringValue("us-east1").build();
+
+    HashMap<String, String> viewParams = new HashMap<>();
+    viewParams.put("user_id", "alice");
+    viewParams.put("location", "us-east1");
+
+    BoundStatement s = boundStatementBuilder().setStringViewParameters(viewParams).build();
+
+    assertThat(s.toProto(EXPECTED_PREPARED_QUERY, REQUEST_CONTEXT, NO_RESUME_TOKEN))
+        .isEqualTo(
+            ExecuteQueryRequest.newBuilder()
+                .setPreparedQuery(EXPECTED_PREPARED_QUERY)
+                .setInstanceName(EXPECTED_INSTANCE_NAME)
+                .setAppProfileId(EXPECTED_APP_PROFILE)
+                .putViewParameters("user_id", stringVal)
+                .putViewParameters("location", locationVal)
+                .build());
+  }
+
+  @Test
+  public void statementWithNullStringViewParameter() {
+    Value nullStringVal = Value.newBuilder().setType(stringType()).build();
+
+    BoundStatement s =
+        boundStatementBuilder().setStringViewParameter("user_id", (String) null).build();
+
+    assertThat(s.toProto(EXPECTED_PREPARED_QUERY, REQUEST_CONTEXT, NO_RESUME_TOKEN))
+        .isEqualTo(
+            ExecuteQueryRequest.newBuilder()
+                .setPreparedQuery(EXPECTED_PREPARED_QUERY)
+                .setInstanceName(EXPECTED_INSTANCE_NAME)
+                .setAppProfileId(EXPECTED_APP_PROFILE)
+                .putViewParameters("user_id", nullStringVal)
+                .build());
+  }
+
+  @Test
+  public void setStringViewParametersNullChecks() {
+    BoundStatement.Builder builder = boundStatementBuilder();
+
+    assertThrows(NullPointerException.class, () -> builder.setStringViewParameter(null, "alice"));
+    assertThrows(NullPointerException.class, () -> builder.setStringViewParameters(null));
+  }
 }

java-bigtable/test-proxy/pom.xml

@@ -54,6 +54,21 @@
       <groupId>com.google.protobuf</groupId>
       <artifactId>protobuf-java</artifactId>
     </dependency>
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>com.google.truth</groupId>
+      <artifactId>truth</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.mockito</groupId>
+      <artifactId>mockito-core</artifactId>
+      <scope>test</scope>
+    </dependency>
   </dependencies>
 
   <build>

java-bigtable/test-proxy/src/main/java/com/google/cloud/bigtable/testproxy/BoundStatementDeserializer.java

@@ -29,7 +29,7 @@
 
 public class BoundStatementDeserializer {
 
-  static BoundStatement toBoundStatement(
+  public static BoundStatement toBoundStatement(
       PreparedStatement preparedStatement, ExecuteQueryRequest request) {
     BoundStatement.Builder boundStatementBuilder = preparedStatement.bind();
     for (Map.Entry<String, Value> paramEntry : request.getRequest().getParamsMap().entrySet()) {
@@ -128,6 +128,23 @@ static BoundStatement toBoundStatement(
           throw new IllegalArgumentException("Unexpected query param type in param: " + value);
       }
     }
+    for (Map.Entry<String, Value> entry : request.getRequest().getViewParametersMap().entrySet()) {
+      String name = entry.getKey();
+      Value value = entry.getValue();
+      switch (value.getType().getKindCase()) {
+        case STRING_TYPE:
+          if (value.getKindCase().equals(KindCase.KIND_NOT_SET)) {
+            boundStatementBuilder.setStringViewParameter(name, null);
+          } else if (value.getKindCase().equals(KindCase.STRING_VALUE)) {
+            boundStatementBuilder.setStringViewParameter(name, value.getStringValue());
+          } else {
+            throw new IllegalArgumentException("Malformed string value: " + value);
+          }
+          break;
+        default:
+          throw new IllegalArgumentException("Unexpected view parameter type in param: " + value);
+      }
+    }
     return boundStatementBuilder.build();
   }
 

java-bigtable/test-proxy/src/test/java/com/google/cloud/bigtable/testproxy/BoundStatementDeserializerTest.java

@@ -0,0 +1,125 @@
+/*
+ * Copyright 2026 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.google.cloud.bigtable.testproxy;
+
+import static com.google.common.truth.Truth.assertThat;
+import static org.junit.Assert.assertThrows;
+import static org.mockito.ArgumentMatchers.anyString;
+import static org.mockito.ArgumentMatchers.nullable;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import com.google.bigtable.v2.ExecuteQueryRequest;
+import com.google.bigtable.v2.Type;
+import com.google.bigtable.v2.Value;
+import com.google.cloud.bigtable.data.v2.models.sql.BoundStatement;
+import com.google.cloud.bigtable.data.v2.models.sql.PreparedStatement;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.JUnit4;
+
+@RunWith(JUnit4.class)
+public class BoundStatementDeserializerTest {
+
+  @Test
+  public void testDeserializeStringViewParameter() {
+    PreparedStatement preparedStatement = mock(PreparedStatement.class);
+    BoundStatement.Builder builder = mock(BoundStatement.Builder.class);
+    when(preparedStatement.bind()).thenReturn(builder);
+    when(builder.setStringViewParameter(anyString(), nullable(String.class))).thenReturn(builder);
+
+    Value stringVal =
+        Value.newBuilder()
+            .setType(Type.newBuilder().setStringType(Type.String.getDefaultInstance()))
+            .setStringValue("alice")
+            .build();
+    com.google.cloud.bigtable.testproxy.ExecuteQueryRequest request =
+        com.google.cloud.bigtable.testproxy.ExecuteQueryRequest.newBuilder()
+            .setRequest(ExecuteQueryRequest.newBuilder().putViewParameters("user_id", stringVal))
+            .build();
+
+    BoundStatementDeserializer.toBoundStatement(preparedStatement, request);
+    verify(builder).setStringViewParameter("user_id", "alice");
+  }
+
+  @Test
+  public void testDeserializeNullStringViewParameter() {
+    PreparedStatement preparedStatement = mock(PreparedStatement.class);
+    BoundStatement.Builder builder = mock(BoundStatement.Builder.class);
+    when(preparedStatement.bind()).thenReturn(builder);
+    when(builder.setStringViewParameter(anyString(), nullable(String.class))).thenReturn(builder);
+
+    Value nullStringVal =
+        Value.newBuilder()
+            .setType(Type.newBuilder().setStringType(Type.String.getDefaultInstance()))
+            .build();
+    com.google.cloud.bigtable.testproxy.ExecuteQueryRequest request =
+        com.google.cloud.bigtable.testproxy.ExecuteQueryRequest.newBuilder()
+            .setRequest(
+                ExecuteQueryRequest.newBuilder().putViewParameters("user_id", nullStringVal))
+            .build();
+
+    BoundStatementDeserializer.toBoundStatement(preparedStatement, request);
+    verify(builder).setStringViewParameter("user_id", null);
+  }
+
+  @Test
+  public void testDeserializeInvalidTypeViewParameterThrows() {
+    PreparedStatement preparedStatement = mock(PreparedStatement.class);
+    BoundStatement.Builder builder = mock(BoundStatement.Builder.class);
+    when(preparedStatement.bind()).thenReturn(builder);
+
+    Value intVal =
+        Value.newBuilder()
+            .setType(Type.newBuilder().setInt64Type(Type.Int64.getDefaultInstance()))
+            .setIntValue(123)
+            .build();
+    com.google.cloud.bigtable.testproxy.ExecuteQueryRequest request =
+        com.google.cloud.bigtable.testproxy.ExecuteQueryRequest.newBuilder()
+            .setRequest(ExecuteQueryRequest.newBuilder().putViewParameters("user_id", intVal))
+            .build();
+
+    IllegalArgumentException e =
+        assertThrows(
+            IllegalArgumentException.class,
+            () -> BoundStatementDeserializer.toBoundStatement(preparedStatement, request));
+    assertThat(e.getMessage()).contains("Unexpected view parameter type in param");
+  }
+
+  @Test
+  public void testDeserializeMalformedStringViewParameterThrows() {
+    PreparedStatement preparedStatement = mock(PreparedStatement.class);
+    BoundStatement.Builder builder = mock(BoundStatement.Builder.class);
+    when(preparedStatement.bind()).thenReturn(builder);
+
+    Value malformedVal =
+        Value.newBuilder()
+            .setType(Type.newBuilder().setStringType(Type.String.getDefaultInstance()))
+            .setIntValue(123)
+            .build();
+    com.google.cloud.bigtable.testproxy.ExecuteQueryRequest request =
+        com.google.cloud.bigtable.testproxy.ExecuteQueryRequest.newBuilder()
+            .setRequest(ExecuteQueryRequest.newBuilder().putViewParameters("user_id", malformedVal))
+            .build();
+
+    IllegalArgumentException e =
+        assertThrows(
+            IllegalArgumentException.class,
+            () -> BoundStatementDeserializer.toBoundStatement(preparedStatement, request));
+    assertThat(e.getMessage()).contains("Malformed string value");
+  }
+}