Subversion Repositories DevTools

                    Package p = findPackage(pv_id, packageCollection);

                    Package p = findPackage(pv_id, packageCollection);

                    String test_type_name = rset11.mustGetString("test_type_name");

                    String user_email = rset12.getString("user_email",null);

        catch ( SQLException e )

        {

            handleSQLException(e, "");

        }

    /**

     * Extract all TEST package-version information

     * Only active in Daemon Mode

     * 

     * @param   rippleEngine        - Instance to use

     * @param   packageCollection   - Package Collection structure to fill. Expected to be cleared

     * @param   baseline            - RtagId of the release being processed, BomId of an Escrow being processed

     *  

     * Overridden in ReleaseManagerUtf

     *  

     */

    protected void queryTest(RippleEngine rippleEngine, ArrayList<Package> packageCollection, int baseline) throws SQLException, Exception

    {

        if (!mDaemon){

            return;

        }

        Phase phase = new Phase("rmData");

        mLogger.debug("queryTest {}", mDaemon);

        try

        {

            // Daemon Instruction: Test Build Package

            //  An op code of 1 means test build

            //

            // Trust nothing - these are mostly wips that at any time may have:

            // - no build location

            // - no build label

            // - an empty build standard collection

            // proceed with defaults above if necessary (the build will subsequently fail)

            // in all cases, build a meaningful email body to inform the user

            // of the snapshot of build information that applied to the build and store in:

            // - mTestBuildEmailBody

            mLogger.debug("queryTest: stmt141");

            phase.setPhase("getTestBuild1");

            DaemonInstruction di = new DaemonInstruction( baseline, 1, true);

            while ( getDaemonInst( di ) )

            {

                mLogger.info("queryPackageVersions test build data {}", di.pvId);

                Package p = getPackageInfo(di.pvId, rippleEngine);

                if ( p == NULL_PACKAGE )

                {

                    mLogger.error("queryTest rset15 no data found {}", di.instruction);

                    markDaemonInstCompleted( di.instruction );

                }

                else

                {

                    packageCollection.add(p);

                    //  Set some Test information

                    //  Avoid interaction with real versions

                    //  Flag as not pegged - so that we test build

                    p.mVersion = "0.0.0000";

                    p.mTestBuildInstruction = di.instruction;

                    p.addEmail(di.userEmail);

                    p.mBuildReason = BuildReason.Test;

                    p.mIsPegged = false;

                    p.mIsNotReleased = true;

                }

            }

        }

        catch ( SQLException e )

        {

            handleSQLException(e, "");

        }

        phase.setPhase("End");

    }

    /**

     * Extract all Ripple Request package-version information

     * The returned list is in daemon instruction id order - ie the first request will be first

     * Only active in Daemon Mode

     * 

     * @param   rippleEngine        - Instance to use

     * @param   packageCollection   - Package Collection structure to fill. Expected to be cleared

     * @param   baseline            - RtagId of the release being processed, BomId of an Escrow being processed

     *  

     * Overridden in ReleaseManagerUtf

     *  

     */

    protected void queryRipples(RippleEngine rippleEngine, ArrayList<Package> packageCollection, int baseline) throws SQLException, Exception

    {

        if (!mDaemon){

            return;

        }

        Phase phase = new Phase("rmData");

        mLogger.debug("queryPackageVersions {}", mDaemon);

        try

        {

            // Daemon Instruction: Force Package Ripple

            //  An op code of 0 means force ripple

            phase.setPhase("getDaemonInstructions1");

            DaemonInstruction di = new DaemonInstruction( baseline, 0, true);

            while ( getDaemonInst( di ) )

            {

                Package p = getPackageInfo(di.pvId, rippleEngine);

                if ( p != NULL_PACKAGE )

                {

                    mLogger.info("queryPackageVersions forced ripple data {}", di.pvId);

                    packageCollection.add(p);

                    p.mForcedRippleInstruction = di.instruction;

                    p.addEmail(di.userEmail);

                    p.mBuildReason = BuildReason.Ripple;

                    p.mIsNotReleased = true;

                }

                else

                {

                    // discard

                    markDaemonInstCompleted( di.instruction );

                }

            }

        }

        catch ( SQLException e )

        {

            handleSQLException(e, "");

        }

        phase.setPhase("End");

    }

    /** Get all build information for a single package

     *  Don't use this where lots of packages are expected, but should be OK to get data for TEST, WIP and Ripples

     *  

     *  Does not get:

     *      mBuildReason

     *      mDirectlyPlanned

     *  

     *  @param  pvId    - Package to process

     * @param rippleEngine - Ripple engine associated wit the Release

     * @throws Exception 

     *  

     *  @returns a package - May be null, but this is not good

     */

    Package getPackageInfo(int pvId, RippleEngine rippleEngine) throws Exception

    {

        Package p = NULL_PACKAGE;

        try

        {

            // Get Package info

            //

            mLogger.debug("getPackageInfo: stmt1");

            PreparedStatement stmt1 = mConnection.prepareStatement(

                    "select pv.pv_id, p.pkg_id, p.pkg_name, pv.pkg_version, " +

                            " pv.v_ext, pv.change_type, pv.ripple_field," +

                            " pv.major_limit, pv.minor_limit, pv.patch_limit, pv.build_number_limit," +

                            " pv.modified_stamp," +

                            " release_manager.PK_RMAPI.return_vcs_tag(pv.pv_id) AS vcsTag," +

                            " pv.build_time" +

                            " from " +

                            "      release_manager.package_versions pv," +

                            "      release_manager.packages p" +

                            " where pv.pv_id=" + pvId +

                            "   and p.pkg_id=pv.pkg_id"

                    );

            stmt1.setFetchSize(500);

            RmResultSet rset1 = new RmResultSet(stmt1.executeQuery(), "getPackageInfo rset1");

            //  Package must exist

            if ( ! rset1.next() )

            {

                return NULL_PACKAGE;

            }

            int pv_id = rset1.mustGetKeyInt("pv_id");

            int pkg_id = rset1.mustGetInt("pkg_id");

            String pkg_name = rset1.mustGetString("pkg_name");

            String pkg_version = rset1.mustGetString("pkg_version");

            int buildTime = rset1.getInt("build_time", 60);

            // Previous Version of this package, without the project suffix

            String pkg_prevVersion = getBaseVersionNumber(pv_id);

            if ( pkg_prevVersion == null)

            {

                // show stopper

                mLogger.error("getPackageInfo. No Previous version {}", pv_id);

                throw new Exception("getPackageInfo. No Previous version" + pv_id);

            }

            String v_ext = rset1.getString("v_ext","");

            String change_type = rset1.getString("change_type", "P");

            char ct = 'P';

            if ( change_type.compareTo("M") == 0 )

            {

                ct = 'M';

            }

            else if ( change_type.compareTo("N") == 0 )

            {

                ct = 'N';

            }

            else if ( change_type.compareTo("P") == 0 )

            {

                ct = 'P';

            }

            else if ( change_type.compareTo("F") == 0 )

            {

                ct = 'F';

            }

            String ripple_field = rset1.getString("ripple_field", "b");

            int major_limit = rset1.getInt("major_limit", 0);

            int minor_limit = rset1.getInt("minor_limit",0);

            int patch_limit = rset1.getInt("patch_limit",0);

            int build_number_limit = rset1.getInt("build_number_limit",0);

            String vcs_tag = rset1.getString("vcsTag", "");

            p = new Package(pkg_id, pv_id, pkg_name, pkg_version, v_ext, pkg_name + v_ext, vcs_tag, ripple_field.charAt(0), ct);

            p.mMajorLimit = major_limit;

            p.mMinorLimit = minor_limit;

            p.mPatchLimit = patch_limit;

            p.mBuildLimit = build_number_limit;

            p.mPrevVersion = pkg_prevVersion;

            p.mBuildTime = buildTime;

            rset1.close();

            stmt1.close();

            // get Package dependency info

            mLogger.debug("getPackageInfo: stmt2");

            PreparedStatement stmt2 = mConnection.prepareStatement(

                    "select dpv.v_ext, dpv.pv_id" +

                            " from " +

                            "     release_manager.package_versions pv,"+

                            "     release_manager.package_dependencies pd," +

                            "     release_manager.package_versions dpv"+

                            " where pv.pv_id=" + pvId + 

                            "  and pd.pv_id=pv.pv_id"+

                            "  and dpv.pv_id=pd.dpv_id"

                    );

            stmt2.setFetchSize(500);

            RmResultSet rset2 = new RmResultSet(stmt2.executeQuery(), "getPackageInfo rset2");

            while ( rset2.next() )

            {

                String dpv_ext = rset2.mustGetKeyString("v_ext");

                int    dpvId = rset2.mustGetInt("pv_id");

                p.mDependencyCollection.add(pkg_name + dpv_ext);

                p.mDependencyIDCollection.add(dpvId);

            }

            rset2.close();

            stmt2.close();

            // get Package build info

            mLogger.debug("getPackageInfo: stmt3");

            PreparedStatement stmt3 = mConnection.prepareStatement(

                    "select bm.bm_name, bsa.bsa_name" +

                            " from " +

                            "   release_manager.package_versions pv," +

                            "   release_manager.package_build_info pbi," +

                            "   release_manager.build_machines bm," +

                            "   release_manager.build_standards_addendum bsa " +

                            " where pv.pv_id=" + pvId + 

                            "   and pbi.pv_id=pv.pv_id" +

                            "   and bm.bm_id=pbi.bm_id" +

                            "   and bsa.bsa_id=pbi.bsa_id "

                    );

            stmt3.setFetchSize(500);

            RmResultSet rset3 = new RmResultSet(stmt3.executeQuery(), "getPackageInfo rset3");

            while ( rset3.next() )

            {

                String bm_name = rset3.mustGetString("bm_name");

                String bsa_name = rset3.mustGetString("bsa_name");

                BuildStandard bs = new BuildStandard(rippleEngine, bm_name, bsa_name);

                if ( bs.supportedBuildStandard() )

                {

                    p.mBuildStandardCollection.add(bs);

                }

            }

            rset3.close();

            stmt3.close();

            // get Package unit test info

            mLogger.debug("getPackageInfo: stmt4");

            PreparedStatement stmt4 = mConnection.prepareStatement(

                    "select pv.pv_id, tt.test_type_name" +

                    "  from "+

                    "       release_manager.package_versions pv,"+

                    "       release_manager.unit_tests ut," +

                    "       release_manager.test_types tt" +

                    " where pv.pv_id=" + pvId + 

                    "  and ut.pv_id=pv.pv_id" +

                    "  and tt.test_type_id=ut.test_types_fk"

                    );

            stmt4.setFetchSize(500);

            RmResultSet rset4 = new RmResultSet(stmt4.executeQuery(), "getPackageInfo rset4");

            while ( rset4.next() )

            {

                String test_type_name = rset4.mustGetString("test_type_name");

                if ( test_type_name.compareTo("Autobuild UTF") == 0 )

                {

                    p.mHasAutomatedUnitTests = true;

                }

            }

            rset4.close();

            stmt4.close();

            // get Package build failure info...

            //      view based

            mLogger.debug("getPackageInfo: stmt5");

            PreparedStatement stmt5 = mConnection.prepareStatement(

                    "SELECT rc.pv_id," +

                            "  u.user_email" +

                            " FROM release_manager.release_content rc," +

                            "  release_manager.release_tags rt," +

                            "  release_manager.package_versions pv," +

                            "  release_manager.autobuild_failure af," +

                            "  release_manager.members_group mg," +

                            "  release_manager.users u" +

                            " WHERE rc.rtag_id     = " + rippleEngine.getRtagId() +

                            " AND rt.rtag_id       = rc.rtag_id" +

                            " AND pv.pv_id=" + pvId +

                            " AND pv.pv_id         = rc.pv_id" +

                            " AND af.view_id       = rc.base_view_id" +

                            " AND mg.group_email_id= af.group_email_id" +

                            " AND u.user_id        = mg.user_id" +

                            " AND af.proj_id       = rt.proj_id"

                    );

            stmt5.setFetchSize(500);

            RmResultSet rset5 = new RmResultSet(stmt5.executeQuery(), "getPackageInfo rset5");

            while ( rset5.next() )

            {

                p.addEmail(rset5.getString("user_email", null));

            }

            rset5.close();

            stmt5.close();

            // get Package build failure info...

            // package version

            mLogger.debug("getPackageInfo: stmt6");

            PreparedStatement stmt6 = mConnection.prepareStatement(

                    "select pv.pv_id, u1.user_email as creator, u2.user_email as owner, u3.user_email as modifier" +

                    " from " +

                    "      release_manager.release_tags rt," +

                    "      release_manager.package_versions pv," +

                    "      release_manager.users u1," +

                    "      release_manager.users u2," +

                    "      release_manager.users u3 " +

                    " where pv.pv_id=" + pvId + 

                    "   and rt.rtag_id=" + rippleEngine.getRtagId() + 

                    "   and pv.build_type='A'" +

                    "   and pv.dlocked='A' " +

                    "   and u1.user_id=pv.creator_id" +

                    "   and u2.user_id=pv.owner_id" +

                    "   and u3.user_id=pv.modifier_id"

                    );

            stmt6.setFetchSize(500);

            RmResultSet rset6 = new RmResultSet(stmt6.executeQuery(), "getPackageInfo rset6");

            while ( rset6.next() )

            {

                p.addEmail( rset6.getString("creator",null));

                p.addEmail( rset6.getString("owner",null));

                p.addEmail( rset6.getString("modifier",null));

            }

            rset6.close();

            stmt6.close();

            // get Package advisory ripple info

            mLogger.debug("getPackageInfo: stmt7");

            PreparedStatement stmt7 = mConnection.prepareStatement(

                    "select pv.pv_id, pv.modified_stamp " +

                    " from " +

                    "      release_manager.package_versions pv," +

                    "      release_manager.advisory_ripple ar " +

                    " where pv.pv_id = " + pvId +

                    "    and ar.rtag_id=" + rippleEngine.getRtagId() +

                    "    and ar.pv_id=pv.pv_id "

                    );

            stmt7.setFetchSize(500);

            RmResultSet rset7 = new RmResultSet(stmt7.executeQuery(), "getPackageInfo rset7");

            if( rset7.next() )

            {

                p.mAdvisoryRipple = true;

            }

            rset7.close();

            stmt7.close();            

        }

        catch ( SQLException e )

        {

            handleSQLException(e, "");

        }

        return p;

    }

    int findPackageLastId = 0;

    int findPackageLastIndex = 0;

    Package findPackageLastPackage = NULL_PACKAGE;

            mLogger.debug("findPackage id {} - cache hit", id);

            retVal = findPackageLastPackage;

        }

        else

            for (Iterator<Package> it = packageCollection.iterator(); it.hasNext(); index++ )

                Package p = it.next();

                if ( p.mId == id )

                {

                    findPackageLastId = id;

                    findPackageLastPackage = p;

                    findPackageLastIndex = index;

                }

        int index = 0;

        findPackageLastIndex = -1;

                findPackageLastId = p.mId;

                findPackageLastPackage = p;

                findPackageLastIndex = index;