iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fixed the name of the fetch example

This commit is contained in:
Venkata Kiran Surapaneni 2019-01-25 03:06:50 -05:00
parent 2fadf8b5a0
commit 474a3675f1
1 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
persistence-modules/core-java-persistence/src/test/java/com/baeldung/jdbc/ResultSetLiveTest.java
View File

@ -79,7 +79,7 @@ public class ResultSetLiveTest {
} }
} }
assertEquals("Employee information retreived by column ids:", expectedEmployee1, employee); assertEquals("Employee information retreived by column ids.", expectedEmployee1, employee);
} }
@Test @Test
@ -112,7 +112,7 @@ public class ResultSetLiveTest {
@Test @Test
public void givenDbConnectionE_whenRowCount_thenCorrect() throws SQLException { public void givenDbConnectionE_whenRowCount_thenCorrect() throws SQLException {
int numOfRows = 0; int numOfRows = 0;
try (PreparedStatement pstmt = dbConnection.prepareStatement("select * from employees", ResultSet.TYPE_SCROLL_SENSITIVE); ResultSet rs = pstmt.executeQuery()) { try (PreparedStatement pstmt = dbConnection.prepareStatement("select * from employees", ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE); ResultSet rs = pstmt.executeQuery()) {
rs.last(); rs.last();
numOfRows = rs.getRow(); numOfRows = rs.getRow();
} }
@ -123,7 +123,7 @@ public class ResultSetLiveTest {
@Test @Test
public void givenDbConnectionG_whenAbsoluteNavigation_thenCorrect() throws SQLException { public void givenDbConnectionG_whenAbsoluteNavigation_thenCorrect() throws SQLException {
Employee secondEmployee = null; Employee secondEmployee = null;
try (PreparedStatement pstmt = dbConnection.prepareStatement("select * from employees", ResultSet.TYPE_SCROLL_SENSITIVE); ResultSet rs = pstmt.executeQuery()) { try (PreparedStatement pstmt = dbConnection.prepareStatement("select * from employees", ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE); ResultSet rs = pstmt.executeQuery()) {
rs.absolute(2); rs.absolute(2);
secondEmployee = populateResultSet(rs); secondEmployee = populateResultSet(rs);
} }
@ -145,7 +145,7 @@ public class ResultSetLiveTest {
@Test @Test
public void givenDbConnectionI_whenNavigation_thenCorrect() throws SQLException { public void givenDbConnectionI_whenNavigation_thenCorrect() throws SQLException {
Employee firstEmployee = null; Employee firstEmployee = null;
try (PreparedStatement pstmt = dbConnection.prepareStatement("select * from employees", ResultSet.TYPE_SCROLL_SENSITIVE); ResultSet rs = pstmt.executeQuery()) { try (PreparedStatement pstmt = dbConnection.prepareStatement("select * from employees", ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE); ResultSet rs = pstmt.executeQuery()) {
while (rs.next()) { while (rs.next()) {
Employee employee = populateResultSet(rs); Employee employee = populateResultSet(rs);
} }
@ -195,6 +195,7 @@ public class ResultSetLiveTest {
@Test @Test
public void givenDbConnectionK_whenUpdate_thenCorrect() throws SQLException { public void givenDbConnectionK_whenUpdate_thenCorrect() throws SQLException {
int numOfRows = 0; int numOfRows = 0;
dbConnection.setHoldability(ResultSet.HOLD_CURSORS_OVER_COMMIT);
try (Statement pstmt = dbConnection.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE, ResultSet.HOLD_CURSORS_OVER_COMMIT)) { try (Statement pstmt = dbConnection.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE, ResultSet.HOLD_CURSORS_OVER_COMMIT)) {
dbConnection.setAutoCommit(false); dbConnection.setAutoCommit(false);
pstmt.executeUpdate("INSERT INTO employees (name, salary,position) VALUES ('Michael',1200.0,'Consultant')"); pstmt.executeUpdate("INSERT INTO employees (name, salary,position) VALUES ('Michael',1200.0,'Consultant')");
@ -211,15 +212,16 @@ public class ResultSetLiveTest {
} }
@Test @Test
public void givenDbConnectionL_whenDelete_thenCorrect() throws SQLException { public void givenDbConnectionM_whenDelete_thenCorrect() throws SQLException {
int numOfRows = 0; int numOfRows = 0;
try (PreparedStatement pstmt = dbConnection.prepareStatement("select * from employees", ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE); ResultSet rs = pstmt.executeQuery()) { try (PreparedStatement pstmt = dbConnection.prepareStatement("select * from employees", ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE); ResultSet rs = pstmt.executeQuery()) {
rs.absolute(3); rs.absolute(3);
rs.deleteRow(); rs.deleteRow();
}
try (PreparedStatement pstmt = dbConnection.prepareStatement("select * from employees", ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE); ResultSet rs = pstmt.executeQuery()) {
rs.last(); rs.last();
numOfRows = rs.getRow(); numOfRows = rs.getRow();
} }
assertEquals("Deleted row", 3, numOfRows); assertEquals("Deleted row", 3, numOfRows);
} }
@ -296,13 +298,13 @@ public class ResultSetLiveTest {
} }
@Test @Test
public void givenDbConnectionM_whenDelete_thenCorrect() throws SQLException { public void givenDbConnectionL_whenFetch_thenCorrect() throws SQLException {
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
ResultSet rs = null; ResultSet rs = null;
List<Employee> listOfEmployees = new ArrayList<Employee>(); List<Employee> listOfEmployees = new ArrayList<Employee>();
try { try {
pstmt = dbConnection.prepareStatement("select * from employees", ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY); pstmt = dbConnection.prepareStatement("select * from employees", ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE);
pstmt.setFetchSize(2); pstmt.setFetchSize(1);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
rs.setFetchSize(1); rs.setFetchSize(1);
while (rs.next()) { while (rs.next()) {
@ -318,7 +320,7 @@ public class ResultSetLiveTest {
pstmt.close(); pstmt.close();
} }
assertEquals(3, listOfEmployees.size()); assertEquals(4, listOfEmployees.size());
} }
@AfterClass @AfterClass