1 .一种数据库的数据迁移方法,包括:
获取源端数据库的待同步的数据库对象;
将所述待同步的数据库对象放入预设的双向队列中;
开启同步线程,所述同步线程包括至少一个从所述双向队列的一端读取数据的第一线
程,以及至少一个从所述双向队列的另一端读取数据的第二线程;
利用所述第一线程和所述第二线程分别从所述双向队列的两端读取数据库对象;
将读取出的数据库对象迁移至目标端数据库。
2 .根据权利要求1所述的数据库的数据迁移方法,其中,所述获取源端数据库的待同步
的数据库对象的步骤之后包括:
检测到获取到预设数量的数据库对象;
根据预设规则对所有所述数据库对象进行排序。
3 .根据权利要求2所述的数据库的数据迁移方法,其中,所述根据预设规则对所有所述
数据库对象进行排序的步骤包括:
根据数据量大小对所有所述数据库对象进行排序。
4 .根据权利要求2所述的数据库的数据迁移方法,其中,所述将所述待同步的数据库对
象放入预设的双向队列中的步骤包括:
将所有所述数据库对象按照排序顺序放入所述双向队列中。
5 .根据权利要求1所述的数据库的数据迁移方法,其中,所述将所述待同步的数据库对
象放入预设的双向队列中的步骤之前包括:
检查所述待同步的数据库对象的数据量是否超出预设阈值,若是,将所述数据量超出
预设阈值的数据库对象进行拆分。
6 .根据权利要求1所述的数据库的数据迁移方法,其中,所述第一线程和所述第二线程
仅用于从所述双向队列读取数据库对象,所述开启同步线程的步骤包括:
开启预设的读线程池和写线程池,所述读线程池包括至少一个所述第一线程和至少一
个所述第二线程,所述写线程池包括至少一个第一写线程和至少一个第二写线程,所述第
一写线程用于将所述第一线程读取的数据库对象写入所述目标端数据库,所述第二写线程
用于将所述第二线程读取的数据库对象写入所述目标端数据库。
7 .根据权利要求1所述的数据库的数据迁移方法,其中,所述将所述待同步的数据库对
象放入预设的双向队列中的步骤包括:
判断所述数据库对象是否大于设定阈值,若是,将所述数据库对象从所述双向队列的
第一端放入所述双向队列中,若否,将所述数据库对象从所述双向队列的第二端放入所述
双向队列中。
8.一种计算机设备,包括存储器、处理器及存储在所述存储器上并在所述处理器上运
行的计算机可执行程序,并且所述处理器执行所述计算机可执行程序时实现根据权利要求
1至7任一项所述的数据库的数据迁移方法。
9 .一种计算机可读存储介质,其上存储有计算机可执行程序,所述计算机可执行程序
被处理器执行时实现根据权利要求1至7任一项所述的数据库的数据迁移方法。
10.一种计算机程序产品,包括计算机可执行程序,所述计算机可执行程序被处理器执
行时实现根据权利要求1至7任一项所述的数据库的数据迁移方法。
权 利 要 求 书
1/1 页
2
评论