improvement BAEL-2897 (#6795)

* added example code for BAEL-2083 * updated example code for BAEL-2083 * added example code for BAEL-2849 * updated the example code with data.sql * improvement BAEL-2897 * updated the persistence module * updated readme
2019-04-24 16:05:24 +01:00
parent ebde333439
commit b798326b29
14 changed files with 3 additions and 2 deletions
@@ -0,0 +1,25 @@
+/target/
+!.mvn/wrapper/maven-wrapper.jar
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/build/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
@@ -0,0 +1,3 @@
+### Relevant Articles: 
+- [Access the Same In-Memory H2 Database in Multiple Spring Boot Applications](https://www.baeldung.com/spring-boot-access-h2-database-multiple-apps)
+- [Spring Boot With H2 Database](https://www.baeldung.com/spring-boot-h2-database)
@@ -0,0 +1,54 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xmlns="http://maven.apache.org/POM/4.0.0"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <groupId>com.baeldung.h2db</groupId>
+    <artifactId>spring-boot-h2-database</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+	<name>spring-boot-h2-database</name>
+    <packaging>jar</packaging>
+    <description>Demo Spring Boot applications that starts H2 in memory database</description>
+
+    <parent>
+        <artifactId>parent-boot-2</artifactId>
+        <groupId>com.baeldung</groupId>
+        <version>0.0.1-SNAPSHOT</version>
+        <relativePath>../../parent-boot-2</relativePath>
+    </parent>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-jpa</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.h2database</groupId>
+            <artifactId>h2</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
+        <java.version>1.8</java.version>
+        <!-- The main class to start by executing java -jar -->
+        <start-class>com.baeldung.h2db.demo.server.SpringBootApp</start-class>
+        <spring-boot.version>2.0.4.RELEASE</spring-boot.version>
+    </properties>
+    	
+</project>
@@ -0,0 +1,14 @@
+package com.baeldung.h2db.auto.configuration;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.ComponentScan;
+
+@SpringBootApplication
+public class AutoConfigurationDemo {
+
+    public static void main(String[] args) {
+        SpringApplication.run(AutoConfigurationDemo.class, args);
+    }
+
+}
@@ -0,0 +1,53 @@
+package com.baeldung.h2db.demo.client;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.Arrays;
+import javax.annotation.PostConstruct;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.PropertySource;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.RowMapper;
+
+@SpringBootApplication
+@ComponentScan("com.baeldung.h2db.demo.client")
+public class ClientSpringBootApp {
+
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
+    public static void main(String[] args) {
+        System.setProperty("spring.datasource.url","jdbc:h2:tcp://localhost:9091/mem:mydb");
+        SpringApplication.run(ClientSpringBootApp.class, args);
+    }
+
+    @PostConstruct
+    private void initDb() {
+        System.out.println("****** Inserting more sample data in the table: Employees ******");
+        String sqlStatements[] = {
+            "insert into employees(first_name, last_name) values('Donald','Trump')",
+            "insert into employees(first_name, last_name) values('Barack','Obama')"
+        };
+
+        Arrays.asList(sqlStatements).stream().forEach(sql -> {
+            System.out.println(sql);
+            jdbcTemplate.execute(sql);
+        });
+
+        System.out.println(String.format("****** Fetching from table: %s ******", "Employees"));
+        jdbcTemplate.query("select id,first_name,last_name from employees",
+            new RowMapper<Object>() {
+                @Override
+                public Object mapRow(ResultSet rs, int i) throws SQLException {
+                    System.out.println(String.format("id:%s,first_name:%s,last_name:%s",
+                        rs.getString("id"),
+                        rs.getString("first_name"),
+                        rs.getString("last_name")));
+                    return null;
+                }
+            });
+    }
+}
@@ -0,0 +1,61 @@
+package com.baeldung.h2db.demo.server;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.util.Arrays;
+import javax.annotation.PostConstruct;
+import org.h2.tools.Server;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.RowMapper;
+
+@SpringBootApplication
+@ComponentScan("com.baeldung.h2db.demo.server")
+public class SpringBootApp {
+
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
+    public static void main(String[] args) {
+        SpringApplication.run(SpringBootApp.class, args);
+    }
+
+    @PostConstruct
+    private void initDb() {
+        System.out.println(String.format("****** Creating table: %s, and Inserting test data ******", "Employees"));
+
+        String sqlStatements[] = {
+            "drop table employees if exists",
+            "create table employees(id serial,first_name varchar(255),last_name varchar(255))",
+            "insert into employees(first_name, last_name) values('Eugen','Paraschiv')",
+            "insert into employees(first_name, last_name) values('Scott','Tiger')"
+        };
+
+        Arrays.asList(sqlStatements).stream().forEach(sql -> {
+            System.out.println(sql);
+            jdbcTemplate.execute(sql);
+        });
+
+        System.out.println(String.format("****** Fetching from table: %s ******", "Employees"));
+        jdbcTemplate.query("select id,first_name,last_name from employees",
+            new RowMapper<Object>() {
+                @Override
+                public Object mapRow(ResultSet rs, int i) throws SQLException {
+                    System.out.println(String.format("id:%s,first_name:%s,last_name:%s",
+                        rs.getString("id"),
+                        rs.getString("first_name"),
+                        rs.getString("last_name")));
+                    return null;
+                }
+            });
+    }
+
+    @Bean(initMethod = "start", destroyMethod = "stop")
+    public Server inMemoryH2DatabaseServer() throws SQLException {
+        return Server.createTcpServer("-tcp", "-tcpAllowOthers", "-tcpPort", "9091");
+    }
+}
@@ -0,0 +1,12 @@
+package com.baeldung.h2db.springboot;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class SpringBootH2Application {
+
+    public static void main(String... args) {
+        SpringApplication.run(SpringBootH2Application.class, args);
+    }
+}
@@ -0,0 +1,10 @@
+package com.baeldung.h2db.springboot.daos;
+
+
+
+
+import com.baeldung.h2db.springboot.models.User;
+import org.springframework.data.repository.CrudRepository;
+
+public interface UserRepository extends CrudRepository<User, Integer> {
+}
@@ -0,0 +1,54 @@
+package com.baeldung.h2db.springboot.models;
+
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+@Table(name = "users")
+@Entity
+public class User {
+
+    @Id
+    @GeneratedValue
+    private int id;
+
+    private String firstName;
+
+    private String lastName;
+
+    public User() { }
+
+    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;
+    }
+
+    @Override
+    public String toString() {
+        return "User{" +
+                "id=" + id +
+                ", firstName='" + firstName + '\'' +
+                ", lastName='" + lastName + '\'' +
+                '}';
+    }
+}
@@ -0,0 +1,8 @@
+spring.datasource.url=jdbc:h2:mem:mydb
+spring.datasource.driverClassName=org.h2.Driver
+spring.datasource.username=sa
+spring.datasource.password=
+spring.jpa.hibernate.ddl-auto=create-drop
+spring.h2.console.enabled=true
+spring.h2.console.path=/h2-console
+debug=true
@@ -0,0 +1,13 @@
+DROP TABLE IF EXISTS billionaires;
+
+CREATE TABLE billionaires (
+  id INT AUTO_INCREMENT  PRIMARY KEY,
+  first_name VARCHAR(250) NOT NULL,
+  last_name VARCHAR(250) NOT NULL,
+  career VARCHAR(250) DEFAULT NULL
+);
+
+INSERT INTO billionaires (first_name, last_name, career) VALUES
+('Aliko', 'Dangote', 'Billionaire Industrialist'),
+('Bill', 'Gates', 'Billionaire Tech Entrepreneur'),
+('Folrunsho', 'Alakija', 'Billionaire Oil Magnate');
@@ -0,0 +1,50 @@
+package com.baeldung;
+
+import com.baeldung.h2db.springboot.SpringBootH2Application;
+import com.baeldung.h2db.springboot.daos.UserRepository;
+import com.baeldung.h2db.springboot.models.User;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+import java.util.List;
+
+import static org.junit.Assert.*;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = SpringBootH2Application.class)
+public class SpringBootH2IntegrationTest {
+
+    @Autowired
+    private UserRepository userRepository;
+
+    @Test
+    public void contextLoads() { }
+
+    @Test
+    public void givenUserProfile_whenAddUser_thenCreateNewUser() {
+        User user = new User();
+        user.setFirstName("John");
+        user.setLastName("Doe");
+        userRepository.save(user);
+        List<User> users = (List<User>) userRepository.findAll();
+        assertFalse(users.isEmpty());
+
+        String firstName = "Aliko";
+        String lastName = "Dangote";
+        User user1 = userRepository.findById(users.get(0).getId()).get();
+        user1.setLastName(lastName);
+        user1.setFirstName(firstName);
+        userRepository.save(user1);
+
+        user = userRepository.findById(user.getId()).get();
+        assertEquals(user.getFirstName(), firstName);
+        assertEquals(user.getLastName(), lastName);
+
+        userRepository.deleteById(user.getId());
+        assertTrue( ((List<User>) userRepository.findAll()).isEmpty());
+    }
+
+}
@@ -0,0 +1,19 @@
+package com.baeldung;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+import org.springframework.test.context.support.AnnotationConfigContextLoader;
+import org.springframework.test.context.web.WebAppConfiguration;
+
+
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(loader = AnnotationConfigContextLoader.class)
+@WebAppConfiguration
+public class SpringContextIntegrationTest {
+
+    @Test
+    public void whenSpringContextIsBootstrapped_thenNoExceptions() {
+    }
+}