批量在mybatis中向BLOB欄位插入資料
阿新 • • 發佈:2020-10-22
最近接手一個需求,需要用xxl-job定時任務同步三方庫中新增的資料,粗略一看挺得意,以為一兩小時就搞定了,但事與願違,編碼兩小時卻被一個BLOB欄位玩了一下午。
每次獲取50條資料過來,每條資料中有一個欄位是BLOB型別的圖片,需求也要將圖片放入資料庫(個人不建議這麼玩,生產上千萬的資料會造成資料庫很臃腫,建議放到ftp或者minio上比較好),欄位中的圖片過來時已經被轉換成了base64的格式,在往資料庫批量插入時,資料庫BLOB欄位對應的實體使用byte[],程式執行時報瞭如下錯誤:
org.springframework.jdbc.UncategorizedSQLException: ### Error updating database. Cause: java.sql.SQLException: ORA-01461: 僅能繫結要插入 LONG 列的 LONG 值 ### The error may exist in file [D:\ZtlandCode\AreaCodeVersion\WX\land-core-wx\land-core-common\target\classes\mapper\DjSfzbMapper.xml] ### The error may involve com.ztland.core.common.mapper.DjSfzbMapper.savaSfzBatch-Inline ### The error occurred while setting parameters ### SQL: INSERT INTO DJ_SFZB (ID, SFZXM, SFZZH, SFZXBMC, SFZMZ, SFZSR, SFZDZ, SFZQPDW, SFZYXQ, SFZTP, SFYX, CJSJ, ZHXGSJ) SELECT DJ_SFZB_ID.nextval AS ID, A.* FROM
(SELECT ? AS SFZXM, ? AS SFZZH, ? AS SFZXBMC, ? AS SFZMZ, ? AS SFZSR, ? AS SFZDZ, ? AS SFZQPDW, ? AS SFZYXQ, ? AS SFZTP, '1' AS SFYX, sysdate AS CJSJ, sysdate AS ZHXGSJ FROM dual) A ### Cause: java.sql.SQLException: ORA-01461: 僅能繫結要插入 LONG 列的 LONG 值 ; uncategorized SQLException; SQL state [72000]; error code [1461]; ORA-01461: 僅能繫結要插入 LONG 列的 LONG 值 ; nested exception is java.sql.SQLException: ORA-01461: 僅能繫結要插入 LONG 列的 LONG 值
原因是oracle中儲存大長度欄位時,長度介於2000-4000之間的欄位會先轉換為LONG型別,報錯時的SQL如下:
INSERT INTO DJ_SFZB ( ID,SFZXM,SFZZH,SFZXBMC,SFZMZ,SFZSR,SFZDZ,SFZQPDW,SFZYXQ,SFZTP, SFYX,CJSJ,ZHXGSJ ) select DJ_SFZB_ID.NEXTVAL as ID,A.* from ( <foreach collection ="list" item="item" index= "index" separator =" union all "> select #{item.sfzxm} as SFZXM,#{item.sfzzh} as SFZZH, #{item.sfzxbmc} as SFZXBMC,#{item.sfzmz} as SFZMZ,#{item.sfzsr} as SFZSR, #{item.sfzdz} as SFZDZ,#{item.sfzqpdw} as SFZQPDW,#{item.sfzyxq} as SFZYXQ, #{item.sfztp,jdbcType=BLOB} as SFZTP,'1' as SFYX,sysdate as CJSJ,sysdate as ZHXGSJ from dual </foreach > ) A
問題排查發現:批量就byte[]儲存到BLOB欄位時,不能使用Union all,不能使用from dual虛表查詢獲取資料的方式,因為欄位長度介於2000-4000之間時,oracle會將欄位型別轉為long型別
解決方法:使用”begin...;end;“的方式,修改後的SQL如下:
begin <foreach collection ="list" item="item" index= "index" separator =";"> INSERT INTO DJ_SFZB ( ID,SFZXM,SFZZH,SFZXBMC,SFZMZ,SFZSR,SFZDZ,SFZQPDW,SFZYXQ,SFZTP, SFYX,CJSJ,ZHXGSJ ) values ( #{item.id,jdbcType=NUMERIC}, #{item.sfzxm,jdbcType=VARCHAR},#{item.sfzzh,jdbcType=VARCHAR}, #{item.sfzxbmc,jdbcType=VARCHAR},#{item.sfzmz,jdbcType=VARCHAR},#{item.sfzsr,jdbcType=VARCHAR}, #{item.sfzdz,jdbcType=VARCHAR},#{item.sfzqpdw,jdbcType=VARCHAR},#{item.sfzyxq,jdbcType=VARCHAR}, #{item.sfztp,jdbcType=BLOB},'1',sysdate,sysdate ) </foreach > ;end;
問題得以解決。