up

db-utils/db_gen_config.sh

@@ -43,6 +43,50 @@ cache_dir=/home/daily_db_backup
 # fi
 
 echo "prepare to get source_port"
+conf=(`curl -s http://192.168.4.3:10088/config_server/get_db_config/$database_name/all`)
+source_db_host=${conf[0]}
+port=${conf[1]}
+source_db_user=${conf[2]}
+source_db_pwd=${conf[3]}
+sys_table_list=${conf[@]:4}
+
+echo "source_port is $port"
+echo "copy ${base_config_file} to ${config_file_name}"
+cp -f $base_config_file $config_file_name
+
+echo "sed -i s/source_db_host/${source_db_host}/g $config_file_name"
+sed -i "s/source_db_host/${source_db_host}/g" $config_file_name
+sed -i "s/source_db_user/${source_db_user}/g" $config_file_name
+sed -i "s/source_db_pwd/${source_db_pwd}/g" $config_file_name
+sed -i "s/target_db_host/${target_db_host}/g" $config_file_name
+sed -i "s/target_db_user/${target_db_user}/g" $config_file_name
+sed -i "s/target_db_pwd/${target_db_pwd}/g" $config_file_name
+sed -i "s/target_db_port/${target_db_port}/g" $config_file_name
+sed -i "s/sync_db_name/${sync_db_name}/g" $config_file_name
+sed -i "s/source_port/${port}/g" $config_file_name
+
+#同步基础数据
+if [ $use_cache = true ];then
+	echo "\cp -rf $cache_dir/$database_name/. $db_backup_sub_folders/"
+	\cp -rf $cache_dir/$database_name/. $db_backup_sub_folders/
+else
+	if [ $database_name = 'quartz' ];then
+		for table_name in $sys_table_list
+		do
+			file_name=$db_backup_sub_folders/$table_name.sql
+			echo "mysqldump -u${source_db_user} -p${source_db_pwd} -h${source_db_host} -P${port} $database_name --tables $table_name --where \"1=1 order by id desc limit 1000\"> $file_name"
+			mysqldump -u${source_db_user} -p${source_db_pwd} -h${source_db_host} -P${port} $database_name --skip-lock-tables --tables $table_name --where "1=1 order by id desc limit 10000" --skip-add-locks --no-create-info --complete-insert > $file_name
+		done
+	else
+		for table_name in $sys_table_list
+		do
+			file_name=$db_backup_sub_folders/$table_name.sql
+			echo "mysqldump -u${source_db_user} -p${source_db_pwd} -h${source_db_host} -P${port} $database_name --tables $table_name > $file_name"
+			mysqldump -u${source_db_user} -p${source_db_pwd} -h${source_db_host} -P${port} $database_name --skip-lock-tables --tables $table_name --skip-add-locks --no-create-info --complete-insert > $file_name
+		done
+	fi
+fi
+
 # if [[ $database_name = 'xyqb' ]]; then
 # 	# 信用钱包database
 # 	sys_table_list='baitiao_merchant baitiao_secure_key channel funding_contract funding_corp loan_product merchant_channel payeco_return_url_info red_packet t_phonenum zmxy_return_url configuration secure_proxy funding_corp_config funding_info_map baitiao_preferential_rule funding_corp_policy'
@@ -181,47 +225,3 @@ echo "prepare to get source_port"
 # sys_table_list=`curl -s http://192.168.4.3:10088/config_server/get_db_config/$database_name/sys_table_list`
 # source_db_host=`curl -s http://192.168.4.3:10088/config_server/get_db_config/$database_name/host`
 # port=`curl -s http://192.168.4.3:10088/config_server/get_db_config/$database_name/port`
\ No newline at end of file
-
-conf=(`curl -s http://192.168.4.3:10088/config_server/get_db_config/$database_name/all`)
-source_db_host=${conf[0]}
-port=${conf[1]}
-source_db_user=${conf[2]}
-source_db_pwd=${conf[3]}
-sys_table_list=${conf[@]:4}
-
-echo "source_port is $port"
-echo "copy ${base_config_file} to ${config_file_name}"
-cp -f $base_config_file $config_file_name
-
-echo "sed -i s/source_db_host/${source_db_host}/g $config_file_name" 
-sed -i "s/source_db_host/${source_db_host}/g" $config_file_name
-sed -i "s/source_db_user/${source_db_user}/g" $config_file_name
-sed -i "s/source_db_pwd/${source_db_pwd}/g" $config_file_name
-sed -i "s/target_db_host/${target_db_host}/g" $config_file_name
-sed -i "s/target_db_user/${target_db_user}/g" $config_file_name
-sed -i "s/target_db_pwd/${target_db_pwd}/g" $config_file_name
-sed -i "s/target_db_port/${target_db_port}/g" $config_file_name
-sed -i "s/sync_db_name/${sync_db_name}/g" $config_file_name
-sed -i "s/source_port/${port}/g" $config_file_name
-
-#同步基础数据
-if [ $use_cache = true ];then
-	echo "\cp -rf $cache_dir/$database_name/. $db_backup_sub_folders/"
-	\cp -rf $cache_dir/$database_name/. $db_backup_sub_folders/
-else
-	if [ $database_name = 'quartz' ];then
-		for table_name in $sys_table_list
-		do
-			file_name=$db_backup_sub_folders/$table_name.sql
-			echo "mysqldump -u${source_db_user} -p${source_db_pwd} -h${source_db_host} -P${port} $database_name --tables $table_name --where \"1=1 order by id desc limit 1000\"> $file_name"
-			mysqldump -u${source_db_user} -p${source_db_pwd} -h${source_db_host} -P${port} $database_name --skip-lock-tables --tables $table_name --where "1=1 order by id desc limit 10000" --skip-add-locks --no-create-info --complete-insert > $file_name
-		done
-	else
-		for table_name in $sys_table_list
-		do
-			file_name=$db_backup_sub_folders/$table_name.sql
-			echo "mysqldump -u${source_db_user} -p${source_db_pwd} -h${source_db_host} -P${port} $database_name --tables $table_name > $file_name"
-			mysqldump -u${source_db_user} -p${source_db_pwd} -h${source_db_host} -P${port} $database_name --skip-lock-tables --tables $table_name --skip-add-locks --no-create-info --complete-insert > $file_name
-		done
-	fi
-fi

db-utils/db_schema_sync.sh

@@ -86,6 +86,7 @@ function db_schema_sync()
 	echo "delete_business_data : $delete_business_data"
 	echo "use_cache : $use_cache"
 
+	echo "sh $work_dir/db_gen_config.sh $source_db_host $source_db_user $source_db_pwd $target_db_host $target_db_user $target_db_pwd $database $config_file_name $db_backup_sub_folders $use_cache $target_db_port"
 	sh $work_dir/db_gen_config.sh $source_db_host $source_db_user $source_db_pwd $target_db_host $target_db_user $target_db_pwd $database $config_file_name $db_backup_sub_folders $use_cache $target_db_port
 	
 	cd $db_backup_sub_folders