查看: 1473|回复: 0

[Java代码] mybatis单笔批量保存实体数据的方法

发表于 2018-2-25 08:00:00

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

一,xml样例

  1. <?xml version="1.0" encoding="GBK"?>
  2. <!-- 1..1 -->
  3. <cisReports batNo="查询批次号" unitName="查询单位名称" subOrgan="分支机构名称" queryUserID="查询操作员登录名" queryCount="查询请求数量" receiveTime="查询申请时间,格式YYYYMMDD HH24:mm:ss">
  4. <!-- 以下为每个查询申请的查询结果 1..n -->
  5. <cisReport reportID="报告编号" buildEndTime="报告生成结束时间,格式YYYY-MM-DD HH24:mm:ss" queryReasonID="查询原因ID,详见数据字典" subReportTypes="查询的收费子报告ID,多个收费子报告ID用逗号分隔" treatResult="对应的收费子报告收费次数,与subReportTypes一一对应,为大于等于0的值的集合,用逗号分隔"
  6. subReportTypesShortCaption="查询的收费子报告中文名称 " refID="引用ID,为查询申请条件中的引用ID" hasSystemError="有否系统错误,true:有错误,false:无错误"
  7. isFrozen="该客户是否被冻结,true:被冻结,false:未被冻结">
  8. <!-- 1查询条件信息 1..1 -->
  9. <queryConditions>
  10. <!-- 1..n -->
  11. <item>
  12. <name>查询条件英文名称</name>
  13. <caption>查询条件中文名称</caption>
  14. <value>查询条件值</value>
  15. </item>
  16. </queryConditions>
  17. <!--2身份认证 1..1 -->
  18. <policeCheckInfo subReportType="10602" subReportTypeCost="96040" treatResult="子报告查询状态,1:查得,2:未查得,3:其他原因未查得" treatErrorCode ="treatResult=3时的错误代码,详见数据字典,treatResult!=3时,该属性不存在" errorMessage="treatResult=3时的错误描述信息,treatResult!=3时,该属性的值为空">
  19. <item>
  20. <name>被查询者姓名</name>
  21. <documentNo>被查询者证件号码</documentNo>
  22. <!--1,一致 2,不一致 treatResult为3时为空-->
  23. <result>身份认证结果,1,一致 2,不一致</result>
  24. </item>
  25. </policeCheckInfo>
  26. <!-- 3个人手机号码核查 1..1 -->
  27. <mobileCheckInfo subReportType="13612" subReportTypeCost="96040" treatResult="子报告查询状态,1:查得,2:未查得,3:其他原因未查得" treatErrorCode="treatResult=3时的错误代码,详见数据字典,treatResult!=3时,该属性不存在" errorMessage="treatResult=3时的错误描述信息,treatResult!=3时,该属性的值为空">
  28. <!--treatresult为2、3时没有以下节点-->
  29. <item>
  30. <nameCheckResult>姓名核查结果,有:一致、基本一致、不一致、无法核查 </nameCheckResult>
  31. <documentNoCheckResult>证件号码核查结果,有:一致、不一致、无法核查 </documentNoCheckResult>
  32. <phoneCheckResult>手机号码核查结果:一致、无法核查 </phoneCheckResult>
  33. <areaInfo>号码归属地</areaInfo>
  34. <operator>运营商 1:中国电信 2:中国移动 3:中国联通 </operator>
  35. </item>
  36. </mobileCheckInfo>
  37. <!--4个人反欺诈风险综述信息 1..1 -->
  38. <personAntiSpoofingDescInfo subReportType="14225" subReportTypeCost="96040" treatResult="子报告查询状态,1:查得,2:未查得,3:其他原因未查得" treatErrorCode="treatResult=3时的错误代码,详见数据字典,treatsult!=3时,该属性不存在" errorMessage="treatResult=3时的错误描述信息,treatResult!=3时,该属性的值为空">
  39. <!--treatresult为2时没有以下节点-->
  40. <!--
  41. 个人反欺诈综述信息。如以下例子,可能为空,可能存在其中0条或n条,根据具体结果返回。
  42. 1、 反欺诈风险评分为100分,风险等级为高,建议拒绝。
  43. 2、 电信手机号码131****1542使用不足1个月。
  44. 3、 命中羊毛党名单。
  45. 4、 命中欺诈风险名单。
  46. 5、 命中高风险人员名单。
  47. 6、 存在7笔逾期的信贷记录。
  48. 7、 存在40条个人风险概要信息。
  49. 8、 在近两年被机构查询过23次个人信息。
  50. -->
  51. <personAntiSpoofingDesc>个人反欺诈综述信息</personAntiSpoofingDesc>
  52. </personAntiSpoofingDescInfo>
  53. <!--5个人反欺诈风险评分信息 1..1 -->
  54. <personAntiSpoofingInfo subReportType="14224" subReportTypeCost="96040" treatResult="子报告查询状态,1:查得,2:未查得,3:其他原因未查得" treatErrorCode="treatResult=3时的错误代码,详见数据字典,treatResult!=3时,该属性不存在" errorMessage="treatResult=3时的错误描述信息,treatResult!=3时,该属性的值为空">
  55. <!--treatresult为2、3时没有以下节点-->
  56. <riskScore>风险评分</riskScore>
  57. <riskLevel>风险等级,取值:高,中度,低</riskLevel>
  58. <suggest>风险建议,取值:建议拒绝,建议复核,建议通过</suggest>
  59. <hitTypes>命中类型:高风险名单、个人风险信息、信贷逾期名单、被机构查询信息、手机号码状态异常、手机号码低网龄、羊毛党名单、欺诈风险名单等等,可能为1个或多个</hitTypes>
  60. </personAntiSpoofingInfo>
  61. <!-- 6手机号码状态信息 1..1 -->
  62. <mobileStatusInfo subReportType="13611" subReportTypeCost="96040" treatResult="子报告查询状态,1:查得,2:未查得,3:其他原因未查得" treatErrorCode="treatResult=3时的错误代码,详见数据字典,treatResult!=3时,该属性不存在" errorMessage="treatResult=3时的错误描述信息,treatResult!=3时,该属性的值为空">
  63. <!--treatresult为2、3时没有以下节点-->
  64. <item>
  65. <operator>运营商 1:中国电信 2:中国移动 3:中国联通 </operator>
  66. <areaInfo>手机号码归属地 </areaInfo>
  67. <phoneStatus>手机状态 1:正常在用 2: 停机 3:未启用 4:已销号 5-其他 6:预销号</phoneStatus>
  68. <timeLength>手机号码在网时长,如:在网时长不足1个月,1-2个月,3-6个月,7-12个月 </timeLength>
  69. <cancelTime>号码注销时间</cancelTime>
  70. </item>
  71. </mobileStatusInfo>
  72. <!--7是否命中羊毛党名单 1..1-->
  73. <econnoisserurInfo subReportType="14228" subReportTypeCost="96040" treatResult="子报告查询状态,1:查得,2:未查得,3:其他原因未查得" treatErrorCode="treatResult=3时的错误代码,详见数据字典,treatResult!=3时,该属性不存在" errorMessage="treatResult=3时的错误描述信息,treatResult!=3时,该属性的值为空">
  74. <!--treatresult为2、3时没有以下节点-->
  75. <state>是否命中羊毛党名单,取值:0/1,0表示未命中羊毛党名单,1表示命中羊毛党名单</state>
  76. </econnoisserurInfo>
  77. <!--8是否命中欺诈风险名单 1..1-->
  78. <fraudRiskInfo subReportType="14229" subReportTypeCost="96040" treatResult="子报告查询状态,1:查得,2:未查得,3:其他原因未查得" treatErrorCode="treatResult=3时的错误代码,详见数据字典,treatResult!=3时,该属性不存在" errorMessage="treatResult=3时的错误描述信息,treatResult!=3时,该属性的值为空">
  79. <!--treatresult为2、3时没有以下节点-->
  80. <state>是否命中欺诈风险名单,取值:0/1,0表示未命中欺诈风险名单,1表示命中欺诈风险名单</state>
  81. </fraudRiskInfo>
  82. <!--9是否命中高风险名单 1..1 -->
  83. <personRiskAssess subReportType="14226" subReportTypeCost="96040" treatResult="子报告查询状态,1:查得,2:未查得,3:其他原因未查得" treatErrorCode="treatResult=3时的错误代码,详见数据字典,treatResult!=3时,该属性不存在" errorMessage="treatResult=3时的错误描述信息,treatResult!=3时,该属性的值为空">
  84. <!--treatresult为2、3时没有以下节点-->
  85. <checkResult>是否命中高风险名单 1:是,2:否</checkResult>
  86. </personRiskAssess>
  87. <!-- 10网贷逾期信息 1..1 -->
  88. <microNearlyThreeYearsOverdueInfo subReportType="13204" subReportTypeCost="96040" treatResult="子报告查询状态,1:查得,2:未查得,3:其他原因未查得" treatErrorCode="treatResult=3时的错误代码,详见数据字典,treatResult!=3时,该属性不存在" errorMessage="treatResult=3时的错误描述信息,treatResult!=3时,该属性的值为空">
  89. <!--treatresult为2、3时没有以下节点-->
  90. <!--逾期汇总信息 0..1-->
  91. <stat>
  92. <overdueAmount>逾期本金,单位:以贷款基本信息的币种为准</overdueAmount>
  93. <overdueDays>逾期天数区间,取值区间:逾期1天(含)以上</overdueDays>
  94. <overdueCount>逾期天数区间的总笔数</overdueCount>
  95. </stat>
  96. <!--0..1-->
  97. <items>
  98. <!--逾期概要信息 1..5 多个记录-->
  99. <item>
  100. <overdueAmount>逾期本金,单位:以贷款基本信息的币种为准</overdueAmount>
  101. <overdueDays>逾期天数区间,取值区间:逾期1-6天,逾期7-29天,逾期30-59天,逾期60-89天,逾期90天(含)以上</overdueDays>
  102. <overdueCount>逾期天数区间的笔数</overdueCount>
  103. </item>
  104. </items>
  105. </microNearlyThreeYearsOverdueInfo>
  106. <!-- 11风险信息 1..1 -->
  107. <personRiskInfo subReportType="14227" subReportTypeCost="96040" treatResult="子报告查询状态,1:查得,2:未查得,3:其他原因未查得" treatErrorCode="treatResult=3时的错误代码,详见数据字典,treatResult!=3时,该属性不存在" errorMessage="treatResult=3时的错误描述信息,treatResult!=3时,该属性的值为空">
  108. <!--treatresult为2、3时没有以下节点-->
  109. <!-- 汇总信息 0..1-->
  110. <stat>
  111. <totleCount>概要汇总条数</totleCount>
  112. <alCount>司法案例信息条数</alCount>
  113. <zxCount>司法执行信息条数</zxCount>
  114. <sxCount>司法失信信息条数</sxCount>
  115. <swCount>税务行政执法信息条数</swCount>
  116. <cqggCount>催欠公告信息条数</cqggCount>
  117. <wdyqCount>网贷逾期信息条数</wdyqCount>
  118. </stat>
  119. <!-- 汇总信息 end-->
  120. <!-- 概要信息 0..1-->
  121. <summary>
  122. <!-- 司法案例信息概要信息 0..1 -->
  123. <als>
  124. <!-- 司法案例信息概要信息内容 1..n -->
  125. <item>
  126. <recordId>记录编号</recordId>
  127. <bt>标题</bt>
  128. <ajlx>案件类型</ajlx>
  129. <sjnf>审结年份,格式:YYYY</sjnf>
  130. <dsrlx>当事人类型</dsrlx>
  131. </item>
  132. </als>
  133. <!-- 司法执行信息概要信息 0..1 -->
  134. <zxs>
  135. <!-- 司法执行信息概要信息内容 1..n -->
  136. <item>
  137. <recordId>记录编号</recordId>
  138. <bt>标题</bt>
  139. <zxbd>执行标的,单位:以币种为准</zxbd>
  140. <larq>立案日期,格式YYYY-MM-DD</larq>
  141. </item>
  142. </zxs>
  143. <!-- 司法失信信息概要信息 0..1 -->
  144. <sxs>
  145. <!-- 司法失信信息概要信息内容 1..n -->
  146. <item>
  147. <recordId>记录编号</recordId>
  148. <bt>标题</bt>
  149. <larq>立案日期,格式YYYY-MM-DD</larq>
  150. <fbrq>发布日期,格式YYYY-MM-DD</fbrq>
  151. </item>
  152. </sxs>
  153. <!-- 税务行政执法信息概要信息 0..1 -->
  154. <sws>
  155. <!-- 税务行政执法信息概要信息内容 1..n -->
  156. <item>
  157. <recordId>记录编号</recordId>
  158. <bt>标题</bt>
  159. <ggrq>公告日期,格式YYYY-MM-DD</ggrq>
  160. </item>
  161. </sws>
  162. <!-- >催欠公告信息概要信息 0..1 -->
  163. <cqs>
  164. <!-- 催欠公告信息概要信息内容 1..n -->
  165. <item>
  166. <recordId>记录编号</recordId>
  167. <bt>标题</bt>
  168. <fbrq>发布日期,格式YYYY-MM-DD</fbrq>
  169. </item>
  170. </cqs>
  171. <!-- 网贷逾期信息概要信息 0..1 -->
  172. <wdyqs>
  173. <!-- 网贷逾期信息概要信息内容 1..n -->
  174. <item>
  175. <recordId>记录编号</recordId>
  176. <bt>标题</bt>
  177. <fbrq>发布日期,格式YYYY-MM-DD</fbrq>
  178. </item>
  179. </wdyqs>
  180. </summary>
  181. </personRiskInfo>
  182. <!--12个人近两年历史查询记录 1..1 -->
  183. <historySimpleQueryInfo subReportType="19902" subReportTypeCost="96040" treatResult="子报告查询状态,1:查得,2:未查得,3:其他原因未查得" treatErrorCode="treatResult=3时的错误代码,详见数据字典,treatResult!=3时,该属性不存在" errorMessage="treatResult=3时的错误描述信息,treatResult!=3时,该属性的值为空">
  184. <!--treatresult为2、3时没有以下节点-->
  185. <!--0..1-->
  186. <items>
  187. <!-- 1..n -->
  188. <item>
  189. <unitMember>单位类型名称</unitMember>
  190. <last1Month>近1个月查询记录数</last1Month>
  191. <last3Month>近3个月查询记录数</last3Month>
  192. <last6Month>近6个月查询记录数</last6Month>
  193. <last12Month>近12个月查询记录数</last12Month>
  194. <last18Month>近18月查询记录数</last18Month>
  195. <last24Month>近24月查询记录数</last24Month>
  196. </item>
  197. </items>
  198. <!--0..1-->
  199. <count>
  200. <last1Month>近1个月各单位类型查询记录总数</last1Month>
  201. <last3Month>近3个月各单位类型查询记录总数</last3Month>
  202. <last6Month>近6个月各单位类型查询记录总数</last6Month>
  203. <last12Month>近12个月各单位类型查询记录总数</last12Month>
  204. <last18Month>近18月各单位类型查询记录总数</last18Month>
  205. <last24Month>近24月各单位类型查询记录总数</last24Month>
  206. </count>
  207. </historySimpleQueryInfo>
  208. </cisReport>
  209. </cisReports>
复制代码

二,表结构设计

1,批次号:各表之间用最外层批次号关联。

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

三,实体设计

分为三层:CisReportRoot ,CisReportChild ,ReportElement

  1. public class CisReportRoot extends BasePojo implements Serializable {
  2. private String docId;
  3. private String batNo;//查询批次号
  4. @JSONField(serialize = false)
  5. private String xmlId;
  6. private CisReportChild cisReportChild;
  7. /**
  8. * 2017/7/21.
  9. * 报告节点属性以及子节点
  10. */
  11. public class CisReportChild extends BasePojo {
  12. /**
  13. * 报告生成结束时间
  14. **/
  15. private String buildEndTime;
  16. /**
  17. * 是否有系统错误 true表示有 false表示没有
  18. **/
  19. private String hasSystemError;
  20. /**
  21. * 该客户是否被冻结
  22. **/
  23. private String isFrozen;
  24. private ReportElement reportElement;
  25. public class ReportElement extends BasePojo {
  26. private String phone;
  27. private PoliceCheckInfo policeCheckInfo;//身份认证
  28. private MobileCheckInfo mobileCheckInfo;//个人手机号码核查
  29. private PersonAntiSpoofingDescInfo personAntiSpoofingDescInfo;//个人反欺诈风险综述信息
  30. private PersonAntiSpoofingInfo personAntiSpoofingInfo;//个人反欺诈风险评分信息
  31. private MobileStatusInfo mobileStatusInfo;//手机号码状态信息
  32. private EconnoisserurInfo econnoisserurInfo;//是否命中羊毛党名单
  33. private FraudRiskInfo fraudRiskInfo;//是否命中欺诈风险名单
  34. private PersonRiskAssess personRiskAssess;//是否命中高风险名单
  35. private MicroNearlyThreeYearsOverdueInfo microNearlyThreeYearsOverdueInfo;//网贷逾期信息
  36. private PersonRiskInfo personRiskInfo;//风险信息
  37. private HistorySimpleQueryInfo historySimpleQueryInfo;//个人近两年历史查询记录
复制代码

四,代码

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

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

如:

  1. private void savePersonRiskInfo(String batNo, PersonRiskInfo personRiskInfo) throws Exception {
  2. Map<String, Object> map = new HashMap<>();
  3. map.put("batNo", batNo);
  4.      //单笔
  5. map.put("item", personRiskInfo);
  6. pyMapper.savePersonRiskInfo(map);
  7. if (!ListUtil.isEmpty(personRiskInfo.getAlList())) {
  8.        //批量
  9. map.put("list", personRiskInfo.getAlList());
  10. pyMapper.saveAlInfoList(map);
  11. }
复制代码

sql:

  1. <!--个人风险记录 -->
  2.    //单笔
  3. <insert id="savePersonRiskInfo" parameterType="java.util.Map">
  4. INSERT INTO TABLE_PERSON_RISK_INFO(BATNO,TOTLECOUNT,ALCOUNT,ZXCOUNT,SXCOUNT,SWCOUNT,CQGGCOUNT,WDYQCOUNT)
  5. VALUES (#{batNo,jdbcType=VARCHAR},
  6. #{item.totleCount,jdbcType=NUMERIC},
  7. #{item.alCount,jdbcType=NUMERIC},#{item.zxCount,jdbcType=NUMERIC},#{item.sxCount,jdbcType=NUMERIC},
  8. #{item.swCount,jdbcType=NUMERIC},#{item.cqggCount,jdbcType=NUMERIC},#{item.wdyqCount,jdbcType=NUMERIC})
  9. </insert>
  10. <!--逾期详细记录 -->
  11.    //批量
  12. <insert id="saveMicroNearlyThreeYearsOverdueInfoList" parameterType="java.util.Map">
  13. INSERT INTO TABLE_MNTYOI (BATNO,OVERDUEAMOUNT,OVERDUEDAYS,OVERDUECOUNT)
  14. <foreach collection="list" item="item" separator="union all">
  15. (
  16. SELECT #{batNo,jdbcType=VARCHAR},
  17. #{item.overdueAmount,jdbcType=VARCHAR},
  18. #{item.overdueDays,jdbcType=VARCHAR},
  19. #{item.overdueCount,jdbcType=NUMERIC}
  20. FROM DUAL
  21. )
  22. </foreach>
  23. </insert>
  24. private CisReportRoot invokePy(PyQueryBean pyQueryBean) throws Exception {
  25. pyQueryBean.setQueryFromPy(QUERY_FROM_PY);
  26. //call py service
  27. CisReportRoot cisReportRoot = queryCisReportFromPyServer(pyQueryBean);
  28. cisReportRoot.getCisReportChild().getReportElement().setPhone(pyQueryBean.getPhone());
  29. //cacheService.save(cisReportRoot);
  30.      //(1)保存数据
  31. saveCisReport(cisReportRoot);
  32. return cisReportRoot;
  33. }
复制代码

(1)保存数据

  1. @Transactional(rollbackFor = Exception.class)
  2. @Override
  3. public CisReportRoot saveCisReport(CisReportRoot cisReportRoot) throws Exception {
  4. try {
  5. ReportElement reportElement = cisReportRoot.getCisReportChild().getReportElement();
  6. PersonRiskInfo personRiskInfo = reportElement.getPersonRiskInfo();
  7. //(2)主表,保存xml所有节点信息(不包含个人风险信息),保存单笔数据
  8. pyMapper.saveCisReport(cisReportRoot);
  9. if (SUCCESS.equals(cisReportRoot.getCisReportChild().getReportElement().getPersonRiskInfo().getTreatResult())) {
  10. savePersonRiskInfo(cisReportRoot.getBatNo(), personRiskInfo);
  11. }
  12. if (cisReportRoot.getCisReportChild().getReportElement().getHistorySimpleQueryInfo().getTreatResult().equals(SUCCESS)) {
  13. Map<String, Object> map = new HashMap<>();
  14.           //(3)保存批量数据
  15. map.put("batNo", cisReportRoot.getBatNo());
  16. if (!ListUtil.isEmpty(cisReportRoot.getCisReportChild().getReportElement().getHistorySimpleQueryInfo().getItemList())) {
  17. map.put("list", cisReportRoot.getCisReportChild().getReportElement().getHistorySimpleQueryInfo().getItemList());
  18. pyMapper.saveHistorySimpleQueryInfoList(map);
  19. }
  20. if (!ListUtil.isEmpty(cisReportRoot.getCisReportChild().getReportElement().getMicroNearlyThreeYearsOverdueInfo().getList())) {
  21. map.put("list", cisReportRoot.getCisReportChild().getReportElement().getMicroNearlyThreeYearsOverdueInfo().getList());
  22. pyMapper.saveMicroNearlyThreeYearsOverdueInfoList(map);
  23. }
  24. }
  25. return cisReportRoot;
  26. } catch (Exception e) {
  27. logger.error("saveCisReport@PyserviceImpl_Exception", e);
  28. throw e;
  29. }
  30. }
复制代码

(2)保存主表

  1. <insert id="saveCisReport" parameterType="java.util.Map">
  2. INSERT INTO TABLE_CISREPORT
  3. (BATNO,BUILDENDTIME,ISFROZEN,
  4. MCI_NAMECHECKRESULT,MCI_AREAINFO,MCI_DOCUMENTNOCHECKRESULT,MCI_OPERATOR,MCI_PHONECHECKRESULT,
  5. PCI_DOCUMENTNO,PCI_NAME,PCI_RESULT,
  6. PASDI_DESC,
  7. PASI_HITTYPES,PASI_RISKLEVEL,PASI_RISKSCORE,PASI_RISKSUGGEST,
  8. MS_AREAINFO,MS_CAnCELTIME,MS_OPERATOR,MS_PHONESTATUS,MS_TIMELENGTH,
  9. ECONNOISSERUR,
  10. FRAUDRISK,
  11. PRA_CHECKRESULT,
  12. MNTYOI_OVERDUEAMOUNT,MNTYOI_OVERDUECOUNT,MNTYOI_OVERDUEDAYS,
  13. HS_LAST1MONTH,HS_LAST3MONTH,HS_LAST6MONTH,HS_LAST12MONTH,HS_LAST18MONTH,HS_LAST24MONTH,
  14. PHONE,XMLID)
  15. VALUES
  16. (#{batNo,jdbcType=VARCHAR},
  17. to_date(#{cisReportChild.buildEndTime},'yyyy-MM-dd hh24:mi:ss'),
  18. #{cisReportChild.isFrozen,jdbcType=VARCHAR},
  19. #{cisReportChild.reportElement.mobileCheckInfo.nameCheckResult,jdbcType=VARCHAR},
  20. #{cisReportChild.reportElement.mobileCheckInfo.areaInfo,jdbcType=VARCHAR},
  21. #{cisReportChild.reportElement.mobileCheckInfo.documentNoCheckResult,jdbcType=VARCHAR},
  22. #{cisReportChild.reportElement.mobileCheckInfo.operator,jdbcType=NUMERIC},
  23. #{cisReportChild.reportElement.mobileCheckInfo.phoneCheckResult,jdbcType=VARCHAR},
  24. #{cisReportChild.reportElement.policeCheckInfo.documentNo,jdbcType=VARCHAR},
  25. #{cisReportChild.reportElement.policeCheckInfo.name,jdbcType=VARCHAR},
  26. #{cisReportChild.reportElement.policeCheckInfo.result,jdbcType=NUMERIC},
  27. #{cisReportChild.reportElement.personAntiSpoofingDescInfo.personAntiSpoofingDesc,jdbcType=VARCHAR},
  28. #{cisReportChild.reportElement.personAntiSpoofingInfo.hitTypes,jdbcType=VARCHAR},
  29. #{cisReportChild.reportElement.personAntiSpoofingInfo.riskLevel,jdbcType=VARCHAR},
  30. #{cisReportChild.reportElement.personAntiSpoofingInfo.riskScore,jdbcType=VARCHAR},
  31. #{cisReportChild.reportElement.personAntiSpoofingInfo.suggest,jdbcType=VARCHAR},
  32. #{cisReportChild.reportElement.mobileStatusInfo.areaInfo,jdbcType=VARCHAR},
  33. #{cisReportChild.reportElement.mobileStatusInfo.cancelTime,jdbcType=VARCHAR},
  34. #{cisReportChild.reportElement.mobileStatusInfo.operator,jdbcType=NUMERIC},
  35. #{cisReportChild.reportElement.mobileStatusInfo.phoneStatus,jdbcType=NUMERIC},
  36. #{cisReportChild.reportElement.mobileStatusInfo.timeLength,jdbcType=VARCHAR},
  37. #{cisReportChild.reportElement.econnoisserurInfo.state,jdbcType=NUMERIC},
  38. #{cisReportChild.reportElement.fraudRiskInfo.state,jdbcType=NUMERIC},
  39. #{cisReportChild.reportElement.personRiskAssess.checkResult,jdbcType=NUMERIC},
  40. #{cisReportChild.reportElement.microNearlyThreeYearsOverdueInfo.overdueAmount,jdbcType=VARCHAR},
  41. #{cisReportChild.reportElement.microNearlyThreeYearsOverdueInfo.overdueCount,jdbcType=NUMERIC},
  42. #{cisReportChild.reportElement.microNearlyThreeYearsOverdueInfo.overdueDays,jdbcType=VARCHAR},
  43. #{cisReportChild.reportElement.historySimpleQueryInfo.totalCount.last1Month,jdbcType=NUMERIC},
  44. #{cisReportChild.reportElement.historySimpleQueryInfo.totalCount.last3Month,jdbcType=NUMERIC},
  45. #{cisReportChild.reportElement.historySimpleQueryInfo.totalCount.last6Month,jdbcType=NUMERIC},
  46. #{cisReportChild.reportElement.historySimpleQueryInfo.totalCount.last12Month,jdbcType=NUMERIC},
  47. #{cisReportChild.reportElement.historySimpleQueryInfo.totalCount.last18Month,jdbcType=NUMERIC},
  48. #{cisReportChild.reportElement.historySimpleQueryInfo.totalCount.last24Month,jdbcType=NUMERIC},
  49. #{cisReportChild.reportElement.phone,jdbcType=VARCHAR},
  50. #{xmlId,jdbcType=VARCHAR}
  51. )
复制代码

(3)保存批量数据(不自动生成主键)

  1. <!--个人近两年历史查询记录 -->
  2. <insert id="saveHistorySimpleQueryInfoList" parameterType="java.util.Map">
  3. INSERT INTO
  4. TABLE_HISTORY_SIMPLE_QUERY
  5. (BATNO,UNIT_MEMBER,LAST1MONTH,LAST3MONTH,LAST6MONTH,LAST12MONTH,LAST18MONTH,LAST24MONTH)
  6. <foreach collection="list" item="item" separator="union all">
  7. (
  8. SELECT
  9. #{batNo,jdbcType=VARCHAR},
  10. #{item.unitMember,jdbcType=VARCHAR},
  11. #{item.last1Month,jdbcType=NUMERIC},#{item.last3Month,jdbcType=NUMERIC},
  12. #{item.last6Month,jdbcType=NUMERIC},#{item.last12Month,jdbcType=NUMERIC},
  13. #{item.last18Month,jdbcType=NUMERIC},#{item.last24Month,jdbcType=NUMERIC}
  14. FROM DUAL
  15. )
  16. </foreach>
  17. </insert>
复制代码

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

单笔含主键

  1. DataServiceDetailResult dataServiceDetailResult = tdService.getDataServiceDetailResult(tdReportRoot);
  2. int n = tdDataServiceMapper.insertDataServiceDetailResult(dataServiceDetailResult);
  3. <!--信息核验接口-->
  4. <!--DATASERVICE-->
  5. <insert id="insertDataServiceDetailResult" parameterType="DataServiceDetailResult">
  6. <selectKey keyProperty="id" resultType="BigDecimal" order="BEFORE">
  7. select SEQ_ICS_TD_DATASERVICE.nextval as id from dual
  8. </selectKey>
  9. insert into ICS_TD_DATASERVICE (ID, RECORDID, REASON_DESC, REASON_CODE,
  10. SUCCESS)
  11. values (#{id,jdbcType=DECIMAL}, #{recordId,jdbcType=DECIMAL}, #{reasonDesc,jdbcType=VARCHAR},
  12. #{reasonCode,jdbcType=VARCHAR},
  13. #{success,jdbcType=DECIMAL})
  14. </insert>
复制代码

批量保存包含主键

  1. if (!ListUtil.isEmpty(interfacesList)) {
  2. map.put("recordId", id);
  3. map.put("list", interfacesList);
  4. tdDataServiceMapper.addBatchInterfaces(map);
  5. }
复制代码

sql:

  1. <!--批量保存interfaces-->
  2. <insert id="addBatchInterfaces" parameterType="java.util.List">
  3. <!--
  4. 注释为mysql插入方式,可以插入但是导致数据回滚不了
  5. 下面为oracle插入方式:注意parameterType:java.util.List或java.util.Map都可以
  6. BEGIN
  7. <foreach collection="list" item="item" index="index" separator="">
  8. INSERT INTO ICS_TD_INTERFACES(ID, RECORDID, TYPE)
  9. VALUES
  10. (
  11. BLOANCRDTDATA.SEQ_ICS_TD_INTERFACES.nextval,
  12. #{recordId,jdbcType=DECIMAL},
  13. #{item.type,jdbcType=VARCHAR}
  14. );
  15. </foreach>
  16. COMMIT;
  17. END;-->
  18. insert into ICS_TD_INTERFACES (ID,RECORDID, TYPE)
  19. SELECT SEQ_ICS_TD_INTERFACES.nextval ID, A.*
  20. FROM(
  21. <foreach collection="list" item="item" index="index" separator="union all">
  22. SELECT
  23. #{recordId,jdbcType=DECIMAL},
  24. #{item.type,jdbcType=VARCHAR}
  25. FROM DUAL
  26. </foreach>
  27. ) A
  28. </insert>
复制代码

总结

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



回复

使用道具 举报