Single-Collection Designs in MongoDB with Spring Data (Part 2)

1
package com.mongodb.devrel.gcr.aerodata;
2
3
import org.springframework.data.annotation.Id;
4
import org.springframework.data.mongodb.core.mapping.Document;
5
6
@Document(collection = "aeroData")
7
public abstract class AeroData {
8
    
9
    @Id
10
    public String id;
11
    public Integer recordType;
12
    
13
    //Getters and Setters...
14
    
15
}

1
package com.mongodb.devrel.gcr.aerodata;
2
3
import org.springframework.data.mongodb.repository.MongoRepository;
4
5
public interface AeroDataRepository extends MongoRepository<AeroData, String>{
6
7
}

1
package com.mongodb.devrel.gcr.aerodata;
2
3
import org.springframework.data.annotation.TypeAlias;
4
import org.springframework.data.mongodb.core.mapping.Document;
5
6
@Document(collection = "aeroData")
7
@TypeAlias("AirlineData")
8
public class Airline extends AeroData{
9
10
    public String airlineName;
11
    public String country;
12
    public String countryISO;
13
    public String callsign;
14
    public String website;
15
16
    public Airline(String id, String airlineName, String country, String countryISO, String callsign, String website) {
17
        this.id = id;
18
        this.airlineName = airlineName;
19
        this.country = country;
20
        this.countryISO = countryISO;
21
        this.callsign = callsign;
22
        this.website = website;
23
    }
24
25
    @Override
26
    public String toString() {
27
        return String.format(
28
            "Airline[id=%s, name='%s', country='%s (%s)', callsign='%s', website='%s']",
29
            id, airlineName, country, countryISO, callsign, website);
30
    }
31
32
}

1
package com.mongodb.devrel.gcr.aerodata;
2
3
import org.springframework.data.mongodb.repository.MongoRepository;
4
5
public interface AirlineRepository extends MongoRepository<Airline, String>{
6
7
}

1
package com.mongodb.devrel.gcr.aerodata;
2
3
import org.springframework.data.annotation.TypeAlias;
4
import org.springframework.data.mongodb.core.mapping.Document;
5
6
@Document(collection = "aeroData")
7
@TypeAlias("AircraftData")
8
public class Aircraft extends AeroData{
9
10
    public String tailNumber;
11
    public String manufacturer;
12
    public String model;
13
14
    public Aircraft(String id, String tailNumber, String manufacturer, String model) {
15
        this.id = id;
16
        this.tailNumber = tailNumber;
17
        this.manufacturer = manufacturer;
18
        this.model = model;
19
    }
20
21
    @Override
22
    public String toString() {
23
        return String.format(
24
            "Aircraft[id=%s, tailNumber='%s', manufacturer='%s', model='%s']",
25
            id, tailNumber, manufacturer, model);
26
    }
27
28
}

1
package com.mongodb.devrel.gcr.aerodata;
2
3
import org.springframework.data.mongodb.repository.MongoRepository;
4
5
public interface AircraftRepository extends MongoRepository<Aircraft, String>{
6
7
}

1
package com.mongodb.devrel.gcr.aerodata;
2
3
import java.util.Date;
4
import org.springframework.data.annotation.TypeAlias;
5
import org.springframework.data.mongodb.core.mapping.Document;
6
7
@Document(collection = "aeroData")
8
@TypeAlias("ADSBRecord")
9
public class ADSBRecord extends AeroData {
10
11
    public Integer altitude; 
12
    public Integer heading;
13
    public Integer speed;
14
    public Integer verticalSpeed;
15
    public Date timestamp;
16
    public GeoPoint geoPoint;
17
18
    public ADSBRecord(String id, Integer altitude, Integer heading, Integer speed, Integer verticalSpeed, Date timestamp, GeoPoint geoPoint) {
19
        this.id = id;
20
        this.altitude = altitude;
21
        this.heading = heading;
22
        this.speed = speed;
23
        this.verticalSpeed = verticalSpeed;
24
        this.timestamp = timestamp;
25
        this.geoPoint = geoPoint;
26
    }
27
28
    @Override
29
    public String toString() {
30
        return String.format(
31
            "ADSB[id=%s, altitude='%d', heading='%d', speed='%d', verticalSpeed='%d' timestamp='%tc', latitude='%f', longitude='%f']",
32
            id, altitude, heading, speed, verticalSpeed, timestamp, geoPoint == null ? null : geoPoint.coordinates[1], geoPoint == null ? null : geoPoint.coordinates[0]);
33
    }
34
}

1
package com.mongodb.devrel.gcr.aerodata;
2
3
import org.springframework.data.mongodb.repository.MongoRepository;
4
5
public interface ADSBRecordRepository extends MongoRepository<ADSBRecord, String>{
6
7
}

1
package com.mongodb.devrel.gcr.aerodata;
2
3
public class GeoPoint {
4
    public String type;
5
    public Double[] coordinates;
6
7
    //Getters and Setters...
8
}

1
spring.data.mongodb.uri=mongodb://myusername:mypassword@abc-c0-shard-00-00.ftspj.mongodb.net:27017,abc-c0-shard-00-01.ftspj.mongodb.net:27017,abc-c0-shard-00-02.ftspj.mongodb.net:27017/air_tracker?ssl=true&replicaSet=atlas-k9999h-shard-0&authSource=admin&retryWrites=true&w=majority

1
package com.mongodb.devrel.gcr.aerodata;
2
3
import java.util.Date;
4
import java.util.Optional;
5
import org.springframework.beans.factory.annotation.Autowired;
6
import org.springframework.boot.CommandLineRunner;
7
import org.springframework.boot.SpringApplication;
8
import org.springframework.boot.autoconfigure.SpringBootApplication;
9
10
@SpringBootApplication
11
public class AerodataApplication implements CommandLineRunner {
12
13
    @Autowired
14
    private AirlineRepository airlineRepo;
15
    
16
    @Autowired
17
    private AircraftRepository aircraftRepo;
18
    
19
    @Autowired
20
    private ADSBRecordRepository adsbRepo;
21
22
    public static void main(String[] args) {
23
        SpringApplication.run(AerodataApplication.class, args);
24
    }
25
26
    @Override
27
    public void run(String... args) throws Exception {
28
29
        // save an airline
30
        airlineRepo.save(new Airline("DAL", "Delta Air Lines", "United States", "US", "DELTA", "delta.com"));
31
        
32
        // add some aircraft aircraft
33
        aircraftRepo.save(new Aircraft("DAL_a93d7c", "N695CA", "Bombardier Inc", "CL-600-2D24"));
34
        aircraftRepo.save(new Aircraft("DAL_ab8379", "N8409N", "Bombardier Inc", "CL-600-2B19"));
35
        aircraftRepo.save(new Aircraft("DAL_a36f7e", "N8409N", "Airbus Industrie", "A319-114"));
36
        
37
        //Add some ADSB position reports
38
        Double[] coords1 = {55.991776, -4.776722};
39
        GeoPoint geoPoint = new GeoPoint(coords1);
40
        adsbRepo.save(new ADSBRecord("DAL_a36f7e_1", 38825, 319, 428, 1024, new Date(1656980617041l), geoPoint));
41
        Double[] coords2 = {55.994843, -4.781466};
42
        geoPoint = new GeoPoint(coords2);
43
        adsbRepo.save(new ADSBRecord("DAL_a36f7e_2", 38875, 319, 429, 1024, new Date(1656980618041l), geoPoint));
44
        Double[] coords3 = {55.99606, -4.783344};
45
        geoPoint = new GeoPoint(coords3);
46
        adsbRepo.save(new ADSBRecord("DAL_a36f7e_3", 38892, 319, 428, 1024, new Date(1656980619041l), geoPoint));        
47
                
48
49
        // fetch all airlines
50
        System.out.println("Airlines found with findAll():");
51
        System.out.println("-------------------------------");
52
        for (Airline airline : airlineRepo.findAll()) {
53
            System.out.println(airline);
54
        }
55
        // fetch a specific airline by ICAO ID
56
        System.out.println("Airline found with findById():");
57
        System.out.println("-------------------------------");
58
        Optional<Airline> airlineResponse = airlineRepo.findById("DAL");
59
        System.out.println(airlineResponse.get());
60
        
61
        System.out.println();
62
63
        // fetch all aircraft
64
        System.out.println("Aircraft found with findAll():");
65
        System.out.println("-------------------------------");
66
        for (Aircraft aircraft : aircraftRepo.findAll()) {
67
            System.out.println(aircraft);
68
        }
69
        // fetch a specific aircraft by ICAO ID
70
        System.out.println("Aircraft found with findById():");
71
        System.out.println("-------------------------------");
72
        Optional<Aircraft> aircraftResponse = aircraftRepo.findById("DAL_a36f7e");
73
        System.out.println(aircraftResponse.get());
74
        
75
        System.out.println();
76
        
77
        // fetch all adsb records
78
        System.out.println("ADSB records found with findAll():");
79
        System.out.println("-------------------------------");
80
        for (ADSBRecord adsb : adsbRepo.findAll()) {
81
            System.out.println(adsb);
82
        }
83
        // fetch a specific ADSB Record by ID
84
        System.out.println("ADSB Record found with findById():");
85
        System.out.println("-------------------------------");
86
        Optional<ADSBRecord> adsbResponse = adsbRepo.findById("DAL_a36f7e_1");
87
        System.out.println(adsbResponse.get());
88
        System.out.println();
89
        
90
    }
91
92
}

1
Airlines found with findAll():
2
-------------------------------
3
Airline[id=DAL, name='Delta Air Lines', country='United States (US)', callsign='DELTA', website='delta.com']
4
Airline[id=DAL_a93d7c, name='null', country='null (null)', callsign='null', website='null']
5
Airline[id=DAL_ab8379, name='null', country='null (null)', callsign='null', website='null']
6
Airline[id=DAL_a36f7e, name='null', country='null (null)', callsign='null', website='null']
7
Airline[id=DAL_a36f7e_1, name='null', country='null (null)', callsign='null', website='null']
8
Airline[id=DAL_a36f7e_2, name='null', country='null (null)', callsign='null', website='null']
9
Airline[id=DAL_a36f7e_3, name='null', country='null (null)', callsign='null', website='null']
10
Airline found with findById():
11
-------------------------------
12
Airline[id=DAL, name='Delta Air Lines', country='United States (US)', callsign='DELTA', website='delta.com']
13
14
Aircraft found with findAll():
15
-------------------------------
16
Aircraft[id=DAL, tailNumber='null', manufacturer='null', model='null']
17
Aircraft[id=DAL_a93d7c, tailNumber='N695CA', manufacturer='Bombardier Inc', model='CL-600-2D24']
18
Aircraft[id=DAL_ab8379, tailNumber='N8409N', manufacturer='Bombardier Inc', model='CL-600-2B19']
19
Aircraft[id=DAL_a36f7e, tailNumber='N8409N', manufacturer='Airbus Industrie', model='A319-114']
20
Aircraft[id=DAL_a36f7e_1, tailNumber='null', manufacturer='null', model='null']
21
Aircraft[id=DAL_a36f7e_2, tailNumber='null', manufacturer='null', model='null']
22
Aircraft[id=DAL_a36f7e_3, tailNumber='null', manufacturer='null', model='null']
23
Aircraft found with findById():
24
-------------------------------
25
Aircraft[id=DAL_a36f7e, tailNumber='N8409N', manufacturer='Airbus Industrie', model='A319-114']
26
27
ADSB records found with findAll():
28
-------------------------------
29
ADSB[id=DAL, altitude='null', heading='null', speed='null', verticalSpeed='null' timestamp='null', latitude='null', longitude='null']
30
ADSB[id=DAL_a93d7c, altitude='null', heading='null', speed='null', verticalSpeed='null' timestamp='null', latitude='null', longitude='null']
31
ADSB[id=DAL_ab8379, altitude='null', heading='null', speed='null', verticalSpeed='null' timestamp='null', latitude='null', longitude='null']
32
ADSB[id=DAL_a36f7e, altitude='null', heading='null', speed='null', verticalSpeed='null' timestamp='null', latitude='null', longitude='null']
33
ADSB[id=DAL_a36f7e_1, altitude='38825', heading='319', speed='428', verticalSpeed='1024' timestamp='Tue Jul 05 01:23:37 BST 2022', latitude='55.991776', longitude='-4.776722']
34
ADSB[id=DAL_a36f7e_2, altitude='38875', heading='319', speed='429', verticalSpeed='1024' timestamp='Tue Jul 05 01:23:38 BST 2022', latitude='55.994843', longitude='-4.781466']
35
ADSB[id=DAL_a36f7e_3, altitude='38892', heading='319', speed='428', verticalSpeed='1024' timestamp='Tue Jul 05 01:23:39 BST 2022', latitude='55.996060', longitude='-4.783344']
36
ADSB Record found with findById():
37
-------------------------------
38
ADSB[id=DAL_a36f7e_1, altitude='38825', heading='319', speed='428', verticalSpeed='1024' timestamp='Tue Jul 05 01:23:37 BST 2022', latitude='-4.776722', longitude='55.991776']

1
package com.mongodb.devrel.gcr.aerodata;
2
3
import java.util.List;
4
import java.util.Optional;
5
import org.springframework.data.mongodb.repository.MongoRepository;
6
import org.springframework.data.mongodb.repository.Query;
7
8
public interface AirlineRepository extends MongoRepository<Airline, String>{
9
    
10
    @Query("{_class: \"AirlineData\"}")
11
    List<Airline> findAllAirlines();
12
    
13
    @Query(value="{_id: /^?0/, _class: \"AirlineData\"}", sort = "{_id: 1}")
14
    Optional<Airline> findAirlineByIcaoAddr(String icaoAddr);
15
16
}

1
package com.mongodb.devrel.gcr.aerodata;
2
3
import java.util.List;
4
import org.springframework.data.mongodb.repository.MongoRepository;
5
import org.springframework.data.mongodb.repository.Query;
6
7
public interface AircraftRepository extends MongoRepository<Aircraft, String>{
8
    
9
    @Query("{_class: \"AircraftData\"}")
10
    List<Aircraft> findAllAircraft();
11
    
12
    @Query("{_id: /^?0/, _class: \"AircraftData\"}")
13
    List<Aircraft> findAircraftDataByIcaoAddr(String icaoAddr);
14
    
15
}

1
package com.mongodb.devrel.gcr.aerodata;
2
3
import java.util.List;
4
import org.springframework.data.mongodb.repository.MongoRepository;
5
import org.springframework.data.mongodb.repository.Query;
6
7
public interface ADSBRecordRepository extends MongoRepository<ADSBRecord, String>{
8
    
9
    @Query(value="{_class: \"ADSBRecord\"}",sort="{_id: 1}")
10
    List<ADSBRecord> findAllADSBRecords();
11
    
12
    @Query(value="{_id: /^?0/, _class: \"ADSBRecord\"}", sort = "{_id: 1}")
13
    List<ADSBRecord> findADSBDataByIcaoAddr(String icaoAddr);
14
    
15
}

1
package com.mongodb.devrel.gcr.aerodata;
2
3
import java.util.Date;
4
import java.util.Optional;
5
import org.springframework.beans.factory.annotation.Autowired;
6
import org.springframework.boot.CommandLineRunner;
7
import org.springframework.boot.SpringApplication;
8
import org.springframework.boot.autoconfigure.SpringBootApplication;
9
10
@SpringBootApplication
11
public class AerodataApplication implements CommandLineRunner {
12
13
    @Autowired
14
    private AirlineRepository airlineRepo;
15
    
16
    @Autowired
17
    private AircraftRepository aircraftRepo;
18
    
19
    @Autowired
20
    private ADSBRecordRepository adsbRepo;
21
22
    public static void main(String[] args) {
23
        SpringApplication.run(AerodataApplication.class, args);
24
    }
25
26
    @Override
27
    public void run(String... args) throws Exception {
28
29
        //Delete any records from a previous run;
30
        airlineRepo.deleteAll();
31
32
        // save an airline
33
        airlineRepo.save(new Airline("DAL", "Delta Air Lines", "United States", "US", "DELTA", "delta.com"));
34
        
35
        // add some aircraft aircraft
36
        aircraftRepo.save(new Aircraft("DAL_a93d7c", "N695CA", "Bombardier Inc", "CL-600-2D24"));
37
        aircraftRepo.save(new Aircraft("DAL_ab8379", "N8409N", "Bombardier Inc", "CL-600-2B19"));
38
        aircraftRepo.save(new Aircraft("DAL_a36f7e", "N8409N", "Airbus Industrie", "A319-114"));
39
        
40
        //Add some ADSB position reports
41
        Double[] coords1 = {-4.776722, 55.991776};
42
        GeoPoint geoPoint = new GeoPoint(coords1);
43
        adsbRepo.save(new ADSBRecord("DAL_a36f7e_1", 38825, 319, 428, 1024, new Date(1656980617041l), geoPoint));
44
        Double[] coords2 = {-4.781466, 55.994843};
45
        geoPoint = new GeoPoint(coords2);
46
        adsbRepo.save(new ADSBRecord("DAL_a36f7e_2", 38875, 319, 429, 1024, new Date(1656980618041l), geoPoint));
47
        Double[] coords3 = {-4.783344, 55.99606};
48
        geoPoint = new GeoPoint(coords3);
49
        adsbRepo.save(new ADSBRecord("DAL_a36f7e_3", 38892, 319, 428, 1024, new Date(1656980619041l), geoPoint));        
50
                
51
52
        // fetch all airlines
53
        System.out.println("Airlines found with findAllAirlines():");
54
        System.out.println("-------------------------------");
55
        for (Airline airline : airlineRepo.findAllAirlines()) {
56
            System.out.println(airline);
57
        }
58
        System.out.println();
59
        // fetch a specific airline by ICAO ID
60
        System.out.println("Airlines found with findAirlineByIcaoAddr(\"DAL\"):");
61
        System.out.println("-------------------------------");
62
        Optional<Airline> airlineResponse = airlineRepo.findAirlineByIcaoAddr("DAL");
63
        System.out.println(airlineResponse.get());
64
        
65
        System.out.println();
66
67
        // fetch all aircraft
68
        System.out.println("Aircraft found with findAllAircraft():");
69
        System.out.println("-------------------------------");
70
        for (Aircraft aircraft : aircraftRepo.findAllAircraft()) {
71
            System.out.println(aircraft);
72
        }
73
        System.out.println();
74
        // fetch Aircraft Documents specific to airline "DAL"
75
        System.out.println("Aircraft found with findAircraftDataByIcaoAddr(\"DAL\"):");
76
        System.out.println("-------------------------------");
77
        for (Aircraft aircraft : aircraftRepo.findAircraftDataByIcaoAddr("DAL")) {
78
            System.out.println(aircraft);
79
        }
80
        
81
        System.out.println();
82
        
83
        // fetch Aircraft Documents specific to aircraft "a36f7e"
84
        System.out.println("Aircraft found with findAircraftDataByIcaoAddr(\"DAL_a36f7e\"):");
85
        System.out.println("-------------------------------");
86
        for (Aircraft aircraft : aircraftRepo.findAircraftDataByIcaoAddr("DAL_a36f7e")) {
87
            System.out.println(aircraft);
88
        }
89
        
90
        System.out.println();
91
        
92
        // fetch all adsb records
93
        System.out.println("ADSB records found with findAllADSBRecords():");
94
        System.out.println("-------------------------------");
95
        for (ADSBRecord adsb : adsbRepo.findAllADSBRecords()) {
96
            System.out.println(adsb);
97
        }
98
        System.out.println();
99
        // fetch ADSB Documents specific to airline "DAL"
100
        System.out.println("ADSB Documents found with findADSBDataByIcaoAddr(\"DAL\"):");
101
        System.out.println("-------------------------------");
102
        for (ADSBRecord adsb : adsbRepo.findADSBDataByIcaoAddr("DAL")) {
103
            System.out.println(adsb);
104
        }
105
        
106
        System.out.println();
107
        
108
        // fetch ADSB Documents specific to aircraft "a36f7e"
109
        System.out.println("ADSB Documents found with findADSBDataByIcaoAddr(\"DAL_a36f7e\"):");
110
        System.out.println("-------------------------------");
111
        for (ADSBRecord adsb : adsbRepo.findADSBDataByIcaoAddr("DAL_a36f7e")) {
112
            System.out.println(adsb);
113
        }
114
    }
115
}

1
Airlines found with findAllAirlines():
2
-------------------------------
3
Airline[id=DAL, name='Delta Air Lines', country='United States (US)', callsign='DELTA', website='delta.com']
4
5
Airlines found with findAirlineByIcaoAddr("DAL"):
6
-------------------------------
7
Airline[id=DAL, name='Delta Air Lines', country='United States (US)', callsign='DELTA', website='delta.com']
8
9
Aircraft found with findAllAircraft():
10
-------------------------------
11
Aircraft[id=DAL_a93d7c, tailNumber='N695CA', manufacturer='Bombardier Inc', model='CL-600-2D24']
12
Aircraft[id=DAL_ab8379, tailNumber='N8409N', manufacturer='Bombardier Inc', model='CL-600-2B19']
13
Aircraft[id=DAL_a36f7e, tailNumber='N8409N', manufacturer='Airbus Industrie', model='A319-114']
14
15
Aircraft found with findAircraftDataByIcaoAddr("DAL"):
16
-------------------------------
17
Aircraft[id=DAL_a36f7e, tailNumber='N8409N', manufacturer='Airbus Industrie', model='A319-114']
18
Aircraft[id=DAL_a93d7c, tailNumber='N695CA', manufacturer='Bombardier Inc', model='CL-600-2D24']
19
Aircraft[id=DAL_ab8379, tailNumber='N8409N', manufacturer='Bombardier Inc', model='CL-600-2B19']
20
21
Aircraft found with findAircraftDataByIcaoAddr("DAL_a36f7e"):
22
-------------------------------
23
Aircraft[id=DAL_a36f7e, tailNumber='N8409N', manufacturer='Airbus Industrie', model='A319-114']
24
25
ADSB records found with findAllADSBRecords():
26
-------------------------------
27
ADSB[id=DAL_a36f7e_1, altitude='38825', heading='319', speed='428', verticalSpeed='1024' timestamp='Tue Jul 05 01:23:37 BST 2022', latitude='55.991776', longitude='-4.776722']
28
ADSB[id=DAL_a36f7e_2, altitude='38875', heading='319', speed='429', verticalSpeed='1024' timestamp='Tue Jul 05 01:23:38 BST 2022', latitude='55.994843', longitude='-4.781466']
29
ADSB[id=DAL_a36f7e_3, altitude='38892', heading='319', speed='428', verticalSpeed='1024' timestamp='Tue Jul 05 01:23:39 BST 2022', latitude='55.996060', longitude='-4.783344']
30
31
ADSB Documents found with findADSBDataByIcaoAddr("DAL"):
32
-------------------------------
33
ADSB[id=DAL_a36f7e_1, altitude='38825', heading='319', speed='428', verticalSpeed='1024' timestamp='Tue Jul 05 01:23:37 BST 2022', latitude='55.991776', longitude='-4.776722']
34
ADSB[id=DAL_a36f7e_2, altitude='38875', heading='319', speed='429', verticalSpeed='1024' timestamp='Tue Jul 05 01:23:38 BST 2022', latitude='55.994843', longitude='-4.781466']
35
ADSB[id=DAL_a36f7e_3, altitude='38892', heading='319', speed='428', verticalSpeed='1024' timestamp='Tue Jul 05 01:23:39 BST 2022', latitude='55.996060', longitude='-4.783344']
36
37
ADSB Documents found with findADSBDataByIcaoAddr("DAL_a36f7e"):
38
-------------------------------
39
ADSB[id=DAL_a36f7e_1, altitude='38825', heading='319', speed='428', verticalSpeed='1024' timestamp='Tue Jul 05 01:23:37 BST 2022', latitude='55.991776', longitude='-4.776722']
40
ADSB[id=DAL_a36f7e_2, altitude='38875', heading='319', speed='429', verticalSpeed='1024' timestamp='Tue Jul 05 01:23:38 BST 2022', latitude='55.994843', longitude='-4.781466']
41
ADSB[id=DAL_a36f7e_3, altitude='38892', heading='319', speed='428', verticalSpeed='1024' timestamp='Tue Jul 05 01:23:39 BST 2022', latitude='55.996060', longitude='-4.783344']