Support of Couchbase for .NET

class Program
{        
    private static Cluster cluster_1 = new Cluster();
        private const string bucket_name = "GeoBucket";
        private static IBucket geobucket;
        static void Main(string[] args)
        {       
            AuthenticateCluster();
            CreateBucket();
            CouchbaseOpenBucket();
    }
        private static void AuthenticateCluster()
        {            
            Console.WriteLine("Cluster Created - Localhost");
            var authenticator = new PasswordAuthenticator("Administrator", "123456");
            cluster_1.Authenticate(authenticator);
               
        }
        private static void CreateBucket()
        {            
            var cm = cluster_1.CreateManager();
            cm.CreateBucket(bucket_name);
    }
        private static void CouchbaseOpenBucket()
        {            
            geobucket = cluster_1.OpenBucket(bucket_name);
                        return;
        }
}

private static void TestClusterHelper4()        
{
            var config = new ClientConfiguration {
            Servers = new List<Uri>{
            new Uri("http://192.168.56.101:8091"),
            new Uri("http://192.168.56.102:8091")
            }  };
            ClusterHelper.Initialize(config);
            var chbucket = ClusterHelper.GetBucket("defaultWayt");        
}

private static void InsertDocumentInBucket()        
{
    geobucket.Insert(SetKarDoc());
    geobucket.Insert(SetGoaDoc());
    geobucket.Insert(SetBengaluruDoc());
    geobucket.Insert(SetChandigarhDoc());
}

private static void UpsertDocumentInBucket()        
{
    geobucket.Upsert(MysuruDoc());        
}

private static void GetDocumentsFromBucket()        
{
    var result = geobucket.GetDocument<dynamic>("Goa").Content;
}

private static void DeleteDocumentInBucket()        
{
    geobucket.Remove(MysuruDoc());
}        

class Program
{        
    private const string users_collection = "collection6";

    public async Task<Employees> GetTheDoc(Employees value)
        {
            var cluster4 = await Cluster.ConnectAsync("couchbase://localhost", "adm", "jim753");
            var bucket = await cluster4.BucketAsync("NewBucket");

            // get a user-defined collection reference
            var scope = await bucket.ScopeAsync("tenant_agent_00");
            var collection = await scope.CollectionAsync(users_collection);
            
            var collection_in_default_scope = await bucket.CollectionAsync("bookings");
        }
}

//create
        public async Task<Employees> PostEmployee(ICluster cluster3, Employees value)
        {
            var bucket = await cluster3.BucketAsync(samplebucket);
            var collection = bucket.DefaultCollection();
            
            // You can access multiple buckets using the same Cluster object.
            var anotherBucket = await cluster3.BucketAsync("AnotherBucket");
            
            // You can access collections other than the default
            var customerC = anotherBucket.Scope("customer-c");
            var trains = customerC.Collection("trains");
            
            int idvalue = value.id;
            var collectiondataa= await trains.InsertAsync( idvalue.ToString(),value );
            if (collectiondataa == null)
            {
                logger.LogError("Error in creating");
            }
            return null;
        }

//update
        public async Task<Employees> OnlyUpdateEmployee(ICluster cluster_new_2, Employees value)
        {
            var bucket = await cluster_new_2.BucketAsync("SmallBucket");
            var collection = bucket.DefaultCollection();
            
            // You can access multiple buckets using the same Cluster object.
            var anotherBucket = await cluster_new_2.BucketAsync("ShiningBucket");
            
            // You can access collections other than the default
            var customerD = anotherBucket.Scope("customer-D");
            var bikes = customerD.Collection("bikes");
            
            int idvalue = value.id;
            var collectiondataa= await bikes.ReplaceAsync( idvalue.ToString(),value );
            if (collectiondataa == null)
            {
                logger.LogError("Error in creating");
            }
            return null;
        }

//get
        public async Task<Employees> GetTheDoc(ICluster cluster4, Employees value)
        {
            var bucket = await cluster4.BucketAsync(newbucket);

            // get a user-defined collection reference
            var scope = await bucket.ScopeAsync("tenant_agent_00");
            var collection = await scope.CollectionAsync(users_collection);
            
            var collection_in_default_scope = await bucket.CollectionAsync("bookings");

            // Get Document
            var getResult = await collection.GetAsync("my-document-key");
        }

public async Task<Employees> DeleteEmployeeById(ICluster cluster1, int id)
        {
            try
            {
                var bucket = await cluster1.BucketAsync("EmployeesBucket");
            
                // You can access collections other than the default
                var customer10 = bucket.Scope("customer-10");
                var bluecolour = customer10.Collection("bluecolour");
           
                int idvalue = value.id;
                var collectiondataa = await bluecolour.RemoveAsync( idvalue.ToString() );
                if (collectiondataa == null)
                {
                    logger.LogError("Error in creating");
                }
                return null;
            }
            catch (BucketNotFoundException)
            {
                logger.LogError("Bucket not found");
                throw;
            }
        
        }      

private static void QueryBucketUsingN1QL()        
{
    var create_index = "CREATE PRIMARY INDEX ON " + bucket_name;
    geobucket.Query<dynamic>(create_index);
    var queryResult = geobucket.Query<dynamic>("SELECT name, state FROM GeoBucket WHERE type = \'city\' and capital=\'Yes\'"); 
    foreach (var row in queryResult.Rows)
        Console.WriteLine(row);
 }

public async Task<List<Employees>> GetEmployees(ICluster cluster_query)
        {
            try
            {
                var queryResult = await cluster_query.QueryAsync<Employees>("SELECT username,name,email,age,location,srccs,phoneNumber,salary,skill,managerName,address,id FROM Employees ", new Couchbase.Query.QueryOptions());
                var queryResult2 = await cluster_query.QueryAsync<Employees>("UPDATE cars SET door = red, window = transparent, WHERE door = blue; ", new Couchbase.Query.QueryOptions());
                List<Employees> empList = new List<Employees>();

                await foreach (var row in queryResult)
                {
                    empList.Add(row);
                }

                return empList;

            }
            catch (IndexFailureException)
            {
                logger.LogError("Bucket not found");
                throw;
            }
           

        }

public static void LookupInMethod2( string id)
{           var builder = geobucket.LookupIn<dynamic>(id).
                Get("type").
                Get("country").
                Exists("notfound");       
}

public static void SubDocMisc(string id, string path, string replace_path, object value)
{
    geobucket.MutateIn<dynamic>(id).
        Remove(path).
        Replace(replace_path, value).
        Execute();
}

static void Increment(IBucket bucket1, string key)
        {
            var result = bucket1.Increment(key);
            if (result.Success)
            {
                Console.WriteLine(result.Value);
            }
        }

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
    <startup> 
        <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5.2" />
    </startup>
  <configSections>
    <sectionGroup name="couchbaseClients">
      <section name="couchbase" type="Couchbase.Configuration.Client.Providers.CouchbaseClientSection, Couchbase.NetClient" />
    </sectionGroup>
  </configSections>
  <couchbaseClients>
    <couchbase username="Administrator" password="123456">
      <servers>
        <add uri="http://192.168.56.101:8091"></add>
        </servers>
      <buckets>
        <add name="mybucket"></add>
        <add name="mybucket2"></add>
      </buckets>
    </couchbase>
  </couchbaseClients>
</configuration>