/*
|
* Licensed to the Apache Software Foundation (ASF) under one
|
* or more contributor license agreements. See the NOTICE file
|
* distributed with this work for additional information
|
* regarding copyright ownership. The ASF licenses this file
|
* to you under the Apache License, Version 2.0 (the
|
* "License"); you may not use this file except in compliance
|
* with the License. You may obtain a copy of the License at
|
*
|
* http://www.apache.org/licenses/LICENSE-2.0
|
*
|
* Unless required by applicable law or agreed to in writing,
|
* software distributed under the License is distributed on an
|
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
* KIND, either express or implied. See the License for the
|
* specific language governing permissions and limitations
|
* under the License.
|
*/
|
|
#include "postgres.h"
|
|
#include "nodes/extensible.h"
|
#include "nodes/nodes.h"
|
#include "nodes/pg_list.h"
|
|
#include "optimizer/cypher_createplan.h"
|
#include "optimizer/cypher_pathnode.h"
|
|
const CustomPathMethods cypher_create_path_methods = {
|
CREATE_PATH_NAME, plan_cypher_create_path, NULL};
|
const CustomPathMethods cypher_set_path_methods = {
|
SET_PATH_NAME, plan_cypher_set_path, NULL};
|
const CustomPathMethods cypher_delete_path_methods = {
|
DELETE_PATH_NAME, plan_cypher_delete_path, NULL};
|
const CustomPathMethods cypher_merge_path_methods = {
|
MERGE_PATH_NAME, plan_cypher_merge_path, NULL};
|
|
CustomPath *create_cypher_create_path(PlannerInfo *root, RelOptInfo *rel,
|
List *custom_private)
|
{
|
CustomPath *cp;
|
|
cp = makeNode(CustomPath);
|
|
cp->path.pathtype = T_CustomScan;
|
|
cp->path.parent = rel;
|
cp->path.pathtarget = rel->reltarget;
|
|
cp->path.param_info = NULL;
|
|
// Do not allow parallel methods
|
cp->path.parallel_aware = false;
|
cp->path.parallel_safe = false;
|
cp->path.parallel_workers = 0;
|
|
cp->path.rows = 0; // Basic CREATE will not return rows
|
cp->path.startup_cost = 0; // Basic CREATE will not fetch any pages
|
cp->path.total_cost = 0;
|
|
// No output ordering for basic CREATE
|
cp->path.pathkeys = NULL;
|
|
// Disable all custom flags for now
|
cp->flags = 0;
|
|
cp->custom_paths = rel->pathlist;
|
cp->custom_private = custom_private;
|
cp->methods = &cypher_create_path_methods;
|
|
return cp;
|
}
|
|
CustomPath *create_cypher_set_path(PlannerInfo *root, RelOptInfo *rel,
|
List *custom_private)
|
{
|
CustomPath *cp;
|
|
cp = makeNode(CustomPath);
|
|
cp->path.pathtype = T_CustomScan;
|
|
cp->path.parent = rel;
|
cp->path.pathtarget = rel->reltarget;
|
|
cp->path.param_info = NULL;
|
|
// Do not allow parallel methods
|
cp->path.parallel_aware = false;
|
cp->path.parallel_safe = false;
|
cp->path.parallel_workers = 0;
|
|
cp->path.rows = 0; // Basic SET will not return rows
|
cp->path.startup_cost = 0; // Basic SET will not fetch any pages
|
cp->path.total_cost = 0;
|
|
// No output ordering for basic SET
|
cp->path.pathkeys = NULL;
|
|
// Disable all custom flags for now
|
cp->flags = 0;
|
|
cp->custom_paths = rel->pathlist;
|
cp->custom_private = custom_private;
|
cp->methods = &cypher_set_path_methods;
|
|
return cp;
|
}
|
|
/*
|
* Creates a Delete Path. Makes the original path a child of the new
|
* path. We leave it to the caller to replace the pathlist of the rel.
|
*/
|
CustomPath *create_cypher_delete_path(PlannerInfo *root, RelOptInfo *rel,
|
List *custom_private)
|
{
|
CustomPath *cp;
|
|
cp = makeNode(CustomPath);
|
|
cp->path.pathtype = T_CustomScan;
|
|
cp->path.parent = rel;
|
cp->path.pathtarget = rel->reltarget;
|
|
cp->path.param_info = NULL;
|
|
// Do not allow parallel methods
|
cp->path.parallel_aware = false;
|
cp->path.parallel_safe = false;
|
cp->path.parallel_workers = 0;
|
|
cp->path.rows = 0;
|
cp->path.startup_cost = 0;
|
cp->path.total_cost = 0;
|
|
// No output ordering for basic SET
|
cp->path.pathkeys = NULL;
|
|
// Disable all custom flags for now
|
cp->flags = 0;
|
|
// Make the original paths the children of the new path
|
cp->custom_paths = rel->pathlist;
|
// Store the metadata Delete will need in the execution phase.
|
cp->custom_private = custom_private;
|
// Tells Postgres how to turn this path to the correct CustomScan
|
cp->methods = &cypher_delete_path_methods;
|
|
return cp;
|
}
|
|
/*
|
* Creates a merge path. Makes the original path a child of the new
|
* path. We leave it to the caller to replace the pathlist of the rel.
|
*/
|
CustomPath *create_cypher_merge_path(PlannerInfo *root, RelOptInfo *rel,
|
List *custom_private)
|
{
|
CustomPath *cp;
|
|
cp = makeNode(CustomPath);
|
|
cp->path.pathtype = T_CustomScan;
|
|
cp->path.parent = rel;
|
cp->path.pathtarget = rel->reltarget;
|
|
cp->path.param_info = NULL;
|
|
// Do not allow parallel methods
|
cp->path.parallel_aware = false;
|
cp->path.parallel_safe = false;
|
cp->path.parallel_workers = 0;
|
|
cp->path.rows = 0;
|
cp->path.startup_cost = 0;
|
cp->path.total_cost = 0;
|
|
// No output ordering for basic SET
|
cp->path.pathkeys = NULL;
|
|
// Disable all custom flags for now
|
cp->flags = 0;
|
|
// Make the original paths the children of the new path
|
cp->custom_paths = rel->pathlist;
|
// Store the metadata Delete will need in the execution phase.
|
cp->custom_private = custom_private;
|
// Tells Postgres how to turn this path to the correct CustomScan
|
cp->methods = &cypher_merge_path_methods;
|
|
return cp;
|
}
|
