一种逻辑复制槽的同步方法和相关装置与流程

本申请涉及数据处理领域，特别是涉及一种逻辑复制槽的同步方法和相关装置。

背景技术：

1、目前，出于灾备的目的，数据中心可以包括一个主数据库和至少一个备用数据库，这样在主数据库异常时，备用数据库可以作为新的主数据库继续提供数据服务。用户在创建逻辑订阅时，可以创建订阅内容对应的逻辑复制槽(slot)，在相关内容产生变化时订阅方通过逻辑复制槽可以获取到相关内容的变化信息。

2、然而目前在将备用数据库作为新的主数据库时，需要基于新的主数据库重新创建逻辑复制槽建立发布订阅，操作较为繁琐。

技术实现思路

1、为了解决上述技术问题，本申请提供了一种逻辑复制槽的同步方法和相关装置，实现了主数据库和备用数据库之前的逻辑复制槽的同步，简化数据库切换后的操作。

2、本申请实施例公开了如下技术方案：

3、一方面，本申请实施例提供了一种逻辑复制槽的同步方法，所述方法包括：

4、在第一数据库中的目标逻辑复制槽的信息存在更新时，确定所述目标逻辑复制槽的更新后的第一复制槽信息，所述目标逻辑复制槽用于向所述目标逻辑复制槽对应的订阅端提供数据服务；

5、若所述目标逻辑复制槽的可同步标识为第一标识，通过同步操作在所述第二数据库中得到所述目标逻辑复制槽的与所述第一复制槽信息对应的第二复制槽信息；

6、若所述第一数据库出障，通过所述第二数据库根据所述第二复制槽信息，向所述目标逻辑复制槽对应的订阅端提供数据服务。

7、另一方面，本申请提供一种逻辑复制槽的同步装置，所述装置包括：

8、复制槽信息确定单元，用于在第一数据库中的目标逻辑复制槽的信息存在更新时，确定所述目标逻辑复制槽的更新后的第一复制槽信息，所述目标逻辑复制槽用于向所述目标逻辑复制槽对应的订阅端提供数据服务；

9、同步单元，用于若所述目标逻辑复制槽的可同步标识为第一标识，通过同步操作在所述第二数据库中得到所述目标逻辑复制槽的与所述第一复制槽信息对应的第二复制槽信息；

10、数据服务提供单元，用于若所述第一数据库出障，通过所述第二数据库根据所述第二复制槽信息，向所述目标逻辑复制槽对应的订阅端提供数据服务。

11、另一方面，本申请提供一种计算机设备，所述设备包括处理器以及存储器：

12、所述存储器用于存储计算机程序，并将所述计算机程序传输给所述处理器；

13、所述处理器用于根据所述计算机程序中的指令执行上述方面所述的逻辑复制槽的同步方法。

14、另一方面，本申请实施例提供了一种计算机可读存储介质，所述计算机可读存储介质用于存储计算机程序，所述计算机程序用于执行上述方面所述的逻辑复制槽的同步方法。

15、另一方面，本申请实施例提供了一种包括计算机程序的计算机程序产品，当其在计算机设备上运行时，使得所述计算机设备执行所述的逻辑复制槽的同步方法。

16、由上述技术方案可以看出，在第一数据库中的目标逻辑复制槽的信息存在更新时，确定目标逻辑复制槽的更新后的第一复制槽信息，目标逻辑复制槽用于向目标逻辑复制槽对应的订阅端提供数据服务，若目标逻辑复制槽的可同步标识为第一标识，通过同步操作在第二数据库中得到目标逻辑复制槽的与第一复制槽信息对应的第二复制槽信息，针对于特定的目标逻辑复制槽，可以实现不同数据库之间的复制槽信息的同步，相比于对于各个逻辑复制槽均进行复制槽信息的同步而言，减少第二数据库的资源消耗，若第一数据库出现故障，由于第二数据库已经同步到目标逻辑复制槽的复制槽信息，因此可以基于复制槽信息接替第一数据库向目标逻辑复制槽对应的订阅端提供数据服务，节省了在第二数据库重新建立目标逻辑复制槽的操作，且可以保证数据服务的不中断，降低操作的复杂度，提高了数据服务的流畅度。

技术特征：

1.一种逻辑复制槽的同步方法，其特征在于，所述方法包括：

2.根据权利要求1所述的方法，其特征在于，所述若所述目标逻辑复制槽的可同步标识为第一标识，通过同步操作在所述第二数据库中得到所述目标逻辑复制槽的与所述第一复制槽信息对应的第二复制槽信息，包括：

3.根据权利要求2所述的方法，其特征在于，所述若所述目标逻辑复制槽的可同步标识为第一标识，根据所述第一复制槽信息生成所述第一复制槽信息对应的第一物理日志，包括：

4.根据权利要求2所述的方法，其特征在于，所述在所述第二数据库中根据来自于所述第一数据库的所述第一物理日志，确定所述目标逻辑复制槽的与所述第一复制槽信息对应的第二复制槽信息，包括：

5.根据权利要求1所述的方法，其特征在于，所述若所述目标逻辑复制槽的可同步标识为第一标识，通过同步操作在所述第二数据库中得到所述目标逻辑复制槽的与所述第一复制槽信息对应的第二复制槽信息，包括：

6.根据权利要求5所述的方法，其特征在于，所述方法还包括：

7.根据权利要求1-6任一项所述的方法，其特征在于，所述方法还包括：

8.根据权利要求7所述的方法，其特征在于，所述若所述第一数据库出现故障，通过所述第二数据库根据所述第二复制槽信息，向所述目标逻辑复制槽对应的订阅端提供数据服务，包括：

9.根据权利要求8所述的方法，其特征在于，所述响应于来自所述订阅端的逻辑复制指示，确定所述目标逻辑复制槽的第三复制槽信息，包括：

10.根据权利要求8所述的方法，其特征在于，所述响应于来自所述订阅端的逻辑复制指示，确定所述目标逻辑复制槽的第三复制槽信息，包括：

11.根据权利要求1-6任一项所述的方法，其特征在于，所述在第一数据库中的目标逻辑复制槽的信息存在更新时，确定所述目标逻辑复制槽的更新后的第一复制槽信息，包括：

12.一种逻辑复制槽的同步装置，其特征在于，所述装置包括：

13.一种计算机设备，其特征在于，所述计算机设备包括处理器以及存储器：

14.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质用于存储计算机程序，所述计算机程序用于执行权利要求1-11中任意一项所述的逻辑复制槽的同步方法。

15.一种包括计算机程序的计算机程序产品，其特征在于，当其在计算机设备上运行时，使得所述计算机设备执行权利要求1-11中任意一项所述的逻辑复制槽的同步方法。

技术总结
本申请公开了一种逻辑复制槽的同步方法和相关装置，在第一数据库中的目标逻辑复制槽的信息存在更新时，确定目标逻辑复制槽的更新后的第一复制槽信息，目标逻辑复制槽用于向目标逻辑复制槽对应的订阅端提供数据服务，若目标逻辑复制槽的可同步标识为第一标识，通过同步操作在第二数据库中得到目标逻辑复制槽的与第一复制槽信息对应的第二复制槽信息，针对于特定的目标逻辑复制槽实现不同数据库之间的复制槽信息的同步，减少第二数据库的资源消耗，若第一数据库出现故障，第二数据库已经同步到目标逻辑复制槽的复制槽信息，则基于复制槽信息向目标逻辑复制槽对应的订阅端提供数据服务，降低操作的复杂度，提高了数据服务的流畅度。

技术研发人员：施博文
受保护的技术使用者：腾讯科技（成都）有限公司
技术研发日：
技术公布日：2024/9/23