[JAVA-2306] Moved articles from spring-persistence-simple-2

* https://www.baeldung.com/spring-jdbctemplate-testing went to spring-jdbc * https://www.baeldung.com/spring-jdbctemplate-in-list went to spring-jdbc * https://www.baeldung.com/spring-mock-jndi-datasource went to spring-persistence-simple * Deleted spring-persistence-simple-2 module as all articles have been moved
2020-08-30 15:59:35 +02:00
parent 4e4ac650fa
commit eb4c306451
30 changed files with 224 additions and 89 deletions
@@ -1,4 +1,4 @@
-package com.baeldung.spring.jdbc;
+package com.baeldung.spring.jdbc.template.guide;

 import java.sql.SQLException;

@@ -1,4 +1,4 @@
-package com.baeldung.spring.jdbc;
+package com.baeldung.spring.jdbc.template.guide;

 public class Employee {
    private int id;
@@ -1,4 +1,4 @@
-package com.baeldung.spring.jdbc;
+package com.baeldung.spring.jdbc.template.guide;

 import java.sql.PreparedStatement;
 import java.sql.SQLException;
@@ -1,4 +1,4 @@
-package com.baeldung.spring.jdbc;
+package com.baeldung.spring.jdbc.template.guide;

 import java.sql.ResultSet;
 import java.sql.SQLException;
@@ -1,4 +1,4 @@
-package com.baeldung.spring.jdbc.config;
+package com.baeldung.spring.jdbc.template.guide.config;

 import javax.sql.DataSource;

@@ -17,8 +17,8 @@ public class SpringJdbcConfig {
    public DataSource dataSource() {
        return new EmbeddedDatabaseBuilder()
          .setType(EmbeddedDatabaseType.H2)
-          .addScript("classpath:jdbc/schema.sql")
-          .addScript("classpath:jdbc/test-data.sql")
+          .addScript("classpath:com/baeldung/spring/jdbc/template/guide/schema.sql")
+          .addScript("classpath:com/baeldung/spring/jdbc/template/guide/test-data.sql")
          .build();
    }

@@ -0,0 +1,42 @@
+package com.baeldung.spring.jdbc.template.inclause;
+
+public class Employee {
+    private int id;
+
+    private String firstName;
+
+    private String lastName;
+
+
+    public Employee(int id, String firstName, String lastName) {
+        this.id = id;
+        this.firstName = firstName;
+        this.lastName = lastName;
+    }
+
+    public int getId() {
+        return id;
+    }
+
+    public void setId(final int id) {
+        this.id = id;
+    }
+
+    public String getFirstName() {
+        return firstName;
+    }
+
+    public void setFirstName(final String firstName) {
+        this.firstName = firstName;
+    }
+
+    public String getLastName() {
+        return lastName;
+    }
+
+    public void setLastName(final String lastName) {
+        this.lastName = lastName;
+    }
+
+
+}
@@ -0,0 +1,61 @@
+package com.baeldung.spring.jdbc.template.inclause;
+
+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.stereotype.Repository;
+
+import javax.sql.DataSource;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+
+@Repository
+public class EmployeeDAO {
+    private JdbcTemplate jdbcTemplate;
+    private NamedParameterJdbcTemplate namedJdbcTemplate;
+
+    public void setDataSource(DataSource dataSource) {
+        jdbcTemplate = new JdbcTemplate(dataSource);
+        namedJdbcTemplate = new NamedParameterJdbcTemplate(dataSource);
+    }
+
+    public List<Employee> getEmployeesFromIdListNamed(List<Integer> ids) {
+        SqlParameterSource parameters = new MapSqlParameterSource("ids", ids);
+        List<Employee> employees = namedJdbcTemplate.query(
+          "SELECT * FROM EMPLOYEE WHERE id IN (:ids)",
+          parameters,
+          (rs, rowNum) -> new Employee(rs.getInt("id"), rs.getString("first_name"), rs.getString("last_name")));
+
+        return employees;
+    }
+
+    public List<Employee> getEmployeesFromIdList(List<Integer> ids) {
+        String inSql = String.join(",", Collections.nCopies(ids.size(), "?"));
+        List<Employee> employees = jdbcTemplate.query(
+          String.format("SELECT * FROM EMPLOYEE WHERE id IN (%s)", inSql),
+          ids.toArray(),
+          (rs, rowNum) -> new Employee(rs.getInt("id"), rs.getString("first_name"), rs.getString("last_name")));
+
+        return employees;
+    }
+
+    public List<Employee> getEmployeesFromLargeIdList(List<Integer> ids) {
+        jdbcTemplate.execute("CREATE TEMPORARY TABLE IF NOT EXISTS employee_tmp (id INT NOT NULL)");
+
+        List<Object[]> employeeIds = new ArrayList<>();
+        for (Integer id : ids) {
+            employeeIds.add(new Object[] { id });
+        }
+        jdbcTemplate.batchUpdate("INSERT INTO employee_tmp VALUES(?)", employeeIds);
+
+        List<Employee> employees = jdbcTemplate.query(
+          "SELECT * FROM EMPLOYEE WHERE id IN (SELECT id FROM employee_tmp)",
+          (rs, rowNum) -> new Employee(rs.getInt("id"), rs.getString("first_name"), rs.getString("last_name")));
+
+        jdbcTemplate.update("DELETE FROM employee_tmp");
+
+        return employees;
+    }
+}
@@ -0,0 +1,42 @@
+package com.baeldung.spring.jdbc.template.testing;
+
+public class Employee {
+    private int id;
+
+    private String firstName;
+
+    private String lastName;
+
+
+    public Employee(int id, String firstName, String lastName) {
+        this.id = id;
+        this.firstName = firstName;
+        this.lastName = lastName;
+    }
+
+    public int getId() {
+        return id;
+    }
+
+    public void setId(final int id) {
+        this.id = id;
+    }
+
+    public String getFirstName() {
+        return firstName;
+    }
+
+    public void setFirstName(final String firstName) {
+        this.firstName = firstName;
+    }
+
+    public String getLastName() {
+        return lastName;
+    }
+
+    public void setLastName(final String lastName) {
+        this.lastName = lastName;
+    }
+
+
+}
@@ -0,0 +1,19 @@
+package com.baeldung.spring.jdbc.template.testing;
+
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Repository;
+
+import javax.sql.DataSource;
+
+@Repository
+public class EmployeeDAO {
+    private JdbcTemplate jdbcTemplate;
+
+    public void setDataSource(DataSource dataSource) {
+        jdbcTemplate = new JdbcTemplate(dataSource);
+    }
+
+    public int getCountOfEmployees() {
+        return jdbcTemplate.queryForObject("SELECT COUNT(*) FROM EMPLOYEE", Integer.class);
+    }
+}
@@ -0,0 +1,7 @@
+CREATE TABLE EMPLOYEE
+(
+	ID int  NOT NULL PRIMARY KEY,
+	FIRST_NAME varchar(255),
+	LAST_NAME varchar(255),
+	ADDRESS varchar(255)
+);
@@ -0,0 +1,7 @@
+INSERT INTO EMPLOYEE VALUES (1, 'James', 'Gosling', 'Canada');
+
+INSERT INTO EMPLOYEE VALUES (2, 'Donald', 'Knuth', 'USA');
+
+INSERT INTO EMPLOYEE VALUES (3, 'Linus', 'Torvalds', 'Finland');
+
+INSERT INTO EMPLOYEE VALUES (4, 'Dennis', 'Ritchie', 'USA');
@@ -0,0 +1,7 @@
+CREATE TABLE EMPLOYEE
+(
+	ID int  NOT NULL PRIMARY KEY,
+	FIRST_NAME varchar(255),
+	LAST_NAME varchar(255),
+	ADDRESS varchar(255)
+);
@@ -0,0 +1,7 @@
+INSERT INTO EMPLOYEE VALUES (1, 'James', 'Gosling', 'Canada');
+
+INSERT INTO EMPLOYEE VALUES (2, 'Donald', 'Knuth', 'USA');
+
+INSERT INTO EMPLOYEE VALUES (3, 'Linus', 'Torvalds', 'Finland');
+
+INSERT INTO EMPLOYEE VALUES (4, 'Dennis', 'Ritchie', 'USA');
@@ -1,9 +1,11 @@
-package com.baeldung.spring.jdbc;
+package com.baeldung.spring.jdbc.template.guide;

 import java.util.ArrayList;
 import java.util.List;

-import com.baeldung.spring.jdbc.config.SpringJdbcConfig;
+import com.baeldung.spring.jdbc.template.guide.Employee;
+import com.baeldung.spring.jdbc.template.guide.EmployeeDAO;
+import com.baeldung.spring.jdbc.template.guide.config.SpringJdbcConfig;
 import org.junit.Assert;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -0,0 +1,80 @@
+package com.baeldung.spring.jdbc.template.inclause;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.Mock;
+import org.mockito.junit.MockitoJUnitRunner;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseBuilder;
+import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseType;
+
+import javax.sql.DataSource;
+import java.util.ArrayList;
+import java.util.List;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+@RunWith(MockitoJUnitRunner.class)
+
+public class EmployeeDAOUnitTest {
+    @Mock
+    JdbcTemplate jdbcTemplate;
+
+    DataSource dataSource;
+
+    @Before
+    public void setup() {
+        dataSource = new EmbeddedDatabaseBuilder().setType(EmbeddedDatabaseType.H2)
+          .generateUniqueName(true)
+          .addScript("classpath:com/baeldung/spring/jdbc/template/inclause/schema.sql")
+          .addScript("classpath:com/baeldung/spring/jdbc/template/inclause/test-data.sql")
+          .build();
+    }
+
+    @Test
+    public void givenSmallIdList_whenGetEmployeesFromIdList_thenReturnCorrectEmployees() {
+        List<Integer> ids = new ArrayList<>();
+        ids.add(1);
+        ids.add(3);
+        ids.add(4);
+        EmployeeDAO employeeDAO = new EmployeeDAO();
+        employeeDAO.setDataSource(dataSource);
+
+        List<Employee> employees = employeeDAO.getEmployeesFromIdList(ids);
+
+        assertEquals(3, employees.size());
+        assertEquals(1, employees.get(0).getId());
+        assertEquals(3, employees.get(1).getId());
+        assertEquals(4, employees.get(2).getId());
+        
+        employees = employeeDAO.getEmployeesFromIdListNamed(ids);
+
+        assertEquals(3, employees.size());
+        assertEquals(1, employees.get(0).getId());
+        assertEquals(3, employees.get(1).getId());
+        assertEquals(4, employees.get(2).getId());
+    }
+
+    @Test
+    public void givenLargeIdList_whenGetEmployeesFromIdList_thenReturnCorrectEmployees() {
+        List<Integer> ids = new ArrayList<>();
+        ids.add(1);
+        ids.add(3);
+        ids.add(4);
+        EmployeeDAO employeeDAO = new EmployeeDAO();
+        employeeDAO.setDataSource(dataSource);
+
+        List<Employee> employees = employeeDAO.getEmployeesFromLargeIdList(ids);
+
+        assertEquals(3, employees.size());
+        assertEquals(1, employees.get(0).getId());
+        assertEquals(3, employees.get(1).getId());
+        assertEquals(4, employees.get(2).getId());
+
+        ids.clear();
+        ids.add(2);
+        employees = employeeDAO.getEmployeesFromLargeIdList(ids);
+        assertEquals(1, employees.size());
+    }
+}
@@ -0,0 +1,56 @@
+package com.baeldung.spring.jdbc.template.testing;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.Mock;
+import org.mockito.Mockito;
+import org.mockito.junit.MockitoJUnitRunner;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseBuilder;
+import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseType;
+import org.springframework.test.util.ReflectionTestUtils;
+
+import javax.sql.DataSource;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+@RunWith(MockitoJUnitRunner.class)
+public class EmployeeDAOUnitTest {
+    @Mock
+    JdbcTemplate jdbcTemplate;
+
+    DataSource dataSource;
+
+    @Before
+    public void setup() {
+        dataSource = new EmbeddedDatabaseBuilder().setType(EmbeddedDatabaseType.H2)
+          .generateUniqueName(true)
+          .addScript("classpath:com/baeldung/spring/jdbc/template/testing/schema.sql")
+          .addScript("classpath:com/baeldung/spring/jdbc/template/testing/test-data.sql")
+          .build();
+    }
+
+    @Test
+    public void whenMockJdbcTemplate_thenReturnCorrectEmployeeCount() {
+        EmployeeDAO employeeDAO = new EmployeeDAO();
+        ReflectionTestUtils.setField(employeeDAO, "jdbcTemplate", jdbcTemplate);
+        Mockito.when(jdbcTemplate.queryForObject("SELECT COUNT(*) FROM EMPLOYEE", Integer.class))
+          .thenReturn(4);
+
+        assertEquals(4, employeeDAO.getCountOfEmployees());
+
+        Mockito.when(jdbcTemplate.queryForObject(Mockito.anyString(), Mockito.eq(Integer.class)))
+          .thenReturn(3);
+
+        assertEquals(3, employeeDAO.getCountOfEmployees());
+    }
+
+    @Test
+    public void whenInjectInMemoryDataSource_thenReturnCorrectEmployeeCount() {
+        EmployeeDAO employeeDAO = new EmployeeDAO();
+        employeeDAO.setDataSource(dataSource);
+
+        assertEquals(4, employeeDAO.getCountOfEmployees());
+    }
+}