diff --git a/src/node_sqlite.cc b/src/node_sqlite.cc index 2c830961e72817..5b925fa5e80c4d 100644 --- a/src/node_sqlite.cc +++ b/src/node_sqlite.cc @@ -1161,18 +1161,22 @@ void StatementSync::All(const FunctionCallbackInfo& args) { auto reset = OnScopeLeave([&]() { sqlite3_reset(stmt->statement_); }); int num_cols = sqlite3_column_count(stmt->statement_); LocalVector rows(isolate); + LocalVector row_keys(isolate); while ((r = sqlite3_step(stmt->statement_)) == SQLITE_ROW) { - LocalVector row_keys(isolate); - row_keys.reserve(num_cols); + if (row_keys.size() == 0) { + row_keys.reserve(num_cols); + for (int i = 0; i < num_cols; ++i) { + Local key; + if (!stmt->ColumnNameToName(i).ToLocal(&key)) return; + row_keys.emplace_back(key); + } + } + LocalVector row_values(isolate); row_values.reserve(num_cols); - for (int i = 0; i < num_cols; ++i) { - Local key; - if (!stmt->ColumnNameToName(i).ToLocal(&key)) return; Local val; if (!stmt->ColumnToValue(i).ToLocal(&val)) return; - row_keys.emplace_back(key); row_values.emplace_back(val); }