database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

!4251 支持忽略PL/SQL间的依赖进行创建PL/SQL

Browse Source 
Merge pull request !4251 from lukeman/master
This commit is contained in:
opengauss_bot
2023-10-24 01:55:31 +00:00
committed by Gitee
parent efa0a6578c 0f4ede314e
commit addc19a2e0
110 changed files with 18161 additions and 485 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/include/utils/builtins.h
View File

@ -856,6 +856,7 @@ extern char* format_operator(Oid operator_oid);
extern char *format_procedure_qualified(Oid procedure_oid);
extern char *format_operator_qualified(Oid operator_oid);
extern void format_procedure_parts(Oid procedure_oid, List **objnames, List **objargs);
extern char * format_procedure_no_visible(Oid procedure_oid);
/* rowtypes.c */
extern Datum record_in(PG_FUNCTION_ARGS);
@ -1101,6 +1102,11 @@ extern Datum unknownout(PG_FUNCTION_ARGS);
extern Datum unknownrecv(PG_FUNCTION_ARGS);
extern Datum unknownsend(PG_FUNCTION_ARGS);
extern Datum undefinedin(PG_FUNCTION_ARGS);
extern Datum undefinedout(PG_FUNCTION_ARGS);
extern Datum undefinedrecv(PG_FUNCTION_ARGS);
extern Datum undefinedsend(PG_FUNCTION_ARGS);
extern Datum pg_column_size(PG_FUNCTION_ARGS);
extern Datum datalength(PG_FUNCTION_ARGS);

2
src/include/utils/lsyscache.h
View File

@ -117,6 +117,7 @@ extern bool type_is_rowtype(Oid typid);
extern bool type_is_enum(Oid typid);
extern bool type_is_range(Oid typid);
extern bool type_is_set(Oid typid);
extern bool type_is_relation(Oid typid);
extern void get_type_category_preferred(Oid typid, char* typcategory, bool* typispreferred);
extern Oid get_typ_typrelid(Oid typid);
extern Oid get_element_type(Oid typid);
@ -219,6 +220,7 @@ extern Oid get_valid_relname_relid(const char* relnamespace, const char* relname
extern bool get_func_iswindow(Oid funcid);
extern char get_func_prokind(Oid funcid);
extern char get_typecategory(Oid typid);
extern Oid get_array_internal_depend_type_oid(Oid arrTypOid);
#ifdef USE_SPQ
/* comparison types */

2
src/include/utils/pl_package.h
View File

@ -72,5 +72,5 @@ extern List* GetPackageListName(const char* pkgName, const Oid nspOid);
extern HeapTuple getPLpgsqlVarTypeTup(char* word);
extern HeapTuple FindRowVarColType(List* nameList, int* collectionType = NULL, Oid* tableofIndexType = NULL,
int32* typMod = NULL);
int32* typMod = NULL, TypeDependExtend* dependExtend = NULL);
#endif

111
src/include/utils/plpgsql.h
View File

@ -289,6 +289,35 @@ typedef enum {
PLPGSQL_CURSOR_NAME
} PLpgSQL_con_info_item_value;
/*
* GsDependency object type
*/
typedef enum {
GSDEPEND_OBJECT_TYPE_INVALID = 0,
GSDEPEND_OBJECT_TYPE_UNDEFIND,
GSDEPEND_OBJECT_TYPE_VARIABLE,
GSDEPEND_OBJECT_TYPE_TYPE,
GSDEPEND_OBJECT_TYPE_FUNCTION,
GSDEPEND_OBJECT_TYPE_PROCHEAD,
GSDEPEND_OBJECT_TYPE_PKG,
GSDEPEND_OBJECT_TYPE_PKG_BODY,
GSDEPEND_OBJECT_TYPE_PKG_RECOMPILE
} GsDependObjectType;
/*
* GsDependency reference object position type
*/
#define GSDEPEND_REFOBJ_POS_INVALID 0
#define GSDEPEND_REFOBJ_POS_IN_TYPE 1
#define GSDEPEND_REFOBJ_POS_IN_PKGSPEC 2
#define GSDEPEND_REFOBJ_POS_IN_PROCHEAD 4
#define GSDEPEND_REFOBJ_POS_IN_PROCBODY 8
#define GSDEPEND_REFOBJ_POS_IN_PKGBODY 16
#define GSDEPEND_REFOBJ_POS_IN_PKGRECOMPILE_OBJ (GSDEPEND_REFOBJ_POS_IN_PKGSPEC | \
GSDEPEND_REFOBJ_POS_IN_PKGBODY | GSDEPEND_REFOBJ_POS_IN_PROCBODY)
#define GSDEPEND_REFOBJ_POS_IN_PKGALL_OBJ (GSDEPEND_REFOBJ_POS_IN_PKGRECOMPILE_OBJ)
#define GSDEPEND_REFOBJ_POS_IN_PROCALL (GSDEPEND_REFOBJ_POS_IN_PROCHEAD | GSDEPEND_REFOBJ_POS_IN_PROCBODY)
/**********************************************************************
* Node and structure definitions
**********************************************************************/
@ -302,6 +331,46 @@ typedef struct PLpgSQL_datum { /* Generic datum array item */
bool ispkg;
} PLpgSQL_datum;
/*
* DependenciesDatum is the common supertype for DependenciesUndefined, DependenciesVariable,
* DependenciesType, DependenciesProchead
*/
typedef struct DependenciesDatum { /* Generic datum array item */
NodeTag type;
} DependenciesDatum;
/*
* PLpgSQL dependencies undefined/type/variable/function/procedure
*/
typedef struct DependenciesUndefined { /* Generic datum array item */
NodeTag type;
} DependenciesUndefined;
typedef struct DependenciesVariable {
NodeTag type;
char* typName;
int32 typMod;
char* extraInfo;
} DependenciesVariable;
typedef struct DependenciesType{
NodeTag type;
char typType;
char typCategory;
char* attrInfo;
bool isRel;
char* elemTypName;
char* idxByTypName;
} DependenciesType;
typedef struct DependenciesProchead{
NodeTag type;
bool undefined;
char* proName;
char* proArgSrc;
char* funcHeadSrc;
} DependenciesProchead;
typedef enum PLpgSQL_trigtype
{
PLPGSQL_DML_TRIGGER,
@ -403,6 +472,8 @@ typedef struct { /* openGauss data type */
* then convert to tuple descriptior.
*/
Oid cursorCompositeOid = InvalidOid;
Oid tableofOid;
TypeDependExtend* dependExtend;
} PLpgSQL_type;
typedef struct {
@ -1161,6 +1232,10 @@ typedef struct PLpgSQL_function { /* Complete compiled function */
bool is_autonomous;
bool is_plpgsql_func_with_outparam;
bool is_insert_gs_source;
/* gs depend */
bool isValid;
bool is_need_recompile;
Oid namespaceOid;
} PLpgSQL_function;
class AutonomousSession;
@ -1362,6 +1437,13 @@ typedef struct plpgsql_pkg_hashent {
} plpgsql_pkg_HashEnt;
#define PACKAGE_INVALID 0x0
#define PACKAGE_SPEC_VALID 0x1
#define PACKAGE_SPEC_INVALID 0xFE
#define PACKAGE_BODY_VALID 0x2
#define PACKAGE_BODY_INVALID 0xFD
#define PACKAGE_VALID 0x3
typedef struct PLpgSQL_package { /* Complete compiled package */
char* pkg_signature;
Oid pkg_oid;
@ -1407,6 +1489,15 @@ typedef struct PLpgSQL_package { /* Complete compiled package */
knl_u_plpgsql_pkg_context* u_pkg;
Oid namespaceOid;
bool isInit;
/**
* gs_dependencies_fn.h
*/
NodeTag type;
List* preRefObjectOidList;
List* preSelfObjectList;
unsigned char status;
bool is_need_recompile;
} PLpgSQL_package;
@ -1664,7 +1755,7 @@ typedef struct plpgsql_hashent {
DListCell* cell; /* Dlist cell for delete function compile results. */
} plpgsql_HashEnt;
extern PLpgSQL_function* plpgsql_compile(FunctionCallInfo fcinfo, bool forValidator);
extern PLpgSQL_function* plpgsql_compile(FunctionCallInfo fcinfo, bool forValidator, bool isRecompile = false);
extern void delete_function(PLpgSQL_function* func, bool fromPackage = false);
extern PLpgSQL_function* plpgsql_compile_nohashkey(FunctionCallInfo fcinfo); /* parse trigger func */
extern PLpgSQL_function* plpgsql_compile_inline(char* proc_source);
@ -1679,10 +1770,10 @@ extern bool plpgsql_parse_tripword(char* word1, char* word2, char* word3, PLwdat
extern bool plpgsql_parse_quadword(char* word1, char* word2, char* word3, char* word4, PLwdatum* wdatum,
PLcword* cword, int* tok_flag);
extern PLpgSQL_type* plpgsql_parse_wordtype(char* ident);
extern PLpgSQL_type* plpgsql_parse_cwordtype(List* idents);
extern PLpgSQL_type* plpgsql_parse_cwordtype(List* idents, TypeDependExtend* dependExtend = NULL);
extern PLpgSQL_type* plpgsql_parse_wordrowtype(char* ident);
extern PLpgSQL_type* plpgsql_parse_cwordrowtype(List* idents);
extern PLpgSQL_type* plpgsql_build_datatype(Oid typeOid, int32 typmod, Oid collation);
extern PLpgSQL_type* plpgsql_build_datatype(Oid typeOid, int32 typmod, Oid collation, TypeDependExtend* type_depend_extend = NULL);
extern PLpgSQL_type* build_datatype(HeapTuple type_tup, int32 typmod, Oid collation);
extern PLpgSQL_type* plpgsql_build_nested_datatype();
extern const char *plpgsql_code_int2cstring(int sqlcode);
@ -1707,12 +1798,13 @@ extern bool plpgsql_check_colocate(Query* query, RangeTblEntry* rte, void* plpgs
extern void plpgsql_HashTableDeleteAll();
extern void plpgsql_hashtable_delete_and_check_invalid_item(int classId, Oid objId);
extern void delete_package_and_check_invalid_item(Oid pkgOid);
extern void plpgsql_hashtable_clear_invalid_obj(bool need_clear = false);
extern void plpgsql_HashTableDelete(PLpgSQL_function* func);
extern bool plpgsql_get_current_value_stp_with_exception();
extern void plpgsql_restore_current_value_stp_with_exception(bool saved_current_stp_with_exception);
extern void plpgsql_set_current_value_stp_with_exception();
extern void delete_pkg_in_HashTable(Oid pkgOid);
extern PLpgSQL_package* plpgsql_pkg_compile(Oid pkgOid, bool for_validator, bool isSpec, bool isCreate=false);
extern PLpgSQL_package* plpgsql_pkg_compile(Oid pkgOid, bool for_validator, bool isSpec, bool isCreate=false, bool isRecompile = false);
extern PLpgSQL_datum* plpgsql_pkg_adddatum(const List* wholeName, char** objname, char** pkgname);
extern int plpgsql_pkg_adddatum2ns(const List* name);
extern bool plpgsql_check_insert_colocate(
@ -1823,7 +1915,7 @@ extern PLpgSQL_nsitem* plpgsql_ns_lookup(
extern PLpgSQL_nsitem* plpgsql_ns_lookup_label(PLpgSQL_nsitem* ns_cur, const char* name);
extern void free_func_tableof_index();
extern void free_temp_func_tableof_index(List* temp_tableof_index);
extern char* GetPackageSchemaName(Oid packageOid);
/* ----------
* Other functions in pl_funcs.c
@ -2008,4 +2100,13 @@ extern void stp_reserve_subxact_resowner(ResourceOwner resowner);
extern void stp_cleanup_subxact_resowner(int64 minStackId);
extern void stp_cleanup_subxact_resource(int64 stackId);
extern void InsertGsSource(Oid objId, Oid nspid, const char* name, const char* type, bool status);
extern void examine_parameter_list(List* parameters, Oid languageOid, const char* queryString,
oidvector** parameterTypes, TypeDependExtend** type_depend_extend, ArrayType** allParameterTypes,
ArrayType** parameterModes, ArrayType** parameterNames,
List** parameterDefaults, Oid* requiredResultType, List** defargpos, bool fenced, bool* has_undefined = NULL);
extern void compute_return_type(
TypeName* returnType, Oid languageOid, Oid* prorettype_p, bool* returnsSet_p, bool fenced, int startLineNumber,
TypeDependExtend* type_depend_extend, bool is_refresh_head);
void plpgsql_free_override_stack(int depth);
#endif /* PLPGSQL_H */

1
src/include/utils/sec_rls_utils.h
View File

@ -115,5 +115,6 @@ extern EnableRlsFeature CheckEnableRlsPolicies(const Relation relation, Oid role
extern SelectStmt* MakeRlsSelectStmtForCopyTo(const Relation relation, const CopyStmt* stmt);
extern void LicenseSupportRls();
extern void SupportRlsForRel(const Relation relation);
extern bool IsRlsFunction(Oid funcid);
#endif /* UTILS_SEC_RLS_UTILS_H */