diff --git a/src/main/java/com/ing/data/cassandra/jdbc/CassandraResultSet.java b/src/main/java/com/ing/data/cassandra/jdbc/CassandraResultSet.java index 07edc07..ec4eb09 100644 --- a/src/main/java/com/ing/data/cassandra/jdbc/CassandraResultSet.java +++ b/src/main/java/com/ing/data/cassandra/jdbc/CassandraResultSet.java @@ -344,7 +344,7 @@ public void close() throws SQLException { public int findColumn(final String columnLabel) throws SQLException { checkNotClosed(); checkName(columnLabel); - return this.currentRow.getColumnDefinitions().firstIndexOf(columnLabel); + return this.currentRow.getColumnDefinitions().firstIndexOf(columnLabel)+1; } @Override @@ -1025,7 +1025,7 @@ public Object getObject(final String columnLabel) throws SQLException { @Override public T getObject(final String columnLabel, final Class type) throws SQLException { final int index = findColumn(columnLabel); - return getObject(index + 1, type); + return getObject(index, type); } @Override @@ -1149,7 +1149,7 @@ public T getObjectFromJson(final int columnIndex, final Class type) throw @Override public T getObjectFromJson(final String columnLabel, final Class type) throws SQLException { final int index = findColumn(columnLabel); - return getObjectFromJson(index + 1, type); + return getObjectFromJson(index, type); } @Override