公开(公告)号：CN119166363B

公开(公告)日：2025-04-11

申请号：CN202411641459.X

申请日：2024-11-18

Applicant: 苏州吉呗思数据技术有限公司 ,  天津南大通用数据技术股份有限公司

Inventor： 侯晓凡

IPC: G06F9/50 ,  G06F16/27

Abstract: 本发明提供了一种基于分布式数据库的请求处理方法及装置，主要涉及计算机技术领域，尤其涉及数据库技术领域。该方法包括：响应于用户对分布式数据库的访问请求，根据上述访问请求包括的查询语句，确定执行树结构；在至少一个上述执行节点中目标执行节点的操作类型为数据迁移操作类型的情况下为上述目标执行节点创建前置节点，得到目标执行树结构；在上述前置节点的数目小于或等于节点数目阈值的情况下，基于每个上述前置节点读取的数据量、每个上述执行节点执行上述查询语句的资源消耗量，确定上述目标执行树结构的执行代价；在上述目标执行树结构的执行代价大于或者等于资源消耗阈值的情况下，基于限流策略对上述访问请求进行限流处理。

公开(公告)号：CN119166363A

公开(公告)日：2024-12-20

申请号：CN202411641459.X

申请日：2024-11-18

Applicant: 苏州吉呗思数据技术有限公司 ,  天津南大通用数据技术股份有限公司

Inventor： 侯晓凡

IPC: G06F9/50 ,  G06F16/27

Abstract: 本发明提供了一种基于分布式数据库的请求处理方法及装置，主要涉及计算机技术领域，尤其涉及数据库技术领域。该方法包括：响应于用户对分布式数据库的访问请求，根据上述访问请求包括的查询语句，确定执行树结构；在至少一个上述执行节点中目标执行节点的操作类型为数据迁移操作类型的情况下为上述目标执行节点创建前置节点，得到目标执行树结构；在上述前置节点的数目小于或等于节点数目阈值的情况下，基于每个上述前置节点读取的数据量、每个上述执行节点执行上述查询语句的资源消耗量，确定上述目标执行树结构的执行代价；在上述目标执行树结构的执行代价大于或者等于资源消耗阈值的情况下，基于限流策略对上述访问请求进行限流处理。

公开(公告)号：CN118332010A

公开(公告)日：2024-07-12

申请号：CN202410755952.8

申请日：2024-06-13

Applicant: 天津南大通用数据技术股份有限公司

Inventor： 易成龙 ,  张益 ,  吴明远 ,  侯晓凡 ,  赵健

IPC: G06F16/2453 ,  G06F16/27 ,  G06F16/2455 ,  G06F16/242 ,  G06F9/50

Abstract: 本发明提供了一种用于分布式数据库的数据批量插入方法，客户端构建并发送包含参数化SQL语句的P消息至数据库，数据库接收P消息后解析其SQL语句，并生成对应的查询树，该查询树被缓存到本地；客户端向数据库发送U消息，数据库利用查询树解析U消息中的数据，使用数据的分片键字段和hash函数确定目标数据节点，进行路由计算；数据库将根据hash值将同一数据节点的数据组打包到新的U消息中，并将此U消息批量发送到对应的数据节点中进行数据插入；遍历T2中所有已确定的数据节点以批量接收插入的U消息，完成数据插入过程。本发明有益效果：显著提升批量数据插入的效率和系统响应速度。

公开(公告)号：CN118332010B

公开(公告)日：2024-10-11

申请号：CN202410755952.8

申请日：2024-06-13

Applicant: 天津南大通用数据技术股份有限公司

Inventor： 易成龙 ,  张益 ,  吴明远 ,  侯晓凡 ,  赵健

IPC: G06F16/2453 ,  G06F16/27 ,  G06F16/2455 ,  G06F16/242 ,  G06F9/50

Abstract: 本发明提供了一种用于分布式数据库的数据批量插入方法，客户端构建并发送包含参数化SQL语句的P消息至数据库，数据库接收P消息后解析其SQL语句，并生成对应的查询树，该查询树被缓存到本地；客户端向数据库发送U消息，数据库利用查询树解析U消息中的数据，使用数据的分片键字段和hash函数确定目标数据节点，进行路由计算；数据库将根据hash值将同一数据节点的数据组打包到新的U消息中，并将此U消息批量发送到对应的数据节点中进行数据插入；遍历T2中所有已确定的数据节点以批量接收插入的U消息，完成数据插入过程。本发明有益效果：显著提升批量数据插入的效率和系统响应速度。