WebSVN – DevTools – Diff – /buildtool/trunk/src/generated/com/erggroup/buildtool/ripple/ReleaseManager.java

   /**in daemon mode
    *   select p.proj_name, rt.rtag_name from release_manager.projects p, release_manager.release_tags rt
    *   where rt.rtag_id=<baseline> and p.proj_id=rt.proj_id;
    * returns a concatenation of the proj_name and rtag_name
    * in escrow mode
-   *   select dp.proj_name, br.branch_name, b.bom_version, b.bom_lifecycle
+   *     dp.proj_name, br.branch_name, b.bom_version, b.bom_lifecycle
    *   from deployment_manager.dm_projects dp, deployment_manager.branches br, deployment_manager.boms b
    *   where b.bom_id=<baseline> and br.branch_id=b.branch_id and dp.proj_id=br.proj_id;
    * returns a concatenation of the proj_name, branch_name, bom_version and bom_lifecycle
    */
   String queryBaselineName(boolean daemonMode, int baseline) throws SQLException, Exception
+    {
       try
+      {
         if (daemonMode)
+        {
+          mLogger.debug("queryPackageVersions: stmt0");
           Vector<String> globalAndProjectWideBuildFailureEmailCollection = new Vector<String>();
           globalAndProjectWideBuildFailureEmailCollection.add(queryGlobalAddresses());
           CallableStatement stmt0 = mConnection.prepareCall(
           "select u.user_email " +
           rset0.close();
           stmt0.close();
           // get planned package info
           // devi 48629 support multiple wips on the same package and build in the order they were released
+          mLogger.debug("queryPackageVersions: stmt1");
           CallableStatement stmt1 = mConnection.prepareCall(
                 "select pl.pv_id, p.pkg_id, p.pkg_name," +
                        "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," +
           rset1.close();
           stmt1.close();
           // get planned package dependency info
+          mLogger.debug("queryPackageVersions: stmt2");
           CallableStatement stmt2 = mConnection.prepareCall(
           "select pl.pv_id, p.pkg_name, dpv.v_ext, pv.modified_stamp " +
           "from release_manager.planned pl, release_manager.package_versions pv, release_manager.package_dependencies pd, release_manager.package_versions dpv, release_manager.packages p " +
           "where pl.rtag_id=" + baseline + " and pv.build_type='A' and pv.dlocked='A' " +
           "and pv.pv_id = pl.pv_id and pd.pv_id=pl.pv_id and dpv.pv_id=pd.dpv_id and p.pkg_id=dpv.pkg_id " +
           rset2.close();
           stmt2.close();
           // get planned package build info
+          mLogger.debug("queryPackageVersions: stmt3");
           CallableStatement stmt3 = mConnection.prepareCall(
           "select pl.pv_id, bm.bm_name, bsa.bsa_name, pv.modified_stamp " +
           "from release_manager.planned pl, release_manager.package_versions pv, release_manager.package_build_info pbi, release_manager.build_machines bm, release_manager.build_standards_addendum bsa " +
           "where pl.rtag_id=" + baseline + " and pv.build_type='A' and pv.dlocked='A' " +
           "and pv.pv_id = pl.pv_id and pbi.pv_id=pv.pv_id and bm.bm_id=pbi.bm_id and bsa.bsa_id=pbi.bsa_id " +
           rset3.close();
           stmt3.close();
           // get planned package unit test info
+          mLogger.debug("queryPackageVersions: stmt4");
           CallableStatement stmt4 = mConnection.prepareCall(
           "select pl.pv_id, tt.test_type_name, pv.modified_stamp " +
           "from release_manager.planned pl, release_manager.package_versions pv, release_manager.unit_tests ut, release_manager.test_types tt " +
           "where pl.rtag_id=" + baseline + " and pv.build_type='A' and pv.dlocked='A' " +
           "and pv.pv_id = pl.pv_id and ut.pv_id=pv.pv_id and tt.test_type_id=ut.test_types_fk " +
           rset4.close();
           stmt4.close();
           // get planned package build failure info...
           // global and project wide based
+          mLogger.debug("queryPackageVersions: stmt50");
           CallableStatement stmt50 = mConnection.prepareCall(
           "select pl.pv_id, pv.modified_stamp " +
           "from release_manager.planned pl, release_manager.release_tags rt, release_manager.package_versions pv " +
           "where pl.rtag_id=" + baseline + " and rt.rtag_id=pl.rtag_id and pv.build_type='A' and pv.dlocked='A' " +
           "and pv.pv_id = pl.pv_id " +
           rset50.close();
           stmt50.close();
           // view based
+          mLogger.debug("queryPackageVersions: stmt5");
           CallableStatement stmt5 = mConnection.prepareCall(
           "select pl.pv_id, u.user_email, pv.modified_stamp " +
           "from release_manager.planned pl, 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 pl.rtag_id=" + baseline + " and rt.rtag_id=pl.rtag_id and pv.build_type='A' and pv.dlocked='A' " +
           "and pv.pv_id = pl.pv_id and af.view_id=pl.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 " +
           rset5.close();
           stmt5.close();
           // package version
+          mLogger.debug("queryPackageVersions: stmt51");
           CallableStatement stmt51 = mConnection.prepareCall(
           "select pl.pv_id, u1.user_email, u2.user_email, u3.user_email, pv.modified_stamp " +
           "from release_manager.planned pl, release_manager.release_tags rt, release_manager.package_versions pv, release_manager.users u1, release_manager.users u2, release_manager.users u3 " +
           "where pl.rtag_id=" + baseline + " and rt.rtag_id=pl.rtag_id and pv.build_type='A' and pv.dlocked='A' " +
           "and pv.pv_id = pl.pv_id and u1.user_id=pv.creator_id and u2.user_id=pv.owner_id and u3.user_id=pv.modifier_id " +
           rset51.close();
           stmt51.close();
           // get planned package advisory ripple info
+          mLogger.debug("queryPackageVersions: stmt7");
           CallableStatement stmt7 = mConnection.prepareCall(
           "select pl.pv_id, pv.modified_stamp " +
           "from release_manager.planned pl, release_manager.package_versions pv, release_manager.advisory_ripple ar " +
           "where pl.rtag_id=" + baseline + " and pv.build_type='A' and pv.dlocked='A' " +
           "and pv.pv_id = pl.pv_id and ar.rtag_id=pl.rtag_id and ar.pv_id=pl.pv_id " +
           rset7.close();
           stmt7.close();
           // get released package info
+          mLogger.debug("queryPackageVersions: stmt8");
           CallableStatement stmt8 = mConnection.prepareCall(
             "select rc.pv_id, p.pkg_id, p.pkg_name, pv.pkg_version, pv.v_ext," +
                 "pv.ripple_field,pv.major_limit, pv.minor_limit, pv.patch_limit," +
                 "pv.build_number_limit," +
                 "release_manager.PK_RMAPI.return_vcs_tag(rc.pv_id) AS vcsTag" +
           stmt8.close();
           // get released package dependency info
           // the not exists subquery was added to ignore dependencies for 'pegged' package versions in a release - DEVI 48876
           // this is the ONLY support for dealing with an inconsistent set of package versions
+          mLogger.debug("queryPackageVersions: stmt9");
           CallableStatement stmt9 = mConnection.prepareCall(
           "select rc.pv_id, dpv.pv_id, p.pkg_name, dpv.v_ext " +
           "from release_manager.release_content rc, release_manager.package_versions pv, release_manager.package_dependencies pd, release_manager.package_versions dpv, release_manager.packages p " +
           "where rc.rtag_id=" + baseline +
           " and pv.pv_id = rc.pv_id and pd.pv_id=pv.pv_id and dpv.pv_id=pd.dpv_id and p.pkg_id=dpv.pkg_id " +
           rset9.close();
           stmt9.close();
           // get released package build info
+          mLogger.debug("queryPackageVersions: stmt10");
           CallableStatement stmt10 = mConnection.prepareCall(
           "select rc.pv_id, bm.bm_name, bsa.bsa_name " +
           "from release_manager.release_content rc, release_manager.package_versions pv, release_manager.package_build_info pbi, release_manager.build_machines bm, release_manager.build_standards_addendum bsa " +
           "where rc.rtag_id=" + baseline +
           " and pv.pv_id = rc.pv_id and pbi.pv_id=pv.pv_id and bm.bm_id=pbi.bm_id and bsa.bsa_id=pbi.bsa_id " +
           rset10.close();
           stmt10.close();
           // get released package unit test info
+          mLogger.debug("queryPackageVersions: stmt11");
           CallableStatement stmt11 = mConnection.prepareCall(
           "select rc.pv_id, tt.test_type_name " +
           "from release_manager.release_content rc, release_manager.package_versions pv, release_manager.unit_tests ut, release_manager.test_types tt " +
           "where rc.rtag_id=" + baseline +
           " and pv.pv_id = rc.pv_id and ut.pv_id=pv.pv_id and tt.test_type_id=ut.test_types_fk " +
           rset11.close();
           stmt11.close();
           // get released package build failure info...
           // global and project wide based
+          mLogger.debug("queryPackageVersions: stmt120");
           CallableStatement stmt120 = mConnection.prepareCall(
           "select rc.pv_id " +
           "from release_manager.release_content rc, release_manager.release_tags rt, release_manager.package_versions pv " +
           "where rc.rtag_id=" + baseline + " and rt.rtag_id=rc.rtag_id " +
           "and pv.pv_id = rc.pv_id " +
           rset120.close();
           stmt120.close();
           // view based
+          mLogger.debug("queryPackageVersions: stmt12");
           CallableStatement stmt12 = mConnection.prepareCall(
           "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=" + baseline + " and rt.rtag_id=rc.rtag_id " +
           "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 " +
           rset12.close();
           stmt12.close();
           // get released advisory ripple info
+          mLogger.debug("queryPackageVersions: stmt14");
           CallableStatement stmt14 = mConnection.prepareCall(
           "select rc.pv_id " +
           "from release_manager.release_content rc, release_manager.package_versions pv, release_manager.advisory_ripple ar " +
           "where rc.rtag_id=" + baseline +
           " and pv.pv_id = rc.pv_id and ar.rtag_id=rc.rtag_id and ar.pv_id=rc.pv_id " +
           // 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
+          mLogger.debug("queryPackageVersions: stmt141");
           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;
               String pkg_name = "";
               String pkg_ext = "";
               String testBuildVcsTag = "null";
               // get wip package info
+              mLogger.debug("queryPackageVersions: stmt15");
               CallableStatement stmt15 = mConnection.prepareCall(
               "select p.pkg_name, pv.v_ext, release_manager.PK_RMAPI.return_vcs_tag(pv.pv_id) AS vcsTag " +
               " from release_manager.work_in_progress wip," +
                     "release_manager.package_versions pv," +
                     "release_manager.packages p" +
+              }
               rset15.close();
               stmt15.close();
+              mLogger.debug("queryPackageVersions: stmt16");
               if ( rsetSize == 0 )
+              {
                 mLogger.error("queryPackageVersions rset15 no wip found " + instruction.value);
                 markDaemonInstCompleted( instruction.value );
+              }
                 rset16.close();
                 stmt16.close();
                 // get planned package build info
+                mLogger.debug("queryPackageVersions: stmt17");
                 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 +
+          }
+        }
         else
+        {
           // get released product info
+          mLogger.debug("queryPackageVersions: stmt18");
           CallableStatement stmt = mConnection.prepareCall(
             "select oc.prod_id, p.pkg_name, pv.pkg_version, pv.v_ext," +
                    "release_manager.PK_RMAPI.return_vcs_tag(pv.pv_id) AS vcsTag" +
             " from deployment_manager.bom_contents bc," +
                 "deployment_manager.operating_systems os," +
+    }
     else
+    {
       try
+      {
+        String sql = new String(
+            "select rc.gbe_buildfilter, rl.pause " +
+            "from release_manager.release_config rc, release_manager.release_tags rt, release_manager.run_level rl " +
+            " where rc.rtag_id=" + rtag_id +
+            " and rc.rcon_id=" + rcon_id +
+            " and rc.daemon_hostname='" + daemon_hostname + "'" +
+            " and rc.daemon_mode='" + daemon_mode + "'" +
+            " and rl.rcon_id=" + rcon_id +
-        String sql = new String("select rc.gbe_buildfilter from release_manager.release_config rc, release_manager.release_tags rt where rc.rtag_id=" + rtag_id + " and rc.rcon_id=" + rcon_id + " and rc.daemon_hostname='" + daemon_hostname + "' and rc.daemon_mode='" + daemon_mode + "' and rt.rtag_id=rc.rtag_id and (rt.official = 'N' or rt.official='R' or rt.official='C')" );
+            " and rt.rtag_id=rc.rtag_id and (rt.official = 'N' or rt.official='R' or rt.official='C')" );
         CallableStatement stmt = mConnection.prepareCall( sql );
         ResultSet rset = stmt.executeQuery();
         int rsetSize = 0;
         while( rset.next() )
+        {
           rsetSize++;
+          //
+          //  Pause: null -> 0 == Run
+          //         1         == Pause
+          //         2         == Disabled
+          //
+          int pause = rset.getInt("pause");
+          if ( rset.wasNull() )
+          {
+            pause = 0;
+          }
+          mLogger.info("queryReleaseConfig 1: " + rtag_id + ", " + rcon_id + ", "+ daemon_mode + ", " + pause );
+          if ( pause <= 1 )
+          {
-          retVal = true;
+            retVal = true;
+          }
+        }
         rset.close();
         stmt.close();
+    {
       try
+      {
         connect();
+        CallableStatement stmt = mConnection.prepareCall(
+            "select rc.rcon_id, rc.daemon_mode, rl.pause" +
-        CallableStatement stmt = mConnection.prepareCall("select rcon_id, daemon_mode from release_manager.release_config where rtag_id=" + rtag_id );
+            " from release_manager.release_config rc, release_manager.run_level rl" +
+            " where rc.rtag_id=" + rtag_id + " and rl.rcon_id=rc.rcon_id");
         ResultSet rset = stmt.executeQuery();
         while( rset.next() )
+        {
           int rcon_id = rset.getInt("rcon_id");
             if ( daemon_mode.compareTo("M") == 0 )
+            {
               dm = 'M';
+            }
+          }
+          //
+          //  Pause: null -> 0 == Run
+          //         1         == Pause
+          //         2         == Disabled
+          //
+          int pause = rset.getInt("pause");
+          if ( rset.wasNull() )
+          {
+            pause = 0;
+          }
+          mLogger.info("queryReleaseConfig 2: " + rtag_id + ", " + rcon_id + ", "+ dm + ", " + pause );
+          if ( pause <= 1 )
+          {
-          ReleaseConfig releaseConfig = new ReleaseConfig( rtag_id, rcon_id, dm );
+            ReleaseConfig releaseConfig = new ReleaseConfig( rtag_id, rcon_id, dm );
-          mReleaseConfigCollection.add(releaseConfig);
+            mReleaseConfigCollection.add(releaseConfig);
+          }
+        }
         rset.close();
         stmt.close();
     else
+    {
       try
+      {
         connect();
+        CallableStatement stmt = mConnection.prepareCall(
+            "select rc.rtag_id, rc.rcon_id, rc.daemon_mode, rl.pause " +
+            "from release_manager.release_config rc, release_manager.release_tags rt, release_manager.run_level rl " +
+            "where rc.daemon_hostname='" + hostname + "'" +
+            "  and rt.rtag_id=rc.rtag_id" +
+            "  and rl.rcon_id=rc.rcon_id" +
-        CallableStatement stmt = mConnection.prepareCall("select rc.rtag_id, rc.rcon_id, rc.daemon_mode from release_manager.release_config rc, release_manager.release_tags rt where rc.daemon_hostname='" + hostname + "' and rt.rtag_id=rc.rtag_id and (rt.official = 'N' or rt.official='R' or rt.official='C')" );
+            "  and (rt.official = 'N' or rt.official='R' or rt.official='C')"
+            );
         ResultSet rset = stmt.executeQuery();
         while( rset.next() )
+        {
           int rtag_id = rset.getInt("rtag_id");
+            {
               dm = 'M';
+            }
+          }
+          //
+          //  Pause: null -> 0 == Run
+          //         1         == Pause
+          //         2         == Disabled
+          //
+          int pause = rset.getInt("pause");
+          if ( rset.wasNull() )
+          {
+            pause = 0;
+          }
+          mLogger.info("queryReleaseConfig 3: " + rtag_id + ", " + rcon_id + ", "+ dm + ", " + pause );
+          if ( pause <= 1 )
+          {
-          ReleaseConfig releaseConfig = new ReleaseConfig( rtag_id, rcon_id, dm );
+            ReleaseConfig releaseConfig = new ReleaseConfig( rtag_id, rcon_id, dm );
-          mReleaseConfigCollection.add(releaseConfig);
+            mReleaseConfigCollection.add(releaseConfig);
+          }
+        }
         rset.close();
         stmt.close();
+      }

Subversion Repositories DevTools

(root)/buildtool/trunk/src/generated/com/erggroup/buildtool/ripple/ReleaseManager.java @ 1313 – Rev 928 → 1313