morning commit

H2-Worksheet.md

 ```SQL
 UPDATE people SET birthday = '1955-01-25' 
 WHERE 
-	last_name = 'Smith' 
+	lastName = 'Smith' 
 	AND id = 4;
 ```
 
 ```SQL
-UPDATE people SET mobile = '333-3333', last_name = 'Johnson' 
-WHERE first_name = 'Noelle' OR first_name = 'Raj';
+UPDATE people SET mobile = '333-3333', lastName = 'Johnson' 
+WHERE firstName = 'Noelle' OR firstName = 'Raj';
 ```
 
 ## Basic Functions
 ```
 
 ```SQL
-SELECT COUNT(DISTINCT last_name) FROM PEOPLE;
+SELECT COUNT(DISTINCT lastName) FROM PEOPLE;
 ```
 
 ```SQL
 ```
 
 ```SQL
-SELECT CONCAT(first_name, ' ', last_name) 
+SELECT CONCAT(firstName, ' ', lastName) 
 FROM people 
-WHERE last_name = 'Smith'
+WHERE lastName = 'Smith'
 ```
 
 ```SQL
-SELECT CONCAT_WS(' ',first_name, last_name, mobile) 
-FROM people WHERE last_name= 'Smith'
+SELECT CONCAT_WS(' ',firstName, lastName, mobile) 
+FROM people WHERE lastName= 'Smith'
 ```
 
 ```SQL
 ## Compare
 
 ```SQL
-SELECT first_name, last_name, YEAR(birthday) FROM people WHERE birthday >= '1970-07-06' AND birthday<='1987-07-06';
+SELECT firstName, lastName, YEAR(birthday) FROM people WHERE birthday >= '1970-07-06' AND birthday<='1987-07-06';
 ```
 
 ```SQL
-SELECT first_name, birthday FROM people WHERE first_name='Thomas' OR first_name='Raj' OR first_name='Sheeri';
+SELECT firstName, birthday FROM people WHERE firstName='Thomas' OR firstName='Raj' OR firstName='Sheeri';
 ```
 
 ```SQL
-SELECT first_name, birthday FROM people WHERE first_name IN ('Noelle', 'Thomas', 'Raj');
+SELECT firstName, birthday FROM people WHERE firstName IN ('Noelle', 'Thomas', 'Raj');
 ```
 
 #### Wild Cards
 
 ```SQL
-SELECT first_name FROM PEOPLE WHERE RIGHT(first_name,1)='e';
+SELECT firstName FROM PEOPLE WHERE RIGHT(firstName,1)='e';
 ```
 
 ```SQL
-SELECT first_name FROM people WHERE first_name LIKE '%j'; 
+SELECT firstName FROM people WHERE firstName LIKE '%j'; 
 ```
 
 ```SQL
-SELECT first_name FROM people WHERE first_name LIKE '%o%';
+SELECT firstName FROM people WHERE firstName LIKE '%o%';
 ```
 
 ```SQL
-SELECT first_name FROM people WHERE first_name NOT LIKE '%o%';
+SELECT firstName FROM people WHERE firstName NOT LIKE '%o%';
 ```
 
 ```SQL
 ```
 
 ```SQL
-SELECT last_name, COUNT(*) FROM people GROUP BY last_name;
+SELECT lastName, COUNT(*) FROM people GROUP BY lastName;
 ```
 
 ```SQL
-SELECT last_name, GROUP_CONCAT(mobile) FROM PEOPLE GROUP BY last_name;
+SELECT lastName, GROUP_CONCAT(mobile) FROM PEOPLE GROUP BY lastName;
 ```
 
 ```SQL
-SELECT last_name, GROUP_CONCAT(mobile SEPARATOR ' and ') FROM people GROUP BY last_name;
+SELECT lastName, GROUP_CONCAT(mobile SEPARATOR ' and ') FROM people GROUP BY lastName;
 ```
 
 ```SQL
-SELECT last_name, GROUP_CONCAT(mobile SEPARATOR ' and ') FROM people GROUP BY last_name  HAVING COUNT(*)>1;
+SELECT lastName, GROUP_CONCAT(mobile SEPARATOR ' and ') FROM people GROUP BY lastName  HAVING COUNT(*)>1;
 ```
 
 ```SQL
-SELECT last_name, GROUP_CONCAT(mobile SEPARATOR ' and ') FROM people WHERE last_name != 'Cabral' GROUP BY last_name  HAVING COUNT(*)>1;
+SELECT lastName, GROUP_CONCAT(mobile SEPARATOR ' and ') FROM people WHERE lastName != 'Cabral' GROUP BY lastName  HAVING COUNT(*)>1;
 ```
 
 #### Sorting 
 
 ```SQL
-SELECT first_name, birthday FROM people ORDER BY birthday;
+SELECT firstName, birthday FROM people ORDER BY birthday;
 ```
 
 ```SQL
-SELECT first_name, birthday FROM people ORDER BY birthday DESC;
+SELECT firstName, birthday FROM people ORDER BY birthday DESC;
 ```
 
 ```SQL
-SELECT first_name, last_name FROM people ORDER BY last_name, first_name;
+SELECT firstName, lastName FROM people ORDER BY lastName, firstName;
 ```
 
 ```SQL
-SELECT first_name, birthday FROM people ORDER BY birthday DESC LIMIT 3;
+SELECT firstName, birthday FROM people ORDER BY birthday DESC LIMIT 3;
 ```
 
 ```SQL
-SELECT first_name, MONTHNAME(birthday) as mon, birthday FROM people ORDER BY MONTH(birthday);
+SELECT firstName, MONTHNAME(birthday) as mon, birthday FROM people ORDER BY MONTH(birthday);
 ```
 
 ```SQL
-SELECT last_name, COUNT(*) FROM  people GROUP BY last_name;
+SELECT lastName, COUNT(*) FROM  people GROUP BY lastName;
 ```
 
 ```SQL
-SELECT last_name, COUNT(*) FROM  people GROUP BY last_name ORDER BY NULL;
+SELECT lastName, COUNT(*) FROM  people GROUP BY lastName ORDER BY NULL;
 ```
 
 ## Inserting and Replacing Records
 
 ```SQL
-INSERT INTO people (first_name, last_name, birthday, home_id)
+INSERT INTO people (firstName, lastName, birthday, home_id)
 	VALUES
 	('John', 'Smith', '1998-04-07', 4),
 	('Maya', 'Wasserman' , NULL, 4),
 #### Replace
 
 ```SQL
-DELETE FROM people WHERE first_name='Maya';
+DELETE FROM people WHERE firstName='Maya';
 ```
 
 ```SQL
 ```
 
 ```SQL
-MERGE INTO people (first_name, last_name, birthday, home_id)
+MERGE INTO people (firstName, lastName, birthday, home_id)
 	VALUES
 	('John', 'Sharma', '1998-04-07', 1),
 	('Paul', 'Sharma', '1996-05-27', 4),
 ## JOIN
 
 ```SQL
-INSERT INTO people (first_name, last_name, birthday)
+INSERT INTO people (firstName, lastName, birthday)
 	VALUES ('Eli', 'Kramer', '1984-01-15');
 ```
 	
 ```
 
 ```SQL
-SELECT p.first_name, h.address 
+SELECT p.firstName, h.address 
 FROM PEOPLE p
 INNER JOIN HOME h  on (p.HOME_ID = h.ID)
 ```
 
 ```SQL
-SELECT first_name, last_name
+SELECT firstName, lastName
 FROM PEOPLE p
 INNER JOIN HOME h  on (p.HOME_ID = h.HOME_ID)
 WHERE p.HOME_ID = 1
 SELECT p.*, h.address, h.homenumber
 FROM PEOPLE p
 INNER JOIN HOME h  on (p.HOME_ID = h.HOME_ID)
-WHERE p.first_name  LIKE '%e%'
+WHERE p.firstName  LIKE '%e%'
 ```
 
 ##### Exercise:

data-h2.sql

 INSERT INTO PERSON ( LAST_NAME, FIRST_NAME, MOBILE, BIRTHDAY, HOME_ID)VALUES ('Smith', 'Thomas', '395-6181', '1987-07-06', 1);
 INSERT INTO PERSON ( LAST_NAME, FIRST_NAME, MOBILE, BIRTHDAY, HOME_ID)VALUES ('Smith', 'Jane', '393-6181', '1987-12-06', 3);
 INSERT INTO PERSON ( LAST_NAME, FIRST_NAME, MOBILE, BIRTHDAY, HOME_ID)VALUES ('Brown', 'Doug', '466-6241', '1954-12-07', 3);
-
-

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

 package io.zipcoder.persistenceapp;
 
+import io.zipcoder.persistenceapp.service.PersonService;
 import org.h2.server.web.WebServlet;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.web.servlet.ServletRegistrationBean;
 import org.springframework.context.annotation.Bean;
 
+import java.sql.*;
+
 @SpringBootApplication
 public class PersistenceStarterApplication {
 
+	@Autowired
+	static PersonService personService;
+
+	// JDBC driver name and database URL
+	static final String JDBC_DRIVER = "org.h2.Driver";
+	static final String DB_URL = "jdbc:h2:mem:testdb";
+
+	//  Database credentials
+	static final String USER = "sa";
+	static final String PASS = "";
+
 	public static void main(String[] args) {
 		SpringApplication.run(PersistenceStarterApplication.class, args);
+
+		Connection conn = null;
+		Statement stmt = null;
+		try{
+			// STEP 1: Register JDBC driver
+			Class.forName(JDBC_DRIVER);
+
+			// STEP 2: Open a connection
+			System.out.println("Connecting to a selected database...");
+			conn = DriverManager.getConnection(DB_URL,USER,PASS);
+			System.out.println("Connected database successfully...");
+
+			// STEP 3: Execute a query
+			stmt = conn.createStatement();
+			String sql = "SELECT * FROM PERSON";
+			ResultSet rs = stmt.executeQuery(sql);
+			System.out.println("query result: ");
+
+			while(rs.next()) {
+				System.out.println("ID: " + rs.getInt(1));
+				System.out.println("First name: " + rs.getString(2));
+				System.out.println("Last name: " + rs.getString(3));
+				System.out.println("Mobile phone: " + rs.getString(4));
+				System.out.println("Birthday date: " + rs.getString(5));
+				System.out.println("Home ID: " + rs.getInt(6));
+			}
+
+			// STEP 4: Clean-up environment
+			stmt.close();
+			conn.close();
+		} catch(SQLException se) {
+			// Handle errors for JDBC
+			se.printStackTrace();
+		} catch(Exception e) {
+			// Handle errors for Class.forName
+			e.printStackTrace();
+		} finally {
+			// finally block used to close resources
+			try {
+				if(stmt!=null) stmt.close();
+			} catch(SQLException se2) {
+			} // nothing we can do
+			try {
+				if(conn!=null) conn.close();
+			} catch(SQLException se) {
+				se.printStackTrace();
+			} // end finally try
+		} // end try
+		System.out.println("Goodbye!");
 	}
 
 	@Bean

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

+package io.zipcoder.persistenceapp.controller;
+
+import io.zipcoder.persistenceapp.model.Person;
+import io.zipcoder.persistenceapp.service.PersonService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+public class PersonController {
+    @Autowired
+    PersonService personService;
+
+    @RequestMapping(value="/person", method= RequestMethod.GET)
+    public ResponseEntity<Iterable<Person>> getPeople() {
+        Iterable<Person> people = personService.getAllPeople();
+        return new ResponseEntity<>(people, HttpStatus.OK);
+    }
+}

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

 import java.util.Date;
 
 public class Person {
-
     private Long id;
-    private String first_name, last_name, mobile;
+    private String firstName, lastName, mobile;
     private Date birthday;
-    private Integer home_ID;
+    private Integer homeId;
 
-    public Person() {
-    }
+    public Person() {}
 
-    public Person(Long id, String first_name, String last_name) {
+    public Person(Long id, String firstName, String lastName) {
         this.id = id;
-        this.first_name = first_name;
-        this.last_name = last_name;
+        this.firstName = firstName;
+        this.lastName = lastName;
     }
 
     public Long getId() {
         this.id = id;
     }
 
-    public String getFirst_name() {
-        return first_name;
+    public String getFirstName() {
+        return firstName;
     }
 
-    public void setFirst_name(String first_name) {
-        this.first_name = first_name;
+    public void setFirstName(String firstName) {
+        this.firstName = firstName;
     }
 
-    public String getLast_name() {
-        return last_name;
+    public String getLastName() {
+        return lastName;
     }
 
-    public void setLast_name(String last_name) {
-        this.last_name = last_name;
+    public void setLastName(String lastName) {
+        this.lastName = lastName;
     }
 
     public String getMobile() {
         this.birthday = birthday;
     }
 
-    public Integer getHome_ID() {
-        return home_ID;
+    public Integer getHomeId() {
+        return homeId;
+    }
+
+    public void setHomeId(Integer homeId) {
+        this.homeId = homeId;
     }
 
-    public void setHome_ID(Integer home_ID) {
-        this.home_ID = home_ID;
+    @Override
+    public java.lang.String toString() {
+        return String.format("Person [id=%s, firstName=%s, lastName=%s, mobile=%s, birthday=%s, homeId=%s]", id,
+                firstName, lastName, mobile, birthday, homeId);
     }
 }

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

 
 import io.zipcoder.persistenceapp.model.Person;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.BeanPropertyRowMapper;
 import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.RowMapper;
 import org.springframework.stereotype.Service;
 
 import java.sql.JDBCType;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.Arrays;
+import java.util.Iterator;
+import java.util.List;
 
 /*
 Service speaks to the repo/jdbc template, controller speaks to service to get stuff
     @Autowired
     JdbcTemplate jdbcTemplate;
 
-    public PersonService() {
+    public PersonService() {}
+
+    class PersonRowMapper implements RowMapper<Person> {
+        @Override
+        public Person mapRow(ResultSet rs, int rowNum) throws SQLException {
+            Person person = new Person();
+            person.setId(rs.getLong("id"));
+            person.setFirstName(rs.getString("first_name"));
+            person.setLastName(rs.getString("last_name"));
+            person.setMobile(rs.getString("mobile"));
+            person.setBirthday(rs.getDate("birthday"));
+            person.setHomeId(rs.getInt("home_id"));
+            return person;
+        }
     }
 
     public void add(Person p) {
-        Object[] info = {p.getFirst_name(), p.getLast_name(), p.getMobile(), p.getBirthday(), p.getHome_ID()};
+        Object[] info = {p.getFirstName(), p.getLastName(), p.getMobile(), p.getBirthday(), p.getHomeId()};
         jdbcTemplate.update(
                 "INSERT INTO person (first_name, last_name, mobile, birthday, home_ID)" +
                         "VALUES (?, ?, ?, ?, ?)", info, types);
     }
 
     public void update(Person p) {
-        Object[] info = {p.getFirst_name(), p.getLast_name(), p.getMobile(), p.getBirthday(), p.getHome_ID()};
+        Object[] info = {p.getFirstName(), p.getLastName(), p.getMobile(), p.getBirthday(), p.getHomeId()};
         jdbcTemplate.update(
                 "UPDATE person set first_name = ?, last_name ?, mobile = ?, birthday = ?, home_ID = ?" +
                         "VALUES (?, ?, ?, ?, ?)", info, types);
         jdbcTemplate.update("DELETE FROM person WHERE id = ?", id);
     }
 
+    public void removePeople(Iterable<Person> p) {
+        p.forEach(person -> remove(person.getId()));
+    }
+
+    public Person findPersonById(Integer id) {
+        return jdbcTemplate.queryForObject("SELECT * FROM PERSON WHERE ID=?", new Object[] {id},
+                new BeanPropertyRowMapper<>(Person.class));
+    }
+
+    public List<Person> getAllPeople() {
+        return jdbcTemplate.query("SELECT * FROM PERSON", new PersonRowMapper());
+    }
 
+    public List<Person> findPeopleByMobile(String mobile) {
+        return jdbcTemplate.query("SELECT * FROM PERSON WHERE MOBILE=?", new Object[] {mobile},
+                new PersonRowMapper());
+    }
+
+    public List<Person> findPeopleByLastName(String lastName) {
+        return jdbcTemplate.query("SELECT * FROM PERSON WHERE LAST_NAME=?", new Object[] {lastName},
+                new PersonRowMapper());
+    }
+
+    public List<Person> generateSurnameMap(String lastName) {
+        return jdbcTemplate.query("SELECT * FROM PERSON WHERE LAST_NAME=?", new Object[] {lastName},
+                new PersonRowMapper());
+    }
 }

src/main/resources/data.sql

+INSERT into movies (title, runtime, genre, imdb_score, rating)
+VALUES ('Howard the Duck', 110, 'Sci-Fi', 4.6, 'PG');
+
+INSERT into movies (title, runtime, genre, imdb_score, rating)
+VALUES ('Lavalantula', 83, 'Horror', 4.7, 'TV-14');
+
+INSERT into movies (title, runtime, genre, imdb_score, rating)
+VALUES ('Starship Troopers', 129, 'Sci-Fi', 7.2, 'PG-13');
+
+INSERT into movies (title, runtime, genre, imdb_score, rating)
+VALUES ('Waltz With Bashir', 90, 'Documentary', 8.0, 'R');
+
+INSERT into movies (title, runtime, genre, imdb_score, rating)
+VALUES ('Spaceballs', 96, 'Comedy', 7.1, 'PG');
+
+INSERT into movies (title, runtime, genre, imdb_score, rating)
+VALUES ('Monsters Inc.', 92, 'Animation', 8.1, 'G');
+
+INSERT into movies (title, runtime, genre, imdb_score, rating)
+VALUES ('Finding Nemo', 101, 'Animation', 8.1, 'G');
+
+INSERT into movies (title, runtime, genre, imdb_score, rating)
+VALUES ('Just Go With It', 117, 'Comedy', 6.4, 'PG-13');
+
+INSERT into movies (title, runtime, genre, imdb_score, rating)
+VALUES ('Dodgeball', 117, 'Comedy', 6.7, 'PG-13');
+
+INSERT INTO HOME (ADDRESS, HOMENUMBER) VALUES ('36 E. Bayberry Rd.Savannah, GA 31404', '565-6895');
+INSERT INTO HOME (ADDRESS, HOMENUMBER) VALUES ('11 Essex Dr.Farmingdale, NY 11735', '454-4544');
+INSERT INTO HOME (ADDRESS, HOMENUMBER) VALUES ('920 Arlington Street Clifton, NJ 07011', '985-4515');
+INSERT INTO HOME (ADDRESS, HOMENUMBER) VALUES ('234 High Street, PA 19159 ', '267-3940');
+
+
+INSERT INTO PERSON ( LAST_NAME, FIRST_NAME, MOBILE, BIRTHDAY, HOME_ID ) VALUES ('Carbral', 'Sheeri', '230-4233', '1970-02-23', 2);
+INSERT INTO PERSON ( LAST_NAME, FIRST_NAME, MOBILE, BIRTHDAY, HOME_ID) VALUES ( 'Sharam', 'Raj', '186-5223', '1980-08-31', 3);
+INSERT INTO PERSON ( LAST_NAME, FIRST_NAME, MOBILE, BIRTHDAY, HOME_ID)VALUES ('Durand', 'Noelle', '395-6161', '1960-07-06', 1);
+INSERT INTO PERSON ( LAST_NAME, FIRST_NAME, MOBILE, BIRTHDAY, HOME_ID)VALUES ('Smith', 'Thomas', '395-6181', '1987-07-06', 1);
+INSERT INTO PERSON ( LAST_NAME, FIRST_NAME, MOBILE, BIRTHDAY, HOME_ID)VALUES ('Smith', 'Jane', '393-6181', '1987-12-06', 3);
+INSERT INTO PERSON ( LAST_NAME, FIRST_NAME, MOBILE, BIRTHDAY, HOME_ID)VALUES ('Brown', 'Doug', '466-6241', '1954-12-07', 3);