Database query using a user-defined function

Patent metadata

Field	Value
Publication number	US-9244999-B2
Application number	US-201313744676-A
Country	US
Kind code	B2
Filing date	Jan 18, 2013
Priority date	Feb 27, 2012
Publication date	Jan 26, 2016
Grant date	Jan 26, 2016

Abstract

A database query by using a user-defined function (UDF) is provided. A computer-implemented method for performing the database query by using the UDF includes detecting whether a command for invoking the UDF to transmit a parameter value has been received. Based on detecting that the command for invoking the UDF to transmit the parameter value has been received: a first interface of the UDF is started; the parameter value is received through the first interface; and the received parameter value is transmitted to an external data source. The method further includes returning to detecting whether the command for invoking the UDF to transmit the parameter value has been received.

First claim

What is claimed is:

1. A computer-implemented method for performing a database query by using a user-defined function (UDF), comprising:
detecting whether a command for invoking the UDF, by a relational database management system (RDBMS), to transmit a parameter value has been received;
based on detecting that the command for invoking the UDF to transmit the parameter value has been received:
starting a first interface that is a transmitting interface of the UDF;
receiving the parameter value through the first interface;
transmitting the received parameter value through the first interface to an external data source; and
returning to detecting whether the command for invoking the UDF to transmit the parameter value has been received;

detecting whether data can be received;
based on detecting that the data can be received:
starting a second interface that is a receiving interface of the UDF, the second interface operating asynchronously with respect to the first interface, and the first and second interfaces are threads of the UDF created by the RDBMS;
creating, by the RDBMS, a buffer in the UDF at runtime;
receiving the data from the external data source through the second interface, wherein the received data is obtained from the external data source in response to the transmitting of the received parameter value to the external data source through the first interface; and
storing, by the second interface, the data received from the external data source into the buffer;

detecting whether stored data has been received from the external source based on monitoring the buffer; and
based on detecting that the stored data has been received from the external data source, providing the data received from the external data source by copying contents of the buffer.

2. The computer-implemented method of claim 1 , further comprising:
removing the data received from the external data source which has been provided.

3. The computer-implemented method of claim 1 , wherein the UDF returns to detecting whether the command for invoking the UDF to transmit the parameter value has been received without waiting for the data to be received by the second interface of the UDF in response to transmitting the received parameter value through the first interface to the external data source.

4. The computer-implemented method of claim 1 , wherein the external data source is a not-only structured query language (NoSQL) system.

5. A system for performing a database query by using a user-defined function (UDF), comprising:
a detecting unit configured to detect whether a command for invoking the UDF, by a relational database management system (RDBMS), to transmit a parameter value is received and whether data can be received;
a transmitting unit configured to perform, in response to determining that the detecting unit detects the command for invoking the UDF to transmit a parameter value:
start a first interface that is a transmitting interface of the UDF;
receive a parameter value through the first interface; and
transmit the received parameter value through the first interface to the external data source;

a returning unit configured to return to detect whether the command for invoking the UDF to transmit a parameter is received;
an obtaining unit configured to perform, in response to determining that the detecting unit detects that the data can be received:
start a second interface that is a receiving interface of the UDF, the second interface operating asynchronously with respect to the first interface, and the first and second interfaces are threads of the UDF created by the RDBMS; and
receive data from the external data source through the second interface, wherein the received data is obtained from the external data source in response to the transmitting of the received parameter value to the external data source through the first interface;

a storing unit configured to store, by the second interface, the data received from the external data source into a buffer, wherein the RDBMS creates the buffer in the UDF at runtime;
wherein the detecting unit is further configured to detect whether there is stored data received from the external data source based on monitoring the buffer; and
a providing unit configured to provide the data received from the external data source, in response to determining that the detecting unit detects that there is stored data received from the external data source by copying contents of the buffer.

6. The system of claim 5 , further comprising:
a removing unit configured to remove the data received from the external data source which has been provided.

7. The system of claim 3 , wherein the system returns to detecting whether the command for invoking the UDF to transmit the parameter value has been received without waiting for the data to be received by the second interface of the UDF in response to transmitting the received parameter value through the first interface to the external data source.

8. The system of claim 5 , wherein the external data source is a not-only structured query language (NoSQL) system.

9. A computer program product for performing a database query by using a user-defined function (UDF), the computer program product comprising:
a computer readable storage medium having computer readable program code embodied therewith, the computer readable program code comprising computer readable program code configured to perform a method comprising:
detecting whether a command for invoking the UDF, by a relational database management system (RDBMS), to transmit a parameter value has been received;
based on detecting that the command for invoking the UDF to transmit the parameter value has been received:
starting a first interface that is a transmitting interface of the UDF;
receiving the parameter value through the first interface;
transmitting the received parameter value through the first interface to an external data source; and
returning to detecting whether the command for invoking the UDF to transmit the parameter value has been received;

detecting whether data can be received;
based on detecting that the data can be received:
starting a second interface that is a receiving interface of the UDF, the second interface operating asynchronously with respect to the first interface, and the first and second interfaces are threads of the UDF created by the RDBMS;
creating, by the RDBMS, a buffer in the UDF at runtime;
receiving the data from the external data source through the second interface, wherein the received data is obtained from the external data source in response to the transmitting of the received parameter value to the external data source through the first interface; and
storing, by the second interface, the data received from the external data source into the buffer;

detecting whether stored data has been received from the external data source based on monitoring the buffer; and
based on detecting that the stored data has been received from the external data source, providing the data received from the external data source by copying contents of the buffer.

10. The computer program product of claim 9 , further comprising:
removing the data received from the external data source which has been provided.

11. The computer program product of claim 9 , wherein the UDF returns to detecting whether the command for invoking the UDF to transmit the parameter value has been received without waiting for the data to be received by the second interface of the UDF in response to transmitting the received parameter value through the first interface to the external data source.

12. The computer program pro

Assignees

• IBM

Inventors

• Jin Yi
• Li Lei
• Ma Chun E
• Ma li li

Classifications

• G06F16/284 Primary

  Relational databases · CPC title

• G06F16/25

  Integrating or interfacing systems involving database management systems · CPC title

• G06F17/30595 Primary

  Physics · mapped topic

• G06F17/30557

  Physics · mapped topic