more naming updates

Author: tpellissier

README.md

@@ -104,7 +104,7 @@ The SDK provides a simple, pythonic interface for Dataverse operations:
 | **Bulk Operations** | Efficient bulk processing for multiple records with automatic optimization |
 | **Paging** | Automatic handling of large result sets with iterators |
 | **Structured Errors** | Detailed exception hierarchy with retry guidance and diagnostic information |
-| **Customization prefix values** | Custom tables and columns require a customization prefix values to be included for all operations (e.g., `"new_Title"`, not `"Title"`). See: [Table definitions in Microsoft Dataverse](https://learn.microsoft.com/en-us/power-apps/developer/data-platform/entity-metadata) |
+| **Customization prefix values** | Custom tables and columns require a customization prefix value to be included for all operations (e.g., `"new_Title"`, not `"Title"`). See: [Table definitions in Microsoft Dataverse](https://learn.microsoft.com/en-us/power-apps/developer/data-platform/entity-metadata) |
 
 ## Examples
 

examples/advanced/walkthrough.py

@@ -80,14 +80,14 @@ def main():
         print(f"  Entity Set: {table_info.get('entity_set_name')}")
     else:
         log_call(f"client.create_table('{table_name}', schema={{...}})")
-        schema = {
+        columns = {
             "new_Title": "string",
             "new_Quantity": "int",
             "new_Amount": "decimal",
             "new_Completed": "bool",
             "new_Priority": Priority
         }
-        table_info = client.create_table(table_name, schema)
+        table_info = client.create_table(table_name, columns)
         print(f"✓ Created table: {table_info.get('table_schema_name')}")
         print(f"  Columns created: {', '.join(table_info.get('columns_created', []))}")
 

examples/basic/functional_testing.py

@@ -96,7 +96,7 @@ def ensure_test_table(client: DataverseClient) -> Dict[str, Any]:
         table_info = client.create_table(
             table_schema_name,
             primary_column_schema_name="test_name",
-            schema=
+            columns=
             {
                 "test_description": "string",   # Description field
                 "test_count": "int",            # Integer field

src/PowerPlatform/Dataverse/client.py

@@ -134,7 +134,7 @@ def create(self, table_schema_name: str, records: Union[Dict[str, Any], List[Dic
                 print(f"Created {len(ids)} accounts")
         """
         od = self._get_odata()
-        entity_set = od._entity_set_from_logical(table_schema_name)
+        entity_set = od._entity_set_from_schema_name(table_schema_name)
         if isinstance(records, dict):
             rid = od._create(entity_set, table_schema_name, records)
             # _create returns str on single input
@@ -420,7 +420,7 @@ def get_table_info(self, table_schema_name: str) -> Optional[Dict[str, Any]]:
     def create_table(
         self,
         table_schema_name: str,
-        schema: Dict[str, Any],
+        columns: Dict[str, Any],
         solution_unique_name: Optional[str] = None,
         primary_column_schema_name: Optional[str] = None,
     ) -> Dict[str, Any]:
@@ -491,7 +491,7 @@ class ItemStatus(IntEnum):
         """
         return self._get_odata()._create_table(
             table_schema_name,
-            schema,
+            columns,
             solution_unique_name,
             primary_column_schema_name,
         )
@@ -662,7 +662,7 @@ def upload_file(
                 )
         """
         od = self._get_odata()
-        entity_set = od._entity_set_from_logical(table_schema_name)
+        entity_set = od._entity_set_from_schema_name(table_schema_name)
         od.upload_file(
             entity_set,
             record_id,

src/PowerPlatform/Dataverse/data/odata.py

@@ -278,7 +278,7 @@ def _primary_id_attr(self, table_schema_name: str) -> str:
         if pid:
             return pid
         # Resolve metadata (populates _logical_primaryid_cache or raises if table_schema_name unknown)
-        self._entity_set_from_logical(table_schema_name)
+        self._entity_set_from_schema_name(table_schema_name)
         pid2 = self._logical_primaryid_cache.get(cache_key)
         if pid2:
             return pid2
@@ -303,7 +303,7 @@ def _update_by_ids(self, table_schema_name: str, ids: List[str], changes: Union[
         if not ids:
             return None
         pk_attr = self._primary_id_attr(table_schema_name)
-        entity_set = self._entity_set_from_logical(table_schema_name)
+        entity_set = self._entity_set_from_schema_name(table_schema_name)
         if isinstance(changes, dict):
             batch = [{pk_attr: rid, **changes} for rid in ids]
             self._update_multiple(entity_set, table_schema_name, batch)
@@ -420,7 +420,7 @@ def _update(self, table_schema_name: str, key: str, data: Dict[str, Any]) -> Non
         # Lowercase all keys to match Dataverse LogicalName expectations
         data = self._lowercase_keys(data)
         data = self._convert_labels_to_ints(table_schema_name, data)
-        entity_set = self._entity_set_from_logical(table_schema_name)
+        entity_set = self._entity_set_from_schema_name(table_schema_name)
         url = f"{self.api}/{entity_set}{self._format_key(key)}"
         r = self._request("patch", url, headers={"If-Match": "*"}, json=data)
 
@@ -481,7 +481,7 @@ def _update_multiple(self, entity_set: str, table_schema_name: str, records: Lis
 
     def _delete(self, table_schema_name: str, key: str) -> None:
         """Delete a record by GUID or alternate key."""
-        entity_set = self._entity_set_from_logical(table_schema_name)
+        entity_set = self._entity_set_from_schema_name(table_schema_name)
         url = f"{self.api}/{entity_set}{self._format_key(key)}"
         self._request("delete", url, headers={"If-Match": "*"})
 
@@ -501,7 +501,7 @@ def _get(self, table_schema_name: str, key: str, select: Optional[str] = None) -
         if select:
             # Lowercase column names for case-insensitive matching
             params["$select"] = select.lower()
-        entity_set = self._entity_set_from_logical(table_schema_name)
+        entity_set = self._entity_set_from_schema_name(table_schema_name)
         url = f"{self.api}/{entity_set}{self._format_key(key)}"
         r = self._request("get", url, params=params)
         return r.json()
@@ -557,7 +557,7 @@ def _do_request(url: str, *, params: Optional[Dict[str, Any]] = None) -> Dict[st
             except ValueError:
                 return {}
 
-        entity_set = self._entity_set_from_logical(table_schema_name)
+        entity_set = self._entity_set_from_schema_name(table_schema_name)
         base_url = f"{self.api}/{entity_set}"
         params: Dict[str, Any] = {}
         if select:
@@ -627,7 +627,7 @@ def _query_sql(self, sql: str) -> list[dict[str, Any]]:
         # Extract logical table name via helper (robust to identifiers ending with 'from')
         logical = self._extract_logical_table(sql)
 
-        entity_set = self._entity_set_from_logical(logical)
+        entity_set = self._entity_set_from_schema_name(logical)
         # Issue GET /{entity_set}?sql=<query>
         url = f"{self.api}/{entity_set}"
         params = {"sql": sql}
@@ -666,7 +666,7 @@ def _extract_logical_table(sql: str) -> str:
         return m.group(1).lower()
 
     # ---------------------- Entity set resolution -----------------------
-    def _entity_set_from_logical(self, logical: str) -> str:
+    def _entity_set_from_schema_name(self, logical: str) -> str:
         """Resolve entity set name (plural) from a logical (singular) name using metadata.
 
         Caches results for subsequent queries. Case-insensitive.

tests/unit/data/test_logical_crud.py

@@ -77,7 +77,7 @@ def test_single_create_update_delete_get():
         (204, {}, {}),  # delete
     ]
     c = TestableClient(responses)
-    entity_set = c._entity_set_from_logical("account")
+    entity_set = c._entity_set_from_schema_name("account")
     rid = c._create(entity_set, "account", {"name": "Acme"})
     assert rid == guid
     rec = c._get("account", rid, select="accountid,name")
@@ -97,7 +97,7 @@ def test_bulk_create_and_update():
         (204, {}, {}),  # UpdateMultiple 1:1
     ]
     c = TestableClient(responses)
-    entity_set = c._entity_set_from_logical("account")
+    entity_set = c._entity_set_from_schema_name("account")
     ids = c._create_multiple(entity_set, "account", [{"name": "A"}, {"name": "B"}])
     assert ids == [g1, g2]
     c._update_by_ids("account", ids, {"statecode": 1})  # broadcast
@@ -122,4 +122,4 @@ def test_unknown_logical_name_raises():
     ]
     c = TestableClient(responses)
     with pytest.raises(MetadataError):
-        c._entity_set_from_logical("nonexistent")
+        c._entity_set_from_schema_name("nonexistent")