Minor cleanups (#585)

Misc cleanups I had stashed locally
duckdb · Feb 12, 2025 · 371a680 · 371a680
1 parent 236e5c1
commit 371a680
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 9 deletions.
diff --git a/include/pgduckdb/logger.hpp b/include/pgduckdb/logger.hpp
@@ -46,7 +46,7 @@ namespace pgduckdb {
 		pd_prevent_errno_in_scope();                                                                                   \
 		static_assert(elevel >= DEBUG5 && elevel <= WARNING_CLIENT_ONLY, "Invalid error level");                       \
 		if (message_level_is_interesting(elevel)) {                                                                    \
-			std::lock_guard<std::mutex> lock(GlobalProcessLock::GetLock());                                            \
+			std::lock_guard<std::mutex> lock(pgduckdb::GlobalProcessLock::GetLock());                                  \
 			if (errstart(elevel, domain))                                                                              \
 				__VA_ARGS__, errfinish(__FILE__, __LINE__, __func__);                                                  \
 		}                                                                                                              \

diff --git a/src/pgduckdb_node.cpp b/src/pgduckdb_node.cpp
@@ -97,8 +97,6 @@ Duckdb_BeginCustomScan(CustomScanState *cscanstate, EState *estate, int eflags)
 static void
 ExecuteQuery(DuckdbScanState *state) {
 	auto &prepared = *state->prepared_statement;
-	auto &query_results = state->query_results;
-	auto &connection = state->duckdb_connection;
 	auto pg_params = state->params;
 	const auto num_params = pg_params ? pg_params->numParams : 0;
 	duckdb::case_insensitive_map_t<duckdb::BoundParameterData> named_values;
@@ -136,14 +134,15 @@ ExecuteQuery(DuckdbScanState *state) {
 		return pending->ThrowError();
 	}
 
-	duckdb::PendingExecutionResult execution_result;
+	duckdb::PendingExecutionResult execution_result = duckdb::PendingExecutionResult::RESULT_NOT_READY;
 	while (true) {
 		execution_result = pending->ExecuteTask();
 		if (duckdb::PendingQueryResult::IsResultReady(execution_result)) {
 			break;
 		}
 
 		if (QueryCancelPending) {
+			auto &connection = state->duckdb_connection;
 			// Send an interrupt
 			connection->Interrupt();
 			auto &executor = duckdb::Executor::Get(*connection->context);
@@ -160,8 +159,8 @@ ExecuteQuery(DuckdbScanState *state) {
 		return pending->ThrowError();
 	}
 
-	query_results = pending->Execute();
-	state->column_count = query_results->ColumnCount();
+	state->query_results = pending->Execute();
+	state->column_count = state->query_results->ColumnCount();
 	state->is_executed = true;
 }
 

diff --git a/src/pgduckdb_planner.cpp b/src/pgduckdb_planner.cpp
@@ -47,8 +47,7 @@ DuckdbPrepare(const Query *query) {
 	elog(DEBUG2, "(PGDuckDB/DuckdbPrepare) Preparing: %s", query_string);
 
 	auto con = pgduckdb::DuckDBManager::GetConnection();
-	auto prepared_query = con->context->Prepare(query_string);
-	return prepared_query;
+	return con->context->Prepare(query_string);
 }
 
 static Plan *

diff --git a/src/utility/copy.cpp b/src/utility/copy.cpp
@@ -21,7 +21,6 @@ extern "C" {
 
 #include "pgduckdb/vendor/pg_list.hpp"
 #include "pgduckdb/pgduckdb_ruleutils.h"
-#include "pgduckdb/vendor/pg_list.hpp"
 }
 
 static constexpr char s3_filename_prefix[] = "s3://";