jmdboconntioncall.java

梦界家园程序开发基底框架

             * 僶僢僠峏怴撪偺峏怴暥偺偆偪丄偙偺椺奜偑敪惗偡傞傑偱偵惓忢偵幚峴偝傟偨傕偺偡傋偰偵懳偡傞峏怴僇僂儞僩傪庢傝弌偟傑偡丅 僐儅儞僪偺 1
             * 偮偑惓偟偔幚峴偝傟側偐偭偨応崌丄僶僢僠峏怴傪幚憰偡傞僪儔僀僶偼丄僶僢僠偵巆偭偰偄傞僐儅儞僪偺張棟傪懕偗傞偙偲傕拞巭偡傞偙偲傕偱偒傑偡丅
             * 僪儔僀僶偑僐儅儞僪偺張棟傪宲懕偡傞応崌丄偙偺儊僜僢僪偵傛偭偰曉偝傟傞攝楍偼丄僶僢僠偵偁傞僐儅儞僪偲摨偠悢偺梫慺傪帩偭偰偄傑偡丅
             * 偦偆偱側偄応崌丄攝楍偼丄BatchUpdateException
             * 偑僗儘乕偝傟傞傑偱偵惓忢偵幚峴偝傟偨偡傋偰偺僐儅儞僪偵懳偡傞峏怴僇僂儞僩傪娷傫偱偄傑偡丅
             * 偙偺儊僜僢僪偵巊梡偱偒傞栠傝抣偼丄Java 2 SDK, Standard Edition, 僶乕僕儑儞 1.3
             * 偱曄峏偝傟傑偟偨丅 偙傟偼丄BatchUpdateException
             * 僆僽僕僃僋僩偑僗儘乕偝傟偨偁偲傕僶僢僠峏怴撪偺僐儅儞僪偺張棟傪宲懕偡傞丄偲偄偆怴偟偄僆僾僔儑儞偵揔墳偡傞偨傔偵峴傢傟傑偟偨丅
             *
             * 栠傝抣: 偙偺僄儔乕偑敪惗偡傞傑偱偵惓忢偵幚峴偝傟偨峏怴偺峏怴僇僂儞僩傪娷傓 int 宆偺攝楍丅
             * 偨偩偟丄僄儔乕屻傕僪儔僀僶偑僐儅儞僪偺張棟傪懕偗傞応崌偼丄僶僢僠撪偺奺僐儅儞僪偵懳偟偰師偺偄偢傟偐偺抣偑奿擺偝傟傞丅 峏怴僇僂儞僩
             * 僐儅儞僪偑惓忢偵幚峴偝傟偨偑塭嬁傪庴偗偨峴悢偼晄柧偱偁傞偙偲傪帵偡 Statement.SUCCESS_NO_INFO
             * 僐儅儞僪偑惓忢偵幚峴偝傟側偐偭偨偙偲傪帵偡 Statement.EXECUTE_FAILED
             *
             */
            // ex.getUpdateCounts();
            oDataOut.setResult(false);

            oDataOut.setResultCode(ex.getErrorCode());
            oDataOut.setResultMessage(ex.getMessage());
            return oDataOut;
        } catch (Exception ex) {
            throw ex;
        }
    }

    /*
     * 僐儅儞僪偺僶僢僠傪僨乕僞儀乕僗偵憲怣偟偰幚峴偟丄偡傋偰偺僐儅儞僪偑惓忢偵幚峴偝傟傞偲丄峏怴僇僂儞僩偺攝楍傪曉偟傑偡丅曉偝傟傞攝楍偺 int
     * 梫慺偼丄僶僢僠撪偺僐儅儞僪偵懳墳偟偰曉偝傟弴彉晅偗傜傟傑偡丅偮傑傝丄僶僢僠偵捛壛偝傟偨弴彉偵廬偭偰弴彉晅偗傜傟傑偡丅儊僜僢僪
     * executeBatch 偵傛偭偰曉偝傟傞攝楍撪偺梫慺偼丄師偺偳傟偐 1 偮偵奩摉偟傑偡丅 僛儘埲忋偺悢抣 --
     * 僐儅儞僪偑惓忢偵張棟偝傟偨偙偲傪帵偟丄僐儅儞僪偺幚峴偵傛偭偰塭嬁傪庴偗偨僨乕僞儀乕僗撪偺峴悢傪巜掕偡傞峏怴僇僂儞僩 SUCCESS_NO_INFO
     * 偺抣 -- 僐儅儞僪偑惓忢偵張棟偝傟偨偑丄塭嬁傪庴偗偨峴悢偑晄柧側偙偲傪帵偡 僶僢僠峏怴撪偺僐儅儞僪偺 1
     * 偮偑惓忢偵幚峴偱偒側偐偭偨応崌丄偙偺儊僜僢僪偼 BatchUpdateException 傪僗儘乕偟丄JDBC
     * 僪儔僀僶偼僶僢僠撪偺巆傝偺僐儅儞僪偺張棟傪宲懕偡傞偙偲傕丄拞巭偡傞偙偲傕偱偒傑偡丅偨偩偟丄僪儔僀僶偺摦嶌偼摿掕偺 DBMS
     * 偲堦娧惈傪曐偮昁梫偑偁傝丄忢偵僐儅儞僪偺張棟傪宲懕偡傞偐丄偁傞偄偼宲懕偟側偄偐偺偳偪傜偐偵側傝傑偡丅幐攕屻丄僪儔僀僶偑張棟傪宲懕偡傞応崌偼丄BatchUpdateException.getUpdateCounts
     * 儊僜僢僪偱曉偝傟傞攝楍偵偼丄僶僢僠撪偺僐儅儞僪偲摨偠悢偺梫慺偑奿擺偝傟丄偦傟傜偺梫慺偺 1 偮埲忋偑師偵奩摉偟傑偡丅
     *
     * EXECUTE_FAILED 偺抣 --
     * 幐攕偟偨僐儅儞僪偑惓忢偵幚峴偝傟偨偙偲傪帵偟丄僐儅儞僪偑幐攕偟偨偁偲偵丄僪儔僀僶偑僐儅儞僪偺張棟傪宲懕偟偨応崌偵尷傝敪惗偡傞
     * 僪儔僀僶偼偙偺儊僜僢僪傪幚憰偡傞昁梫偼偁傝傑偣傫丅Java 2 SDK, Standard Edition, 僶乕僕儑儞 1.3
     * 偱偼丄巊梡偱偒傞幚憰偍傛傃栠傝抣偑廋惓偝傟偰丄BatchUpdateException
     * 僆僽僕僃僋僩偑僗儘乕偝傟偨偁偲偵僶僢僠峏怴撪偺僐儅儞僪偺張棟傪宲懕偱偒傞僆僾僔儑儞偑梡堄偝傟偰偄傑偡丅
     *
     * 栠傝抣: 僶僢僠撪偺僐儅儞僪偛偲偵 1 偮偺梫慺偑奿擺偝傟偰偄傞峏怴僇僂儞僩偺攝楍丅攝楍偺梫慺偼僐儅儞僪偑僶僢僠偵捛壛偝傟偨弴彉偱暲傋傜傟傞
     * 椺奜: SQLException -
     * 僨乕僞儀乕僗傾僋僙僗僄儔乕偑敪惗偟偨応崌丄傑偨偼僪儔僀僶偑僶僢僠暥傪僒億乕僩偟側偄応崌丅僨乕僞儀乕僗偵憲怣偝傟偨僐儅儞僪偺 1
     * 偮偑惓忢偵幚峴偝傟側偐偭偨応崌傗丄寢壥僙僢僩傪曉偦偆偲偡傞偲 BatchUpdateException (SQLException 偺僒僽僋儔僗)
     * 偑僗儘乕偝傟傞 摫擖偝傟偨僶乕僕儑儞: 1.3
     */
    // protected synchronized JMMap<String, JMVal> executeFree() throws
    // Exception {
    // final String sMethod = "executeFree";
    // JMMap<String, JMVal> oDataOut = new JMMap<String, JMVal>();
    // try {
    // boolean pbresult = true;
    //
    // if (!mGetDbCon()) {
    // throw new Exception("DB Connection get err");
    // }
    // statement_ = conn_.prepareStatement(oDBSQLBean_.getSQL());
    //
    // int oOut = statement_.executeUpdate();
    //
    // if (!DBCommit() || !DBClose()) {
    // pbresult = false;
    // }
    //
    // oDataOut.put(SVC_DB_RESULT, new JMVal(pbresult));
    // oDataOut.put(SVC_DB_SQL_COUNT, new JMVal(oOut));
    //
    // return oDataOut;
    // } catch (SQLException ex) {
    // try {
    // DBRollback();
    // } catch (SQLException ez) {
    // throw new Exception(CLASS_NAME + "." + sMethod, ez);
    // }
    // oDataOut.put(SVC_DB_RESULT, new JMVal(false));
    // oDataOut.put(SVC_DB_SQL_CODE, new JMVal(ex.getErrorCode()));
    // oDataOut.put(SVC_DB_SQL_MESSAGE, new JMVal(ex.getMessage()));
    // return oDataOut;
    // } catch (Exception ex) {
    // ex.updateSource(CLASS_NAME + "." + sMethod);
    // throw ex;
    // } catch (Exception ex) {
    // throw new Exception(CLASS_NAME + "." + sMethod, ex);
    // }
    // }
    /*
     * 偙偺 PreparedStatement 僆僽僕僃僋僩偺 SQL INSERT 暥丄UPDATE 暥丄傑偨偼 DELETE
     * 暥傪幚峴偟傑偡丅偝傜偵丄DDL 暥偺傛偆側壗傕曉偝側偄 SQL 暥傪幚峴偡傞偙偲傕偱偒傑偡丅 栠傝抣: UPDATE 暥丄DELETE
     * 暥偺応崌偼峴悢丅壗傕曉偝側偄 SQL 暥偺応崌偼 0 椺奜: SQLException - 僨乕僞儀乕僗傾僋僙僗僄儔乕偑敪惗偟偨応崌丄傑偨偼
     * SQL 暥偑 ResultSet 僆僽僕僃僋僩傪曉偡応崌
     */
    protected synchronized JMDBOOutKeyValue executeOthers () throws Exception {
        JMDBOOutKeyValue oDataOut = new JMDBOOutKeyValue();
        try {
            boolean pbresult = true;

            if (!mGetDbCon()) {
                throw new Exception("DB Connection get err");
            }
            pstmt_ = conn_.prepareStatement(oDBSQLBean_.getSQL());

            int oOut = pstmt_.executeUpdate();

            if (!commit() || !close()) {
                pbresult = false;
            }

            oDataOut.setResult(pbresult);
            oDataOut.setResultCount(oOut);
            JM2DArray oOuts = new JM2DArray("DBResult");
            oOuts.setAutoNext(true);
            oOuts.addItem(SVC_DB_PARAM, oOut);

            oDataOut.setResultData(oOuts);

            return oDataOut;
        } catch (SQLException ex) {
            try {
                rollback();
            } catch (Exception ez) {
                throw ez;
            }
            oDataOut.setResult(false);

            oDataOut.setResultCode(ex.getErrorCode());
            oDataOut.setResultMessage(ex.getMessage());
            return oDataOut;
        } catch (Exception ex) {
            throw ex;
        }
    }

    /**
     * creat SQL
     *
     * @param flag
     *            boolean
     * @return String
     * @throws Exception
     */
    protected String mSQLSetTable (String asDBsql, boolean count, int iPageRowNo,
                                   int iCurrentPageNo) throws Exception {
        final String sMethod = "mSQLSetTable";
        try {
            StringBuffer sql = new StringBuffer();
            // get all count
            if (count) {
                sql.append("SELECT COUNT(1) ");
                sql.append(asDBsql.substring(asDBsql.indexOf("FROM"), asDBsql
                                             .length()));
            } else {
                if (iPageRowNo != 0) {
                }
            }
            return sql.toString();
        } catch (Exception e) {
            throw new Exception(CLASS_NAME + "." + sMethod, e);
        }
    }

    /**
     * get table data
     *
     * @param aoDbuse
     *            JM2DArray
     * @param asUsqlId
     *            String
     * @param iPageRowNo
     *            int
     * @param iCurrentRowNo
     *            int
     * @return JMMap<String,JMVal>
     * @throws Exception
     */
    protected synchronized JMDBOOutKeyValue mDBaseSelectTable (int iPageRowNo,
                                                               int iCurrentPageNo) throws Exception {
        JMDBOOutKeyValue oDataOut = new JMDBOOutKeyValue();
        JM2DArray oOut = new JM2DArray("DBResult");
        boolean pbresult = true;

        // sql set
        String rowcount = mSQLSetTable(oDBSQLBean_.getSQL(), true,
                                       iPageRowNo, iCurrentPageNo);
        if (!mDbConnSelect(rowcount)) {
            pbresult = false;
        } else {
            int count = Integer.parseInt(resultData_.getString(1));
            if (count == 0) {
                oDataOut.setResult(pbresult);
                oDataOut.setResultData(oOut);
                return oDataOut;
            }
        }

        oDataOut.setResult(pbresult);
        oDataOut.setResultData(oOut);
        return oDataOut;

    }

    protected synchronized boolean getSQLFromDB (String asSqlId) throws Exception {

        String psUSql = DB_SQLS + " '" + asSqlId + "'";
        // sql search
        if (!mDbConnSelect(psUSql)) {
            return false;
        }
        // ////////////////////////////////////////////////////////////////////
        // sql get
        while (resultData_.next()) {
            // SQL儅僗僞 SQL ID
            oDBSQLBean_.setStrSqlid(JMUtility.changNvl(resultData_
                                                       .getString(DB_KEY_SQLID)));
            // 嬈柋庬椶*/
           oDBSQLBean_.setStrType(JMUtility.changNvl(resultData_
                                                     .getString(DB_KEY_TYPE)));
            // 撪梕*/
           oDBSQLBean_.setStrSqldata(JMUtility.changNvl(resultData_
                                                        .getString(DB_KEY_SQLDATA)));
            // 撪梕*/
           oDBSQLBean_.setStrSqltable(JMUtility.changNvl(resultData_
                                                         .getString(DB_KEY_SQLTABLE)));
            // 撪梕*/
           oDBSQLBean_.setStrSqlwhere(JMUtility.changNvl(resultData_
                                                         .getString(DB_KEY_SQLWHERE)));
            // 撪梕*/
           oDBSQLBean_.setStrSqlorderby(JMUtility.changNvl(resultData_
                                                           .getString(DB_KEY_SQLORDERBY)));
            // 撪梕*/
           oDBSQLBean_.setStrSqlgroupby(JMUtility.changNvl(resultData_
                                                           .getString(DB_KEY_SQLGROUPBY)));
            // 尃尷*/
           oDBSQLBean_.setStrRool(JMUtility.changNvl(resultData_
                                                     .getString(DB_KEY_ROOL)));
        }

        return oDBSQLBean_.invoker();

    }

    /**
     * SQL 暥惗惉
     *
     * @param asSqlId
     * @return
     * @throws Exception
     */
    protected synchronized boolean mGetSQL (String iSQLId) throws Exception {
        String sqlFromType = oDBSQLBean_.getSqlFromType();
        if (isSQLFree_) {
            oDBSQLBean_.setSQL(iSQLId);
            return oDBSQLBean_.invoker();
        } else if (SVC_DB_TYPE_DB.equals(sqlFromType)) {
            return getSQLFromDB(iSQLId);
        } else if (SVC_DB_TYPE_XML.equals(sqlFromType)) {
            return getSQLFromDB(iSQLId);
        } else if (SVC_DB_TYPE_PROPERTIES.equals(sqlFromType)) {
            return getSQLFromDB(iSQLId);
        }
        return false;
    }

    protected synchronized JMDBOOutKeyValue mDBasePicCon () throws Exception {
        final String sMethod = "mDBasePicCon";
        JMDBOOutKeyValue oDataOut = new JMDBOOutKeyValue();
        // boolean pbresult = true;
        try {