Techniques for aggregating and emitting database activity record batches are described. Database activity records can be written to a shared memory queue and emitted to a destination using a remote procedure call (RPC). Individual database connection server processes can write client activity records to the queue. An activity monitor plugin in the database engine can monitor the audit records and aggregate the audit records into batches. Batches of audit records can be sent via RPC to their final or intermediate destination. Each instance host in a database service can include a client backend process configured to define how to submit audit records to shared memory. The activity monitor plugin can batch audit records in to messages and submit those messages via RPC to a security host manager and relaying response back to each relevant client backend.

A computer implemented method processes a search query from a requestor. A number of processor units selects an access path from access paths for each database in a set of databases based on reducing a cost for searching the set of databases using a set of access paths selected for the set of databases in response to receiving the search query from a requestor. The number of processor units receives a result set from searching the set of databases using the set of access paths selected for the set of databases. The number of processor units removes a number of duplicate records from records in the result set. The number of processor units sends the result set with the number of duplicate records removed to the requestor.

Computer-implemented systems and methods are disclosed for indexing and aggregating proxy server data. In accordance with some embodiments, the systems comprise a memory device configured to store a set of instructions, and one or more processors configured to execute the set of instructions to receive a plurality of log lines of proxy server data comprising a plurality of data components and index one or more of the plurality of data components for the plurality of log lines. The processors also generate a plurality of log data records, each including the one or more indexed data components, and generate a summarized data record by aggregating one or more log data records having at least one matching indexed data component.

A follower system and a leader system store records for a plurality of users. Each of the follower system and the leader system stores at least a record for a user. Each of the follower system and the leader system stores a private log and a public log. The public log is periodically synchronized across the follower system and the leader system. The private log of each system is maintained independent of the other system. The follower system transmits information stored in the public logs to the leader system for synchronizing the public logs of the follower system and the leader system in response to updating the public logs with information describing the second set of transactions.

The present disclosure provides a data aggregation processing apparatus and method, and a storage medium. According to the apparatus, a relatively complex target data sequence may be split, by a sequence grouping module, into a plurality of subsequences, which then can be subjected to simultaneous aggregation processing in a parallel processing mode by means of a plurality of parallel aggregation modules included in an aggregation module group, so as to obtain corresponding intermediate processing results. Subsequently, the intermediate processing results are merged by a merging module to obtain an aggregation processing result for the target data sequence. Aggregation processing for the target data sequence is completed, thus solving the technical problems in the existing methods, such as low aggregation processing efficiency and prolonged processing procedure. The technical effects of improving the aggregation processing efficiency and shortening the waiting time of users are achieved.

A database query is received at a primary database in a query language of the primary database. A determination is made whether the database query is to be handled by a secondary database different from the primary database but storing synchronized records of at least a portion of the primary database. In response to determining that the database query is to be handled by the secondary database, the database query is translated to a query language of the secondary database, including by determining a tree data structure representation of the database query, translating one or more elements of the tree data structure representation, and synthesizing the tree data structure representation to automatically generate the database query in the query language of the secondary database. The automatically generated database query is provided in the query language of the secondary database to the secondary database.

Systems and methods are presented for data quality monitoring. Data quality monitors may be created and configured to identify objects with specified data quality issues and/or property values. Objects identified by a data quality monitor can be presented to users for confirmation and resolution. Properties used by the data quality monitor to match objects may also be displayed to users.

Cached data is updated by a computing machine coupled to a primary database maintaining original data and to a cache maintaining data corresponding to the data in the primary database. In response to receiving a first database query relating to a first data, the computing machine determines whether to process the first database query by utilizing the cache or based on the primary database. In response to concluding processing the first database query, the computing machine determines whether to update the first data in the cache, and based on the result of the determining, updates the first data in the cache based on original first data in the primary database.

A method of enhancing one or more fields of a master database record based on a consumption of one or more data points provided via a third-party data subscription service is disclosed. An aggregated view corresponding to a master database record is accessed. The aggregated view identifies correspondences between the one or more fields of the master database record and the one or more data points provided via the third-party data subscription service. Based on a determination that one or more consumption criteria are met, the one or more data points are consumed and stored in a central database. The one or more fields of the master database record are updated based on the one or more consumed data points. The enhanced master database record is provided via a network to one or more computerized processes associated with one or more consumers of the enhanced master database record.

Joining data using a disjunctive operator is described. An example computer-implemented method can include receiving a query that includes a first disjunctive predicate involving a first table and a second table. The method may also include determining a first set of rows from the first table and generating a filter from the first set of rows. The method may also further include applying the filter to the second table to generate a second set of rows. Additionally, the method may also include joining the first set of rows and the second set of rows using a first disjunctive operator of the first disjunctive predicate to generate a first results set.