mybatis单笔批量保存实体数据的方法

2023-09-17 16:48:05 317

这一篇主要介绍，如何保存实体数据。具体内容如下所示；

一，xml样例










查询条件英文名称
查询条件中文名称
查询条件值





被查询者姓名
被查询者证件号码

身份认证结果，1，一致2,不一致






姓名核查结果,有：一致、基本一致、不一致、无法核查
证件号码核查结果，有：一致、不一致、无法核查
手机号码核查结果:一致、无法核查
号码归属地
运营商1：中国电信2：中国移动3:中国联通






个人反欺诈综述信息




风险评分
风险等级，取值：高，中度，低
风险建议，取值：建议拒绝，建议复核，建议通过
命中类型：高风险名单、个人风险信息、信贷逾期名单、被机构查询信息、手机号码状态异常、手机号码低网龄、羊毛党名单、欺诈风险名单等等，可能为1个或多个





运营商1：中国电信2：中国移动3:中国联通
手机号码归属地
手机状态1：正常在用2:停机3：未启用4：已销号5-其他6：预销号
手机号码在网时长，如：在网时长不足1个月，1-2个月，3-6个月，7-12个月
号码注销时间





是否命中羊毛党名单，取值：0/1，0表示未命中羊毛党名单，1表示命中羊毛党名单




是否命中欺诈风险名单，取值：0/1，0表示未命中欺诈风险名单，1表示命中欺诈风险名单




是否命中高风险名单1：是，2：否






逾期本金，单位：以贷款基本信息的币种为准
逾期天数区间,取值区间：逾期1天（含）以上
逾期天数区间的总笔数





逾期本金，单位：以贷款基本信息的币种为准
逾期天数区间,取值区间：逾期1-6天，逾期7-29天，逾期30-59天，逾期60-89天，逾期90天（含）以上
逾期天数区间的笔数








概要汇总条数
司法案例信息条数
司法执行信息条数
司法失信信息条数
税务行政执法信息条数
催欠公告信息条数
网贷逾期信息条数








记录编号
标题
案件类型
审结年份，格式：YYYY
当事人类型






记录编号
标题
执行标的，单位：以币种为准
立案日期，格式YYYY-MM-DD






记录编号
标题
立案日期，格式YYYY-MM-DD
发布日期，格式YYYY-MM-DD






记录编号
标题
公告日期，格式YYYY-MM-DD


催欠公告信息概要信息0..1-->



记录编号
标题
发布日期，格式YYYY-MM-DD






记录编号
标题
发布日期，格式YYYY-MM-DD











单位类型名称
近1个月查询记录数
近3个月查询记录数
近6个月查询记录数
近12个月查询记录数
近18月查询记录数
近24月查询记录数




近1个月各单位类型查询记录总数
近3个月各单位类型查询记录总数
近6个月各单位类型查询记录总数
近12个月各单位类型查询记录总数
近18月各单位类型查询记录总数
近24月各单位类型查询记录总数

二，表结构设计

1，批次号：各表之间用最外层批次号关联。

2，主表：即把各层字段全部存在一个表中。

三，实体设计

分为三层：CisReportRoot,CisReportChild,ReportElement

publicclassCisReportRootextendsBasePojoimplementsSerializable{
privateStringdocId;
privateStringbatNo;//查询批次号
@JSONField(serialize=false)
privateStringxmlId;
privateCisReportChildcisReportChild;
/**
*2017/7/21.
*报告节点属性以及子节点
*/
publicclassCisReportChildextendsBasePojo{
/**
*报告生成结束时间
**/
privateStringbuildEndTime;
/**
*是否有系统错误true表示有false表示没有
**/
privateStringhasSystemError;
/**
*该客户是否被冻结
**/
privateStringisFrozen;
privateReportElementreportElement;

publicclassReportElementextendsBasePojo{
privateStringphone;
privatePoliceCheckInfopoliceCheckInfo;//身份认证
privateMobileCheckInfomobileCheckInfo;//个人手机号码核查
privatePersonAntiSpoofingDescInfopersonAntiSpoofingDescInfo;//个人反欺诈风险综述信息
privatePersonAntiSpoofingInfopersonAntiSpoofingInfo;//个人反欺诈风险评分信息
privateMobileStatusInfomobileStatusInfo;//手机号码状态信息
privateEconnoisserurInfoeconnoisserurInfo;//是否命中羊毛党名单
privateFraudRiskInfofraudRiskInfo;//是否命中欺诈风险名单
privatePersonRiskAssesspersonRiskAssess;//是否命中高风险名单
privateMicroNearlyThreeYearsOverdueInfomicroNearlyThreeYearsOverdueInfo;//网贷逾期信息
privatePersonRiskInfopersonRiskInfo;//风险信息
privateHistorySimpleQueryInfohistorySimpleQueryInfo;//个人近两年历史查询记录

四，代码

<1>单笔，批量无需主键

无论单笔还是批量都可以把数据存在map中，sql中通过map的键获取数据。

如：

privatevoidsavePersonRiskInfo(StringbatNo,PersonRiskInfopersonRiskInfo)throwsException{
Mapmap=newHashMap<>();
map.put("batNo",batNo);
//单笔
map.put("item",personRiskInfo);
pyMapper.savePersonRiskInfo(map);
if(!ListUtil.isEmpty(personRiskInfo.getAlList())){
//批量
map.put("list",personRiskInfo.getAlList());
pyMapper.saveAlInfoList(map);
}

sql:


//单笔

INSERTINTOTABLE_PERSON_RISK_INFO(BATNO,TOTLECOUNT,ALCOUNT,ZXCOUNT,SXCOUNT,SWCOUNT,CQGGCOUNT,WDYQCOUNT)
VALUES(#{batNo,jdbcType=VARCHAR},
#{item.totleCount,jdbcType=NUMERIC},
#{item.alCount,jdbcType=NUMERIC},#{item.zxCount,jdbcType=NUMERIC},#{item.sxCount,jdbcType=NUMERIC},
#{item.swCount,jdbcType=NUMERIC},#{item.cqggCount,jdbcType=NUMERIC},#{item.wdyqCount,jdbcType=NUMERIC})


//批量

INSERTINTOTABLE_MNTYOI(BATNO,OVERDUEAMOUNT,OVERDUEDAYS,OVERDUECOUNT)

(
SELECT#{batNo,jdbcType=VARCHAR},
#{item.overdueAmount,jdbcType=VARCHAR},
#{item.overdueDays,jdbcType=VARCHAR},
#{item.overdueCount,jdbcType=NUMERIC}
FROMDUAL
)



privateCisReportRootinvokePy(PyQueryBeanpyQueryBean)throwsException{
pyQueryBean.setQueryFromPy(QUERY_FROM_PY);
//callpyservice
CisReportRootcisReportRoot=queryCisReportFromPyServer(pyQueryBean);
cisReportRoot.getCisReportChild().getReportElement().setPhone(pyQueryBean.getPhone());
//cacheService.save(cisReportRoot);
//（1）保存数据
saveCisReport(cisReportRoot);
returncisReportRoot;
}

（1）保存数据

@Transactional(rollbackFor=Exception.class)
@Override
publicCisReportRootsaveCisReport(CisReportRootcisReportRoot)throwsException{
try{
ReportElementreportElement=cisReportRoot.getCisReportChild().getReportElement();
PersonRiskInfopersonRiskInfo=reportElement.getPersonRiskInfo();
//（2）主表，保存xml所有节点信息（不包含个人风险信息），保存单笔数据
pyMapper.saveCisReport(cisReportRoot);
if(SUCCESS.equals(cisReportRoot.getCisReportChild().getReportElement().getPersonRiskInfo().getTreatResult())){
savePersonRiskInfo(cisReportRoot.getBatNo(),personRiskInfo);
}
if(cisReportRoot.getCisReportChild().getReportElement().getHistorySimpleQueryInfo().getTreatResult().equals(SUCCESS)){
Mapmap=newHashMap<>();
//（3）保存批量数据
map.put("batNo",cisReportRoot.getBatNo());
if(!ListUtil.isEmpty(cisReportRoot.getCisReportChild().getReportElement().getHistorySimpleQueryInfo().getItemList())){
map.put("list",cisReportRoot.getCisReportChild().getReportElement().getHistorySimpleQueryInfo().getItemList());
pyMapper.saveHistorySimpleQueryInfoList(map);
}
if(!ListUtil.isEmpty(cisReportRoot.getCisReportChild().getReportElement().getMicroNearlyThreeYearsOverdueInfo().getList())){
map.put("list",cisReportRoot.getCisReportChild().getReportElement().getMicroNearlyThreeYearsOverdueInfo().getList());
pyMapper.saveMicroNearlyThreeYearsOverdueInfoList(map);
}
}
returncisReportRoot;
}catch(Exceptione){
logger.error("saveCisReport@PyserviceImpl_Exception",e);
throwe;
}
}

（2）保存主表


INSERTINTOTABLE_CISREPORT
(BATNO,BUILDENDTIME,ISFROZEN,
MCI_NAMECHECKRESULT,MCI_AREAINFO,MCI_DOCUMENTNOCHECKRESULT,MCI_OPERATOR,MCI_PHONECHECKRESULT,
PCI_DOCUMENTNO,PCI_NAME,PCI_RESULT,
PASDI_DESC,
PASI_HITTYPES,PASI_RISKLEVEL,PASI_RISKSCORE,PASI_RISKSUGGEST,
MS_AREAINFO,MS_CAnCELTIME,MS_OPERATOR,MS_PHONESTATUS,MS_TIMELENGTH,
ECONNOISSERUR,
FRAUDRISK,
PRA_CHECKRESULT,
MNTYOI_OVERDUEAMOUNT,MNTYOI_OVERDUECOUNT,MNTYOI_OVERDUEDAYS,
HS_LAST1MONTH,HS_LAST3MONTH,HS_LAST6MONTH,HS_LAST12MONTH,HS_LAST18MONTH,HS_LAST24MONTH,
PHONE,XMLID)
VALUES
(#{batNo,jdbcType=VARCHAR},
to_date(#{cisReportChild.buildEndTime},'yyyy-MM-ddhh24:mi:ss'),
#{cisReportChild.isFrozen,jdbcType=VARCHAR},
#{cisReportChild.reportElement.mobileCheckInfo.nameCheckResult,jdbcType=VARCHAR},
#{cisReportChild.reportElement.mobileCheckInfo.areaInfo,jdbcType=VARCHAR},
#{cisReportChild.reportElement.mobileCheckInfo.documentNoCheckResult,jdbcType=VARCHAR},
#{cisReportChild.reportElement.mobileCheckInfo.operator,jdbcType=NUMERIC},
#{cisReportChild.reportElement.mobileCheckInfo.phoneCheckResult,jdbcType=VARCHAR},
#{cisReportChild.reportElement.policeCheckInfo.documentNo,jdbcType=VARCHAR},
#{cisReportChild.reportElement.policeCheckInfo.name,jdbcType=VARCHAR},
#{cisReportChild.reportElement.policeCheckInfo.result,jdbcType=NUMERIC},
#{cisReportChild.reportElement.personAntiSpoofingDescInfo.personAntiSpoofingDesc,jdbcType=VARCHAR},
#{cisReportChild.reportElement.personAntiSpoofingInfo.hitTypes,jdbcType=VARCHAR},
#{cisReportChild.reportElement.personAntiSpoofingInfo.riskLevel,jdbcType=VARCHAR},
#{cisReportChild.reportElement.personAntiSpoofingInfo.riskScore,jdbcType=VARCHAR},
#{cisReportChild.reportElement.personAntiSpoofingInfo.suggest,jdbcType=VARCHAR},
#{cisReportChild.reportElement.mobileStatusInfo.areaInfo,jdbcType=VARCHAR},
#{cisReportChild.reportElement.mobileStatusInfo.cancelTime,jdbcType=VARCHAR},
#{cisReportChild.reportElement.mobileStatusInfo.operator,jdbcType=NUMERIC},
#{cisReportChild.reportElement.mobileStatusInfo.phoneStatus,jdbcType=NUMERIC},
#{cisReportChild.reportElement.mobileStatusInfo.timeLength,jdbcType=VARCHAR},
#{cisReportChild.reportElement.econnoisserurInfo.state,jdbcType=NUMERIC},
#{cisReportChild.reportElement.fraudRiskInfo.state,jdbcType=NUMERIC},
#{cisReportChild.reportElement.personRiskAssess.checkResult,jdbcType=NUMERIC},
#{cisReportChild.reportElement.microNearlyThreeYearsOverdueInfo.overdueAmount,jdbcType=VARCHAR},
#{cisReportChild.reportElement.microNearlyThreeYearsOverdueInfo.overdueCount,jdbcType=NUMERIC},
#{cisReportChild.reportElement.microNearlyThreeYearsOverdueInfo.overdueDays,jdbcType=VARCHAR},
#{cisReportChild.reportElement.historySimpleQueryInfo.totalCount.last1Month,jdbcType=NUMERIC},
#{cisReportChild.reportElement.historySimpleQueryInfo.totalCount.last3Month,jdbcType=NUMERIC},
#{cisReportChild.reportElement.historySimpleQueryInfo.totalCount.last6Month,jdbcType=NUMERIC},
#{cisReportChild.reportElement.historySimpleQueryInfo.totalCount.last12Month,jdbcType=NUMERIC},
#{cisReportChild.reportElement.historySimpleQueryInfo.totalCount.last18Month,jdbcType=NUMERIC},
#{cisReportChild.reportElement.historySimpleQueryInfo.totalCount.last24Month,jdbcType=NUMERIC},
#{cisReportChild.reportElement.phone,jdbcType=VARCHAR},
#{xmlId,jdbcType=VARCHAR}
)

（3）保存批量数据（不自动生成主键）



INSERTINTO
TABLE_HISTORY_SIMPLE_QUERY
(BATNO,UNIT_MEMBER,LAST1MONTH,LAST3MONTH,LAST6MONTH,LAST12MONTH,LAST18MONTH,LAST24MONTH)

(
SELECT
#{batNo,jdbcType=VARCHAR},
#{item.unitMember,jdbcType=VARCHAR},
#{item.last1Month,jdbcType=NUMERIC},#{item.last3Month,jdbcType=NUMERIC},
#{item.last6Month,jdbcType=NUMERIC},#{item.last12Month,jdbcType=NUMERIC},
#{item.last18Month,jdbcType=NUMERIC},#{item.last24Month,jdbcType=NUMERIC}
FROMDUAL
)

<2>单笔，批量需要插入主键

单笔含主键

DataServiceDetailResultdataServiceDetailResult=tdService.getDataServiceDetailResult(tdReportRoot);
intn=tdDataServiceMapper.insertDataServiceDetailResult(dataServiceDetailResult);





selectSEQ_ICS_TD_DATASERVICE.nextvalasidfromdual

insertintoICS_TD_DATASERVICE(ID,RECORDID,REASON_DESC,REASON_CODE,
SUCCESS)
values(#{id,jdbcType=DECIMAL},#{recordId,jdbcType=DECIMAL},#{reasonDesc,jdbcType=VARCHAR},
#{reasonCode,jdbcType=VARCHAR},
#{success,jdbcType=DECIMAL})

批量保存包含主键

if(!ListUtil.isEmpty(interfacesList)){
map.put("recordId",id);
map.put("list",interfacesList);
tdDataServiceMapper.addBatchInterfaces(map);
}

sql:




insertintoICS_TD_INTERFACES(ID,RECORDID,TYPE)
SELECTSEQ_ICS_TD_INTERFACES.nextvalID,A.*
FROM(

SELECT
#{recordId,jdbcType=DECIMAL},
#{item.type,jdbcType=VARCHAR}
FROMDUAL

)A

总结

以上所述是小编给大家介绍的mybatis单笔批量保存实体数据的方法，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对毛票票网站的支持！

mybatis单笔批量保存实体数据的方法

热门推荐

随机推荐