Airline join queries working + Capella Working

Author: teetangh

src/main/java/org/couchbase/quickstart/springboot/Application.java

@@ -7,8 +7,8 @@
 
 import lombok.extern.slf4j.Slf4j;
 
-@SpringBootApplication(exclude = SecurityAutoConfiguration.class, proxyBeanMethods = false)
 @Slf4j
+@SpringBootApplication(exclude = SecurityAutoConfiguration.class, proxyBeanMethods = false)
 public class Application implements CommandLineRunner {
 
     public static void main(String[] args) {

src/main/java/org/couchbase/quickstart/springboot/configs/DBProperties.java

@@ -17,7 +17,5 @@ public class DBProperties {
     private String password;
     @Value("${spring.couchbase.bucket.name}")
     private String bucketName;
-    @Value("${spring.couchbase.bucket.scope}")
-    private String scopeName;
 
 }

src/main/java/org/couchbase/quickstart/springboot/controllers/AirlineController.java

@@ -134,4 +134,17 @@ public ResponseEntity<List<Airline>> listAirlinesByCountry(@PathVariable String
             return new ResponseEntity<>(HttpStatus.INTERNAL_SERVER_ERROR);
         }
     }
+
+    @Operation(summary = "List all airlines by destination airport")
+    @GetMapping("/destination/{destinationAirport}")
+    public ResponseEntity<List<Airline>> listAirlinesByDestinationAirport(
+            @PathVariable String destinationAirport) {
+        try {
+            List<Airline> airlines = airlineService.listAirlinesByDestinationAirport(destinationAirport);
+            return new ResponseEntity<>(airlines, HttpStatus.OK);
+        } catch (Exception e) {
+            log.error(INTERNAL_SERVER_ERROR + ": " + e.getMessage());
+            return new ResponseEntity<>(HttpStatus.INTERNAL_SERVER_ERROR);
+        }
+    }
 }

src/main/java/org/couchbase/quickstart/springboot/repositories/AirlineRepositoryImpl.java

@@ -9,6 +9,7 @@
 import com.couchbase.client.java.Bucket;
 import com.couchbase.client.java.Cluster;
 import com.couchbase.client.java.Collection;
+import com.couchbase.client.java.json.JsonArray;
 import com.couchbase.client.java.json.JsonObject;
 import com.couchbase.client.java.query.QueryOptions;
 import com.couchbase.client.java.query.QueryScanConsistency;
@@ -74,15 +75,19 @@ public List<Airline> findByCountry(String country) {
 
     @Override
     public List<Airline> findByDestinationAirport(String destinationAirport) {
-        String statement = "SELECT air.callsign, air.country, air.iata, air.icao, air.id, air.name, air.type FROM (SELECT DISTINCT META(airline).id AS airlineId FROM `"
-                + dbProperties.getBucketName() + "`.`inventory`.`route` JOIN `" + dbProperties.getBucketName()
-                + "`.`inventory`.`airline` ON route.airlineid = META(airline).id WHERE route.destinationairport = "
-                + destinationAirport + ") AS subquery JOIN `" + dbProperties.getBucketName()
-                + "`.`inventory`.`airline` AS air ON META(air).id = subquery.airlineId";
-        return cluster
-                .query(statement,
-                        QueryOptions.queryOptions().scanConsistency(QueryScanConsistency.REQUEST_PLUS)
-                                .parameters(JsonObject.create().put("destinationAirport", destinationAirport)))
+        String statement = "SELECT air.callsign, air.country, air.iata, air.icao, air.id, air.name, air.type " +
+                "FROM (SELECT DISTINCT META(airline).id AS airlineId " +
+                "      FROM `" + dbProperties.getBucketName() + "`.`inventory`.`route` " +
+                "      JOIN `" + dbProperties.getBucketName() + "`.`inventory`.`airline` " +
+                "      ON route.airlineid = META(airline).id " +
+                "      WHERE route.destinationairport = $1) AS subquery " +
+                "JOIN `" + dbProperties.getBucketName() + "`.`inventory`.`airline` AS air " +
+                "ON META(air).id = subquery.airlineId";
+
+        return cluster.query(
+                statement,
+                QueryOptions.queryOptions().parameters(JsonArray.from(destinationAirport))
+                        .scanConsistency(QueryScanConsistency.REQUEST_PLUS))
                 .rowsAs(Airline.class);
     }
 

src/main/resources/application.properties

@@ -1,6 +1,5 @@
-spring.couchbase.bootstrap-hosts=localhost
+spring.couchbase.bootstrap-hosts=#######
 spring.couchbase.bucket.name=travel-sample
 spring.couchbase.bucket.user=kaustav
-spring.couchbase.bucket.scope=inventory
-spring.couchbase.bucket.password=password
-spring.mvc.pathmatch.matching-strategy=ANT_PATH_MATCHER
+spring.couchbase.bucket.password=#######
+spring.mvc.pathmatch.matching-strategy=ANT_PATH_MATCHER