oracleblobparseblh.java

以前做的一个j2ee的项目

                         con.close();
                     }
                 } catch (SQLException se) {  }
             }
          return rei;
    }
    public int saveblob(String urlstring,ByteArrayOutputStream bs){
          int rei=0;
          int BUFFER = 2048;
          /**
          GZDAfileDetailVO detail=new GZDAfileDetailVO();
          detail.setUrl(urlstring);
          BLOB blob=null;
          List list=null;
          try {
                  blob = BLOB.empty_lob();


          } catch (SQLException e1) {
                  // TODO 自动生成 catch 块
                  e1.printStackTrace();
          }

          detail.setFiledoc(blob) ;

          daoManager.startTransaction();

          rei=inserttfile("insertfile",detail);

             list=selectfile("selectfile",urlstring);
             if(list.isEmpty()){
                System.out.println("插入空BLOB出错！");
             }

           GZDAfileDetailVO td=(GZDAfileDetailVO)list.get(0);
           BLOB lob=(BLOB)td.getFiledoc();


           OutputStream outStream=null;
           try {
                  //System.out.println(td.getFiledoc());
                  outStream= lob.getBinaryOutputStream();
           } catch (SQLException e) {
                  // TODO 自动生成 catch 块
                  e.printStackTrace();
           }
           byte[] b;
                          int len = 0;
                          try {
                                  b = new byte[lob.getBufferSize()];

                                          //while ((len = in.read(b)) != -1) {
                                              outStream.write(bs.toByteArray());
                                             //lob.putBytes(1,b);
                                          //}
                                  } catch (IOException e2) {
                                          // TODO 自动生成 catch 块
                                          e2.printStackTrace();
                                  }
                                  catch (SQLException e2) {
                                          // TODO 自动生成 catch 块
                                          e2.printStackTrace();
                                  }
                                   finally {
                                          try {
                                           if(outStream!=null){
                                   outStream.flush();
                                   outStream.close();
                               }
                                           } catch (IOException io) {}
                                   }
                                  //detail.setUrl("2111");
                                  //detail.setFiledoc(lob) ;
                                  //rei=inserttfile("insertfile",detail);
          daoManager.commitTransaction();
          **/
         Connection con=null;
         weblogic.jdbc.vendor.oracle.OracleThinBlob blob=null;
         OutputStream outStream=null;
         //try {
         //        blob = BLOB.empty_lob();


         //} catch (SQLException e1) {
                 // TODO 自动生成 catch 块
         //        e1.printStackTrace();
         //}
         try {
             con = JDBCLocator.getInstance().getJDBCConnection();
             con.setAutoCommit(false);
             Statement st = con.createStatement();
             st.executeUpdate("insert into T_GZDA_FILEMANAGERDETAIL  values('" + urlstring +
                              "',empty_blob())");
             ResultSet rs = st.executeQuery(
                     "SELECT url, filedoc  FROM T_GZDA_FILEMANAGERDETAIL  WHERE url='" +
                     urlstring + "' for update");
             while (rs.next()) {
                 blob = (weblogic.jdbc.vendor.oracle.OracleThinBlob)rs.getBlob("filedoc");
             }
             outStream = blob.getBinaryOutputStream();
             ByteArrayOutputStream newbs=createZipStream(bs);
             byte[] b;
                            int len = 0;
                            try {
                                    b = new byte[blob.getBufferSize()];

                                            //while ((len = dis.read(b)) != -1) {
                                                outStream.write(newbs.toByteArray());
                                                //outStream.write(b, 0, len);
                                                //lob.putBytes(1,b);
                                            //}
                                    } catch (IOException e2) {
                                            // TODO 自动生成 catch 块
                                            e2.printStackTrace();
                                    }
                                    catch (SQLException e2) {
                                            // TODO 自动生成 catch 块
                                            e2.printStackTrace();
                                    }
                                     finally {
                                            try {
                                             if(outStream!=null){
                                     outStream.flush();
                                     outStream.close();
                                     newbs.close();
                                     bs.close();
                                 }
                                             } catch (IOException io) {}
                                   }

             rei=1;
             // sqlMap.commitTransaction();
             } catch (SQLException ex) {
                 System.out.println(ex.toString());
             }finally{
                 try {
                     if(con!=null){
                         con.commit();
                         con.close();
                     }

                 } catch (SQLException se) {  }
             }
          return rei;
    }

//	得到XML节点中的二进制数据
    public ByteArrayOutputStream  getBytetream(HttpServletRequest request, HttpServletResponse response){
        Document document=null;
        ByteArrayInputStream inStream=null;
         ByteArrayOutputStream bytearray=new ByteArrayOutputStream();

        //XmlGetter xmlGetter=new XmlGetter();
        String xml=XmlGetter.getData(request,"gb2312");
        //System.out.println("传入的数据:"+xml);
        StringReader SR = new StringReader(xml);
        SAXBuilder builder = new SAXBuilder();
        try{
            document = builder.build(SR);
        }catch(JDOMException je){
           System.out.println(je.toString());
        }
       // Get the root element
        Element root = document.getRootElement();
        Element params=root.getChild("upData");
        String files=params.getText();


       try {
          byte[]  bytes = new sun.misc.BASE64Decoder().decodeBuffer(files);
          inStream=new ByteArrayInputStream(bytes);
          } catch (IOException ex) {
              System.out.println(ex.toString());
       }

        byte[] b = new byte[1024];
        int len = 0;
        try {
         while ((len = inStream.read(b)) != -1) {

               bytearray.write(b,0,len);
          }
               //bytearray.close();
         } catch (IOException ex1) {
                    System.out.println(ex1.toString());
         }

       return bytearray;
    }
    protected ResponseEvent validateData(RequestEvent req) throws
            Exception {
        return null;
    }

    protected ResponseEvent performTask(RequestEvent req) throws
        TaxBaseBizException, TaxBaseSystemException {
         GZDAfileReqEvent reqEvent=(GZDAfileReqEvent)req ;
         String dealMethod = reqEvent.getDealMethod();
         int result=0;
         GZDAfileResEvent resEvent = new GZDAfileResEvent();
         if("selectblob".equalsIgnoreCase(dealMethod)){
             String url=reqEvent.getURL();
             resEvent.setDocfile(this.selectblob(url));

         }else if("saveblob".equalsIgnoreCase(dealMethod)){
             ByteArrayOutputStream bstream=reqEvent.getBs();
             String url=reqEvent.getURL();
             result=this.deleteblob(url);
             if(result>0){
                 result = this.saveblob(url, bstream);
                 if (result != 1) {
                     resEvent.setRepCode(
                             "error save bolb to t_gzda_filedetail.2");
                 }
             }else{
                 resEvent.setRepCode(
                         "error save bolb to t_gzda_filedetail.1");

             }
         }else if("savneweblob".equalsIgnoreCase(dealMethod)){
             ByteArrayOutputStream bstream=reqEvent.getBs();
             String url=reqEvent.getURL();
             result = this.saveblob(url, bstream);
             if (result != 1) {
                 resEvent.setRepCode(
                         "error save bolb to t_gzda_filedetail.2");
             }

         }
    return resEvent;
   }

   private ByteArrayOutputStream createZipStream(ByteArrayOutputStream stream){
       ByteArrayOutputStream btyout=new ByteArrayOutputStream();
       ZipOutputStream out = null;
       out=new ZipOutputStream(new BufferedOutputStream(btyout));
       out.setMethod(ZipOutputStream.DEFLATED);
                try {
                    out.putNextEntry(new ZipEntry("zip"));
                } catch (IOException ex1) {
                }

                try {
                    out.write(stream.toByteArray());
                    out.close();
                    btyout.close();
                } catch (IOException ex2) {
                }

        return btyout;
   }

   private InputStream createZipStream(InputStream stream){
       ByteArrayOutputStream btyout=new ByteArrayOutputStream();
       ZipOutputStream out = null;
       out=new ZipOutputStream(new BufferedOutputStream(btyout));
       out.setMethod(ZipOutputStream.DEFLATED);
                try {
                    out.putNextEntry(new ZipEntry("zip"));
                } catch (IOException ex1) {
                }

                try {
                    int l=0;
                    byte[] b=new byte[1024];
                    while((l=stream.read(b))!= -1)
                    out.write(b,0,l);
                } catch (IOException ex2) {
                }finally{
                    try {
                         out.close();
                         btyout.close();
                    } catch (IOException ex) {
                    }
                }
        InputStream ins=new ByteArrayInputStream(btyout.toByteArray());
        return ins;
   }

   public static void main(String[] args) {

       FileOutputStream dest = null;
            ZipOutputStream out = null;
            ByteArrayOutputStream byteout=new ByteArrayOutputStream();
            System.out.println("a:"+byteout.size());
    try {
      dest = new FileOutputStream("C:\\test\\989898989898989.zip");
    } catch (FileNotFoundException ex) {
    }
       out=new ZipOutputStream(new BufferedOutputStream(byteout));
       out.setMethod(ZipOutputStream.DEFLATED);
                try {
                    out.putNextEntry(new ZipEntry("zip"));
                } catch (IOException ex1) {
                }
                byte[] test={'a','b','c',};
                try {
                    out.write(test);

                    out.close();
                    dest.close();
                    byteout.close();
                } catch (IOException ex2) {
                }
                               System.out.println("b:"+byteout.toString());
   }

}