Skip to content

Commit d793e65

Browse files
committed
returning written rows right from response
1 parent 11206f1 commit d793e65

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

jdbc-v2/src/main/java/com/clickhouse/jdbc/StatementImpl.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -193,16 +193,18 @@ public int executeUpdate(String sql, QuerySettings settings) throws SQLException
193193
QuerySettings mergedSettings = QuerySettings.merge(connection.getDefaultQuerySettings(), settings);
194194
mergedSettings.serverSetting(ServerSettings.WAIT_END_OF_QUERY, "1");
195195
lastSql = parseJdbcEscapeSyntax(sql);
196+
int updateCount = 0;
196197
try (QueryResponse response = queryTimeout == 0 ? connection.client.query(lastSql, mergedSettings).get()
197198
: connection.client.query(lastSql, mergedSettings).get(queryTimeout, TimeUnit.SECONDS)) {
198199
currentResultSet = null;
200+
updateCount = (int) response.getWrittenRows();
199201
metrics = response.getMetrics();
200202
lastQueryId = response.getQueryId();
201203
} catch (Exception e) {
202204
throw ExceptionUtils.toSqlState(e);
203205
}
204206

205-
return (int) metrics.getMetric(ServerMetrics.NUM_ROWS_WRITTEN).getLong();
207+
return updateCount;
206208
}
207209

208210
@Override

0 commit comments

Comments
 (0)