gs_install support non-interactive whit init-passwd

script/gspylib/common/ParallelBaseOM.py

@@ -886,7 +886,7 @@ class ParallelBaseOM(object):
             self.sshTool.scpFiles(scpFile, caPath, hostList)
         self.logger.debug("Successfully generated grpc CA files.")
 
-    def genCipherAndRandFile(self, hostList=None):
+    def genCipherAndRandFile(self, hostList=None, initPwd=None):
         self.logger.debug("Encrypting cipher and rand files.")
         if hostList is None:
             hostList = []
@@ -894,8 +894,11 @@ class ParallelBaseOM(object):
         binPath = os.path.join(appPath, "bin")
         retry = 0
         while True:
-            sshpwd = getpass.getpass("Please enter password for database:")
+            if not initPwd:
-            sshpwd_check = getpass.getpass("Please repeat for database:")
+                sshpwd = getpass.getpass("Please enter password for database:")
+                sshpwd_check = getpass.getpass("Please repeat for database:")
+            else:
+                sshpwd = sshpwd_check = initPwd
             if sshpwd_check != sshpwd:
                 sshpwd = ""
                 sshpwd_check = ""
@@ -910,6 +913,7 @@ class ParallelBaseOM(object):
                 (status, output) = subprocess.getstatusoutput(cmd)
                 sshpwd = ""
                 sshpwd_check = ""
+                initPwd = ""
                 if status != 0:
                     self.logger.error(
                         ErrorCode.GAUSS_503["GAUSS_50322"] % "database"

script/impl/install/InstallImpl.py

@@ -347,7 +347,8 @@ class InstallImpl:
             self.configZenithInst()
             self.context.logger.log("encrypt cipher and rand files "
                                     "for database.")
-            self.context.genCipherAndRandFile()
+            initPasswd = self.getPasswdFromInitParam()
+            self.context.genCipherAndRandFile(None, initPasswd)
             self.context.logger.log("begin to create CA cert files")
             self.context.createServerCa()
             if not self.context.localMode:
@@ -360,6 +361,32 @@ class InstallImpl:
         self.context.logger.log("Cluster installation is completed.",
                                 "constant")
 
+    def getPasswdFromInitParam(self):
+        """
+        function: get passwd from init-parameter
+        return: passwd
+        get passwd from --gsinit-parameter. if the passwd has been assigned,
+        the database will install with non-interactive.
+        """ 
+        if len(self.context.dbInitParam) == 0:
+            return None
+        passwd = None
+        pwdIndex = -1
+        for idx,param in enumerate(self.context.dbInitParam):
+            if param.startswith("--pwpasswd="):
+                passwd = param[11:]
+                pwdIndex = idx
+                break
+            elif param.startswith("-w="):
+                passwd = param[3:]
+                pwdIndex = idx
+                break
+        
+        #remove initpasswd from dbInitParam. otherwise it will be printed in log.
+        if pwdIndex > -1:
+            self.context.dbInitParam.pop(pwdIndex)
+        return passwd
+
     def configZenithInst(self):
         """
         function: config zenith inst