productaction.java

hibernate应用测试,初学hibernate 的会员可以看看.

package com.action;

import org.apache.struts.action.*;
import java.io.*;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import java.util.List;
import java.sql.SQLException;

import com.bean.*;
import com.bean.LogTable;
import com.dao.*;
import com.tool.pagetool.*;
import com.tool.QueryStrCreator;
import com.tool.LogTableWriter;

public class ProductAction extends Action {
    public ActionForward execute(ActionMapping mapping,
                                 ActionForm form,
                                 HttpServletRequest request,
                                 HttpServletResponse response) throws Exception {
        request.setCharacterEncoding("gb2312");
        response.setContentType("text/html;charset=gb2312");

        ProductTable productTable = (ProductTable) form;
        String flag = request.getParameter("flag");
        ActionErrors actionErrors = new ActionErrors();
        String target = "";
        if (productTable != null)

            //添加用户
            if (flag.equals("forA")) {
                try {
                    //检查产品信息是否重复
                    String whereStr = "where product_name='" +
                                      productTable.getProductName() + "' and " +
                                      "product_type='" +
                                      productTable.getProductType() +
                                      "' and pin_pai='" +
                                      productTable.getPinPai() + "' " +
                                      "and product_technics='" +
                                      productTable.getProductTechnics() +
                                      "' and product_manufacturer='" +
                                      productTable.getProductManufacturer() +
                                      "'";
                    boolean tmp = ProductTableDAO.selectIsHasProduct(whereStr);
                    if (tmp) {
                        ActionError actionError = new ActionError(
                                "errors.generally.failed", "重复的产品信息");
                        actionErrors.add("", actionError);
                        saveErrors(request, actionErrors);
                        target = "addProduct";
                        return mapping.findForward(target);
                    }
                    //产品信息不重复，添加到数据库
                    ProductTableDAO.startTransation();
                    int lastId = ProductTableDAO.getLastId();
                    productTable.setProductId(lastId + 1);
                    ProductTableDAO.insertProductTable(productTable);
                    ProductTableDAO.commit();
                    ActionError actionError = new ActionError(
                            "errors.addSuccese");
                    actionErrors.add("", actionError);
                    saveErrors(request, actionErrors);
                    //写入日志
                    String operatorType = "增";
                    String sql = "insert into PRODUCT_TABLE " +
                                 "(product_id,product_name,product_type," +
                                 "pin_pai,product_technics,product_package," +
                                 "product_manufacturer,product_grade,produce_batch," +
                                 "guarantee_period,del_flag) values" +
                                 " (" + productTable.getProductId() + "," +
                                 productTable.getProductName() + "," +
                                 productTable.getProductType() + "," +
                                 productTable.getPinPai() + "," +
                                 productTable.getProductTechnics() + "," +
                                 productTable.getProductPackage() + "," +
                                 productTable.getProductManufacturer() + "," +
                                 productTable.getProductGrade() + "," +
                                 productTable.getProduceBatch() + "," +
                                 productTable.getGuaranteePeriod() + "," +
                                 productTable.getDelFlag() + ")";
                    LogTableWriter.write(request, operatorType, sql);
                } catch (Exception e) {
                    e.printStackTrace();
                    ActionError actionError = new ActionError(
                            "errors.addFailed");
                    actionErrors.add("addClientFeiled", actionError);
                    saveErrors(request, actionErrors);
                } finally {
                    target = "addProduct";
                    ProductTableDAO.rollback();
                }
            }
            //查询用户
            else if (flag.equals("query")) {
                initPage(request); //初始化分页数据并放于request中
                target = "listProduct";
                String flag2 = request.getParameter("flag2");
                if (flag2 != null && flag2.equals("forDelete")) { //跳转到删除列表
                    target = "deleteProduct";
                } else if (flag2 != null && flag2.equals("listForModify")) { //跳转到修改列表
                    target = "forModify";
                }else if (flag2 != null && flag2.equals("listForTransferStor")) { //跳转到修改列表
                    target = "listForTransferStor";
                }

            }
            //跳转到修改页面
            else if (flag.equals("forM")) {
                String productIdStr = request.getParameter("productId");
                int productId = -1;
                try {
                    productId = new Integer(productIdStr).intValue();
                } catch (Exception e) {
                    e.printStackTrace();
                }
                try {
                    ProductTable productTable2 = ProductTableDAO.
                                                 selectProductTableByproductId(
                            productId);
                    request.setAttribute("productTable", productTable2);
                } catch (Exception e) {
                    e.printStackTrace();
                }
                target = "modifyProduct";
            }
            //执行修改
            else if (flag.equals("modify")) {
                try {
                    //检查产品信息是否重复
                    String whereStr = "where product_name='" +
                                      productTable.getProductName() +
                                      "' and product_id<>" +
                                      productTable.getProductId() +
                                      " and product_type='" +
                                      productTable.getProductType() +
                                      "' and pin_pai='" +
                                      productTable.getPinPai() + "' " +
                                      "and product_technics='" +
                                      productTable.getProductTechnics() +
                                      "' and product_manufacturer='" +
                                      productTable.getProductManufacturer() +
                                      "'";
                    boolean tmp = ProductTableDAO.selectIsHasProduct(whereStr);
                    if (tmp) {
                        ActionError actionError = new ActionError(