simpleentitytable.java

MSN客服自动化机器人

            }
        }

        if (!JMCheck.isNull(orderby)) {
            sql.append(" order by " + orderby);
        }
        value_.setStrType(SVC_SELECT);
        value_.setSQLID(sql.toString());
//System.out.println("select==" + value_.getSQLID());
        return execute(value_);
    }

    public DBOutValue select(String sqlWhere, String orderby, String groupby,
            String[] fields) throws Exception {
        StringBuffer sql = new StringBuffer(getSQLFirst(fields));
        // where
        if (!JMCheck.isNull(sqlWhere)) {
            sql.append(" where " + sqlWhere);
        } else {
            sqlWhere = getSQLWhere();
            if (!"".equals(sqlWhere)) {
                sql.append(" where " + sqlWhere);
            }
        }

        if (!JMCheck.isNull(orderby)) {
            sql.append(" order by " + orderby);
        }
        if (!JMCheck.isNull(groupby)) {
            sql.append(" group by " + groupby);
        }

        value_.setStrType(SVC_SELECT);
        value_.setSQLID(sql.toString());
//System.out.println("select==" + value_.getSQLID());
        return execute(value_);
    }

    public DBOutValue insert() throws Exception {
        StringBuffer sql = new StringBuffer();
        StringBuffer sqlParam = new StringBuffer();
        // insert
        sql.append(" insert into ");
        // from
        sql.append(" " + this.getName() + " (");
        JM2DArray iParameter = new JM2DArray();
        JMUtility.reflectIntoJM2DArray(entity_, iParameter, -1);

        JMVector colNames = iParameter.getColNames();

        boolean addG = false;
        for (int i = 0; i < colNames.size(); i++) {
            if (addG) {
                sql.append(" , ");
                sqlParam.append(" , ");
            } else {
                addG = true;
            }
            sql.append(colNames.get(i));
            sqlParam.append(" ? ");
        }

        value_.setStrType(SVC_INSERT);
        value_.setSQLID(sql + " ) values ( " + sqlParam + " )");
        value_.setUpParameter(iParameter);
//System.out.println("insert.SQLID==" + value_.getSQLID());
//System.out.println("insert.iParameter==" + iParameter);
        return execute(value_);
    }

    /**
     * û������ֶ�ʹ��Ĭ��ֵ������ݿ⣨Ĭ��ֵΪ��ǿո�1��
     * @return
     * @throws Exception
     */
    public DBOutValue insertUseDefaultBlank() throws Exception {
        return insertUseDefault(ITEM_BLANK);
    }
    public DBOutValue insertUseDefault(String defaultValue) throws Exception {
        StringBuffer sql = new StringBuffer();
        StringBuffer sqlParam = new StringBuffer();
        // insert
        sql.append(" insert into ");
        // from
        sql.append(" " + this.getName() + " (");
        JM2DArray iParameter = new JM2DArray();
        //JMUtility.reflectIntoJM2DArray(entity_, iParameter, -1);
        JMVector colnames = new JMVector(entity_.getItems().split(JMEntity.SPLIT));
        for (int i = 0; i < colnames.size(); i++) {
            String fieldValue = entity_.getFieldValue(""+colnames.get(i));
            if(JMCheck.isNull(fieldValue)){
                fieldValue = defaultValue;
            }
            iParameter.addItem(""+colnames.get(i), fieldValue);            
        }

        JMVector colNames = iParameter.getColNames();

        boolean addG = false;
        for (int i = 0; i < colNames.size(); i++) {
            if (addG) {
                sql.append(" , ");
                sqlParam.append(" , ");
            } else {
                addG = true;
            }
            sql.append(colNames.get(i));
            sqlParam.append(" ? ");
        }

        value_.setStrType(SVC_INSERT);
        value_.setSQLID(sql + " ) values ( " + sqlParam + " )");
        value_.setUpParameter(iParameter);
//System.out.println("SQLID==" + value_.getSQLID());
//System.out.println("iParameter==" + iParameter);
        return execute(value_);
    }
    public DBOutValue update(String sqlWhere) throws Exception {
        StringBuffer sql = new StringBuffer();

        // delete
        sql.append(" update ");
        // from
        sql.append(" " + this.getName() + " ");
        // set
        sql.append(" set ");

        boolean addG = false;
        JMMap paramters = new JMMap();
        JMUtility.reflectIntoJMMap(entity_, paramters);
        Iterator it = paramters.entrySet().iterator();
        while (it.hasNext()) {
            Map.Entry mpField = (Map.Entry) it.next();
            if (!JMCheck.isNull(mpField.getValue())) {
                if (addG) {
                    sql.append(" , ");
                } else {
                    addG = true;
                }
                sql.append(mpField.getKey() + " = " + "'" + mpField.getValue()
                        + "'");
            }
        }

        if (!JMCheck.isNull(sqlWhere)) {
            sql.append(" where " + sqlWhere);
        }

        value_.setStrType(SVC_UPDATE);
        value_.setSQLID(sql.toString());
//System.out.println("update(String sqlWhere)==" + sql);
        return execute(value_);
    }

    public DBOutValue update(JMEntity whereEntity) throws Exception {
        StringBuffer sql = new StringBuffer();

        // delete
        sql.append(" update ");
        // from
        sql.append(" " + this.getName() + " ");
        // set
        sql.append(" set ");

        boolean addG = false;
        JMMap paramters = new JMMap();
        JMUtility.reflectIntoJMMap(entity_, paramters);
        Iterator it = paramters.entrySet().iterator();
        //���set ���
        while (it.hasNext()) {
            Map.Entry mpField = (Map.Entry) it.next();
            if (!JMCheck.isNull(mpField.getValue())) {
                if (addG) {
                    sql.append(" , ");
                } else {
                    addG = true;
                }
                sql.append(mpField.getKey() + " = " + "'" + mpField.getValue()
                        + "'");
            }
        }

        //���where���
        if (whereEntity != null) {
            //            JM2DArray dataSource = new JM2DArray();
            //            JMUtility.reflectIntoJM2DArray(oldEntity, dataSource, -1);
            //            JMVector<String> colnames = dataSource.getColNames();
            //            addG = false;
            //            for (int i = 0; i < colnames.size(); i++) {
            //                if (!JMCheck.isNull(dataSource.getStringValue(0, i))) {
            //                    if (addG) {
            //                        sql.append(" and ");
            //                    } else {
            //                        addG = true;
            //                        sql.append(" where ");
            //                    }
            //                    sql.append(colnames.get(i) + " = " + "'" + dataSource.getStringValue(0, i) + "'");
            //                }
            //            }
            String sqlWhere = getSQLWhere(whereEntity);
            if (!"".equals(sqlWhere)) {
                sql.append(" where " + sqlWhere);
            }
        }
        value_.setStrType(SVC_UPDATE);
        value_.setSQLID(sql.toString());
//System.out.println("update(JMEntity whereEntity)==" + whereEntity);
//System.out.println("update(JMEntity whereEntity)==" + sql);
        return execute(value_);
    }

    public DBOutValue delete() throws Exception {
        StringBuffer sql = new StringBuffer(" delete from " + this.getName()
                + " ");
        /////////////////////////////////////////
        StringBuffer sqlWhere = new StringBuffer();
        boolean addG = false;
        JMMap paramters = new JMMap();
        JMUtility.reflectIntoJMMap(entity_, paramters);
//System.out.println("paramters===" + paramters);
        Iterator it = paramters.entrySet().iterator();
        while (it.hasNext()) {
            Map.Entry mpField = (Map.Entry) it.next();
            if (!JMCheck.isNull(mpField.getValue())) {
                if (addG) {
                    sqlWhere.append(" and ");
                } else {
                    addG = true;
                }
                sqlWhere.append(mpField.getKey() + " = " + "'"
                        + mpField.getValue() + "'");
            }
        }
        if (addG) {
            sql.append(" where " + sqlWhere);
        }

        value_.setStrType(SVC_DELETE);
        value_.setSQLID(sql.toString());
//System.out.println("delete==" + sql);
        //        if(true){
        //            return new DBOutValue();
        //        }
        return execute(value_);
    }

    public DBOutValue delete(String where) throws Exception {
        StringBuffer sql = new StringBuffer(" delete from " + this.getName()
                + " ");
        if (!JMCheck.isNull(where)) {
            sql.append(" where " + where);
        }

        value_.setStrType(SVC_DELETE);
        value_.setSQLID(sql.toString());

        return execute(value_);
    }

    // //////////////////////////////////////////////////////////////////////////////
    /**
     * SQL ����
     *
     * @param inValue
     *            DBInValue
     * @return DBOutValue
     * @throws Exception
     */
    private synchronized DBOutValue execute(DBInValue inValue) throws Exception {

        conntion_ = JMDBOConntionCall.getInstance();
        conntion_.setSQLFree(true);
        // SQL ����
        JMDBOOutKeyValue _result = conntion_.inVoker(inValue);
        DBOutValue result = new DBOutValue();
        result.setResult(_result.getResult());
        result.setResultCode(_result.getResultCode());
        result.setResultCount(_result.getResultCount());
        result.setResultData(_result.getResultData());
        result.setResultList(_result.getResultList());
        result.setResultMessage(_result.getResultMessage());
        return result;
    }

}