in src/main/java/com/aliyun/odps/jdbc/OdpsConnection.java [571:585]
public void close() throws SQLException {
MDC.remove("connectionId");
if (!isClosed) {
for (Statement stmt : stmtHandles) {
if (stmt != null && !stmt.isClosed()) {
stmt.close();
}
}
if (runningInInteractiveMode()) {
executor.close();
}
}
isClosed = true;
log.info("connection closed");
}