@Override
  public Object getValueFromResultSet( ResultSet rs, ValueMetaInterface val, int index ) throws KettleDatabaseException {
    Object data;
    try {
      if ( val.getType() == ValueMetaInterface.TYPE_BINARY ) {
        data = rs.getString( index + 1 );
      } else {
        return super.getValueFromResultSet( rs, val, index );
      }
      if ( rs.wasNull() ) {
        data = null;
      }
    } catch ( SQLException e ) {
      throw new KettleDatabaseException( "Unable to get value '"
          + val.toStringMeta() + "' from database resultset, index " + index, e );
    }
    return data;
  }
@Test(expected = KettleDatabaseException.class)
  public void testGetValueFromResultSetWhenExceptionIsComing() throws SQLException, KettleDatabaseException {
    ResultSet rs = mock( ResultSet.class );
    Mockito.when( rs.getString( 3 ) ).thenThrow( SQLException.class );
    ValueMetaString ts = new ValueMetaString( "AzureDB" );
    dbMeta.getValueFromResultSet( rs,ts,2 );
  }