diff --git a/src/main/java/net/starschema/clouddb/jdbc/BQForwardOnlyResultSet.java b/src/main/java/net/starschema/clouddb/jdbc/BQForwardOnlyResultSet.java index 1131ea2b..d7607aac 100644 --- a/src/main/java/net/starschema/clouddb/jdbc/BQForwardOnlyResultSet.java +++ b/src/main/java/net/starschema/clouddb/jdbc/BQForwardOnlyResultSet.java @@ -383,7 +383,7 @@ public int findColumn(String columnLabel) throws SQLException { } int columncount = this.getMetaData().getColumnCount(); for (int i = 1; i <= columncount; i++) { - if (this.getMetaData().getCatalogName(i).equals(columnLabel)) { + if (this.getMetaData().getColumnName(i).equals(columnLabel)) { return i; } } diff --git a/src/test/java/BQJDBC/QueryResultTest/BQForwardOnlyResultSetFunctionTest.java b/src/test/java/BQJDBC/QueryResultTest/BQForwardOnlyResultSetFunctionTest.java index 0e0ae21d..260efd94 100644 --- a/src/test/java/BQJDBC/QueryResultTest/BQForwardOnlyResultSetFunctionTest.java +++ b/src/test/java/BQJDBC/QueryResultTest/BQForwardOnlyResultSetFunctionTest.java @@ -217,6 +217,8 @@ public void QueryLoad() { .createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY); stmt.setQueryTimeout(500); BQForwardOnlyResultSetFunctionTest.Result = stmt.executeQuery(sql); + Assert.assertNotNull(BQForwardOnlyResultSetFunctionTest.Result.findColumn("word")); + Assert.assertNotNull(BQForwardOnlyResultSetFunctionTest.Result.findColumn("count")); } catch (SQLException e) { this.logger.error("SQLexception" + e.toString()); Assert.fail("SQLException" + e.toString());