Parallel database management method and parallel database management system

• US 5,983,228 A
• Filed: 02/18/1998
• Issued: 11/09/1999
• Est. Priority Date: 02/19/1997
• Status: Expired due to Term

• Current Assignee: Hitachi, Ltd.
• Original Assignee: Hitachi, Ltd.
• Inventors: Kobayashi, Susumu, Hara, Norihiro, Yamamoto, Yoichi, Tsuchida, Masashi, Nakano, Yukio, Kamegi, Yoshito
• Primary Examiner(s): HO, RUAY L
• Application Number:
  US09/025,245
• Time in Patent Office: 629 Days
• Field of Search: 707/1-10, 707/100-104, 707/200-206, 709/200-253, 395/702-710
• US Class Current: 1/1
• CPC Class Codes: G06F 16/2291 User-Defined Types; Storage management thereof
• CPC Class Codes: G06F 16/24532 of parallel queries
• CPC Class Codes: Y10S 707/99932 Access augmentation or optimizing
• CPC Class Codes: Y10S 707/99933 Query processing, i.e. searching
• CPC Class Codes: Y10S 707/99934 Query formulation, input preparation, or translation
• CPC Class Codes: Y10S 707/99938 Concurrency, e.g. lock management in shared database
• CPC Class Codes: Y10S 707/99943 Generating database or data structure, e.g. via user interface

Abstract

In a database management system including a request reception server and a plurality of execution servers, each having a plug-in program module incorporated by a user, the request reception server analyzes a processing request from the user to determine whether or not the plurality of execution servers require currently unidentified input parameters when executing external functions in their plug-in modules, based on a definition information table created from descriptions of interface specifications for the plug-in program modules. When it is determined that the execution servers require such input parameters, an external function in the plug-in program module in the request reception server is executed to previously acquire the unidentified input parameters. The request reception server creates an execution processing procedure code, to be executed by the plurality of execution servers, assuming that the unidentified input parameters have already been inputted, and passes the execution processing procedure code together with the input parameters acquired by the request reception server to the plurality of execution servers.

Claims

1. In a parallel database management system including a request reception server for receiving a request from a user, and a plurality of execution servers for parallelly executing database processing appropriate to the request from the user, said request reception server and said plurality of execution servers each having a function of executing a plug-in program module incorporated by the user in a database system, a database management system method performing a database execution control comprising the steps of:

when said request reception server creates an execution procedure code for instructing a procedure for executing the database processing appropriate to the request from the user, said request reception server recognizing that another plug-in module is executed on said request reception server to acquire information to be passed to the plug-in module as an input when an plug-in module is executed on each said execution server;

executing said other plug-in module on said request reception server in accordance with said recognition to acquire said information to be passed as an input; and

said request reception server editing said execution procedure code such that the information acquired at the preceding step is passed as an input when said plug-in module is executed on each said execution server.

2. A database management method according to claim 1, wherein said request reception server receives information which is passed as the input when said plug-in module is executed on each execution server, on the basis of descriptions of interface specifications for said plug-in modules.

3. A database management method according to claim 2, wherein when said plug-in module in each said execution server is executed in response to a function call to said plug-in module, said description of the interface specification includes additional information as an input parameter for executing said plug-in module in said execution server, in addition to an input parameter passed by said function call.

4. A database management method according to claim 2, wherein said description of the interface specification includes an instruction of executing another plug-in module on said request reception server to previously acquire information to be passed as an input parameter to said plug-in module when said plug-in module is executed on each said execution server.

5. A database management method according to claim 3, wherein said description of the interface specification includes an instruction of executing another plug-in module on said request reception server to previously acquire information to be passed as an input parameter to said plug-in module when said plug-in module is executed on said execution server.

6. A parallel database management system comprising:

a request reception server for receiving a request from a user; and

a plurality of execution servers for parallelly executing database processing appropriate to the request from the user in response to an instruction from said request reception server,

wherein said request reception server executes a plug-in module for acquiring input information to acquire the input information, and said execution servers execute plug-in modules using said input information.

7. A database management method in a database management system including a request reception server and a plurality of execution servers, comprising the steps of:

receiving a processing request from a user at said request reception server;

determining, by analyzing said processing request in said request reception server, whether or not currently unidentified input information is required after said plurality of execution servers have initiated parallel executions of an execution processing procedure code appropriate to said processing request;

previously acquiring said input information in said request reception server when determining that said execution servers require said input information;

creating in said request reception server said execution processing procedure code assuming that said currently unidentified input information has already been inputted; and

passing said execution processing procedure code together with said acquired input information from said request reception server to said plurality of execution servers.

8. A database management method according to clam 7, wherein said input information passed from said request reception server to said plurality of execution servers is treated as a known input parameter when executing a function in a plug-in program module incorporated by the user in each of said plurality of execution servers.

9. A database management method according to claim 8, wherein at said step of acquiring input information by said request reception server, said input information is acquired by executing a plug-in program module incorporated by the user in said request reception server.

10. A database management method according to claim 9, wherein said processing request from the user is analyzed by said request reception server based on descriptions of interface specifications related to plug-in program modules incorporated in said request reception server and said plurality of execution servers.

11. A method of processing a request from a user in a database management system including a request reception server and a plurality of execution servers, said request reception servers and said execution servers each having a plug-in program module incorporated by the user, said method comprising the steps executed by said request reception server of:

receiving a processing request from the user;

determining, by analyzing said processing request from the user, whether or not plug-in program modules requiring currently unidentified input information are executed in said plurality of execution servers after said plurality of execution servers have initiated parallel executions of an execution processing procedure code appropriate to said processing request, based on a definition information table created from descriptions of interface specifications related to said plug-in program modules;

previously acquiring said currently unidentified input information by executing a plug-in program module in said request reception server when determining that the plug-in program modules requiring said currently unidentified input information are executed in said execution servers;

creating said execution processing procedure code assuming that said input information has already been inputted; and

passing said execution processing procedure code together with said acquired input information from said request reception server to said plurality of execution servers.

12. A request reception server in a database management system including said request reception server and a plurality of execution servers, said request reception servers and said execution servers each having a plug-in program module incorporated by the user, said request reception server comprising:

a processing unit for receiving a processing request from the user;

a processing unit for determining, by analyzing said processing request from the user, whether or not plug-in program modules requiring currently unidentified input information are executed in said plurality of execution servers after said plurality of execution servers have initiated parallel executions of an execution processing procedure code appropriate to said processing request, based on a definition information table created from descriptions of interface specifications related to said plug-in program modules;

a processing unit for previously acquiring said currently unidentified input information by executing a plug-in program module in said request reception server when determining that the plug-in program modules requiring said currently unidentified input information are executed in said execution servers;

a processing unit for creating said execution processing procedure code assuming that said input information has already been inputted; and

a processing unit for passing said execution processing procedure code together with said acquired input information from said request reception server to said plurality of execution servers.

13. A database system comprising:

a client connected to a communication path for issuing a processing request from a user in response to a query of the user;

a request reception server connected to said communication path for receiving said processing request from said client, said request reception server including a plug-in program module incorporated by the user;

a plurality of execution servers connected to said communication path for parallelly executing an execution processing procedure code appropriate to said processing request, said plurality of execution server each including a plug-in program module incorporated by the user;

a definition registering server connected to said communication path, said definition registering server including a storage device for storing descriptions of interface specifications related to said plug-in program modules in said request reception server and said plurality of execution servers, and a definition registering tool for creating, from said description of the interface specifications, a definition information table required for determining whether or not the plug-in program modules in said plurality of execution servers require currently unidentified input information after said plurality of execution servers have initiated parallel executions of said execution processing procedure code; and

a dictionary server connected to said communication path, and including a storage device for storing said definition information table, and a definition information management unit for managing said definition information table,

said request reception server including;

a processing unit for analyzing said processing request received from said client to determine whether or not currently unidentified input information is required when said plurality of execution servers execute said plug-in program modules, based on said definition information table retrieved by accessing said dictionary server;

a processing unit for previously acquiring said input information from said dictionary server by executing a plug-in program module in said request reception server when determining that the executions of the plug-in program modules in said plurality of execution servers require said currently unidentified input information;

a processing unit for creating said execution processing procedure code assuming that said input information has already been inputted;

a processing unit for passing said execution processing procedure code together with said acquired input information from said request reception server to said plurality of execution servers; and

a processing unit for receiving an execution result of said execution processing procedure code by said plurality of execution servers and holding said execution result in a holding unit.

14. A definition registering node in a database management system, said definition registering node connected to a communication path, said database management system comprising:

a request reception server connected to said communication path for receiving a processing request from a user, said request reception server including a plug-in program module incorporated by the user;

a plurality of execution servers connected to said communication path for parallelly executing an execution processing procedure code appropriate to said processing request, said plurality of execution servers each including a plug-in program module incorporated by the user; and

a dictionary server connected to said communication path, and including a storage device for storing definition information, and a definition information management unit for managing said definition information,

wherein said definition registering node including a storage device for storing descriptions of interface specifications related to said plug-in program modules in said request reception server and said plurality of execution servers, and a definition registering tool for creating, from said description of the interface specifications, a definition information table required for determining whether or not plug-in program modules requiring currently unidentified input information are executed in said execution servers after said plurality of execution servers have initiated parallel executions of said execution processing procedure code;

said definition registering tool accesses said dictionary server, and instructs said definition information management unit to register said definition information table in said storage device in said dictionary server; and

said request reception server analyzes said processing request, and executes said program module in said request receiver server to previously acquire said input information from said dictionary server when said request reception server determines, based on said definition information table retrieved by accessing said dictionary server, that the executions of said plug-in program modules require currently unidentified input information after said plurality of execution servers have initiated the parallel executions of said execution processing procedure code.

15. A storage medium readable by a request reception server in a database management system including said request reception server and a plurality of execution servers, said storage medium encoding a computer process comprising:

a processing portion for receiving a processing request from a user;

a processing portion for determining, by analyzing said processing request from the user, whether or not said plurality of execution servers require currently unidentified input information after said plurality of execution servers have initiated parallel executions of a execution processing procedure code appropriate to said processing request;

a processing portion for previously acquiring said input information when determining that said plurality of execution servers require said input information;

a processing portion for creating said execution processing procedure code assuming that said input information has already been inputted; and

a processing portion for passing said execution processing procedure code together with said input information from said request reception server to said plurality of execution servers.

16. A storage medium readable by a request reception server in a database management system including said request reception server and a plurality of execution servers, each having a plug-in program module incorporated by a user, said recording medium encoding a computer process comprising:

a processing portion for receiving a processing request from the user;

a processing portion for determining, by analyzing said processing request, whether or not plug-in modules requiring currently unidentified input information are executed in said plurality of execution servers after said plurality of execution servers have initiated parallel executions of an execution processing procedure code appropriate to said processing request, based on a definition information table created from descriptions of interface specifications for said plug-in program modules;

a processing portion for previously acquiring said input information by executing said plug-in program module in said request reception server, when determining that said plug-in program modules in said plurality of execution servers require said currently unidentified input information;

a processing portion for creating said execution processing procedure code assuming that said input information has already been inputted; and

a processing portion for passing said execution processing procedure code together with said acquired input information from said request reception server to said plurality of execution servers.