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

   /**Unit test hook
    * Container of persisted run levels for unit test usage
    * Must be managed by the unit test code
    * @attribute
    */
-  public static Vector mPersistedRunLevelCollection = new Vector();
+  public static Vector<Integer> mPersistedRunLevelCollection = new Vector<Integer>();
   /**database represented enumerated value
    * @attribute
    */
   public static final int DB_CANNOT_CONTINUE = 1;
   private int mRunLevelIndex = -1;
   /**collection of ReleaseConfig objects
    * @attribute
    */
-  private Vector mReleaseConfigCollection = new Vector();
+  private Vector<ReleaseConfig> mReleaseConfigCollection = new Vector<ReleaseConfig>();
   /**database connection string
    * @attribute
    */
   private static String mConnectionString = new String();
   private static String mPassword = new String();
   /**collection of RunLevel objects
    * @attribute
    */
-  private Vector mRunLevelCollection = new Vector();
+  private Vector<RunLevel> mRunLevelCollection = new Vector<RunLevel>();
   /**in daemon mode
    *   select gm.gbe_value from release_config rc, gbe_machtype gm
    *   where rc.rtag_id=<baseline> and gm.gbe_id=rc.gbe_id;
    * in escrow mode
    *   select gm.gbe_value from boms b, release_manager.release_config rc,
    *   release_manager.gbe_machtype gm
    *   where b.bom_id=<baseline> and rc.rtag_id=b.rtag_id_fk and gm.gbe_id=rc.gbe_id;
    * populates the machtypeCollection with the resultset
    */
-  void queryMachtypes(Vector machtypeCollection, boolean daemonMode, int baseline) throws SQLException, Exception
+  void queryMachtypes(Vector<String> machtypeCollection, boolean daemonMode, int baseline) throws SQLException, Exception
+  {
     mLogger.debug("queryMachtypes " + daemonMode);
     if ( !mUseDatabase )
+    {
       mLogger.info("queryMachtypes !mUseDatabase");
    *    test_type_name="Autobuild UTF"
    *    bm_name="Generic"|"Linux"|"Solaris"|"Win32"
    *    bsa_name="Debug"|"Production"|"Production and Debug"|"Java 1.4"|"Java 1.5"|"Java 1.6"
    */
   void queryPackageVersions(RippleEngine rippleEngine,
-                            Vector packageCollection, boolean daemonMode, int baseline) throws SQLException, Exception
+                            Vector<Package> packageCollection, boolean daemonMode, int baseline) throws SQLException, Exception
+  {
     mLogger.debug("queryPackageVersions " + daemonMode);
     if ( !mUseDatabase )
+    {
          if ( mConnectionString.compareTo("iteration1") == 0
            || mConnectionString.compareTo("iteration2") == 0
            || mConnectionString.compareTo("iteration3") == 0 )
+         {
            p = findPackage(3, packageCollection);
-           p.mBuildFailureEmailCollection.add("jimmyfishcake@erggroup.com");
+           p.addEmail("jimmyfishcake@erggroup.com");
-           p.mBuildFailureEmailCollection.add("rayhaddock@erggroup.com");
+           p.addEmail("rayhaddock@erggroup.com");
+         }
          if ( mConnectionString.compareTo("iteration1") == 0
            || mConnectionString.compareTo("iteration2") == 0
            || mConnectionString.compareTo("iteration3") == 0
            || mConnectionString.compareTo("iteration4") == 0
            || mConnectionString.compareTo("iteration5") == 0 )
+         {
            p = findPackage(5, packageCollection);
-           p.mBuildFailureEmailCollection.add("timbutdim@erggroup.com");
+           p.addEmail("timbutdim@erggroup.com");
+         }
         /* planned do not ripple info
          * pv_id
          * 6
          if ( mConnectionString.compareTo("iteration1") != 0
            && mConnectionString.compareTo("iteration2") != 0
            && mConnectionString.compareTo("iteration3") != 0 )
+         {
            p = findPackage(3, packageCollection);
-           p.mBuildFailureEmailCollection.add("jimmyfishcake@erggroup.com");
+           p.addEmail("jimmyfishcake@erggroup.com");
-           p.mBuildFailureEmailCollection.add("rayhaddock@erggroup.com");
+           p.addEmail("rayhaddock@erggroup.com");
+         }
          if ( mConnectionString.compareTo("iteration1") != 0
            && mConnectionString.compareTo("iteration2") != 0
            && mConnectionString.compareTo("iteration3") != 0
            && mConnectionString.compareTo("iteration4") != 0
            && mConnectionString.compareTo("iteration5") != 0 )
+         {
            p = findPackage(5, packageCollection);
-           p.mBuildFailureEmailCollection.add("timbutdim@erggroup.com");
+           p.addEmail("timbutdim@erggroup.com");
+         }
          if ( mConnectionString.compareTo("iteration1") == 0
            || mConnectionString.compareTo("iteration2") == 0
            || mConnectionString.compareTo("iteration3") == 0 )
+         {
            p = findPackage(10, packageCollection);
-           p.mBuildFailureEmailCollection.add("jimmyfishcake@erggroup.com");
+           p.addEmail("jimmyfishcake@erggroup.com");
+         }
         /* released do not ripple info
          * pv_id
          * 11
+    {
       try
+      {
         if (daemonMode)
+        {
+          Vector<String> globalAndProjectWideBuildFailureEmailCollection = new Vector<String>();
+          // populate globalAndProjectWideBuildFailureCollection
+          CallableStatement stmt = mConnection.prepareCall(
+          "select u.user_email from release_manager.build_service_config bsc, users u " +
+          "where bsc.service='GLOBAL EMAIL ADDRESS LIST' and u.full_name=bsc.config"
+          );
+          ResultSet rset = stmt.executeQuery();
+          while( rset.next() )
+          {
+            String email = rset.getString("user_email");
+            if ( email != null )
+            {
+              globalAndProjectWideBuildFailureEmailCollection.add(email);
+            }
+          }
+          rset.close();
+          stmt.close();
+          CallableStatement stmt0 = mConnection.prepareCall(
+          "select u.user_email " +
+          "from release_manager.autobuild_failure af, release_manager.members_group mg, release_manager.users u, release_manager.views v, release_manager.release_tags rt " +
+          "where rt.rtag_id=" + baseline + " " +
+          "and v.view_name='PROJECT WIDE' " +
+          "and af.proj_id=rt.proj_id " +
+          "and af.view_id=v.view_id " +
+          "and mg.group_email_id=af.group_email_id " +
+          "and u.user_id=mg.user_id"
+          );
+          ResultSet rset0 = stmt0.executeQuery();
+          while( rset0.next() )
+          {
+            String email = rset0.getString("user_email");
+            if ( email != null )
+            {
+              globalAndProjectWideBuildFailureEmailCollection.add(email);
+            }
+          }
+          rset0.close();
+          stmt0.close();
           // get planned package info
           CallableStatement stmt1 = mConnection.prepareCall(
           "select pl.pv_id, p.pkg_id, p.pkg_name, pv.v_ext, pv.pkg_label, pv.src_path, pv.change_type " +
           "from release_manager.planned pl, release_manager.package_versions pv, release_manager.packages p " +
           "where pl.rtag_id=" + baseline + " and pv.build_type='A' and pv.dlocked='A' " +
+          }
           rset4.close();
           stmt4.close();
-          // get planned package build failure info
+          // get planned package build failure info...
+          // global and project wide based
+          CallableStatement stmt50 = mConnection.prepareCall(
+          "select pl.pv_id " +
+          "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 " +
+          "order by pl.pv_id"
+          );
+          ResultSet rset50 = stmt50.executeQuery();
+          while( rset50.next() )
+          {
+            int pv_id = rset50.getInt("pv_id");
+            if ( rset50.wasNull() )
+            {
+              mLogger.fatal("queryPackageVersions rset50 null pv_id");
+              // show stopper
+              throw new Exception();
+            }
+            Package p = findPackage(pv_id, packageCollection);
+            if ( p == NULL_PACKAGE )
+            {
+              mLogger.info("queryPackageVersions rset50 highly unlikely " + pv_id);
+              // highly unlikely but package may have been added in between queries
+            }
+            else
+            {
+              for (Iterator<String> it = globalAndProjectWideBuildFailureEmailCollection.iterator(); it.hasNext(); )
+              {
+                p.addEmail(it.next());
+              }
+            }
+          }
+          rset50.close();
+          stmt50.close();
+          // view based
           CallableStatement stmt5 = mConnection.prepareCall(
           "select pl.pv_id, u.user_email " +
           "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 " +
           );
           ResultSet rset5 = stmt5.executeQuery();
           while( rset5.next() )
+          {
-            boolean ignore = false;
             int pv_id = rset5.getInt("pv_id");
             if ( rset5.wasNull() )
+            {
               mLogger.fatal("queryPackageVersions rset5 null pv_id");
             if ( p == NULL_PACKAGE )
+            {
               mLogger.info("queryPackageVersions rset5 highly unlikely " + pv_id);
               // highly unlikely but package may have been added in between queries
-              ignore = true;
+            }
+            else
+            {
+              String user_email = rset5.getString("user_email");
+              if ( user_email != null )
+              {
+                p.addEmail(user_email);
+              }
+            }
+          }
+          rset5.close();
+          stmt5.close();
+          // package version
+          CallableStatement stmt51 = mConnection.prepareCall(
-            String user_email = rset5.getString("user_email");
+          "select pl.pv_id, u1.user_email, u2.user_email, u3.user_email " +
+          "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 " +
+          "order by pl.pv_id"
+          );
+          ResultSet rset51 = stmt51.executeQuery();
+          while( rset51.next() )
+          {
+            int pv_id = rset51.getInt("pv_id");
-            if ( user_email == null )
+            if ( rset51.wasNull() )
+            {
+              mLogger.fatal("queryPackageVersions rset51 null pv_id");
-              // this can be null!
+              // show stopper
-              ignore = true;
+              throw new Exception();
+            }
+            Package p = findPackage(pv_id, packageCollection);
-            if ( !ignore )
+            if ( p == NULL_PACKAGE )
+            {
+              mLogger.info("queryPackageVersions rset51 highly unlikely " + pv_id);
+              // highly unlikely but package may have been added in between queries
+            }
+            else
+            {
+              // walk the 3 columns of user_email in the resultset
+              // columns 2, 3 and 4, all of the same name, repectively
+              for(int column=2; column<5; column++ )
+              {
+                String user_email = rset51.getString(column);
+                if ( user_email != null )
+                {
-              p.mBuildFailureEmailCollection.add(user_email);
+                  p.addEmail(user_email);
+                }
+              }
+            }
+          }
-          rset5.close();
+          rset51.close();
-          stmt5.close();
+          stmt51.close();
           // get planned package do not ripple info
           CallableStatement stmt6 = mConnection.prepareCall(
           "select pl.pv_id " +
           "from release_manager.planned pl, release_manager.package_versions pv, release_manager.do_not_ripple dnr " +
+          }
           rset11.close();
           stmt11.close();
-          // get released package build failure email info
+          // get released package build failure info...
+          // global and project wide based
+          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 " +
+          "order by rc.pv_id"
+          );
+          ResultSet rset120 = stmt120.executeQuery();
+          while( rset120.next() )
+          {
+            int pv_id = rset120.getInt("pv_id");
+            if ( rset120.wasNull() )
+            {
+              mLogger.fatal("queryPackageVersions rset120 null pv_id");
+              // show stopper
+              throw new Exception();
+            }
+            Package p = findPackage(pv_id, packageCollection);
+            if ( p == NULL_PACKAGE )
+            {
+              mLogger.info("queryPackageVersions rset120 highly unlikely " + pv_id);
+              // highly unlikely but package may have been added in between queries
+            }
+            else
+            {
+              for (Iterator<String> it = globalAndProjectWideBuildFailureEmailCollection.iterator(); it.hasNext(); )
+              {
+                p.addEmail(it.next());
+              }
+            }
+          }
+          rset120.close();
+          stmt120.close();
+          // view based
           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 " +
           );
           ResultSet rset12 = stmt12.executeQuery();
           while( rset12.next() )
+          {
-            boolean ignore = false;
             int pv_id = rset12.getInt("pv_id");
             if ( rset12.wasNull() )
+            {
               mLogger.fatal("queryPackageVersions rset12 null pv_id");
             Package p = findPackage(pv_id, packageCollection);
             if ( p == NULL_PACKAGE )
+            {
               mLogger.info("queryPackageVersions rset12 package may have been superceded by planned " + pv_id);
-              ignore = true;
+            }
-            String user_email = rset12.getString("user_email");
+            else
-            if ( user_email == null )
+            {
-              // this can be null
-              ignore = true;
+              String user_email = rset12.getString("user_email");
-            }
-            if ( !ignore )
+              if ( user_email != null )
-            {
+              {
-              p.mBuildFailureEmailCollection.add(user_email);
+                p.addEmail(user_email);
+              }
+            }
+          }
           rset12.close();
           stmt12.close();
+    }
     if (!daemonMode)
+    {
       // use a ListIterator as it allows traverseDependencies to modify the packageCollection
-      for (ListIterator it = packageCollection.listIterator(); it.hasNext(); )
+      for (ListIterator<Package> it = packageCollection.listIterator(); it.hasNext(); )
+      {
-        Package p = (Package) it.next();
+        Package p = it.next();
         traverseDependencies(packageCollection, p, false, it);
+      }
-      for (Iterator it = packageCollection.iterator(); it.hasNext(); )
+      for (Iterator<Package> it = packageCollection.iterator(); it.hasNext(); )
+      {
-        Package p = (Package) it.next();
+        Package p = it.next();
         queryBuildInfo(rippleEngine, p);
+      }
+    }
+  }
    * 2 for each dpv.pv_id in the resultset
    *     call traverseDependencies( packageCollection, dpv.pv_id, true )
    *     if the pv_id is not in the collection, add it
+   *
    */
-  private void traverseDependencies(Vector packageCollection, Package pkg,
+  private void traverseDependencies(Vector<Package> packageCollection, Package pkg,
                                      boolean checkCollection,
-                                     ListIterator listIterator) throws SQLException, Exception
+                                     ListIterator<Package> listIterator) throws SQLException, Exception
+  {
     mLogger.debug("traverseDependencies " + checkCollection);
     boolean pvIdInCollection = false;
     if ( checkCollection )
+    {
-      for (Iterator it = packageCollection.iterator(); it.hasNext(); )
+      for (Iterator<Package> it = packageCollection.iterator(); it.hasNext(); )
+      {
-        Package p = (Package) it.next();
+        Package p = it.next();
         if ( p.mId == pkg.mId )
+        {
           pvIdInCollection = true;
           break;
+      }
+    }
     if ( !pvIdInCollection )
+    {
-      Vector resultset = new Vector();
+      Vector<Package> resultset = new Vector<Package>();
       if ( !mUseDatabase )
+      {
         mLogger.info("traverseDependencies !mUseDatabase");
             throw new Exception();
+          }
+        }
+      }
-      for (Iterator it = resultset.iterator(); it.hasNext(); )
+      for (Iterator<Package> it = resultset.iterator(); it.hasNext(); )
+      {
-        Package r = (Package) it.next();
+        Package r = it.next();
         traverseDependencies(packageCollection, r, true, listIterator);
         pvIdInCollection = false;
-        for (Iterator it2 = packageCollection.iterator(); it2.hasNext(); )
+        for (Iterator<Package> it2 = packageCollection.iterator(); it2.hasNext(); )
+        {
-          Package p = (Package) it2.next();
+          Package p = it2.next();
           if ( p.mId == r.mId )
+          {
             pvIdInCollection = true;
             break;
+    }
+  }
   /**returns the Package with the matching mID or NULL_PACKAGE if no package has the mID
    */
-  private Package findPackage(int id, Vector packageCollection)
+  private Package findPackage(int id, Vector<Package> packageCollection)
+  {
     mLogger.debug("findPackage 1 id " + id);
     Package retVal = NULL_PACKAGE;
-    for (Iterator it = packageCollection.iterator(); it.hasNext(); )
+    for (Iterator<Package> it = packageCollection.iterator(); it.hasNext(); )
+    {
-      Package p = (Package) it.next();
+      Package p = it.next();
       if ( p.mId == id )
+      {
         retVal = p;
         break;
+    }
+  }
   /**returns the Package with the matching mAlias or NULL_PACKAGE if no package has the mAlias
    */
-  private Package findPackage(String alias, Vector packageCollection)
+  private Package findPackage(String alias, Vector<Package> packageCollection)
+  {
     mLogger.debug("findPackage 2 alias " + alias);
     Package retVal = NULL_PACKAGE;
-    for (Iterator it = packageCollection.iterator(); it.hasNext(); )
+    for (Iterator<Package> it = packageCollection.iterator(); it.hasNext(); )
+    {
-      Package p = (Package) it.next();
+      Package p = it.next();
       if ( p.mAlias.compareTo( alias ) == 0 )
+      {
         retVal = p;
         break;
     boolean retVal = true;
     try
+    {
       mReleaseConfigIndex = 0;
-      ReleaseConfig rc = (ReleaseConfig)mReleaseConfigCollection.get( mReleaseConfigIndex );
+      ReleaseConfig rc = mReleaseConfigCollection.get( mReleaseConfigIndex );
       rcon_id.value = rc.get_rcon_id();
+    }
     catch( ArrayIndexOutOfBoundsException e )
+    {
       retVal = false;
     boolean retVal = true;
     try
+    {
       mReleaseConfigIndex = 0;
-      ReleaseConfig rc = (ReleaseConfig)mReleaseConfigCollection.get( mReleaseConfigIndex );
+      ReleaseConfig rc = mReleaseConfigCollection.get( mReleaseConfigIndex );
       rtag_id.value = rc.get_rtag_id();
       rcon_id.value = rc.get_rcon_id();
       daemon_mode.value = rc.get_daemon_mode();
       gbebuildfilter.value = rc.get_gbebuildfilter();
+    }
     boolean retVal = true;
     try
+    {
       mRunLevelIndex = 0;
-      RunLevel rl = (RunLevel)mRunLevelCollection.get( mRunLevelIndex );
+      RunLevel rl = mRunLevelCollection.get( mRunLevelIndex );
       rcon_id.value = rl.get_rcon_id();
       current_run_level.value = rl.get_current_run_level();
+    }
     catch( ArrayIndexOutOfBoundsException e )
+    {
     boolean retVal = true;
     try
+    {
       mReleaseConfigIndex++;
-      ReleaseConfig rc = (ReleaseConfig)mReleaseConfigCollection.get( mReleaseConfigIndex );
+      ReleaseConfig rc = mReleaseConfigCollection.get( mReleaseConfigIndex );
       rcon_id.value = rc.get_rcon_id();
+    }
     catch( ArrayIndexOutOfBoundsException e )
+    {
       retVal = false;
     boolean retVal = true;
     try
+    {
       mReleaseConfigIndex++;
-      ReleaseConfig rc = (ReleaseConfig)mReleaseConfigCollection.get( mReleaseConfigIndex );
+      ReleaseConfig rc = mReleaseConfigCollection.get( mReleaseConfigIndex );
       rtag_id.value = rc.get_rtag_id();
       rcon_id.value = rc.get_rcon_id();
       daemon_mode.value = rc.get_daemon_mode();
       gbebuildfilter.value = rc.get_gbebuildfilter();
+    }
     boolean retVal = true;
     try
+    {
       mRunLevelIndex++;
-      RunLevel rl = (RunLevel)mRunLevelCollection.get( mRunLevelIndex );
+      RunLevel rl = mRunLevelCollection.get( mRunLevelIndex );
       rcon_id.value = rl.get_rcon_id();
       current_run_level.value = rl.get_current_run_level();
+    }
     catch( ArrayIndexOutOfBoundsException e )
+    {
+            }
             rset.close();
             stmt.close();
+          }
+          if (configured)
+          {
-          CallableStatement stmt = mConnection.prepareCall("insert into release_manager.run_level (rcon_id) values (" + rcon_id + ")" );
+            CallableStatement stmt = mConnection.prepareCall("insert into release_manager.run_level (rcon_id) values (" + rcon_id + ")" );
-          stmt.executeUpdate();
+            stmt.executeUpdate();
-          stmt.close();
+            stmt.close();
+          }
+        }
+        {
           CallableStatement stmt = mConnection.prepareCall("update release_manager.run_level set current_run_level=" + runLevel + " where rcon_id=" + rcon_id);
           stmt.executeUpdate();

Subversion Repositories DevTools

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