[發(fā)明專利]大批量數(shù)據(jù)處理方法、裝置、計(jì)算機(jī)設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 201910367480.8
• 申請(qǐng)日: 2019-05-05
• 公開(kāi)（公告）號(hào): CN110263048A
• 公開(kāi)（公告）日: 2019-09-20
• 發(fā)明（設(shè)計(jì)）人: 孫強(qiáng);唐龍
• 申請(qǐng)（專利權(quán)）人: 平安科技（深圳）有限公司
• 主分類(lèi)號(hào): G06F16/23
• 分類(lèi)號(hào): G06F16/23;G06F16/951
• 代理公司: 深圳市精英專利事務(wù)所 44242
• 代理人: 林燕云

1.一種大批量數(shù)據(jù)處理方法，其特征在于，包括：

從預(yù)設(shè)數(shù)據(jù)庫(kù)中獲取所有待處理批次數(shù)據(jù)并對(duì)每個(gè)所述待處理批次數(shù)據(jù)分配批次號(hào)；

將其中一個(gè)批次號(hào)的所述待處理批次數(shù)據(jù)作為目標(biāo)批次數(shù)據(jù)，對(duì)所述目標(biāo)批次數(shù)據(jù)添加排他鎖并處理所述目標(biāo)批次數(shù)據(jù)；

若所述目標(biāo)批次數(shù)據(jù)處理完成，獲取所述目標(biāo)批次數(shù)據(jù)中的初始預(yù)設(shè)字段值并根據(jù)所述初始預(yù)設(shè)字段值將所述目標(biāo)批次數(shù)據(jù)提交至所述預(yù)設(shè)數(shù)據(jù)庫(kù)以釋放所述排他鎖；

根據(jù)所述批次號(hào)將下一批次號(hào)的所述待處理批次數(shù)據(jù)作為目標(biāo)批次數(shù)據(jù)進(jìn)行處理直至所有批次號(hào)的所述待處理批次數(shù)據(jù)全部處理完成。

2.根據(jù)權(quán)利要求1所述的大批量數(shù)據(jù)處理方法，其特征在于，所述從預(yù)設(shè)數(shù)據(jù)庫(kù)中獲取所有待處理批次數(shù)據(jù)并對(duì)每個(gè)所述待處理批次數(shù)據(jù)分配批次號(hào)，包括：

從預(yù)設(shè)數(shù)據(jù)庫(kù)中獲取所有待處理批次數(shù)據(jù)；

根據(jù)所述待處理批次數(shù)據(jù)的批次數(shù)量分配批次號(hào)；

根據(jù)所述批次號(hào)按照由小到大對(duì)所述待處理批次數(shù)據(jù)進(jìn)行排序。

3.根據(jù)權(quán)利要求1所述的大批量數(shù)據(jù)處理方法，其特征在于，所述將其中一個(gè)批次號(hào)的所述待處理批次數(shù)據(jù)作為目標(biāo)批次數(shù)據(jù)，對(duì)所述目標(biāo)批次數(shù)據(jù)添加排他鎖并處理所述目標(biāo)批次數(shù)據(jù)，包括：

將其中一個(gè)批次號(hào)的所述待處理批次數(shù)據(jù)作為目標(biāo)批次數(shù)據(jù)；

調(diào)用所述預(yù)設(shè)數(shù)據(jù)庫(kù)的排他鎖機(jī)制對(duì)所述目標(biāo)批次數(shù)據(jù)添加排他鎖；

對(duì)已添加所述排他鎖的所述目標(biāo)批次數(shù)據(jù)進(jìn)行處理；

對(duì)處理完成的所述目標(biāo)批次數(shù)據(jù)添加處理標(biāo)記。

4.根據(jù)權(quán)利要求1所述的大批量數(shù)據(jù)處理方法，其特征在于，所述獲取所述目標(biāo)批次數(shù)據(jù)中的初始預(yù)設(shè)字段值并根據(jù)所述初始預(yù)設(shè)字段值將所述目標(biāo)批次數(shù)據(jù)提交至所述預(yù)設(shè)數(shù)據(jù)庫(kù)以釋放所述排他鎖，包括：

從所述目標(biāo)批次數(shù)據(jù)中獲取初始預(yù)設(shè)字段值；

從所述預(yù)設(shè)數(shù)據(jù)庫(kù)中獲取所述目標(biāo)批次數(shù)據(jù)的當(dāng)前預(yù)設(shè)字段值；

將所述初始預(yù)設(shè)字段值與所述當(dāng)前預(yù)設(shè)字段值進(jìn)行對(duì)比；

若所述初始預(yù)設(shè)字段值與所述當(dāng)前預(yù)設(shè)字段值相同，則提交所述目標(biāo)批次數(shù)據(jù)至所述預(yù)設(shè)數(shù)據(jù)庫(kù)以釋放所述排他鎖。

5.根據(jù)權(quán)利要求3所述的大批量數(shù)據(jù)處理方法，其特征在于，所述根據(jù)所述批次號(hào)將下一批次號(hào)的所述待處理批次數(shù)據(jù)作為目標(biāo)批次數(shù)據(jù)進(jìn)行處理直至所有批次號(hào)的所述待處理批次數(shù)據(jù)全部處理完成，包括：

根據(jù)所述批次號(hào)獲取下一批次號(hào)的所述待處理批次數(shù)據(jù)；

判斷所述待處理批次數(shù)據(jù)是否存在所述處理標(biāo)記；

若所述待處理批次數(shù)據(jù)存在所述處理標(biāo)記，將下一批次號(hào)的所述待處理批次數(shù)據(jù)作為目標(biāo)批次數(shù)據(jù)進(jìn)行處理。

6.一種大批量數(shù)據(jù)處理裝置，其特征在于，包括：

分配單元，用于從預(yù)設(shè)數(shù)據(jù)庫(kù)中獲取所有待處理批次數(shù)據(jù)并對(duì)每個(gè)所述待處理批次數(shù)據(jù)分配批次號(hào)；

排他單元，用于將其中一個(gè)批次號(hào)的所述待處理批次數(shù)據(jù)作為目標(biāo)批次數(shù)據(jù)，對(duì)所述目標(biāo)批次數(shù)據(jù)添加排他鎖并處理所述目標(biāo)批次數(shù)據(jù)；

釋放單元，用于若所述目標(biāo)批次數(shù)據(jù)處理完成，獲取所述目標(biāo)批次數(shù)據(jù)中的初始預(yù)設(shè)字段值并根據(jù)所述初始預(yù)設(shè)字段值將所述目標(biāo)批次數(shù)據(jù)提交至所述預(yù)設(shè)數(shù)據(jù)庫(kù)以釋放所述排他鎖；

處理單元，用于根據(jù)所述批次號(hào)將下一批次號(hào)的所述待處理批次數(shù)據(jù)作為目標(biāo)批次數(shù)據(jù)進(jìn)行處理直至所有批次號(hào)的所述待處理批次數(shù)據(jù)全部處理完成。

7.根據(jù)權(quán)利要求6所述的大批量數(shù)據(jù)處理裝置，其特征在于，所述分配單元包括：

獲取子單元，用于從預(yù)設(shè)數(shù)據(jù)庫(kù)中獲取所有待處理批次數(shù)據(jù)；

分配子單元，用于根據(jù)所述待處理批次數(shù)據(jù)的批次數(shù)量分配批次號(hào)；

排序單元，用于根據(jù)所述批次號(hào)按照由小到大對(duì)所述待處理批次數(shù)據(jù)進(jìn)行排序。