picaction.java~5~

一个J2EE模式的

package com.hanb.pic.wkhPic;

import org.apache.struts.action.ActionMapping;
import org.apache.struts.action.ActionForm;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.Action;
import org.apache.struts.upload.FormFile;
import java.io.InputStream;
import com.hanb.pic.wkhPic.PicForm;

import java.sql.*;

public class PicAction extends Action {
    public ActionForward execute(ActionMapping actionMapping,
                                 ActionForm actionForm,
                                 HttpServletRequest servletRequest,
                                 HttpServletResponse servletResponse)throws Exception {
        PicForm picForm = (PicForm) actionForm;


        if(picForm.getAction().equals("Save")){
        //存储图片专用
        FormFile file=picForm.getPicfile();
        InputStream imgstm =file.getInputStream();
       byte[] bufferArray = new byte[imgstm.available()];
       imgstm.read(bufferArray);
       imgstm.close();


       try {
           //下面连接数据库
           Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").
                   newInstance();
           String url =
                   "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=TestPic";

           String user = "sa";
           String password = "";
           Connection conn = DriverManager.getConnection(url, user, password);
           Statement stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
                                                 ResultSet.CONCUR_UPDATABLE);
           //先查出来

           String sql_insert = "insert into test (picData) values (null) "; //插入一条空
           //String sql_ID="select IDD=@@Identity from test ";
           String sql_query = "select * from test where id=@@Identity "; //查询刚刚插入的一条记录

           stmt.executeUpdate(sql_insert); //插入一条空

           ResultSet rs = stmt.executeQuery(sql_query); //查询刚刚插入的一条记录
           if (rs.next()) {
               rs.updateBytes("picData", bufferArray);
               rs.updateRow();
           }
       } catch (Exception e) {
           e.printStackTrace();
           System.out.println("Operateor DataBase Error!");
           return actionMapping.findForward("Error");
       }

       return actionMapping.findForward("OK");
        }

        return actionMapping.findForward("OK");
    }
}