Merge pull request #349 from Mytherin/issue323

Fix #323: add support for PASSFILE to Postgres secrets

Author: Mytherin

src/postgres_extension.cpp

@@ -92,6 +92,8 @@ unique_ptr<BaseSecret> CreatePostgresSecretFunction(ClientContext &context, Crea
 			result->secret_map["password"] = named_param.second.ToString();
 		} else if (lower_name == "port") {
 			result->secret_map["port"] = named_param.second.ToString();
+		} else if (lower_name == "passfile") {
+			result->secret_map["passfile"] = named_param.second.ToString();
 		} else {
 			throw InternalException("Unknown named parameter passed to CreatePostgresSecretFunction: " + lower_name);
 		}
@@ -109,6 +111,7 @@ void SetPostgresSecretParameters(CreateSecretFunction &function) {
 	function.named_parameters["user"] = LogicalType::VARCHAR;
 	function.named_parameters["database"] = LogicalType::VARCHAR; // alias for dbname
 	function.named_parameters["dbname"] = LogicalType::VARCHAR;
+	function.named_parameters["passfile"] = LogicalType::VARCHAR;
 }
 
 void SetPostgresNullByteReplacement(ClientContext &context, SetScope scope, Value &parameter) {

src/storage/postgres_catalog.cpp

@@ -92,6 +92,7 @@ string PostgresCatalog::GetConnectionString(ClientContext &context, const string
 		new_connection_info += AddConnectionOption(kv_secret, "host");
 		new_connection_info += AddConnectionOption(kv_secret, "port");
 		new_connection_info += AddConnectionOption(kv_secret, "dbname");
+		new_connection_info += AddConnectionOption(kv_secret, "passfile");
 
 		connection_string = new_connection_info + connection_string;
 	} else if (explicit_secret) {