Multi concurrent (multi process) reads data files from the source table of the old core AS400, transcodes and generates standard data block files,
downloads and transmits them to the x86 server, and then imports the data into the distributed database in batches according to the original table structure
Every time a table is migrated, a signal is sent to the comparison system, and the system drives the comparison component to quickly compare
the field contents of the data table in the two sets of databases to complete the data comparison
Points consumed in this process:
- 1. The bandwidth performance of the network card is limited. The network card under AS400 is a Gigabit card
- 2. AS400 has a bottleneck in disk IO
- 3. During disassembly, some tables also need patch keys and large field conversion
In order to meet the requirements of data migration, one-time switching and real-time data comparison,
incremental data migration and comparison are required:
- 1. The incremental data of as / 400 is synchronized to the distributed database in quasi real time.
- 2. Speed: complete the synchronization of 500g database incremental log of as / 400 core system within 12 hours.
- 3. Consistency: the data before and after data synchronization is required to be completely consistent.
- 4. Ease of use: support manual pause and start, errors encountered during synchronization, log recording and breakpoint continuation.
The incremental data migration process is:
400 local mirror: deploy local mirror in the local machine room of as / 400 core system to synchronize the data changes on the local standby machine through Mimix.
Deploy jrn log acquisition program on the upper part of the mirror to collect incremental jrn logs in quasi real time and push them to the data synchronizer
Data synchronizer: after receiving the incremental jrn log of as / 400, it performs format analysis and transcoding,
then stores and sorts it, identifies the transaction window according to the data table, generates SQL, fills the partition key according to the requirements of the distributed database,
and sends it to the distributed database.
Distributed database: after receiving a single SQL statement sent by the synchronizer, the database agent completes the database write and update processing.
(incremental migration flowchart)
The incremental data comparison process is:
Analyze the historical information of the change record set of the change table in the jrn log, take the primary key information of the last change table,
extract data from the target distributed database, and conduct real-time and rolling comparison with the relevant records of the target database.
(Incremental comparison process)
Overall one-time switching flow chart:
(X86 core data migration process plan)
Core switching product tool chain:
1.Full migration of heterogeneous complex tables
The as / 400 core system extracts the complex table, converts the code system, parses the large field type, converts the data content,
supplements the data fragment key, and finally generates the insert statement and migrates the data to the distributed database in high concurrency and large quantities
under the connection.
2.Full data comparison of heterogeneous databases
In the static state of as / 400 core system and x86 distributed database, quickly compare the field contents of the full data table in the two databases
according to the specified data table range and field range.
3.Data log synchronization
Incrementally synchronize the database changes in the as / 400 core system to the distributed database to ensure that the data changes of the two
databases are completely consistent. The data synchronization process supports pause and restart. In case of failure, it can support continuous transmission at breakpoints.
The transaction consistency of the two databases needs to be ensured in the whole process.
4.Heterogeneous database sampling data comparison
Before system switching, the as / 400 core system and x86 distributed database continuously synchronize data,
verify the consistency of data synchronization through non-stop rolling comparison,
reduce the pressure of full data verification during system switching and reduce the switching time window.