src/main/java/io/zipcoder/persistenceapp/Home.java

@@ -0,0 +1,46 @@
+package io.zipcoder.persistenceapp;
+
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+
+public class Home {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.AUTO)
+    private Integer id;
+    private String address;
+    private String homeNumber;
+
+    public Home(String address, String homeNumber) {
+        this.address = address;
+        this.homeNumber = homeNumber;
+    }
+
+    public Home() {
+    }
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getAddress() {
+        return address;
+    }
+
+    public void setAddress(String address) {
+        this.address = address;
+    }
+
+    public String getHomeNumber() {
+        return homeNumber;
+    }
+
+    public void setHomeNumber(String homeNumber) {
+        this.homeNumber = homeNumber;
+    }
+}

src/main/java/io/zipcoder/persistenceapp/HomeController.java

@@ -0,0 +1,45 @@
+package io.zipcoder.persistenceapp;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+
+@RestController
+public class HomeController {
+
+    final HomeService homeService;
+
+    @Autowired
+    public HomeController(HomeService homeService) { this.homeService = homeService; }
+
+    @PostMapping("/home/{address}/{homeNumber}")
+    Home createHome(@PathVariable String address,
+                    @PathVariable String homeNumber) {
+        Home home = new Home(address, homeNumber);
+        homeService.addHome(home);
+        return home;
+    }
+
+    @GetMapping("/home")
+    List<Home> getHomes() {
+        return homeService.getAllHomes();
+    }
+
+    @GetMapping("/home/{id}")
+    Home getHomeById(@PathVariable Integer id) {
+        return homeService.getHomeById(id);
+    }
+
+    @PutMapping("/home/{id}/{address}/{homeNumber}")
+    Home updateHome(@ModelAttribute("home") Home h) {
+        homeService.updateHome(h);
+        return h;
+    }
+
+    @DeleteMapping("/home/{id}")
+    void deleteHome(@PathVariable Integer id) {
+        homeService.deleteHome(homeService.getHomeById(id));
+    }
+
+}

src/main/java/io/zipcoder/persistenceapp/HomeMapper.java

@@ -0,0 +1,17 @@
+package io.zipcoder.persistenceapp;
+
+import org.springframework.jdbc.core.RowMapper;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+public class HomeMapper implements RowMapper<Home> {
+    @Override
+    public Home mapRow(ResultSet resultSet, int i) throws SQLException {
+        Home home = new Home();
+        home.setId(resultSet.getInt("id"));
+        home.setAddress(resultSet.getString("address"));
+        home.setHomeNumber(resultSet.getString("homenumber"));
+        return home;
+    }
+}

src/main/java/io/zipcoder/persistenceapp/HomeService.java

@@ -0,0 +1,41 @@
+package io.zipcoder.persistenceapp;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class HomeService {
+
+    @Autowired
+    JdbcTemplate jdbcTemplate;
+
+    private final String SQL_FIND_HOME = "select * from home where id = ?";
+    private final String SQL_DELETE_HOME = "delete from home where id = ?";
+    private final String SQL_UPDATE_HOME = "update home set address = ?, homenumber = ?, where id = ?";
+    private final String SQL_GET_ALL = "select * from home";
+    private final String SQL_INSERT_HOME = "insert into home(address, homenumber) values(?,?)";
+
+    public Home getHomeById(Integer id) {
+        return jdbcTemplate.queryForObject(SQL_FIND_HOME, new Object[] { id }, new HomeMapper());
+    }
+
+    public List<Home> getAllHomes() {
+        return jdbcTemplate.query(SQL_GET_ALL, new HomeMapper());
+    }
+
+    public boolean deleteHome(Home home) {
+        return jdbcTemplate.update(SQL_DELETE_HOME, home.getId()) > 0;
+    }
+
+    public boolean updateHome(Home home) {
+        return jdbcTemplate.update(SQL_UPDATE_HOME, home.getAddress(), home.getHomeNumber()) > 0;
+    }
+
+    public boolean addHome(Home home) {
+        return jdbcTemplate.update(SQL_INSERT_HOME, home.getAddress(), home.getHomeNumber()) > 0;
+    }
+
+}

src/main/java/io/zipcoder/persistenceapp/Person.java

@@ -0,0 +1,81 @@
+package io.zipcoder.persistenceapp;
+
+import org.springframework.stereotype.Component;
+
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+import java.util.Date;
+
+@Entity
+public class Person {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.AUTO)
+    private Integer id;
+    private String firstName;
+    private String lastName;
+    private Date birthdate;
+    private Long mobile;
+    private Integer homeId;
+
+    public Person(String firstName, String lastName, Date birthdate, Long mobile) {
+        this.firstName = firstName;
+        this.lastName = lastName;
+        this.birthdate = birthdate;
+        this.mobile = mobile;
+    }
+
+    public Person() {
+    }
+
+    public void setHomeId(Integer homeId) {
+        this.homeId = homeId;
+    }
+
+    public Integer getHomeId() {
+        return homeId;
+    }
+
+    public Integer getId() {
+        return id;
+    }
+
+    public Date getBirthdate() {
+        return birthdate;
+    }
+
+    public void setBirthdate(Date birthdate) {
+        this.birthdate = birthdate;
+    }
+
+    public Long getMobile() {
+        return mobile;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public void setMobile(Long mobile) {
+        this.mobile = mobile;
+    }
+
+    public String getFirstName() {
+        return firstName;
+    }
+
+    public String getLastName() {
+        return lastName;
+    }
+
+    public void setFirstName(String firstName) {
+        this.firstName = firstName;
+    }
+
+    public void setLastName(String lastName) {
+        this.lastName = lastName;
+    }
+
+}

src/main/java/io/zipcoder/persistenceapp/PersonController.java

@@ -0,0 +1,53 @@
+package io.zipcoder.persistenceapp;
+
+import io.zipcoder.persistenceapp.jdbc.JdbcPersonServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.format.annotation.DateTimeFormat;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Date;
+import java.util.List;
+
+@RestController
+public class PersonController {
+
+    final JdbcPersonServiceImpl jdbcPersonServiceImpl;
+
+    @Autowired
+    public PersonController(JdbcPersonServiceImpl jdbcPersonServiceImpl) { this.jdbcPersonServiceImpl = jdbcPersonServiceImpl; }
+
+    @PostMapping("/people/{firstName}/{lastName}/{birthday}/{mobile}")
+    Person createPerson(@PathVariable String firstName, @PathVariable String lastName, @PathVariable @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) Date birthday, @PathVariable Long mobile) {
+        Person person = new Person(firstName, lastName, birthday, mobile);
+        jdbcPersonServiceImpl.addPerson(person);
+        return person;
+    }
+
+    @GetMapping("/people/{id}")
+    Person getPerson(@PathVariable Integer id) {
+        return jdbcPersonServiceImpl.getPersonById(id);
+    }
+
+    @GetMapping("/people")
+    List<Person> getPersonList() {
+        return jdbcPersonServiceImpl.getAllPersons();
+    }
+
+    @PutMapping("/people/{id}/{firstName}/{lastName}/{birthday}/{mobile}")
+    Person updatePerson(@PathVariable Integer id, @PathVariable String firstName, @PathVariable String lastName, @PathVariable @DateTimeFormat(iso = DateTimeFormat.ISO.DATE) Date birthday, @PathVariable Long mobile) {
+        jdbcPersonServiceImpl.updatePerson(id, firstName, lastName, birthday, mobile);
+        return jdbcPersonServiceImpl.getPersonById(id);
+    }
+
+    @DeleteMapping("/people/{id}")
+    void deletePerson(@PathVariable Integer id) {
+        jdbcPersonServiceImpl.deletePerson(jdbcPersonServiceImpl.getPersonById(id));
+    }
+
+    @PutMapping("/people/{id}/{homeId}")
+    Person assignHome(@PathVariable Integer id, @PathVariable Integer homeId) {
+        jdbcPersonServiceImpl.assignHome(id, homeId);
+        return jdbcPersonServiceImpl.getPersonById(id);
+    }
+
+}

src/main/java/io/zipcoder/persistenceapp/PersonMapper.java

@@ -0,0 +1,22 @@
+package io.zipcoder.persistenceapp;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+import org.springframework.jdbc.core.RowMapper;
+
+public class PersonMapper implements RowMapper<Person> {
+
+    public Person mapRow(ResultSet resultSet, int i) throws SQLException {
+
+        Person person = new Person();
+        person.setId(resultSet.getInt("id"));
+        person.setFirstName(resultSet.getString("first_name"));
+        person.setLastName(resultSet.getString("last_name"));
+        person.setBirthdate(resultSet.getDate("birthday"));
+        person.setMobile(resultSet.getLong("mobile"));
+        person.setHomeId(resultSet.getInt("home_id"));
+        return person;
+    }
+}
+

src/main/java/io/zipcoder/persistenceapp/PersonService.java

@@ -0,0 +1,4 @@
+package io.zipcoder.persistenceapp;
+
+public interface PersonService {
+}

src/main/java/io/zipcoder/persistenceapp/jdbc/JdbcPersonServiceImpl.java

@@ -0,0 +1,51 @@
+package io.zipcoder.persistenceapp.jdbc;
+
+import io.zipcoder.persistenceapp.Person;
+import io.zipcoder.persistenceapp.PersonMapper;
+import io.zipcoder.persistenceapp.PersonService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+import java.util.List;
+
+@Service
+public class JdbcPersonServiceImpl implements PersonService {
+
+    @Autowired
+    JdbcTemplate jdbcTemplate;
+
+    private final String SQL_FIND_PERSON = "select * from people where id = ?";
+    private final String SQL_DELETE_PERSON = "delete from people where id = ?";
+    private final String SQL_UPDATE_PERSON = "update people set first_name = ?, last_name = ?, mobile  = ?, birthday = ? where id = ?";
+    private final String SQL_GET_ALL = "select * from people";
+    private final String SQL_INSERT_PERSON = "insert into people(first_name, last_name, mobile, birthday) values(?,?,?,?)";
+    private final String SQL_ASSIGN_HOME = "update people set home_id = ? where id = ?";
+
+
+    public Person getPersonById(Integer id) {
+        return jdbcTemplate.queryForObject(SQL_FIND_PERSON, new Object[] { id }, new PersonMapper());
+    }
+
+    public List<Person> getAllPersons() {
+        return jdbcTemplate.query(SQL_GET_ALL, new PersonMapper());
+    }
+
+    public boolean deletePerson(Person person) {
+        return jdbcTemplate.update(SQL_DELETE_PERSON, person.getId()) > 0;
+    }
+
+    public boolean updatePerson(Integer id, String first_name, String last_name, Date birthday, Long mobile) {
+        return jdbcTemplate.update(SQL_UPDATE_PERSON, first_name, last_name, birthday, mobile, id) > 0;
+    }
+
+    public boolean addPerson(Person person) {
+        return jdbcTemplate.update(SQL_INSERT_PERSON, person.getFirstName(), person.getLastName(), person.getMobile(), person.getBirthdate()) > 0;
+    }
+
+    public boolean assignHome(Integer id, Integer home_id) {
+        return jdbcTemplate.update(SQL_ASSIGN_HOME, home_id, id) > 0;
+    }
+
+}

src/main/java/io/zipcoder/persistenceapp/jpa/JpaPersonServiceImpl.java

@@ -0,0 +1,65 @@
+package io.zipcoder.persistenceapp.jpa;
+
+import io.zipcoder.persistenceapp.HomeController;
+import io.zipcoder.persistenceapp.Person;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Primary;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+import java.util.List;
+
+@Service
+@Primary
+public class JpaPersonServiceImpl {
+
+    private
+    PersonRepository personRepository;
+
+    @Autowired
+    public JpaPersonServiceImpl(PersonRepository personRepository) {
+        this.personRepository = personRepository;
+    }
+
+    public Person getPersonById(Integer id) {
+        return personRepository.findOne(id);
+    }
+
+    public List<Person> getAllPersons() {
+        return personRepository.findAll();
+    }
+
+    public boolean deletePerson(Person person) {
+        if (!personRepository.exists(person.getId())) return false;
+        else personRepository.delete(person);
+        return true;
+    }
+
+    public boolean updatePerson(Integer id, String first_name, String last_name, Date birthday, Long mobile) {
+        if (!personRepository.exists(id)) return false;
+        else {
+            Person p = getPersonById(id);
+            p.setFirstName(first_name);
+            p.setLastName(last_name);
+            p.setBirthdate(birthday);
+            p.setMobile(mobile);
+            personRepository.save(p);
+        }
+        return true;
+    }
+
+    public boolean addPerson(Person person) {
+        if (personRepository.exists(person.getId())) return false;
+        else personRepository.save(person);
+        return true;
+    }
+
+    public boolean assignHome(Integer id, Integer home_id) {
+        if (!personRepository.exists(id)) return false;
+        else {Person person = new Person();
+            person.setHomeId(id);
+            personRepository.save(person);}
+        return true;
+    }
+
+}

src/main/java/io/zipcoder/persistenceapp/jpa/PersonRepository.java

@@ -0,0 +1,9 @@
+package io.zipcoder.persistenceapp.jpa;
+
+import io.zipcoder.persistenceapp.Person;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface PersonRepository extends JpaRepository<Person, Integer> {
+}

src/main/resources/application-h2.properties

@@ -1,4 +1,5 @@
-spring.datasource.url=jdbc:h2:mem:testdb;Mode=Oracle
+spring.datasource.url=jdbc:h2:mem:test;Mode=Oracle
 spring.datasource.platform=h2
 spring.jpa.hibernate.ddl-auto=none
-spring.datasource.continue-on-error=true
+spring.datasource.continue-on-error=true
+spring.datasource.initialization-mode=always

src/main/resources/application.properties

@@ -1,3 +1,5 @@
 spring.profiles.active=h2
 logging.level.org.springframework.boot.context.embedded=INFO
-spring.jpa.database-platform=org.hibernate.dialect.Oracle10gDialect
+spring.jpa.database-platform=org.hibernate.dialect.Oracle10gDialect
+spring.jpa.hibernate.ddl-auto=none
+spring.datasource.initialization-mode=always

src/main/resources/schema-h2.sql → src/main/resources/schema.sql

@@ -1,6 +1,6 @@
 DROP TABLE IF EXISTS PERSON;
 
-CREATE TABLE PERSON (
+CREATE TABLE PEOPLE (
   ID INT NOT NULL AUTO_INCREMENT,
   FIRST_NAME VARCHAR2(255) NOT NULL DEFAULT '',
   LAST_NAME VARCHAR2(255) NOT NULL DEFAULT '',
@@ -9,10 +9,10 @@ CREATE TABLE PERSON (
   HOME_ID SMALLINT DEFAULT NULL,
   PRIMARY KEY (ID));
 
-  ALTER TABLE PERSON
-  ADD FOREIGN KEY (HOME_ID)
-  REFERENCES HOME(ID);
-
+  INSERT INTO people (FIRST_NAME, LAST_NAME, MOBILE, BIRTHDAY)
+VALUES ('Ned', 'Redmond', '3023023022', '1898-01-28'),
+  ('Nas', 'Pronina', '3023021234', '2000-01-01'),
+  ('Shep', 'Pronin', '1231231234', '2018-01-28');
 
 DROP TABLE IF EXISTS HOME;
 
@@ -23,6 +23,16 @@ CREATE TABLE HOME (
   PRIMARY KEY (ID)
 );
 
+INSERT INTO home (ADDRESS, HOMENUMBER)
+VALUES ('36 E. Bayberry Rd.Savannah, GA 31404', '565-6895'),
+  ('11 Essex Dr.Farmingdale, NY 11735', '454-4544'),
+  ('920 Arlington Street Clifton, NJ 07011', '985-4515'),
+  ('234 High Street, PA 19159', '267-3940');
+
+  ALTER TABLE PEOPLE
+  ADD FOREIGN KEY (HOME_ID)
+  REFERENCES HOME(ID);
+
 DROP TABLE IF EXISTS movies;
 
 CREATE TABLE movies (

src/main/resources/script.sql

@@ -0,0 +1,40 @@
+INSERT INTO movies (title, runtime, genre, imdb_score, rating)
+VALUES ('Howard the Duck', 110, 'Sci-Fi', 4.6, 'PG'),
+       ('Lavalantula',	83,	'Horror',	4.7,	'TV-14'),
+       ('Starship Troopers',	129,	'Sci-Fi',	7.2,	'PG-13'),
+       ('Waltz With Bashir',	90,	'Documentary',	8.0,	'R'),
+       ('Spaceballs',	96,	'Comedy',	7.1,	'PG'),
+       ('Monsters Inc.',	92,	'Animation',	8.1,	'G'),
+       ('Blue Velvet', 121, 'Drama/Mystery', 7.8, 'R'),
+       ('The Hunger', 100, 'Fantasy/Thriller', 6.7, 'R'),
+       ('The Color of Pomegranates', 75, 'Drama/Art film', 7.7, 'NR'),
+       ('Little Nemo: Adventures in Slumberland', 94, 'Fantasy/Adventure', 7.2, 'G'),
+       ('The Last Unicorn', 93, 'Drama/Fantasy', 7.5, 'G'),
+       ('The 7th Voyage of Sinbad', 88, 'Fantasy/Action', 7.1, 'G');
+
+-- Create a query to find all movies in the Sci-Fi genre.
+SELECT * FROM movies WHERE genre = 'Sci-Fi';
+
+--Create a query to find all films that scored at least a 6.5 on IMDB
+SELECT * FROM movies WHERE imdb_score >= 6.5;
+
+-- For parents who have young kids, but who don't want to sit through long children's movies, create a query to find all of the movies rated G or PG that are less than 100 minutes long.
+SELECT * FROM movies WHERE rating = 'G' OR rating = 'PG' AND runtime <= 100;
+
+-- Create a query to show the average runtimes of movies rated below a 7.5, grouped by their respective genres.
+SELECT genre, AVG(runtime) AS Average_Runtime FROM movies WHERE imdb_score < 7.5 GROUP BY genre;
+
+-- There's been a data entry mistake; Starship Troopers is actually rated R, not PG-13. Create a query that finds the movie by its title and changes its rating to R.
+UPDATE movies SET rating = 'R' WHERE title = 'Starship Troopers';
+
+-- Show the ID number and rating of all of the Horror and Documentary movies in the database. Do this in only one query.
+SELECT id, rating FROM movies WHERE genre = 'Horror' OR genre = 'Documentary';
+
+-- This time let's find the average, maximum, and minimum IMDB score for movies of each rating.
+SELECT rating, AVG(imdb_score), MAX(imdb_score), MIN(imdb_score) FROM movies GROUP BY rating;
+
+-- That last query isn't very informative for ratings that only have 1 entry. use a HAVING COUNT(*) > 1 clause to only show ratings with multiple movies showing.
+SELECT rating, AVG(imdb_score), MAX(imdb_score), MIN(imdb_score) FROM movies GROUP BY rating HAVING COUNT(*) > 1;
+
+-- Let's make our movie list more child-friendly. Delete all entries that have a rating of R. Remember to record your query in script.sql.
+DELETE FROM movies WHERE rating = 'R';