Merge branch 'issue#96' into develop

Author: Marcin Przepiorowski

bin/dx_ctl_env.pl

@@ -11,7 +11,7 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-# Copyright (c) 2014,2016 by Delphix. All rights reserved.
+# Copyright (c) 2014,2019 by Delphix. All rights reserved.
 #
 # Program Name : dx_ctl_env.pl
 # Description  : Get database and host information
@@ -48,6 +48,8 @@
   'name|n=s' => \(my $envname),
   'reference|r=s' => \(my $reference),
   'action=s' => \(my $action),
+  'host=s' => \(my $host),
+  'newhost=s' => \(my $newhost),
   'username=s' => \(my $username),
   'authtype=s' => \(my $authtype),
   'password=s' => \(my $password),
@@ -98,14 +100,26 @@
     (lc $action eq 'addrepo') || (lc $action eq 'deleterepo') ||
     (lc $action eq 'adddatabase') || (lc $action eq 'deletedatabase') ||
     (lc $action eq 'addlistener') || (lc $action eq 'deletelistener') ||
-    (lc $action eq 'adduser') || (lc $action eq 'deleteuser')
+    (lc $action eq 'adduser') || (lc $action eq 'deleteuser') ||
+    (lc $action eq 'updatehost')
     ))
     {
       print "Unknown action $action\n";
       pod2usage(-verbose => 1,  -input=>\*DATA);
       exit (1);
 }
 
+if (lc $action eq 'updatehost') {
+  if (!defined($newhost)) {
+    print "New host has to be set\n";
+    exit 1;
+  }
+  if ((!defined($envname)) && (!defined($host))) {
+    print "Environment name or an existing host name has to be set for updatehost action\n";
+    exit 1;
+  }
+}
+
 if (lc $action eq 'addrepo') {
   if (!defined($repotype)) {
     print "Repository type has to be set\n";
@@ -203,6 +217,7 @@
 
   my @env_list;
   my @jobs;
+  my $hostupdate;
 
   if (defined($reference)) {
     push(@env_list, $reference);
@@ -227,7 +242,8 @@
 
     my $env_name = $environments->getName($envitem);
 
-    if ((lc $action eq 'enable') || (lc $action eq 'disable') || (lc $action eq 'refresh')) {
+    if ((lc $action eq 'enable') || (lc $action eq 'disable') || (lc $action eq 'refresh') ||
+        (lc $action eq 'updatehost') ) {
 
       if ( $action eq 'enable' ) {
         if ( $environments->getStatus($envitem) eq 'enabled' ) {
@@ -254,6 +270,14 @@
         $jobno = $environments->refresh($envitem);
       }
 
+      if ( lc $action eq 'updatehost' ) {
+        print "Checking environment for host update $env_name ";
+        $jobno = $environments->updatehost($envitem, $host, $newhost);
+        if (defined($jobno)) {
+          $hostupdate = 1;
+        }
+      }
+
       if (defined ($jobno) ) {
         print "Starting job $jobno for environment $env_name.\n";
         my $job = new Jobs_obj($engine_obj, $jobno, 'true', $debug);
@@ -393,6 +417,8 @@
       }
     }
 
+
+
   }
 
   if (defined($parallel) && (scalar(@jobs) > 0)) {
@@ -402,6 +428,11 @@
     }
   }
 
+  if (!defined($hostupdate)) {
+    # no environment found with a IP - need to report an error
+    $ret = $ret + 1;
+  }
+
 }
 
 exit $ret;
@@ -413,7 +444,8 @@ =head1 SYNOPSIS
 
  dx_ctl_env [ -engine|d <delphix identifier> | -all ] [ -configfile file ]
             [ -name env_name | -reference reference ]
-            -acton <enable|disable|refresh|adduser|addrepo|adddatabase|addlistener|deleteuser|deleterepo|deletedatabase|deletelistener>
+            -acton <enable|disable|refresh|adduser|addrepo|adddatabase|addlistener
+                   |deleteuser|deleterepo|deletedatabase|deletelistener|updatehost>
             [-dbname dbname]
             [-instancename instancename]
             [-uniquename db_unique_name]
@@ -425,6 +457,8 @@ =head1 SYNOPSIS
             [-password password]
             [-repotype oracle|vfiles]
             [-repopath ORACLE_HOME]
+            [-host name/ip of existing host to update]
+            [-newhost new name/ip of the host]
             [-help|? ]
             [-debug ]
 
@@ -457,7 +491,7 @@ =head2 Actions
 
 =over 1
 
-=item B<-action> <enable|disable|refresh|adduser|addrepo|adddatabase|addlistener|deleteuser|deleterepo|deletedatabase|deletelistener>
+=item B<-action> <enable|disable|refresh|adduser|addrepo|adddatabase|addlistener|deleteuser|deleterepo|deletedatabase|deletelistener|updatehost>
 Run an action specified for environments selected by filter or all environments deployed on Delphix Engine
 
 =back
@@ -517,6 +551,13 @@ =head1 OPTIONS
 =item B<-oraclebase path>
 Oracle Base path
 
+=item B<-host hostname/IP>
+Host name or IP from an environment to be updated.
+Not required if environment name is specified
+
+=item B<-newhost hostname/IP>
+New Host name or IP of host being updated
+
 =item B<-help>
 Print this screen
 
@@ -608,4 +649,23 @@ =head1 EXAMPLES
  Deleting vfiles swingbench from environment LINUXSOURCE
  Database swingbench deleted from Unstructured Files
 
+Chaging an IP of the environment
+
+ dx_ctl_env -d 53 -name linuxsource -newhost 172.16.200.130 -action updatehost
+ Checking environment for host update linuxsource Starting job JOB-2850 for environment linuxsource.
+ 0 - 30 - 40 - 80 - 100
+ Job JOB-2850 finished with state: COMPLETED
+
+Chaging an IP of particular host
+
+ dx_ctl_env -d 53 -host 172.16.200.130 -newhost 172.16.180.129 -action updatehost
+ Checking environment for host update racattack121 Host with IP 172.16.200.130 not found
+ Checking environment for host update racattack Host with IP 172.16.200.130 not found
+ Checking environment for host update oracle18tgt Host with IP 172.16.200.130 not found
+ Checking environment for host update oracle18 Host with IP 172.16.200.130 not found
+ Checking environment for host update linuxsource Starting job JOB-2852 for environment linuxsource.
+ 0 - 30 - 40 - 80 - 100
+ Job JOB-2852 finished with state: COMPLETED
+ Checking environment for host update linuxtarget Host with IP 172.16.200.130 not found
+
 =cut

lib/Environment_obj.pm

@@ -30,6 +30,8 @@ use strict;
 use Data::Dumper;
 use JSON;
 use Toolkit_helpers qw (logger);
+use lib '../lib';
+use Host_obj;
 
 # constructor
 # parameters
@@ -499,12 +501,12 @@ sub getClusterName {
     return $ret;
 }
 
-# Procedure getClusterNode
+# Procedure getClusterNodes
 # parameters:
 # - reference
-# Return environment cluster location for specific environment reference
+# Return all nodes from cluster
 
-sub getClusterNode {
+sub getClusterNodes {
     my $self = shift;
     my $reference = shift;
 
@@ -515,14 +517,32 @@ sub getClusterNode {
 
     if (($environments->{$reference}->{'type'} eq 'OracleCluster') || ($environments->{$reference}->{'type'} eq 'WindowsCluster')) {
       my @nodes = grep { defined($environments->{$_}->{cluster}) && ( $environments->{$_}->{cluster} eq $reference ) } sort (keys %{$environments} );
-      $ret = $nodes[0];
+      $ret = \@nodes;
     } else {
       $ret = 'N/A';
     }
 
     return $ret;
 }
 
+# Procedure getClusterNode
+# parameters:
+# - reference
+# Return first node from cluster
+
+sub getClusterNode {
+    my $self = shift;
+    my $reference = shift;
+
+    my $nodelist = $self->getClusterNodes($reference);
+
+    if ($nodelist eq 'N/A') {
+      return 'N/A';
+    } else {
+      return $nodelist->[0];
+    }
+}
+
 # Procedure getASEUser
 # parameters:
 # - reference
@@ -1494,4 +1514,66 @@ sub deleteListener
     }
 }
 
+
+sub updatehost {
+    my $self = shift;
+    my $envitem = shift;
+    my $hostip = shift;
+    my $newhost = shift;
+
+    logger($self->{_debug}, "Entering Environment_obj::updatehost",1);
+    my $hosts = new Host_obj($self->{_dlpxObject}, $self->{_debug});
+    my $hostobj;
+    my $host;
+
+    if (!defined($hostip)) {
+      $host = $self->getHost($envitem);
+      if ($host eq 'CLUSTER') {
+        print "Please specify which host in a cluster environment you want to change\n";
+        return undef;
+      }
+      $hostobj = $hosts->getHost($host);
+    } else {
+      $host = $self->getHost($envitem);
+      my @nodestocheck;
+      if ($host eq 'CLUSTER') {
+        my @clusternodes = @{$self->getClusterNodes($envitem)};
+        @nodestocheck = map { $self->{_environments}->{$_}->{host} } @clusternodes;
+      } else {
+        push(@nodestocheck, $host);
+      }
+      logger($self->{_debug}, "Looking for IP: ". $hostip,2);
+      my $foundhost;
+      for my $h (@nodestocheck) {
+        $hostobj = $hosts->getHost($h);
+        my $ip = $hostobj->{"address"};
+        logger($self->{_debug}, "Checking IP: ". $ip,2);
+        if ($hostip eq $ip) {
+          logger($self->{_debug}, "Found IP: ". $ip,2);
+          $foundhost = $h;
+          last;
+        }
+      }
+
+      if (defined($foundhost)) {
+        # host will be set to one depend on IP matching
+        $host = $foundhost;
+      } else {
+        print "Host with IP $hostip not found\n";
+        return undef;
+      }
+
+    }
+
+    my %hostupdate = (
+      "type" => $hostobj->{"type"},
+      "address" => $newhost
+    );
+
+    my $operation = "resources/json/delphix/host/" . $host;
+
+    return $self->runJobOperation($operation, to_json(\%hostupdate));
+
+}
+
 1;