Evaluation of existential and universal subquery in a relational database management system for increased efficiency5864840Abstract A relational data base management system includes a query processor that permits consideration of alternative query plans by the query optimizer so one table can be sent to a selected network location for subquery evaluation in consideration of maximum processing efficiency. Subqueries are converted from "predicate push-down" form to scalar subqueries, enabling upper tables to be sent to nodes of lower tables and vice versa, thereby permitting selection of the node direction depending on the least cost alternative. The optimizer of the query processor is presented with rewritten query code that permits more than one alternative for sending tables for evaluation. The optimizer evaluates the alternatives permitted by the rewritten code, determines the optimal plan for each alternative, and selects the least-cost plan from among the plans evaluated. Thus, the optimizer can decide to send an outer table to where a subquery table is located, or can decide to send a subquery table to where an outer table is located, depending on which is more efficient. Claims We claim: Description BACKGROUND OF THE INVENTION
______________________________________
Query 1
______________________________________
SELECT *
FROM T
WHERE
. . . (T.C1 IN (SELECT S.C1 FROM S WHERE T.C2=S.C2)) . . .
______________________________________
Without loss of generality, it is assumed that all NOT operators in the WHERE clause have pushed down using well-known techniques in this example as well as in all other examples used in the preferred embodiment. This query (Query 1) calls for selection of all tuples from the table T where the first column in table T (T.C1) matches the first column in table S (SELECT S.C1 FROM S) for those rows in which the second column in table T matches the second column in table S (WHERE T.C2=S.C2). The parenthetical clause in the last line of Query 1 is known as a correlated subquery. A possible execution plan for Query 1 may be given by the following pseudo-code table:
______________________________________
Pseudo Code Table 1
______________________________________
In each table T partition;
For each tuple in each table T partition, send the correlation
value (T.C2) to the processors where table S resides and
evaluate the subquery "SELECT S.C1 FROM S
WHERE T.C2=S.C2" remotely (that is, send table T
tuples to the nodes where the table S tuples reside),
Upon receiving a set of rows from the processors where the
table S resides and the subquery "SELECT S.C1 FROM
S WHERE T.C2=S.C2" is evaluated, the subquery
predicate is evaluated if T.C1 matches any of the rows
received via evaluating the subquery condition
"T.C1=S.C1". If there is a match, the table T tuple is
returned to the user.
______________________________________
The evaluation of the subquery above may involve scanning a partition of table S via an index or via a table scan. The result of the subquery evaluation, (S.C1), is a set of rows, and is returned to the originator of the correlation value. Thus, the table T tuples are sent to the nodes where the table S tuples are stored, for evaluation of the subquery. The potential inefficiency of this conventional SQL processing may be illustrated by considering the case where the table S is much smaller than the table T. The table T tuples will be sent to the locations of the table S tuples, because the table T tuples are the outer table and the table S tuples are the lower table. So table T is potentially sent tuple by tuple, with comparisons performed at many different nodes, even though it would undoubtedly be more efficient for table S to be sent to the relatively fewer number of nodes for table T, where the requisite comparisons would be performed. From the discussion above, it should be apparent that there is a need for a relational database management system that efficiently evaluates complex subquery statements. The present invention fulfills this need. SUMMARY OF THE INVENTION The present invention provides efficient subquery evaluation in a relational database management system by permitting the query processor to consider alternative query plans before selecting where to send one table to another for subquery evaluation. More particularly, the optimizer of a query processor is enabled for considering more than one alternative for sending tables for evaluation. In accordance with standard system evaluation routines, the optimizer evaluates the alternative execution plans, determines the optimal plan for each alternative, and selects the least-cost plan from among the plans evaluated. In this way, the optimizer can decide to send an outer table to where a subquery table is located, or can decide to send a subquery table to where an outer table is located, depending on which is more efficient. This increases subquery evaluation efficiency. In another aspect of the invention, the query processor performs a predicate push-down operation to convert an existential or universal subquery, such as subqueries having either "=ANY" or "=ALL", respectively, using an EXISTS predicate. A subquery with an EXISTS predicate can be evaluated more efficiently than the subquery in the original form, especially in the MPP environment, because: (1) the EXISTS predicate does not require returning any user data values and thus it is sufficient to return an indicator of a tuple existence from the subquery, thereby reducing the communication overhead; and (2) the subquery need not return multiple tuple existence indicators when there are multiple matches because the EXISTS predicate is insensitive to duplicates, and thus the subquery can return only one tuple existence indicator when there are multiple matches. As soon as there is a match, the subquery can return a tuple indicator and stop the current subquery evaluation. Hence, an early-out capability is exploited. To permit considering different alternatives of tuple sending for processing, the query processor can transform the converted query into what is known as a scalar subquery, taking advantage of the fact that a scalar subquery can be processed like a join operation. To perform these tasks, the query processor operates specially on two types of subqueries. The first type of subquery is the "existential" subquery having predicate quantifiers such as "IN" and "=ANY". In such a case, the query processor pushes the subquery predicate from the query down to the subquery level, resulting in an EXISTS predicate, and then transforms the existential subquery into a scalar subquery, thereby generating table-sending alternatives. The rewritten and transformed subquery is provided to the query optimizer for selection from among the alternatives. The second type of subquery specially processed by the query processor is the "universal" subquery having predicate quantifiers such as "=ALL". For such a universal subquery, the query processor pushes the subquery predicate down to the subquery level resulting in a "NOT EXISTS" predicate, and then transforms the universal subquery into a scalar subquery, thereby generating table-sending alternatives. In all cases, the optimizer advantageously considers the scalar subqueries and is then free to select the most efficient query plan for execution. Other features and advantages of the present invention should be apparent from the following description of the preferred embodiment, which illustrates, by way of example, the principles of the invention. BRIEF DESCRIPTION OF THE DRAWINGS FIG. 1 is a representation of a computer network system constructed in accordance with the present invention. FIG. 2 is a representation of a computer processing system at a node of the FIG. 1 network that implements a relational data base management system in accordance with the present invention. FIG. 3 is a flow diagram that illustrates the processing steps executed by the computer processing system of FIG. 2 to interpret and execute an SQL statement in an interactive environment. FIG. 4 is a flow diagram that illustrates the processing steps executed by the computer processing system of FIG. 2 to interpret and execute an SQL statement embedded in source code. FIG. 5 is a flow diagram that illustrates the processing steps executed by the computer processing system of FIG. 2 to optimize the SQL query in accordance with either the FIG. 3 interactive processing or the FIG. 4 batch processing. DESCRIPTION OF THE PREFERRED EMBODIMENTS FIG. 1 illustrates an exemplary computing system 10 constructed in accordance with the present invention. The system includes multiple computers, two of which 12, 14 are shown, connected to a communication network 16 in a massively parallel processing (MPP) shared-nothing configuration. Each of the computers 12, 14 has a similar construction, so that details described with respect to one computer will be understood to apply to all computers of the system. Each computer includes a central processing unit (CPU) 18, an operating main memory 20, and a local direct access storage device (DASD) 22, such as a disk drive. Each computer communicates with the others via the network 16, thereby comprising a network node. The DASD units 22 of each computer contain table data that comprises a relational database management system (RDBMS). An application program provides an RDBMS interface to the users and can reside in each computer 12, 14 or can be installed on a single file server computer of the network. In either case, data files of the RDBMS are distributed across the DASD units of the network. Thus, a Table X of the RDBMS shown in FIG. 1 having multiple rows is stored across the computers of the network 16 such that rows 1 through i, for example, are stored in DASD of the first computer 12, rows j through k are stored in DASD of the second computer 14, and the remaining rows are stored in other computers (not illustrated). In this way, each table is stored across a set of the network nodes. In the preferred embodiment, the RDBMS interface comprises an SQL system stored in operating memory 20 of each machine. A user at a computer of the network 16 can pose a query for solution by an SQL query processor of the RDBMS. In the "DB2 Common Server Version 2" product from International Business Machines (IBM) Corporation, scalar subqueries are treated as derived tables allowing them to appear as operands of joins. Such derived tables return either a null-valued tuple when the computation of the subquery results in an empty answer set or one tuple, which is the computation result of the subquery. In accordance with the invention, subqueries can be converted into a scalar subquery and hence, for the rewritten SQL code, the query processor can consider alternatives wherein the main query tables are sent to the nodes where subquery tables reside, or vice versa. The query optimizer evaluates the table sending alternatives permitted by the rewritten SQL code by determining their resource cost, determines the optimal plan for each alternative, and selects the least-cost plan from the plans evaluated. In this way, the optimizer can decide to send an outer table to the node where a subquery inner table is located, or can decide to send a subquery table to where an outer table is located, depending on which is more efficient. Without the techniques in the present invention, the query optimizer is restricted to sending tuples from the outer table to the subquery tables. a. Network Configuration Each computer CPU 18 performs its functions by executing instructions stored in the operating memory 20. The instructions can be received through an optional storage drive 24 or through an interface with the network 16. The storage drive permits a program product storage device 26 to be received and for program steps recorded on the program product storage device to be read and transferred into the operating memory 20. In this way, the processing steps necessary for operation in accordance with the invention can be embodied on a program product. Those skilled in the art will appreciate that the program products can comprise machine-readable storage devices 26 such as magnetic media disks on which are recorded program instructions whose execution implements the RDBMS of the present invention. The storage devices 26 also can comprise, for example, media such as optical disks and other machine-readable storage devices. Other suitable program product storage devices can include magnetic tape and semiconductor memory. Alternatively, the program steps can be received into the operating memory 20 from the DASD 22, or over the network 16. In the latter method, the computer system also includes a network interface 28 that permits communication between the CPU 18 at the first node 12 and other computer systems 14 over the network 16. In that way, the computer system 12 can receive data into the main memory 20 through the interface 28 after network communication has been established by well-known methods that will be understood by those skilled in the art without further explanation. b. RDBMS Configuration FIG. 2 illustrates a computer environment at a node 12 (see FIG. 1) of the exemplary RDBMS computing system. In the exemplary computer environment, a computer system 102 at the node accesses network data storage devices, such as disk drives, in which are stored user and system tables 104 and log data tables 106. An operator of the computer system 102 uses a standard operator terminal interface 108, such as one of the interfaces known as IMS/DB/DC, CICS, TSO, OS/2, or some other appropriate interface, to transmit electrical signals to and from the computer system that represent commands for performing various search and retrieval functions against the databases 104, 106. The commands are viewed on a visual monitor 109. These search and retrieval functions are generally referred to as queries. In the preferred embodiment of the present invention, these queries conform to the SQL standard interface, and invoke functions performed by RDBMS software. In the preferred embodiment of the present invention, the RDBMS software comprises the "DB2" product offered by the IBM Corporation for the "MVS", "AIX", or "OS/2" operating systems. Such software generally resides in memory of network-based computers. Those skilled in the art will recognize that the present invention has application to any RDBMS software that uses SQL, and may similarly be applied to non-SQL queries. As illustrated in FIG. 2, the DB2 product architecture for the MVS operating system includes three major components: the Resource Lock Manager ("RLM") 110, the System Services module 112, and the Database Services module 114. The RLM handles locking services, because DB2 treats data as a shared resource, thereby allowing any number of users to access the same data simultaneously, and thus concurrency control is required to isolate users and to maintain data integrity. The Systems Services module 112 controls the overall DB2 execution environment, including managing the log data sets 106, gathering system statistics, handling startup and shutdown operations, and providing management support. At the center of the DB2 product architecture is the Database Services Processor module 114. The Database Services Processor module contains several submodules, including the Relational Database System (RDS) 116, the Data Manager 118, the Buffer Manager 120, and other database components 122, including an SQL compiler/interpreter. These submodules support the functions of the SQL language, such as definitions, access control, retrieval, and update of user and system data. The Database Services Processor module 114 preferably comprises one or more processors that execute a series of computer-executable programming instructions. These programming instructions preferably reside in storage locations such as fast-access memory 20 (see FIG. 1) of the computer 102. Alternatively, the instructions may be stored on a computer diskette 26 (FIG. 1), direct access storage device, magnetic tape, conventional "hard drive", electronic read-only memory, optical storage device, paper punch cards, or another suitable data storage medium containing logically segmented storage locations. As noted above, and in accordance with the present invention, the SQL query processor component of the RDBMS will respond to submission of a user query by providing the SQL optimizer with rewritten SQL code that permits selecting from multiple execution plans to send query tuples to more than one alternative node for evaluation. After the optimizer receives the rewritten SQL code, conventional optimizer selection techniques can be applied to select the most efficient alternative. That is, an SQL optimizer is conventionally provided with system information such as the location of tables and parts of tables, the size of such tables, network node locations, system operating characteristics and statistics, and the like. In the preferred embodiment, such query processing can take place in either an interactive operating mode or in a batch processing mode, both of which will be described next. c. Interactive SQL Execution FIG. 3 is a flow diagram that illustrates the operating steps necessary for the interpretation and execution of SQL statements in an interactive network environment such as shown in FIG. 1, in accordance with the present invention. These steps are implemented as computer program steps stored in one of the network computers 12, 14. The first flow diagram box of FIG. 3, numbered 302, represents the input of an SQL statement into the computer system from the user. The next flow diagram box 304 of FIG. 3 represents the step of compiling or interpreting the received SQL statement. In the preferred embodiment, this step includes an optimization function that rewrites and transforms the SQL query in a manner described in greater detail below. The FIG. 3 flow diagram box numbered 306 represents the step of generating a compiled set of runtime structures called an application plan from the compiled SQL statements. Generally, the SQL statements received as input from the user (step 302) specify the data the user wants, in the form of a query, but do not specify how to get it. The application plan represents the computer-generated sequence of operations to obtain the data specified by the user query. Generation of the application plan involves consideration of both the available access paths (indexes, sequential reads, etc.) and system held statistics on the data to be accessed (the size of the table, the number of distinct values in a particular column, etc.), to choose what the RDBMS processor considers to be the most efficient access path for the query. The selection of the most efficient access path utilizes query, database, and system information that is conventionally available to SQL optimizers. The FIG. 3 flow diagram box numbered 308 represents the execution of the application plan. The last block 310 in FIG. 3 represents the output of the results of the application plan to the user. d. Embedded/Batch SQL Execution FIG. 4 is a flow diagram that illustrates the steps necessary for the interpretation and execution of SQL statements embedded in source code for batch operation according to the present invention. The first block 402 represents program source code containing a host language (such as COBOL or C) and embedded SQL statements that is received by the RDBMS processor for batch processing. The received program source code is next subjected to a pre-compile step 404. There are two types of output code from the pre-compile step 404: a modified SQL source module 406 and a Database Request Module ("DBRM") 408. The modified SQL source module 406 contains host language calls to the DB2 program, which the pre-compile step 404 inserts into the pre-compile output code in place of the SQL source statements. The other output of the pre-compile step, the DBRM 408, consists of the SQL statements from the program source code 402. After the modified source 406 is produced, a compile and link-edit step 410 uses the modified source output to produce a load module 412, while an optimize and bind step 414 uses the DBRM output 408 to produce a compiled set of runtime structures for the application plan 416. As indicated above in conjunction with the description of FIG. 3, the SQL statements from the program source code 402 specify only the data that the user wants, but not how to get to it. In the preferred embodiment, the optimize and bind step 414 optimizes the SQL query in a manner described in greater detail below. The optimize and bind step then considers both the available access paths (indexes, sequential reads, etc.) and system held statistics on the data to be accessed (the size of the table, the number of distinct values in a particular column, etc.), to choose what it considers to be the most efficient access path for the query. The load module 412 and application plan 416 are then executed together at the last step, represented by the flow diagram box numbered 418. e. Optimization in Accordance With the Invention In accordance with the invention, the RDBMS processor (FIG. 2) processes existential subqueries and universal subqueries so as to convert the respective subqueries into scalar subqueries and permit the RDBMS optimizer to choose which table will be sent to which node for evaluation. In this way, selection of the least cost execution plan for evaluation is assured. In another aspect of the invention, the RDBMS processor converts a universal subquery into a scalar subquery by determining whether the predicate being pushed down in nullable or not nullable, as explained below. FIG. 5 is a flow diagram that represents the predicate pushdown processing steps performed by the SQL processor of the invention. In particular, FIG. 5 represents the processing steps performed in the optimization step of FIG. 3 (box 304) and of FIG. 4 (414). In the first step of FIG. 5, illustrated by the flow diagram box numbered 502, the query is translated into one or more query blocks having representations of queries and subqueries. In this step, the processor may also identify existential subqueries and universal subqueries for processing, as described in greater detail below. The flow diagram box numbered 504 represents the operation of pushing the predicate down to the subquery level. An "early out" processing step is performed next, as indicated by the flow diagram box numbered 505. This step, described further below, checks for the first match with an "exists" predicate, whereupon an "early out" indicator is returned so that further match checking can be halted. The result of the early out processing step is returned to both a conversion step (box 506) and an optimizer selection step (box 510). The processing step represented by the box numbered 506 converts the subquery with pushed predicate to a scalar subquery, thereby producing a subquery that permits table-sending alternatives during optimization. At the box numbered 508, the processor provides the rewritten SQL query, with the table-sending alternatives, to the processor optimizer. At the flow diagram box numbered 510, the optimizer receives an early out indication if an "exists" predicate match was found and also receives the rewritten scalar subquery, and then selects the most efficient (least cost) of these alternative query plans for execution. The SQL processor then continues operation. The processing illustrated in FIG. 5 is performed on queries relating to existential operators and queries relating to universal queries, as described further below. i. The existential subquery An existential query is a query that inquires whether a specified data arrangement exists within the database. The invention permits conversion of such a query into two converted forms, after which the optimizer can make a decision as to which is more efficient in terms of table-sending alternatives. In particular, the preferred embodiment of the present invention operates on a SELECT query to push down predicates, following the user input step described above in conjunction with FIGS. 3 and 4. For example, consider again the SQL query from above called "Query 1" as a user-provided input:
______________________________________
Query 1
______________________________________
SELECT *
FROM T
WHERE
. . . (T.C1 IN (SELECT S.C1 FROM S WHERE T.C2=S.C2)) . .
______________________________________
.;
The conversion to scalar subquery in accordance with the invention first "pushes" the subquery condition to the next level, as follows:
______________________________________
Converted Query 1 Following Predicate Push-Down
______________________________________
SELECT *
FROM T
WHERE
. . . (EXISTS (SELECT 1
FROM S
WHERE T.C2=S.C2 AND T.C1=S.C1)). . .;
______________________________________
For the subquery predicate T.C1=S.C1 (table T is sent to table S, tested for whether the first column of T is the same as the first column of S), if the original query returns a non-null S.C1 column entry, then the EXISTS predicate is true, else it is false. If the subquery returns one or more null S.C1 column entries, then the EXISTS predicate is false, and if the subquery returns the empty set, then the EXISTS predicate also is false. Notice that the opposite subquery is not equivalent: for S.C1=T.C1 (table S sent to table T): if S.C1=T.C1 returns a non-null, then the EXISTS predicate is true; if the equivalency returns an empty set, then the EXISTS predicate is false. The above converted query is more efficient to evaluate than Query 1, especially in the MPP environment, because the subquery need not return column values (S.C1 in Query 1) to the main query for the subquery predicate evaluation. For the EXISTS predicate in the preferred embodiment, a tuple existence indicator is optionally returned by the subquery as soon as there is a match, and thus less communication overhead is incurred. Furthermore, because the EXISTS predicate is insensitive to duplicates, the subquery can return only one tuple existence indicator even when there are multiple matches, and thus the subquery processing can terminate upon finding the first match. That is, as soon as there is a match and the EXISTS predicate is shown to be true, no further processing for the EXISTS predicate need be performed. This is the processing represented by the FIG. 5 flow diagram box numbered 505. In this way, the query processor provides an early-out capability for more efficient operation. It should be noted that the processing of box 505 is performed and results are provided to the optimizer (at box 510) with (boxes 506, 508) and without the conversion of the subquery to a scalar subquery. The optimizer thereby has a plurality of query plan alternatives from which to choose, and will therefore process queries with greater efficiency. The second processing step in accordance with the present invention for converting to a scalar subquery results in the following:
______________________________________
Converted Query 1 After Scalar Subquery Transformation
______________________________________
SELECT *
FROM T
WHERE
. . . (1 = (SELECT DISTINCT 1
FROM S
WHERE T.C2=S.C2 AND T.C1=S.C1)). . .;
______________________________________
In the "Converted Query 1 Following Predicate Push-Down" query above, the query is in the form of a counting quantifier predicate. As a result, the SQL optimizer has potentially many restrictions as to when it can apply the subquery, which usually is applied as soon as possible. A typical execution plan for this type of converted subquery is to send T tuples, one at a time, to the S sites. Each S site will return either a "1" or a null, and the originator node of the T tuple will collect all returned results and apply the subquery predicate. Under such a scenario, the optimizer will be unable to generate an execution plan that sends S tuples to the T sites for execution. The invention recognizes the more efficient possibilities presented by making the second conversion shown above. In the "Converted Query 1 After Scalar Subquery Transformation" query above, the SQL optimizer can send T tuples to S table sites for execution or can send S tuples to T table sites for execution. The optimizer of the preferred embodiment will determine if the T table is a very large table compared with the S table, and in response will send the S tuples to the T table sites for execution, gaining greater efficiency. If the optimizer determines that the S table is very large compared to the T table, then it will respond by sending the T tuples to the S table sites for execution. This processing is represented by the flow diagram box numbered 510. As noted, the first conversion step in evaluating a query is generally referred to as pushing the predicate condition down to a lower subquery, and the second step is a transformation of the query into a scalar subquery. In general then, the processing represented by the FIG. 5 processing is to perform predicate pushdown processing (the FIG. 5 flow diagram box numbered 504) and then to transform to a scalar subquery (flow diagram box numbered 506). These operations may be summarized follows, beginning with being applied to a source existential query that has the form:
______________________________________
Existential Subquery Source
______________________________________
SELECT *
FROM T1 Q1
WHERE
. . . C1 relop (SELECT C1
FROM T2 Q2
WHERE Q1.C2 = Q2.C2)). . .;
______________________________________
where "relop" is a relational operator, such as EQUAL, NOT EQUAL, LESS THAN, GREATER THAN, LESS THAN/EQUAL, GREATER THAN/EQUAL, where T1 and T2 represent database tables, and where C1 and C2 represent respective columns of those tables. After predicate pushdown (box 504), the converted query is:
______________________________________
Converted Existential Ouery After Predicate Push-Down
______________________________________
SELECT *
FROM T1 Q1
WHERE
. . . (EXISTS (SELECT 1
FROM T2 Q2
WHERE Q1.C2 = Q2.C2 AND Q1.C1 relop Q2.C1)). . .;
______________________________________
where "relop", T1, T2, C1, and C2 are as defined above. After predicate pushdown, the converted query is subjected to a transformation processing in accordance with the invention (box 506), which produces a scalar query as follows, such that table-sending alternatives may be considered by the SQL optimizer:
______________________________________
Converted Existential Query After Scalar Transformation
______________________________________
SELECT *
FROM T1 Q1
WHERE
. . . (1 = (SELECT DISTINCT 1
FROM T2 Q2
WHERE Q1.C2 = Q2.C2 AND Q1.C1 relop Q2.C1)). . .;
______________________________________
The query expressions above are general expressions for the existential query conversion processing performed by the SQL processor of the preferred embodiment. Note that the above transformations can be done independently of any predicate in the subquery ("Q1.C2=Q2.C2" in the above example). ii. The universal subquery A universal subquery is a subquery that involves a quantified predicate, such as "ALL", that compares a data value against all rows produced by a subquery. For example, consider the universal subquery illustrated in Query 2 as follows:
______________________________________
Query 2
______________________________________
SELECT *
FROM T
WHERE
. . . (T.C1=ALL (SELECT C1 FROM S WHERE T.C2=S.C2)). . .;
______________________________________
In Query 2, the value of column C1 of each row in Table T is compared against each corresponding row produced from the SELECT clause, and a single value is returned that describes the result of the entire set of comparisons. That is, if the SELECT subquery returns a non-null S.C1, then the WHERE . . . ALL statement is true if and only if the statement "C1=all C1" is true. If the subquery returns one or more null S.C1 entries, then the WHERE . . . ALL statement is false. Lastly, if the subquery returns an empty set, then the WHERE . . . ALL statement is true. In accordance with the present invention, the universal subquery can be transformed into either one of two cases, depending on whether the S.C1 and T.C1 entries are nullable or not nullable. If both S.C1 and T.C1 are not nullable, then predicate pushdown processing transforms Query 2 into the following rewritten SQL:
______________________________________
Converted Universal Query 2--Not Nullable
______________________________________
SELECT *
FROM T
WHERE
. . . (NOT EXISTS (SELECT 1 FROM S
WHERE T.C2=S.C2 AND T.C1<>S.C1)). . . ;
______________________________________
The column entry T.C1 must be non-nullable because if T.C1 is null, then the subquery returns an empty set and therefore the subquery predicate will always be true. If either S.C1 or T.C1, or both, are nullable, then predicate pushdown processing transforms Query 2 into:
______________________________________
Converted Universal Query 2--Nullable
______________________________________
SELECT *
FROM T
WHERE
. . . NOT EXISTS (SELECT 1
FROM S
WHERE T.C2=S.C2 AND
0=CASE WHEN T.C1=S.C1 THEN 1
ELSE 0 END)). . .;
______________________________________
This is a valid transformation because if there is a null in the column S.C1, then the subquery returns a tuple and thus the NOT EXISTS statement is false. Taking the nullable case as an example, the SQL processor in accordance with the invention next transforms the converted query into a scalar subquery as follows:
______________________________________
Converted Nullable Universal Query 2 After Scalar
Subquery Transformation
______________________________________
SELECT *
FROM T
WHERE
. . . (SELECT DISTINCT 1
FROM S
WHERE T.C2=S.C2 AND
0=CASE WHEN T.C1=S.C1 THEN 1
ELSE 0 END) IS NULL) . . .;
______________________________________
thus, the scalar subquery returns one tuple, either a "1" or a null value for the case of an empty subquery. Thus, the processing represented by the FIG. 5 processing of a universal subquery is to perform predicate pushdown processing (the FIG. 5 flow diagram box numbered 504) and then to transform the subquery to a scalar subquery (the flow diagram box numbered 506). These operations may be summarized as follows, beginning with a source universal query that has the form:
______________________________________
Universal Subquery Source
______________________________________
SELECT *
FROM T1 T
WHERE
. . . (C1 relop ALL (SELECT C1
FROM T2 S
WHERE T.C2=S.C2)). . .;
______________________________________
where "relop" is a relational operator, such as EQUAL, NOT EQUAL, LESS THAN, GREATER THAN, LESS THAN/EQUAL, GREATER THAN/EQUAL, where T1 and T2 represent database tables, and where C1 and C2 represent respective columns of those tables. After predicate pushdown, for the case of not nullable columns and for nullable columns, respectively, the converted query looks like:
______________________________________
Converted Universal Query After Predicate Push-Down (Not
______________________________________
Nullable)
SELECT *
FROM T1 T
WHERE
. . . (NOT EXISTS (SELECT 1
FROM T2 S
WHERE T.C2=S.C2 AND
NOT(T.C1 relop S.C1))) . . .;
______________________________________
for the not nullable case, and for the nullable case:
______________________________________
Converted Universal Query After Predicate Push-Down (Nullable)
______________________________________
SELECT *
FROM T1 T
WHERE
. . . (NOT EXISTS (SELECT 1
FROM T2 S
WHERE T.C2=S.C2 AND
O=CASE WHEN T.C1 relop S.C1 THEN 1
ELSE 0 END)) . . .;
______________________________________
where such transformations are correct regardless of whether or not the subquery is correlated and regardless of the correlation predicates. The pushed subquery condition can help to eliminate rows that are returned to the main query. Furthermore, the subquery will not return any column values, and instead will return a row identifier or other indicator for each row returned. This is especially advantageous in a system having an MPP-shared nothing environment, because in such systems there is less communication among processors during evaluation of the subquery. After the predicate push-down, the converted nullable query is transformed to a scalar subquery, as follows:
______________________________________
Converted Universal Query After Scalar Subquery
Transformation (nullable)
______________________________________
SELECT *
FROM T1 T
WHERE
. . . ((SELECT DISTINCT 1
FROM T2 S
WHERE T.C2=S.C2 AND
0=CASE WHEN T.C1 relop S.C1 THEN 1
ELSE 0 END) IS NULL) . . .;
______________________________________
and the subquery will return exactly one tuple, either "1" or the null value in the case of an empty subquery. As with the case of the existential query transformation, the SQL optimizer will have the option of where to send the respective tables, and will make its selection based on which will provide the greater efficiency. Similarly, after the predicate push-down, the converted not nullable query is transformed to a scalar subquery, as follows:
______________________________________
Converted Universal Query After Scalar Subquery
Transformation (not nullable)
______________________________________
SELECT *
FROM T1 T
WHERE
. . . (SELECT DISTINCT 1
FROM T2 S
WHERE T.C2=S.C2 AND
NOT (T.C1 relop S.CI)) IS NULL . . . ;
______________________________________
Again, as with the case of the existential query transformation, the SQL optimizer will have the option of where to send the respective tables, and will make its selection based on which will provide the greater efficiency. ADVANTAGES OF THE INVENTION Using the transformations described above, subqueries can be converted to scalar subqueries, thereby taking advantage of processing algorithms for scalar subqueries and permitting upper tables to be sent to nodes of lower tables and vice versa, and thereby permitting selection of the node direction depending on the least cost alternative. Thus, a relational data base management system constructed in accordance with the present invention includes a query processor that permits consideration of alternative query plans by the query optimizer so one table can be sent to a selected network location for subquery evaluation in consideration of maximum processing efficiency. The optimizer of the query processor is presented with rewritten query that permits more than one alternative for sending tables for evaluation. The optimizer evaluates the alternatives permitted by the rewritten code, determines the optimal plan for each alternative, and selects the least-cost plan from among the plans evaluated. Thus, the optimizer can decide to send an outer table to where a subquery table is located, or can decide to send a subquery table to where an outer table is located, depending on which is more efficient. The present invention has been described above in terms of presently preferred embodiments so that an understanding of the present invention can be conveyed. There are, however, many configurations for SQL-processing relational data base management systems not specifically described herein but with which the present invention is applicable. The present invention should therefore not be seen as limited to the particular embodiments described herein, but rather, it should be understood that the present invention has wide applicability with respect to SQL-processing relational data base management systems generally. All modifications, variations, or equivalent arrangements and implementations that are within the scope of the attached claims should therefore be considered within the scope of the invention.
|
Same subclass Same class Consider this |
||||||||||