如何使用Groovy连接Redshift并执行查询？

Groovy完全兼容Java，你可以直接复用Java的JDBC逻辑，且Groovy的语法能让代码更简洁，以下是完整实现步骤：

1. 引入Redshift JDBC驱动 #

如果用Gradle管理项目，在build.gradle中添加依赖：

dependencies {
    implementation 'com.amazon.redshift:redshift-jdbc42:2.1.0.17'
}

如果是Maven，对应依赖配置：

<dependency>
    <groupId>com.amazon.redshift</groupId>
    <artifactId>redshift-jdbc42</artifactId>
    <version>2.1.0.17</version>
</dependency>

2. 连接与查询示例代码 #

Groovy的withCloseable方法会自动关闭资源，无需手动处理try-catch和资源释放，代码更简洁：

import java.sql.DriverManager

// 替换为你的Redshift连接参数
def redshiftUrl = "jdbc:redshift://your-cluster-endpoint:5439/your-db-name"
def username = "your-username"
def password = "your-password"

// 建立连接并执行查询
DriverManager.getConnection(redshiftUrl, username, password).withCloseable { conn ->
    conn.createStatement().withCloseable { stmt ->
        def query = "SELECT * FROM your-target-table LIMIT 10"
        stmt.executeQuery(query).withCloseable { rs ->
            // 遍历处理查询结果
            while (rs.next()) {
                println "字段1: ${rs.getString(1)}, 字段2: ${rs.getInt(2)}"
            }
        }
    }
}

3. 防SQL注入的PreparedStatement用法 #

如果需要执行带参数的查询，用PreparedStatement的写法和Java一致，Groovy同样可以简化：

def paramQuery = "SELECT * FROM your-target-table WHERE id = ?"
DriverManager.getConnection(redshiftUrl, username, password).withCloseable { conn ->
    conn.prepareStatement(paramQuery).withCloseable { pstmt ->
        pstmt.setInt(1, 123) // 设置参数
        pstmt.executeQuery().withCloseable { rs ->
            // 处理结果
            if (rs.next()) {
                println "查询结果: ${rs.getString('column-name')}"
            }
        }
    }
}

内容的提问来源于stack exchange，提问作者Nagalaxmi Shetty