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);
}