home service

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

@@ -27,7 +27,7 @@ public class PersonController {
 
     @PutMapping(value = "/people/{id}")
     public ResponseEntity<Person> updatePersonById(@PathVariable Integer id, Person p) {
-        personService.update(p.getId(), p);
+        personService.update(p);
         return new ResponseEntity<>(HttpStatus.OK);
     }
 

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

@@ -0,0 +1,98 @@
+package io.zipcoder.persistenceapp.service;
+
+import io.zipcoder.persistenceapp.model.Home;
+import io.zipcoder.persistenceapp.model.Person;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.jdbc.core.BeanPropertyRowMapper;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.RowMapper;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.List;
+
+public class HomeService {
+
+    @Autowired
+    JdbcTemplate jdbcTemplate;
+
+    public HomeService() {
+    }
+    /*
+    SELECT * FROM person
+    INNER JOIN home ON person.home_id = home.id
+    WHERE home.id = ?
+    value = parameter
+     */
+
+    static class HomeRowMapper implements RowMapper<Home> {
+        @Override
+        public Home mapRow(ResultSet rs, int rowNum) throws SQLException {
+            Home home = new Home();
+            home.setAddress(rs.getString("address"));
+            home.setHomeNumber(rs.getString("homenumber"));
+            home.setId(rs.getInt("id"));
+            return home;
+        }
+    }
+
+    public void addHome(Home home) {
+        jdbcTemplate.update(
+                "INSERT INTO home(address, homenumber)" +
+                        "VALUES(?,?)", home.getAddress(), home.getHomeNumber());
+    }
+
+    // Test this one
+    public void addPersonToHome(Person p, Home home) {
+        jdbcTemplate.update(
+                "UPDATE person SET home_id = ?" +
+                        "VALUE(?) WHERE id = ?",
+                home.getId(), p.getId());
+    }
+
+    public void updateHome(Integer id, Home home) {
+        jdbcTemplate.update(
+                "UPDATE home set address = ?, homenumber = ?" +
+                        "VALUES(?, ?)", home.getAddress(), home.getHomeNumber());
+    }
+
+    public void remove(Integer id) {
+        jdbcTemplate.update(
+                "DELETE FROM home WHERE id = ?", id);
+    }
+
+    public void removeHomes(Iterable<Home> homes) {
+        homes.forEach(home -> remove(home.getId()));
+    }
+
+    public Home findHomeById(Integer id) {
+        return jdbcTemplate.queryForObject(
+                "SELECT * FROM home WHERE ID = ?",
+                new Object[] {id}, new BeanPropertyRowMapper<>(Home.class));
+    }
+
+    public Home findHomeByHomeNumber(String homeNumber) {
+        return jdbcTemplate.queryForObject(
+                "SELECT * FROM HOME WHERE homenumber = ?",
+                new Object[]{homeNumber}, new BeanPropertyRowMapper<>(Home.class));
+    }
+
+    public Home findHomeByAddress(String address) {
+        return jdbcTemplate.queryForObject(
+                "SELECT * FROM HOME WHERE address = ?",
+                new Object[]{address}, new BeanPropertyRowMapper<>(Home.class));
+    }
+
+    public Home findHomeByPersonId(Integer id) {
+        return jdbcTemplate.queryForObject(
+                "SELECT * FROM home INNER JOIN person on home.id = person.home_id WHERE person.id = ?",
+                new Object[]{id}, new BeanPropertyRowMapper<>(Home.class));
+    }
+
+    public List<Person> generatePeopleInHome(Integer id) {
+        return jdbcTemplate.query(
+                "SELECT * FROM person INNER JOIN home on person.home_id = home.id WHERE home.id = ?",
+                new Object[]{id}, new PersonService.PersonRowMapper());
+    }
+}

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

@@ -28,7 +28,7 @@ public class PersonService {
 
     public PersonService() {}
 
-    class PersonRowMapper implements RowMapper<Person> {
+    static class PersonRowMapper implements RowMapper<Person> {
         @Override
         public Person mapRow(ResultSet rs, int rowNum) throws SQLException {
             Person person = new Person();
@@ -49,7 +49,8 @@ public class PersonService {
                         "VALUES (?, ?, ?, ?, ?)", info);
     }
 
-    public void update(Integer id, Person p) {
+    // Test this one
+    public void update(Person p) {
         jdbcTemplate.update(
                 "UPDATE person set first_name = ?, last_name ?, mobile = ?, birthday = ?, home_ID = ?" +
                         "VALUES (?, ?, ?, ?, ?) WHERE id = ?",
@@ -87,4 +88,8 @@ public class PersonService {
         return jdbcTemplate.query("SELECT * FROM PERSON WHERE LAST_NAME=?", new Object[] {lastName},
                 new PersonRowMapper());
     }
+
+    /*
+    implement the count for people with selected first name
+     */
 }