Skip to content

Commit d29e544

Browse files
committed
Update project settings and controller methods
Update AirlineRepository and AirlineService
1 parent c155e29 commit d29e544

File tree

4 files changed

+26
-22
lines changed

4 files changed

+26
-22
lines changed

settings.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
rootProject.name = 'example'
1+
rootProject.name = 'org.couchbase.quickstart.springdata'

src/main/java/org/couchbase/quickstart/springdata/controller/AirlineController.java

Lines changed: 12 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -63,18 +63,23 @@ public ResponseEntity<Page<Airline>> listAirlines(@RequestParam(defaultValue = "
6363
}
6464

6565
@GetMapping("/country/{country}")
66-
public ResponseEntity<Page<Airline>> listAirlinesByCountry(@PathVariable String country, @RequestParam(defaultValue = "0") int page,
66+
public ResponseEntity<Page<Airline>> listAirlinesByCountry(
67+
@PathVariable String country,
68+
@RequestParam(defaultValue = "0") int page,
6769
@RequestParam(defaultValue = "10") int size) {
68-
Page<Airline> airlines = airlineService.findByCountry(country,PageRequest.of(page, size));
70+
Page<Airline> airlines = airlineService.findByCountry(country, PageRequest.of(page, size));
6971
return new ResponseEntity<>(airlines, HttpStatus.OK);
7072
}
7173

7274
@GetMapping("/destination/{destinationAirport}")
73-
public ResponseEntity<Page<Airline>> listAirlinesByDestinationAirport(@RequestParam(defaultValue = "0") int page,
74-
@RequestParam(defaultValue = "10") int size, @PathVariable String destinationAirport) {
75-
Page<Airline> airlines = airlineService.findByDestinationAirport(PageRequest.of(page, size),
76-
destinationAirport);
75+
public ResponseEntity<Page<Airline>> listAirlinesByDestinationAirport(
76+
@PathVariable String destinationAirport,
77+
@RequestParam(defaultValue = "0") int page,
78+
@RequestParam(defaultValue = "10") int size) {
79+
80+
Page<Airline> airlines = airlineService.findByDestinationAirport(destinationAirport,
81+
PageRequest.of(page, size));
82+
7783
return new ResponseEntity<>(airlines, HttpStatus.OK);
7884
}
79-
8085
}

src/main/java/org/couchbase/quickstart/springdata/repository/AirlineRepository.java

Lines changed: 11 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package org.couchbase.quickstart.springdata.repository;
22

3-
43
import org.couchbase.quickstart.springdata.model.Airline;
54
import org.springframework.data.couchbase.repository.Collection;
65
import org.springframework.data.couchbase.repository.CouchbaseRepository;
@@ -21,28 +20,28 @@ public interface AirlineRepository extends CouchbaseRepository<Airline, String>
2120

2221
// Create the query to find all airlines
2322

24-
// @Query("SELECT META().id AS _ID, callsign, country, iata, icao, name, type FROM #{#n1ql.bucket}")
25-
// @Query("#{#n1ql.selectEntity} WHERE #{#n1ql.filter}")
23+
// @Query("SELECT META().id AS _ID, callsign, country, iata, icao, name, type
24+
// FROM #{#n1ql.bucket}")
25+
// @Query("#{#n1ql.selectEntity} WHERE #{#n1ql.filter}")
2626
@Query("#{#n1ql.selectEntity}")
2727
Page<Airline> findAll(Pageable pageable);
2828

29-
// @Query("SELECT META().id AS _ID, callsign, country, iata, icao, name, type FROM #{#n1ql.bucket} AND country = 'United States'")
29+
// @Query("SELECT META().id AS _ID, callsign, country, iata, icao, name, type
30+
// FROM #{#n1ql.bucket} AND country = 'United States'")
3031
@Query("#{#n1ql.selectEntity} WHERE country = $1")
3132
Page<Airline> findByCountry(String country, Pageable pageable);
3233

33-
// @Query("#{#n1ql.selectEntity} FROM (SELECT DISTINCT META(airline).id AS airlineId FROM route " +
34-
// "JOIN airline ON route.airlineid = META(airline).id " +
35-
// "WHERE route.destinationairport = $1) AS subquery " +
36-
// "JOIN #{#n1ql.bucket} AS air ON META(air).id = subquery.airlineId")
34+
// @Query("#{#n1ql.selectEntity} FROM (SELECT DISTINCT META(airline).id AS
35+
// airlineId FROM route " +
36+
// "JOIN airline ON route.airlineid = META(airline).id " +
37+
// "WHERE route.destinationairport = $1) AS subquery " +
38+
// "JOIN #{#n1ql.bucket} AS air ON META(air).id = subquery.airlineId")
3739

3840
@Query("SELECT META(air).id AS __id, air.callsign, air.country, air.iata, air.icao, air.id, air.name, air.type " +
3941
"FROM (SELECT DISTINCT META(airline).id AS airlineId FROM route " +
4042
"JOIN airline ON route.airlineid = META(airline).id " +
4143
"WHERE route.destinationairport = 'MRS') AS subquery " +
4244
"JOIN #{#n1ql.bucket} AS air ON META(air).id = subquery.airlineId")
43-
Page<Airline> findByDestinationAirport(Pageable pageable, String destinationAirport);
44-
45-
46-
45+
Page<Airline> findByDestinationAirport(String destinationAirport, Pageable pageable);
4746

4847
}

src/main/java/org/couchbase/quickstart/springdata/services/AirlineService.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -46,8 +46,8 @@ public Page<Airline> findByCountry(String country, Pageable pageable) {
4646
return airlineRepository.findByCountry(country,pageable);
4747
}
4848

49-
public Page<Airline> findByDestinationAirport(Pageable pageable,String destinationAirport) {
50-
return airlineRepository.findByDestinationAirport(pageable,destinationAirport);
49+
public Page<Airline> findByDestinationAirport(String destinationAirport, Pageable pageable) {
50+
return airlineRepository.findByDestinationAirport(destinationAirport, pageable);
5151
}
5252

5353
}

0 commit comments

Comments
 (0)