Module cvpysdk.instances.db2instance
File for operating on a DB2 Instance.
DB2Instance is the only class defined in this file.
DB2Instance: Derived class from Instance Base class, representing a DB2 instance, and to perform operations on that instance
DB2Instance:
_restore_destination_json() -- setter for the Db2 Destination options in restore JSON
_db2_restore_options_json() -- setter for the db2 options of in restore JSON
_restore_json() -- returns the JSON request to pass to the API as per
the options selected by the user
restore_entire_database() -- Restores the db2 database
restore_out_of_place() -- runs the out of place restore for given backupset
restore_table_level() -- Table level restore function
DB2Instance instance Attributes:
**version** -- returns db2 version
**home_directory** -- returns db2 home directory
**user_name** -- returns db2 user name
**data_backup_storage_policy** -- returns data backup storage policy
**command_line_storage_policy** -- returns commandline storage policy
**log_backup_storage_policy** -- returns log backup storage policy
Expand source code Browse git
# -*- coding: utf-8 -*-
# --------------------------------------------------------------------------
# Copyright Commvault Systems, Inc.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
# --------------------------------------------------------------------------
"""File for operating on a DB2 Instance.
DB2Instance is the only class defined in this file.
DB2Instance: Derived class from Instance Base class, representing a
DB2 instance, and to perform operations on that instance
DB2Instance:
============
_restore_destination_json() -- setter for the Db2 Destination options in restore JSON
_db2_restore_options_json() -- setter for the db2 options of in restore JSON
_restore_json() -- returns the JSON request to pass to the API as per
the options selected by the user
restore_entire_database() -- Restores the db2 database
restore_out_of_place() -- runs the out of place restore for given backupset
restore_table_level() -- Table level restore function
DB2Instance instance Attributes:
================================
**version** -- returns db2 version
**home_directory** -- returns db2 home directory
**user_name** -- returns db2 user name
**data_backup_storage_policy** -- returns data backup storage policy
**command_line_storage_policy** -- returns commandline storage policy
**log_backup_storage_policy** -- returns log backup storage policy
"""
from __future__ import unicode_literals
from ..instance import Instance
from ..exception import SDKException
from base64 import b64encode
class DB2Instance(Instance):
""" Derived class from Instance Base class, representing a DB2 instance,
and to perform operations on that Instance."""
@property
def version(self):
"""returns db2 version
Returns:
(str) -- db2 version value in string
"""
return self._properties.get('version', "")
@property
def home_directory(self):
"""
returns db2 home directory
Returns:
(str) - string of db2_home
"""
return self._properties.get('db2Instance', {}).get('homeDirectory', "")
@property
def user_name(self):
"""
returns db2 user name
Returns:
(str) - String containing db2 user
"""
return self._properties.get(
'db2Instance', {}).get('userAccount', {}).get('userName', "")
@property
def data_backup_storage_policy(self):
""" returns data backup storage policy
Returns:
(str) -- Storage policy name from db2 instance level
"""
return self._properties.get('db2Instance', {}).get(
'DB2StorageDevice', {}).get('dataBackupStoragePolicy', {}).get('storagePolicyName', "")
@property
def command_line_storage_policy(self):
"""returns commandline storage policy
Returns:
(str) -- Command line sp name from db2 instance level
"""
return self._properties.get('db2Instance', {}).get(
'DB2StorageDevice', {}).get('commandLineStoragePolicy', {}).get('storagePolicyName', "")
@property
def log_backup_storage_policy(self):
"""
returns log backup storage policy
Returns:
(str) -- Log backup SP name from instance level
"""
return self._properties.get('db2Instance', {}).get(
'DB2StorageDevice', {}).get('logBackupStoragePolicy', {}).get('storagePolicyName', "")
def _restore_destination_json(self, value):
"""setter for the Db2 Destination options in restore JSON"""
if not isinstance(value, dict):
raise SDKException('Instance', '101')
self._destination_restore_json = {
"destinationInstance": {
"clientName": value.get("dest_client_name", ""),
"instanceName": value.get("dest_instance_name", ""),
"backupsetName": value.get("dest_backupset_name", ""),
"appName": "DB2"
},
"destClient": {
"clientName": value.get("dest_client_name", "")
}
}
def _db2_restore_options_json(self, value):
"""setter for the db2 options of in restore JSON
Args:
value (dict) -- Dictionary of options need to be set for restore
"""
if not isinstance(value, dict):
raise SDKException('Instance', '101')
self.db2_options_restore_json = {
"restoreType": value.get("restore_type", 0),
"restoreLevel": value.get("restore_level", 0),
"redirect": value.get("redirect", False),
"rollForwardPending": value.get("rollforward_pending", False),
"restoreArchiveLogs": value.get("restore_archive_logs", True),
"rollForward": value.get("roll_forward", True),
"restoreIncremental": value.get("restore_incremental", False),
"archiveLogLSN": value.get("archivelog_lsn", False),
"archiveLogTime": value.get("archive_log_time", False),
"startLSN": value.get("start_lsn", False),
"endLSN": value.get("end_lsn", False),
"logTimeStart": value.get("logtime_start", False),
"logTimeEnd": value.get("logtime_end", False),
"rollForwardToEnd": value.get("roll_forward_to_end", 1),
"useAlternateLogFile": value.get("use_alternate_logfile", False),
"restoreData": value.get("restore_data", True),
"restoreOnline": value.get("restore_online", False),
"targetDb": value.get("target_db", " "),
"targetPath": value.get("target_path", " "),
"reportFile": value.get("report_file", " "),
"buffers": value.get("buffers", 2),
"bufferSize": value.get("buffer_size", 1024),
"rollForwardDir": value.get("roll_forward_dir", " "),
"recoverDb": value.get("recover_db", False),
"dbHistoryFilepath": value.get("db_history_filepath", False),
"storagePath": value.get("storage_path", False),
"parallelism": value.get("parallelism", 0),
"useSnapRestore": value.get("use_snap_restore", False),
"useLatestImage": value.get("use_latest_image", True),
"tableViewRestore": value.get("table_view_restore", False),
"useLogTarget": value.get("use_log_target", False),
"cloneRecovery": value.get("clone_recovery", False)
}
return self.db2_options_restore_json
def _restore_json(self, **kwargs):
"""Returns the JSON request to pass to the API as per the options selected by the user.
Args:
kwargs (dict) -- list of options need to be set for restore
Returns:
dict - JSON request to pass to the API
"""
rest_json = super(DB2Instance, self)._restore_json(**kwargs)
restore_option = {}
if kwargs.get("restore_option"):
restore_option = kwargs["restore_option"]
for key in kwargs:
if not key == "restore_option":
restore_option[key] = kwargs[key]
else:
restore_option = kwargs
json = self._db2_restore_options_json(restore_option)
rest_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"] = json
return rest_json
def restore_entire_database(
self,
dest_client_name,
dest_instance_name,
dest_database_name,
**kwargs
):
"""Restores the db2 database
Args:
dest_client_name (str) -- destination client name
dest_instance_name (str) -- destination db2 instance name of
destination on destination client
dest_database_name (str) -- destination database name
restore_type (str) -- db2 restore type
default: "ENTIREDB"
recover_db (bool) -- recover database flag
default: True
restore_incremental (bool) -- Restore incremental flag
default: True
restore_data (bool) -- Restore data or not
default: True
copy_precedence (int) -- Copy precedence to perform restore from
default : None
roll_forward (bool) -- Rollforward database or not
default: True
restore_logs (bool) - Restore the logs or not
default: True
Returns:
object - instance of the Job class for this restore job
Raises:
SDKException:
if failed to initialize job
if response is empty
if response is not success
"""
recover_db = kwargs.get("recover_db", True)
restore_incremental = kwargs.get("restore_incremental", True)
restore_data = kwargs.get("restore_data", True)
copy_precedence = kwargs.get("copy_precedence", None)
roll_forward = kwargs.get("roll_forward", True)
restore_logs = kwargs.get("restore_logs", True)
restore_type = kwargs.get("restore_type", 'ENTIREDB')
if "entiredb" in restore_type.lower():
restore_type = 0
request_json = self._restore_json(
dest_client_name=dest_client_name,
dest_instance_name=dest_instance_name,
dest_backupset_name=dest_database_name,
target_db=dest_database_name,
restore_type=restore_type,
recover_db=recover_db,
restore_incremental=restore_incremental,
restore_data=restore_data,
copy_precedence=copy_precedence,
roll_forward=roll_forward,
rollforward_pending=not roll_forward,
restore_archive_logs=restore_logs
)
request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][
"browseOption"]["backupset"]["backupsetName"] = dest_database_name
return self._process_restore_response(request_json)
def restore_out_of_place(
self,
dest_client_name,
dest_instance_name,
dest_backupset_name,
target_path,
**kwargs):
"""Restores the DB2 data/log files specified in the input paths
list to the same location.
Args:
dest_client_name (str) -- destination client name where files are to be
restored
dest_instance_name (str) -- destination db2 instance name of
destination client
dest_backupset_name (str) -- destination db2 backupset name of
destination client
target_path (str) -- Destination DB restore path
copy_precedence (int) -- copy precedence value of storage policy copy
default: None
from_time (str) -- time to retore the contents after
format: YYYY-MM-DD HH:MM:SS
default: None
to_time (str) -- time to retore the contents before
format: YYYY-MM-DD HH:MM:SS
default: None
redirect_enabled (bool) -- boolean to specify if redirect restore is
enabled
default: False
redirect_storage_group_path (dict) -- Path specified for each storage group
in advanced restore options in order to perform redirect restore
format: {'Storage Group Name': 'Redirect Path'}
default: None
redirect_tablespace_path (dict) -- Path specified for each tablespace in advanced
restore options in order to perform redirect restore
format: {'Tablespace name': 'Redirect Path'}
default: None
destination_path (str) -- destinath path for restore
default: None
restore_data (bool) -- Restore data or not
Returns:
object - instance of the Job class for this restore job
Raises:
SDKException:
if failed to initialize job
if response is empty
if response is not success
"""
copy_precedence = kwargs.get('copy_precedence', None)
from_time = kwargs.get('from_time', None)
to_time = kwargs.get('to_time', None)
redirect_enabled = kwargs.get('redirect_enabled', False)
redirect_tablespace_path = kwargs.get('redirect_tablespace_path', None)
redirect_storage_group_path = kwargs.get('redirect_storage_group_path', None)
rollforward = kwargs.get('rollforward', True)
restoreArchiveLogs = kwargs.get('restoreArchiveLogs', False)
restore_incremental = kwargs.get('restore_incremental', True)
restore_data = kwargs.get('restore_data', True)
if redirect_enabled:
if not (isinstance(redirect_tablespace_path, dict) or isinstance(redirect_tablespace_path, str)) and \
not isinstance(redirect_storage_group_path, dict):
raise SDKException('Instance', '101')
request_json = self._restore_json(
dest_client_name=dest_client_name,
dest_instance_name=dest_instance_name,
dest_backupset_name=dest_backupset_name,
target_db=dest_backupset_name,
target_path=target_path,
copy_precedence=copy_precedence,
from_time=from_time,
to_time=to_time,
redirect=redirect_enabled,
redirect_storage_group_path=redirect_storage_group_path,
redirect_tablespace_path=redirect_tablespace_path,
rollforward_pending=not rollforward,
restore_archive_logs=restoreArchiveLogs,
roll_forward=rollforward,
restore_incremental=restore_incremental,
storage_path=True,
restore_data=restore_data)
if redirect_storage_group_path:
storagePaths = []
storageGroup = {"storageGroup": []}
for name, path in redirect_storage_group_path.items():
if isinstance(path, str):
storageGroup["storageGroup"].append({"groupName": name, "stoPaths": [path]})
storagePaths = [path]
else:
storageGroup["storageGroup"].append({"groupName": name, "stoPaths": path})
storagePaths = [path[0]]
request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][
"redirectStorageGroups"] = True
request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][
"storagePaths"] = storagePaths
request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][
"storageGroupInfo"] = storageGroup
if redirect_tablespace_path:
if isinstance(redirect_tablespace_path, str):
request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][
"redirectAllPaths"] = redirect_tablespace_path
request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][
"redirectAllTableSpacesSelected"] = True
request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][
"redirectAllTableSpacesValue"] = redirect_tablespace_path
else:
redirect_info = []
for tablespace, path in redirect_tablespace_path.items():
table_string = "%s\t1\t%s\t6\t25600\t1\t1" % (tablespace, path)
redirect_info.append(table_string)
request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][
"redirectInfo"] = redirect_info
request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][
"browseOption"]["backupset"]["backupsetName"] = dest_backupset_name
return self._process_restore_response(request_json)
def restore_table_level(
self,
aux_client_name,
aux_instance_name,
aux_backupset_name,
dest_client_name,
dest_instance_name,
dest_backupset_name,
target_path,
staging_path,
tables_path,
user_name,
password,
**kwargs
):
"""
Performs DB2 table level restore
Args:
aux_client_name (str) -- auxiliary client name where files are to be restored
aux_instance_name (str) -- auxiliary instance name where files are to be restored
aux_backupset_name (str) -- auxiliary backupset name where files are to be restored
dest_client_name (str) -- destination client name where files are to be restored
dest_instance_name (str) -- destination db2 instance name of destination client
dest_backupset_name (str) -- destination db2 backupset name of destination client
target_path (str) -- Destination DB restore path
src_backupset_name (str) -- Source Backupset Name
staging_path (str) -- Staging Path
user_name (str) -- Destination User name
password (str) -- Destination User Password
tables_path (list) -- List of tables path
Example:
Unix: ['/+tblview+/instance_name/database_name/schema_name/table_name/**']
Windows: ["\+tblview+\instance_name\database_name\schema_name\table_name\**"]
copy_precedence (int) -- copy precedence value of storage policy copy
default: None
from_time (str) -- time to retore the contents after
format: YYYY-MM-DD HH:MM:SS
default: None
to_time (str) -- time to retore the contents before
format: YYYY-MM-DD HH:MM:SS
default: None
rollForward (bool) -- Rollforward or not
default: True
destination_path (str) -- destinath path for restore
default: None
server_port (int) -- Server Port Destination instance
default: 50000
generateAuthorizationDDL (bool) -- Generate Authorization DDL
default: False
extractDDLStatements (bool) -- Extracts DDL statement or not
default: True
clearAuxiliary (bool) -- Cleanup auxilliary or not
default: True
dropTable (bool) -- Drop table for import
default: False
Returns:
object - instance of the Job class for this restore job
Raises:
SDKException:
if failed to initialize job
if response is empty
if response is not success
"""
copy_precedence = kwargs.get('copy_precedence', None)
from_time = kwargs.get('from_time', None)
to_time = kwargs.get('to_time', None)
rollforward = kwargs.get('rollforward', True)
restoreArchiveLogs = kwargs.get('restoreArchiveLogs', False)
request_json = self._restore_json(
dest_client_name=aux_client_name,
dest_instance_name=aux_instance_name,
dest_backupset_name=aux_backupset_name,
target_db=aux_backupset_name,
target_path=target_path,
copy_precedence=copy_precedence,
from_time=from_time,
to_time=to_time,
rollforward_pending=not rollforward,
restoreArchiveLogs=restoreArchiveLogs,
roll_forward=rollforward,
storage_path=True,
table_view_restore=True)
request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][
"storagePaths"] = [target_path]
password = b64encode(password.encode()).decode()
table_json = {
"additionalExportParameter": kwargs.get("additionalExportParameter", ""),
"serverPort": kwargs.get("server_port", 50000),
"generateAuthorizationDDL": kwargs.get("generateAuthorizationDDL", False),
"importInstance": dest_instance_name,
"extractDDLStatements": kwargs.get("extractDDLStatements", True),
"useAdditionalExportParameters": kwargs.get("useAdditionalExportParameters", False),
"auxiliaryInstance": False,
"clearAuxiliary": kwargs.get("clearAuxiliary", True),
"importDatabase": dest_backupset_name,
"importToWhere": 2,
"dropTable": kwargs.get("dropTable", False),
"stagingPath": staging_path,
"importDbClient": {"clientName": dest_client_name},
"importUserInfo": {"userName": user_name, "password": password}
}
request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][
"storagePaths"] = [target_path]
request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][
"databaseTableRstOptions"] = table_json
request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][
"browseOption"]["backupset"]["backupsetId"] = int(self.backupsets.get(aux_backupset_name).backupset_id)
request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][
"browseOption"]["backupset"]["backupsetName"] = aux_backupset_name
request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][
"restoreArchiveLogs"] = False
request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][
"fileOption"]["filterItem"] = tables_path
request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][
"fileOption"]["sourceItem"] = tables_path
return self._process_restore_response(request_json)Classes
class DB2Instance (agent_object, instance_name, instance_id=None)-
Derived class from Instance Base class, representing a DB2 instance, and to perform operations on that Instance.
Initialise the instance object.
Args
agent_object (object) – instance of the Agent class
instance_name (str) – name of the instance
instance_id (str) – id of the instance default: None
Returns
object - instance of the Instance class
Expand source code Browse git
class DB2Instance(Instance): """ Derived class from Instance Base class, representing a DB2 instance, and to perform operations on that Instance.""" @property def version(self): """returns db2 version Returns: (str) -- db2 version value in string """ return self._properties.get('version', "") @property def home_directory(self): """ returns db2 home directory Returns: (str) - string of db2_home """ return self._properties.get('db2Instance', {}).get('homeDirectory', "") @property def user_name(self): """ returns db2 user name Returns: (str) - String containing db2 user """ return self._properties.get( 'db2Instance', {}).get('userAccount', {}).get('userName', "") @property def data_backup_storage_policy(self): """ returns data backup storage policy Returns: (str) -- Storage policy name from db2 instance level """ return self._properties.get('db2Instance', {}).get( 'DB2StorageDevice', {}).get('dataBackupStoragePolicy', {}).get('storagePolicyName', "") @property def command_line_storage_policy(self): """returns commandline storage policy Returns: (str) -- Command line sp name from db2 instance level """ return self._properties.get('db2Instance', {}).get( 'DB2StorageDevice', {}).get('commandLineStoragePolicy', {}).get('storagePolicyName', "") @property def log_backup_storage_policy(self): """ returns log backup storage policy Returns: (str) -- Log backup SP name from instance level """ return self._properties.get('db2Instance', {}).get( 'DB2StorageDevice', {}).get('logBackupStoragePolicy', {}).get('storagePolicyName', "") def _restore_destination_json(self, value): """setter for the Db2 Destination options in restore JSON""" if not isinstance(value, dict): raise SDKException('Instance', '101') self._destination_restore_json = { "destinationInstance": { "clientName": value.get("dest_client_name", ""), "instanceName": value.get("dest_instance_name", ""), "backupsetName": value.get("dest_backupset_name", ""), "appName": "DB2" }, "destClient": { "clientName": value.get("dest_client_name", "") } } def _db2_restore_options_json(self, value): """setter for the db2 options of in restore JSON Args: value (dict) -- Dictionary of options need to be set for restore """ if not isinstance(value, dict): raise SDKException('Instance', '101') self.db2_options_restore_json = { "restoreType": value.get("restore_type", 0), "restoreLevel": value.get("restore_level", 0), "redirect": value.get("redirect", False), "rollForwardPending": value.get("rollforward_pending", False), "restoreArchiveLogs": value.get("restore_archive_logs", True), "rollForward": value.get("roll_forward", True), "restoreIncremental": value.get("restore_incremental", False), "archiveLogLSN": value.get("archivelog_lsn", False), "archiveLogTime": value.get("archive_log_time", False), "startLSN": value.get("start_lsn", False), "endLSN": value.get("end_lsn", False), "logTimeStart": value.get("logtime_start", False), "logTimeEnd": value.get("logtime_end", False), "rollForwardToEnd": value.get("roll_forward_to_end", 1), "useAlternateLogFile": value.get("use_alternate_logfile", False), "restoreData": value.get("restore_data", True), "restoreOnline": value.get("restore_online", False), "targetDb": value.get("target_db", " "), "targetPath": value.get("target_path", " "), "reportFile": value.get("report_file", " "), "buffers": value.get("buffers", 2), "bufferSize": value.get("buffer_size", 1024), "rollForwardDir": value.get("roll_forward_dir", " "), "recoverDb": value.get("recover_db", False), "dbHistoryFilepath": value.get("db_history_filepath", False), "storagePath": value.get("storage_path", False), "parallelism": value.get("parallelism", 0), "useSnapRestore": value.get("use_snap_restore", False), "useLatestImage": value.get("use_latest_image", True), "tableViewRestore": value.get("table_view_restore", False), "useLogTarget": value.get("use_log_target", False), "cloneRecovery": value.get("clone_recovery", False) } return self.db2_options_restore_json def _restore_json(self, **kwargs): """Returns the JSON request to pass to the API as per the options selected by the user. Args: kwargs (dict) -- list of options need to be set for restore Returns: dict - JSON request to pass to the API """ rest_json = super(DB2Instance, self)._restore_json(**kwargs) restore_option = {} if kwargs.get("restore_option"): restore_option = kwargs["restore_option"] for key in kwargs: if not key == "restore_option": restore_option[key] = kwargs[key] else: restore_option = kwargs json = self._db2_restore_options_json(restore_option) rest_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"] = json return rest_json def restore_entire_database( self, dest_client_name, dest_instance_name, dest_database_name, **kwargs ): """Restores the db2 database Args: dest_client_name (str) -- destination client name dest_instance_name (str) -- destination db2 instance name of destination on destination client dest_database_name (str) -- destination database name restore_type (str) -- db2 restore type default: "ENTIREDB" recover_db (bool) -- recover database flag default: True restore_incremental (bool) -- Restore incremental flag default: True restore_data (bool) -- Restore data or not default: True copy_precedence (int) -- Copy precedence to perform restore from default : None roll_forward (bool) -- Rollforward database or not default: True restore_logs (bool) - Restore the logs or not default: True Returns: object - instance of the Job class for this restore job Raises: SDKException: if failed to initialize job if response is empty if response is not success """ recover_db = kwargs.get("recover_db", True) restore_incremental = kwargs.get("restore_incremental", True) restore_data = kwargs.get("restore_data", True) copy_precedence = kwargs.get("copy_precedence", None) roll_forward = kwargs.get("roll_forward", True) restore_logs = kwargs.get("restore_logs", True) restore_type = kwargs.get("restore_type", 'ENTIREDB') if "entiredb" in restore_type.lower(): restore_type = 0 request_json = self._restore_json( dest_client_name=dest_client_name, dest_instance_name=dest_instance_name, dest_backupset_name=dest_database_name, target_db=dest_database_name, restore_type=restore_type, recover_db=recover_db, restore_incremental=restore_incremental, restore_data=restore_data, copy_precedence=copy_precedence, roll_forward=roll_forward, rollforward_pending=not roll_forward, restore_archive_logs=restore_logs ) request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][ "browseOption"]["backupset"]["backupsetName"] = dest_database_name return self._process_restore_response(request_json) def restore_out_of_place( self, dest_client_name, dest_instance_name, dest_backupset_name, target_path, **kwargs): """Restores the DB2 data/log files specified in the input paths list to the same location. Args: dest_client_name (str) -- destination client name where files are to be restored dest_instance_name (str) -- destination db2 instance name of destination client dest_backupset_name (str) -- destination db2 backupset name of destination client target_path (str) -- Destination DB restore path copy_precedence (int) -- copy precedence value of storage policy copy default: None from_time (str) -- time to retore the contents after format: YYYY-MM-DD HH:MM:SS default: None to_time (str) -- time to retore the contents before format: YYYY-MM-DD HH:MM:SS default: None redirect_enabled (bool) -- boolean to specify if redirect restore is enabled default: False redirect_storage_group_path (dict) -- Path specified for each storage group in advanced restore options in order to perform redirect restore format: {'Storage Group Name': 'Redirect Path'} default: None redirect_tablespace_path (dict) -- Path specified for each tablespace in advanced restore options in order to perform redirect restore format: {'Tablespace name': 'Redirect Path'} default: None destination_path (str) -- destinath path for restore default: None restore_data (bool) -- Restore data or not Returns: object - instance of the Job class for this restore job Raises: SDKException: if failed to initialize job if response is empty if response is not success """ copy_precedence = kwargs.get('copy_precedence', None) from_time = kwargs.get('from_time', None) to_time = kwargs.get('to_time', None) redirect_enabled = kwargs.get('redirect_enabled', False) redirect_tablespace_path = kwargs.get('redirect_tablespace_path', None) redirect_storage_group_path = kwargs.get('redirect_storage_group_path', None) rollforward = kwargs.get('rollforward', True) restoreArchiveLogs = kwargs.get('restoreArchiveLogs', False) restore_incremental = kwargs.get('restore_incremental', True) restore_data = kwargs.get('restore_data', True) if redirect_enabled: if not (isinstance(redirect_tablespace_path, dict) or isinstance(redirect_tablespace_path, str)) and \ not isinstance(redirect_storage_group_path, dict): raise SDKException('Instance', '101') request_json = self._restore_json( dest_client_name=dest_client_name, dest_instance_name=dest_instance_name, dest_backupset_name=dest_backupset_name, target_db=dest_backupset_name, target_path=target_path, copy_precedence=copy_precedence, from_time=from_time, to_time=to_time, redirect=redirect_enabled, redirect_storage_group_path=redirect_storage_group_path, redirect_tablespace_path=redirect_tablespace_path, rollforward_pending=not rollforward, restore_archive_logs=restoreArchiveLogs, roll_forward=rollforward, restore_incremental=restore_incremental, storage_path=True, restore_data=restore_data) if redirect_storage_group_path: storagePaths = [] storageGroup = {"storageGroup": []} for name, path in redirect_storage_group_path.items(): if isinstance(path, str): storageGroup["storageGroup"].append({"groupName": name, "stoPaths": [path]}) storagePaths = [path] else: storageGroup["storageGroup"].append({"groupName": name, "stoPaths": path}) storagePaths = [path[0]] request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "redirectStorageGroups"] = True request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "storagePaths"] = storagePaths request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "storageGroupInfo"] = storageGroup if redirect_tablespace_path: if isinstance(redirect_tablespace_path, str): request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "redirectAllPaths"] = redirect_tablespace_path request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "redirectAllTableSpacesSelected"] = True request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "redirectAllTableSpacesValue"] = redirect_tablespace_path else: redirect_info = [] for tablespace, path in redirect_tablespace_path.items(): table_string = "%s\t1\t%s\t6\t25600\t1\t1" % (tablespace, path) redirect_info.append(table_string) request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "redirectInfo"] = redirect_info request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][ "browseOption"]["backupset"]["backupsetName"] = dest_backupset_name return self._process_restore_response(request_json) def restore_table_level( self, aux_client_name, aux_instance_name, aux_backupset_name, dest_client_name, dest_instance_name, dest_backupset_name, target_path, staging_path, tables_path, user_name, password, **kwargs ): """ Performs DB2 table level restore Args: aux_client_name (str) -- auxiliary client name where files are to be restored aux_instance_name (str) -- auxiliary instance name where files are to be restored aux_backupset_name (str) -- auxiliary backupset name where files are to be restored dest_client_name (str) -- destination client name where files are to be restored dest_instance_name (str) -- destination db2 instance name of destination client dest_backupset_name (str) -- destination db2 backupset name of destination client target_path (str) -- Destination DB restore path src_backupset_name (str) -- Source Backupset Name staging_path (str) -- Staging Path user_name (str) -- Destination User name password (str) -- Destination User Password tables_path (list) -- List of tables path Example: Unix: ['/+tblview+/instance_name/database_name/schema_name/table_name/**'] Windows: ["\+tblview+\instance_name\database_name\schema_name\table_name\**"] copy_precedence (int) -- copy precedence value of storage policy copy default: None from_time (str) -- time to retore the contents after format: YYYY-MM-DD HH:MM:SS default: None to_time (str) -- time to retore the contents before format: YYYY-MM-DD HH:MM:SS default: None rollForward (bool) -- Rollforward or not default: True destination_path (str) -- destinath path for restore default: None server_port (int) -- Server Port Destination instance default: 50000 generateAuthorizationDDL (bool) -- Generate Authorization DDL default: False extractDDLStatements (bool) -- Extracts DDL statement or not default: True clearAuxiliary (bool) -- Cleanup auxilliary or not default: True dropTable (bool) -- Drop table for import default: False Returns: object - instance of the Job class for this restore job Raises: SDKException: if failed to initialize job if response is empty if response is not success """ copy_precedence = kwargs.get('copy_precedence', None) from_time = kwargs.get('from_time', None) to_time = kwargs.get('to_time', None) rollforward = kwargs.get('rollforward', True) restoreArchiveLogs = kwargs.get('restoreArchiveLogs', False) request_json = self._restore_json( dest_client_name=aux_client_name, dest_instance_name=aux_instance_name, dest_backupset_name=aux_backupset_name, target_db=aux_backupset_name, target_path=target_path, copy_precedence=copy_precedence, from_time=from_time, to_time=to_time, rollforward_pending=not rollforward, restoreArchiveLogs=restoreArchiveLogs, roll_forward=rollforward, storage_path=True, table_view_restore=True) request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "storagePaths"] = [target_path] password = b64encode(password.encode()).decode() table_json = { "additionalExportParameter": kwargs.get("additionalExportParameter", ""), "serverPort": kwargs.get("server_port", 50000), "generateAuthorizationDDL": kwargs.get("generateAuthorizationDDL", False), "importInstance": dest_instance_name, "extractDDLStatements": kwargs.get("extractDDLStatements", True), "useAdditionalExportParameters": kwargs.get("useAdditionalExportParameters", False), "auxiliaryInstance": False, "clearAuxiliary": kwargs.get("clearAuxiliary", True), "importDatabase": dest_backupset_name, "importToWhere": 2, "dropTable": kwargs.get("dropTable", False), "stagingPath": staging_path, "importDbClient": {"clientName": dest_client_name}, "importUserInfo": {"userName": user_name, "password": password} } request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "storagePaths"] = [target_path] request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "databaseTableRstOptions"] = table_json request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][ "browseOption"]["backupset"]["backupsetId"] = int(self.backupsets.get(aux_backupset_name).backupset_id) request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][ "browseOption"]["backupset"]["backupsetName"] = aux_backupset_name request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "restoreArchiveLogs"] = False request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][ "fileOption"]["filterItem"] = tables_path request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][ "fileOption"]["sourceItem"] = tables_path return self._process_restore_response(request_json)Ancestors
Instance variables
var command_line_storage_policy-
returns commandline storage policy
Returns
(str) – Command line sp name from db2 instance level
Expand source code Browse git
@property def command_line_storage_policy(self): """returns commandline storage policy Returns: (str) -- Command line sp name from db2 instance level """ return self._properties.get('db2Instance', {}).get( 'DB2StorageDevice', {}).get('commandLineStoragePolicy', {}).get('storagePolicyName', "") var data_backup_storage_policy-
returns data backup storage policy
Returns
(str) – Storage policy name from db2 instance level
Expand source code Browse git
@property def data_backup_storage_policy(self): """ returns data backup storage policy Returns: (str) -- Storage policy name from db2 instance level """ return self._properties.get('db2Instance', {}).get( 'DB2StorageDevice', {}).get('dataBackupStoragePolicy', {}).get('storagePolicyName', "") var home_directory-
returns db2 home directory
Returns
(str) - string of db2_home
Expand source code Browse git
@property def home_directory(self): """ returns db2 home directory Returns: (str) - string of db2_home """ return self._properties.get('db2Instance', {}).get('homeDirectory', "") var log_backup_storage_policy-
returns log backup storage policy
Returns: (str) -- Log backup SP name from instance levelExpand source code Browse git
@property def log_backup_storage_policy(self): """ returns log backup storage policy Returns: (str) -- Log backup SP name from instance level """ return self._properties.get('db2Instance', {}).get( 'DB2StorageDevice', {}).get('logBackupStoragePolicy', {}).get('storagePolicyName', "") var user_name-
returns db2 user name
Returns
(str) - String containing db2 user
Expand source code Browse git
@property def user_name(self): """ returns db2 user name Returns: (str) - String containing db2 user """ return self._properties.get( 'db2Instance', {}).get('userAccount', {}).get('userName', "") var version-
returns db2 version
Returns
(str) – db2 version value in string
Expand source code Browse git
@property def version(self): """returns db2 version Returns: (str) -- db2 version value in string """ return self._properties.get('version', "")
Methods
def restore_entire_database(self, dest_client_name, dest_instance_name, dest_database_name, **kwargs)-
Restores the db2 database
Args
dest_client_name (str) – destination client name
dest_instance_name (str) – destination db2 instance name of destination on destination client
dest_database_name (str) – destination database name
restore_type (str) – db2 restore type
default: "ENTIREDB"recover_db (bool) – recover database flag
default: Truerestore_incremental (bool) – Restore incremental flag
default: Truerestore_data (bool) – Restore data or not default: True
copy_precedence (int) – Copy precedence to perform restore from default : None
roll_forward (bool) – Rollforward database or not default: True
- restore_logs (bool) - Restore the logs or not
default- True
Returns
object - instance of the Job class for this restore job
Raises
SDKException:
if failed to initialize job if response is empty if response is not successExpand source code Browse git
def restore_entire_database( self, dest_client_name, dest_instance_name, dest_database_name, **kwargs ): """Restores the db2 database Args: dest_client_name (str) -- destination client name dest_instance_name (str) -- destination db2 instance name of destination on destination client dest_database_name (str) -- destination database name restore_type (str) -- db2 restore type default: "ENTIREDB" recover_db (bool) -- recover database flag default: True restore_incremental (bool) -- Restore incremental flag default: True restore_data (bool) -- Restore data or not default: True copy_precedence (int) -- Copy precedence to perform restore from default : None roll_forward (bool) -- Rollforward database or not default: True restore_logs (bool) - Restore the logs or not default: True Returns: object - instance of the Job class for this restore job Raises: SDKException: if failed to initialize job if response is empty if response is not success """ recover_db = kwargs.get("recover_db", True) restore_incremental = kwargs.get("restore_incremental", True) restore_data = kwargs.get("restore_data", True) copy_precedence = kwargs.get("copy_precedence", None) roll_forward = kwargs.get("roll_forward", True) restore_logs = kwargs.get("restore_logs", True) restore_type = kwargs.get("restore_type", 'ENTIREDB') if "entiredb" in restore_type.lower(): restore_type = 0 request_json = self._restore_json( dest_client_name=dest_client_name, dest_instance_name=dest_instance_name, dest_backupset_name=dest_database_name, target_db=dest_database_name, restore_type=restore_type, recover_db=recover_db, restore_incremental=restore_incremental, restore_data=restore_data, copy_precedence=copy_precedence, roll_forward=roll_forward, rollforward_pending=not roll_forward, restore_archive_logs=restore_logs ) request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][ "browseOption"]["backupset"]["backupsetName"] = dest_database_name return self._process_restore_response(request_json) def restore_out_of_place(self, dest_client_name, dest_instance_name, dest_backupset_name, target_path, **kwargs)-
Restores the DB2 data/log files specified in the input paths list to the same location.
Args: dest_client_name (str) -- destination client name where files are to be restored dest_instance_name (str) -- destination db2 instance name of destination client dest_backupset_name (str) -- destination db2 backupset name of destination client target_path (str) -- Destination DB restore path copy_precedence (int) -- copy precedence value of storage policy copy default: None from_time (str) -- time to retore the contents after format: YYYY-MM-DD HH:MM:SS default: None to_time (str) -- time to retore the contents before format: YYYY-MM-DD HH:MM:SS default: None redirect_enabled (bool) -- boolean to specify if redirect restore is enabled default: False redirect_storage_group_path (dict) -- Path specified for each storage group in advanced restore options in order to perform redirect restore format: {'Storage Group Name': 'Redirect Path'} default: None redirect_tablespace_path (dict) -- Path specified for each tablespace in advanced restore options in order to perform redirect restore format: {'Tablespace name': 'Redirect Path'} default: None destination_path (str) -- destinath path for restore default: None restore_data (bool) -- Restore data or not Returns: object - instance of the Job class for this restore job Raises: SDKException: if failed to initialize job if response is empty if response is not successExpand source code Browse git
def restore_out_of_place( self, dest_client_name, dest_instance_name, dest_backupset_name, target_path, **kwargs): """Restores the DB2 data/log files specified in the input paths list to the same location. Args: dest_client_name (str) -- destination client name where files are to be restored dest_instance_name (str) -- destination db2 instance name of destination client dest_backupset_name (str) -- destination db2 backupset name of destination client target_path (str) -- Destination DB restore path copy_precedence (int) -- copy precedence value of storage policy copy default: None from_time (str) -- time to retore the contents after format: YYYY-MM-DD HH:MM:SS default: None to_time (str) -- time to retore the contents before format: YYYY-MM-DD HH:MM:SS default: None redirect_enabled (bool) -- boolean to specify if redirect restore is enabled default: False redirect_storage_group_path (dict) -- Path specified for each storage group in advanced restore options in order to perform redirect restore format: {'Storage Group Name': 'Redirect Path'} default: None redirect_tablespace_path (dict) -- Path specified for each tablespace in advanced restore options in order to perform redirect restore format: {'Tablespace name': 'Redirect Path'} default: None destination_path (str) -- destinath path for restore default: None restore_data (bool) -- Restore data or not Returns: object - instance of the Job class for this restore job Raises: SDKException: if failed to initialize job if response is empty if response is not success """ copy_precedence = kwargs.get('copy_precedence', None) from_time = kwargs.get('from_time', None) to_time = kwargs.get('to_time', None) redirect_enabled = kwargs.get('redirect_enabled', False) redirect_tablespace_path = kwargs.get('redirect_tablespace_path', None) redirect_storage_group_path = kwargs.get('redirect_storage_group_path', None) rollforward = kwargs.get('rollforward', True) restoreArchiveLogs = kwargs.get('restoreArchiveLogs', False) restore_incremental = kwargs.get('restore_incremental', True) restore_data = kwargs.get('restore_data', True) if redirect_enabled: if not (isinstance(redirect_tablespace_path, dict) or isinstance(redirect_tablespace_path, str)) and \ not isinstance(redirect_storage_group_path, dict): raise SDKException('Instance', '101') request_json = self._restore_json( dest_client_name=dest_client_name, dest_instance_name=dest_instance_name, dest_backupset_name=dest_backupset_name, target_db=dest_backupset_name, target_path=target_path, copy_precedence=copy_precedence, from_time=from_time, to_time=to_time, redirect=redirect_enabled, redirect_storage_group_path=redirect_storage_group_path, redirect_tablespace_path=redirect_tablespace_path, rollforward_pending=not rollforward, restore_archive_logs=restoreArchiveLogs, roll_forward=rollforward, restore_incremental=restore_incremental, storage_path=True, restore_data=restore_data) if redirect_storage_group_path: storagePaths = [] storageGroup = {"storageGroup": []} for name, path in redirect_storage_group_path.items(): if isinstance(path, str): storageGroup["storageGroup"].append({"groupName": name, "stoPaths": [path]}) storagePaths = [path] else: storageGroup["storageGroup"].append({"groupName": name, "stoPaths": path}) storagePaths = [path[0]] request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "redirectStorageGroups"] = True request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "storagePaths"] = storagePaths request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "storageGroupInfo"] = storageGroup if redirect_tablespace_path: if isinstance(redirect_tablespace_path, str): request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "redirectAllPaths"] = redirect_tablespace_path request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "redirectAllTableSpacesSelected"] = True request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "redirectAllTableSpacesValue"] = redirect_tablespace_path else: redirect_info = [] for tablespace, path in redirect_tablespace_path.items(): table_string = "%s\t1\t%s\t6\t25600\t1\t1" % (tablespace, path) redirect_info.append(table_string) request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "redirectInfo"] = redirect_info request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][ "browseOption"]["backupset"]["backupsetName"] = dest_backupset_name return self._process_restore_response(request_json) def restore_table_level(self, aux_client_name, aux_instance_name, aux_backupset_name, dest_client_name, dest_instance_name, dest_backupset_name, target_path, staging_path, tables_path, user_name, password, **kwargs)-
Performs DB2 table level restore Args: aux_client_name (str) – auxiliary client name where files are to be restored aux_instance_name (str) – auxiliary instance name where files are to be restored aux_backupset_name (str) – auxiliary backupset name where files are to be restored dest_client_name (str) – destination client name where files are to be restored dest_instance_name (str) – destination db2 instance name of destination client dest_backupset_name (str) – destination db2 backupset name of destination client
target_path (str) -- Destination DB restore path src_backupset_name (str) -- Source Backupset Name staging_path (str) -- Staging Path user_name (str) -- Destination User name password (str) -- Destination User Password tables_path (list) -- List of tables path Example: Unix: ['/+tblview+/instance_name/database_name/schema_name/table_name/**'] Windows: ["\+tblview+\instance_name\database_name\schema_name able_name\**"] copy_precedence (int) -- copy precedence value of storage policy copy default: None from_time (str) -- time to retore the contents after format: YYYY-MM-DD HH:MM:SS default: None to_time (str) -- time to retore the contents before format: YYYY-MM-DD HH:MM:SS default: None rollForward (bool) -- Rollforward or not default: True destination_path (str) -- destinath path for restore default: None server_port (int) -- Server Port Destination instance default: 50000 generateAuthorizationDDL (bool) -- Generate Authorization DDL default: False extractDDLStatements (bool) -- Extracts DDL statement or not default: True clearAuxiliary (bool) -- Cleanup auxilliary or not default: True dropTable (bool) -- Drop table for import default: False Returns: object - instance of the Job class for this restore job Raises: SDKException: if failed to initialize job if response is empty if response is not successExpand source code Browse git
def restore_table_level( self, aux_client_name, aux_instance_name, aux_backupset_name, dest_client_name, dest_instance_name, dest_backupset_name, target_path, staging_path, tables_path, user_name, password, **kwargs ): """ Performs DB2 table level restore Args: aux_client_name (str) -- auxiliary client name where files are to be restored aux_instance_name (str) -- auxiliary instance name where files are to be restored aux_backupset_name (str) -- auxiliary backupset name where files are to be restored dest_client_name (str) -- destination client name where files are to be restored dest_instance_name (str) -- destination db2 instance name of destination client dest_backupset_name (str) -- destination db2 backupset name of destination client target_path (str) -- Destination DB restore path src_backupset_name (str) -- Source Backupset Name staging_path (str) -- Staging Path user_name (str) -- Destination User name password (str) -- Destination User Password tables_path (list) -- List of tables path Example: Unix: ['/+tblview+/instance_name/database_name/schema_name/table_name/**'] Windows: ["\+tblview+\instance_name\database_name\schema_name\table_name\**"] copy_precedence (int) -- copy precedence value of storage policy copy default: None from_time (str) -- time to retore the contents after format: YYYY-MM-DD HH:MM:SS default: None to_time (str) -- time to retore the contents before format: YYYY-MM-DD HH:MM:SS default: None rollForward (bool) -- Rollforward or not default: True destination_path (str) -- destinath path for restore default: None server_port (int) -- Server Port Destination instance default: 50000 generateAuthorizationDDL (bool) -- Generate Authorization DDL default: False extractDDLStatements (bool) -- Extracts DDL statement or not default: True clearAuxiliary (bool) -- Cleanup auxilliary or not default: True dropTable (bool) -- Drop table for import default: False Returns: object - instance of the Job class for this restore job Raises: SDKException: if failed to initialize job if response is empty if response is not success """ copy_precedence = kwargs.get('copy_precedence', None) from_time = kwargs.get('from_time', None) to_time = kwargs.get('to_time', None) rollforward = kwargs.get('rollforward', True) restoreArchiveLogs = kwargs.get('restoreArchiveLogs', False) request_json = self._restore_json( dest_client_name=aux_client_name, dest_instance_name=aux_instance_name, dest_backupset_name=aux_backupset_name, target_db=aux_backupset_name, target_path=target_path, copy_precedence=copy_precedence, from_time=from_time, to_time=to_time, rollforward_pending=not rollforward, restoreArchiveLogs=restoreArchiveLogs, roll_forward=rollforward, storage_path=True, table_view_restore=True) request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "storagePaths"] = [target_path] password = b64encode(password.encode()).decode() table_json = { "additionalExportParameter": kwargs.get("additionalExportParameter", ""), "serverPort": kwargs.get("server_port", 50000), "generateAuthorizationDDL": kwargs.get("generateAuthorizationDDL", False), "importInstance": dest_instance_name, "extractDDLStatements": kwargs.get("extractDDLStatements", True), "useAdditionalExportParameters": kwargs.get("useAdditionalExportParameters", False), "auxiliaryInstance": False, "clearAuxiliary": kwargs.get("clearAuxiliary", True), "importDatabase": dest_backupset_name, "importToWhere": 2, "dropTable": kwargs.get("dropTable", False), "stagingPath": staging_path, "importDbClient": {"clientName": dest_client_name}, "importUserInfo": {"userName": user_name, "password": password} } request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "storagePaths"] = [target_path] request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "databaseTableRstOptions"] = table_json request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][ "browseOption"]["backupset"]["backupsetId"] = int(self.backupsets.get(aux_backupset_name).backupset_id) request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][ "browseOption"]["backupset"]["backupsetName"] = aux_backupset_name request_json["taskInfo"]["subTasks"][0]["options"]["restoreOptions"]["db2Option"][ "restoreArchiveLogs"] = False request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][ "fileOption"]["filterItem"] = tables_path request_json['taskInfo']["subTasks"][0]["options"]["restoreOptions"][ "fileOption"]["sourceItem"] = tables_path return self._process_restore_response(request_json)
Inherited members