CN113760858B - Dynamic migration method and device for memory database data, computing equipment and storage equipment - Google Patents
Dynamic migration method and device for memory database data, computing equipment and storage equipment Download PDFInfo
- Publication number
- CN113760858B CN113760858B CN202010505942.0A CN202010505942A CN113760858B CN 113760858 B CN113760858 B CN 113760858B CN 202010505942 A CN202010505942 A CN 202010505942A CN 113760858 B CN113760858 B CN 113760858B
- Authority
- CN
- China
- Prior art keywords
- client
- data
- migration
- migrated
- fragments
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
Classifications
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/21—Design, administration or maintenance of databases
- G06F16/214—Database migration support
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/27—Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
Landscapes
- Engineering & Computer Science (AREA)
- Databases & Information Systems (AREA)
- Theoretical Computer Science (AREA)
- Data Mining & Analysis (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Computing Systems (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
The embodiment of the invention relates to the technical field of business support, and discloses a method, a device, a computing device and a storage device for dynamic migration of memory database data, wherein the method comprises the following steps: obtaining data to be migrated and the number of clients to be migrated corresponding to the client fragments from a distributed cluster cache according to the client fragments; sequentially acquiring the data to be migrated corresponding to a client for any client fragment and migrating the data; and accumulating the migration client number until the migration client number is equal to the client data to be migrated. Through the mode, the embodiment of the invention can convert the data management unit from a single client to a batch of clients with the same client fragments, improves the data management efficiency, simplifies the migration process, and can realize the continuous dynamic migration of the memory database data.
Description
Technical Field
The embodiment of the invention relates to the technical field of business support, in particular to a method, a device, computing equipment and storage equipment for dynamic migration of memory database data.
Background
With the development of the pound of mobile internet service and the acceleration and cost reduction of the country to the mobile internet service, users are increasingly widespread to use mobile phones to access the internet, and the amount of customer data received by a corresponding charging system is rapidly increasing. The rapid increase of the traffic and the customer data volume makes the phenomenon that the local traffic increase difference causes unbalanced load of the memory database and the like more remarkable, and simultaneously, the data expansion is more frequent, and the routing processing capacity, particularly the load capacity, the concurrent processing capacity and the automatic expansion capacity of the service support system are more required.
The prior art responds to the rapid increase of client data by frequently expanding the complex memory bank and transferring the data, and the means indeed relieve the pressure of increasing the data volume. However, the capacity expansion and data migration operation in the prior art need to be stopped, and frequent suspension of the service can lead to backlog of service data, thereby bringing negative effects of untimely charging treatment, untimely flow reminding and untimely arrearage treatment to partial users; in addition, in the customer data management mode taking a single customer as a unit, in the process of expanding the memory bank which involves a large number of manual operations, the process is complicated, the workload is huge, the problem investigation is difficult, and the risk coefficient is high.
Disclosure of Invention
In view of the above, embodiments of the present invention provide a method, an apparatus, a computing device, and a storage device for dynamically migrating database data, which overcome or at least partially solve the above problems.
According to an aspect of an embodiment of the present invention, there is provided a method for dynamically migrating database data, the method including: obtaining data to be migrated and the number of clients to be migrated corresponding to the client fragments from a distributed cluster cache according to the client fragments; sequentially acquiring the data to be migrated corresponding to a client for any client fragment and migrating the data; and accumulating the migration client number until the migration client number is equal to the client data to be migrated.
In an optional manner, for any of the client slices, sequentially acquiring and migrating the data to be migrated corresponding to a client, including: sequentially taking the data to be migrated of the client in the client fragments; judging whether an associated client field of the client is empty according to the data to be migrated; if the associated client field is not null, acquiring the data to be migrated of the associated client corresponding to the associated client field; and if the data to be migrated of the client and the associated client are empty, merging and migrating the data to be migrated in a distributed cluster cache.
In an optional manner, before the obtaining, from the distributed cluster cache, the data to be migrated and the number of clients to be migrated corresponding to the client tile, the method includes: when the state of the newly added customer data or the stock customer data is changed, the newly added customer data and the stock customer data are subjected to one-time slicing processing through decoupling according to a preset slicing rule and are solidified from a business library to enter a data physical library; and storing the newly added client data and the stock client data after the slicing processing from the data physical library to a distributed memory database through loading or refreshing.
In an alternative, the method further comprises:
responding to an application to initiate an access request to a data node of a client, and inquiring whether a local zone fragment of the client is in a zone equilibrium state list or not according to a zone number corresponding to the client; if the zone of the client is not in the zone balanced state list, acquiring data nodes from a distributed cluster cache, and if the distributed cluster cache has no data nodes, acquiring the data nodes through a routing service; and if the zone of the client is in the zone balanced state list, acquiring the data node through a routing service.
In an alternative manner, the obtaining the data node through a routing service includes: starting a routing service, and locking data of all migration areas in the memory parameter library; judging whether the client fragments belong to migration zone fragments or not according to the client fragments to which the client belongs; if the client fragments belong to non-migration zone fragments, acquiring the data nodes according to migration states of the associated clients; and if the client fragments belong to migration zone fragments, inquiring the migration state in a client migration state table in the memory parameter library, attempting to access the data node of the client, and returning an access result according to the migration state of the client.
In an optional manner, the obtaining the data node according to the migration status of the associated client includes: inquiring whether associated data are being migrated according to the associated client service table; if yes, returning that the current data is being migrated; and if the client is in a service processing state, directly returning to the data node.
In an optional manner, the returning the access result according to the migration state of the client includes: if the client migration is completed, the access is successful, and the data node is returned; if the client is migrating, the query fails, returning to the migrating/processing failure.
According to another aspect of an embodiment of the present invention, there is provided a dynamic migration apparatus for database data, including: the data acquisition unit is used for acquiring data to be migrated and the number of clients to be migrated corresponding to the client fragments from the distributed cluster cache according to the client fragments; the dynamic migration unit is used for sequentially acquiring the data to be migrated corresponding to one client for any client fragment and migrating the data; and the migration completion unit is used for accumulating the migration client number until the migration client number is equal to the client data to be migrated.
According to another aspect of an embodiment of the present invention, there is provided a computing device including: the device comprises a processor, a memory, a communication interface and a communication bus, wherein the processor, the memory and the communication interface complete communication with each other through the communication bus;
the memory is used for storing at least one executable instruction, and the executable instruction enables the processor to execute the steps of the dynamic migration method of the database data.
According to yet another aspect of the embodiments of the present invention, there is provided a computer storage medium having at least one executable instruction stored therein, the executable instruction causing the processor to perform the steps of the above-described method for dynamically migrating database data.
According to the embodiment of the invention, the data to be migrated and the number of the clients to be migrated corresponding to the client fragments are obtained from the distributed cluster cache according to the client fragments; sequentially acquiring the data to be migrated corresponding to a client for any client fragment and migrating the data; and accumulating the migration client numbers until the migration client numbers are equal to the client data to be migrated, and converting a data management unit from a single client to a batch of clients with the same client fragments, so that the data management efficiency is improved, the migration process is simplified, and meanwhile, the dynamic migration of the memory database data can be realized without stopping.
The foregoing description is only an overview of the technical solutions of the embodiments of the present invention, and may be implemented according to the content of the specification, so that the technical means of the embodiments of the present invention can be more clearly understood, and the following specific embodiments of the present invention are given for clarity and understanding.
Drawings
Various other advantages and benefits will become apparent to those of ordinary skill in the art upon reading the following detailed description of the preferred embodiments. The drawings are only for purposes of illustrating the preferred embodiments and are not to be construed as limiting the invention. Also, like reference numerals are used to designate like parts throughout the figures. In the drawings:
Fig. 1 is a schematic flow chart of a dynamic migration method of database data according to an embodiment of the present invention;
FIG. 2 is a schematic diagram of client fragmentation of a dynamic migration method of database data according to an embodiment of the present invention;
fig. 3 is a schematic diagram illustrating a dynamic migration process of a dynamic migration method of database data in a memory according to an embodiment of the present invention;
fig. 4 is a schematic diagram illustrating a routing service access process of a dynamic migration method of database data according to an embodiment of the present invention;
fig. 5 is a schematic structural diagram of a dynamic migration device for database data according to an embodiment of the present invention;
FIG. 6 illustrates a schematic diagram of a computing device provided by an embodiment of the present invention.
Detailed Description
Exemplary embodiments of the present invention will be described in more detail below with reference to the accompanying drawings. While exemplary embodiments of the present invention are shown in the drawings, it should be understood that the present invention may be embodied in various forms and should not be limited to the embodiments set forth herein. Rather, these embodiments are provided so that this disclosure will be thorough and complete, and will fully convey the scope of the invention to those skilled in the art.
Fig. 1 is a flow chart illustrating a method for dynamically migrating database data according to an embodiment of the present invention. The dynamic migration method of the memory database data is mainly applied to the server. As shown in fig. 1, the dynamic migration method of the database data includes:
Step S11: and obtaining data to be migrated and the number of clients to be migrated corresponding to the client fragments from the distributed cluster cache according to the client fragments.
In the naming of the present invention, before step S11, a client slice is obtained according to a slice rule preset in a memory parameter library, where client slice=area code+routing client code (ID) mod client slice number. When the client data stored in the distributed memory database is initialized, namely when the function is started for the first time, newly-added business data and stock client data are subjected to splitting treatment again through decoupling and enter the physical database of the data, and then the data are refreshed/loaded into the distributed memory database. Initializing the memory parameter library and the data information of the data physical library. The newly added customer data and the stock customer data are subjected to customer slicing as shown in fig. 2, and business newly added customer data and stock customer data are subjected to once slicing treatment and solidification through decoupling according to slicing rules defined by a memory parameter library and enter a data physical library; the fragmentation information is stored into a distributed cluster cache (distributed memory database) by loading/refreshing.
When the state of the newly added customer data or the stock customer data changes, the newly added customer data and the stock customer data are subjected to one-time slicing processing through decoupling according to a preset slicing rule and are solidified from a business library to enter a data physical library; and storing the newly added client data and the stock client data after the slicing processing from the data physical library to a distributed memory database through loading or refreshing. Although the data amount of the stored client is huge, the stored data is simple, and meanwhile, the distributed memory database is adopted to store the data, so that the system stability can be improved.
In the embodiment of the invention, the client data is subjected to application transformation, and the applications such as routing service, a data communication router (Data Communication Router, dccRouter), an online charging flow, decoupling refreshing and the like are transformed, so that the client fragments are supported to be acquired through the routing service, and the data nodes are further acquired. The memory parameter library and the data physical library maintain the fragment data information, and mainly comprise a newly added migration state table, a service processing table and the like.
In step S11, when the access bottleneck is caused by the uneven distribution in the memory parameter library, the dynamic migration of the memory library data is realized based on the client data fragment route, and the fragment migration is started. Firstly initializing data, acquiring data to be migrated of any client fragment according to a record of inconsistent new and old containers in a client fragment definition table, and generating the data to be migrated of the client fragment according to a client migration table. Specifically, a record of inconsistent ID of a new container and an old container in a client partition definition table of a memory parameter library is obtained, and data to be migrated is obtained. After the data in the region equilibrium state table is initialized, the state of the region to be migrated is changed, and meanwhile, the client data to be migrated is generated according to the client migration table. The data initialization preparation is completed. Wherein, the new and old containers refer to the new and old data nodes storing the client data.
Step S12: and aiming at any client fragment, sequentially acquiring the data to be migrated corresponding to a client and migrating the data.
After initializing the data, the fragment migration is performed in sequence. Firstly, judging the state in a client migration table, and screening out client data to be migrated. Further, judging the associated clients, namely judging whether the piece of data to be migrated is associated data of the service access locking data; and merging and migrating the data to be migrated meeting the conditions in the distributed cluster cache, and accumulating the successfully migrated client data after success. Judging the data volume of the migration client, if not, repeating the steps, and waiting for unlocking the service locking data; and after the quantity is met, finishing dynamic migration. Specifically, the data to be migrated of any client and the associated client are sequentially fetched from the client partition, and merged migration is performed in a distributed cluster cache. In step S12, the data to be migrated of the client is sequentially fetched in the client partition; judging whether an associated client field of the client is empty according to the data to be migrated; if the associated client field is not null, acquiring the data to be migrated of the associated client corresponding to the associated client field; and if the data to be migrated of the client and the associated client are empty, merging and migrating the data to be migrated in a distributed cluster cache.
Step S13: and accumulating the migration client number until the migration client number is equal to the client data to be migrated.
And finally accumulating the migration client number, and if the migration client number is smaller than the client data to be migrated, repeating the step S12 until the migration client number is equal to the client data to be migrated. Thus, the dynamic data migration of the memory bank without stopping service is completed.
A more detailed live migration process is shown in fig. 3, comprising:
step S301: and starting data migration.
Step S302: initializing data.
And acquiring the data to be migrated of any client fragment according to the record of the inconsistency between the new container and the old container in the client fragment definition table, and generating the client data to be migrated of the client fragment according to the client migration table.
Step S303: and taking data to be migrated of any client in sequence.
And sequentially taking the data to be migrated of any client in the client fragments.
Step S304: and judging the migration state. If the migration status is that the migration is completed, directly returning to step S303; if the migration status is migration failure, step S305 is performed; if the migration status is to be migrated, step S306 is performed.
And judging the migration state of the acquired data to be migrated. If the migration status of the data to be migrated is completed, which means that the data to be migrated has been migrated, the process directly jumps to step S303, and the data to be migrated of the next client is sequentially fetched.
Step S305: the migration state table is changed. And then returns to step S303.
When the migration status of the data to be migrated is failure, the migration status table of the data to be migrated is changed, for example, to be changed into the state to be migrated.
Step S306: it is determined whether the associated client field is empty. If yes, step S307 is executed; if not, return to step S303.
When the migration state of the data to be migrated is the state to be migrated, the data to be migrated is required to be migrated, and at the moment, whether the associated client field is empty is judged to acquire the associated client of the client. If the associated client field is empty, indicating that the data to be migrated for the associated client for that client has been obtained, or that the client has no associated client. If the associated client field is not null, indicating that the piece of data to be migrated is associated data of the service access locking data, the process goes to step S303 to obtain associated data of the associated client.
Step S307: and merging and migrating the data to be migrated.
After the data to be migrated of the client and the associated client are obtained, the data to be migrated of the client and the associated client are combined and migrated in the distributed cluster cache.
Step S308: the number of mobile clients is accumulated.
After the migration is completed, the number of migration clients is accumulated.
Step S309: it is determined whether the number of migration clients is satisfied. If yes, go to step S310; if not, return to step S303.
I.e. whether the number of migration clients is equal to the previously acquired client data to be migrated. And if the data to be migrated of the client partition are equal, the data to be migrated of the client partition is indicated to be migrated. If not, the data to be migrated of the client partition is not migrated, and the process jumps to step S303, and the data to be migrated of the next client is acquired in sequence, and dynamic migration is continued.
Step S310: and (3) finishing.
And finishing the dynamic migration of the data to be migrated of the client fragments, and continuing the dynamic migration of the data to be migrated of other client fragments in sequence.
The embodiment of the invention carries out slicing according to the client routing ID and the defined slicing rule, supports the slicing processing mode, converts a data management unit from a single client to a batch of clients with the same client slicing, and can improve the data management efficiency, simplify the migration flow, reduce the interface calling times and basically realize automatic expansion when being applied to the dynamic migration of data with a memory bank and the routing access; the distributed cache has the advantages of high performance, high reliability and high concurrency, the distributed memory database is used for storing the client routing information, the processing efficiency of the routing can be greatly improved, the performance, the reliability and the concurrency of data access are improved, the reliability of the system is improved, and the high availability of the system is realized.
In the embodiment of the invention, after the application initiates the access request, the application responds to the access request initiated by the application, and the routing access inquiry is carried out according to the migration state of the client. Specifically, responding to an application to initiate an access request to a data node of a client, and inquiring whether a zone partition where the client is located is in a zone equilibrium state list according to a zone number corresponding to the client; if the zone of the client is not in the zone balanced state list, acquiring data nodes from a distributed cluster cache, and if the distributed cluster cache has no data nodes, acquiring the data nodes through a routing service; and if the zone of the client is in the zone balanced state list, acquiring the data node through a routing service. Therefore, the calling times of the routing service are reduced, and meanwhile, the access efficiency is improved. And acquiring the data node through a routing service, and simultaneously placing the acquired data node into the distributed cluster cache.
When the data nodes are obtained through the routing service, the routing service is started, and data of all migration areas in the memory parameter library are locked. Obtaining a client fragment from the distributed cluster cache, and judging whether the client fragment belongs to a migration zone fragment according to the client fragment to which the client belongs; if the client fragments belong to non-migration zone fragments, acquiring the data nodes according to migration states of the associated clients; and if the client fragments belong to migration zone fragments, inquiring the migration state in a client migration state table in the memory parameter library, attempting to access the data node of the client, and returning an access result according to the migration state of the client. If the client migration is completed, the access is successful, and the data node is returned; if the client is migrating, the query fails, returning to the migrating/processing failure.
If the client fragments belong to non-migration zone fragments, acquiring the data nodes according to the migration state of the associated client, and particularly inquiring whether associated data are being migrated according to the associated client service table; if yes, returning that the current data is being migrated; and if the client is in a service processing state, directly returning to the data node.
In the embodiment of the present invention, the complete process of routing service access is shown in fig. 4, and includes:
step S401: the application initiates an access request.
Step S402: and judging whether the current city is in balance or not. If not, then step S403 is performed; if so, the process proceeds to step S405.
And inquiring a regional equilibrium state table of the parameter library, and judging whether the current local city is migrated or not.
Step S403: the cache is accessed.
The current city is not migrated, the distributed cluster cache is accessed, and the data nodes are obtained from the distributed cluster cache. If the distributed cluster cache has no data node yet to be queried, the process jumps to execute step S405.
Step S404: and returning the data node.
And returning the data nodes acquired from the distributed cluster cache.
Step S405: the routing service is started.
Step S406: and locking the migration area.
And locking the data of all the migration areas in the memory parameter library.
Step S407: client fragments are obtained from REDIS.
Client tiles are obtained from a distributed cluster cache (REDIS). While also obtaining migration zone tiles.
Step S408: and judging whether the client belongs to the migration fragment. If not, executing step S409; if so, the process proceeds to step S412.
It is determined whether the client is in a migratedly distinguished patch.
Step S409: and querying a customer associated service table.
If the client belongs to the non-migration zone, directly inquiring the client association service table.
Step S410: and judging the service type.
Specifically, it is queried whether associated data is being migrated. If there is associated data being migrated, step S411 is performed; if no associated data is being migrated, i.e. the client is in a business process state, the process jumps to execute step S415.
Step S411: the return is migrating.
When the associated data is being migrated, returning that the current data is being migrated.
Step S412: the memory parameter library queries the client migration state table.
If the client belongs to the migration zone, the state in the client migration state table in the memory parameter library is inquired, and access attempt is carried out. The states in the client migration state table can be mainly divided into a migrated state, an in-migration state and a to-be-migrated state, wherein a new client can be regarded as the migrated state.
Step S413: and judging the query result.
And acquiring a query result of the access attempt, and judging whether the query is successful. If yes, jump to execute step S405; if not, step S414 is performed.
Step S414: return processing failed/is migrating.
If the client is in a migration state, access is denied, the query fails, and the current data is being migrated/processed to fail. And then jumps to step S408.
Step S415: and returning the data node.
And if the client is in the migrated state or the state to be migrated, the query is successful, and the acquired data node is returned. Specifically, when the client is in the migrated state, returning to the target data node; and returning to the current data node when the client is in a state to be migrated.
Step S416: unlocking the customer profile.
And unlocking the client data after the required data nodes are obtained. The embodiment of the invention converts a data management unit from a single client into a group of clients with the same client fragments, and applies the data migration and the dynamic migration of the memory bank data and the route access, simplifies the migration flow, reduces the interface call times, accurately identifies the data in the service access and the related client data thereof, locks the data through the route service, realizes the data migration of the dynamic memory bank and the parallel service access, can effectively prevent the data migration service from accessing the data, and realizes the non-stop dynamic migration; and the distributed memory database is used for storing the client routing information, so that the performance, reliability and concurrency of data access are improved.
According to the embodiment of the invention, the data to be migrated and the number of the clients to be migrated corresponding to the client fragments are obtained from the distributed cluster cache according to the client fragments; sequentially acquiring the data to be migrated corresponding to a client for any client fragment and migrating the data; and accumulating the migration client numbers until the migration client numbers are equal to the client data to be migrated, and converting a data management unit from a single client to a batch of clients with the same client fragments, so that the data management efficiency is improved, the migration process is simplified, and meanwhile, the dynamic migration of the memory database data can be realized without stopping.
Fig. 5 is a schematic structural diagram of a dynamic migration device for database data according to an embodiment of the present invention. As shown in fig. 5, the dynamic migration device for database data includes: a data acquisition unit 501, a live migration unit 502, a migration completion unit 503, a client sharding unit 504, and a routing service unit 505. Wherein:
the data obtaining unit 501 is configured to obtain data to be migrated and the number of clients to be migrated corresponding to a client partition from a distributed cluster cache according to the client partition; the dynamic migration unit 502 is configured to sequentially obtain, for any one of the client slices, the data to be migrated corresponding to a client, and perform migration; the migration completion unit 503 is configured to accumulate the migration number of clients until the migration number of clients is equal to the to-be-migrated client data.
In an alternative way, the live migration unit 502 is configured to: sequentially taking the data to be migrated of the client in the client fragments; judging whether an associated client field of the client is empty according to the data to be migrated; if the associated client field is not null, acquiring the data to be migrated of the associated client corresponding to the associated client field; and if the data to be migrated of the client and the associated client are empty, merging and migrating the data to be migrated in a distributed cluster cache.
In an alternative approach, the client tile unit 504 is configured to: when the state of the newly added customer data or the stock customer data is changed, the newly added customer data and the stock customer data are subjected to one-time slicing processing through decoupling according to a preset slicing rule and are solidified from a business library to enter a data physical library; and storing the newly added client data and the stock client data after the slicing processing from the data physical library to a distributed memory database through loading or refreshing.
In an alternative manner, the routing service unit 505 is configured to: responding to an application to initiate an access request to a data node of a client, and inquiring whether a local zone fragment of the client is in a zone equilibrium state list or not according to a zone number corresponding to the client; if the zone of the client is not in the zone balanced state list, acquiring data nodes from a distributed cluster cache, and if the distributed cluster cache has no data nodes, acquiring the data nodes through a routing service; and if the zone of the client is in the zone balanced state list, acquiring the data node through a routing service.
In an alternative manner, the routing service unit 505 is further configured to: starting a routing service, and locking data of all migration areas in the memory parameter library; judging whether the client fragments belong to migration zone fragments or not according to the client fragments to which the client belongs; if the client fragments belong to non-migration zone fragments, acquiring the data nodes according to migration states of the associated clients; and if the client fragments belong to migration zone fragments, inquiring the migration state in a client migration state table in the memory parameter library, attempting to access the data node of the client, and returning an access result according to the migration state of the client.
In an alternative manner, the routing service unit 505 is further configured to: inquiring whether associated data are being migrated according to the associated client service table; if yes, returning that the current data is being migrated; and if the client is in a service processing state, directly returning to the data node.
In an alternative manner, the routing service unit 505 is further configured to: if the client migration is completed, the access is successful, and the data node is returned; if the client is migrating, the query fails, returning to the migrating/processing failure.
According to the embodiment of the invention, the data to be migrated and the number of the clients to be migrated corresponding to the client fragments are obtained from the distributed cluster cache according to the client fragments; sequentially acquiring the data to be migrated corresponding to a client for any client fragment and migrating the data; and accumulating the migration client numbers until the migration client numbers are equal to the client data to be migrated, and converting a data management unit from a single client to a batch of clients with the same client fragments, so that the data management efficiency is improved, the migration process is simplified, and meanwhile, the dynamic migration of the memory database data can be realized without stopping.
The embodiment of the invention provides a nonvolatile computer storage medium, which stores at least one executable instruction, and the computer executable instruction can execute the dynamic migration method of the memory bank data in any method embodiment.
The executable instructions may be particularly useful for causing a processor to:
obtaining data to be migrated and the number of clients to be migrated corresponding to the client fragments from a distributed cluster cache according to the client fragments;
sequentially acquiring the data to be migrated corresponding to a client for any client fragment and migrating the data;
And accumulating the migration client number until the migration client number is equal to the client data to be migrated.
In one alternative, the executable instructions cause the processor to:
sequentially taking the data to be migrated of the client in the client fragments;
judging whether an associated client field of the client is empty according to the data to be migrated;
if the associated client field is not null, acquiring the data to be migrated of the associated client corresponding to the associated client field;
and if the data to be migrated of the client and the associated client are empty, merging and migrating the data to be migrated in a distributed cluster cache.
In one alternative, the executable instructions cause the processor to:
when the state of the newly added customer data or the stock customer data is changed, the newly added customer data and the stock customer data are subjected to one-time slicing processing through decoupling according to a preset slicing rule and are solidified from a business library to enter a data physical library;
and storing the newly added client data and the stock client data after the slicing processing from the data physical library to a distributed memory database through loading or refreshing.
In one alternative, the executable instructions cause the processor to:
responding to an application to initiate an access request to a data node of a client, and inquiring whether a local zone fragment of the client is in a zone equilibrium state list or not according to a zone number corresponding to the client;
if the zone of the client is not in the zone balanced state list, acquiring data nodes from a distributed cluster cache, and if the distributed cluster cache has no data nodes, acquiring the data nodes through a routing service;
and if the zone of the client is in the zone balanced state list, acquiring the data node through a routing service.
In one alternative, the executable instructions cause the processor to:
starting a routing service, and locking data of all migration areas in the memory parameter library;
judging whether the client fragments belong to migration zone fragments or not according to the client fragments to which the client belongs;
if the client fragments belong to non-migration zone fragments, acquiring the data nodes according to migration states of the associated clients;
and if the client fragments belong to migration zone fragments, inquiring the migration state in a client migration state table in the memory parameter library, attempting to access the data node of the client, and returning an access result according to the migration state of the client.
In one alternative, the executable instructions cause the processor to:
inquiring whether associated data are being migrated according to the associated client service table;
if yes, returning that the current data is being migrated;
and if the client is in a service processing state, directly returning to the data node.
In one alternative, the executable instructions cause the processor to:
if the client migration is completed, the access is successful, and the data node is returned;
if the client is migrating, the query fails, returning to the migrating/processing failure.
According to the embodiment of the invention, the data to be migrated and the number of the clients to be migrated corresponding to the client fragments are obtained from the distributed cluster cache according to the client fragments; sequentially acquiring the data to be migrated corresponding to a client for any client fragment and migrating the data; and accumulating the migration client numbers until the migration client numbers are equal to the client data to be migrated, and converting a data management unit from a single client to a batch of clients with the same client fragments, so that the data management efficiency is improved, the migration process is simplified, and meanwhile, the dynamic migration of the memory database data can be realized without stopping.
Embodiments of the present invention provide a computer program product comprising a computer program stored on a computer storage medium, the computer program comprising program instructions which, when executed by a computer, cause the computer to perform the method for dynamically migrating database data in any of the method embodiments described above.
The executable instructions may be particularly useful for causing a processor to:
obtaining data to be migrated and the number of clients to be migrated corresponding to the client fragments from a distributed cluster cache according to the client fragments;
sequentially acquiring the data to be migrated corresponding to a client for any client fragment and migrating the data;
and accumulating the migration client number until the migration client number is equal to the client data to be migrated.
In one alternative, the executable instructions cause the processor to:
sequentially taking the data to be migrated of the client in the client fragments;
judging whether an associated client field of the client is empty according to the data to be migrated;
if the associated client field is not null, acquiring the data to be migrated of the associated client corresponding to the associated client field;
And if the data to be migrated of the client and the associated client are empty, merging and migrating the data to be migrated in a distributed cluster cache.
In one alternative, the executable instructions cause the processor to:
when the state of the newly added customer data or the stock customer data is changed, the newly added customer data and the stock customer data are subjected to one-time slicing processing through decoupling according to a preset slicing rule and are solidified from a business library to enter a data physical library;
and storing the newly added client data and the stock client data after the slicing processing from the data physical library to a distributed memory database through loading or refreshing.
In one alternative, the executable instructions cause the processor to:
responding to an application to initiate an access request to a data node of a client, and inquiring whether a local zone fragment of the client is in a zone equilibrium state list or not according to a zone number corresponding to the client;
if the zone of the client is not in the zone balanced state list, acquiring data nodes from a distributed cluster cache, and if the distributed cluster cache has no data nodes, acquiring the data nodes through a routing service;
And if the zone of the client is in the zone balanced state list, acquiring the data node through a routing service.
In one alternative, the executable instructions cause the processor to:
starting a routing service, and locking data of all migration areas in the memory parameter library;
judging whether the client fragments belong to migration zone fragments or not according to the client fragments to which the client belongs;
if the client fragments belong to non-migration zone fragments, acquiring the data nodes according to migration states of the associated clients;
and if the client fragments belong to migration zone fragments, inquiring the migration state in a client migration state table in the memory parameter library, attempting to access the data node of the client, and returning an access result according to the migration state of the client.
In one alternative, the executable instructions cause the processor to:
inquiring whether associated data are being migrated according to the associated client service table;
if yes, returning that the current data is being migrated;
and if the client is in a service processing state, directly returning to the data node.
In one alternative, the executable instructions cause the processor to:
if the client migration is completed, the access is successful, and the data node is returned;
if the client is migrating, the query fails, returning to the migrating/processing failure.
According to the embodiment of the invention, the data to be migrated and the number of the clients to be migrated corresponding to the client fragments are obtained from the distributed cluster cache according to the client fragments; sequentially acquiring the data to be migrated corresponding to a client for any client fragment and migrating the data; and accumulating the migration client numbers until the migration client numbers are equal to the client data to be migrated, and converting a data management unit from a single client to a batch of clients with the same client fragments, so that the data management efficiency is improved, the migration process is simplified, and meanwhile, the dynamic migration of the memory database data can be realized without stopping.
FIG. 6 is a schematic diagram of a computing device according to an embodiment of the present invention, and the embodiment of the present invention is not limited to the specific implementation of the device.
As shown in fig. 6, the computing device may include: a processor 602, a communication interface (Communications Interface), a memory 606, and a communication bus 608.
Wherein: processor 602, communication interface 604, and memory 606 perform communication with each other via communication bus 608. Communication interface 604 is used to communicate with network elements of other devices, such as clients or other servers. The processor 602 is configured to execute the program 610, and may specifically perform relevant steps in the foregoing embodiment of the method for dynamically migrating database data.
In particular, program 610 may include program code including computer-operating instructions.
The processor 602 may be a central processing unit CPU, or a specific integrated circuit ASIC (Application Specific Integrated Circuit), or one or more integrated circuits configured to implement embodiments of the present invention. The device includes one or each processor, which may be the same type of processor, such as one or each CPU; but may also be different types of processors such as one or each CPU and one or each ASIC.
A memory 606 for storing a program 610. The memory 606 may comprise high-speed RAM memory or may further comprise non-volatile memory (non-volatile memory), such as at least one disk memory.
The program 610 may be specifically operable to cause the processor 602 to:
Obtaining data to be migrated and the number of clients to be migrated corresponding to the client fragments from a distributed cluster cache according to the client fragments;
sequentially acquiring the data to be migrated corresponding to a client for any client fragment and migrating the data;
and accumulating the migration client number until the migration client number is equal to the client data to be migrated.
In an alternative, the program 610 causes the processor to:
sequentially taking the data to be migrated of the client in the client fragments;
judging whether an associated client field of the client is empty according to the data to be migrated;
if the associated client field is not null, acquiring the data to be migrated of the associated client corresponding to the associated client field;
and if the data to be migrated of the client and the associated client are empty, merging and migrating the data to be migrated in a distributed cluster cache.
In an alternative, the program 610 causes the processor to:
when the state of the newly added customer data or the stock customer data is changed, the newly added customer data and the stock customer data are subjected to one-time slicing processing through decoupling according to a preset slicing rule and are solidified from a business library to enter a data physical library;
And storing the newly added client data and the stock client data after the slicing processing from the data physical library to a distributed memory database through loading or refreshing.
In an alternative, the program 610 causes the processor to:
responding to an application to initiate an access request to a data node of a client, and inquiring whether a local zone fragment of the client is in a zone equilibrium state list or not according to a zone number corresponding to the client;
if the zone of the client is not in the zone balanced state list, acquiring data nodes from a distributed cluster cache, and if the distributed cluster cache has no data nodes, acquiring the data nodes through a routing service;
and if the zone of the client is in the zone balanced state list, acquiring the data node through a routing service.
In an alternative, the program 610 causes the processor to:
starting a routing service, and locking data of all migration areas in the memory parameter library;
judging whether the client fragments belong to migration zone fragments or not according to the client fragments to which the client belongs;
If the client fragments belong to non-migration zone fragments, acquiring the data nodes according to migration states of the associated clients;
and if the client fragments belong to migration zone fragments, inquiring the migration state in a client migration state table in the memory parameter library, attempting to access the data node of the client, and returning an access result according to the migration state of the client.
In an alternative, the program 610 causes the processor to:
inquiring whether associated data are being migrated according to the associated client service table;
if yes, returning that the current data is being migrated;
and if the client is in a service processing state, directly returning to the data node.
In an alternative, the program 610 causes the processor to:
if the client migration is completed, the access is successful, and the data node is returned;
if the client is migrating, the query fails, returning to the migrating/processing failure.
According to the embodiment of the invention, the data to be migrated and the number of the clients to be migrated corresponding to the client fragments are obtained from the distributed cluster cache according to the client fragments; sequentially acquiring the data to be migrated corresponding to a client for any client fragment and migrating the data; and accumulating the migration client numbers until the migration client numbers are equal to the client data to be migrated, and converting a data management unit from a single client to a batch of clients with the same client fragments, so that the data management efficiency is improved, the migration process is simplified, and meanwhile, the dynamic migration of the memory database data can be realized without stopping.
The algorithms or displays presented herein are not inherently related to any particular computer, virtual system, or other apparatus. Various general-purpose systems may also be used with the teachings herein. The required structure for a construction of such a system is apparent from the description above. In addition, embodiments of the present invention are not directed to any particular programming language. It will be appreciated that the teachings of the present invention described herein may be implemented in a variety of programming languages, and the above description of specific languages is provided for disclosure of enablement and best mode of the present invention.
In the description provided herein, numerous specific details are set forth. However, it is understood that embodiments of the invention may be practiced without these specific details. In some instances, well-known methods, structures and techniques have not been shown in detail in order not to obscure an understanding of this description.
Similarly, it should be appreciated that in the above description of exemplary embodiments of the invention, various features of the embodiments of the invention are sometimes grouped together in a single embodiment, figure, or description thereof for the purpose of streamlining the disclosure and aiding in the understanding of one or more of the various inventive aspects. However, the disclosed method should not be construed as reflecting the intention that: i.e., the claimed invention requires more features than are expressly recited in each claim. Rather, as the following claims reflect, inventive aspects lie in less than all features of a single foregoing disclosed embodiment. Thus, the claims following the detailed description are hereby expressly incorporated into this detailed description, with each claim standing on its own as a separate embodiment of this invention.
Those skilled in the art will appreciate that the modules in the apparatus of the embodiments may be adaptively changed and disposed in one or more apparatuses different from the embodiments. The modules or units or components of the embodiments may be combined into one module or unit or component and, furthermore, they may be divided into a plurality of sub-modules or sub-units or sub-components. Any combination of all features disclosed in this specification (including any accompanying claims, abstract and drawings), and all of the processes or units of any method or apparatus so disclosed, may be used in combination, except insofar as at least some of such features and/or processes or units are mutually exclusive. Each feature disclosed in this specification (including any accompanying claims, abstract and drawings), may be replaced by alternative features serving the same, equivalent or similar purpose, unless expressly stated otherwise.
Furthermore, those skilled in the art will appreciate that while some embodiments herein include some features but not others included in other embodiments, combinations of features of different embodiments are meant to be within the scope of the invention and form different embodiments. For example, in the following claims, any of the claimed embodiments can be used in any combination.
It should be noted that the above-mentioned embodiments illustrate rather than limit the invention, and that those skilled in the art will be able to design alternative embodiments without departing from the scope of the appended claims. In the claims, any reference signs placed between parentheses shall not be construed as limiting the claim. The word "comprising" does not exclude the presence of elements or steps not listed in a claim. The word "a" or "an" preceding an element does not exclude the presence of a plurality of such elements. The invention may be implemented by means of hardware comprising several distinct elements, and by means of a suitably programmed computer. In the unit claims enumerating several means, several of these means may be embodied by one and the same item of hardware. The use of the words first, second, third, etc. do not denote any order. These words may be interpreted as names. The steps in the above embodiments should not be construed as limiting the order of execution unless specifically stated.
Claims (9)
1. A method for dynamically migrating database data in a memory, the method comprising:
when the state of the newly added customer data or the stock customer data is changed, the newly added customer data and the stock customer data are subjected to one-time slicing processing through decoupling according to a preset slicing rule and are solidified from a business library to enter a data physical library;
The newly added client data and the stock client data after the slicing processing are stored from the data physical library to a distributed memory database through loading or refreshing;
obtaining data to be migrated and the number of clients to be migrated corresponding to the client fragments from a distributed cluster cache according to the client fragments; the client shard = area code + routing client code (ID) mod client shard number;
sequentially acquiring the data to be migrated corresponding to a client for any client fragment and migrating the data;
and accumulating the migration client number until the migration client number is equal to the client data to be migrated.
2. The method according to claim 1, wherein for any of the client slices, sequentially acquiring and migrating the data to be migrated corresponding to a client, comprises:
sequentially taking the data to be migrated of the client in the client fragments;
judging whether an associated client field of the client is empty according to the data to be migrated;
if the associated client field is not null, acquiring the data to be migrated of the associated client corresponding to the associated client field;
and if the data to be migrated of the client and the associated client are empty, merging and migrating the data to be migrated in a distributed cluster cache.
3. The method according to claim 1, wherein the method further comprises:
responding to an application to initiate an access request to a data node of a client, and inquiring whether a local zone fragment of the client is in a zone equilibrium state list or not according to a zone number corresponding to the client;
if the zone of the client is not in the zone balanced state list, acquiring data nodes from a distributed cluster cache, and if the distributed cluster cache has no data nodes, acquiring the data nodes through a routing service;
and if the zone of the client is in the zone balanced state list, acquiring the data node through a routing service.
4. A method according to claim 3, wherein said obtaining said data node via a routing service comprises:
starting a routing service, and locking data of all migration areas in a memory parameter library;
judging whether the client fragments belong to migration zone fragments or not according to the client fragments to which the client belongs;
if the client fragments belong to non-migration zone fragments, acquiring the data nodes according to migration states of the associated clients;
And if the client fragments belong to migration zone fragments, inquiring the migration state in a client migration state table in the memory parameter library, attempting to access the data node of the client, and returning an access result according to the migration state of the client.
5. The method of claim 4, wherein the obtaining the data node according to the migration status of the associated client comprises:
inquiring whether associated data are being migrated according to the associated client service table;
if yes, returning that the current data is being migrated;
and if the client is in a service processing state, directly returning to the data node.
6. The method of claim 4, wherein the returning access results based on the migration status of the client comprises:
if the client migration is completed, the access is successful, and the data node is returned;
if the client is migrating, the query fails, returning to the migrating/processing failure.
7. A memory bank data dynamic migration apparatus, the apparatus comprising:
the client slicing unit is used for carrying out one-time slicing processing on the newly added client data and the stock client data through decoupling according to a preset slicing rule when the state of the newly added client data or the stock client data changes, and solidifying the newly added client data and the stock client data from a business library to enter a data physical library; the newly added client data and the stock client data after the slicing processing are stored from the data physical library to a distributed memory database through loading or refreshing;
The data acquisition unit is used for acquiring data to be migrated and the number of clients to be migrated corresponding to the client fragments from the distributed cluster cache according to the client fragments; the client shard = area code + routing client code (ID) mod client shard number;
the dynamic migration unit is used for sequentially acquiring the data to be migrated corresponding to one client for any client fragment and migrating the data;
and the migration completion unit is used for accumulating the migration client number until the migration client number is equal to the client data to be migrated.
8. A computing device, comprising: the device comprises a processor, a memory, a communication interface and a communication bus, wherein the processor, the memory and the communication interface complete communication with each other through the communication bus;
the memory is configured to store at least one executable instruction that causes the processor to perform the steps of the method for dynamically migrating database data according to any one of claims 1-6.
9. A computer storage medium having stored therein at least one executable instruction for causing a processor to perform the steps of the method for live migration of database data according to any one of claims 1 to 6.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010505942.0A CN113760858B (en) | 2020-06-05 | 2020-06-05 | Dynamic migration method and device for memory database data, computing equipment and storage equipment |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010505942.0A CN113760858B (en) | 2020-06-05 | 2020-06-05 | Dynamic migration method and device for memory database data, computing equipment and storage equipment |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN113760858A CN113760858A (en) | 2021-12-07 |
| CN113760858B true CN113760858B (en) | 2024-03-19 |
Family
ID=78784989
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202010505942.0A Active CN113760858B (en) | 2020-06-05 | 2020-06-05 | Dynamic migration method and device for memory database data, computing equipment and storage equipment |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN113760858B (en) |
Families Citing this family (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN115118604B (en) * | 2022-07-01 | 2023-04-11 | 杭州宇信数字科技有限公司 | Dynamic capacity expansion data migration method, device, system and medium |
| CN115550434B (en) * | 2022-09-29 | 2025-04-25 | 新浪技术（中国）有限公司 | A distributed cache system and method based on istio |
Citations (10)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN103345519A (en) * | 2013-07-11 | 2013-10-09 | 华为技术有限公司 | Method and device for data distribution of shared-nothing distributed database |
| CN103810265A (en) * | 2014-01-27 | 2014-05-21 | 南京邮电大学 | Database optimization method based on WiMAX local routing |
| CN105930389A (en) * | 2016-04-14 | 2016-09-07 | 北京京东尚科信息技术有限公司 | Method and system for transferring data |
| CN106844510A (en) * | 2016-12-28 | 2017-06-13 | 北京五八信息技术有限公司 | The data migration method and device of a kind of distributed experiment ＆ measurement system |
| CN107153680A (en) * | 2017-04-18 | 2017-09-12 | 北京思特奇信息技术股份有限公司 | A kind of method and system of the online expanding node of distributed memory database |
| WO2018059032A1 (en) * | 2016-09-30 | 2018-04-05 | 华为技术有限公司 | Data migration method for virtual node, and virtual node |
| CN109246198A (en) * | 2018-08-16 | 2019-01-18 | 杭州数梦工场科技有限公司 | A kind of cloud host-initiated control method and system based on distributed storage cluster |
| CN110580246A (en) * | 2019-07-30 | 2019-12-17 | 平安科技（深圳）有限公司 | Method and device for migrating data, computer equipment and storage medium |
| CN110674108A (en) * | 2019-08-30 | 2020-01-10 | 中国人民财产保险股份有限公司 | Data processing method and device |
| CN111125059A (en) * | 2019-12-17 | 2020-05-08 | 南京甄视智能科技有限公司 | Data migration method and device, storage medium and server |
Family Cites Families (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US10684999B2 (en) * | 2016-10-05 | 2020-06-16 | Sap Se | Multi-procedure support in data migration |
| CN108132949B (en) * | 2016-12-01 | 2021-02-12 | 腾讯科技（深圳）有限公司 | Data migration method and device in database cluster |
-
2020
- 2020-06-05 CN CN202010505942.0A patent/CN113760858B/en active Active
Patent Citations (11)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN103345519A (en) * | 2013-07-11 | 2013-10-09 | 华为技术有限公司 | Method and device for data distribution of shared-nothing distributed database |
| CN103810265A (en) * | 2014-01-27 | 2014-05-21 | 南京邮电大学 | Database optimization method based on WiMAX local routing |
| CN105930389A (en) * | 2016-04-14 | 2016-09-07 | 北京京东尚科信息技术有限公司 | Method and system for transferring data |
| WO2018059032A1 (en) * | 2016-09-30 | 2018-04-05 | 华为技术有限公司 | Data migration method for virtual node, and virtual node |
| CN107885758A (en) * | 2016-09-30 | 2018-04-06 | 华为技术有限公司 | The data migration method and dummy node of a kind of dummy node |
| CN106844510A (en) * | 2016-12-28 | 2017-06-13 | 北京五八信息技术有限公司 | The data migration method and device of a kind of distributed experiment ＆ measurement system |
| CN107153680A (en) * | 2017-04-18 | 2017-09-12 | 北京思特奇信息技术股份有限公司 | A kind of method and system of the online expanding node of distributed memory database |
| CN109246198A (en) * | 2018-08-16 | 2019-01-18 | 杭州数梦工场科技有限公司 | A kind of cloud host-initiated control method and system based on distributed storage cluster |
| CN110580246A (en) * | 2019-07-30 | 2019-12-17 | 平安科技（深圳）有限公司 | Method and device for migrating data, computer equipment and storage medium |
| CN110674108A (en) * | 2019-08-30 | 2020-01-10 | 中国人民财产保险股份有限公司 | Data processing method and device |
| CN111125059A (en) * | 2019-12-17 | 2020-05-08 | 南京甄视智能科技有限公司 | Data migration method and device, storage medium and server |
Non-Patent Citations (2)
| Title |
|---|
| 内存数据库迁移方法改进研究;李璋琪;电子技术与软件工程;第163卷(第17期);172-174 * |
| 非关系型数据库负载均衡策略研究;尹君;云南电力技术;第45卷(第03期);121-124 * |
Also Published As
| Publication number | Publication date |
|---|---|
| CN113760858A (en) | 2021-12-07 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US11709843B2 (en) | Distributed real-time partitioned MapReduce for a data fabric | |
| EP3674909B1 (en) | Data transaction processing method, device, and electronic device | |
| US10838875B2 (en) | System and method for managing memory for large keys and values | |
| CN113760858B (en) | Dynamic migration method and device for memory database data, computing equipment and storage equipment | |
| CN110321225B (en) | Load balancing method, metadata server and computer readable storage medium | |
| CN116150160B (en) | Adjustment method and device for database cluster processing nodes and storage medium | |
| CN111427931A (en) | Distributed query engine and method for querying relational database by using same | |
| US12177065B2 (en) | Method, apparatus, electronic device and storage medium for resource operation | |
| EP4057160B1 (en) | Data reading and writing method and device for database | |
| CN110162395B (en) | Memory allocation method and device | |
| CN111857979A (en) | Information management method, system, storage medium and equipment of distributed system | |
| CN110806942B (en) | Data processing method and device | |
| CN112286685B (en) | A method and device for resource allocation | |
| JP5603843B2 (en) | Database load balancer | |
| CN115002228B (en) | Service cascade calling method and device, electronic equipment and storage medium | |
| CN112579319A (en) | Service calling method and device based on LRU Cache optimization | |
| CN114205354B (en) | Event management system, event management method, server, and storage medium | |
| US11954069B2 (en) | Find operation for union-mounted systems | |
| CN112632114B (en) | Method, device and computing equipment for fast reading data by MPP database | |
| CN116541402A (en) | Database concurrent spin locking and unlocking optimization method and equipment | |
| CN115480816A (en) | Interface calling method and device, electronic equipment and readable storage medium | |
| CN108958967A (en) | A kind of method and server of data processing | |
| CN114647663A (en) | Resource processing method, device and system, electronic equipment and storage medium | |
| WO2025060018A1 (en) | System and methods to support scalability in a distributed online transactional processing database | |
| US12346310B2 (en) | Supporting database transactions in a distributed computing environment |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |