java 處理 BLOB OutputStream(插入空的Blob字段到表中)

1.插入占位資料：

insert into TEST_CUICF(t1,t2) values(12,empty_blob())

2.獲得占位資料：

select t1,t2 from TEST_CUICF t for update

BLOB oracleBlobMockIn = oracleBlobMockIn = control.createMock(BLOB.class);

...

  oracleBlobMockIn.getBinaryStream();

  expectLastCall().andReturn(new FileInputStream(inPdfFile)).times(1);

...

  ResultSet rs = st.executeQuery(sql);

  BLOB oracleBlobMockOut = null;

  if (rs.next()) {

   rs.getString("t1");

   oracleBlobMockOut = (BLOB) rs.getBlob("t2");

  }

...

  control.replay();

  Watermark.addPdfWatermark(oracleBlobMockIn, oracleBlobMockOut, markImagePath);

  control.verify();

  control.reset();

3.應用 輸出流 (增加水印處理)

 public static void addPdfWatermark(BLOB inputPdfFileBlob, BLOB outPdfFileBlob, String markImagePath) throws Exception {

  if (null == WATERMARK_IMAGE) {

   logger.info("watermark_image inital~~");

   WATERMARK_IMAGE = Image.getInstance(markImagePath);

   WATERMARK_IMAGE.setAbsolutePosition(10, 250);

  }

  PdfReader reader = null;

  PdfStamper stamp = null;

  try {

   reader = new PdfReader(inputPdfFileBlob.getBinaryStream(), "PDF".getBytes());

   stamp = new PdfStamper(reader, outPdfFileBlob.getBinaryOutputStream()); //獲得輸出流

   int numberOfPages = reader.getNumberOfPages();

   for (int i = 1; i <= numberOfPages; i++) {

    PdfContentByte under = stamp.getUnderContent(i);

    under.addImage(WATERMARK_IMAGE);

   }

  } finally {

   stamp.close();

  }

 }

4.關閉連接配接

  con.commit();

  con.close();