geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dschnei...@apache.org
Subject [geode] 01/01: removed value-contains-primary-key from jdbc-mapping
Date Fri, 02 Nov 2018 00:05:10 GMT
This is an automated email from the ASF dual-hosted git repository.

dschneider pushed a commit to branch feature/GEODE-5969
in repository https://gitbox.apache.org/repos/asf/geode.git

commit 5ba56739e73ede5fcd5175270e3c2f31a42c96e7
Author: Darrel Schneider <dschneider@pivotal.io>
AuthorDate: Thu Nov 1 17:04:03 2018 -0700

    removed value-contains-primary-key from jdbc-mapping
---
 .../geode/connectors/jdbc/JdbcDistributedTest.java | 18 ++---
 .../jdbc/internal/TestConfigService.java           |  2 +-
 .../internal/cli/AlterMappingCommandDUnitTest.java |  3 -
 .../cli/CreateMappingCommandDUnitTest.java         | 46 ------------
 .../cli/DescribeMappingCommandDUnitTest.java       |  6 +-
 .../cli/DestroyMappingCommandDunitTest.java        |  2 -
 .../cli/JdbcClusterConfigDistributedTest.java      |  3 +-
 .../internal/cli/ListMappingCommandDUnitTest.java  |  4 +-
 .../cli/AlterMappingCommandIntegrationTest.java    |  4 +-
 .../cli/CreateMappingCommandIntegrationTest.java   | 12 +--
 .../cli/DestroyMappingCommandIntegrationTest.java  |  2 +-
 .../jdbc/internal/SqlToPdxInstanceCreator.java     |  9 +--
 .../jdbc/internal/cli/AlterMappingCommand.java     |  2 +-
 .../jdbc/internal/cli/AlterMappingFunction.java    |  4 +-
 .../jdbc/internal/cli/CreateMappingCommand.java    |  8 +-
 .../jdbc/internal/cli/DescribeMappingCommand.java  |  2 -
 .../jdbc/internal/configuration/RegionMapping.java | 24 +-----
 .../connectors/jdbc/internal/xml/ElementType.java  |  2 -
 .../xml/JdbcConnectorServiceXmlParser.java         |  1 -
 .../geode.apache.org/schema/jdbc/jdbc-1.0.xsd      |  1 -
 .../jdbc/internal/RegionMappingTest.java           | 85 ++++++++++------------
 .../jdbc/internal/SqlToPdxInstanceCreatorTest.java | 25 +------
 .../internal/cli/AlterMappingFunctionTest.java     | 30 +++-----
 .../internal/cli/CreateMappingFunctionTest.java    |  2 +-
 .../internal/cli/DescribeMappingCommandTest.java   |  4 +-
 .../jdbc/internal/cli/ListMappingCommandTest.java  |  4 +-
 .../jdbc/internal/xml/ElementTypeTest.java         |  3 -
 27 files changed, 81 insertions(+), 227 deletions(-)

diff --git a/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/JdbcDistributedTest.java b/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/JdbcDistributedTest.java
index eee9dda..b4c9318 100644
--- a/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/JdbcDistributedTest.java
+++ b/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/JdbcDistributedTest.java
@@ -474,7 +474,7 @@ public abstract class JdbcDistributedTest implements Serializable {
     createTable();
     createRegionUsingGfsh(true, false, true);
     createJdbcConnection();
-    createMapping(REGION_NAME, CONNECTION_NAME, Employee.class.getName(), false);
+    createMapping(REGION_NAME, CONNECTION_NAME, Employee.class.getName());
     server.invoke(() -> {
       String key = "id1";
       Employee value = new Employee("Emp1", 55);
@@ -496,7 +496,7 @@ public abstract class JdbcDistributedTest implements Serializable {
 
     createRegionUsingGfsh(true, false, true);
     createJdbcConnection();
-    createMapping(REGION_NAME, CONNECTION_NAME, ClassWithSupportedPdxFields.class.getName(), false);
+    createMapping(REGION_NAME, CONNECTION_NAME, ClassWithSupportedPdxFields.class.getName());
     client.invoke(() -> {
       String key = "id1";
       ClassWithSupportedPdxFields value = new ClassWithSupportedPdxFields(true, (byte) 1, (short) 2,
@@ -519,7 +519,7 @@ public abstract class JdbcDistributedTest implements Serializable {
 
     createRegionUsingGfsh(true, false, true);
     createJdbcConnection();
-    createMapping(REGION_NAME, CONNECTION_NAME, ClassWithSupportedPdxFields.class.getName(), false);
+    createMapping(REGION_NAME, CONNECTION_NAME, ClassWithSupportedPdxFields.class.getName());
     client.invoke(() -> {
       String key = "id1";
       ClassWithSupportedPdxFields value = new ClassWithSupportedPdxFields();
@@ -540,7 +540,7 @@ public abstract class JdbcDistributedTest implements Serializable {
     createClientRegion(client);
     createRegionUsingGfsh(true, false, true);
     createJdbcConnection();
-    createMapping(REGION_NAME, CONNECTION_NAME, ClassWithSupportedPdxFields.class.getName(), false);
+    createMapping(REGION_NAME, CONNECTION_NAME, ClassWithSupportedPdxFields.class.getName());
     String key = "id1";
     ClassWithSupportedPdxFields value = new ClassWithSupportedPdxFields(true, (byte) 1, (short) 2,
         3, 4, 5.5f, 6.0, "BigEmp", new Date(0), "BigEmpObject", new byte[] {1, 2}, 'c');
@@ -568,7 +568,7 @@ public abstract class JdbcDistributedTest implements Serializable {
     createClientRegion(client);
     createRegionUsingGfsh(true, false, true);
     createJdbcConnection();
-    createMapping(REGION_NAME, CONNECTION_NAME, ClassWithSupportedPdxFields.class.getName(), false);
+    createMapping(REGION_NAME, CONNECTION_NAME, ClassWithSupportedPdxFields.class.getName());
     String key = "id1";
     ClassWithSupportedPdxFields value = new ClassWithSupportedPdxFields();
 
@@ -640,14 +640,8 @@ public abstract class JdbcDistributedTest implements Serializable {
   }
 
   private void createMapping(String regionName, String connectionName, String pdxClassName) {
-    createMapping(regionName, connectionName, pdxClassName, true);
-  }
-
-  private void createMapping(String regionName, String connectionName, String pdxClassName,
-      boolean valueContainsPrimaryKey) {
     final String commandStr = "create jdbc-mapping --region=" + regionName + " --connection="
-        + connectionName + (valueContainsPrimaryKey ? " --value-contains-primary-key" : "")
-        + (pdxClassName != null ? " --pdx-class-name=" + pdxClassName : "");
+        + connectionName + (pdxClassName != null ? " --pdx-class-name=" + pdxClassName : "");
     gfsh.executeAndAssertThat(commandStr).statusIsSuccess();
   }
 
diff --git a/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/internal/TestConfigService.java b/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/internal/TestConfigService.java
index 6cc1d16..714b3dd 100644
--- a/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/internal/TestConfigService.java
+++ b/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/internal/TestConfigService.java
@@ -53,6 +53,6 @@ public class TestConfigService {
   private static RegionMapping createRegionMapping(String pdxClassName,
       boolean primaryKeyInValue) {
     return new RegionMapping(REGION_NAME, pdxClassName, REGION_TABLE_NAME,
-        CONNECTION_CONFIG_NAME, primaryKeyInValue);
+        CONNECTION_CONFIG_NAME);
   }
 }
diff --git a/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingCommandDUnitTest.java b/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingCommandDUnitTest.java
index f93dc9d..0cdd2fb 100644
--- a/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingCommandDUnitTest.java
+++ b/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingCommandDUnitTest.java
@@ -27,7 +27,6 @@ import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand
 import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__PDX_CLASS_NAME;
 import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__REGION_NAME;
 import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__TABLE_NAME;
-import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__VALUE_CONTAINS_PRIMARY_KEY;
 import static org.assertj.core.api.Assertions.assertThat;
 
 import java.util.List;
@@ -77,7 +76,6 @@ public class AlterMappingCommandDUnitTest {
     csb.addOption(CREATE_MAPPING__CONNECTION_NAME, "connection");
     csb.addOption(CREATE_MAPPING__TABLE_NAME, "myTable");
     csb.addOption(CREATE_MAPPING__PDX_CLASS_NAME, "myPdxClass");
-    csb.addOption(CREATE_MAPPING__VALUE_CONTAINS_PRIMARY_KEY, "true");
     csb.addOption(CREATE_MAPPING__FIELD_MAPPING, "field1:column1,field2:column2");
 
     gfsh.executeAndAssertThat(csb.toString()).statusIsSuccess();
@@ -108,7 +106,6 @@ public class AlterMappingCommandDUnitTest {
       assertThat(mapping.getConnectionConfigName()).isEqualTo("newConnection");
       assertThat(mapping.getTableName()).isEqualTo("newTable");
       assertThat(mapping.getPdxClassName()).isEqualTo("newPdxClass");
-      assertThat(mapping.isPrimaryKeyInValue()).isEqualTo(false);
       List<RegionMapping.FieldMapping> fieldMappings = mapping.getFieldMapping();
       assertThat(fieldMappings).hasSize(2);
       assertThat(fieldMappings.get(0).getFieldName()).isEqualTo("field3");
diff --git a/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommandDUnitTest.java b/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommandDUnitTest.java
index 12cbf7f..4965aa2 100644
--- a/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommandDUnitTest.java
+++ b/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommandDUnitTest.java
@@ -20,7 +20,6 @@ import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand
 import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__PDX_CLASS_NAME;
 import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__REGION_NAME;
 import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__TABLE_NAME;
-import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__VALUE_CONTAINS_PRIMARY_KEY;
 import static org.assertj.core.api.Assertions.assertThat;
 
 import java.util.List;
@@ -29,8 +28,6 @@ import org.junit.Before;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.experimental.categories.Category;
-import org.w3c.dom.Element;
-import org.w3c.dom.NodeList;
 
 import org.apache.geode.connectors.jdbc.internal.JdbcConnectorService;
 import org.apache.geode.connectors.jdbc.internal.configuration.RegionMapping;
@@ -79,7 +76,6 @@ public class CreateMappingCommandDUnitTest {
     csb.addOption(CREATE_MAPPING__CONNECTION_NAME, "connection");
     csb.addOption(CREATE_MAPPING__TABLE_NAME, "myTable");
     csb.addOption(CREATE_MAPPING__PDX_CLASS_NAME, "myPdxClass");
-    csb.addOption(CREATE_MAPPING__VALUE_CONTAINS_PRIMARY_KEY, "true");
     csb.addOption(CREATE_MAPPING__FIELD_MAPPING, "field1:column1,field2:column2");
 
     gfsh.executeAndAssertThat(csb.toString()).statusIsSuccess();
@@ -97,47 +93,6 @@ public class CreateMappingCommandDUnitTest {
       assertThat(mapping.getConnectionConfigName()).isEqualTo("connection");
       assertThat(mapping.getTableName()).isEqualTo("myTable");
       assertThat(mapping.getPdxClassName()).isEqualTo("myPdxClass");
-      assertThat(mapping.isPrimaryKeyInValue()).isEqualTo(true);
-      List<RegionMapping.FieldMapping> fieldMappings = mapping.getFieldMapping();
-      assertThat(fieldMappings).hasSize(2);
-      assertThat(fieldMappings.get(0).getFieldName()).isEqualTo("field1");
-      assertThat(fieldMappings.get(0).getColumnName()).isEqualTo("column1");
-      assertThat(fieldMappings.get(1).getFieldName()).isEqualTo("field2");
-      assertThat(fieldMappings.get(1).getColumnName()).isEqualTo("column2");
-    });
-  }
-
-  @Test
-  public void validateThatPrimaryKeyInValueDefaultsToFalse() {
-    CommandStringBuilder csb = new CommandStringBuilder(CREATE_MAPPING);
-    csb.addOption(CREATE_MAPPING__REGION_NAME, REGION_NAME);
-    csb.addOption(CREATE_MAPPING__CONNECTION_NAME, "connection");
-    csb.addOption(CREATE_MAPPING__TABLE_NAME, "myTable");
-    csb.addOption(CREATE_MAPPING__PDX_CLASS_NAME, "myPdxClass");
-    csb.addOption(CREATE_MAPPING__FIELD_MAPPING, "field1:column1,field2:column2");
-
-    gfsh.executeAndAssertThat(csb.toString()).statusIsSuccess();
-
-    locator.invoke(() -> {
-      String xml = InternalLocator.getLocator().getConfigurationPersistenceService()
-          .getConfiguration("cluster").getCacheXmlContent();
-      assertThat(xml).isNotNull().contains("primary-key-in-value=\"false\"");
-      Element element = InternalLocator.getLocator().getConfigurationPersistenceService()
-          .getXmlElement(null, "region", "name", REGION_NAME);
-      assertThat(element).isNotNull();
-      NodeList list = element.getElementsByTagName("jdbc:mapping");
-      assertThat(list).isNotNull();
-      assertThat(list.getLength()).isEqualTo(1);
-    });
-
-    server.invoke(() -> {
-      InternalCache cache = ClusterStartupRule.getCache();
-      RegionMapping mapping =
-          cache.getService(JdbcConnectorService.class).getMappingForRegion(REGION_NAME);
-      assertThat(mapping.getConnectionConfigName()).isEqualTo("connection");
-      assertThat(mapping.getTableName()).isEqualTo("myTable");
-      assertThat(mapping.getPdxClassName()).isEqualTo("myPdxClass");
-      assertThat(mapping.isPrimaryKeyInValue()).isEqualTo(false);
       List<RegionMapping.FieldMapping> fieldMappings = mapping.getFieldMapping();
       assertThat(fieldMappings).hasSize(2);
       assertThat(fieldMappings.get(0).getFieldName()).isEqualTo("field1");
@@ -154,7 +109,6 @@ public class CreateMappingCommandDUnitTest {
     csb.addOption(CREATE_MAPPING__CONNECTION_NAME, "connection");
     csb.addOption(CREATE_MAPPING__TABLE_NAME, "myTable");
     csb.addOption(CREATE_MAPPING__PDX_CLASS_NAME, "myPdxClass");
-    csb.addOption(CREATE_MAPPING__VALUE_CONTAINS_PRIMARY_KEY, "false");
 
     gfsh.executeAndAssertThat(csb.toString()).statusIsSuccess();
 
diff --git a/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingCommandDUnitTest.java b/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingCommandDUnitTest.java
index b11e0b4..67111c8 100644
--- a/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingCommandDUnitTest.java
+++ b/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingCommandDUnitTest.java
@@ -20,7 +20,6 @@ import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand
 import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__PDX_CLASS_NAME;
 import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__REGION_NAME;
 import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__TABLE_NAME;
-import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__VALUE_CONTAINS_PRIMARY_KEY;
 import static org.apache.geode.connectors.jdbc.internal.cli.DescribeMappingCommand.DESCRIBE_MAPPING;
 import static org.apache.geode.connectors.jdbc.internal.cli.DescribeMappingCommand.DESCRIBE_MAPPING__REGION_NAME;
 import static org.assertj.core.api.Assertions.assertThat;
@@ -75,7 +74,6 @@ public class DescribeMappingCommandDUnitTest implements Serializable {
     csb.addOption(CREATE_MAPPING__CONNECTION_NAME, "connection");
     csb.addOption(CREATE_MAPPING__TABLE_NAME, "testTable");
     csb.addOption(CREATE_MAPPING__PDX_CLASS_NAME, "myPdxClass");
-    csb.addOption(CREATE_MAPPING__VALUE_CONTAINS_PRIMARY_KEY, "true");
     csb.addOption(CREATE_MAPPING__FIELD_MAPPING, "field1:column1,field2:column2");
 
     gfsh.executeAndAssertThat(csb.toString()).statusIsSuccess();
@@ -90,7 +88,6 @@ public class DescribeMappingCommandDUnitTest implements Serializable {
     commandResultAssert.containsKeyValuePair(CREATE_MAPPING__CONNECTION_NAME, "connection");
     commandResultAssert.containsKeyValuePair(CREATE_MAPPING__TABLE_NAME, "testTable");
     commandResultAssert.containsKeyValuePair(CREATE_MAPPING__PDX_CLASS_NAME, "myPdxClass");
-    commandResultAssert.containsKeyValuePair(CREATE_MAPPING__VALUE_CONTAINS_PRIMARY_KEY, "true");
     commandResultAssert.containsOutput("field1");
     commandResultAssert.containsOutput("field2");
     commandResultAssert.containsOutput("column1");
@@ -135,14 +132,13 @@ public class DescribeMappingCommandDUnitTest implements Serializable {
     commandResultAssert.containsKeyValuePair(CREATE_MAPPING__CONNECTION_NAME, "connection");
     commandResultAssert.containsKeyValuePair(CREATE_MAPPING__TABLE_NAME, "testTable");
     commandResultAssert.containsKeyValuePair(CREATE_MAPPING__PDX_CLASS_NAME, "myPdxClass");
-    commandResultAssert.containsKeyValuePair(CREATE_MAPPING__VALUE_CONTAINS_PRIMARY_KEY, "true");
   }
 
   private void createRegionMapping() throws RegionMappingExistsException {
     InternalCache cache = ClusterStartupRule.getCache();
     JdbcConnectorService service = cache.getService(JdbcConnectorService.class);
     service.createRegionMapping(new RegionMapping(REGION_NAME, "myPdxClass",
-        "testTable", "connection", true));
+        "testTable", "connection"));
     assertThat(service.getMappingForRegion(REGION_NAME)).isNotNull();
   }
 }
diff --git a/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyMappingCommandDunitTest.java b/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyMappingCommandDunitTest.java
index 9697532..a637a95 100644
--- a/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyMappingCommandDunitTest.java
+++ b/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyMappingCommandDunitTest.java
@@ -20,7 +20,6 @@ import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand
 import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__PDX_CLASS_NAME;
 import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__REGION_NAME;
 import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__TABLE_NAME;
-import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__VALUE_CONTAINS_PRIMARY_KEY;
 import static org.apache.geode.connectors.jdbc.internal.cli.DestroyMappingCommand.DESTROY_MAPPING;
 import static org.apache.geode.connectors.jdbc.internal.cli.DestroyMappingCommand.DESTROY_MAPPING__REGION_NAME;
 import static org.assertj.core.api.Assertions.assertThat;
@@ -76,7 +75,6 @@ public class DestroyMappingCommandDunitTest implements Serializable {
     csb.addOption(CREATE_MAPPING__CONNECTION_NAME, "connection");
     csb.addOption(CREATE_MAPPING__TABLE_NAME, "myTable");
     csb.addOption(CREATE_MAPPING__PDX_CLASS_NAME, "myPdxClass");
-    csb.addOption(CREATE_MAPPING__VALUE_CONTAINS_PRIMARY_KEY, "true");
     csb.addOption(CREATE_MAPPING__FIELD_MAPPING, "field1:column1,field2:column2");
 
     gfsh.executeAndAssertThat(csb.toString()).statusIsSuccess();
diff --git a/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/JdbcClusterConfigDistributedTest.java b/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/JdbcClusterConfigDistributedTest.java
index bef158e..239a8b4 100644
--- a/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/JdbcClusterConfigDistributedTest.java
+++ b/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/JdbcClusterConfigDistributedTest.java
@@ -55,7 +55,7 @@ public class JdbcClusterConfigDistributedTest {
     gfsh.executeAndAssertThat("create region --name=regionName --type=PARTITION").statusIsSuccess();
 
     gfsh.executeAndAssertThat(
-        "create jdbc-mapping --region=regionName --connection=connection --table=testTable --pdx-class-name=myPdxClass --value-contains-primary-key --field-mapping=field1:column1,field2:column2")
+        "create jdbc-mapping --region=regionName --connection=connection --table=testTable --pdx-class-name=myPdxClass --field-mapping=field1:column1,field2:column2")
         .statusIsSuccess();
 
     server.invoke(() -> {
@@ -80,7 +80,6 @@ public class JdbcClusterConfigDistributedTest {
     assertThat(regionMapping.getConnectionConfigName()).isEqualTo("connection");
     assertThat(regionMapping.getTableName()).isEqualTo("testTable");
     assertThat(regionMapping.getPdxClassName()).isEqualTo("myPdxClass");
-    assertThat(regionMapping.isPrimaryKeyInValue()).isEqualTo(true);
     assertThat(regionMapping.getColumnNameForField("field1", mock(TableMetaDataView.class)))
         .isEqualTo("column1");
     assertThat(regionMapping.getColumnNameForField("field2", mock(TableMetaDataView.class)))
diff --git a/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/ListMappingCommandDUnitTest.java b/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/ListMappingCommandDUnitTest.java
index 2ffe403..770a0c1 100644
--- a/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/ListMappingCommandDUnitTest.java
+++ b/geode-connectors/src/distributedTest/java/org/apache/geode/connectors/jdbc/internal/cli/ListMappingCommandDUnitTest.java
@@ -62,7 +62,7 @@ public class ListMappingCommandDUnitTest implements Serializable {
         .statusIsSuccess();
 
     String mapping = "create jdbc-mapping --region=testRegion --connection=connection "
-        + "--table=myTable --pdx-class-name=myPdxClass --value-contains-primary-key=true "
+        + "--table=myTable --pdx-class-name=myPdxClass "
         + "--field-mapping=field1:column1,field2:column2";
     gfsh.executeAndAssertThat(mapping).statusIsSuccess();
 
@@ -117,7 +117,7 @@ public class ListMappingCommandDUnitTest implements Serializable {
     for (int i = 1; i <= N; i++) {
       String name = regionName + "-" + i;
       service.createRegionMapping(
-          new RegionMapping(name, "x.y.MyPdxClass", "table", "connection", true));
+          new RegionMapping(name, "x.y.MyPdxClass", "table", "connection"));
       assertThat(service.getMappingForRegion(name)).isNotNull();
     }
   }
diff --git a/geode-connectors/src/integrationTest/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingCommandIntegrationTest.java b/geode-connectors/src/integrationTest/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingCommandIntegrationTest.java
index f142b4f..38d25e3 100644
--- a/geode-connectors/src/integrationTest/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingCommandIntegrationTest.java
+++ b/geode-connectors/src/integrationTest/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingCommandIntegrationTest.java
@@ -45,7 +45,6 @@ public class AlterMappingCommandIntegrationTest {
     String connectionName = "connection";
     String tableName = "testTable";
     String pdxClass = "myPdxClass";
-    Boolean keyInValue = true;
     String[] fieldMappings = new String[] {"field1:column1", "field2:column2"};
 
     cache = (InternalCache) new CacheFactory().set("locators", "").set("mcast-port", "0")
@@ -53,7 +52,7 @@ public class AlterMappingCommandIntegrationTest {
     cache.createRegionFactory(RegionShortcut.LOCAL).create(regionName);
     CreateMappingCommand create = new CreateMappingCommand();
     create.setCache(cache);
-    assertThat(create.createMapping(regionName, connectionName, tableName, pdxClass, keyInValue,
+    assertThat(create.createMapping(regionName, connectionName, tableName, pdxClass,
         fieldMappings).isSuccessful()).isTrue();
 
     alterRegionMappingCommand = new AlterMappingCommand();
@@ -80,7 +79,6 @@ public class AlterMappingCommandIntegrationTest {
     assertThat(regionMapping.getConnectionConfigName()).isEqualTo("newConnection");
     assertThat(regionMapping.getTableName()).isEqualTo("newTable");
     assertThat(regionMapping.getPdxClassName()).isEqualTo("newPdxClass");
-    assertThat(regionMapping.isPrimaryKeyInValue()).isFalse();
   }
 
 }
diff --git a/geode-connectors/src/integrationTest/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommandIntegrationTest.java b/geode-connectors/src/integrationTest/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommandIntegrationTest.java
index d47b6f4..cd3f2dd 100644
--- a/geode-connectors/src/integrationTest/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommandIntegrationTest.java
+++ b/geode-connectors/src/integrationTest/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommandIntegrationTest.java
@@ -45,7 +45,6 @@ public class CreateMappingCommandIntegrationTest {
   private String connectionName;
   private String tableName;
   private String pdxClass;
-  private boolean keyInValue;
   private String[] fieldMappings;
 
   @Before
@@ -54,7 +53,6 @@ public class CreateMappingCommandIntegrationTest {
     connectionName = "connection";
     tableName = "testTable";
     pdxClass = "myPdxClass";
-    keyInValue = true;
     fieldMappings = new String[] {"field1:column1", "field2:column2"};
 
     cache = (InternalCache) new CacheFactory().set("locators", "").set("mcast-port", "0")
@@ -73,7 +71,7 @@ public class CreateMappingCommandIntegrationTest {
   @Test
   public void createsRegionMappingInService() {
     ResultModel result = createRegionMappingCommand.createMapping(regionName, connectionName,
-        tableName, pdxClass, keyInValue, fieldMappings);
+        tableName, pdxClass, fieldMappings);
 
     assertThat(result.getStatus()).isSameAs(Result.Status.OK);
 
@@ -85,7 +83,6 @@ public class CreateMappingCommandIntegrationTest {
     assertThat(regionMapping.getConnectionConfigName()).isEqualTo(connectionName);
     assertThat(regionMapping.getTableName()).isEqualTo(tableName);
     assertThat(regionMapping.getPdxClassName()).isEqualTo(pdxClass);
-    assertThat(regionMapping.isPrimaryKeyInValue()).isEqualTo(keyInValue);
     assertThat(regionMapping.getColumnNameForField("field1", mock(TableMetaDataView.class)))
         .isEqualTo("column1");
     assertThat(regionMapping.getColumnNameForField("field2", mock(TableMetaDataView.class)))
@@ -98,7 +95,7 @@ public class CreateMappingCommandIntegrationTest {
     ResultModel result;
     result =
         createRegionMappingCommand.createMapping(regionName, connectionName, tableName, pdxClass,
-            keyInValue, fieldMappings);
+            fieldMappings);
     assertThat(result.getStatus()).isSameAs(Result.Status.OK);
 
     IgnoredException ignoredException =
@@ -106,7 +103,7 @@ public class CreateMappingCommandIntegrationTest {
 
     try {
       result = createRegionMappingCommand.createMapping(regionName, connectionName, tableName,
-          pdxClass, keyInValue, fieldMappings);
+          pdxClass, fieldMappings);
     } finally {
       ignoredException.remove();
     }
@@ -117,7 +114,7 @@ public class CreateMappingCommandIntegrationTest {
   @Test
   public void createsRegionMappingWithMinimumParams() {
     ResultModel result = createRegionMappingCommand.createMapping(regionName, connectionName, null,
-        null, false, null);
+        null, null);
 
     assertThat(result.getStatus()).isSameAs(Result.Status.OK);
 
@@ -129,7 +126,6 @@ public class CreateMappingCommandIntegrationTest {
     assertThat(regionMapping.getConnectionConfigName()).isEqualTo(connectionName);
     assertThat(regionMapping.getTableName()).isNull();
     assertThat(regionMapping.getPdxClassName()).isNull();
-    assertThat(regionMapping.isPrimaryKeyInValue()).isFalse();
     assertThat(regionMapping.getFieldMapping()).isEmpty();
   }
 }
diff --git a/geode-connectors/src/integrationTest/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyMappingCommandIntegrationTest.java b/geode-connectors/src/integrationTest/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyMappingCommandIntegrationTest.java
index df08f1f..6f9896a 100644
--- a/geode-connectors/src/integrationTest/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyMappingCommandIntegrationTest.java
+++ b/geode-connectors/src/integrationTest/java/org/apache/geode/connectors/jdbc/internal/cli/DestroyMappingCommandIntegrationTest.java
@@ -44,7 +44,7 @@ public class DestroyMappingCommandIntegrationTest {
     regionName = "testRegion";
 
     String[] params = new String[] {"param1:value1", "param2:value2"};
-    mapping = new RegionMapping(regionName, null, null, null, null);
+    mapping = new RegionMapping(regionName, null, null, null);
 
     cache = (InternalCache) new CacheFactory().set("locators", "").set("mcast-port", "0")
         .set(ENABLE_CLUSTER_CONFIGURATION, "true").create();
diff --git a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/SqlToPdxInstanceCreator.java b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/SqlToPdxInstanceCreator.java
index 126fdea..1f3ef78 100644
--- a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/SqlToPdxInstanceCreator.java
+++ b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/SqlToPdxInstanceCreator.java
@@ -55,12 +55,9 @@ class SqlToPdxInstanceCreator {
     final int columnCount = metaData.getColumnCount();
     for (int i = 1; i <= columnCount; i++) {
       String columnName = metaData.getColumnName(i);
-      if (regionMapping.isPrimaryKeyInValue()
-          || !tableMetaData.getKeyColumnName().equals(columnName)) {
-        String fieldName = regionMapping.getFieldNameForColumn(columnName, typeRegistry);
-        FieldType fieldType = getFieldType(typeRegistry, fieldName);
-        writeField(columnName, i, fieldName, fieldType);
-      }
+      String fieldName = regionMapping.getFieldNameForColumn(columnName, typeRegistry);
+      FieldType fieldType = getFieldType(typeRegistry, fieldName);
+      writeField(columnName, i, fieldName, fieldType);
     }
     if (resultSet.next()) {
       throw new JdbcConnectorException(
diff --git a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingCommand.java b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingCommand.java
index b095915..e3c425a 100644
--- a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingCommand.java
+++ b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingCommand.java
@@ -78,7 +78,7 @@ public class AlterMappingCommand extends SingleGfshCommand {
     // input
     Set<DistributedMember> targetMembers = getMembers(null, null);
     RegionMapping newMapping = new RegionMapping(regionName,
-        pdxClassName, table, connectionName, keyInValue);
+        pdxClassName, table, connectionName);
     newMapping.setFieldMapping(fieldMappings);
 
     // action
diff --git a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingFunction.java b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingFunction.java
index e0b182d..e555025 100644
--- a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingFunction.java
+++ b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingFunction.java
@@ -54,8 +54,6 @@ public class AlterMappingFunction extends CliFunction<RegionMapping> {
     String table = getValue(regionMapping.getTableName(), existingMapping.getTableName());
     String pdxClassName =
         getValue(regionMapping.getPdxClassName(), existingMapping.getPdxClassName());
-    Boolean keyInValue = regionMapping.isPrimaryKeyInValue() == null
-        ? existingMapping.isPrimaryKeyInValue() : regionMapping.isPrimaryKeyInValue();
 
     List<RegionMapping.FieldMapping> fieldMappings =
         regionMapping.getFieldMapping();
@@ -63,7 +61,7 @@ public class AlterMappingFunction extends CliFunction<RegionMapping> {
       fieldMappings = existingMapping.getFieldMapping();
     }
     RegionMapping alteredMapping = new RegionMapping(
-        existingMapping.getRegionName(), pdxClassName, table, connectionName, keyInValue);
+        existingMapping.getRegionName(), pdxClassName, table, connectionName);
     alteredMapping.getFieldMapping().addAll(fieldMappings);
     return alteredMapping;
   }
diff --git a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommand.java b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommand.java
index e51893e..7ea6697 100644
--- a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommand.java
+++ b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingCommand.java
@@ -48,9 +48,6 @@ public class CreateMappingCommand extends SingleGfshCommand {
       "Name of database table for values to be written to.";
   static final String CREATE_MAPPING__CONNECTION_NAME = "connection";
   static final String CREATE_MAPPING__CONNECTION_NAME__HELP = "Name of JDBC connection to use.";
-  static final String CREATE_MAPPING__VALUE_CONTAINS_PRIMARY_KEY = "value-contains-primary-key";
-  static final String CREATE_MAPPING__PRIMARY_KEY_IN_VALUE__HELP =
-      "If true, the primary key is contained in the PDX object, otherwise the region entry key is used for the primary key column value.";
   static final String CREATE_MAPPING__FIELD_MAPPING = "field-mapping";
   static final String CREATE_MAPPING__FIELD_MAPPING__HELP =
       "Key value pairs of PDX field names to database column names formatted like \"key:value(,key:value)*\".";
@@ -68,15 +65,12 @@ public class CreateMappingCommand extends SingleGfshCommand {
           help = CREATE_MAPPING__TABLE_NAME__HELP) String table,
       @CliOption(key = CREATE_MAPPING__PDX_CLASS_NAME,
           help = CREATE_MAPPING__PDX_CLASS_NAME__HELP) String pdxClassName,
-      @CliOption(key = CREATE_MAPPING__VALUE_CONTAINS_PRIMARY_KEY,
-          help = CREATE_MAPPING__PRIMARY_KEY_IN_VALUE__HELP, unspecifiedDefaultValue = "false",
-          specifiedDefaultValue = "true") boolean keyInValue,
       @CliOption(key = CREATE_MAPPING__FIELD_MAPPING,
           help = CREATE_MAPPING__FIELD_MAPPING__HELP) String[] fieldMappings) {
     // input
     Set<DistributedMember> targetMembers = getMembers(null, null);
     RegionMapping mapping = new RegionMapping(regionName,
-        pdxClassName, table, connectionName, keyInValue);
+        pdxClassName, table, connectionName);
     mapping.setFieldMapping(fieldMappings);
 
     // action
diff --git a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingCommand.java b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingCommand.java
index 8905cbf..cc0e885 100644
--- a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingCommand.java
+++ b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingCommand.java
@@ -18,7 +18,6 @@ import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand
 import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__PDX_CLASS_NAME;
 import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__REGION_NAME;
 import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__TABLE_NAME;
-import static org.apache.geode.connectors.jdbc.internal.cli.CreateMappingCommand.CREATE_MAPPING__VALUE_CONTAINS_PRIMARY_KEY;
 
 import java.util.Set;
 
@@ -87,7 +86,6 @@ public class DescribeMappingCommand extends GfshCommand {
     sectionModel.addData(CREATE_MAPPING__CONNECTION_NAME, mapping.getConnectionConfigName());
     sectionModel.addData(CREATE_MAPPING__TABLE_NAME, mapping.getTableName());
     sectionModel.addData(CREATE_MAPPING__PDX_CLASS_NAME, mapping.getPdxClassName());
-    sectionModel.addData(CREATE_MAPPING__VALUE_CONTAINS_PRIMARY_KEY, mapping.isPrimaryKeyInValue());
 
     TabularResultModel tabularResultData = resultModel.addTable(FIELD_TO_COLUMN_TABLE);
     tabularResultData.setHeader("Field to Column Mappings:");
diff --git a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/configuration/RegionMapping.java b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/configuration/RegionMapping.java
index bfd1280..e41be59 100644
--- a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/configuration/RegionMapping.java
+++ b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/configuration/RegionMapping.java
@@ -65,7 +65,6 @@ import org.apache.geode.pdx.internal.TypeRegistry;
  *       &lt;attribute name="connection-name" type="{http://www.w3.org/2001/XMLSchema}string" />
  *       &lt;attribute name="table" type="{http://www.w3.org/2001/XMLSchema}string" />
  *       &lt;attribute name="pdx-class" type="{http://www.w3.org/2001/XMLSchema}string" />
- *       &lt;attribute name="primary-key-in-value" type="{http://www.w3.org/2001/XMLSchema}string" />
  *     &lt;/restriction>
  *   &lt;/complexContent>
  * &lt;/complexType>
@@ -92,8 +91,6 @@ public class RegionMapping implements CacheElement {
   protected String tableName;
   @XmlAttribute(name = "pdx-class")
   protected String pdxClassName;
-  @XmlAttribute(name = "primary-key-in-value")
-  protected Boolean primaryKeyInValue;
 
   @XmlTransient
   protected String regionName;
@@ -103,12 +100,11 @@ public class RegionMapping implements CacheElement {
   public RegionMapping() {}
 
   public RegionMapping(String regionName, String pdxClassName, String tableName,
-      String connectionConfigName, Boolean primaryKeyInValue) {
+      String connectionConfigName) {
     this.regionName = regionName;
     this.pdxClassName = pdxClassName;
     this.tableName = tableName;
     this.connectionConfigName = connectionConfigName;
-    this.primaryKeyInValue = primaryKeyInValue;
   }
 
   public void setFieldMapping(String[] mappings) {
@@ -149,10 +145,6 @@ public class RegionMapping implements CacheElement {
     this.pdxClassName = pdxClassName;
   }
 
-  public void setPrimaryKeyInValue(Boolean primaryKeyInValue) {
-    this.primaryKeyInValue = primaryKeyInValue;
-  }
-
   public boolean isFieldMappingModified() {
     return fieldMappingModified;
   }
@@ -180,14 +172,6 @@ public class RegionMapping implements CacheElement {
     return tableName;
   }
 
-  public Boolean getPrimaryKeyInValue() {
-    return primaryKeyInValue;
-  }
-
-  public Boolean isPrimaryKeyInValue() {
-    return primaryKeyInValue;
-  }
-
   public String getRegionToTableName() {
     if (tableName == null) {
       return regionName;
@@ -313,9 +297,6 @@ public class RegionMapping implements CacheElement {
 
     RegionMapping that = (RegionMapping) o;
 
-    if (primaryKeyInValue != that.primaryKeyInValue) {
-      return false;
-    }
     if (regionName != null ? !regionName.equals(that.regionName) : that.regionName != null) {
       return false;
     }
@@ -343,7 +324,6 @@ public class RegionMapping implements CacheElement {
     result = 31 * result + (pdxClassName != null ? pdxClassName.hashCode() : 0);
     result = 31 * result + (tableName != null ? tableName.hashCode() : 0);
     result = 31 * result + (connectionConfigName != null ? connectionConfigName.hashCode() : 0);
-    result = 31 * result + (primaryKeyInValue ? 1 : 0);
     return result;
   }
 
@@ -351,7 +331,7 @@ public class RegionMapping implements CacheElement {
   public String toString() {
     return "RegionMapping{" + "regionName='" + regionName + '\'' + ", pdxClassName='"
         + pdxClassName + '\'' + ", tableName='" + tableName + '\'' + ", connectionConfigName='"
-        + connectionConfigName + '\'' + ", primaryKeyInValue=" + primaryKeyInValue + '}';
+        + connectionConfigName + '\'' + '}';
   }
 
   @Override
diff --git a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/xml/ElementType.java b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/xml/ElementType.java
index 9d262d9..2cef36c 100644
--- a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/xml/ElementType.java
+++ b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/xml/ElementType.java
@@ -37,8 +37,6 @@ public enum ElementType {
           attributes.getValue(JdbcConnectorServiceXmlParser.CONNECTION_NAME));
       mapping.setTableName(attributes.getValue(JdbcConnectorServiceXmlParser.TABLE));
       mapping.setPdxClassName(attributes.getValue(JdbcConnectorServiceXmlParser.PDX_CLASS));
-      mapping.setPrimaryKeyInValue(
-          Boolean.valueOf(attributes.getValue(JdbcConnectorServiceXmlParser.PRIMARY_KEY_IN_VALUE)));
       stack.push(mapping);
     }
 
diff --git a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/xml/JdbcConnectorServiceXmlParser.java b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/xml/JdbcConnectorServiceXmlParser.java
index dc379ac..f80476a 100644
--- a/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/xml/JdbcConnectorServiceXmlParser.java
+++ b/geode-connectors/src/main/java/org/apache/geode/connectors/jdbc/internal/xml/JdbcConnectorServiceXmlParser.java
@@ -32,7 +32,6 @@ public class JdbcConnectorServiceXmlParser extends AbstractXmlParser {
   static final String PDX_CLASS = "pdx-class";
   static final String FIELD_NAME = "field-name";
   static final String COLUMN_NAME = "column-name";
-  static final String PRIMARY_KEY_IN_VALUE = "primary-key-in-value";
 
   @Override
   public String getNamespaceUri() {
diff --git a/geode-connectors/src/main/resources/META-INF/schemas/geode.apache.org/schema/jdbc/jdbc-1.0.xsd b/geode-connectors/src/main/resources/META-INF/schemas/geode.apache.org/schema/jdbc/jdbc-1.0.xsd
index c48128d..10f4116 100644
--- a/geode-connectors/src/main/resources/META-INF/schemas/geode.apache.org/schema/jdbc/jdbc-1.0.xsd
+++ b/geode-connectors/src/main/resources/META-INF/schemas/geode.apache.org/schema/jdbc/jdbc-1.0.xsd
@@ -55,7 +55,6 @@ XML schema for JDBC Connector Service in Geode.
                 <xsd:attribute type="xsd:string" name="connection-name" use="optional"/>
                 <xsd:attribute type="xsd:string" name="table" use="optional"/>
                 <xsd:attribute type="xsd:string" name="pdx-class" use="optional"/>
-                <xsd:attribute type="xsd:string" name="primary-key-in-value" use="optional"/>
             </xsd:complexType>
         </xsd:element>
 </xsd:schema>
diff --git a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/RegionMappingTest.java b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/RegionMappingTest.java
index d231863..ec38620 100644
--- a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/RegionMappingTest.java
+++ b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/RegionMappingTest.java
@@ -57,7 +57,7 @@ public class RegionMappingTest {
 
   @Test
   public void emptyArrayFiledMapping() {
-    mapping = new RegionMapping("region", "class", "table", "connection", false);
+    mapping = new RegionMapping("region", "class", "table", "connection");
     mapping.setFieldMapping(new String[0]);
     assertThat(mapping.isFieldMappingModified()).isTrue();
     assertThat(mapping.getFieldMapping()).isEmpty();
@@ -65,7 +65,7 @@ public class RegionMappingTest {
 
   @Test
   public void initiatedWithNullValues() {
-    mapping = new RegionMapping(null, null, null, null, false);
+    mapping = new RegionMapping(null, null, null, null);
 
     assertThat(mapping.getTableName()).isNull();
     assertThat(mapping.getRegionName()).isNull();
@@ -80,7 +80,7 @@ public class RegionMappingTest {
 
   @Test
   public void hasCorrectTableName() {
-    mapping = new RegionMapping(null, null, name, null, false);
+    mapping = new RegionMapping(null, null, name, null);
 
     assertThat(mapping.getTableName()).isEqualTo(name);
     assertThat(mapping.getRegionToTableName()).isEqualTo(name);
@@ -88,7 +88,7 @@ public class RegionMappingTest {
 
   @Test
   public void hasCorrectTableNameWhenRegionNameIsSet() {
-    mapping = new RegionMapping("regionName", null, "tableName", null, false);
+    mapping = new RegionMapping("regionName", null, "tableName", null);
 
     assertThat(mapping.getRegionName()).isEqualTo("regionName");
     assertThat(mapping.getTableName()).isEqualTo("tableName");
@@ -97,7 +97,7 @@ public class RegionMappingTest {
 
   @Test
   public void hasCorrectRegionName() {
-    mapping = new RegionMapping(name, null, null, null, false);
+    mapping = new RegionMapping(name, null, null, null);
 
     assertThat(mapping.getRegionName()).isEqualTo(name);
     assertThat(mapping.getRegionToTableName()).isEqualTo(name);
@@ -105,28 +105,21 @@ public class RegionMappingTest {
 
   @Test
   public void hasCorrectConfigName() {
-    mapping = new RegionMapping(null, null, null, name, false);
+    mapping = new RegionMapping(null, null, null, name);
 
     assertThat(mapping.getConnectionConfigName()).isEqualTo(name);
   }
 
   @Test
   public void hasCorrectPdxClassName() {
-    mapping = new RegionMapping(null, name, null, null, false);
+    mapping = new RegionMapping(null, name, null, null);
 
     assertThat(mapping.getPdxClassName()).isEqualTo(name);
   }
 
   @Test
-  public void primaryKeyInValueSetCorrectly() {
-    mapping = new RegionMapping(null, null, null, null, true);
-
-    assertThat(mapping.isPrimaryKeyInValue()).isTrue();
-  }
-
-  @Test
   public void returnsColumnNameIfFieldNotMapped() {
-    mapping = new RegionMapping(null, null, null, null, true);
+    mapping = new RegionMapping(null, null, null, null);
     mapping.setFieldMapping(new String[] {"otherField:column"});
 
     String columnName = mapping.getColumnNameForField(fieldName1, mock(TableMetaDataView.class));
@@ -137,7 +130,7 @@ public class RegionMappingTest {
   @Test
   public void returnsColumnNameFromTableMetaDataIfFieldNotMappedAndMetaDataMatchesWithCaseDiffering() {
     String metaDataColumnName = fieldName1.toUpperCase();
-    mapping = new RegionMapping(null, null, null, null, true);
+    mapping = new RegionMapping(null, null, null, null);
     mapping.setFieldMapping(new String[] {"otherField:column"});
     TableMetaDataView tableMetaDataView = mock(TableMetaDataView.class);
     when(tableMetaDataView.getColumnNames()).thenReturn(Collections.singleton(metaDataColumnName));
@@ -149,7 +142,7 @@ public class RegionMappingTest {
   @Test
   public void returnsColumnNameFromTableMetaDataIfFieldNotMappedAndMetaDataMatchesExactly() {
     String metaDataColumnName = fieldName1;
-    mapping = new RegionMapping(null, null, null, null, true);
+    mapping = new RegionMapping(null, null, null, null);
     mapping.setFieldMapping(new String[] {"otherField:column"});
     TableMetaDataView tableMetaDataView = mock(TableMetaDataView.class);
     when(tableMetaDataView.getColumnNames()).thenReturn(Collections.singleton(metaDataColumnName));
@@ -160,7 +153,7 @@ public class RegionMappingTest {
 
   @Test
   public void returnsColumnNameIfFieldNotMappedAndNotInMetaData() {
-    mapping = new RegionMapping(null, null, null, null, true);
+    mapping = new RegionMapping(null, null, null, null);
     mapping.setFieldMapping(new String[] {"otherField:column"});
     TableMetaDataView tableMetaDataView = mock(TableMetaDataView.class);
     when(tableMetaDataView.getColumnNames()).thenReturn(Collections.singleton("does not match"));
@@ -170,7 +163,7 @@ public class RegionMappingTest {
 
   @Test
   public void getColumnNameForFieldThrowsIfTwoColumnsMatchField() {
-    mapping = new RegionMapping(null, null, null, null, true);
+    mapping = new RegionMapping(null, null, null, null);
     mapping.setFieldMapping(new String[] {"otherField:column"});
 
     TableMetaDataView tableMetaDataView = mock(TableMetaDataView.class);
@@ -187,7 +180,7 @@ public class RegionMappingTest {
 
   @Test
   public void ifMixedCaseColumnNameNotMappedReturnsItAsFieldName() {
-    mapping = new RegionMapping(null, null, null, null, true);
+    mapping = new RegionMapping(null, null, null, null);
     mapping.setFieldMapping(new String[] {"otherField:column"});
 
     assertThat(mapping.getFieldNameForColumn("columnName", null)).isEqualTo("columnName");
@@ -195,7 +188,7 @@ public class RegionMappingTest {
 
   @Test
   public void ifLowerCaseColumnNameNotMappedReturnsItAsFieldName() {
-    mapping = new RegionMapping(null, null, null, null, true);
+    mapping = new RegionMapping(null, null, null, null);
     mapping.setFieldMapping(new String[] {"otherField:column"});
 
     assertThat(mapping.getFieldNameForColumn("columnname", null)).isEqualTo("columnname");
@@ -203,7 +196,7 @@ public class RegionMappingTest {
 
   @Test
   public void ifUpperCaseColumnNameNotMappedReturnsItLowerCasedAsFieldName() {
-    mapping = new RegionMapping(null, null, null, null, true);
+    mapping = new RegionMapping(null, null, null, null);
     mapping.setFieldMapping(new String[] {"otherField:column"});
 
     assertThat(mapping.getFieldNameForColumn("COLUMNNAME", null)).isEqualTo("columnname");
@@ -212,7 +205,7 @@ public class RegionMappingTest {
 
   @Test
   public void throwsIfColumnNotMappedAndPdxClassNameDoesNotExist() {
-    mapping = new RegionMapping(null, "pdxClassName", null, null, true);
+    mapping = new RegionMapping(null, "pdxClassName", null, null);
     TypeRegistry typeRegistry = mock(TypeRegistry.class);
     when(typeRegistry.getPdxTypesForClassName("pdxClassName")).thenReturn(Collections.emptySet());
     expectedException.expect(JdbcConnectorException.class);
@@ -225,7 +218,7 @@ public class RegionMappingTest {
   public void throwsIfColumnNotMappedAndPdxClassNameDoesExistButHasNoMatchingFields() {
     String pdxClassName = "pdxClassName";
     String columnName = "columnName";
-    mapping = new RegionMapping(null, pdxClassName, null, null, true);
+    mapping = new RegionMapping(null, pdxClassName, null, null);
     TypeRegistry typeRegistry = mock(TypeRegistry.class);
     HashSet<PdxType> pdxTypes = new HashSet<>(Arrays.asList(mock(PdxType.class)));
     when(typeRegistry.getPdxTypesForClassName(pdxClassName)).thenReturn(pdxTypes);
@@ -240,7 +233,7 @@ public class RegionMappingTest {
   public void throwsIfColumnNotMappedAndPdxClassNameDoesExistButHasMoreThanOneMatchingFields() {
     String pdxClassName = "pdxClassName";
     String columnName = "columnName";
-    mapping = new RegionMapping(null, pdxClassName, null, null, true);
+    mapping = new RegionMapping(null, pdxClassName, null, null);
     TypeRegistry typeRegistry = mock(TypeRegistry.class);
     PdxType pdxType = mock(PdxType.class);
     when(pdxType.getFieldNames())
@@ -258,7 +251,7 @@ public class RegionMappingTest {
   public void returnsIfColumnNotMappedAndPdxClassNameDoesExistAndHasOneFieldThatInexactlyMatches() {
     String pdxClassName = "pdxClassName";
     String columnName = "columnName";
-    mapping = new RegionMapping(null, pdxClassName, null, null, true);
+    mapping = new RegionMapping(null, pdxClassName, null, null);
     TypeRegistry typeRegistry = mock(TypeRegistry.class);
     PdxType pdxType = mock(PdxType.class);
     when(pdxType.getFieldNames())
@@ -274,7 +267,7 @@ public class RegionMappingTest {
   public void returnsIfColumnNotMappedAndPdxClassNameDoesExistAndHasOneFieldThatExactlyMatches() {
     String pdxClassName = "pdxClassName";
     String columnName = "columnName";
-    mapping = new RegionMapping(null, pdxClassName, null, null, true);
+    mapping = new RegionMapping(null, pdxClassName, null, null);
     TypeRegistry typeRegistry = mock(TypeRegistry.class);
     PdxType pdxType = mock(PdxType.class);
     when(pdxType.getPdxField(columnName)).thenReturn(mock(PdxField.class));
@@ -286,7 +279,7 @@ public class RegionMappingTest {
 
   @Test
   public void returnsMappedColumnNameForField() {
-    mapping = new RegionMapping(null, null, null, null, true);
+    mapping = new RegionMapping(null, null, null, null);
     mapping.setFieldMapping(new String[] {fieldName1 + ":" + columnName1});
 
     assertThat(mapping.getColumnNameForField(fieldName1, mock(TableMetaDataView.class)))
@@ -295,7 +288,7 @@ public class RegionMappingTest {
 
   @Test
   public void returnsMappedColumnNameForFieldEvenIfMetaDataMatches() {
-    mapping = new RegionMapping(null, null, null, null, true);
+    mapping = new RegionMapping(null, null, null, null);
     mapping.setFieldMapping(new String[] {fieldName1 + ":" + columnName1});
 
     TableMetaDataView tableMetaDataView = mock(TableMetaDataView.class);
@@ -306,7 +299,7 @@ public class RegionMappingTest {
 
   @Test
   public void returnsMappedFieldNameForColumn() {
-    mapping = new RegionMapping(null, null, null, null, true);
+    mapping = new RegionMapping(null, null, null, null);
     mapping.setFieldMapping(new String[] {fieldName1 + ":" + columnName1});
 
     assertThat(mapping.getFieldNameForColumn(columnName1, null)).isEqualTo(fieldName1);
@@ -314,7 +307,7 @@ public class RegionMappingTest {
 
   @Test
   public void returnsCachedFieldNameForColumn() {
-    mapping = new RegionMapping(null, null, null, null, true);
+    mapping = new RegionMapping(null, null, null, null);
     mapping.setFieldMapping(new String[] {fieldName1 + ":" + columnName1});
 
     TableMetaDataView tableMetaDataView = mock(TableMetaDataView.class);
@@ -326,7 +319,7 @@ public class RegionMappingTest {
 
   @Test
   public void returnsCachedColumnNameForField() {
-    mapping = new RegionMapping(null, null, null, null, true);
+    mapping = new RegionMapping(null, null, null, null);
     mapping.setFieldMapping(new String[] {fieldName1 + ":" + columnName1});
 
     mapping.getFieldNameForColumn(columnName1, null);
@@ -338,7 +331,7 @@ public class RegionMappingTest {
 
   @Test
   public void returnsAllMappings() {
-    mapping = new RegionMapping(null, null, null, null, true);
+    mapping = new RegionMapping(null, null, null, null);
     mapping.setFieldMapping(
         new String[] {fieldName1 + ":" + columnName1, fieldName2 + ":" + columnName2});
 
@@ -352,12 +345,12 @@ public class RegionMappingTest {
   @Test
   public void verifyTwoNonDefaultInstancesAreEqual() {
     RegionMapping rm1 = new RegionMapping("regionName",
-        "pdxClassName", "tableName", "connectionName", true);
+        "pdxClassName", "tableName", "connectionName");
     rm1.setFieldMapping(
         new String[] {fieldName1 + ":" + columnName1, fieldName2 + ":" + columnName2});
 
     RegionMapping rm2 = new RegionMapping("regionName",
-        "pdxClassName", "tableName", "connectionName", true);
+        "pdxClassName", "tableName", "connectionName");
     rm2.setFieldMapping(
         new String[] {fieldName1 + ":" + columnName1, fieldName2 + ":" + columnName2});
 
@@ -367,9 +360,9 @@ public class RegionMappingTest {
   @Test
   public void verifyTwoDefaultInstancesAreEqual() {
     RegionMapping rm1 =
-        new RegionMapping("regionName", null, null, "connectionName", false);
+        new RegionMapping("regionName", null, null, "connectionName");
     RegionMapping rm2 =
-        new RegionMapping("regionName", null, null, "connectionName", false);
+        new RegionMapping("regionName", null, null, "connectionName");
     assertThat(rm1).isEqualTo(rm2);
   }
 
@@ -377,12 +370,12 @@ public class RegionMappingTest {
   @Test
   public void verifyTwoInstancesThatAreEqualHaveSameHashCode() {
     RegionMapping rm1 = new RegionMapping("regionName",
-        "pdxClassName", "tableName", "connectionName", true);
+        "pdxClassName", "tableName", "connectionName");
     rm1.setFieldMapping(
         new String[] {fieldName1 + ":" + columnName1, fieldName2 + ":" + columnName2});
 
     RegionMapping rm2 = new RegionMapping("regionName",
-        "pdxClassName", "tableName", "connectionName", true);
+        "pdxClassName", "tableName", "connectionName");
     rm1.setFieldMapping(
         new String[] {fieldName1 + ":" + columnName1, fieldName2 + ":" + columnName2});
 
@@ -391,7 +384,7 @@ public class RegionMappingTest {
 
   @Test
   public void verifyThatMappingIsEqualToItself() {
-    mapping = new RegionMapping(null, null, null, null, false);
+    mapping = new RegionMapping(null, null, null, null);
     boolean result = mapping.equals(mapping);
     assertThat(mapping.hashCode()).isEqualTo(mapping.hashCode());
     assertThat(result).isTrue();
@@ -399,14 +392,14 @@ public class RegionMappingTest {
 
   @Test
   public void verifyThatNullIsNotEqual() {
-    mapping = new RegionMapping(null, null, null, null, false);
+    mapping = new RegionMapping(null, null, null, null);
     boolean result = mapping.equals(null);
     assertThat(result).isFalse();
   }
 
   @Test
   public void verifyOtherClassIsNotEqual() {
-    mapping = new RegionMapping(null, null, null, null, false);
+    mapping = new RegionMapping(null, null, null, null);
     boolean result = mapping.equals("not equal");
     assertThat(result).isFalse();
   }
@@ -414,9 +407,9 @@ public class RegionMappingTest {
   @Test
   public void verifyMappingWithDifferentRegionNamesAreNotEqual() {
     RegionMapping rm1 =
-        new RegionMapping(null, null, null, null, false);
+        new RegionMapping(null, null, null, null);
     RegionMapping rm2 =
-        new RegionMapping("name", null, null, null, false);
+        new RegionMapping("name", null, null, null);
     boolean result = rm1.equals(rm2);
     assertThat(result).isFalse();
   }
@@ -424,9 +417,9 @@ public class RegionMappingTest {
   @Test
   public void verifyMappingWithDifferentPdxClassNameAreNotEqual() {
     RegionMapping rm1 =
-        new RegionMapping(null, null, null, null, false);
+        new RegionMapping(null, null, null, null);
     RegionMapping rm2 =
-        new RegionMapping(null, "pdxClass", null, null, false);
+        new RegionMapping(null, "pdxClass", null, null);
     boolean result = rm1.equals(rm2);
     assertThat(result).isFalse();
   }
diff --git a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/SqlToPdxInstanceCreatorTest.java b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/SqlToPdxInstanceCreatorTest.java
index 7dd372e..51b7b84 100644
--- a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/SqlToPdxInstanceCreatorTest.java
+++ b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/SqlToPdxInstanceCreatorTest.java
@@ -20,7 +20,6 @@ import static org.mockito.ArgumentMatchers.anyBoolean;
 import static org.mockito.ArgumentMatchers.anyString;
 import static org.mockito.ArgumentMatchers.eq;
 import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.verifyNoMoreInteractions;
 import static org.mockito.Mockito.when;
@@ -111,33 +110,11 @@ public class SqlToPdxInstanceCreatorTest {
   }
 
   @Test
-  public void readResultOmitsKeyColumnIfNotInValue() throws Exception {
+  public void readResultIncludesKeyColumnInPdxValue() throws Exception {
     setupResultSetForTwoObjectColumns(resultSet);
     when(resultSet.next()).thenReturn(true).thenReturn(false);
     PdxInstanceFactory factory = mock(PdxInstanceFactory.class);
     when(cache.createPdxInstanceFactory(anyString(), anyBoolean())).thenReturn(factory);
-    when(regionMapping.isPrimaryKeyInValue()).thenReturn(false);
-    when(regionMapping.getFieldNameForColumn(eq(COLUMN_NAME_1), any()))
-        .thenReturn(PDX_FIELD_NAME_1);
-    when(regionMapping.getFieldNameForColumn(eq(COLUMN_NAME_2), any()))
-        .thenReturn(PDX_FIELD_NAME_2);
-    tableMetaDataView = mock(TableMetaDataView.class);
-    when(tableMetaDataView.getKeyColumnName()).thenReturn(COLUMN_NAME_1);
-
-    createPdxInstance();
-
-    verify(factory).writeObject(PDX_FIELD_NAME_2, COLUMN_VALUE_2);
-    verify(factory, times(1)).writeObject(any(), any());
-    verify(factory).create();
-  }
-
-  @Test
-  public void readResultIncludesKeyColumnIfPrimaryKeyInValue() throws Exception {
-    setupResultSetForTwoObjectColumns(resultSet);
-    when(resultSet.next()).thenReturn(true).thenReturn(false);
-    PdxInstanceFactory factory = mock(PdxInstanceFactory.class);
-    when(cache.createPdxInstanceFactory(anyString(), anyBoolean())).thenReturn(factory);
-    when(regionMapping.isPrimaryKeyInValue()).thenReturn(true);
     when(regionMapping.getFieldNameForColumn(eq(COLUMN_NAME_1), any()))
         .thenReturn(PDX_FIELD_NAME_1);
     when(regionMapping.getFieldNameForColumn(eq(COLUMN_NAME_2), any()))
diff --git a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingFunctionTest.java b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingFunctionTest.java
index 7b94ad7..fb7a158 100644
--- a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingFunctionTest.java
+++ b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/AlterMappingFunctionTest.java
@@ -65,10 +65,10 @@ public class AlterMappingFunctionTest {
     DistributedMember distributedMember = mock(DistributedMember.class);
     service = mock(JdbcConnectorService.class);
 
-    regionMapping = new RegionMapping(REGION_NAME, null, null, null, null);
-    existingMapping = new RegionMapping(REGION_NAME, null, null, null, null);
+    regionMapping = new RegionMapping(REGION_NAME, null, null, null);
+    existingMapping = new RegionMapping(REGION_NAME, null, null, null);
     mappingToAlter =
-        new RegionMapping(REGION_NAME, "pdxClass", "myTable", "connection", true);
+        new RegionMapping(REGION_NAME, "pdxClass", "myTable", "connection");
     mappingToAlter.setFieldMapping(new String[] {"field1:column1", "field2:column2"});
 
     when(context.getResultSender()).thenReturn(resultSender);
@@ -138,7 +138,7 @@ public class AlterMappingFunctionTest {
   @Test
   public void alterMappingPdxClassName() {
     RegionMapping newConfigValues =
-        new RegionMapping(REGION_NAME, "newClassName", null, null, null);
+        new RegionMapping(REGION_NAME, "newClassName", null, null);
 
     RegionMapping alteredConfig =
         function.alterRegionMapping(newConfigValues, mappingToAlter);
@@ -147,7 +147,6 @@ public class AlterMappingFunctionTest {
     assertThat(alteredConfig.getPdxClassName()).isEqualTo("newClassName");
     assertThat(alteredConfig.getTableName()).isEqualTo("myTable");
     assertThat(alteredConfig.getConnectionConfigName()).isEqualTo("connection");
-    assertThat(alteredConfig.isPrimaryKeyInValue()).isTrue();
 
     assertFieldMapping(alteredConfig);
   }
@@ -165,7 +164,7 @@ public class AlterMappingFunctionTest {
   @Test
   public void alterRegionMappingTable() {
     RegionMapping newConfigValues =
-        new RegionMapping(REGION_NAME, null, "newTable", null, null);
+        new RegionMapping(REGION_NAME, null, "newTable", null);
 
     RegionMapping alteredConfig =
         function.alterRegionMapping(newConfigValues, mappingToAlter);
@@ -174,14 +173,13 @@ public class AlterMappingFunctionTest {
     assertThat(alteredConfig.getPdxClassName()).isEqualTo("pdxClass");
     assertThat(alteredConfig.getTableName()).isEqualTo("newTable");
     assertThat(alteredConfig.getConnectionConfigName()).isEqualTo("connection");
-    assertThat(alteredConfig.isPrimaryKeyInValue()).isTrue();
     assertFieldMapping(alteredConfig);
   }
 
   @Test
   public void alterRegionMappingPrimaryKeyInValue() {
     RegionMapping newConfigValues =
-        new RegionMapping(REGION_NAME, null, null, null, false);
+        new RegionMapping(REGION_NAME, null, null, null);
 
     RegionMapping alteredConfig =
         function.alterRegionMapping(newConfigValues, mappingToAlter);
@@ -190,14 +188,13 @@ public class AlterMappingFunctionTest {
     assertThat(alteredConfig.getPdxClassName()).isEqualTo("pdxClass");
     assertThat(alteredConfig.getTableName()).isEqualTo("myTable");
     assertThat(alteredConfig.getConnectionConfigName()).isEqualTo("connection");
-    assertThat(alteredConfig.isPrimaryKeyInValue()).isFalse();
     assertFieldMapping(alteredConfig);
   }
 
   @Test
   public void alterRegionMappingConnectionName() {
     RegionMapping newConfigValues =
-        new RegionMapping(REGION_NAME, null, null, "newConnection", null);
+        new RegionMapping(REGION_NAME, null, null, "newConnection");
 
     RegionMapping alteredConfig =
         function.alterRegionMapping(newConfigValues, mappingToAlter);
@@ -206,14 +203,13 @@ public class AlterMappingFunctionTest {
     assertThat(alteredConfig.getPdxClassName()).isEqualTo("pdxClass");
     assertThat(alteredConfig.getTableName()).isEqualTo("myTable");
     assertThat(alteredConfig.getConnectionConfigName()).isEqualTo("newConnection");
-    assertThat(alteredConfig.isPrimaryKeyInValue()).isTrue();
     assertFieldMapping(alteredConfig);
   }
 
   @Test
   public void alterRegionMappingFieldMappings() {
     RegionMapping newConfigValues =
-        new RegionMapping(REGION_NAME, null, null, null, null);
+        new RegionMapping(REGION_NAME, null, null, null);
     newConfigValues.setFieldMapping(new String[] {"field5:column5", "field6:column6"});
 
 
@@ -224,7 +220,6 @@ public class AlterMappingFunctionTest {
     assertThat(alteredConfig.getPdxClassName()).isEqualTo("pdxClass");
     assertThat(alteredConfig.getTableName()).isEqualTo("myTable");
     assertThat(alteredConfig.getConnectionConfigName()).isEqualTo("connection");
-    assertThat(alteredConfig.isPrimaryKeyInValue()).isTrue();
     List<RegionMapping.FieldMapping> fieldMappings =
         alteredConfig.getFieldMapping();
     assertThat(fieldMappings).hasSize(2);
@@ -237,7 +232,7 @@ public class AlterMappingFunctionTest {
   @Test
   public void alterRegionMappingRemoveFieldMappings() {
     RegionMapping newConfigValues =
-        new RegionMapping(REGION_NAME, null, null, null, null);
+        new RegionMapping(REGION_NAME, null, null, null);
     newConfigValues.setFieldMapping(new String[0]);
     RegionMapping alteredConfig =
         function.alterRegionMapping(newConfigValues, mappingToAlter);
@@ -246,7 +241,6 @@ public class AlterMappingFunctionTest {
     assertThat(alteredConfig.getPdxClassName()).isEqualTo("pdxClass");
     assertThat(alteredConfig.getTableName()).isEqualTo("myTable");
     assertThat(alteredConfig.getConnectionConfigName()).isEqualTo("connection");
-    assertThat(alteredConfig.isPrimaryKeyInValue()).isTrue();
     List<RegionMapping.FieldMapping> fieldMappings =
         alteredConfig.getFieldMapping();
     assertThat(fieldMappings).hasSize(0);
@@ -255,7 +249,7 @@ public class AlterMappingFunctionTest {
   @Test
   public void alterRegionMappingWithEmptyString() {
     RegionMapping newConfigValues =
-        new RegionMapping(REGION_NAME, null, null, null, null);
+        new RegionMapping(REGION_NAME, null, null, null);
     newConfigValues.setFieldMapping(new String[] {""});
     RegionMapping alteredConfig =
         function.alterRegionMapping(newConfigValues, mappingToAlter);
@@ -264,7 +258,6 @@ public class AlterMappingFunctionTest {
     assertThat(alteredConfig.getPdxClassName()).isEqualTo("pdxClass");
     assertThat(alteredConfig.getTableName()).isEqualTo("myTable");
     assertThat(alteredConfig.getConnectionConfigName()).isEqualTo("connection");
-    assertThat(alteredConfig.isPrimaryKeyInValue()).isTrue();
     List<RegionMapping.FieldMapping> fieldMappings =
         alteredConfig.getFieldMapping();
     assertThat(fieldMappings).hasSize(0);
@@ -273,7 +266,7 @@ public class AlterMappingFunctionTest {
   @Test
   public void alterRegionMappingWithNothingToAlter() {
     RegionMapping newConfigValues =
-        new RegionMapping(REGION_NAME, null, null, null, null);
+        new RegionMapping(REGION_NAME, null, null, null);
 
     RegionMapping alteredConfig =
         function.alterRegionMapping(newConfigValues, mappingToAlter);
@@ -282,7 +275,6 @@ public class AlterMappingFunctionTest {
     assertThat(alteredConfig.getPdxClassName()).isEqualTo("pdxClass");
     assertThat(alteredConfig.getTableName()).isEqualTo("myTable");
     assertThat(alteredConfig.getConnectionConfigName()).isEqualTo("connection");
-    assertThat(alteredConfig.isPrimaryKeyInValue()).isTrue();
     assertFieldMapping(alteredConfig);
   }
 }
diff --git a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingFunctionTest.java b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingFunctionTest.java
index 5250419..eac2343 100644
--- a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingFunctionTest.java
+++ b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/CreateMappingFunctionTest.java
@@ -66,7 +66,7 @@ public class CreateMappingFunctionTest {
     distributedMember = mock(DistributedMember.class);
     service = mock(JdbcConnectorService.class);
 
-    regionMapping = new RegionMapping(REGION_NAME, null, null, null, null);
+    regionMapping = new RegionMapping(REGION_NAME, null, null, null);
 
     when(context.getResultSender()).thenReturn(resultSender);
     when(context.getCache()).thenReturn(cache);
diff --git a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingCommandTest.java b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingCommandTest.java
index aa94d2e..c8695b4 100644
--- a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingCommandTest.java
+++ b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/DescribeMappingCommandTest.java
@@ -66,7 +66,7 @@ public class DescribeMappingCommandTest {
         null);
 
     RegionMapping mapping =
-        new RegionMapping("region", "class1", "table1", "name1", true);
+        new RegionMapping("region", "class1", "table1", "name1");
     mapping.getFieldMapping()
         .add(new RegionMapping.FieldMapping("field1", "value1"));
     mapping.getFieldMapping()
@@ -80,7 +80,7 @@ public class DescribeMappingCommandTest {
     gfsh.executeAndAssertThat(command, COMMAND).statusIsSuccess().containsOutput("region", "region")
         .containsOutput("connection", "name1").containsOutput("table", "table1")
         .containsOutput("pdx-class-name", "class1")
-        .containsOutput("value-contains-primary-key", "true").containsOutput("field1", "value1")
+        .containsOutput("field1", "value1")
         .containsOutput("field2", "value2");
   }
 
diff --git a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/ListMappingCommandTest.java b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/ListMappingCommandTest.java
index 678d4d3..3097a7a 100644
--- a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/ListMappingCommandTest.java
+++ b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/cli/ListMappingCommandTest.java
@@ -62,14 +62,14 @@ public class ListMappingCommandTest {
         null);
 
     RegionMapping mapping1 =
-        new RegionMapping("region1", "class1", "table1", "name1", true);
+        new RegionMapping("region1", "class1", "table1", "name1");
     mapping1.getFieldMapping()
         .add(new RegionMapping.FieldMapping("field1", "value1"));
     mapping1.getFieldMapping()
         .add(new RegionMapping.FieldMapping("field2", "value2"));
 
     RegionMapping mapping2 =
-        new RegionMapping("region2", "class2", "table2", "name2", true);
+        new RegionMapping("region2", "class2", "table2", "name2");
     mapping2.getFieldMapping()
         .add(new RegionMapping.FieldMapping("field3", "value3"));
     mapping2.getFieldMapping()
diff --git a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/xml/ElementTypeTest.java b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/xml/ElementTypeTest.java
index 49a53b3..c372582 100644
--- a/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/xml/ElementTypeTest.java
+++ b/geode-connectors/src/test/java/org/apache/geode/connectors/jdbc/internal/xml/ElementTypeTest.java
@@ -21,7 +21,6 @@ import static org.apache.geode.connectors.jdbc.internal.xml.JdbcConnectorService
 import static org.apache.geode.connectors.jdbc.internal.xml.JdbcConnectorServiceXmlParser.CONNECTION_NAME;
 import static org.apache.geode.connectors.jdbc.internal.xml.JdbcConnectorServiceXmlParser.FIELD_NAME;
 import static org.apache.geode.connectors.jdbc.internal.xml.JdbcConnectorServiceXmlParser.PDX_CLASS;
-import static org.apache.geode.connectors.jdbc.internal.xml.JdbcConnectorServiceXmlParser.PRIMARY_KEY_IN_VALUE;
 import static org.apache.geode.connectors.jdbc.internal.xml.JdbcConnectorServiceXmlParser.TABLE;
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
@@ -79,7 +78,6 @@ public class ElementTypeTest {
     when(attributes.getValue(CONNECTION_NAME)).thenReturn("connectionName");
     when(attributes.getValue(TABLE)).thenReturn("table");
     when(attributes.getValue(PDX_CLASS)).thenReturn("pdxClass");
-    when(attributes.getValue(PRIMARY_KEY_IN_VALUE)).thenReturn("true");
     when(regionCreation.getFullPath()).thenReturn("/region");
     stack.push(regionCreation);
 
@@ -90,7 +88,6 @@ public class ElementTypeTest {
     assertThat(regionMapping.getConnectionConfigName()).isEqualTo("connectionName");
     assertThat(regionMapping.getTableName()).isEqualTo("table");
     assertThat(regionMapping.getPdxClassName()).isEqualTo("pdxClass");
-    assertThat(regionMapping.isPrimaryKeyInValue()).isEqualTo(true);
   }
 
   @Test


Mime
View raw message