| package integration |
| |
| import ( |
| "database/sql" |
| "os" |
| |
| "github.com/cloudberrydb/gp-common-go-libs/structmatcher" |
| "github.com/cloudberrydb/gp-common-go-libs/testhelper" |
| "github.com/cloudberrydb/gpbackup/backup" |
| "github.com/cloudberrydb/gpbackup/testutils" |
| |
| . "github.com/onsi/ginkgo/v2" |
| . "github.com/onsi/gomega" |
| ) |
| |
| var _ = Describe("backup integration create statement tests", func() { |
| BeforeEach(func() { |
| tocfile, backupfile = testutils.InitializeTestTOC(buffer, "predata") |
| }) |
| Describe("PrintExternalTableCreateStatement", func() { |
| var ( |
| extTable backup.ExternalTableDefinition |
| testTable backup.Table |
| ) |
| BeforeEach(func() { |
| extTable = backup.ExternalTableDefinition{Oid: 0, Type: 0, Protocol: backup.FILE, Location: sql.NullString{String: "file://tmp/ext_table_file", Valid: true}, |
| ExecLocation: "ALL_SEGMENTS", FormatType: "t", FormatOpts: "delimiter ' ' null '\\N' escape '\\'", |
| Command: "", RejectLimit: 0, RejectLimitType: "", ErrTableName: "", ErrTableSchema: "", Encoding: "UTF8", |
| Writable: false, URIs: []string{"file://tmp/ext_table_file"}} |
| testTable = backup.Table{ |
| Relation: backup.Relation{Schema: "public", Name: "testtable"}, |
| TableDefinition: backup.TableDefinition{IsExternal: true}, |
| } |
| _, _ = os.Create("/tmp/ext_table_file") |
| }) |
| AfterEach(func() { |
| _ = os.Remove("/tmp/ext_table_file") |
| testhelper.AssertQueryRuns(connectionPool, "DROP EXTERNAL TABLE public.testtable") |
| testhelper.AssertQueryRuns(connectionPool, "DROP TABLE IF EXISTS public.err_table") |
| testhelper.AssertQueryRuns(connectionPool, `DROP TABLE IF EXISTS public."err_table%percent"`) |
| }) |
| It("creates a READABLE EXTERNAL table", func() { |
| extTable.Type = backup.READABLE |
| extTable.Writable = false |
| extTable.LogErrors = true |
| extTable.RejectLimit = 2 |
| extTable.RejectLimitType = "r" |
| testTable.ExtTableDef = extTable |
| |
| backup.PrintExternalTableCreateStatement(backupfile, tocfile, testTable) |
| |
| testhelper.AssertQueryRuns(connectionPool, buffer.String()) |
| |
| oid := testutils.OidFromObjectName(connectionPool, "public", "testtable", backup.TYPE_RELATION) |
| resultTableDefs := backup.GetExternalTableDefinitions(connectionPool) |
| resultTableDef := resultTableDefs[oid] |
| resultTableDef.Type, resultTableDef.Protocol = backup.DetermineExternalTableCharacteristics(resultTableDef) |
| |
| structmatcher.ExpectStructsToMatchExcluding(&extTable, &resultTableDef, "Oid") |
| }) |
| It("creates a READABLE WEB EXTERNAL table with an EXECUTE statement containing special characters", func() { |
| extTable.Type = backup.READABLE_WEB |
| extTable.Writable = false |
| extTable.Location = sql.NullString{String: "", Valid: true} |
| extTable.Protocol = backup.HTTP |
| extTable.URIs = nil |
| extTable.Command = `bash % someone's \.custom_script.sh` |
| testTable.ExtTableDef = extTable |
| if true { |
| // The query for GPDB 7+ will have a NULL value instead of "" |
| extTable.Location.Valid = false |
| } |
| |
| backup.PrintExternalTableCreateStatement(backupfile, tocfile, testTable) |
| |
| testhelper.AssertQueryRuns(connectionPool, buffer.String()) |
| |
| oid := testutils.OidFromObjectName(connectionPool, "public", "testtable", backup.TYPE_RELATION) |
| resultTableDefs := backup.GetExternalTableDefinitions(connectionPool) |
| resultTableDef := resultTableDefs[oid] |
| resultTableDef.Type, resultTableDef.Protocol = backup.DetermineExternalTableCharacteristics(resultTableDef) |
| |
| structmatcher.ExpectStructsToMatchExcluding(&extTable, &resultTableDef, "Oid") |
| }) |
| It("creates a READABLE EXTERNAL table with CSV FORMAT options", func() { |
| extTable.Type = backup.READABLE |
| extTable.Writable = false |
| extTable.FormatType = "c" |
| extTable.FormatOpts = `delimiter '|' null '' escape ''' quote ''' force not null i` |
| testTable.ExtTableDef = extTable |
| |
| backup.PrintExternalTableCreateStatement(backupfile, tocfile, testTable) |
| |
| testhelper.AssertQueryRuns(connectionPool, buffer.String()) |
| |
| oid := testutils.OidFromObjectName(connectionPool, "public", "testtable", backup.TYPE_RELATION) |
| resultTableDefs := backup.GetExternalTableDefinitions(connectionPool) |
| resultTableDef := resultTableDefs[oid] |
| resultTableDef.Type, resultTableDef.Protocol = backup.DetermineExternalTableCharacteristics(resultTableDef) |
| |
| structmatcher.ExpectStructsToMatchExcluding(&extTable, &resultTableDef, "Oid") |
| }) |
| It("creates a READABLE EXTERNAL table with CUSTOM formatter", func() { |
| extTable.Type = backup.READABLE |
| extTable.Writable = false |
| extTable.FormatType = "b" |
| extTable.FormatOpts = "formatter 'fixedwidth_out' i '20' " |
| if true { |
| extTable.FormatOpts = "formatter 'fixedwidth_out'i '20'" |
| } |
| testTable.ExtTableDef = extTable |
| |
| backup.PrintExternalTableCreateStatement(backupfile, tocfile, testTable) |
| |
| testhelper.AssertQueryRuns(connectionPool, buffer.String()) |
| |
| oid := testutils.OidFromObjectName(connectionPool, "public", "testtable", backup.TYPE_RELATION) |
| resultTableDefs := backup.GetExternalTableDefinitions(connectionPool) |
| resultTableDef := resultTableDefs[oid] |
| resultTableDef.Type, resultTableDef.Protocol = backup.DetermineExternalTableCharacteristics(resultTableDef) |
| |
| structmatcher.ExpectStructsToMatchExcluding(&extTable, &resultTableDef, "Oid") |
| }) |
| It("creates a READABLE EXTERNAL table with LOG ERRORS INTO", func() { |
| testutils.SkipIfNot4(connectionPool) |
| extTable.Type = backup.READABLE |
| extTable.Writable = false |
| extTable.ErrTableName = `"err_table%percent"` |
| extTable.ErrTableSchema = "public" |
| extTable.RejectLimit = 2 |
| extTable.RejectLimitType = "r" |
| testTable.ExtTableDef = extTable |
| |
| backup.PrintExternalTableCreateStatement(backupfile, tocfile, testTable) |
| |
| testhelper.AssertQueryRuns(connectionPool, buffer.String()) |
| |
| oid := testutils.OidFromObjectName(connectionPool, "public", "testtable", backup.TYPE_RELATION) |
| resultTableDefs := backup.GetExternalTableDefinitions(connectionPool) |
| resultTableDef := resultTableDefs[oid] |
| resultTableDef.Type, resultTableDef.Protocol = backup.DetermineExternalTableCharacteristics(resultTableDef) |
| |
| structmatcher.ExpectStructsToMatchExcluding(&extTable, &resultTableDef, "Oid") |
| }) |
| It("creates a READABLE EXTERNAL table with FORMAT delimiter", func() { |
| extTable.Type = backup.READABLE |
| extTable.Writable = false |
| extTable.FormatOpts = "delimiter '%' null '' escape 'OFF'" |
| extTable.FormatType = "t" |
| testTable.ExtTableDef = extTable |
| |
| backup.PrintExternalTableCreateStatement(backupfile, tocfile, testTable) |
| |
| testhelper.AssertQueryRuns(connectionPool, buffer.String()) |
| |
| oid := testutils.OidFromObjectName(connectionPool, "public", "testtable", backup.TYPE_RELATION) |
| resultTableDefs := backup.GetExternalTableDefinitions(connectionPool) |
| resultTableDef := resultTableDefs[oid] |
| resultTableDef.Type, resultTableDef.Protocol = backup.DetermineExternalTableCharacteristics(resultTableDef) |
| |
| structmatcher.ExpectStructsToMatchExcluding(&extTable, &resultTableDef, "Oid") |
| }) |
| It("creates a WRITABLE EXTERNAL table", func() { |
| extTable.Type = backup.WRITABLE |
| extTable.Writable = true |
| extTable.Location = sql.NullString{String: "gpfdist://outputhost:8081/data1.out", Valid: true} |
| extTable.URIs = []string{"gpfdist://outputhost:8081/data1.out"} |
| extTable.Protocol = backup.GPFDIST |
| testTable.ExtTableDef = extTable |
| |
| backup.PrintExternalTableCreateStatement(backupfile, tocfile, testTable) |
| |
| testhelper.AssertQueryRuns(connectionPool, buffer.String()) |
| |
| oid := testutils.OidFromObjectName(connectionPool, "public", "testtable", backup.TYPE_RELATION) |
| resultTableDefs := backup.GetExternalTableDefinitions(connectionPool) |
| resultTableDef := resultTableDefs[oid] |
| resultTableDef.Type, resultTableDef.Protocol = backup.DetermineExternalTableCharacteristics(resultTableDef) |
| |
| structmatcher.ExpectStructsToMatchExcluding(&extTable, &resultTableDef, "Oid") |
| }) |
| }) |
| Describe("PrintCreateExternalProtocolStatement", func() { |
| protocolReadOnly := backup.ExternalProtocol{Oid: 1, Name: "s3_read", Owner: "testrole", Trusted: true, ReadFunction: 2, WriteFunction: 0, Validator: 0} |
| protocolWriteOnly := backup.ExternalProtocol{Oid: 1, Name: "s3_write", Owner: "testrole", Trusted: false, ReadFunction: 0, WriteFunction: 1, Validator: 0} |
| protocolReadWrite := backup.ExternalProtocol{Oid: 1, Name: "s3_read_write", Owner: "testrole", Trusted: false, ReadFunction: 2, WriteFunction: 1, Validator: 0} |
| emptyMetadata := backup.ObjectMetadata{} |
| funcInfoMap := map[uint32]backup.FunctionInfo{ |
| 1: {QualifiedName: "public.write_to_s3", Arguments: sql.NullString{String: "", Valid: true}, IsInternal: false}, |
| 2: {QualifiedName: "public.read_from_s3", Arguments: sql.NullString{String: "", Valid: true}, IsInternal: false}, |
| } |
| |
| It("creates a trusted protocol with a read function, privileges, and an owner", func() { |
| protoMetadata := backup.ObjectMetadata{Privileges: []backup.ACL{{Grantee: "testrole", Select: true, Insert: true}}, Owner: "testrole"} |
| |
| backup.PrintCreateExternalProtocolStatement(backupfile, tocfile, protocolReadOnly, funcInfoMap, protoMetadata) |
| |
| testhelper.AssertQueryRuns(connectionPool, "CREATE OR REPLACE FUNCTION public.read_from_s3() RETURNS integer AS '$libdir/gps3ext.so', 's3_import' LANGUAGE C STABLE;") |
| defer testhelper.AssertQueryRuns(connectionPool, "DROP FUNCTION public.read_from_s3()") |
| |
| testhelper.AssertQueryRuns(connectionPool, buffer.String()) |
| defer testhelper.AssertQueryRuns(connectionPool, "DROP PROTOCOL s3_read") |
| |
| resultExternalProtocols := backup.GetExternalProtocols(connectionPool) |
| |
| Expect(resultExternalProtocols).To(HaveLen(1)) |
| structmatcher.ExpectStructsToMatchExcluding(&protocolReadOnly, &resultExternalProtocols[0], "Oid", "ReadFunction", "FuncMap") |
| }) |
| It("creates a protocol with a write function", func() { |
| backup.PrintCreateExternalProtocolStatement(backupfile, tocfile, protocolWriteOnly, funcInfoMap, emptyMetadata) |
| |
| testhelper.AssertQueryRuns(connectionPool, "CREATE OR REPLACE FUNCTION public.write_to_s3() RETURNS integer AS '$libdir/gps3ext.so', 's3_export' LANGUAGE C STABLE;") |
| defer testhelper.AssertQueryRuns(connectionPool, "DROP FUNCTION public.write_to_s3()") |
| |
| testhelper.AssertQueryRuns(connectionPool, buffer.String()) |
| defer testhelper.AssertQueryRuns(connectionPool, "DROP PROTOCOL s3_write") |
| |
| resultExternalProtocols := backup.GetExternalProtocols(connectionPool) |
| |
| Expect(resultExternalProtocols).To(HaveLen(1)) |
| structmatcher.ExpectStructsToMatchExcluding(&protocolWriteOnly, &resultExternalProtocols[0], "Oid", "WriteFunction", "FuncMap") |
| }) |
| It("creates a protocol with a read and write function", func() { |
| backup.PrintCreateExternalProtocolStatement(backupfile, tocfile, protocolReadWrite, funcInfoMap, emptyMetadata) |
| |
| testhelper.AssertQueryRuns(connectionPool, "CREATE OR REPLACE FUNCTION public.read_from_s3() RETURNS integer AS '$libdir/gps3ext.so', 's3_import' LANGUAGE C STABLE;") |
| defer testhelper.AssertQueryRuns(connectionPool, "DROP FUNCTION public.read_from_s3()") |
| |
| testhelper.AssertQueryRuns(connectionPool, "CREATE OR REPLACE FUNCTION public.write_to_s3() RETURNS integer AS '$libdir/gps3ext.so', 's3_export' LANGUAGE C STABLE;") |
| defer testhelper.AssertQueryRuns(connectionPool, "DROP FUNCTION public.write_to_s3()") |
| |
| testhelper.AssertQueryRuns(connectionPool, buffer.String()) |
| defer testhelper.AssertQueryRuns(connectionPool, "DROP PROTOCOL s3_read_write") |
| |
| resultExternalProtocols := backup.GetExternalProtocols(connectionPool) |
| |
| Expect(resultExternalProtocols).To(HaveLen(1)) |
| structmatcher.ExpectStructsToMatchExcluding(&protocolReadWrite, &resultExternalProtocols[0], "Oid", "ReadFunction", "WriteFunction", "FuncMap") |
| }) |
| }) |
| Describe("PrintExchangeExternalPartitionStatements", func() { |
| tables := []backup.Table{ |
| {Relation: backup.Relation{Oid: 1, Schema: "public", Name: "part_tbl_ext_part_"}}, |
| {Relation: backup.Relation{Oid: 2, Schema: "public", Name: "part_tbl"}}, |
| } |
| emptyPartInfoMap := make(map[uint32]backup.PartitionInfo) |
| BeforeEach(func() { |
| // For GPDB 7+, external partitions will have their own ATTACH PARTITION DDL commands. |
| if true { |
| Skip("Test is not applicable to GPDB 7+") |
| } |
| }) |
| AfterEach(func() { |
| testhelper.AssertQueryRuns(connectionPool, "DROP TABLE public.part_tbl") |
| }) |
| It("writes an alter statement for a named list partition", func() { |
| externalPartition := backup.PartitionInfo{ |
| PartitionRuleOid: 1, |
| PartitionParentRuleOid: 0, |
| ParentRelationOid: 2, |
| ParentSchema: "public", |
| ParentRelationName: "part_tbl", |
| RelationOid: 1, |
| PartitionName: "girls", |
| PartitionRank: 0, |
| IsExternal: true, |
| } |
| testhelper.AssertQueryRuns(connectionPool, ` |
| CREATE TABLE public.part_tbl (id int, gender char(1)) |
| DISTRIBUTED BY (id) |
| PARTITION BY LIST (gender) |
| ( PARTITION girls VALUES ('F'), |
| PARTITION boys VALUES ('M'), |
| DEFAULT PARTITION other );`) |
| testhelper.AssertQueryRuns(connectionPool, ` |
| CREATE EXTERNAL WEB TABLE public.part_tbl_ext_part_ (like public.part_tbl_1_prt_girls) |
| EXECUTE 'echo -e "2\n1"' on host |
| FORMAT 'csv';`) |
| externalPartitions := []backup.PartitionInfo{externalPartition} |
| |
| backup.PrintExchangeExternalPartitionStatements(backupfile, tocfile, externalPartitions, emptyPartInfoMap, tables) |
| testhelper.AssertQueryRuns(connectionPool, buffer.String()) |
| |
| resultExtPartitions, resultPartInfoMap := backup.GetExternalPartitionInfo(connectionPool) |
| Expect(resultExtPartitions).To(HaveLen(1)) |
| Expect(resultPartInfoMap).To(HaveLen(3)) |
| structmatcher.ExpectStructsToMatchExcluding(&externalPartition, &resultExtPartitions[0], "PartitionRuleOid", "RelationOid", "ParentRelationOid") |
| }) |
| It("writes an alter statement for an unnamed range partition", func() { |
| externalPartition := backup.PartitionInfo{ |
| PartitionRuleOid: 1, |
| PartitionParentRuleOid: 0, |
| ParentRelationOid: 2, |
| ParentSchema: "public", |
| ParentRelationName: "part_tbl", |
| RelationOid: 1, |
| PartitionName: "", |
| PartitionRank: 1, |
| IsExternal: true, |
| } |
| testhelper.AssertQueryRuns(connectionPool, ` |
| CREATE TABLE public.part_tbl (a int) |
| DISTRIBUTED BY (a) |
| PARTITION BY RANGE (a) |
| (start(1) end(3) every(1));`) |
| testhelper.AssertQueryRuns(connectionPool, ` |
| CREATE EXTERNAL WEB TABLE public.part_tbl_ext_part_ (like public.part_tbl_1_prt_1) |
| EXECUTE 'echo -e "2\n1"' on host |
| FORMAT 'csv';`) |
| externalPartitions := []backup.PartitionInfo{externalPartition} |
| |
| backup.PrintExchangeExternalPartitionStatements(backupfile, tocfile, externalPartitions, emptyPartInfoMap, tables) |
| testhelper.AssertQueryRuns(connectionPool, buffer.String()) |
| |
| resultExtPartitions, resultPartInfoMap := backup.GetExternalPartitionInfo(connectionPool) |
| Expect(resultExtPartitions).To(HaveLen(1)) |
| Expect(resultPartInfoMap).To(HaveLen(2)) |
| structmatcher.ExpectStructsToMatchExcluding(&externalPartition, &resultExtPartitions[0], "PartitionRuleOid", "RelationOid", "ParentRelationOid") |
| }) |
| It("writes an alter statement for a two level partition", func() { |
| testutils.SkipIfBefore5(connectionPool) |
| externalPartition := backup.PartitionInfo{ |
| PartitionRuleOid: 10, |
| PartitionParentRuleOid: 11, |
| ParentRelationOid: 2, |
| ParentSchema: "public", |
| ParentRelationName: "part_tbl", |
| RelationOid: 1, |
| PartitionName: "apj", |
| PartitionRank: 0, |
| IsExternal: true, |
| } |
| externalPartitionParent := backup.PartitionInfo{ |
| PartitionRuleOid: 11, |
| PartitionParentRuleOid: 0, |
| ParentRelationOid: 2, |
| ParentSchema: "public", |
| ParentRelationName: "part_tbl", |
| RelationOid: 0, |
| PartitionName: "Dec16", |
| PartitionRank: 0, |
| IsExternal: false, |
| } |
| testhelper.AssertQueryRuns(connectionPool, ` |
| CREATE TABLE public.part_tbl (a int,b date,c text,d int) |
| DISTRIBUTED BY (a) |
| PARTITION BY RANGE (b) |
| SUBPARTITION BY LIST (c) |
| SUBPARTITION TEMPLATE |
| (SUBPARTITION usa values ('usa'), |
| SUBPARTITION apj values ('apj'), |
| SUBPARTITION eur values ('eur')) |
| ( PARTITION Sep16 START (date '2016-09-01') INCLUSIVE , |
| PARTITION Oct16 START (date '2016-10-01') INCLUSIVE , |
| PARTITION Nov16 START (date '2016-11-01') INCLUSIVE , |
| PARTITION Dec16 START (date '2016-12-01') INCLUSIVE |
| END (date '2017-01-01') EXCLUSIVE); |
| `) |
| |
| testhelper.AssertQueryRuns(connectionPool, `CREATE EXTERNAL TABLE public.part_tbl_ext_part_ (a int,b date,c text,d int) LOCATION ('gpfdist://127.0.0.1/apj') FORMAT 'text';`) |
| partInfoMap := map[uint32]backup.PartitionInfo{externalPartitionParent.PartitionRuleOid: externalPartitionParent} |
| externalPartitions := []backup.PartitionInfo{externalPartition} |
| |
| backup.PrintExchangeExternalPartitionStatements(backupfile, tocfile, externalPartitions, partInfoMap, tables) |
| testhelper.AssertQueryRuns(connectionPool, buffer.String()) |
| |
| resultExtPartitions, _ := backup.GetExternalPartitionInfo(connectionPool) |
| externalPartition.RelationOid = testutils.OidFromObjectName(connectionPool, "public", "part_tbl_1_prt_dec16_2_prt_apj", backup.TYPE_RELATION) |
| Expect(resultExtPartitions).To(HaveLen(1)) |
| structmatcher.ExpectStructsToMatchExcluding(&externalPartition, &resultExtPartitions[0], "PartitionRuleOid", "PartitionParentRuleOid", "ParentRelationOid") |
| }) |
| It("writes an alter statement for a three level partition", func() { |
| testutils.SkipIfBefore5(connectionPool) |
| externalPartition := backup.PartitionInfo{ |
| PartitionRuleOid: 10, |
| PartitionParentRuleOid: 11, |
| ParentRelationOid: 2, |
| ParentSchema: "public", |
| ParentRelationName: "part_tbl", |
| RelationOid: 1, |
| PartitionName: "europe", |
| PartitionRank: 0, |
| IsExternal: true, |
| } |
| externalPartitionParent1 := backup.PartitionInfo{ |
| PartitionRuleOid: 11, |
| PartitionParentRuleOid: 12, |
| ParentRelationOid: 2, |
| ParentSchema: "public", |
| ParentRelationName: "part_tbl", |
| RelationOid: 0, |
| PartitionName: "", |
| PartitionRank: 1, |
| IsExternal: false, |
| } |
| externalPartitionParent2 := backup.PartitionInfo{ |
| PartitionRuleOid: 12, |
| PartitionParentRuleOid: 0, |
| ParentRelationOid: 2, |
| ParentSchema: "public", |
| ParentRelationName: "part_tbl", |
| RelationOid: 0, |
| PartitionName: "", |
| PartitionRank: 3, |
| IsExternal: false, |
| } |
| testhelper.AssertQueryRuns(connectionPool, ` |
| CREATE TABLE public.part_tbl (id int, year int, month int, day int, region text) |
| DISTRIBUTED BY (id) |
| PARTITION BY RANGE (year) |
| SUBPARTITION BY RANGE (month) |
| SUBPARTITION TEMPLATE ( |
| START (1) END (4) EVERY (1) ) |
| SUBPARTITION BY LIST (region) |
| SUBPARTITION TEMPLATE ( |
| SUBPARTITION usa VALUES ('usa'), |
| SUBPARTITION europe VALUES ('europe'), |
| SUBPARTITION asia VALUES ('asia') |
| ) |
| ( START (2002) END (2005) EVERY (1)); |
| `) |
| |
| testhelper.AssertQueryRuns(connectionPool, `CREATE EXTERNAL TABLE public.part_tbl_ext_part_ (like public.part_tbl_1_prt_3_2_prt_1_3_prt_europe) LOCATION ('gpfdist://127.0.0.1/apj') FORMAT 'text';`) |
| partInfoMap := map[uint32]backup.PartitionInfo{externalPartitionParent1.PartitionRuleOid: externalPartitionParent1, externalPartitionParent2.PartitionRuleOid: externalPartitionParent2} |
| externalPartitions := []backup.PartitionInfo{externalPartition} |
| |
| backup.PrintExchangeExternalPartitionStatements(backupfile, tocfile, externalPartitions, partInfoMap, tables) |
| testhelper.AssertQueryRuns(connectionPool, buffer.String()) |
| |
| resultExtPartitions, _ := backup.GetExternalPartitionInfo(connectionPool) |
| externalPartition.RelationOid = testutils.OidFromObjectName(connectionPool, "public", "part_tbl_1_prt_3_2_prt_1_3_prt_europe", backup.TYPE_RELATION) |
| Expect(resultExtPartitions).To(HaveLen(1)) |
| structmatcher.ExpectStructsToMatchExcluding(&externalPartition, &resultExtPartitions[0], "PartitionRuleOid", "PartitionParentRuleOid", "ParentRelationOid") |
| }) |
| }) |
| }) |
