Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 6 additions & 6 deletions .github/workflows/MainDistributionPipeline.yml
Original file line number Diff line number Diff line change
Expand Up @@ -14,21 +14,21 @@ concurrency:
jobs:
duckdb-stable-build:
name: Build extension binaries
uses: duckdb/extension-ci-tools/.github/workflows/_extension_distribution.yml@v1.4.2
uses: duckdb/extension-ci-tools/.github/workflows/_extension_distribution.yml@v1.5.0
with:
duckdb_version: v1.4.2
ci_tools_version: v1.4.2
duckdb_version: v1.5.0
ci_tools_version: v1.5.0
extension_name: postgres_scanner
exclude_archs: 'wasm_mvp;wasm_eh;wasm_threads;windows_amd64_mingw'

duckdb-stable-deploy:
name: Deploy extension binaries
needs: duckdb-stable-build
uses: duckdb/extension-ci-tools/.github/workflows/_extension_deploy.yml@v1.4.2
uses: duckdb/extension-ci-tools/.github/workflows/_extension_deploy.yml@v1.5.0
secrets: inherit
with:
duckdb_version: v1.4.2
ci_tools_version: v1.4.2
duckdb_version: v1.5.0
ci_tools_version: v1.5.0
extension_name: postgres_scanner
exclude_archs: 'wasm_mvp;wasm_eh;wasm_threads;windows_amd64_mingw'
deploy_latest: ${{ startsWith(github.ref, 'refs/heads/v') || github.ref == 'refs/heads/main' }}
2 changes: 1 addition & 1 deletion duckdb
Submodule duckdb updated 3392 files
2 changes: 1 addition & 1 deletion src/include/storage/postgres_delete.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ class PostgresDelete : public PhysicalOperator {

public:
// Source interface
SourceResultType GetData(ExecutionContext &context, DataChunk &chunk, OperatorSourceInput &input) const override;
SourceResultType GetDataInternal(ExecutionContext &context, DataChunk &chunk, OperatorSourceInput &input) const override;

bool IsSource() const override {
return true;
Expand Down
2 changes: 1 addition & 1 deletion src/include/storage/postgres_index.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ class PostgresCreateIndex : public PhysicalOperator {

public:
// Source interface
SourceResultType GetData(ExecutionContext &context, DataChunk &chunk, OperatorSourceInput &input) const override;
SourceResultType GetDataInternal(ExecutionContext &context, DataChunk &chunk, OperatorSourceInput &input) const override;

bool IsSource() const override {
return true;
Expand Down
2 changes: 1 addition & 1 deletion src/include/storage/postgres_insert.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ class PostgresInsert : public PhysicalOperator {

public:
// Source interface
SourceResultType GetData(ExecutionContext &context, DataChunk &chunk, OperatorSourceInput &input) const override;
SourceResultType GetDataInternal(ExecutionContext &context, DataChunk &chunk, OperatorSourceInput &input) const override;

bool IsSource() const override {
return true;
Expand Down
2 changes: 1 addition & 1 deletion src/include/storage/postgres_update.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ class PostgresUpdate : public PhysicalOperator {

public:
// Source interface
SourceResultType GetData(ExecutionContext &context, DataChunk &chunk, OperatorSourceInput &input) const override;
SourceResultType GetDataInternal(ExecutionContext &context, DataChunk &chunk, OperatorSourceInput &input) const override;

bool IsSource() const override {
return true;
Expand Down
5 changes: 2 additions & 3 deletions src/postgres_storage.cpp
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
#include "duckdb.hpp"

#include "duckdb/main/settings.hpp"
#include "postgres_storage.hpp"
#include "storage/postgres_catalog.hpp"
#include "duckdb/parser/parsed_data/attach_info.hpp"
Expand All @@ -10,8 +10,7 @@ namespace duckdb {
static unique_ptr<Catalog> PostgresAttach(optional_ptr<StorageExtensionInfo> storage_info, ClientContext &context,
AttachedDatabase &db, const string &name, AttachInfo &info,
AttachOptions &attach_options) {
auto &config = DBConfig::GetConfig(context);
if (!config.options.enable_external_access) {
if (!Settings::Get<EnableExternalAccessSetting>(context)) {
throw PermissionException("Attaching Postgres databases is disabled through configuration");
}
string attach_path = info.path;
Expand Down
2 changes: 1 addition & 1 deletion src/storage/postgres_delete.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ SinkFinalizeType PostgresDelete::Finalize(Pipeline &pipeline, Event &event, Clie
//===--------------------------------------------------------------------===//
// GetData
//===--------------------------------------------------------------------===//
SourceResultType PostgresDelete::GetData(ExecutionContext &context, DataChunk &chunk,
SourceResultType PostgresDelete::GetDataInternal(ExecutionContext &context, DataChunk &chunk,
OperatorSourceInput &input) const {
auto &insert_gstate = sink_state->Cast<PostgresDeleteGlobalState>();
chunk.SetCardinality(1);
Expand Down
2 changes: 1 addition & 1 deletion src/storage/postgres_index.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ PostgresCreateIndex::PostgresCreateIndex(PhysicalPlan &physical_plan, unique_ptr
//===--------------------------------------------------------------------===//
// Source
//===--------------------------------------------------------------------===//
SourceResultType PostgresCreateIndex::GetData(ExecutionContext &context, DataChunk &chunk,
SourceResultType PostgresCreateIndex::GetDataInternal(ExecutionContext &context, DataChunk &chunk,
OperatorSourceInput &input) const {
auto &catalog = table.catalog;
auto &schema = table.schema;
Expand Down
2 changes: 1 addition & 1 deletion src/storage/postgres_insert.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -148,7 +148,7 @@ SinkFinalizeType PostgresInsert::Finalize(Pipeline &pipeline, Event &event, Clie
//===--------------------------------------------------------------------===//
// GetData
//===--------------------------------------------------------------------===//
SourceResultType PostgresInsert::GetData(ExecutionContext &context, DataChunk &chunk,
SourceResultType PostgresInsert::GetDataInternal(ExecutionContext &context, DataChunk &chunk,
OperatorSourceInput &input) const {
auto &insert_gstate = sink_state->Cast<PostgresInsertGlobalState>();
chunk.SetCardinality(1);
Expand Down
2 changes: 1 addition & 1 deletion src/storage/postgres_update.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -177,7 +177,7 @@ SinkFinalizeType PostgresUpdate::Finalize(Pipeline &pipeline, Event &event, Clie
//===--------------------------------------------------------------------===//
// GetData
//===--------------------------------------------------------------------===//
SourceResultType PostgresUpdate::GetData(ExecutionContext &context, DataChunk &chunk,
SourceResultType PostgresUpdate::GetDataInternal(ExecutionContext &context, DataChunk &chunk,
OperatorSourceInput &input) const {
auto &insert_gstate = sink_state->Cast<PostgresUpdateGlobalState>();
chunk.SetCardinality(1);
Expand Down
Loading