java向oracle数据库Clob读取，写入数据

look321

public void CreateXmlFile(StringBuilder str, String name) {　　
  file = new File(ConstantTool.filePath + "/" + name + "ws.xml");
　　
  logger.info("开始往路径写入数据.." + file.getAbsolutePath());
　　
  try {
　　
   fos = new FileOutputStream(file);
　　
   osw = new OutputStreamWriter(fos, "UTF-8");
　　
   osw.write(str.toString());
　　
   osw.close();
　　
  } catch (FileNotFoundException e) {
　　
   logger.info(e);
　　
   e.printStackTrace();
　　
  } catch (IOException e) {
　　
   logger.info(e);
　　
   e.printStackTrace();
　　
  }
　　
  // database----------------------------------------------------------
　　
  DAODB db = new DAODB();
　　
  Connection conn = db.conn();
　　
  PreparedStatement pre1;
　　
  PreparedStatement pre2;
　　
  PreparedStatement pre3;
　　
  PreparedStatement pre4;
　　
  PreparedStatement pre5;
　　
  CLOB clob = null;
　　
  ResultSet rs = null;
　　
  BufferedWriter bw;
　　
  int i = 0;
　　
  pre1 = db.pre(ConstantTool.sqlsearch_3555_update_key);
　　
  pre2 = db.pre(ConstantTool.sqlinsertinto_3555);
　　
  pre3 = db.pre(ConstantTool.sqlupdateid_3555);
　　
  pre4 = db.pre(ConstantTool.sqlselect_3555_blob);
　　
  pre5 = db.pre(ConstantTool.sqlsearch_3555_update_clob_empty);
　　
  // public static final String sqlinsertinto_3555 = "insert "
　　
  // +
　　
  // " into PTR_AssetXml(cChr_AssetPlanId,cChr_AssetData,Create_Date,Submitter,Last_Modified_By,Modified_Date,Status,Short_Description,Request_ID) "
　　
  // +
　　
  // "values(?,empty_clob(),?,?,?,?,?,?,(select nextid from arschema where schemaid=3555))";
　　
  String[] planstr = name.split("_");
　　
  try {
　　
   conn.setAutoCommit(false);
　　
   pre1.setLong(1, new Date().getTime() / 1000);
　　
   pre1.setString(2, planstr[0]);
　　
   i = pre1.executeUpdate();
　　
   conn.commit();
　　
   if (i == 0) {
　　
    pre3.executeUpdate();
　　
    conn.commit();
　　
    pre2.setString(1, planstr[0]);
　　
    pre2.setLong(2, (new Date().getTime() / 1000));
　　
    pre2.setString(3, "同步");
　　
    pre2.setString(4, "同步");
　　
    pre2.setLong(5, (new Date().getTime() / 1000));
　　
    pre2.setInt(6, 1);
　　
    pre2.setString(7, "同步");
　　
    pre2.executeUpdate();
　　
    conn.commit();
　　
    pre4.setString(1, planstr[0]);
　　
    conn.setAutoCommit(false);
　　
    rs = pre4.executeQuery();
　　
    rs.next();
　　
    clob = (CLOB) rs.getClob(1);
　　
    bw = new BufferedWriter(clob.getCharacterOutputStream());
　　
    bw.write(str.toString());
　　
    if (bw != null) {
　　
     bw.close();
　　
    }
　　
    conn.commit();
　　
   }
　　
   if (i != 0) {
　　
    pre5.setString(1, planstr[0]);
　　
    pre5.executeUpdate();
　　
    conn.commit();
　　
    pre4.setString(1, planstr[0]);
　　
    conn.setAutoCommit(false);
　　
    rs = pre4.executeQuery();
　　
    rs.next();
　　
    clob = (CLOB) rs.getClob(1);
　　
    bw = new BufferedWriter(clob.getCharacterOutputStream());
　　
    bw.write(str.toString());
　　
    if (bw != null) {
　　
     bw.close();
　　
    }
　　
    conn.commit();
　　
   }
　　

　　
   if(pre1!=null){
　　
    pre1.close();
　　
   }
　　
   if(pre2!=null){
　　
    pre1.close();
　　
   }
　　
   if(pre3!=null){
　　
    pre1.close();
　　
   }
　　
   if(pre4!=null){
　　
    pre1.close();
　　
   }
　　
   if(pre5!=null){
　　
    pre1.close();
　　
   }
　　
   db.closeConn();
　　
  } catch (SQLException e) {
　　
   e.printStackTrace();
　　
  } catch (IOException e) {
　　
   e.printStackTrace();
　　
  }
　　
}
　　
}