DdlNodes.h

/*
 *  The contents of this file are subject to the Initial
 *  Developer's Public License Version 1.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.ibphoenix.com/main.nfs?a=ibphoenix&page=ibp_idpl.
 *
 *  Software distributed under the License is distributed AS IS,
 *  WITHOUT WARRANTY OF ANY KIND, either express or implied.
 *  See the License for the specific language governing rights
 *  and limitations under the License.
 *
 *  The Original Code was created by Adriano dos Santos Fernandes
 *  for the Firebird Open Source RDBMS project.
 *
 *  Copyright (c) 2008 Adriano dos Santos Fernandes <adrianosf@uol.com.br>
 *  and all contributors signed below.
 *
 *  All Rights Reserved.
 *  Contributor(s): ______________________________________.
 */

#ifndef DSQL_DDL_NODES_H
#define DSQL_DDL_NODES_H

#include <functional>
#include <optional>
#include "firebird/impl/blr.h"
#include "../jrd/dyn.h"
#include "../common/msg_encode.h"
#include "../dsql/make_proto.h"
#include "../dsql/BlrDebugWriter.h"
#include "../dsql/Nodes.h"
#include "../dsql/ExprNodes.h"
#include "../dsql/NodePrinter.h"
#include "../common/classes/array.h"
#include "../common/classes/ByteChunk.h"
#include "../common/classes/TriState.h"
#include "../jrd/Savepoint.h"
#include "../dsql/errd_proto.h"

namespace Jrd {

enum SqlSecurity
{
	SS_INVOKER,
	SS_DEFINER,
	SS_DROP
};

class LocalDeclarationsNode;
class RelationSourceNode;
class ValueListNode;
class SecDbContext;

class BoolSourceClause : public Printable
{
public:
	explicit BoolSourceClause(MemoryPool& p)
		: value(NULL),
		  source(p)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override
	{
		NODE_PRINT(printer, value);
		NODE_PRINT(printer, source);

		return "BoolSourceClause";
	}

public:
	NestConst<BoolExprNode> value;
	Firebird::string source;
};


class ValueSourceClause final : public Printable
{
public:
	explicit ValueSourceClause(MemoryPool& p)
		: value(NULL),
		  source(p)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override
	{
		NODE_PRINT(printer, value);
		NODE_PRINT(printer, source);

		return "ValueSourceClause";
	}

public:
	NestConst<ValueExprNode> value;
	Firebird::string source;
};


class ExternalClause final : public Printable
{
public:
	ExternalClause(MemoryPool& p, const ExternalClause& o)
		: name(p, o.name),
		  engine(p, o.engine),
		  udfModule(p, o.udfModule)
	{
	}

	explicit ExternalClause(MemoryPool& p)
		: name(p),
		  engine(p),
		  udfModule(p)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override
	{
		NODE_PRINT(printer, name);
		NODE_PRINT(printer, engine);
		NODE_PRINT(printer, udfModule);

		return "ExternalClause";
	}

public:
	Firebird::string name;
	MetaName engine;
	Firebird::string udfModule;
};


class ParameterClause final : public Printable
{
public:
	ParameterClause(MemoryPool& pool, dsql_fld* field,
		ValueSourceClause* aDefaultClause = NULL, ValueExprNode* aParameterExpr = NULL);

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;

public:
	MetaName name;
	NestConst<dsql_fld> type;
	NestConst<ValueSourceClause> defaultClause;
	NestConst<ValueExprNode> parameterExpr;
	std::optional<int> udfMechanism;
};


struct CollectedParameter
{
	CollectedParameter()
	{
		comment.clear();
		defaultSource.clear();
		defaultValue.clear();
	}

	bid comment;
	bid defaultSource;
	bid defaultValue;
};

typedef Firebird::LeftPooledMap<MetaName, CollectedParameter> CollectedParameterMap;


class ExecInSecurityDb
{
public:
	virtual ~ExecInSecurityDb() { }

	void executeInSecurityDb(jrd_tra* tra);

protected:
	virtual void runInSecurityDb(SecDbContext* secDbContext) = 0;
};


template <typename CreateNode, typename DropNode, ISC_STATUS ERROR_CODE>
class RecreateNode : public DdlNode
{
public:
	RecreateNode(MemoryPool& p, CreateNode* aCreateNode)
		: DdlNode(p),
		  createNode(aCreateNode),
		  dropNode(p, createNode->name)
	{
		dropNode.silent = true;
		dropNode.recreate = true;
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override
	{
		Node::internalPrint(printer);

		NODE_PRINT(printer, createNode);
		NODE_PRINT(printer, dropNode);

		return "RecreateNode";
	}

	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override
	{
		dropNode.checkPermission(tdbb, transaction);
		createNode->checkPermission(tdbb, transaction);
	}

	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override
	{
		// run all statements under savepoint control
		AutoSavePoint savePoint(tdbb, transaction);

		dropNode.execute(tdbb, dsqlScratch, transaction);
		createNode->execute(tdbb, dsqlScratch, transaction);

		savePoint.release();	// everything is ok
	}

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		createNode->dsqlPass(dsqlScratch);
		dropNode.dsqlPass(dsqlScratch);
		return DdlNode::dsqlPass(dsqlScratch);
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(ERROR_CODE) << createNode->name.toQuotedString();
	}

protected:
	NestConst<CreateNode> createNode;
	DropNode dropNode;
};


class AlterCharSetNode final : public DdlNode
{
public:
	AlterCharSetNode(MemoryPool& pool, const QualifiedName& aCharSet, const QualifiedName& aDefaultCollation)
		: DdlNode(pool),
		  charSet(pool, aCharSet),
		  defaultCollation(pool, aDefaultCollation)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		dsqlScratch->qualifyExistingName(charSet, obj_charset);
		dsqlScratch->ddlSchema = charSet.schema;

		dsqlScratch->qualifyExistingName(defaultCollation, obj_collation);

		return DdlNode::dsqlPass(dsqlScratch);
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_alter_charset_failed) << charSet.toQuotedString();
	}

private:
	QualifiedName charSet;
	QualifiedName defaultCollation;
};


class AlterEDSPoolSetNode final : public DdlNode
{
public:
	enum PARAM { POOL_SIZE, POOL_LIFETIME };

	AlterEDSPoolSetNode(MemoryPool& pool, PARAM prm, int val)
		: DdlNode(pool),
		  m_param(prm),
		  m_value(val)
	{
	}

public:
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	bool mustBeReplicated() const override
	{
		return false;
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		// TODO: statusVector << Firebird::Arg::Gds(??);
	}

private:
	PARAM m_param;
	int m_value;
};


class AlterEDSPoolClearNode final : public DdlNode
{
public:
	enum PARAM { POOL_ALL, POOL_OLDEST, POOL_DB };

	AlterEDSPoolClearNode(MemoryPool& pool, PARAM prm, const Firebird::string& val = "")
		: DdlNode(pool),
		  m_param(prm),
		  m_value(pool)
	{
		m_value = val;
	}

public:
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	bool mustBeReplicated() const override
	{
		return false;
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		// TODO: statusVector << Firebird::Arg::Gds(??);
	}

private:
	PARAM m_param;
	Firebird::string m_value;
};


class CommentOnNode final : public DdlNode
{
public:
	CommentOnNode(MemoryPool& pool, ObjectType aObjType,
				const QualifiedName& aName, const MetaName& aSubName,
				const Firebird::string aText)
		: DdlNode(pool),
		  objType(aObjType),
		  name(pool, aName),
		  subName(pool, aSubName),
		  text(pool, aText),
		  str(pool)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		str = name.toQuotedString();

		if (subName.hasData())
			str.append(".").append(subName.c_str());

		statusVector << Firebird::Arg::Gds(isc_dsql_comment_on_failed) << str;
	}

private:
	ObjectType objType;
	QualifiedName name;
	MetaName subName;
	Firebird::string text, str;
};


class CreateAlterFunctionNode final : public DdlNode
{
public:
	CreateAlterFunctionNode(MemoryPool& pool, const QualifiedName& aName)
		: DdlNode(pool),
		  name(pool, aName),
		  create(true),
		  alter(false),
		  external(NULL),
		  parameters(pool),
		  returnType(NULL),
		  localDeclList(NULL),
		  source(pool),
		  body(NULL),
		  compiled(false),
		  invalid(false),
		  packageOwner(pool),
		  privateScope(false),
		  preserveDefaults(false),
		  udfReturnPos(0)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector <<
			Firebird::Arg::Gds(createAlterCode(create, alter,
					isc_dsql_create_func_failed, isc_dsql_alter_func_failed,
					isc_dsql_create_alter_func_failed)) <<
				name.toQuotedString();
	}

private:
	bool isUdf() const
	{
		return external && external->udfModule.hasData();
	}

	bool executeCreate(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction);
	bool executeAlter(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction,
		bool secondPass, bool runTriggers);
	bool executeAlterIndividualParameters(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction,
		bool secondPass, bool runTriggers);

	void storeArgument(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction,
		unsigned pos, bool returnArg, ParameterClause* parameter,
		const CollectedParameter* collectedParameter);
	void compile(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch);
	void collectParameters(thread_db* tdbb, jrd_tra* transaction, CollectedParameterMap& items);

public:
	QualifiedName name;
	bool create;
	bool alter;
	bool createIfNotExistsOnly = false;
	NestConst<ExternalClause> external;
	Firebird::TriState deterministic;
	Firebird::Array<NestConst<ParameterClause>> parameters;
	NestConst<ParameterClause> returnType;
	NestConst<LocalDeclarationsNode> localDeclList;
	Firebird::string source;
	NestConst<StmtNode> body;
	bool compiled;
	bool invalid;
	MetaName packageOwner;
	bool privateScope;
	bool preserveDefaults;
	SLONG udfReturnPos;
	std::optional<SqlSecurity> ssDefiner;
};


class AlterExternalFunctionNode final : public DdlNode
{
public:
	AlterExternalFunctionNode(MemoryPool& p, const QualifiedName& aName)
		: DdlNode(p),
		  name(p, aName),
		  clauses(p)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		dsqlScratch->qualifyExistingName(name, obj_udf);
		protectSystemSchema(name.schema, obj_udf);
		dsqlScratch->ddlSchema = name.schema;

		return DdlNode::dsqlPass(dsqlScratch);
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_alter_func_failed) << name.toQuotedString();
	}

public:
	QualifiedName name;
	ExternalClause clauses;
};


class DropFunctionNode final : public DdlNode
{
public:
	DropFunctionNode(MemoryPool& pool, const QualifiedName& aName)
		: DdlNode(pool),
		  name(pool, aName),
		  silent(false)
	{
	}

public:
	static void dropArguments(thread_db* tdbb, jrd_tra* transaction, const QualifiedName& functionName);

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_drop_func_failed) << name.toQuotedString();
	}

public:
	QualifiedName name;
	bool silent;
	bool recreate = false;
};


typedef RecreateNode<CreateAlterFunctionNode, DropFunctionNode, isc_dsql_recreate_func_failed>
	RecreateFunctionNode;


class CreateAlterProcedureNode final : public DdlNode
{
public:
	CreateAlterProcedureNode(MemoryPool& pool, const QualifiedName& aName)
		: DdlNode(pool),
		  name(pool, aName),
		  create(true),
		  alter(false),
		  external(NULL),
		  parameters(pool),
		  returns(pool),
		  source(pool),
		  localDeclList(NULL),
		  body(NULL),
		  compiled(false),
		  invalid(false),
		  packageOwner(pool),
		  privateScope(false),
		  preserveDefaults(false)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector <<
			Firebird::Arg::Gds(createAlterCode(create, alter,
					isc_dsql_create_proc_failed, isc_dsql_alter_proc_failed,
					isc_dsql_create_alter_proc_failed)) <<
				name.toQuotedString();
	}

private:
	bool executeCreate(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction);
	bool executeAlter(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction,
		bool secondPass, bool runTriggers);
	bool executeAlterIndividualParameters(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction,
		bool secondPass, bool runTriggers);

	void storeParameter(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction,
		USHORT parameterType, unsigned pos, ParameterClause* parameter,
		const CollectedParameter* collectedParameter);
	void compile(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch);
	void collectParameters(thread_db* tdbb, jrd_tra* transaction, CollectedParameterMap& items);

public:
	QualifiedName name;
	bool create;
	bool alter;
	bool createIfNotExistsOnly = false;
	NestConst<ExternalClause> external;
	Firebird::Array<NestConst<ParameterClause> > parameters;
	Firebird::Array<NestConst<ParameterClause> > returns;
	Firebird::string source;
	NestConst<LocalDeclarationsNode> localDeclList;
	NestConst<StmtNode> body;
	bool compiled;
	bool invalid;
	MetaName packageOwner;
	bool privateScope;
	bool preserveDefaults;
	std::optional<SqlSecurity> ssDefiner;
};


class DropProcedureNode final : public DdlNode
{
public:
	DropProcedureNode(MemoryPool& pool, const QualifiedName& aName)
		: DdlNode(pool),
		  name(pool, aName),
		  silent(false)
	{
	}

public:
	static void dropParameters(thread_db* tdbb, jrd_tra* transaction, const QualifiedName& procedureName);

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_drop_proc_failed) << name.toQuotedString();
	}

public:
	QualifiedName name;
	bool silent;
	bool recreate = false;
};


typedef RecreateNode<CreateAlterProcedureNode, DropProcedureNode, isc_dsql_recreate_proc_failed>
	RecreateProcedureNode;


class TriggerDefinition
{
public:
	explicit TriggerDefinition(MemoryPool& p)
		: name(p),
		  relationName(p),
		  external(NULL),
		  source(p),
		  systemFlag(fb_sysflag_user),
		  fkTrigger(false)
	{
	}

	void store(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction);
	bool modify(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction);

	virtual ~TriggerDefinition()
	{
	}

protected:
	virtual void preModify(thread_db* /*tdbb*/, DsqlCompilerScratch* /*dsqlScratch*/,
		jrd_tra* /*transaction*/)
	{
	}

	virtual void postModify(thread_db* /*tdbb*/, DsqlCompilerScratch* /*dsqlScratch*/,
		jrd_tra* /*transaction*/)
	{
	}

public:
	QualifiedName name;
	QualifiedName relationName;
	std::optional<FB_UINT64> type;
	Firebird::TriState active;
	std::optional<int> position;
	NestConst<ExternalClause> external;
	Firebird::string source;
	Firebird::ByteChunk blrData;
	Firebird::ByteChunk debugData;
	USHORT systemFlag;
	bool fkTrigger;
	std::optional<SqlSecurity> ssDefiner;
};


class CreateAlterTriggerNode final : public DdlNode, public TriggerDefinition
{
public:
	CreateAlterTriggerNode(MemoryPool& p, const QualifiedName& aName)
		: DdlNode(p),
		  TriggerDefinition(p),
		  create(true),
		  alter(false),
		  localDeclList(NULL),
		  body(NULL),
		  compiled(false),
		  invalid(false)
	{
		name = aName;
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector <<
			Firebird::Arg::Gds(createAlterCode(create, alter,
					isc_dsql_create_trigger_failed, isc_dsql_alter_trigger_failed,
					isc_dsql_create_alter_trigger_failed)) <<
				name.toQuotedString();
	}

	void preModify(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override
	{
		if (alter)
		{
			executeDdlTrigger(tdbb, dsqlScratch, transaction, DTW_BEFORE,
				DDL_TRIGGER_ALTER_TRIGGER, name, {});
		}
	}

	void postModify(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override
	{
		if (alter)
		{
			executeDdlTrigger(tdbb, dsqlScratch, transaction, DTW_AFTER,
				DDL_TRIGGER_ALTER_TRIGGER, name, {});
		}
	}

private:
	void executeCreate(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction);
	void compile(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch);

	static inline bool hasOldContext(const unsigned value)
	{
		const unsigned val1 = ((value + 1) >> 1) & 3;
		const unsigned val2 = ((value + 1) >> 3) & 3;
		const unsigned val3 = ((value + 1) >> 5) & 3;
		return (val1 && val1 != 1) || (val2 && val2 != 1) || (val3 && val3 != 1);
	}

	static inline bool hasNewContext(const unsigned value)
	{
		const unsigned val1 = ((value + 1) >> 1) & 3;
		const unsigned val2 = ((value + 1) >> 3) & 3;
		const unsigned val3 = ((value + 1) >> 5) & 3;
		return (val1 && val1 != 3) || (val2 && val2 != 3) || (val3 && val3 != 3);
	}

public:
	bool create;
	bool alter;
	bool createIfNotExistsOnly = false;
	NestConst<LocalDeclarationsNode> localDeclList;
	NestConst<StmtNode> body;
	bool compiled;
	bool invalid;
};


class DropTriggerNode final : public DdlNode
{
public:
	DropTriggerNode(MemoryPool& p, const QualifiedName& aName)
		: DdlNode(p),
		  name(p, aName),
		  silent(false)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_drop_trigger_failed) << name.toQuotedString();
	}

public:
	QualifiedName name;
	bool silent;
	bool recreate = false;
};


class RecreateTriggerNode final :
	public RecreateNode<CreateAlterTriggerNode, DropTriggerNode, isc_dsql_recreate_trigger_failed>
{
public:
	using RecreateNode::RecreateNode;

public:
	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		createNode->dsqlPass(dsqlScratch);

		if (dropNode.name.schema.isEmpty())
			dropNode.name.schema = createNode->name.schema;

		dropNode.dsqlPass(dsqlScratch);

		return DdlNode::dsqlPass(dsqlScratch);
	}
};


class CreateCollationNode final : public DdlNode
{
public:
	CreateCollationNode(MemoryPool& p, const QualifiedName& aName, const QualifiedName& aForCharSet)
		: DdlNode(p),
		  name(p, aName),
		  forCharSet(p, aForCharSet),
		  fromName(p),
		  fromExternal(p),
		  specificAttributes(p),
		  attributesOn(0),
		  attributesOff(0),
		  forCharSetId(0),
		  fromCollationId(0)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	void setAttribute(USHORT attribute)
	{
		if ((attributesOn | attributesOff) & attribute)
		{
			// msg: 222: "Invalid collation attributes"
			using namespace Firebird;
			ERRD_post(Arg::Gds(isc_sqlerr) << Arg::Num(-104) << Arg::PrivateDyn(222));
		}

		attributesOn |= attribute;
	}

	void unsetAttribute(USHORT attribute)
	{
		if ((attributesOn | attributesOff) & attribute)
		{
			// msg: 222: "Invalid collation attributes"
			using namespace Firebird;
			ERRD_post(Arg::Gds(isc_sqlerr) << Arg::Num(-104) << Arg::PrivateDyn(222));
		}

		attributesOff |= attribute;
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_create_collation_failed) << name.toQuotedString();
	}

public:
	QualifiedName name;
	QualifiedName forCharSet;
	QualifiedName fromName;
	Firebird::string fromExternal;
	Firebird::UCharBuffer specificAttributes;
	bool createIfNotExistsOnly = false;

private:
	USHORT attributesOn;
	USHORT attributesOff;
	USHORT forCharSetId;
	USHORT fromCollationId;
};


class DropCollationNode final : public DdlNode
{
public:
	DropCollationNode(MemoryPool& p, const QualifiedName& aName)
		: DdlNode(p),
		  name(p, aName)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		dsqlScratch->qualifyExistingName(name, obj_collation);
		protectSystemSchema(name.schema, obj_collation);
		dsqlScratch->ddlSchema = name.schema;

		return DdlNode::dsqlPass(dsqlScratch);
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_drop_collation_failed) << name.toQuotedString();
	}

public:
	QualifiedName name;
	bool silent = false;
};


class CreateDomainNode final : public DdlNode
{
public:
	CreateDomainNode(MemoryPool& p, const QualifiedName& aName, dsql_fld* aType, ValueSourceClause* aDefaultClause)
		: DdlNode(p),
		  name(aName),
		  type(aType),
		  defaultClause(aDefaultClause)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		dsqlScratch->qualifyNewName(name);
		protectSystemSchema(name.schema, obj_collation);
		dsqlScratch->ddlSchema = name.schema;

		type->resolve(dsqlScratch);

		return DdlNode::dsqlPass(dsqlScratch);
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_create_domain_failed) << name.toQuotedString();
	}

public:
	QualifiedName name;
	NestConst<dsql_fld> type;
	NestConst<ValueSourceClause> defaultClause;
	NestConst<BoolSourceClause> check;
	bool notNull = false;
	bool createIfNotExistsOnly = false;
};


class AlterDomainNode final : public DdlNode
{
public:
	AlterDomainNode(MemoryPool& p, const QualifiedName& aName)
		: DdlNode(p),
		  name(p, aName),
		  renameTo(p)
	{
	}

public:
	static void checkUpdate(const dyn_fld& origFld, const dyn_fld& newFld);
	static ULONG checkUpdateNumericType(const dyn_fld& origFld, const dyn_fld& newFld);
	static void getDomainType(thread_db* tdbb, jrd_tra* transaction, dyn_fld& dynFld);
	static void modifyLocalFieldIndex(thread_db* tdbb, jrd_tra* transaction,
		const QualifiedName& relationName, const MetaName& fieldName,
		const MetaName& newFieldName);

	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		dsqlScratch->qualifyExistingName(name, obj_field);
		protectSystemSchema(name.schema, obj_field);
		dsqlScratch->ddlSchema = name.schema;

		if (type)
			type->resolve(dsqlScratch);

		return DdlNode::dsqlPass(dsqlScratch);
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_alter_domain_failed) << name.toQuotedString();
	}

private:
	void rename(thread_db* tdbb, jrd_tra* transaction, SSHORT dimensions);

public:
	QualifiedName name;
	NestConst<BoolSourceClause> setConstraint;
	NestConst<ValueSourceClause> setDefault;
	MetaName renameTo;
	Firebird::AutoPtr<dsql_fld> type;
	Firebird::TriState notNullFlag;	// true = NOT NULL / false = NULL
	bool dropConstraint = false;
	bool dropDefault = false;
};


class DropDomainNode final : public DdlNode
{
public:
	DropDomainNode(MemoryPool& p, const QualifiedName& aName)
		: DdlNode(p),
		  name(p, aName)
	{
	}

	static bool deleteDimensionRecords(thread_db* tdbb, jrd_tra* transaction,
		const QualifiedName& name);

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		dsqlScratch->qualifyExistingName(name, obj_field);
		protectSystemSchema(name.schema, obj_field);
		dsqlScratch->ddlSchema = name.schema;

		return DdlNode::dsqlPass(dsqlScratch);
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_drop_domain_failed) << name.toQuotedString();
	}

private:
	void check(thread_db* tdbb, jrd_tra* transaction);

public:
	QualifiedName name;
	bool silent = false;
};


class CreateAlterExceptionNode final : public DdlNode
{
public:
	CreateAlterExceptionNode(MemoryPool& p, const QualifiedName& aName,
				const Firebird::string& aMessage)
		: DdlNode(p),
		  name(p, aName),
		  message(p, aMessage),
		  create(true),
		  alter(false)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		if (create)
			dsqlScratch->qualifyNewName(name);
		else
			dsqlScratch->qualifyExistingName(name, obj_exception);

		protectSystemSchema(name.schema, obj_exception);
		dsqlScratch->ddlSchema = name.schema;

		return DdlNode::dsqlPass(dsqlScratch);
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector <<
			Firebird::Arg::Gds(createAlterCode(create, alter,
					isc_dsql_create_except_failed, isc_dsql_alter_except_failed,
					isc_dsql_create_alter_except_failed)) <<
				name.toQuotedString();
	}

private:
	void executeCreate(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction);
	bool executeAlter(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction);

public:
	QualifiedName name;
	Firebird::string message;
	bool create;
	bool alter;
	bool createIfNotExistsOnly = false;
};


class DropExceptionNode final : public DdlNode
{
public:
	DropExceptionNode(MemoryPool& p, const QualifiedName& aName)
		: DdlNode(p),
		  name(p, aName),
		  silent(false)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		if (recreate)
			dsqlScratch->qualifyNewName(name);
		else
			dsqlScratch->qualifyExistingName(name, obj_exception);

		protectSystemSchema(name.schema, obj_exception);
		dsqlScratch->ddlSchema = name.schema;

		return DdlNode::dsqlPass(dsqlScratch);
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_drop_except_failed) << name.toQuotedString();
	}

public:
	QualifiedName name;
	bool silent;
	bool recreate = false;
};


typedef RecreateNode<CreateAlterExceptionNode, DropExceptionNode, isc_dsql_recreate_except_failed>
	RecreateExceptionNode;


class CreateAlterSequenceNode final : public DdlNode
{
public:
	CreateAlterSequenceNode(MemoryPool& pool, const QualifiedName& aName)
		: DdlNode(pool),
		  create(true),
		  alter(false),
		  legacy(false),
		  restartSpecified(false),
		  name(pool, aName)
	{
		// Unfortunately, line/column carry no useful information here.
		// Hence, the check was created directly in parse.y.
		/*
		if (!aValue.specified && !aStep.specified)
		{
			using namespace Firebird;
			ERRD_post(Arg::Gds(isc_sqlerr) << Arg::Num(-104) <<
					  // Unexpected end of command
					  Arg::Gds(isc_command_end_err2) << Arg::Num(this->line) <<
													Arg::Num(this->column));
		}
		*/
	}

	static SSHORT store(thread_db* tdbb, jrd_tra* transaction, const QualifiedName& name,
		fb_sysflag sysFlag, SINT64 value, SLONG step);

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		if (create)
			dsqlScratch->qualifyNewName(name);
		else
			dsqlScratch->qualifyExistingName(name, obj_generator);

		if (!restartSpecified)
			protectSystemSchema(name.schema, obj_generator);

		dsqlScratch->ddlSchema = name.schema;

		dsqlScratch->getDsqlStatement()->setType(legacy ? DsqlStatement::TYPE_SET_GENERATOR : DsqlStatement::TYPE_DDL);

		return this;
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override;

private:
	void executeCreate(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction);
	bool executeAlter(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction);

public:
	bool create;
	bool alter;
	bool createIfNotExistsOnly = false;
	bool legacy;
	bool restartSpecified;
	QualifiedName name;
	std::optional<SINT64> value;
	std::optional<SLONG> step;
};


class DropSequenceNode final : public DdlNode
{
public:
	DropSequenceNode(MemoryPool& pool, const QualifiedName& aName)
		: DdlNode(pool),
		  name(pool, aName),
		  silent(false)
	{
	}

	static void deleteIdentity(thread_db* tdbb, jrd_tra* transaction, const QualifiedName& name);

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		if (recreate)
			dsqlScratch->qualifyNewName(name);
		else
			dsqlScratch->qualifyExistingName(name, obj_generator);

		protectSystemSchema(name.schema, obj_generator);
		dsqlScratch->ddlSchema = name.schema;

		return DdlNode::dsqlPass(dsqlScratch);
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_drop_sequence_failed) << name.toQuotedString();
	}

public:
	QualifiedName name;
	bool silent;
	bool recreate = false;
};


typedef RecreateNode<CreateAlterSequenceNode, DropSequenceNode, isc_dsql_recreate_sequence_failed>
	RecreateSequenceNode;


class RelationNode : public DdlNode
{
public:
	class FieldDefinition
	{
	public:
		explicit FieldDefinition(MemoryPool& p)
			: name(p),
			  relationName(p),
			  fieldSource(p),
			  identitySequence(p),
			  defaultSource(p),
			  baseField(p)
		{
		}

		void modify(thread_db* tdbb, jrd_tra* transaction);
		void store(thread_db* tdbb, jrd_tra* transaction);

	public:
		MetaName name;
		QualifiedName relationName;
		QualifiedName fieldSource;
		QualifiedName identitySequence;
		std::optional<IdentityType> identityType;
		std::optional<USHORT> collationId;
		Firebird::TriState notNullFlag;	// true = NOT NULL / false = NULL
		std::optional<USHORT> position;
		Firebird::string defaultSource;
		Firebird::ByteChunk defaultValue;
		std::optional<USHORT> viewContext;
		MetaName baseField;
	};

	struct IndexConstraintClause
	{
		explicit IndexConstraintClause(MemoryPool& p)
			: name(p),
			  descending(false)
		{
		}

		MetaName name;
		bool descending;
	};

	struct Constraint
	{
		enum Type { TYPE_CHECK, TYPE_NOT_NULL, TYPE_PK, TYPE_UNIQUE, TYPE_FK };

		// Specialized BlrWriter for constraints.
		class BlrWriter final : public Jrd::BlrDebugWriter
		{
		public:
			explicit BlrWriter(MemoryPool& p)
				: Jrd::BlrDebugWriter(p),
				  dsqlScratch(NULL)
			{
			}

			void init(DsqlCompilerScratch* aDsqlScratch)
			{
				dsqlScratch = aDsqlScratch;
				dsqlScratch->getBlrData().clear();
				dsqlScratch->getDebugData().clear();
				appendUChar(isVersion4() ? blr_version4 : blr_version5);
			}

			bool isVersion4() override
			{
				return dsqlScratch->isVersion4();
			}

		private:
			DsqlCompilerScratch* dsqlScratch;
		};

		explicit Constraint(MemoryPool& p)
			: type(TYPE_CHECK),	// Just something to initialize. Do not assume it.
			  columns(p),
			  index(NULL),
			  refRelation(p),
			  refColumns(p),
			  refUpdateAction(RI_RESTRICT),
			  refDeleteAction(RI_RESTRICT),
			  triggers(p),
			  blrWritersHolder(p)
		{
		}

		Constraint::Type type;
		Firebird::ObjectsArray<MetaName> columns;
		NestConst<IndexConstraintClause> index;
		QualifiedName refRelation;
		Firebird::ObjectsArray<MetaName> refColumns;
		const char* refUpdateAction;
		const char* refDeleteAction;
		Firebird::ObjectsArray<TriggerDefinition> triggers;
		Firebird::ObjectsArray<BlrWriter> blrWritersHolder;
		bool enforced = true;
	};

	struct CreateDropConstraint
	{
		explicit CreateDropConstraint(MemoryPool& p)
			: name(p)
		{
		}

		MetaName name;
		Firebird::AutoPtr<Constraint> create;
		bool silent = false;
	};

	struct Clause
	{
		enum Type
		{
			TYPE_ADD_CONSTRAINT,
			TYPE_ADD_COLUMN,
			TYPE_ALTER_COL_NAME,
			TYPE_ALTER_COL_NULL,
			TYPE_ALTER_COL_POS,
			TYPE_ALTER_COL_TYPE,
			TYPE_ALTER_CONSTRAINT,
			TYPE_DROP_COLUMN,
			TYPE_DROP_CONSTRAINT,
			TYPE_ALTER_SQL_SECURITY,
			TYPE_ALTER_PUBLICATION
		};

		explicit Clause(MemoryPool& p, Type aType)
			: type(aType)
		{
		}

		const Type type;
	};

	struct RefActionClause
	{
		static const unsigned ACTION_CASCADE		= 1;
		static const unsigned ACTION_SET_DEFAULT	= 2;
		static const unsigned ACTION_SET_NULL		= 3;
		static const unsigned ACTION_NONE			= 4;

		RefActionClause(MemoryPool& p, unsigned aUpdateAction, unsigned aDeleteAction)
			: updateAction(aUpdateAction),
			  deleteAction(aDeleteAction)
		{
		}

		unsigned updateAction;
		unsigned deleteAction;
	};

	struct AddConstraintClause : public Clause
	{
		enum ConstraintType
		{
			CTYPE_NOT_NULL,
			CTYPE_PK,
			CTYPE_FK,
			CTYPE_UNIQUE,
			CTYPE_CHECK
		};

		explicit AddConstraintClause(MemoryPool& p)
			: Clause(p, TYPE_ADD_CONSTRAINT),
			  name(p),
			  constraintType(CTYPE_NOT_NULL),
			  columns(p),
			  index(NULL),
			  refRelation(p),
			  refColumns(p),
			  refAction(NULL),
			  check(NULL)
		{
		}

		MetaName name;
		ConstraintType constraintType;
		Firebird::ObjectsArray<MetaName> columns;
		NestConst<IndexConstraintClause> index;
		QualifiedName refRelation;
		Firebird::ObjectsArray<MetaName> refColumns;
		NestConst<RefActionClause> refAction;
		NestConst<BoolSourceClause> check;
		bool createIfNotExistsOnly = false;
		bool enforced = true;
	};

	struct IdentityOptions
	{
		IdentityOptions(MemoryPool&, IdentityType aType)
			: type(aType),
			  restart(false)
		{
		}

		IdentityOptions(MemoryPool&)
			: restart(false)
		{
		}

		std::optional<IdentityType> type;
		std::optional<SINT64> startValue;
		std::optional<SLONG> increment;
		bool restart;	// used in ALTER
	};

	struct AddColumnClause : public Clause
	{
		explicit AddColumnClause(MemoryPool& p)
			: Clause(p, TYPE_ADD_COLUMN),
			  field(NULL),
			  defaultValue(NULL),
			  constraints(p),
			  collate(p),
			  computed(NULL),
			  identityOptions(NULL),
			  notNullSpecified(false)
		{
		}

		dsql_fld* field;
		NestConst<ValueSourceClause> defaultValue;
		Firebird::ObjectsArray<AddConstraintClause> constraints;
		QualifiedName collate;
		NestConst<ValueSourceClause> computed;
		NestConst<IdentityOptions> identityOptions;
		bool notNullSpecified;
		bool createIfNotExistsOnly = false;
	};

	struct AlterColNameClause : public Clause
	{
		explicit AlterColNameClause(MemoryPool& p)
			: Clause(p, TYPE_ALTER_COL_NAME),
			  fromName(p),
			  toName(p)
		{
		}

		MetaName fromName;
		MetaName toName;
	};

	struct AlterColNullClause : public Clause
	{
		explicit AlterColNullClause(MemoryPool& p)
			: Clause(p, TYPE_ALTER_COL_NULL),
			  name(p),
			  notNullFlag(false)
		{
		}

		MetaName name;
		bool notNullFlag;
	};

	struct AlterColPosClause : public Clause
	{
		explicit AlterColPosClause(MemoryPool& p)
			: Clause(p, TYPE_ALTER_COL_POS),
			  name(p),
			  newPos(0)
		{
		}

		MetaName name;
		SSHORT newPos;
	};

	struct AlterColTypeClause : public Clause
	{
		explicit AlterColTypeClause(MemoryPool& p)
			: Clause(p, TYPE_ALTER_COL_TYPE),
			  field(NULL),
			  defaultValue(NULL),
			  dropDefault(false),
			  dropIdentity(false),
			  identityOptions(NULL),
			  computed(NULL)
		{
		}

		dsql_fld* field;
		NestConst<ValueSourceClause> defaultValue;
		bool dropDefault;
		bool dropIdentity;
		NestConst<IdentityOptions> identityOptions;
		NestConst<ValueSourceClause> computed;
	};

	struct DropColumnClause : public Clause
	{
		explicit DropColumnClause(MemoryPool& p)
			: Clause(p, TYPE_DROP_COLUMN),
			  name(p)
		{
		}

		MetaName name;
		bool cascade = false;
		bool silent = false;
	};

	struct DropConstraintClause : public Clause
	{
		explicit DropConstraintClause(MemoryPool& p)
			: Clause(p, TYPE_DROP_CONSTRAINT),
			  name(p)
		{
		}

		MetaName name;
		bool silent = false;
	};

	struct AlterConstraintClause : public Clause
	{
		explicit AlterConstraintClause(MemoryPool& p)
			: Clause(p, TYPE_ALTER_CONSTRAINT),
			  name(p)
		{
		}

		MetaName name;
		bool enforced = false;
	};

	RelationNode(MemoryPool& p, RelationSourceNode* aDsqlNode);

	static bool deleteLocalField(thread_db* tdbb, jrd_tra* transaction,
		const QualifiedName& relationName, const MetaName& fieldName, bool silent,
		std::function<void()> preChangeHandler = {});

	static void addToPublication(thread_db* tdbb, jrd_tra* transaction,
		const QualifiedName& tableName, const MetaName& pubName);
	static void dropFromPublication(thread_db* tdbb, jrd_tra* transaction,
		const QualifiedName& tableName, const MetaName& pubName);

public:
	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override;

protected:
	Firebird::string internalPrint(NodePrinter& printer) const override
	{
		DdlNode::internalPrint(printer);

		//// FIXME-PRINT: NODE_PRINT(printer, dsqlNode);
		NODE_PRINT(printer, name);
		//// FIXME-PRINT: NODE_PRINT(printer, clauses);

		return "RelationNode";
	}

	void defineField(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction,
		AddColumnClause* clause, SSHORT position,
		const Firebird::ObjectsArray<MetaName>* pkcols);
	bool defineDefault(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, dsql_fld* field,
		ValueSourceClause* clause, Firebird::string& source, BlrDebugWriter::BlrData& value);
	void makeConstraint(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction,
		AddConstraintClause* clause, Firebird::ObjectsArray<CreateDropConstraint>& constraints,
		bool* notNull = NULL);
	void defineConstraint(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction,
		MetaName& constraintName, Constraint& constraint);
	void defineCheckConstraint(DsqlCompilerScratch* dsqlScratch, Constraint& constraint,
		BoolSourceClause* clause);
	void defineCheckConstraintTrigger(DsqlCompilerScratch* dsqlScratch, Constraint& constraint,
		BoolSourceClause* clause, FB_UINT64 triggerType);
	void defineSetDefaultTrigger(DsqlCompilerScratch* dsqlScratch, Constraint& constraint,
		bool onUpdate);
	void defineSetNullTrigger(DsqlCompilerScratch* dsqlScratch, Constraint& constraint,
		bool onUpdate);
	void defineDeleteCascadeTrigger(DsqlCompilerScratch* dsqlScratch, Constraint& constraint);
	void defineUpdateCascadeTrigger(DsqlCompilerScratch* dsqlScratch, Constraint& constraint);
	void generateUnnamedTriggerBeginning(Constraint& constraint, bool onUpdate,
		BlrDebugWriter& blrWriter);
	void stuffDefaultBlr(const Firebird::ByteChunk& defaultBlr, BlrDebugWriter& blrWriter);
	void stuffMatchingBlr(Constraint& constraint, BlrDebugWriter& blrWriter);
	void stuffTriggerFiringCondition(const Constraint& constraint, BlrDebugWriter& blrWriter);

public:
	NestConst<RelationSourceNode> dsqlNode;
	QualifiedName name;
	Firebird::Array<NestConst<Clause> > clauses;
	Firebird::TriState ssDefiner;
	Firebird::TriState replicationState;
};


class CreateRelationNode final : public RelationNode
{
public:
	CreateRelationNode(MemoryPool& p, RelationSourceNode* aDsqlNode,
				const Firebird::string* aExternalFile = NULL)
		: RelationNode(p, aDsqlNode),
		  externalFile(aExternalFile)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		dsqlScratch->qualifyNewName(name);
		protectSystemSchema(name.schema, obj_relation);
		dsqlScratch->ddlSchema = name.schema;

		return RelationNode::dsqlPass(dsqlScratch);
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_create_table_failed) << name.toQuotedString();
	}

private:
	const Firebird::ObjectsArray<MetaName>* findPkColumns();

public:
	const Firebird::string* externalFile;
	std::optional<rel_t> relationType = rel_persistent;
	bool preserveRowsOpt;
	bool deleteRowsOpt;
	bool createIfNotExistsOnly = false;
};


class AlterRelationNode final : public RelationNode
{
public:
	AlterRelationNode(MemoryPool& p, RelationSourceNode* aDsqlNode)
		: RelationNode(p, aDsqlNode)
	{
	}

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		dsqlScratch->qualifyExistingName(name, obj_relation);
		protectSystemSchema(name.schema, obj_relation);
		dsqlScratch->ddlSchema = name.schema;

		return RelationNode::dsqlPass(dsqlScratch);
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_alter_table_failed) << name.toQuotedString();
	}

private:
	void modifyField(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction,
		AlterColTypeClause* clause);
};


class DropRelationNode final : public DdlNode
{
public:
	DropRelationNode(MemoryPool& p, const QualifiedName& aName, bool aView = false)
		: DdlNode(p),
		  name(p, aName),
		  view(aView),
		  silent(false)
	{
	}

	static void deleteGlobalField(thread_db* tdbb, jrd_tra* transaction, const QualifiedName& globalName);

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		if (recreate)
			dsqlScratch->qualifyNewName(name);
		else
			dsqlScratch->qualifyExistingName(name, (view ? obj_view : obj_relation));

		protectSystemSchema(name.schema, (view ? obj_view : obj_relation));
		dsqlScratch->ddlSchema = name.schema;

		return DdlNode::dsqlPass(dsqlScratch);
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(view ? isc_dsql_drop_view_failed : isc_dsql_drop_table_failed) <<
			name.toQuotedString();
	}

public:
	QualifiedName name;
	bool view;
	bool silent;
	bool recreate = false;
};


typedef RecreateNode<CreateRelationNode, DropRelationNode, isc_dsql_recreate_table_failed>
	RecreateTableNode;


class CreateAlterViewNode final : public RelationNode
{
public:
	CreateAlterViewNode(MemoryPool& p, RelationSourceNode* aDsqlNode, ValueListNode* aViewFields,
				SelectExprNode* aSelectExpr)
		: RelationNode(p, aDsqlNode),
		  create(true),
		  alter(false),
		  viewFields(aViewFields),
		  selectExpr(aSelectExpr),
		  source(p),
		  withCheckOption(false)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector <<
			Firebird::Arg::Gds(createAlterCode(create, alter,
					isc_dsql_create_view_failed, isc_dsql_alter_view_failed,
					isc_dsql_create_alter_view_failed)) <<
				name.toQuotedString();
	}

private:
	void createCheckTrigger(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, ValueListNode* items,
		TriggerType triggerType);

public:
	bool create;
	bool alter;
	bool createIfNotExistsOnly = false;
	NestConst<ValueListNode> viewFields;
	NestConst<SelectExprNode> selectExpr;
	Firebird::string source;
	bool withCheckOption;
};


class RecreateViewNode final :
	public RecreateNode<CreateAlterViewNode, DropRelationNode, isc_dsql_recreate_view_failed>
{
public:
	RecreateViewNode(MemoryPool& p, CreateAlterViewNode* aCreateNode)
		: RecreateNode<CreateAlterViewNode, DropRelationNode, isc_dsql_recreate_view_failed>(
				p, aCreateNode)
	{
		dropNode.view = true;
	}
};


class CreateIndexNode final : public DdlNode
{
public:
	struct Definition
	{
		Definition()
			: type(0)
		{
			expressionBlr.clear();
			expressionSource.clear();
			conditionBlr.clear();
			conditionSource.clear();
		}

		QualifiedName relation;
		Firebird::ObjectsArray<MetaName> columns;
		Firebird::TriState unique;
		Firebird::TriState descending;
		Firebird::TriState inactive;
		SSHORT type;
		bid expressionBlr;
		bid expressionSource;
		bid conditionBlr;
		bid conditionSource;
		QualifiedName refRelation;
		Firebird::ObjectsArray<MetaName> refColumns;
	};

public:
	CreateIndexNode(MemoryPool& p, const QualifiedName& aName)
		: DdlNode(p),
		  name(p, aName)
	{
	}

public:
	static void store(thread_db* tdbb, jrd_tra* transaction, QualifiedName& name,
		const Definition& definition, QualifiedName* referredIndexName = nullptr);

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;
	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override;

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_create_index_failed) << name.toQuotedString();
	}

public:
	QualifiedName name;
	bool unique = false;
	bool descending = false;
	bool active = true;
	NestConst<RelationSourceNode> relation;
	NestConst<ValueListNode> columns;
	NestConst<ValueSourceClause> computed;
	NestConst<BoolSourceClause> partial;
	bool createIfNotExistsOnly = false;
};


class AlterIndexNode final : public DdlNode
{
public:
	AlterIndexNode(MemoryPool& p, const QualifiedName& aName, bool aActive)
		: DdlNode(p),
		  name(p, aName),
		  active(aActive)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		dsqlScratch->qualifyExistingName(name, obj_index);
		dsqlScratch->ddlSchema = name.schema;

		return DdlNode::dsqlPass(dsqlScratch);
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_alter_index_failed) << name.toQuotedString();
	}

public:
	QualifiedName name;
	bool active;
};


class SetStatisticsNode final : public DdlNode
{
public:
	SetStatisticsNode(MemoryPool& p, const QualifiedName& aName)
		: DdlNode(p),
		  name(p, aName)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		dsqlScratch->qualifyExistingName(name, obj_index);
		dsqlScratch->ddlSchema = name.schema;

		return DdlNode::dsqlPass(dsqlScratch);
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		// ASF: using ALTER INDEX's code.
		statusVector << Firebird::Arg::Gds(isc_dsql_alter_index_failed) << name.toQuotedString();
	}

public:
	QualifiedName name;
};


class DropIndexNode final : public DdlNode
{
public:
	DropIndexNode(MemoryPool& p, const QualifiedName& aName)
		: DdlNode(p),
		  name(p, aName)
	{
	}

	static bool deleteSegmentRecords(thread_db* tdbb, jrd_tra* transaction, const QualifiedName& name);

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		dsqlScratch->qualifyExistingName(name, obj_index);
		dsqlScratch->ddlSchema = name.schema;

		return DdlNode::dsqlPass(dsqlScratch);
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_drop_index_failed) << name.toQuotedString();
	}

public:
	QualifiedName name;
	bool silent = false;
};


class CreateFilterNode final : public DdlNode
{
public:
	class NameNumber : public Printable
	{
	public:
		NameNumber(MemoryPool& p, const MetaName& aName)
			: name(p, aName),
			  number(0)
		{
		}

		NameNumber(MemoryPool& p, SSHORT aNumber)
			: name(p),
			  number(aNumber)
		{
		}

	public:
		Firebird::string internalPrint(NodePrinter& printer) const override
		{
			NODE_PRINT(printer, name);
			NODE_PRINT(printer, number);

			return "NameNumber";
		}

	public:
		MetaName name;
		SSHORT number;
	};

public:
	CreateFilterNode(MemoryPool& p, const MetaName& aName)
		: DdlNode(p),
		  name(p, aName),
		  entryPoint(p),
		  moduleName(p)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_create_filter_failed) << name;
	}

public:
	MetaName name;
	NestConst<NameNumber> inputFilter;
	NestConst<NameNumber> outputFilter;
	Firebird::string entryPoint;
	Firebird::string moduleName;
};


class DropFilterNode final : public DdlNode
{
public:
	DropFilterNode(MemoryPool& p, const MetaName& aName)
		: DdlNode(p),
		  name(p, aName)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_drop_filter_failed) << name;
	}

public:
	MetaName name;
	bool silent = false;
};


class CreateShadowNode final : public DdlNode
{
public:
	CreateShadowNode(MemoryPool& p, SSHORT aNumber, bool aManual, bool aConditional,
					 const Firebird::string& aFileName)
		: DdlNode(p),
		  number(aNumber),
		  manual(aManual),
		  conditional(aConditional),
		  fileName(p, aFileName)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	bool mustBeReplicated() const override
	{
		return false;
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_create_shadow_failed) << Firebird::Arg::Num(number);
	}

public:
	SSHORT number;
	bool manual;
	bool conditional;
	Firebird::string fileName;
	bool createIfNotExistsOnly = false;
};


class DropShadowNode final : public DdlNode
{
public:
	DropShadowNode(MemoryPool& p, const SSHORT aNumber, const bool aNodelete)
		: DdlNode(p),
		  number(aNumber),
		  nodelete(aNodelete)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	bool mustBeReplicated() const override
	{
		return false;
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_drop_shadow_failed) << Firebird::Arg::Num(number);
	}

public:
	SSHORT number;
	bool nodelete;
};


class PrivilegesNode : public DdlNode
{
public:
	PrivilegesNode(MemoryPool& p)
		: DdlNode(p)
	{
	}

protected:
	static USHORT convertPrivilegeFromString(thread_db* tdbb, jrd_tra* transaction,
		MetaName privilege);
};

class CreateAlterRoleNode final : public PrivilegesNode
{
public:
	CreateAlterRoleNode(MemoryPool& p, const MetaName& aName)
		: PrivilegesNode(p),
		  name(p, aName),
		  createFlag(false),
		  sysPrivDrop(false),
		  privileges(p)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(createFlag ? isc_dsql_create_role_failed :
			isc_dsql_alter_role_failed) << name;
	}

private:
	bool isItUserName(thread_db* tdbb, jrd_tra* transaction);

public:
	MetaName name;
	bool createFlag;
	bool sysPrivDrop;
	bool createIfNotExistsOnly = false;

	void addPrivilege(const MetaName* privName)
	{
		fb_assert(privName);
		privileges.push(*privName);
	}

private:
	Firebird::HalfStaticArray<MetaName, 4> privileges;
};


class MappingNode final : public DdlNode, private ExecInSecurityDb
{
public:
	enum OP {MAP_ADD, MAP_MOD, MAP_RPL, MAP_DROP, MAP_COMMENT};

	MappingNode(MemoryPool& p, OP o, const MetaName& nm)
		: DdlNode(p),
		  name(p, nm),
		  fromUtf8(p),
		  op(o)
	{
	}

	void validateAdmin();

public:
	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		if (from)
			from->dsqlPass(dsqlScratch);

		return DdlNode::dsqlPass(dsqlScratch);
	}

	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_mapping_failed) << name <<
			(op == MAP_ADD ? "CREATE" : op == MAP_MOD ?
			 "ALTER" : op == MAP_RPL ? "CREATE OR ALTER" : op == MAP_DROP ?
			 "DROP" : "COMMENT ON");
	}
	void runInSecurityDb(SecDbContext* secDbContext) override;

private:
	void addItem(Firebird::string& ddl, const char* text, char quote = '"');

public:
	MetaName name;
	Firebird::string fromUtf8;
	MetaName* plugin = nullptr;
	MetaName* db = nullptr;
	MetaName* fromType = nullptr;
	IntlString* from = nullptr;
	MetaName* to = nullptr;
	Firebird::string* comment = nullptr;
	OP op;
	char mode = '#';	// * - any source, P - plugin, M - mapping, S - any serverwide plugin
	bool global = false;
	bool role = false;
	bool silentDrop = false;
	bool createIfNotExistsOnly = false;
};


class DropRoleNode final : public DdlNode
{
public:
	DropRoleNode(MemoryPool& p, const MetaName& aName)
		: DdlNode(p),
		  name(p, aName)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_drop_role_failed) << name;
	}

public:
	MetaName name;
	bool silent = false;
};


class UserNode : public DdlNode
{
public:
	explicit UserNode(MemoryPool& p)
		: DdlNode(p)
	{ }

protected:
	MetaName upper(const MetaName& str);
};


class CreateAlterUserNode final : public UserNode
{
public:
	enum Mode {USER_ADD, USER_MOD, USER_RPL};

	CreateAlterUserNode(MemoryPool& p, Mode md, const MetaName& aName)
		: UserNode(p),
		  properties(p),
		  name(p, upper(aName)),
		  password(NULL),
		  firstName(NULL),
		  middleName(NULL),
		  lastName(NULL),
		  plugin(NULL),
		  comment(NULL),
		  mode(md)
	{ }

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	bool mustBeReplicated() const override
	{
		return false;
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(mode == USER_ADD ?
			isc_dsql_create_user_failed : isc_dsql_alter_user_failed) << name;
	}

public:
	class Property
	{
	public:
		explicit Property(MemoryPool& p)
			: value(p)
		{ }

		MetaName property;
		Firebird::string value;
	};

	Firebird::ObjectsArray<Property> properties;
	const MetaName name;
	Firebird::string* password;
	Firebird::string* firstName;
	Firebird::string* middleName;
	Firebird::string* lastName;
	MetaName* plugin;
	Firebird::string* comment;
	Firebird::TriState adminRole;
	Firebird::TriState active;
	Mode mode;
	bool createIfNotExistsOnly = false;

	void addProperty(MetaName* pr, Firebird::string* val = NULL)
	{
		fb_assert(pr);

		Property& p = properties.add();
		p.property = *pr;
		if (val)
		{
			p.value = *val;
		}
	}
};


class DropUserNode final : public UserNode
{
public:
	DropUserNode(MemoryPool& p, const MetaName& aName, const MetaName* aPlugin = NULL)
		: UserNode(p),
		  name(p, upper(aName)),
		  plugin(p),
		  silent(false)
	{
		if (aPlugin)
			plugin = *aPlugin;
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	bool mustBeReplicated() const override
	{
		return false;
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_drop_user_failed) << name;
	}

public:
	const MetaName name;
	MetaName plugin;
	bool silent;
	bool recreate = false;
};


template <>
inline RecreateNode<CreateAlterUserNode, DropUserNode, isc_dsql_recreate_user_failed>::
	RecreateNode(MemoryPool& p, CreateAlterUserNode* aCreateNode)
		: DdlNode(p),
		  createNode(aCreateNode),
		  dropNode(p, createNode->name, createNode->plugin)
	{
		dropNode.silent = true;
	}

typedef RecreateNode<CreateAlterUserNode, DropUserNode, isc_dsql_recreate_user_failed>
	RecreateUserNode;


typedef Firebird::NonPooledPair<char, Firebird::ObjectsArray<MetaName>*> PrivilegeClause;
typedef Firebird::NonPooledPair<ObjectType, QualifiedName> GranteeClause;

class GrantRevokeNode final : public PrivilegesNode, private ExecInSecurityDb
{
public:
	GrantRevokeNode(MemoryPool& p, bool aIsGrant)
		: PrivilegesNode(p),
		  createDbJobs(p),
		  isGrant(aIsGrant),
		  privileges(p),
		  roles(p),
		  defaultRoles(p),
		  object(NULL),
		  users(p),
		  grantAdminOption(false),
		  grantor(NULL),
		  isDdl(false)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		Firebird::Array<GranteeClause*> grantees;

		if (object)
			grantees.add(object);

		for (auto& user : users)
			grantees.add(&user);

		for (auto grantee : grantees)
		{
			switch (grantee->first)
			{
				case obj_charset:
				case obj_collation:
				case obj_exception:
				case obj_field:
				case obj_generator:
				case obj_index:
				case obj_package_header:
				case obj_procedure:
				case obj_relation:
				case obj_view:
				case obj_trigger:
				case obj_udf:
					dsqlScratch->qualifyExistingName(grantee->second, grantee->first);
					break;

				case obj_database:
				case obj_schema:
				case obj_user:
				case obj_user_or_role:
				case obj_sql_role:
				case obj_privilege:
				case obj_roles:
				case obj_filters:
				case obj_jobs:
				case obj_tablespaces:
				case obj_schemas:
					break;

				case obj_relations:
				case obj_views:
				case obj_procedures:
				case obj_functions:
				case obj_packages:
				case obj_generators:
				case obj_domains:
				case obj_exceptions:
				case obj_charsets:
				case obj_collations:
					fb_assert(grantee->second.object.hasData());

					if (grantee->second.schema.isEmpty())
					{
						fb_assert(grantee->second.object.hasData());
						dsqlScratch->qualifyNewName(grantee->second);
					}

					break;

				default:
					fb_assert(false);
					break;
			}

			if (grantee == object)
				dsqlScratch->ddlSchema = object->second.schema;
		}

		return PrivilegesNode::dsqlPass(dsqlScratch);
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector <<
			Firebird::Arg::Gds(isGrant ? isc_dsql_grant_failed : isc_dsql_revoke_failed);
	}

	void runInSecurityDb(SecDbContext* secDbContext) override;

private:
	void modifyPrivileges(thread_db* tdbb, jrd_tra* transaction, SSHORT option, const GranteeClause* user);
	void grantRevoke(thread_db* tdbb, jrd_tra* transaction, const GranteeClause* object,
		const GranteeClause* userNod, const char* privs, MetaName field, int options);
	static void checkGrantorCanGrantRelation(thread_db* tdbb, jrd_tra* transaction, const char* grantor,
		const char* privilege, const QualifiedName& relationName,
		const MetaName& fieldName, bool topLevel);
	static void checkGrantorCanGrantRole(thread_db* tdbb, jrd_tra* transaction,
			const MetaName& grantor, const MetaName& roleName);
	static void checkGrantorCanGrantDdl(thread_db* tdbb, jrd_tra* transaction,
			const MetaName& grantor, const char* privilege, const QualifiedName& objName);
	static void checkGrantorCanGrantObject(thread_db* tdbb, jrd_tra* transaction, const char* grantor,
		const char* privilege, const QualifiedName& objName, SSHORT objType);
	static void storePrivilege(thread_db* tdbb, jrd_tra* transaction,
		const QualifiedName& object, const QualifiedName& user,
		const MetaName& field, const TEXT* privilege, SSHORT userType,
		SSHORT objType, int option, const MetaName& grantor);
	static void setFieldClassName(thread_db* tdbb, jrd_tra* transaction,
		const QualifiedName& relation, const MetaName& field);

	// Diagnostics print helper.
	static const char* privilegeName(char symbol)
	{
		switch (UPPER7(symbol))
		{
			case 'A': return "ALL";
			case 'I': return "INSERT";
			case 'U': return "UPDATE";
			case 'D': return "DELETE";
			case 'S': return "SELECT";
			case 'X': return "EXECUTE";
			case 'G': return "USAGE";
			case 'M': return "ROLE";
			case 'R': return "REFERENCE";
			// ddl
			case 'C': return "CREATE";
			case 'L': return "ALTER";
			case 'O': return "DROP";
		}

		return "<Unknown>";
	}

	struct CreateDbJob
	{
		CreateDbJob(SSHORT a_userType, const MetaName& a_user)
			: allOnAll(false), grantErased(false), badGrantor(false),
			  userType(a_userType), user(a_user)
		{ }

		bool allOnAll, grantErased, badGrantor;
		SSHORT userType;
		MetaName user, revoker;
	};
	Firebird::Array<CreateDbJob> createDbJobs;

public:
	bool isGrant;
	Firebird::Array<PrivilegeClause> privileges;
	Firebird::Array<GranteeClause> roles;
	Firebird::Array<bool> defaultRoles;
	NestConst<GranteeClause> object;
	Firebird::Array<GranteeClause> users;
	bool grantAdminOption;
	NestConst<MetaName> grantor;
	// ddl rights
	bool isDdl;
};


class AlterDatabaseNode final : public DdlNode
{
public:
	static const unsigned CLAUSE_BEGIN_BACKUP		= 0x01;
	static const unsigned CLAUSE_END_BACKUP			= 0x02;
	static const unsigned CLAUSE_DROP_DIFFERENCE	= 0x04;
	static const unsigned CLAUSE_CRYPT				= 0x08;
	static const unsigned CLAUSE_ENABLE_PUB			= 0x10;
	static const unsigned CLAUSE_DISABLE_PUB		= 0x20;
	static const unsigned CLAUSE_PUB_INCL_TABLE		= 0x40;
	static const unsigned CLAUSE_PUB_EXCL_TABLE		= 0x80;

	static const unsigned RDB_DATABASE_MASK =
		CLAUSE_BEGIN_BACKUP | CLAUSE_END_BACKUP | CLAUSE_DROP_DIFFERENCE;

public:
	AlterDatabaseNode(MemoryPool& p)
		: DdlNode(p),
		  differenceFile(p),
		  setDefaultCharSet(p),
		  setDefaultCollation(p),
		  cryptPlugin(p),
		  keyName(p),
		  pubTables(p)
	{
	}

public:
	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override
	{
		dsqlScratch->qualifyExistingName(setDefaultCharSet, obj_charset);
		dsqlScratch->qualifyExistingName(setDefaultCollation, obj_collation);

		for (auto& pubTable : pubTables)
			dsqlScratch->qualifyExistingName(pubTable, obj_relation);

		dsqlScratch->getDsqlStatement()->setType(
			create ? DsqlStatement::TYPE_CREATE_DB : DsqlStatement::TYPE_DDL);
		return this;
	}

	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

	bool mustBeReplicated() const override
	{
		return false;
	}

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_alter_database_failed);
	}

private:
	static void changeBackupMode(thread_db* tdbb, jrd_tra* transaction, unsigned clause);
	static void defineDifference(thread_db* tdbb, jrd_tra* transaction, const Firebird::PathName& file);
	void checkClauses(thread_db* tdbb);

public:
	bool create = false;	// Is the node created with a CREATE DATABASE command?
	SLONG linger = -1;
	unsigned clauses = 0;
	Firebird::string differenceFile;
	QualifiedName setDefaultCharSet;
	QualifiedName setDefaultCollation;
	MetaName cryptPlugin;
	MetaName keyName;
	Firebird::TriState ssDefiner;
	Firebird::Array<QualifiedName> pubTables;
};


class CreateAlterSchemaNode final : public DdlNode
{
public:
	CreateAlterSchemaNode(MemoryPool& pool, const MetaName& aName)
		: DdlNode(pool),
		  name(pool, aName)
	{
	}

public:
	DdlNode* dsqlPass(DsqlCompilerScratch* dsqlScratch) override;
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector <<
			Firebird::Arg::Gds(createAlterCode(create, alter,
					isc_dsql_create_schema_failed, isc_dsql_alter_schema_failed,
					isc_dsql_create_alter_schema_failed)) <<
				name.toQuotedString();
	}

private:
	void executeCreate(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction);
	bool executeAlter(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction);

public:
	MetaName name;
	std::optional<QualifiedName> setDefaultCharSet;	// use empty QualifiedName with DROP DEFAULT CHARACTER SET
	std::optional<SqlSecurity> setDefaultSqlSecurity;
	bool create = true;
	bool alter = false;
	bool createIfNotExistsOnly = false;
};


class DropSchemaNode final : public DdlNode
{
public:
	DropSchemaNode(MemoryPool& pool, const MetaName& aName)
		: DdlNode(pool),
		  name(pool, aName)
	{
	}

public:
	Firebird::string internalPrint(NodePrinter& printer) const override;
	void checkPermission(thread_db* tdbb, jrd_tra* transaction) override;
	void execute(thread_db* tdbb, DsqlCompilerScratch* dsqlScratch, jrd_tra* transaction) override;

protected:
	void putErrorPrefix(Firebird::Arg::StatusVector& statusVector) override
	{
		statusVector << Firebird::Arg::Gds(isc_dsql_drop_schema_failed) << name.toQuotedString();
	}

private:
	bool collectObjects(thread_db* tdbb, jrd_tra* transaction,
		Firebird::Array<Firebird::RightPooledPair<ObjectType, MetaName>>* objects = nullptr);

public:
	MetaName name;
	bool silent = false;
	bool recreate = false;
};


using RecreateSchemaNode = RecreateNode<CreateAlterSchemaNode, DropSchemaNode, isc_dsql_recreate_schema_failed>;


} // namespace

#endif // DSQL_DDL_NODES_H