4141 'zurich' : 'eu-zurich-1'
4242}
4343
44- def print_mysql (region , vnc_client , mysql_db , values_for_column , ntk_compartment_name , state , ct , row ):
44+ def print_mysql (region , vnc_client , mysql_db , values_for_column , ntk_compartment_name , state , ct , mysql_aas_client ):
4545 mysql_tf_name = commonTools .check_tf_variable (mysql_db .display_name )
4646 mysql_subnet_id = mysql_db .subnet_id
4747
@@ -66,40 +66,24 @@ def print_mysql(region, vnc_client, mysql_db, values_for_column, ntk_compartment
6666 if hasattr (mysql_db , 'configuration_id' ) and mysql_db .configuration_id :
6767 config_id = mysql_db .configuration_id
6868 try :
69- # Create MySQL client with the same config as the parent client
70- config_copy = dict (vnc_client .base_client .config )
71- # Create a copy of the config and set the region from Excel row
72- config_copy = config_copy .copy ()
73- excel_region = row ['Region' ].lower ().strip ()
74- config_copy ['region' ] = region_mapping .get (excel_region , excel_region )
69+ config_obj = mysql_aas_client .get_configuration (mysql_db .configuration_id ).data
70+ except Exception as e2 :
71+ print (f"\n Warning2: Could not fetch configuration details for { mysql_db .display_name } : { str (e2 )} " )
72+ config_obj = None
7573
76- # Try with both client types
77- try :
78- mysql_client = oci .mysql .MysqlaasClient (config = config_copy , retry_strategy = oci .retry .DEFAULT_RETRY_STRATEGY , signer = vnc_client .base_client .signer )
79- config_obj = mysql_client .get_configuration (mysql_db .configuration_id ).data
80- except Exception as e1 :
81- try :
82- mysql_client = oci .mysql .MysqlaasClient (config = config_copy , retry_strategy = oci .retry .DEFAULT_RETRY_STRATEGY , signer = vnc_client .base_client .signer )
83- config_obj = mysql_client .get_configuration (mysql_db .configuration_id ).data
84- except Exception as e2 :
85- print (f"\n Warning2: Could not fetch configuration details for { mysql_db .display_name } : { str (e2 )} " )
86- config_obj = None
87-
88- if hasattr (config_obj , 'display_name' ):
89- config_name = config_obj .display_name
74+ if hasattr (config_obj , 'display_name' ):
75+ config_name = config_obj .display_name
9076
91- # Get configuration compartment name
92- for comp_name , comp_id in ct .ntk_compartment_ids .items ():
93- if comp_id == config_obj .compartment_id :
94- config_compartment_name = comp_name
95- break
77+ # Get configuration compartment name
78+ for comp_name , comp_id in ct .ntk_compartment_ids .items ():
79+ if comp_id == config_obj .compartment_id :
80+ config_compartment_name = comp_name
81+ break
9682
97- # Format configuration name similar to subnet_name
98- if config_compartment_name and config_name :
99- config_id = config_compartment_name + '@' + config_name
83+ # Format configuration name similar to subnet_name
84+ if config_compartment_name and config_name :
85+ config_id = config_compartment_name + '@' + config_name
10086
101- except Exception as e :
102- print (f"\n Warning1: Could not fetch configuration details for { mysql_db .display_name } : { str (e )} " )
10387
10488 # Check if resource exists in terraform state
10589 tf_resource = f'module.mysql_db_system[\\ "{ mysql_tf_name } \\ "].oci_mysql_mysql_db_system.db_system'
@@ -125,9 +109,6 @@ def print_mysql(region, vnc_client, mysql_db, values_for_column, ntk_compartment
125109 values_for_column [col_header ].append (config_name )
126110 else :
127111 values_for_column [col_header ].append ("" )
128- elif col_header == 'Hostname Label' :
129- hostname = mysql_db .hostname_label if mysql_db .hostname_label else mysql_db .display_name .lower ().replace ("-" , "" )
130- values_for_column [col_header ].append (hostname )
131112 elif col_header == 'Shape' :
132113 values_for_column [col_header ].append (mysql_db .shape_name )
133114 elif col_header == 'Network Details' :
@@ -244,14 +225,14 @@ def export_mysql_db(inputfile, outdir, service_dir, config, signer, ct, export_c
244225
245226 region = reg .capitalize ()
246227 vnc_client = oci .core .VirtualNetworkClient (config = config , retry_strategy = oci .retry .DEFAULT_RETRY_STRATEGY , signer = signer )
228+ mysql_client = oci .mysql .DbSystemClient (config = config , retry_strategy = oci .retry .DEFAULT_RETRY_STRATEGY , signer = signer )
229+ mysql_aas_client = oci .mysql .MysqlaasClient (config = config , retry_strategy = oci .retry .DEFAULT_RETRY_STRATEGY , signer = signer )
247230
248231 for ntk_compartment_name in export_compartments :
249- mysql_dbs = oci .pagination .list_call_get_all_results (oci .mysql .DbSystemClient (config = config , retry_strategy = oci .retry .DEFAULT_RETRY_STRATEGY , signer = signer ).list_db_systems ,
250- compartment_id = ct .ntk_compartment_ids [ntk_compartment_name ],
251- lifecycle_state = "ACTIVE" )
232+ mysql_dbs = oci .pagination .list_call_get_all_results (mysql_client .list_db_systems ,compartment_id = ct .ntk_compartment_ids [ntk_compartment_name ],lifecycle_state = "ACTIVE" )
252233 for mysql_db in mysql_dbs .data :
253234
254- mysql_db = oci . mysql . DbSystemClient ( config = config , retry_strategy = oci . retry . DEFAULT_RETRY_STRATEGY , signer = signer ) .get_db_system (mysql_db .id ).data
235+ mysql_db = mysql_client .get_db_system (mysql_db .id ).data
255236 # Tags filter
256237 defined_tags = mysql_db .defined_tags
257238 tags_list = []
@@ -268,7 +249,7 @@ def export_mysql_db(inputfile, outdir, service_dir, config, signer, ct, export_c
268249 if check == False :
269250 continue
270251
271- print_mysql (region , vnc_client , mysql_db , values_for_column , ntk_compartment_name , state , ct , df . iloc [ 0 ] )
252+ print_mysql (region , vnc_client , mysql_db , values_for_column , ntk_compartment_name , state , ct , mysql_aas_client )
272253
273254 commonTools .write_to_cd3 (values_for_column , cd3file , sheetName )
274255 print ("{0} MySQL Database Systems exported into CD3.\n " .format (len (values_for_column ["Region" ])))
0 commit comments