Support of Couchbase for Spring Data

spring.couchbase.bootstrap-hosts=localhost
spring.couchbase.bucket.name=test

@Bean
    public Bucket campusBucket() throws Exception {
        return couchbaseCluster().openBucket("test2", "pwd");
    }
     @Bean
     public CouchbaseTemplate campusTemplate() throws Exception {
         CouchbaseTemplate template = new CouchbaseTemplate(
           couchbaseClusterInfo(), campusBucket(),
           mappingCouchbaseConverter(), translationService());
         template.setDefaultConsistency(getDefaultConsistency());
         return template;
     }

     @Override
     public void configureRepositoryOperationsMapping(
      RepositoryOperationsMapping baseMapping) {
      try {
       baseMapping.mapEntity(Campus.class, campusTemplate());
      } catch (Exception e) {
      }
     }

public class dbConfig extends AbstractCouchbaseConfiguration {
    
    @Value("${couchbase.bucketname}")
    private String bucketName;
    
    @Value("${couchbase.node}")
    private String node;
    
    @Value("${couchbase.password}")
    private String pswd;
    

    @Override
    protected String getBucketName() {
        this.bucketName = bucketName;
        return this.bucketName;
    }

    @Override
    protected String getBucketPassword() {
        this.pswd = pswd;
        return this.pswd;
    }

    @Override
    protected List<String> getBootstrapHosts(String x,String y) {
        // TODO Auto-generated method stub.
        this.node = node;
        List<String> nodes = new ArrayList<String>("one","two","three");
        nodes.add(this.node);
        return nodes;
    }

}

@GetMapping("/insert")
    public void insert() {
        CouchbaseOperations cop= context.getBean(campusRepo.class).getCouchbaseOperations();
        List<Campus> campus = new ArrayList<Campus>();
        campus.add(new Campus("SP234","Chennai",new Point(67.456,78.987)));
        campus.add(new Campus("SP456","Hyderabad",new Point(56.274,108.943)));
        cop.insert(campus);
        
    }

@GetMapping("/execute")
    public book executeAct() {
        CouchbaseOperations cop = context.getBean(bookRepo.class).getCouchbaseOperations();
        return cop.execute(new BucketCallback<book>() {
            public book doInBucket() throws java.util.concurrent.TimeoutException,ExecutionException, InterruptedException {
                book bk1 = new book("789UV","Spring-data","framework","Deepak Vohra");
                cop.save(bk1);
                return bk1;
            }});

@GetMapping("/insertObj")
    public void insertObj() {
        CouchbaseOperations cop= context.getBean(campusRepo.class).getCouchbaseOperations();
        Campus campus = new Campus("SP678","Trivandrum",new Point(67.456,78.987));
        cop.insert(campus);
        
    }

@PostMapping("/update")
    public void updateCustomer(@RequestBody Customer customer) {
        CouchbaseOperations cOperations = repository.getCouchbaseOperations();
        cOperations.update(customer);
    }

@GetMapping("/squery")
    public List<book> SVquery() {
        CouchbaseOperations cop = context.getBean(bookRepo.class).getCouchbaseOperations();
        return cop.findBySpatialView(SpatialViewQuery.from("book","all"),book.class );
    }

@GetMapping("/Vquery")
    public List<book> Vquery() {
        CouchbaseOperations cop = context.getBean(bookRepo.class).getCouchbaseOperations();
        return cop.findByView(ViewQuery.from("book","all"),book.class);
    }

@GetMapping("/removeC")
    public void remC() {
        CouchbaseOperations cop= context.getBean(campusRepo.class).getCouchbaseOperations();
        List<Campus> campus = new ArrayList<Campus>();
        campus.add(new Campus("SP89A","Mumbai",new Point(32.456,160.987)));
        campus.add(new Campus("SPABC","Kolkata",new Point(90.274,186.943)));
        cop.remove(campus);
    }

@GetMapping("/deletebyname/{name}")
    public void deletebyname(@PathVariable(required = true) String name) {
        List<Customer> customers = repository.findByName(name);
        repository.deleteAll(customers);
    }

@GetMapping("/delete/{id}")
    public void delete(@PathVariable(required = true) int id) {
        Optional<Customer> customer = repository.findById(id);
        repository.delete(customer.get());
    }

@N1qlPrimaryIndexed
@ViewIndexed(designDoc = "building")
public interface BuildingRepository extends CouchbaseRepository<Building, String> {

    List<Building> findByCompanyId(String companyId);

    Page<Building> findByCompanyIdAndNameLikeOrderByName(String companyId, String name, Pageable pageable);
}

@N1qlPrimaryIndexed
@ViewIndexed(designDoc = "building")
public interface BuildingRepository extends CouchbaseRepository<Building, String> {

    List<Building> findByCompanyId(String companyId);

    Page<Building> findByCompanyIdAndNameLikeOrderByName(String companyId, String name, Pageable pageable);

    @Query("#{#n1ql.selectEntity} where #{#n1ql.filter} and companyId = $1 and $2 within #{#n1ql.bucket}")
    Building findByCompanyAndAreaId(String companyId, String areaId);

    @Query("#{#n1ql.selectEntity} where #{#n1ql.filter} AND ANY phone IN phoneNumbers SATISFIES phone = $1 END")
    List<Building> findByPhoneNumber(String telephoneNumber);

    @Query("SELECT COUNT(*) AS count FROM #{#n1ql.bucket} WHERE #{#n1ql.filter} and companyId = $1")
    Long countBuildings(String companyId);
}