using System;

using System.Linq;

using Microsoft.WindowsAzure.Storage; // Namespace for CloudStorageAccount

using Microsoft.WindowsAzure.Storage.Table; // Namespace for Table storage types

using System.Net;

​

​

namespace LoadDataIntoAzureTables

{

    public class Program

    {

        [assembly: SecurityRules(SecurityRuleSet.Level1)]

        public static void Main(string[] args)

        {

            // Retrieve the storage account from the connection string.

            CloudStorageAccount storageAccount = CloudStorageAccount.Parse("DefaultEndpointsProtocol=https;AccountName=petabytenosqldb;AccountKey=eq6G0sb0t1c5HRBideLQzOpAIYVyNSS8ta8f790dEF8EWWyHQ+/uRLbgndwgqiIa+OyQBsOJiBI/hNWBraUXdQ==");

            ServicePoint tableServicePoint = ServicePointManager.FindServicePoint(storageAccount.TableEndpoint);

            //This is a notorious issue that has affected many developers. By default, the value 

            //for the number of .NET HTTP connections is 2.

            //This implies that only 2 concurrent connections can be maintained. This manifests itself

            //as "underlying connection was closed..." when the number of concurrent requests is

            //greater than 2.

            tableServicePoint.ConnectionLimit = 1000;

            // Create the table client.

            CloudTableClient tableClient = storageAccount.CreateCloudTableClient();

            // Retrieve a reference to the table.

            CloudTable table = tableClient.GetTableReference("people");

            // Delete the table it if exists.

            //table.DeleteIfExists();

            //System.Threading.Thread.Sleep(15000);

            // Create the table if it doesn't exist.

            table.CreateIfNotExists();

            // Create a new customer entity.

            CustomerEntity customer1 = new CustomerEntity("Harp", "Walter");

            customer1.Email = "Walter@contoso.com";

            customer1.PhoneNumber = "425-555-0101";

            // Create the TableOperation object that inserts the customer entity.

            TableOperation insertOperation = TableOperation.Insert(customer1);

            // Execute the insert operation.

            table.Execute(insertOperation);

            // Create the batch operation.

            TableBatchOperation batchOperation = new TableBatchOperation();

            // Create a customer entity and add it to the table.

            CustomerEntity customer2 = new CustomerEntity("Smith", "Jeff");

            customer2.Email = "Jeff@contoso.com";

            customer2.PhoneNumber = "425-555-0104";

            // Create another customer entity and add it to the table.

            CustomerEntity customer3 = new CustomerEntity("Smith", "Ben");

            customer3.Email = "Ben@contoso.com";

            customer3.PhoneNumber = "425-555-0102";

            // Add both customer entities to the batch insert operation.

            batchOperation.Insert(customer2);

            batchOperation.Insert(customer3);

            // Execute the batch operation.

            table.ExecuteBatch(batchOperation);

            //Now Insert a Million

            // Create the batch operation.

            TableBatchOperation batchOperationMillion = new TableBatchOperation();

            for (int i = 0; i < 100; i++)

            {

                // Create a customer entity and add it to the table.

                CustomerEntity customerN = new CustomerEntity("BATCH1", "FirstName" + i.ToString());

                customerN.Email = "Jeff" + i.ToString() + "@contoso.com";

                customerN.PhoneNumber = "425-555-0104";

                batchOperationMillion.Insert(customerN);

            }

​

            table.ExecuteBatch(batchOperationMillion);

            // Construct the query operation for all customer entities where PartitionKey="Smith".

            TableQuery<CustomerEntity> query = new TableQuery<CustomerEntity>();

            Console.WriteLine(query.Count());

            // Construct the query operation for all customer entities where PartitionKey="Smith".

            query = new TableQuery<CustomerEntity>().Where(TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, "Smith"));

            // Print the fields for each customer.

            foreach (CustomerEntity entity in table.ExecuteQuery(query))

            {

                Console.WriteLine("{0}, {1}\t{2}\t{3}", entity.PartitionKey, entity.RowKey, entity.Email, entity.PhoneNumber);

            }

​

            // Create a retrieve operation that takes a customer entity.

            TableOperation retrieveOperation = TableOperation.Retrieve<CustomerEntity>("Smith", "Ben");

            // Execute the operation.

            TableResult retrievedResult = table.Execute(retrieveOperation);

            // Assign the result to a CustomerEntity object.

            CustomerEntity updateEntity = (CustomerEntity)retrievedResult.Result;

            if (updateEntity != null)

            {

                // Change the phone number.

                updateEntity.PhoneNumber = "425-555-1234";

                // Create the InsertOrReplace TableOperation.

                TableOperation insertOrReplaceOperation = TableOperation.InsertOrReplace(updateEntity);

                // Execute the operation.

                table.Execute(insertOrReplaceOperation);

                Console.WriteLine("Entity was updated.");

            }

            else

                Console.WriteLine("Entity could not be retrieved.");

            // Define the query, and select only the Email property.

            TableQuery<DynamicTableEntity> projectionQuery = new TableQuery<DynamicTableEntity>().Select(new string[]

            {

            "Email"

            }

​

            );

            // Define an entity resolver to work with the entity after retrieval.

            EntityResolver<string> resolver = (pk, rk, ts, props, etag) => props.ContainsKey("Email") ? props["Email"].StringValue : null;

            foreach (string projectedEmail in table.ExecuteQuery(projectionQuery, resolver, null, null))

            {

                Console.WriteLine(projectedEmail);

            }

​

#region DELETE AND CHECK AGAIN

​

            // Create a retrieve operation that expects a customer entity.

            retrieveOperation = TableOperation.Retrieve<CustomerEntity>("Smith", "Ben");

            // Execute the operation.

            retrievedResult = table.Execute(retrieveOperation);

            // Assign the result to a CustomerEntity.

            CustomerEntity deleteEntity = (CustomerEntity)retrievedResult.Result;

            // Create the Delete TableOperation.

            if (deleteEntity != null)

            {

                TableOperation deleteOperation = TableOperation.Delete(deleteEntity);

                // Execute the operation.

                table.Execute(deleteOperation);

                Console.WriteLine("Entity deleted.");

            }

            else

                Console.WriteLine("Could not retrieve the entity.");

            // Construct the query operation for all customer entities where PartitionKey = "Smith".

            query = new TableQuery<CustomerEntity>(); //.Where(TableQuery.GenerateFilterCondition("PartitionKey", QueryComparisons.Equal, "Smith"));

            // Print the fields for each customer.

            foreach (CustomerEntity entity in table.ExecuteQuery(query))

            {

                Console.WriteLine("{0}, {1}\t{2}\t{3}", entity.PartitionKey, entity.RowKey, entity.Email, entity.PhoneNumber);

            }

#endregion

        }

​

        public class CustomerEntity : TableEntity

        {

            public CustomerEntity(string lastName, string firstName)

            {

                this.PartitionKey = lastName;

                this.RowKey = firstName;

            }

​

            public CustomerEntity()

            {

            }

​

            public string Email

            {

                get;

                set;

            }

​

            public string PhoneNumber

            {

                get;

                set;

            }

        }

    }

}