productaction.java

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

                                "errors.generally.failed", "重复的产品信息");
                        actionErrors.add("", actionError);
                        saveErrors(request, actionErrors);
                        request.setAttribute("productTable", productTable);
                        target = "modifyProduct";
                        return mapping.findForward(target);
                    }
                    //产品信息不重复执行更新
                    ProductTableDAO.updateProductTable(productTable);

                    ActionError actionError = new ActionError(
                            "errors.modifyUserInfoSuccese");
                    actionErrors.add("", actionError);
                    saveErrors(request, actionErrors);
                    //写入日志
                    String operatorType = "改";
                    String sql = "update PRODUCT_TABLE set " +
                                 "PRODUCT_ID=" + productTable.getProductId() +
                                 "," +
                                 "PRODUCT_NAME=" + productTable.getProductName() +
                                 "," +
                                 "PRODUCT_TYPE=" +
                                 productTable.getProductTechnics() + "," +
                                 "PIN_PAI=" + productTable.getPinPai() +
                                 ",PRODUCT_TECHNICS=" +
                                 productTable.getProductTechnics() + "," +
                                 "PRODUCT_PACKAGE=" +
                                 productTable.getProductPackage() + "," +
                                 "PRODUCT_MANUFACTURER=" +
                                 productTable.getProductManufacturer() + "," +
                                 "PRODUCT_GRADE=" +
                                 productTable.getProductGrade() + "," +
                                 "PRODUCE_BATCH=" +
                                 productTable.getProduceBatch() + "," +
                                 "GUARANTEE_PERIOD=" +
                                 productTable.getGuaranteePeriod() + "," +
                                 "DEL_FLAG=" + productTable.getDelFlag() + " " +
                                 "where PRODUCT_ID = " +
                                 productTable.getProductId();
                    LogTableWriter.write(request, operatorType, sql);
                } catch (Exception e) {
                    e.printStackTrace();
                    ActionError actionError = new ActionError(
                            "errors.modifyUserInfoFailed");
                    actionErrors.add("addClientFeiled", actionError);
                    saveErrors(request, actionErrors);
                }
                request.setAttribute("productTable", productTable);
                target = "modifyProduct";
            }
        //删除
        if (flag.equals("delete")) {

            String productIdStr = request.getParameter("productId");
            int productId = -1;
            try {
                productId = Integer.parseInt(productIdStr);
                productTable = ProductTableDAO.selectProductTableByproductId(
                        productId);
                boolean tmp = ProductTableDAO.selectIsReferProduct(productTable);
                if (tmp) { //如果产品已被引用
                    ActionError actionError = new ActionError(
                            "errors.generally.failed", "产品已被引用");
                    actionErrors.add("", actionError);
                    saveErrors(request, actionErrors);
                    target = "listProduct";
                    return mapping.findForward(target);
                }
                productTable.setDelFlag(1);
                ProductTableDAO.updateProductTable(productTable);
                ActionError actionError = new ActionError(
                        "errors.generally.succese");
                actionErrors.add("", actionError);
                saveErrors(request, actionErrors);
                //写入日志
                String operatorType = "删";
                String sql = "update PRODUCT_TABLE set " +
                             "PRODUCT_ID=" + productTable.getProductId() + "," +
                             "PRODUCT_NAME=" + productTable.getProductName() +
                             "," +
                             "PRODUCT_TYPE=" + productTable.getProductTechnics() +
                             "," +
                             "PIN_PAI=" + productTable.getPinPai() +
                             ",PRODUCT_TECHNICS=" +
                             productTable.getProductTechnics() + "," +
                             "PRODUCT_PACKAGE=" +
                             productTable.getProductPackage() + "," +
                             "PRODUCT_MANUFACTURER=" +
                             productTable.getProductManufacturer() + "," +
                             "PRODUCT_GRADE=" + productTable.getProductGrade() +
                             "," +
                             "PRODUCE_BATCH=" + productTable.getProduceBatch() +
                             "," +
                             "GUARANTEE_PERIOD=" +
                             productTable.getGuaranteePeriod() + "," +
                             "DEL_FLAG=" + productTable.getDelFlag() + " " +
                             "where PRODUCT_ID = " + productTable.getProductId();
                LogTableWriter.write(request, operatorType, sql);
            } catch (Exception e) {
                e.printStackTrace();
                ActionError actionError = new ActionError(
                        "errors.generally.failed", e.getMessage());
                actionErrors.add("", actionError);
                saveErrors(request, actionErrors);
            }
            target = "listProduct";
        }
        return mapping.findForward(target);
    }

    //初始化并获得分页
    private Page initPage(HttpServletRequest request) {
        String currentPageStr = request.getParameter("currentPage");
        String queryStr = QueryStrCreator.create("productTable", request);
        int currentPage = 1; //当前页码
        int size = 20; //每页的记录数
        try { //防止从地址栏直接输入非法页码
            if (currentPageStr != null) currentPage = new Integer(
                    currentPageStr).intValue();
        } catch (Exception e) {
            e.printStackTrace();
        }
        //处理分页
        //会话中是否已有分页生成工具
        PageTool pageTool = null;
        HttpSession session = request.getSession();
        pageTool = (PageTool) session.getAttribute("productPageTool"); //有，则直接拿来用
        if (pageTool == null) { //没有，则新建，并放进会话中，以备下次用
            pageTool = PageToolBuilder.builder(new ProductTableDAO());
            session.setAttribute("productPageTool", pageTool);
        }
        //由分页工具生成分页
        Page page = null;
        try {
            String flag = request.getParameter("flag");
            if (flag.equals("query")) //查询时的分页
                page = pageTool.createPage(currentPage, size, queryStr);
            else //其它非查询的分页
                page = pageTool.createPage(currentPage, size);
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        //将分页放进请求中，分发到下一个页面显示
        request.setAttribute("allProductPage", page);
        return page;
    }
}