jdbctemplate data source not find correct DB

data-h2.sql

@@ -13,3 +13,12 @@ INSERT INTO PERSON ( LAST_NAME, FIRST_NAME, MOBILE, BIRTHDAY, HOME_ID)VALUES ('S
 INSERT INTO PERSON ( LAST_NAME, FIRST_NAME, MOBILE, BIRTHDAY, HOME_ID)VALUES ('Brown', 'Doug', '466-6241', '1954-12-07', 3);
 
 
+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 ('Lords of Dogtown',	107,	'Sport',	7.1,	'PG-13');
+INSERT INTO MOVIES (Title, Runtime, Genre, IMDB_Score, Rating) VALUES ('A Beautiful Mind',	135,	'Drama',	8.2,	'PG-13');

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

@@ -0,0 +1,92 @@
+package io.zipcoder.persistenceapp;
+
+import javax.persistence.*;
+
+@Entity
+public class Person {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Integer id;
+    private String firstName;
+    private String lastName;
+    private String mobile;
+    private String birthday;
+    private Integer homeId;
+
+    public Person() {
+        this.firstName = "firstName";
+        this.lastName = "lastName";
+        this.mobile = "mobile";
+        this.birthday = "2000-01-01";
+        this.homeId = 0;
+    }
+
+    public Person(String firstName, String lastName, String mobile, String birthday, int homeId) {
+        this.firstName = firstName;
+        this.lastName = lastName;
+        this.mobile = mobile;
+        this.birthday = birthday;
+        this.homeId = homeId;
+    }
+
+    public int getId() {
+        return id;
+    }
+
+    public void setId(int id) {
+        this.id = id;
+    }
+
+    public String getFirstName() {
+        return firstName;
+    }
+
+    public void setFirstName(String firstName) {
+        this.firstName = firstName;
+    }
+
+    public String getLastName() {
+        return lastName;
+    }
+
+    public void setLastName(String lastName) {
+        this.lastName = lastName;
+    }
+
+    public String getMobile() {
+        return mobile;
+    }
+
+    public void setMobile(String mobile) {
+        this.mobile = mobile;
+    }
+
+    public String getBirthday() {
+        return birthday;
+    }
+
+    public void setBirthday(String birthday) {
+        this.birthday = birthday;
+    }
+
+    public int getHomeId() {
+        return homeId;
+    }
+
+    public void setHomeId(int homeId) {
+        this.homeId = homeId;
+    }
+
+    @Override
+    public String toString() {
+        return "Person{" +
+                "id=" + id +
+                ", firstName='" + firstName + '\'' +
+                ", lastName='" + lastName + '\'' +
+                ", mobile='" + mobile + '\'' +
+                ", birthday='" + birthday + '\'' +
+                ", homeId=" + homeId +
+                '}';
+    }
+}

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

@@ -0,0 +1,105 @@
+package io.zipcoder.persistenceapp;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+@RestController
+public class PersonController {
+
+    @Autowired
+    PersonService serv;
+
+    @PostMapping("/people")
+    public Person createPerson(@RequestBody Person person){
+        int id = serv.savePerson(person);
+        person.setId(id);
+        return person;
+    }
+
+    @PutMapping("/people/{id}")
+    @ResponseStatus(code = HttpStatus.NOT_FOUND, reason = "Person not found.")
+    public Person updatePerson(@PathVariable int id, @RequestBody Person updatedPerson){
+        Person p = serv.findById(id);
+        updatedPerson.setId(p.getId());
+        if( p != null ) {
+            serv.updatePerson(updatedPerson);
+        } else {
+            new ResponseEntity(HttpStatus.NOT_FOUND);
+        }
+        return null;
+    }
+
+    @GetMapping("/people")
+    public List<Person> getAllPeople(){
+        return serv.getAllPeople();
+    }
+
+    @GetMapping("/people/{id}")
+    public Person getPersonById(@PathVariable int id){
+        return serv.findById(id);
+    }
+
+    @DeleteMapping("/people/{id}")
+    public Person deletePersonById(@PathVariable int id){
+        Person person = serv.findById(id);
+        serv.deletePerson(person);
+        return null;
+    }
+
+
+    @GetMapping("/people/reverselookup/{mobileNumber}")
+    public List<Person> getPeopleByNumber(@PathVariable String mobileNumber){
+        List<Person> people = serv.getAllPeople();
+        List<Person> peopleWithNumber = new ArrayList<>();
+        for(Person person : people){
+            if(person.getMobile().equals(mobileNumber)){
+                peopleWithNumber.add(person);
+            }
+        }
+       return peopleWithNumber;
+    }
+
+    @GetMapping("/people/surname/{lastName}")
+    public List<Person> getAllByLastName(@PathVariable String lastName){
+        Map<String, List<Person>> map = serv.surnameQuery();
+        for(String key : map.keySet()){
+            if(key.equals(lastName)){
+                return map.get(key);
+            }
+        }
+        return null;
+    }
+
+    @GetMapping("/people/surname")
+    public String getSurnameReport(){
+        String report = "";
+        Map<String, List<Person>> map = serv.surnameQuery();
+        for(String key : map.keySet()){
+            report += key + ": \n";
+            for(Person person : map.get(key)){
+                report += person.toString() + "\n";
+            }
+        }
+        return report;
+    }
+
+    @GetMapping("/people/firstname/stats")
+    public String getFirstNameCount(){
+        //Get the report of first name frequencies
+        String report = "";
+        Map<String, Integer> map = serv.firstNameCount();
+        for(String name : map.keySet()){
+            report += name + ", amount: " + map.get(name);
+        }
+        return report;
+    }
+
+
+
+}

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

@@ -0,0 +1,107 @@
+package io.zipcoder.persistenceapp;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
+import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
+import org.springframework.jdbc.core.namedparam.SqlParameterSource;
+import org.springframework.jdbc.support.GeneratedKeyHolder;
+import org.springframework.jdbc.support.KeyHolder;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class PersonService {
+
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
+    @Autowired
+    private NamedParameterJdbcTemplate namedParameterJdbcTemplate;
+
+
+    public List<Person> getAllPeople(){
+        List<Map<String, Object>> list = jdbcTemplate.queryForList("SELECT * FROM PERSON");
+        List<Person> people = new ArrayList<>();
+        for (Map<String, Object> row : list) {
+            Person person = new Person(String.valueOf(row.get("FIRST_NAME")), String.valueOf(row.get("LAST_NAME")), String.valueOf(row.get("MOBILE")), row.get("BIRTHDAY").toString(), (Short)row.get("HOME_ID"));
+            person.setId((Integer)row.get("ID"));
+            people.add(person);
+        }
+        return people;
+    }
+
+    public int savePerson(Person e){
+        System.out.println(e.toString());
+        KeyHolder holder = new GeneratedKeyHolder();
+        SqlParameterSource parameters = new MapSqlParameterSource()
+                .addValue("first_name", e.getFirstName())
+                .addValue("last_name", e.getLastName())
+                .addValue("mobile", e.getMobile())
+                .addValue("birthday", e.getBirthday())
+                .addValue("home_id", e.getHomeId());
+
+        namedParameterJdbcTemplate.update("INSERT INTO PERSON (FIRST_NAME, LAST_NAME, MOBILE, BIRTHDAY, HOME_ID) VALUES (:first_name, :last_name, :mobile, :birthday, :home_id);", parameters, holder);
+        return holder.getKey().intValue();
+    }
+
+    public int updatePerson(Person e){
+        return jdbcTemplate.update("UPDATE PERSON SET FIRST_NAME = '" +
+                e.getFirstName() + "', LAST_NAME = '" +
+                e.getLastName() + "', MOBILE = '" +
+                e.getMobile() + "', BIRTHDAY = '" +
+                e.getBirthday() + "', HOME_ID = '" +
+                e.getHomeId() + "' where id = '" + e.getId() + "');");
+    }
+
+    public int deletePerson(Person e){
+        return jdbcTemplate.update("DELETE FROM PERSON where ID = " + e.getId() + ";");
+    }
+
+    public void removeList(Person... e){
+        for(Person person : e){
+            deletePerson(person);
+        }
+    }
+
+    public List<Person> findAllByFirstName(String firstName, Class objectType){
+        return jdbcTemplate.queryForList("SELECT * FROM PERSON WHERE FIRST_NAME = '" + firstName + "';", Person.class);
+    }
+
+    public Person findById(int ID){
+        return jdbcTemplate.queryForObject("SELECT * FROM PERSON WHERE ID = " + ID + ";", Person.class);
+    }
+
+    public Map<String, List<Person>> surnameQuery(){
+        List<Person> people = getAllPeople();
+        Map<String, List<Person>> map = new HashMap<>();
+        for(Person person : people){
+            if(map.containsKey(person.getLastName())){
+                map.get(person.getLastName()).add(person);
+            } else {
+                map.put(person.getLastName(), new ArrayList<Person>());
+                map.get(person.getLastName()).add(person);
+            }
+        }
+        return map;
+    }
+
+    public Map<String, Integer> firstNameCount(){
+        List<Person> people = getAllPeople();
+        Map<String, Integer> map = new HashMap<>();
+        for(Person person : people){
+            if(map.containsKey(person.getFirstName())){
+                int amount = map.get(person.getFirstName());
+                amount = amount + 1;
+                map.put(person.getFirstName(), amount);
+            } else {
+                map.put(person.getFirstName(), 1);
+            }
+        }
+        return map;
+    }
+}

src/main/resources/Qs

@@ -0,0 +1,26 @@
+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 ('Lords of Dogtown',	107,	'Sport',	7.1,	'PG-13');
+INSERT INTO MOVIES (Title, Runtime, Genre, IMDB_Score, Rating) VALUES ('A Beautiful Mind',	135,	'Drama',	8.2,	'PG-13');
+
+select * from movies where genre = 'Sci-Fi'
+
+select * from movies where IMDB_SCORE > 6.5
+
+select * from movies where rating = 'G' or rating = 'PG' and RUNTIME < 100
+
+select AVG(RUNTIME) from movies where IMDB_SCORE < 7.5 group by genre
+
+update movies set rating = 'R' where title = 'Starship Troopers'
+
+select rating, id from movies where genre = 'Horror' or genre = 'Documentary' order by rating
+
+select avg(IMDB_SCORE), rating from movies group by rating
+
+select rating from movies group by rating HAVING COUNT(*) > 1
+
+delete from movies where rating = 'R'

src/main/resources/application-h2.properties

@@ -1,4 +1,9 @@
-spring.datasource.url=jdbc:h2:mem:testdb;Mode=Oracle
+spring.profiles.active=h2
+logging.level.org.springframework.boot.context.embedded=INFO
+spring.jpa.database-platform=org.hibernate.dialect.Oracle10gDialect
+
+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.h2.console.enabled=true

src/main/resources/application.properties

@@ -1,3 +1,4 @@
 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
+