Azure Tables Sync and Async Code Snippets

sdk/tables/azure-data-tables/pom.xml

@@ -49,14 +49,26 @@ Licensed under the MIT License.
     </dependency>
     <dependency>
       <groupId>org.junit.jupiter</groupId>
-      <artifactId>junit-jupiter</artifactId>
-      <version>5.6.2</version> <!-- {x-version-update;org.junit.jupiter:junit-jupiter;external_dependency} -->
+      <artifactId>junit-jupiter-api</artifactId>
+      <version>5.6.2</version> <!-- {x-version-update;org.junit.jupiter:junit-jupiter-api;external_dependency} -->
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.junit.jupiter</groupId>
+      <artifactId>junit-jupiter-engine</artifactId>
+      <version>5.6.2</version> <!-- {x-version-update;org.junit.jupiter:junit-jupiter-engine;external_dependency} -->
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.junit.jupiter</groupId>
+      <artifactId>junit-jupiter-params</artifactId>
+      <version>5.6.2</version> <!-- {x-version-update;org.junit.jupiter:junit-jupiter-params;external_dependency} -->
       <scope>test</scope>
     </dependency>
     <dependency>
       <groupId>io.projectreactor</groupId>
       <artifactId>reactor-test</artifactId>
-      <version>3.3.5.RELEASE</version>  <!-- {x-version-update;io.projectreactor:reactor-test;external_dependency} -->
+      <version>3.3.5.RELEASE</version> <!-- {x-version-update;io.projectreactor:reactor-test;external_dependency} -->
       <scope>test</scope>
     </dependency>
     <dependency>
@@ -65,6 +77,12 @@ Licensed under the MIT License.
       <version>1.3.1</version> <!-- {x-version-update;com.azure:azure-core-test;dependency} -->
       <scope>test</scope>
     </dependency>
+    <dependency>
+      <groupId>org.mockito</groupId>
+      <artifactId>mockito-core</artifactId>
+      <version>3.0.0</version> <!-- {x-version-update;org.mockito:mockito-core;external_dependency} -->
+      <scope>test</scope>
+    </dependency>
   </dependencies>
 
   <build>

sdk/tables/azure-data-tables/src/main/java/com/azure/data/tables/AzureTable.java

@@ -0,0 +1,31 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+package com.azure.data.tables;
+
+/**
+ * class for a table object
+ */
+public class AzureTable {
+    private final String name;
+
+    AzureTable(String name) {
+        this.name = name;
+    }
+
+    /**
+     * returns the name of this table
+     *
+     * @return table name
+     */
+    public String getName() {
+        return name;
+    }
+
+    /**
+     * returns the associated table client or null if it doesn't exist
+     * @return the associated table client
+     */
+    public TableClient getClient() {
+        return null;
+    }
+}

sdk/tables/azure-data-tables/src/main/java/com/azure/data/tables/QueryOptions.java

@@ -0,0 +1,79 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+package com.azure.data.tables;
+
+import com.azure.core.annotation.Fluent;
+
+/**
+ * helps construct a query
+ */
+@Fluent
+public final class QueryOptions {
+    private Integer top;
+    private String select;
+    private String filter;
+
+    /**
+     * Get the top property: Maximum number of records to return.
+     *
+     * @return the top value.
+     */
+    public Integer getTop() {
+        return this.top;
+    }
+
+    /**
+     * Set the top property: Maximum number of records to return.
+     *
+     * @param top the top value to set.
+     * @return the QueryOptions object itself.
+     */
+    public QueryOptions setTop(Integer top) {
+        this.top = top;
+        return this;
+    }
+
+    /**
+     * Get the select property: Select expression using OData notation. Limits the columns on each record to just those
+     * requested, e.g. "$select=PolicyAssignmentId, ResourceId".
+     *
+     * @return the select value.
+     */
+    public String getSelect() {
+        return this.select;
+    }
+
+    /**
+     * Set the select property: Select expression using OData notation. Limits the columns on each record to just those
+     * requested, e.g. "$select=PolicyAssignmentId, ResourceId".
+     *
+     * @param select the select value to set.
+     * @return the QueryOptions object itself.
+     */
+    public QueryOptions setSelect(String select) {
+        this.select = select;
+        return this;
+    }
+
+    /**
+     * Get the filter property: OData filter expression.
+     *
+     * @return the filter value.
+     */
+    public String getFilter() {
+        return this.filter;
+    }
+
+    /**
+     * Set the filter property: OData filter expression.
+     *
+     * @param filter the filter value to set.
+     * @return the QueryOptions object itself.
+     */
+    public QueryOptions setFilter(String filter) {
+        this.filter = filter;
+        return this;
+    }
+}
+

sdk/tables/azure-data-tables/src/main/java/com/azure/data/tables/TableAsyncClient.java

@@ -0,0 +1,106 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+package com.azure.data.tables;
+
+import com.azure.core.annotation.ServiceClient;
+import com.azure.core.http.rest.PagedFlux;
+import java.util.Map;
+import reactor.core.publisher.Mono;
+
+/**
+ * class for the table async client
+ */
+@ServiceClient(
+    builder = TableClientBuilder.class,
+    isAsync = true)
+public class TableAsyncClient {
+    private final String tableName;
+
+    TableAsyncClient(String tableName) {
+        this.tableName = tableName;
+    }
+
+    /**
+     * Queries and returns entities in the given table using the select and filter strings
+     *
+     * @param queryOptions the odata query object
+     * @return a paged flux of all the entity which fit this criteria
+     */
+    public PagedFlux<TableEntity> queryEntities(QueryOptions queryOptions) {
+        return null;
+    }
+
+    /**
+     * returns the entity with the given rowKey and ParitionKey
+     *
+     * @param rowKey the given row key
+     * @param partitionKey the given partition key
+     * @return an entity that fits the criteria
+     */
+    public Mono<TableEntity> get(String rowKey, String partitionKey) {
+        return null;
+    }
+
+    /**
+     * insert a TableEntity with the given properties and return that TableEntity. Property map must include
+     * rowKey and partitionKey
+     *
+     * @param tableEntityProperties a map of properties for the TableEntity
+     * @return the created TableEntity
+     */
+    public Mono<TableEntity> createEntity(Map<String, Object> tableEntityProperties) {
+        return Mono.empty();
+    }
+
+    /**
+     * based on Mode it either inserts or merges if exists or inserts or merges if exists
+     *
+     * @param updateMode type of upsert
+     * @param tableEntity entity to upsert
+     * @return void
+     */
+    public Mono<Void> upsertEntity(UpdateMode updateMode, TableEntity tableEntity) {
+        return Mono.empty();
+    }
+
+    /**
+     * based on Mode it either updates or fails if it does exists or replaces or fails if it does exists
+     *
+     * @param updateMode type of update
+     * @param tableEntity entity to update
+     * @return void
+     */
+    public Mono<Void> updateEntity(UpdateMode updateMode, TableEntity tableEntity) {
+        return Mono.empty();
+    }
+
+    /**
+     * deletes the given entity
+     *
+     * @param tableEntity entity to delete
+     * @return void
+     */
+    public Mono<Void> deleteEntity(TableEntity tableEntity) {
+        return Mono.empty();
+    }
+
+    /**
+     * deletes the given entity
+     *
+     * @param partitionKey the partition key
+     * @param rowKey the row key
+     * @return void
+     */
+    public Mono<Void> deleteEntity(String partitionKey, String rowKey) {
+        return Mono.empty();
+    }
+
+    /**
+     * returns the table name associated with the client
+     *
+     * @return table name
+     */
+    public String getTableName() {
+        return tableName;
+    }
+}

sdk/tables/azure-data-tables/src/main/java/com/azure/data/tables/TableClient.java

@@ -0,0 +1,99 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+package com.azure.data.tables;
+
+import com.azure.core.annotation.ServiceClient;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * sync client for table operations
+ */
+@ServiceClient(
+    builder = TableClientBuilder.class)
+public class TableClient {
+    final String tableName;
+
+    TableClient(String tableName) {
+        this.tableName = tableName;
+    }
+
+    /**
+     * Queries and returns entities in the given table using the select and filter strings
+     *
+     * @param queryOptions the odata query object
+     * @return a list of the tables that fit the query
+     */
+    public List<TableEntity> queryEntities(QueryOptions queryOptions) {
+        return null;
+    }
+
+    /**
+     * returns the entity with the given rowKey and ParitionKey
+     *
+     * @param rowKey the given row key
+     * @param partitionKey the given partition key
+     * @return an entity that fits the criteria
+     */
+    public TableEntity get(String rowKey, String partitionKey) {
+        return null;
+    }
+
+
+    /**
+     * insert a TableEntity with the given properties and return that TableEntity. Property map must include
+     * rowKey and partitionKey
+     *
+     * @param tableEntityProperties a map of properties for the TableEntity
+     * @return the created TableEntity
+     */
+    public TableEntity createEntity(Map<String, Object> tableEntityProperties) {
+        return null;
+    }
+
+    /**
+     * based on Mode it either inserts or merges if exists or inserts or merges if exists
+     *
+     * @param updateMode type of upsert
+     * @param tableEntity entity to upsert
+     */
+    public void upsertEntity(UpdateMode updateMode, TableEntity tableEntity) {
+    }
+
+    /**
+     * based on Mode it either updates or fails if it does exists or replaces or fails if it does exists
+     *
+     * @param updateMode type of update
+     * @param tableEntity entity to update
+     */
+    public void updateEntity(UpdateMode updateMode, TableEntity tableEntity) {
+    }
+
+    /**
+     * deletes the given entity
+     *
+     * @param tableEntity entity to delete
+     */
+    public void deleteEntity(TableEntity tableEntity) {
+    }
+
+    /**
+     * deletes the given entity
+     *
+     * @param partitionKey the partition key
+     * @param rowKey the row key
+     */
+    public void deleteEntity(String partitionKey, String rowKey) {
+    }
+
+    /**
+     * returns the table name associated with the client
+     *
+     * @return table name
+     */
+    public String getTableName() {
+        return this.tableName;
+    }
+
+
+}