Large transaction-oriented fragmentation execution method and device based on row change
An execution method and transaction technology, applied in the computer field, can solve the problems of low probability of large transactions, waste of resources, and low memory configuration in the operating environment, so as to improve synchronization efficiency, ensure integrity, and reduce memory configuration requirements. Effect
- Summary
- Abstract
- Description
- Claims
- Application Information
AI Technical Summary
Problems solved by technology
Method used
Image
Examples
Embodiment 1
[0041] The present disclosure provides a large transaction-oriented sharding execution method based on row changes. This embodiment includes the following steps:
[0042] S1: Obtain the row change data of the synchronized database, convert it into a row change object and push it to the row change queue;
[0043] S2: Extract the row change object from the row change queue, convert multiple row change objects into a transaction object and push it to the transaction queue;
[0044] S3: Fragment the large transaction object, obtain the fragmented transaction object from the transaction queue, parse it into a corresponding SQL statement and execute it in the second database, and the second database synchronously updates the row change data.
[0045] Such as Figure 2-5 As shown, the meanings of the nouns in the figure are explained as follows:
[0046] CURRENT_MEM_SIZE: the total memory usage of all unexecuted row changes in the running environment;
[0047] MAX_MEM_SIZE: The ma...
Embodiment 2
[0072] The disclosure provides a large-scale transaction-oriented shard execution device based on row changes, including a row change push module, a transaction push module, and a transaction execution module;
[0073] The row change push module, transaction push module, and transaction execution module are executed in parallel.
[0074] The row change push module is responsible for converting the row change into Row (row change object) and pushing it to RowQueue (row change queue);
[0075] RowQueue is responsible for storing the pushed row changes;
[0076] The transaction push module is responsible for obtaining Row from RowQueue and converting it into Transaction (transaction object) and pushing it to TransQueue (transaction queue);
[0077] TransQueue is responsible for storing transactions to be executed;
[0078] The transaction execution module is responsible for obtaining Transaction from TransQueue and parsing it into corresponding SQL statements for execution.
Embodiment 3
[0080] The present disclosure provides an electronic device, including a memory, a processor, and a computer program stored in the memory and operable on the processor. When the processor executes the program, a large transaction-oriented analysis based on row changes is implemented. The slice performs the steps described in the method.
PUM
Abstract
Description
Claims
Application Information
- R&D Engineer
- R&D Manager
- IP Professional
- Industry Leading Data Capabilities
- Powerful AI technology
- Patent DNA Extraction
Browse by: Latest US Patents, China's latest patents, Technical Efficacy Thesaurus, Application Domain, Technology Topic, Popular Technical Reports.
© 2024 PatSnap. All rights reserved.Legal|Privacy policy|Modern Slavery Act Transparency Statement|Sitemap|About US| Contact US: help@patsnap.com