Replace getColumnName() with getColumnLabel() (#112)

Author: A3a3e1

.circleci/config.yml

@@ -103,7 +103,7 @@ jobs:
       - node/install:
           node-version: << pipeline.parameters.node-version >>
       - setup_remote_docker:
-          version: 19.03.13
+          version: default
           docker_layer_caching: true
       # build and push Docker image
       - run:

CHANGELOG.md

@@ -1,3 +1,6 @@
+## 2.5.10 (June 27, 2025)
+* Fixed the issue with aliases in the `Select Query` action ([#Issue 111](https://github.com/elasticio/jdbc-component/issues/111))
+
 ## 2.5.9 (August 01, 2024)
 * Bumped Sailor to 4.0.3
 * 

README.md

@@ -164,6 +164,12 @@ FROM users
 WHERE userid = @id:number AND language = @lang:string
 ```
 
+You can use aliases too:
+```sql
+SELECT users.id AS internal_id
+FROM internal_users users
+```
+
 Following types are supported:
  * ``string``
  * ``number``

build.gradle

@@ -41,6 +41,7 @@ test {
 task integrationTest(type: Test) {
     testLogging {
         showStandardStreams = true
+        exceptionFormat "full"
     }
     filter() {
         includeTestsMatching "io.elastic.jdbc.integration.*"

component.json

@@ -1,7 +1,7 @@
 {
   "title": "Database",
   "description": "Database JDBC connector",
-  "version": "2.5.9",
+  "version": "2.5.10",
   "credentials": {
     "verifier": "io.elastic.jdbc.JdbcCredentialsVerifier",
     "fields": {

dependencyCheck-suppression.xml

@@ -17,6 +17,14 @@
     <packageUrl regex="true">^pkg:maven/com\.google\.protobuf/protobuf\-java@.*$</packageUrl>
     <cve>CVE-2022-3171</cve>
   </suppress>
+  <suppress>
+    <notes><![CDATA[
+      file name: protobuf-java-3.25.1.jar
+      ]]>
+    </notes>
+    <packageUrl regex="true">^pkg:maven/com\.google\.protobuf/protobuf\-java@.*$</packageUrl>
+    <cve>CVE-2024-7254</cve>
+  </suppress>
   <suppress>
     <notes><![CDATA[
       file name: logback-json-classic-0.1.5.jar

src/main/java/io/elastic/jdbc/utils/Utils.java

@@ -298,7 +298,7 @@ public static Map<String, String> getVariableTypes(String sqlQuery) {
   public static JsonObjectBuilder getColumnDataByType(ResultSet rs, ResultSetMetaData metaData,
       int i, JsonObjectBuilder row) {
     try {
-      final String columnName = metaData.getColumnName(i);
+      final String columnName = metaData.getColumnLabel(i);
       if (null == rs.getObject(columnName)) {
         row.add(columnName, JsonValue.NULL);
         return row;

src/test/groovy/io/elastic/jdbc/integration/actions/select_action/SelectMySQLSpec.groovy

@@ -85,6 +85,13 @@ class SelectMySQLSpec extends Specification {
     return config;
   }
 
+  def getAliasStarsConfig() {
+    JsonObject config = TestUtils.getMysqlConfigurationBuilder()
+        .add("sqlQuery", "SELECT strs.id AS strsid from stars strs")
+        .build()
+    return config;
+  }
+
   def prepareStarsTable() {
     String sql = "DROP TABLE IF EXISTS stars"
     connection.createStatement().execute(sql);
@@ -112,4 +119,15 @@ class SelectMySQLSpec extends Specification {
     0 * errorCallback.receive(_)
   }
 
+  def "select with alias"() {
+    prepareStarsTable();
+    JsonObject snapshot = Json.createObjectBuilder().build();
+    JsonObject body = Json.createObjectBuilder()
+        .build()
+    when:
+    runAction(getAliasStarsConfig(), body, snapshot)
+    then:
+    0 * errorCallback.receive(_)
+  }
+
 }