Real-time distributed database system and method
First Claim
1. A method of forming a distributed database, comprising:
- (a) providing a plurality of nodes connected via a communication medium;
(b) providing at least one application on each node;
(c) creating a database on each node, each database at least partially overlapping at least one other database, each database including a plurality of tables, and each table including at least one record, said step (c) including the substep of (c1) assigning ownership of each table in each database to only one application;
(d) allowing only an owning application to modify a table owned by said owning application;
(e) allowing only one application to read from and write to a database at a time;
(f) distributing updates made to each database to every other database; and
(g) updating each database in accordance with said distributed updates.
2 Assignments
0 Petitions
Accused Products
Abstract
A distributed database system includes a plurality of nodes connected via a network medium. Each node runs at least one application and stores a database. Each database at least partially overlaps at least one other database. Each database includes a plurality of tables, and each table includes at least one record. Ownership of each table in the database is assigned to only one application, and only an owning application can modify a table owned by the owning application. Each node also schedules running of the applications on the node such that only one application reads from and writes to the database at a time, distributes updates made to the database to every other database, and updates the database in accordance with received distributed updates.
188 Citations
45 Claims
-
1. A method of forming a distributed database, comprising:
-
(a) providing a plurality of nodes connected via a communication medium; (b) providing at least one application on each node; (c) creating a database on each node, each database at least partially overlapping at least one other database, each database including a plurality of tables, and each table including at least one record, said step (c) including the substep of (c1) assigning ownership of each table in each database to only one application; (d) allowing only an owning application to modify a table owned by said owning application; (e) allowing only one application to read from and write to a database at a time; (f) distributing updates made to each database to every other database; and (g) updating each database in accordance with said distributed updates. - View Dependent Claims (2, 3, 4)
-
-
5. A method for generating a data update message corresponding to a database stored at a node in a distributed database system, which includes a plurality of nodes each storing a database, to distribute updates to each database, each database overlapping at least partially with a database stored on one other node, each database containing a plurality of tables, each table having a table update flag associated therewith and containing at least one record, each record having a record update flag associated therewith, said table update flag and said record update flag indicating that a corresponding table and record, respectively, have been modified when set, the method comprising:
-
(a) locating a modified table in said database based on said table update flags; (b) locating a modified record in said modified table based on said record update flags; (c) writing a header in said data update message, said header including a table identifier and record number, said table identifier identifying said modified table, said record number identifying said modified record in said modified table; (d) writing contents of said modified record in said data update message; and (e) sending said data update message to each node via a communication medium connecting said nodes. - View Dependent Claims (6, 7, 8, 9, 10, 11, 12)
-
-
13. A method for generating a data update message corresponding to a database stored at a node in a distributed database system, which includes a plurality of nodes each storing a database, to distribute updates to each database, each database overlapping at least partially with a database stored on one other node, each database containing a plurality of tables, each table having a table identifier associated therewith and containing at least one record, each record having a record number associated therewith, said database at each node having an updated table list associated therewith, said updated table list storing said table identifier for each modified table in said database, each table having an updated record list associated therewith, said updated record list storing said record number for each modified record in an associated table, the method comprising:
-
(a) locating a modified table in said database based on said updated table list; (b) locating a modified record in said modified table based on said updated record list associated with said modified table; (c) writing a header in said data update message, said header including said table identifier for said modified table and said record number for said modified record; (d) writing contents of said modified record in said data update message; and (e) sending said data update message to each node via a communication medium connecting said nodes. - View Dependent Claims (14, 15, 16, 17, 18, 19)
-
-
20. A method of updating a database stored at a node in a distributed database system, which includes a plurality of nodes each storing a database and connected via a communication medium, each database overlapping at least partially with a database stored on one other node, each database containing a plurality of tables, each table containing at least one record, the method comprising:
-
(a) receiving, at a node, a data update message on said communication medium, said data update message including at least one header associated with a record and contents of said record, said header including a table identifier identifying a table containing said record and a record number associated with said record; (b) extracting said header from said data update message; (c) locating said record in said database stored at said node based on said table identifier and said record number in said extracted header; and (d) writing said contents of said record in said data update message into said record of said database located in step (c). - View Dependent Claims (21, 22)
-
-
23. A distributed database system, comprising:
-
a plurality of nodes connected via a communication medium; and
whereineach node includes, at least one application; a database stored on said node, said database at least partially overlapping at least one other database, said database including a plurality of tables, and each table including at least one record, ownership of each table in said database being assigned to only one application, and only an owning application being able to modify a table owned by said owning application; scheduling means for scheduling running of said applications on said node such that only one application reads from and writes to said database at a time; distributing means for distributing updates made to said database to every other database; and updating means for updating said database in accordance with received distributed updates. - View Dependent Claims (24, 25, 26)
-
-
27. A distributed database system, comprising:
-
a plurality of nodes connected via a communication medium, each node storing a database, each database overlapping at least partially with a database stored on one other node, each database containing a plurality of tables, each table having a table update flag associated therewith and containing at least one record, each record having a record update flag associated therewith, said table update flag and said record update flag indicating that a corresponding table and record, respectively, have been modified when set; and
whereineach node locates a modified table in said database based on said table update flags, locates a modified record in said modified table based on said record update flags, first writes a header in a data update message, said header including a table identifier and record number, said table identifier identifying said modified table, said record number identifying said modified record in said modified table, second writes contents of said modified record in said data update message, and sends said data update message to each node via said communication medium. - View Dependent Claims (28, 29, 30, 31, 32, 33, 34)
-
-
35. A distributed database system, comprising:
-
a plurality of nodes connected via a communication medium, each node storing a database, each database overlapping at least partially with a database stored on one other node, each database containing a plurality of tables, each table having a table identifier associated therewith and containing at least one record, each record having a record number associated therewith, said database at each node having an updated table list associated therewith, said updated table list storing said table identifier for each modified table in said database, each table having an updated record list associated therewith, said updated record list storing said record number for each modified record in an associated table; and
whereineach node first locates a modified table in said database based on said updated table list, second locates a modified record in said modified table based on said updated record list associated with said modified table, first writes a header in a data update message, said header including said table identifier for said modified table and said record number for said modified record, second writes contents of said modified record in said data update message, and sends said data update message to each node via said communication medium. - View Dependent Claims (36, 37, 38, 39, 40, 41)
-
-
42. A distributed database system, comprising:
-
a plurality of nodes each storing a database and connected via a communication medium, each database overlapping at least partially with a database stored on one other node, each database containing a plurality of tables, each table containing at least one record; at least one node receiving a data update message on said communication medium, said data update message including at least one header associated with a record and contents of said record, said header including a table identifier identifying a table containing said record and a record number associated with said record; said node extracting said header from said data update message, locating said record in said database stored at said node based on said table identifier and said record number in said extracted header, and writing said contents of said record in said data update message into said located record of said database. - View Dependent Claims (43, 44)
-
-
45. A method of communication between applications in a distributed database system which includes a plurality of nodes connected via a network medium, each node running at least one application and storing a database, each database at least partially overlapping at least one other database, each database including a plurality of tables, and each table including at least one record and being owned by only one application, the method comprising:
-
(a) sending modification requests from non-owning applications to an owning application via said communication medium, said modification requests indicating a desired modification to a record in a table not owned by said non-owning application and owned by said owning application; (b) receiving, by said owning application, modification requests which request modification of a record in a table owned by said owning application; and (c) modifying tables owned by said owning application in accordance with modifications generated by said owning application and modifications in said received modification requests.
-
Specification