System and method for adaptively integrating a database state notification service with a distributed transactional middleware machine

• US 9,569,224 B2
• Filed: 01/22/2015
• Issued: 02/14/2017
• Est. Priority Date: 05/06/2014
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Zheng, Qingsheng, Little, Todd J., Shen, Xugang
• Primary Examiner(s): Zhen, Wei
• Assistant Examiner(s): LUU, BINH K
• Application Number:
  US14/603,108
• Publication Number:
  US 20150324222A1
• Time in Patent Office: 754 Days
• Field of Search: None
• US Class Current: 1/1
• CPC Class Codes: G06F 16/27 Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
• CPC Class Codes: G06F 9/44 Arrangements for executing specific programs
• CPC Class Codes: G06F 9/466 Transaction processing
• CPC Class Codes: H04L 65/40 Support for services or applications
• CPC Class Codes: H04L 67/1097 for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS]

Abstract

A system and method can handle various database state notifications in a transactional middleware machine environment. The system can connect one or more transaction servers to a database service, wherein the database service is associated with a notification service. Furthermore, a notification service client that is associated with said one or more transaction servers can receive one or more events from the notification service, wherein said one or more events indicates one or more state changes in the database service. Then, one or more transaction servers operate to adaptively respond to the one or more state changes in the database service.

Claims

1. A method for handling various database state notifications in a transactional middleware machine environment, the method comprising:

connecting a plurality of transaction servers to a database service, wherein the database service is associated with a notification service;

providing an application notification server;

storing database service state information in a database state table in a shared memory using the application notification server;

receiving, with the application notification server, a plurality of events from the notification service, wherein said plurality of events indicate one or more state changes in the database service;

wherein said plurality of events comprise a plurality of high availability (HA) events, each of which indicates an up/down for at least one of a service, an instance, and a host node associated with the database service;

making a plurality of modifications to said database service state information stored in said state table using the application notification server in response to said plurality of events from the notification service;

polling said database service state information stored in said database state table using said plurality of transaction servers; and

adaptively responding, with said plurality of transaction servers, to the plurality of modifications to said database state information stored in said database state table;

wherein said adaptively responding comprises rapid failure detection by said plurality of transaction servers in response to modifications to said database state information made in response to the plurality HA events which indicate a down without testing database connections, and removing one or more invalid database connections from said plurality of transaction servers to said database service and creating one or more valid database connections thereby supporting fast connection failover.

2. The method of claim 1, further comprising:

allowing the database service to be based on a clustered database that includes one or more databases, instances, host nodes, and services.

3. The method of claim 1, further comprising:

handling the plurality of events based on one or more routing policies.

4. The method of claim 1, wherein:

adaptively responding, with said plurality of transaction servers, to the plurality of modifications to said database state information stored in said database state table, further comprises terminating in-flight transactions on said one or more invalid database connections.

5. The method of claim 1, further comprising:

allowing said plurality of events to include runtime load balance (RLB) events, each of which indicates a runtime load and affinity per database instance that is associated with the database service.

6. The method of claim 5, further comprising:

distributing runtime work requests to active database instances based on the RLB events.

7. The method of claim 1, further comprising:

providing with the application notification server a notification service client of the notification service of the database service.

8. The method of claim 1, further comprising:

providing with the application notification server a notification service client of the notification service of the database service; and

creating, via a main process of the application notification server, one or more receiving threads, each of which operates to receive and handle one or more events.

9. A system for handling various database state notifications in a transactional middleware machine environment, comprising:

a plurality of transaction servers each comprising a microprocessor and a memory, wherein the plurality of transaction servers are connected to a database service, wherein the database service is associated with a notification service;

an application notification server comprising a microprocessor and a memory;

wherein the application notification server is configured to store database service state information in a database state table in a shared memory;

wherein the application notification server is configured to receive a plurality of events from the notification service, wherein each of said plurality of events indicates one or more state changes in the database service;

wherein said plurality of events comprise a plurality of high availability (HA) events, each of which indicates an up/down for at least one of a service, an instance, and a host node associated with the database service;

wherein the application notification server is configured to make a plurality of modifications to said database service state information stored in said state table in response to said plurality of events received from the notification service;

wherein the plurality of transaction servers are configured to poll said database service state information stored in said database state table; and

wherein the plurality of transaction servers are configured to adaptively respond to the plurality of modifications to said database state information stored in said database state table;

wherein the plurality of transaction servers are configured to adaptively respond to the modifications to said database state information made in response to the plurality HA events which indicate a down without testing database connections, and support fast connection failover by removing one or more invalid database connections to said database service and creating one or more valid database connections to said database service.

10. The system according to claim 9, wherein:

the database service is based on a clustered database that includes one or more databases, instances, host nodes, and services.

11. The system of claim 9, wherein:

the system is configured to handle the plurality of events based on one or more routing policies.

12. The system of claim 9, wherein:

the plurality of transaction servers are further configured to adaptively respond to the plurality of modifications to said database state information stored in said database state table, by terminating in-flight transactions on said one or more invalid database connections.

13. The system of claim 9, wherein:

said plurality of events are runtime load balance (RLB) events, each of which indicates a runtime load and affinity per database instance that is associated with the database service.

14. The system of claim 13, wherein:

said plurality of transaction servers operates to distribute runtime work requests to active database instances based on the RLB events.

15. The system of claim 9, wherein:

the application notification server is configured to provide a notification service client of the notification service of the database service; and

wherein a main process of the application notification server operates to create one or more receiving threads, each of which operates to receive and handle one or more events.

16. A non-transitory machine readable storage medium having instructions stored thereon for handling various database state notifications in a transactional middleware machine environment, which instructions, when executed, cause a system to perform steps comprising:

connecting a plurality of transaction servers to a database service, wherein the database service is associated with a notification service;

providing an application notification server;

storing database service state information in a database state table in a shared memory using the application notification server;

receiving, with the application notification server, a plurality of events from the notification service, wherein each of said plurality of events indicate one or more state changes in the database service;

wherein said plurality of events comprise a plurality of high availability (HA) events, each of which indicates an up/down for at least one of a service, an instance, and a host node associated with the database service;

making a plurality of modifications to said database service state information stored in said state table using the application notification server in response to said plurality of events from the notification service;

polling said database service state information stored in said database state table using said plurality of transaction servers; and

adaptively responding, with said plurality of transaction servers, to the plurality of modifications to said database state information stored in said database state table;

wherein said adaptively responding comprises rapid failure detection in response to modifications to said database state information made in response to the plurality HA events which indicate a down without testing database connections, and removing one or more invalid database connections from said plurality of transaction servers to said database service and creating one or more valid database connections thereby supporting fast connection failover.

17. The non-transitory machine readable storage medium of claim 16 wherein:

the database service is based on a clustered database that includes one or more databases, instances, host nodes, and services.

18. The non-transitory machine readable storage medium of claim 16 wherein said steps further comprise:

handling the plurality of events based on one or more routing policies.

19. The non-transitory machine readable storage medium of claim 16 wherein said steps further comprise:

adaptively responding, with said plurality of transaction servers, to the plurality of modifications to said database state information stored in said database state table, further comprises terminating in-flight transactions on said one or more invalid database connections.

20. The non-transitory machine readable storage medium of claim 16 wherein:

said plurality of events include runtime load balance (RLB) events, each of which indicates a runtime load and affinity per database instance that is associated with the database service.