Skip to content

Commit f7068b8

Browse files
committed
fix: move the extension out of the duckdb namespace into adbc_scanner
1 parent a3ecd00 commit f7068b8

34 files changed

+143
-124
lines changed

src/adbc_catalog.cpp

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,8 +9,8 @@
99
#include "duckdb/parser/parsed_data/create_table_function_info.hpp"
1010
#include <nanoarrow/nanoarrow.h>
1111

12-
namespace duckdb {
13-
namespace adbc {
12+
namespace adbc_scanner {
13+
using namespace duckdb;
1414

1515
// Info code to name mapping
1616
static string GetInfoName(uint32_t info_code) {
@@ -1215,5 +1215,4 @@ void RegisterAdbcCatalogFunctions(DatabaseInstance &db) {
12151215
}
12161216
}
12171217

1218-
} // namespace adbc
1219-
} // namespace duckdb
1218+
} // namespace adbc_scanner

src/adbc_connection.cpp

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
#include "adbc_connection.hpp"
22

3-
namespace duckdb {
4-
namespace adbc {
3+
namespace adbc_scanner {
4+
using namespace duckdb;
55

66
shared_ptr<AdbcConnectionWrapper> GetValidatedConnection(int64_t connection_id, const string &function_name) {
77
auto &registry = ConnectionRegistry::Get();
@@ -94,5 +94,4 @@ shared_ptr<AdbcConnectionWrapper> CreateConnectionFromOptions(const vector<pair<
9494
return connection;
9595
}
9696

97-
} // namespace adbc
98-
} // namespace duckdb
97+
} // namespace adbc_scanner

src/adbc_filter_pushdown.cpp

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,8 @@
66
#include "duckdb/common/enum_util.hpp"
77
#include "duckdb/common/constants.hpp"
88

9-
namespace duckdb {
10-
namespace adbc {
9+
namespace adbc_scanner {
10+
using namespace duckdb;
1111

1212
string AdbcFilterPushdown::CreateExpression(string &column_name, vector<unique_ptr<TableFilter>> &filters,
1313
string op, vector<Value> &params, vector<LogicalType> &param_types) {
@@ -145,5 +145,4 @@ FilterPushdownResult AdbcFilterPushdown::TransformFilters(const vector<column_t>
145145
return result;
146146
}
147147

148-
} // namespace adbc
149-
} // namespace duckdb
148+
} // namespace adbc_scanner

src/adbc_functions.cpp

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,8 @@
55
#include "duckdb/main/extension/extension_loader.hpp"
66
#include "duckdb/parser/parsed_data/create_scalar_function_info.hpp"
77

8-
namespace duckdb {
9-
namespace adbc {
8+
namespace adbc_scanner {
9+
using namespace duckdb;
1010

1111
// Helper to extract key-value pairs from either a STRUCT or MAP
1212
static vector<pair<string, string>> ExtractOptions(Vector &options_vector, idx_t row_idx) {
@@ -231,5 +231,4 @@ void RegisterAdbcScalarFunctions(DatabaseInstance &db) {
231231
}
232232
}
233233

234-
} // namespace adbc
235-
} // namespace duckdb
234+
} // namespace adbc_scanner

src/adbc_scan.cpp

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -18,8 +18,8 @@
1818
#include <nanoarrow/nanoarrow.h>
1919
#include <queue>
2020

21-
namespace duckdb {
22-
namespace adbc {
21+
namespace adbc_scanner {
22+
using namespace duckdb;
2323

2424
// Numeric value from ADBC statistics union (type_id: 0=int64, 1=uint64, 2=float64)
2525
struct AdbcStatValue {
@@ -1728,5 +1728,4 @@ void RegisterAdbcInsertFunction(DatabaseInstance &db) {
17281728
loader.RegisterFunction(info);
17291729
}
17301730

1731-
} // namespace adbc
1732-
} // namespace duckdb
1731+
} // namespace adbc_scanner

src/adbc_scanner_extension.cpp

Lines changed: 16 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -9,39 +9,43 @@
99
#include "duckdb/main/config.hpp"
1010
#include "query_farm_telemetry.hpp"
1111

12-
namespace duckdb {
12+
namespace adbc_scanner {
1313

14-
static void LoadInternal(ExtensionLoader &loader) {
14+
static void LoadInternal(duckdb::ExtensionLoader &loader) {
1515
// Register ADBC secret type and create secret function
16-
adbc::RegisterAdbcSecrets(loader);
16+
RegisterAdbcSecrets(loader);
1717

1818
// Register ADBC scalar functions (adbc_connect, adbc_disconnect)
19-
adbc::RegisterAdbcScalarFunctions(loader.GetDatabaseInstance());
19+
RegisterAdbcScalarFunctions(loader.GetDatabaseInstance());
2020

2121
// Register ADBC table functions (adbc_scan)
22-
adbc::RegisterAdbcTableFunctions(loader.GetDatabaseInstance());
22+
RegisterAdbcTableFunctions(loader.GetDatabaseInstance());
2323

2424
// Register ADBC catalog functions (adbc_info, adbc_tables)
25-
adbc::RegisterAdbcCatalogFunctions(loader.GetDatabaseInstance());
25+
RegisterAdbcCatalogFunctions(loader.GetDatabaseInstance());
2626

2727
// Register ADBC execute function (adbc_execute for DDL/DML)
28-
adbc::RegisterAdbcExecuteFunction(loader.GetDatabaseInstance());
28+
RegisterAdbcExecuteFunction(loader.GetDatabaseInstance());
2929

3030
// Register ADBC insert function (adbc_insert for bulk ingestion)
31-
adbc::RegisterAdbcInsertFunction(loader.GetDatabaseInstance());
31+
RegisterAdbcInsertFunction(loader.GetDatabaseInstance());
3232

3333
// Register ADBC clear cache function
3434
RegisterAdbcClearCacheFunction(loader.GetDatabaseInstance());
3535

3636
// Register ADBC storage extension for ATTACH support
37-
auto &config = DBConfig::GetConfig(loader.GetDatabaseInstance());
38-
config.storage_extensions["adbc"] = make_uniq<AdbcStorageExtension>();
37+
auto &config = duckdb::DBConfig::GetConfig(loader.GetDatabaseInstance());
38+
config.storage_extensions["adbc"] = duckdb::make_uniq<AdbcStorageExtension>();
3939

4040
QueryFarmSendTelemetry(loader, "adbc", "2025120801");
4141
}
4242

43+
} // namespace adbc_scanner
44+
45+
namespace duckdb {
46+
4347
void AdbcScannerExtension::Load(ExtensionLoader &loader) {
44-
LoadInternal(loader);
48+
adbc_scanner::LoadInternal(loader);
4549
}
4650

4751
std::string AdbcScannerExtension::Name() {
@@ -57,6 +61,6 @@ std::string AdbcScannerExtension::Version() const {
5761
extern "C" {
5862

5963
DUCKDB_CPP_EXTENSION_ENTRY(adbc_scanner, loader) {
60-
duckdb::LoadInternal(loader);
64+
adbc_scanner::LoadInternal(loader);
6165
}
6266
}

src/adbc_secrets.cpp

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2,8 +2,8 @@
22
#include "duckdb/main/extension/extension_loader.hpp"
33
#include "duckdb/common/string_util.hpp"
44

5-
namespace duckdb {
6-
namespace adbc {
5+
namespace adbc_scanner {
6+
using namespace duckdb;
77

88
unique_ptr<SecretEntry> AdbcGetSecretByName(ClientContext &context, const string &secret_name) {
99
auto &secret_manager = SecretManager::Get(context);
@@ -202,5 +202,4 @@ void RegisterAdbcSecrets(ExtensionLoader &loader) {
202202
loader.RegisterFunction(adbc_secret_function);
203203
}
204204

205-
} // namespace adbc
206-
} // namespace duckdb
205+
} // namespace adbc_scanner

src/include/adbc_connection.hpp

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -8,8 +8,8 @@
88
#include <mutex>
99
#include <unordered_set>
1010

11-
namespace duckdb {
12-
namespace adbc {
11+
namespace adbc_scanner {
12+
using namespace duckdb;
1313

1414
// Forward declaration
1515
class AdbcConnectionWrapper;
@@ -465,5 +465,4 @@ void ForEachArrowBatch(ArrowArrayStream &stream, const string &function_name, Ca
465465
}
466466
}
467467

468-
} // namespace adbc
469-
} // namespace duckdb
468+
} // namespace adbc_scanner

src/include/adbc_filter_pushdown.hpp

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -12,8 +12,8 @@
1212
#include "duckdb/planner/filter/conjunction_filter.hpp"
1313
#include "duckdb/planner/filter/constant_filter.hpp"
1414

15-
namespace duckdb {
16-
namespace adbc {
15+
namespace adbc_scanner {
16+
using namespace duckdb;
1717

1818
// Result of transforming filters - contains both the WHERE clause and bound parameters
1919
struct FilterPushdownResult {
@@ -47,5 +47,4 @@ class AdbcFilterPushdown {
4747
string op, vector<Value> &params, vector<LogicalType> &param_types);
4848
};
4949

50-
} // namespace adbc
51-
} // namespace duckdb
50+
} // namespace adbc_scanner

src/include/adbc_functions.hpp

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2,8 +2,8 @@
22

33
#include "duckdb.hpp"
44

5-
namespace duckdb {
6-
namespace adbc {
5+
namespace adbc_scanner {
6+
using namespace duckdb;
77

88
// Register scalar functions (adbc_connect, adbc_disconnect)
99
void RegisterAdbcScalarFunctions(DatabaseInstance &db);
@@ -20,9 +20,7 @@ void RegisterAdbcExecuteFunction(DatabaseInstance &db);
2020
// Register insert function (adbc_insert for bulk ingestion)
2121
void RegisterAdbcInsertFunction(DatabaseInstance &db);
2222

23-
} // namespace adbc
24-
25-
// Register adbc_clear_cache scalar function (outside adbc namespace)
23+
// Register adbc_clear_cache scalar function
2624
void RegisterAdbcClearCacheFunction(DatabaseInstance &db);
2725

28-
} // namespace duckdb
26+
} // namespace adbc_scanner

0 commit comments

Comments
 (0)