initial commit

README.md

@@ -5,7 +5,7 @@
 The following lab is to be completed using the H2 Console. Once you have figured out the correct queries for each step, save a copy in a file called `src/main/resources/script.sql`. This will be how you submit this assignment. If at any time you need to reset the database, you can restart your Spring Boot server.
 
 ### Mini Movie Database
-
+_**`****__`**_
 Add the following movies to the `movies` table using an insert statement:
 
 | Title | Runtime | Genre | IMDB Score | Rating |

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

@@ -1,13 +1,26 @@
 package io.zipcoder.persistenceapp;
 
+import com.apple.eawt.Application;
 import org.h2.server.web.WebServlet;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
 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 org.springframework.jdbc.core.JdbcTemplate;
+
+import java.util.Arrays;
+import java.util.List;
+import java.util.stream.Collectors;
 
 @SpringBootApplication
-public class PersistenceStarterApplication {
+public class PersistenceStarterApplication implements CommandLineRunner  {
+
+	private static final Logger log = LoggerFactory.getLogger(Application.class);
+
 
 	public static void main(String[] args) {
 		SpringApplication.run(PersistenceStarterApplication.class, args);
@@ -19,4 +32,26 @@ public class PersistenceStarterApplication {
 		registrationBean.addUrlMappings("/console/*");
 		return registrationBean;
 	}
+     @Autowired
+
+	 JdbcTemplate jdbcTemplate;
+
+	@Override
+
+	public void run(String... strings) throws Exception {
+		log.info("Creating tables");
+		jdbcTemplate.execute("DROP TABLE Person IF EXISTS");
+		jdbcTemplate.execute("CREATE TABLE Person(" +
+				"id Integer(10), first_name VARCHAR(255), last_name VARCHAR(255),Mobile VARCHAR(255),Birthday DATE,Home_Id SMALLINT(5)");
+
+		jdbcTemplate.batchUpdate("INSERT INTO Person(id,first_name, last_name,Mobile,Birthday,Home_Id) VALUES ('1','hello','world','111-222-3333','01-2-1980','2')");
+	    jdbcTemplate.batchUpdate("INSERT INTO Person(id,first_name, last_name,Mobile,Birthday,Home_Id) VALUES ('2','hai','world1','222-222-3333','02-3-1985','3')");
+		jdbcTemplate.batchUpdate("INSERT INTO Person(id,first_name, last_name,Mobile,Birthday,Home_Id) VALUES ('3','welcome','world','333-222-3333','03-5-1989','4')");
+		jdbcTemplate.batchUpdate("INSERT INTO Person(id,first_name, last_name,Mobile,Birthday,Home_Id) VALUES ('4','hai','','111-222-3333','01-2-1980','2')");
+
+//		List<Object[]> splitUpNames = Arrays.asList("John Woo", "Jeff Dean", "Josh Bloch", "Josh Long").stream()
+//				.map(name -> name.split(" "))
+//				.collect(Collectors.toList());
+		//jdbcTemplate.query("select * from Person where id='1'");
+	}
 }

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

@@ -0,0 +1,61 @@
+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 org.springframework.web.servlet.support.ServletUriComponentsBuilder;
+
+import java.net.URI;
+import java.util.stream.Collectors;
+import java.util.stream.StreamSupport;
+
+@RestController
+public class PersonController  {
+
+    @Autowired
+    PersonRepository personRepository;
+
+    @RequestMapping(value = "/person", method = RequestMethod.POST )
+
+    public ResponseEntity<?> createPerson(@RequestBody PersonService p){
+
+        URI newPollUri = ServletUriComponentsBuilder
+                .fromCurrentRequest()
+                .path("/{id}")
+                .buildAndExpand(p.getID() )
+                .toUri();
+        return new ResponseEntity<> (null, HttpStatus.CREATED) ;
+
+    }
+
+    @RequestMapping(value = "/person{id}", method = RequestMethod.GET)
+
+    public  ResponseEntity<?> getPerson(@PathVariable Integer id){
+
+        PersonService person=personRepository.findOne(id);
+
+        return new ResponseEntity<>(person ,HttpStatus.OK ) ;
+    }
+
+    @RequestMapping(value = "/person", method = RequestMethod.GET)
+    public ResponseEntity<Iterable  <PersonService > >getPersonList( ){
+        Iterable<PersonService> person = personRepository .findAll();
+
+        Iterable<PersonService > personIterable = StreamSupport.stream(person .spliterator(),false)
+
+                .collect(Collectors.toList() );
+        return new ResponseEntity<>(personIterable  , HttpStatus.OK ) ;
+    }
+
+//    @RequestMapping(value = "/person/{id}", method = RequestMethod.PUT)
+//    public  ResponseEntity<?> updatePerson(@RequestBody PersonService person,@PathVariable Integer id){
+//        PersonService  p=personRepository.save(person ) ;
+//        return new ResponseEntity<>(HttpStatus.OK);
+//    }
+    @RequestMapping(value = "/person{id}", method = RequestMethod.DELETE )
+    public void deletePerson( @PathVariable Integer id){
+        personRepository .delete(id);
+
+    }
+}

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

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

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

@@ -0,0 +1,81 @@
+package io.zipcoder.persistenceapp;
+
+import java.util.Date;
+
+public class PersonService {
+    Integer  ID;
+    String FIRST_NAME;
+    String LAST_NAME;
+    String MOBILE;
+    Date BIRTHDAY;
+    int HOME_ID;
+
+    public PersonService(Integer ID, String FIRST_NAME, String LAST_NAME, String MOBILE, Date BIRTHDAY, int HOME_ID) {
+        this.ID = ID;
+        this.FIRST_NAME = FIRST_NAME;
+        this.LAST_NAME = LAST_NAME;
+        this.MOBILE = MOBILE;
+        this.BIRTHDAY = BIRTHDAY;
+        this.HOME_ID = HOME_ID;
+    }
+
+    public Integer getID() {
+        return ID;
+    }
+
+    public void setID(Integer ID) {
+        this.ID = ID;
+    }
+
+    public String getFIRST_NAME() {
+        return FIRST_NAME;
+    }
+
+    public void setFIRST_NAME(String FIRST_NAME) {
+        this.FIRST_NAME = FIRST_NAME;
+    }
+
+    public String getLAST_NAME() {
+        return LAST_NAME;
+    }
+
+    public void setLAST_NAME(String LAST_NAME) {
+        this.LAST_NAME = LAST_NAME;
+    }
+
+    public String getMOBILE() {
+        return MOBILE;
+    }
+
+    public void setMOBILE(String MOBILE) {
+        this.MOBILE = MOBILE;
+    }
+
+    public Date getBIRTHDAY() {
+        return BIRTHDAY;
+    }
+
+    public void setBIRTHDAY(Date BIRTHDAY) {
+        this.BIRTHDAY = BIRTHDAY;
+    }
+
+    public int getHOME_ID() {
+        return HOME_ID;
+    }
+
+    public void setHOME_ID(int HOME_ID) {
+        this.HOME_ID = HOME_ID;
+    }
+
+    @Override
+    public String toString() {
+        return "PersonService{" +
+                "ID=" + ID +
+                ", FIRST_NAME='" + FIRST_NAME + '\'' +
+                ", LAST_NAME='" + LAST_NAME + '\'' +
+                ", MOBILE='" + MOBILE + '\'' +
+                ", BIRTHDAY=" + BIRTHDAY +
+                ", HOME_ID=" + HOME_ID +
+                '}';
+    }
+}

src/main/resources/schema-h2.sql

@@ -60,6 +60,12 @@ CREATE TABLE auto_prices (
 
 );
 
+--INSERT INTO movies(id,title,runtime,genre ,imdb_score ,rating )VALUES    (Howard the Duck , 110 , Sci-Fi , 4.6 , PG );
+--INSERT INTO movies(id,title,runtime,genre ,imdb_score ,rating )VALUES   ( Lavalantula , 83 , Horror , 4.7 , TV-14  );
+--INSERT INTO movies(id,title,runtime,genre ,imdb_score ,rating )VALUES   (Starship Troopers , 129 , Sci-Fi , 7.2 , PG-13);
+--INSERT INTO movies(id,title,runtime,genre ,imdb_score ,rating )VALUES   (Waltz With Bashir , 90 , Documentary , 8.0 , R);
+--INSERT INTO movies(id,title,runtime,genre ,imdb_score ,rating )VALUES   (Spaceballs , 96 , Comedy , 7.1 , PG );
+--INSERT INTO movies(id,title,runtime,genre ,imdb_score ,rating )VALUES   ( Monsters Inc. , 92 , Animation , 8.1 , G);
 
 DROP SEQUENCE hibernate_sequence;
 

src/main/resources/script.sql

@@ -0,0 +1,29 @@
+SELECT * FROM MOVIES;
+
+SELECT  * FROM  MOVIES WHERE GENRE='SCI-FI';
+
+SELECT * FROM MOVIES WHERE IMDB_SCORE>7.0;
+
+SELECT * FROM MOVIES WHERE RATING= ('G' || 'PG')>100;
+
+SELECT AVG(RUNTIME) FROM MOVIES WHERE  RUNTIME<7.5 GROUP BY RATING;
+
+SELECT  * FROM  MOVIES ORDER BY  TITLE WHERE RATING='R';
+
+SELECT ID,RATING FROM MOVIES WHERE GENRE='HORROR' OR GENRE= 'DOCUMENTARY';
+
+SELECT MAX(IMDB_SCORE) AS LargestIMDB_SCORE FROM MOVIES ;
+
+SELECT MIN(IMDB_SCORE)FROM MOVIES;
+
+SELECT AVG(IMDB_SCORE) FROM MOVIES;
+
+SELECT DISTINCT (RATING), ID, TITLE, RUNTIME, GENRE FROM MOVIES;
+
+SELECT * FROM MOVIES;
+SELECT  DISTINCT (RATING), MAX(IMDB_SCORE), MIN (IMDB_SCORE), AVG(IMDB_SCORE) FROM MOVIES GROUP BY RATING
+
+SELECT  DISTINCT (RATING), MAX(IMDB_SCORE), MIN (IMDB_SCORE), AVG(IMDB_SCORE) FROM MOVIES GROUP BY RATING HAVING COUNT(RATING) >1;
+
+
+SELECT DELETE FROM MOVIES WHERE RATING='R';