OAF_文件系列4_实现OAF上传显示数据库动态图片Image（案例）

package bxj.oracle.apps.ap.employees.webui;

import bxj.oracle.apps.ap.employees.server.EmpManageAMImpl;
import bxj.oracle.apps.ap.employees.server.EmployeeImageVOImpl;

import java.io.Serializable;

import oracle.apps.fnd.common.VersionInfo;
import oracle.apps.fnd.framework.OAApplicationModule;
import oracle.apps.fnd.framework.webui.OAControllerImpl;
import oracle.apps.fnd.framework.webui.OAPageContext;
import oracle.apps.fnd.framework.webui.beans.OAImageBean;
import oracle.apps.fnd.framework.webui.beans.OAWebBean;

public class EmployeeImageCO extends OAControllerImpl
{
  public static final String RCS_ID="$Header$";
  public static final boolean RCS_ID_RECORDED =
        VersionInfo.recordClassVersion(RCS_ID, "%packagename%");

  /**初始化insert
  public void processRequest(OAPageContext pageContext, OAWebBean webBean)
  {
    super.processRequest(pageContext, webBean);
    
    EmpManageAMImpl am = (EmpManageAMImpl) pageContext.getApplicationModule(webBean);
    am.invokeMethod("initemployeeimage");
  }

  /**
  public void processFormRequest(OAPageContext pageContext, OAWebBean webBean)
  {
    super.processFormRequest(pageContext, webBean);
    
    OAApplicationModule am = pageContext.getApplicationModule(webBean);
    
    if ("upload".equals(pageContext.getParameter(EVENT_PARAM))) {
        am.getTransaction().commit();
        
        System.out.println("processRequest2");
        String employee_id = pageContext.getParameter("EmployeeId");
        //物理路径
        String phyPath = pageContext.getTemporaryImageLocation();
        //相对路径
        String relPath = pageContext.getTemporaryImageSource();
        System.out.println("co phyPath"+phyPath);
        System.out.println("co relPath"+relPath);
          
        /*以下两行注释用于生成唯一图片名，可视需要使用*/
        String imageName = "UserIcon"+employee_id+".gif";
        Serializable[] parameters = { employee_id, phyPath, imageName };
        am.invokeMethod("queryUser", parameters);
        
        OAImageBean image =  (OAImageBean)webBean.findIndexedChildRecursive("EmployeeImage");
        if (image != null) {
          image.setSource(relPath + imageName);
        }
    }
  }

}

 //初始化
    public void initemployeeimage() {  
         EmployeeImageVOImpl vo =  this.getEmployeeImageVO();
         //vo.setMaxFetchSize(0);
         vo.setWhereClause(" EMPLOYEE_ID = 2 ");
         vo.executeQuery();
         
         System.out.println("initemployeeimage "+vo.getRowCount());
         //EmployeeImageVORowImpl employeeimagerow = (EmployeeImageVORowImpl) vo.createRow();
         //vo.insertRow(employeeimagerow);
         //employeeimagerow.setNewRowState(Row.STATUS_INITIALIZED);
    }  

    public void queryUser(String user_id, String phyPath, String imageName) {  
        //此处调用了视图的查询方法   
        EmployeeImageVOImpl empvo =  this.getEmployeeImageVO();
        EmployeeImageVORowImpl emprow = (EmployeeImageVORowImpl) empvo.getRowAtRangeIndex(0);
        BlobDomain image = emprow.getBlob();
        if (image != null) {
          initImage(image, phyPath, imageName);  
        }
    }   
        
    //使用IO流输出图片（AM代码）：
    private void initImage(BlobDomain image, String phyPath, String imageName) {     
        File directory = new File(phyPath);     
        if (!directory.exists())     
          directory.mkdirs();     
          File imageFile = new File(directory, imageName);     
        try {     
           fromInputToOutput(image.getBinaryStream(), new FileOutputStream(imageFile));     
        } catch (Exception exception) {     
           exception.printStackTrace();     
        }     
        //DEBUG专用，看看路径对不对      
        System.out.println(imageFile.getAbsolutePath());     
    }     
        
    /*复制方法，图片大可以增大byte块*/    
    public void fromInputToOutput(InputStream inputstream, OutputStream outputstream) throws IOException {    
        byte abyte0[] = new byte[255];     
        for (int i = 255; i == 255; ) {     
          i = inputstream.read(abyte0);     
          if (i < 0)     
            break;     
            outputstream.write(abyte0, 0, i);     
        }     
        outputstream.close();     
        inputstream.close();     
    }