Subversion Repositories DevTools

          // force ripple info

          // an op code of 0 means force ripple

          MutableInt instruction = new MutableInt();

          instruction.value = 0;

          MutableInt pvid = new MutableInt();

          MutableInt userid = new MutableInt();

          while ( getDaemonInst( baseline, instruction, 0, pvid, userid ) )

          {

            Package p = findPackage(pvid.value, packageCollection);

            if ( p != NULL_PACKAGE )

            {

              mLogger.info("queryPackageVersions forced ripple data " + pvid.value);

              p.mForcedRippleInstruction = instruction.value;

            }

            else

            {

              // discard

              markDaemonInstCompleted( instruction.value );

            }

          }

          // test build info

          // bare minimal data collection - last thing needed is more data to collect

          // the approach...

          // query all test build instructions for this baseline

          // for each, query its build information

          // store them in "mTestBuild" Package attributes as follows:

          // - mTestBuildInstruction (default 0)

          // - mTestBuildEmail (default "null")

          // - mTestBuildLocation (default "null")

          // - mTestBuildLabel (default "null")

          // - mTestBuildStandardCollection

          // - mTestBuildDependencyCollection

          // additionally, trust nothing - these are 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

          // an op code of 1 means test build

          instruction.value = 0;

          while ( getDaemonInst( baseline, instruction, 1, pvid, userid ) )

          {

            // can only do one test build at a time - others will be discarded until future cycle

            boolean discard = false;

            mLogger.info("queryPackageVersions test build data " + pvid.value);

            int testBuildPvId = pvid.value;

            int testBuildInstruction = instruction.value;

            String testBuildEmail = "";

            CallableStatement stmt141 = mConnection.prepareCall(

            "select user_email from release_manager.users where user_id=" + userid.value);

            ResultSet rset141 = stmt141.executeQuery();

            while( rset141.next() )

            {

              testBuildEmail = rset141.getString("user_email");

              if ( testBuildEmail == null )

              {

                // no one to inform - discard

                discard = true;

              }

            }

            rset141.close();

            stmt141.close();

            if ( discard )

            {

              mLogger.error("queryPackageVersions rset141 null user_email " + userid.value);

              markDaemonInstCompleted( instruction.value );

            }

            else

            {

              String pkg_name = "";

              String pkg_ext = "";

              String testBuildLabel = "null";

              String testBuildLocation = "null";

              // get wip package info

              CallableStatement stmt15 = mConnection.prepareCall(

              "select p.pkg_name, pv.v_ext, pv.pkg_label, pv.src_path " +

              "from release_manager.work_in_progress wip, release_manager.package_versions pv, release_manager.packages p " +

              "where wip.rtag_id=" + baseline +

              " and pv.pv_id=" + testBuildPvId +

              " and wip.pv_id=" + testBuildPvId +

              " and p.pkg_id=pv.pkg_id "

              );

              ResultSet rset15 = stmt15.executeQuery();

              int rsetSize = 0;

              while( rset15.next() )

              {

                rsetSize++;

                pkg_name = rset15.getString("pkg_name");

                if ( pkg_name == null )

                {

                  mLogger.fatal("queryPackageVersions rset15 null pkg_name " + testBuildPvId);

                  // show stopper

                  throw new Exception("queryPackageVersions rset15 null pkg_name " + testBuildPvId);

                }

                pkg_ext = rset15.getString("v_ext");

                if ( pkg_ext == null )

                {

                  pkg_ext = "";

                }

                testBuildLabel = rset15.getString("pkg_label");

                if ( testBuildLabel == null )

                {

                  testBuildLabel = "null";

                }

                testBuildLocation = rset15.getString("src_path");

                if ( testBuildLocation == null )

                {

                  testBuildLocation = "null";

                }

              }

              rset15.close();

              stmt15.close();

              if ( rsetSize == 0 )

              {

                mLogger.error("queryPackageVersions rset15 no wip found " + instruction.value);

                markDaemonInstCompleted( instruction.value );

              }

              else

              {

                Package q = findPackage(pkg_name + pkg_ext, packageCollection);

                if ( q == NULL_PACKAGE )

                {

                  // wip package alias does not exist in this release (planned or released packages)

                  q = new Package( pkg_name, pkg_ext, pkg_name + pkg_ext, testBuildLabel, testBuildLocation, testBuildInstruction, testBuildEmail);

                  packageCollection.add(q);

                }

                else

                {

                  // avoid interaction with real versions

                  q.mVersion = "0.0.0000";

                  q.mTestBuildLabel = testBuildLabel;

                  q.mTestBuildLocation = testBuildLocation;

                  q.mTestBuildInstruction = testBuildInstruction;

                  q.mTestBuildEmail = testBuildEmail;

                }

                // get wip package dependency info

                CallableStatement stmt16 = mConnection.prepareCall(

                "select p.pkg_name, dpv.v_ext " +

                "from release_manager.work_in_progress wip, release_manager.package_versions pv, " +

                "release_manager.package_dependencies pd, release_manager.package_versions dpv, release_manager.packages p " +

                "where wip.rtag_id=" + baseline +

                " and pv.pv_id=" + testBuildPvId +

                " and wip.pv_id=" + testBuildPvId +

                " and pd.pv_id=" + testBuildPvId +

                " and dpv.pv_id=pd.dpv_id and p.pkg_id=dpv.pkg_id "

                );

                ResultSet rset16 = stmt16.executeQuery();

                while( rset16.next() )

                {

                  String dpkg_name = rset16.getString("pkg_name");

                  if ( dpkg_name == null )

                  {

                    mLogger.fatal("queryPackageVersions rset16 null pkg_name " + testBuildPvId);

                    // show stopper

                    throw new Exception("queryPackageVersions rset16 null pkg_name " + testBuildPvId);

                  }

                  String v_ext = rset16.getString("v_ext");

                  if ( v_ext == null )

                  {

                    v_ext = "";

                  }

                  q.mTestBuildDependencyCollection.add(dpkg_name + v_ext);

                }

                rset16.close();

                stmt16.close();

                // get planned package build info

                CallableStatement stmt17 = mConnection.prepareCall(

                "select bm.bm_name, bsa.bsa_name " +

                "from release_manager.work_in_progress wip, release_manager.package_versions pv, release_manager.package_build_info pbi, release_manager.build_machines bm, release_manager.build_standards_addendum bsa " +

                "where wip.rtag_id=" + baseline +

                " and wip.pv_id=" + testBuildPvId +

                " and pv.pv_id=" + testBuildPvId +

                " and pbi.pv_id=pv.pv_id and bm.bm_id=pbi.bm_id and bsa.bsa_id=pbi.bsa_id "

                );

                ResultSet rset17 = stmt17.executeQuery();

                while( rset17.next() )

                {

                  String bm_name = rset17.getString("bm_name");

                  if ( bm_name == null )

                  {

                    mLogger.fatal("queryPackageVersions rset17 null bm_name " + testBuildPvId);

                    // show stopper

                    throw new Exception("queryPackageVersions rset17 null bm_name " + testBuildPvId);

                  }

                  String bsa_name = rset17.getString("bsa_name");

                  if ( bsa_name == null )

                  {

                    mLogger.fatal("queryPackageVersions rset17 null bsa_name " + testBuildPvId);

                    // show stopper

                    throw new Exception("queryPackageVersions rset17 null bsa_name " + testBuildPvId);

                  }

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

                  if ( bs.supportedBuildStandard() )

                  {

                    q.mTestBuildStandardCollection.add(bs);

                  }

                }

                rset17.close();

                stmt17.close();

              }

            }

          }

   * testBuildInstruction IN will prevent the execution of Exclude_Indirect_From_Build when > 0

                               String rootCause, String rootFile,

    if ( testBuildInstruction > 0 )

    {

      return;

    }

        disconnect();

      }

    }

  }

  /**executes the get_daemon_inst function with the passed parameters

   * returns true when an instruction exists

   */

  private boolean getDaemonInst(final int rtagId, MutableInt instruction, 

                               final int opCode, MutableInt pvId, MutableInt userId ) throws SQLException, Exception

  {

    mLogger.debug("getDaemonInst " + instruction);

    boolean retVal = false;

    if ( mUseDatabase )

    {

      try

      {

        CallableStatement stmt = mConnection.prepareCall( "begin ? := PK_BUILDAPI.GET_DAEMON_INST(?,?,?,?,?,?); end;" );

        stmt.registerOutParameter(1, Types.INTEGER);

        stmt.registerOutParameter(3, Types.INTEGER);

        stmt.registerOutParameter(4, Types.INTEGER);

        stmt.registerOutParameter(5, Types.INTEGER);

        stmt.registerOutParameter(6, Types.INTEGER);

        stmt.registerOutParameter(7, Types.INTEGER);

        stmt.setInt(2, rtagId );

        stmt.setInt( 3, instruction.value );

        stmt.setInt( 4, opCode );

        stmt.execute();

        int result = stmt.getInt( 1 );

          retVal = true;

          instruction.value = stmt.getInt( 3 );

          pvId.value = stmt.getInt( 5 );

          userId.value = stmt.getInt( 6 );

        }

      }

      catch( SQLException e )

      {

        if ( mConnection == null || ( mConnection != null && !mConnection.isValid(10) ) )

        {

          mLogger.error("getDaemonInst database access error only");

          throw new SQLException();

        }

        else

        {

          mLogger.fatal("getDaemonInst show stopper");

          throw new Exception("getDaemonInst show stopper");

    return retVal;

  }

  /**executes the mark_daemon_inst_in_progress function with the passed parameters

   */

  public void markDaemonInstInProgress(final int instruction) throws SQLException, Exception

  {

    mLogger.debug("markDaemonInstInProgress " + instruction);

    if ( mUseDatabase )

    {

      try

      {

        CallableStatement stmt = mConnection.prepareCall( "call PK_BUILDAPI.MARK_DAEMON_INST_IN_PROGRESS(?)" );

        stmt.setInt( 1, instruction );

        stmt.executeUpdate();

        stmt.close();

      }

      catch( SQLException e )

      {

        if ( mConnection == null || ( mConnection != null && !mConnection.isValid(10) ) )

        {

          mLogger.error("markDaemonInstInProgress database access error only");

          throw new SQLException();

        }

        else

        {

          mLogger.fatal("markDaemonInstInProgress show stopper");

          throw new Exception("markDaemonInstInProgress show stopper");

        }

      }

    }

  }

  /**executes the mark_daemon_inst_completed function with the passed parameters

   */

  public void markDaemonInstCompleted(final int instruction) throws SQLException, Exception

  {

    mLogger.debug("markDaemonInstCompleted " + instruction);

    if ( mUseDatabase )

    {

      try

      {

        CallableStatement stmt = mConnection.prepareCall( "call PK_BUILDAPI.MARK_DAEMON_INST_COMPLETED(?)" );

        stmt.setInt( 1, instruction );

        stmt.executeUpdate();

        stmt.close();

      }

      catch( SQLException e )

      {

        if ( mConnection == null || ( mConnection != null && !mConnection.isValid(10) ) )

        {

          mLogger.error("markDaemonInstCompleted database access error only");

          throw new SQLException();

        }

        else

        {

          mLogger.fatal("markDaemonInstCompleted show stopper");

          throw new Exception("markDaemonInstCompleted show stopper");

        }

      }

    }

  }

  /**handles database connection/disconnection

   * executes the mark_daemon_inst_completed function with the passed parameters

   */

  public void markDaemonInstCompletedConnect(final int instruction) throws SQLException, Exception

  {

    mLogger.debug("markDaemonInstCompletedConnect " + instruction);

    try

    {

      connect();

      markDaemonInstCompleted(instruction);

      commit();

    }

    catch( SQLException e )

    {

      if ( mConnection == null || ( mConnection != null && !mConnection.isValid(10) ) )

      {

        mLogger.error("markDaemonInstCompletedConnect database access error only");

        throw new SQLException();

      }

      else

      {

        mLogger.fatal("markDaemonInstCompletedConnect show stopper");

        throw new Exception("markDaemonInstCompletedConnect show stopper");

      }

    }

    finally

    {

      // this block is executed regardless of what happens in the try block

      // even if an exception is thrown

      // ensure disconnect

      disconnect();

    }

          // force email notification by using a zero test build instruction