System, method and computer program product for storing data in a databa using a multi-thread shared memory message queue buffer

摘要

Systems, methods and/or computer program products for storing data from multiple clients in a database include a Multi-thread Shared Memory message Queue Buffer (MSMQB) that includes multiple First-In First-Out (FIFO) queues, a respective one of which is associated with a respective one of the clients. The MSMQB is configured to store sequential bursts of data records that are received from the clients in the associated FIFO queues. The data records in the sequential bursts are sorted by a primary key. A Semi-Merge Sort Module (SMSM) also is provided that is responsive to the FIFO queues in the MSMQB. The SMSM is configured to sort the first sequential bursts in the FIFO queues based on the primary key of at least one selected record therein, to produce a semi-sorted record stream. The SMSM also serially stores the semi-sorted record stream in the database. Thus, a database can handle multiple clients and multiple bursts for high throughput writing of data into the database. Moreover, by performing a semi-merge sort, the records may be placed into the record stream based on the value of the primary key of at least one selected record, so that an efficient rough sort may be provided.