(#28) Added getBlob

citrusframework · Apr 12, 2019 · c8cc8b9 · c8cc8b9
1 parent 3d6ef4c
commit c8cc8b9
Show file tree

Hide file tree

Showing 2 changed files with 26 additions and 4 deletions.
diff --git a/driver/src/main/java/com/consol/citrus/db/driver/JdbcCallableStatement.java b/driver/src/main/java/com/consol/citrus/db/driver/JdbcCallableStatement.java
@@ -181,8 +181,8 @@ public Ref getRef(final int parameterIndex) throws SQLException {
 
     @Override
     public Blob getBlob(final int parameterIndex) throws SQLException {
-        notSupported("getBlob(int parameterIndex)");
-        return null;
+        prepareResultSet();
+        return resultSet.getBlob(parameterIndex);
     }
 
     @Override
@@ -464,8 +464,8 @@ public Ref getRef(final String parameterName) throws SQLException {
 
     @Override
     public Blob getBlob(final String parameterName) throws SQLException {
-        notSupported("getBlob(String parameterName)");
-        return null;
+        prepareResultSet();
+        return resultSet.getBlob(parameterName);
     }
 
     @Override

diff --git a/driver/src/test/java/com/consol/citrus/db/driver/JdbcCallableStatementTest.java b/driver/src/test/java/com/consol/citrus/db/driver/JdbcCallableStatementTest.java
@@ -867,6 +867,28 @@ public void testGetClobByName() {
         verify(resultSetSpy).getClob(TEST_VALUE_NAME);
     }
 
+    @Test
+    public void testGetBlobByIndex() throws SQLException {
+
+        //WHEN
+        callableStatement.getBlob(TEST_VALUE_INDEX);
+
+        //THEN
+        verify(resultSetSpy).next();
+        verify(resultSetSpy).getBlob(TEST_VALUE_INDEX);
+    }
+
+    @Test
+    public void testGetBlobByName() throws SQLException  {
+
+        //WHEN
+        callableStatement.getBlob(TEST_VALUE_NAME);
+
+        //THEN
+        verify(resultSetSpy).next();
+        verify(resultSetSpy).getBlob(TEST_VALUE_NAME);
+    }
+
     @Test
     public void testToString(){
         ToStringVerifier