AI 助理
备案控制台
开发者社区 数据库 文章 正文

【MySQL】 mysql 日常工单处理脚本 解放你的双手！！！

2024-08-20 39
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 RDS MySQL，集群系列 2核4GB
推荐场景：
搭建个人博客
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
RDS MySQL Serverless 高可用系列，价值2615元额度，1个月
简介： 【MySQL】 mysql 日常工单处理脚本 解放你的双手！！！

简介

在工作中经常帮助开发的小伙伴执行些 sql，手动执行效率低不直观，还要单独备份等等，极为麻烦，怎么办？用它！解放时间多摸鱼！！！我的摸鱼小帮手。

流程图：

功能：

  • 语法检查： 检查是否 符合脚本正则
  • 数据量检查：检查数据量大小，数据量大时可选择其他时间或工具执行，数据量小时可继续执行
  • 备份数据： alter 备份整个表，带 where 条件的备份符合 where 条件的数据。
  • 执行 SQL： 最后执行 SQL 语句
  • 语法支持类型：
  • delete
  • insert
  • update
  • create table
  • alter table
  • create index
  • drop index
  • backup table ：当需要备份某个表时，将需要备份的表名写入 1_sql_info.txt 表即可

需要安装 :

  • mysql 命令
  • mysqldump 命令

文件示例：

├── 1_sql_info.txt           # 1. 将需要执行的 SQL 粘贴到这个文件中。
├── 2_sql_bak_exec.sh        # 2. 执行这个 shell 脚本即可
├── dba
│   ├── bak
│   │   ├── test.table1_240117_144416.sql
│   │   ├── test.table2_240117_144416.sql

脚本内容

cat /root/2_sql_bak_exec.sh
#!/bin/bash
MySQL_user='root'
MySQL_host='127.0.0.1'
MySQL_password='123456'
MySQL_port=3306
MySQL_database='test'                      # 备份表所在库
MySQL_bak_dir='/root/dba/bak'              # 保存备份文件的地址
MySQL_SqlInfo_file='/root/1_sql_info.txt'  # 需要执行的 SQL 文件
#格式化后SQL保存文件
MySQL_Read_SqlFile='/root/.mysql_sql_tmp.txt'
# 获取时间
Date=$(date +%y%m%d_%H%M%S)
# 获取mysqldump命令路径
MysqlDump_Command=$(/usr/bin/which mysqldump)
# 获取mysql命令路径
Mysql_Command=$(/usr/bin/which mysql)
# 拼接MySQL连接参数
MySQL_Connection="${Mysql_Command} -u"${MySQL_user}" -p"${MySQL_password}" -h${MySQL_host} -P${MySQL_port}"
# 总行数大于这个值就进行提示
Rows_Sum=10
# 过滤语法##########################################################################################################################################
function Match_Regular() {
Delete_Line=$(echo ${line}|egrep -ci '^delete\s+from\s+(`)?(\w+)?(`)?(.)?(`)?\w+(`)?\s+where\s+.*;')
Create_index_Line=$(echo ${line}|egrep -ci '^CREATE\s+(UNIQUE|FULLTEXT|SPATIAL)?\s*INDEX\s+\w+\s+ON\s+(`)?(\w+)?(`)?(.)?(`)?\w+(`)?\s*\(\w+\)\s*;')
Drop_index_Line=$(echo ${line}|egrep -ci '^drop\s+INDEX\s+\w+\s+ON\s+(`)?(\w+)?(`)?(.)?(`)?\w+(`)?\s*;')
Insert_Line=$(echo ${line}|egrep -ci '^insert\s+into\s+(`)?(\w+)?(`)?(.)?(`)?\w+(`)?\s*(\(.*\))?\s+values\s*(.*)\s*;')
Create_table_Line=$(echo ${line}|egrep  -ic '^create\s+table\s+(\`)?(\w+)?(\`)?(.)?(\`)?\w+(\`)?\s*(.*).*;')
Alter_Line=$(echo ${line} | grep -iPc  '^alter\s+table\s+(`)?(\w+)?(`)?(.)?(`)?\w+(`)?\s+(ADD|MODIFY|DROP|RENAME|ENGINE|CHARSET|AUTO_INCREMENT|COMMENT)?.*;')
Update_Line=$(echo ${line}|egrep  -ic '^update\s+(`?[a-zA-Z0-9_]+`?\.)?(`?[a-zA-Z0-9_]+`?)\s+(join\s+(`?[a-zA-Z0-9_]+`?\.)?(`?[a-zA-Z0-9_]+`?)\s+on\s+.+\s+)?set\s+(.*)\s+where\s+(`)?\w+(`)?.*;')
Bak_table_Line=$(echo ${line}|egrep -ic '^(`)?[a-zA-Z0-9_]*(`)?$')
}
Bak_table_Line_Format=$(egrep -v '^$|^#|^\s+#' ${MySQL_SqlInfo_file}|egrep -ic '^(`)?[a-zA-Z0-9_]*(`)?$')
# 2、检查语法
function Check_Syntax() {
while read line
do
# 调用正则配置语法
Match_Regular
  if [[  ${Insert_Line} != 1  &&  ${Delete_Line} != 1 && ${Update_Line} != 1 && ${Alter_Line} != 1  && ${Create_index_Line} != 1 && ${Drop_index_Line} != 1   && ${Create_table_Line} != 1   && ${Bak_table_Line_Format} = 0 ]];then
        echo "${MySQL_SqlInfo_file} 文件如下内容,格式错误:"
        echo ' '
        echo "${line}"|fmt
        exit 1
  fi
done < ${MySQL_Read_SqlFile}
}
# 检查库表行数 
function Check_database_table_rows() {
while read  -u 3 line
do
# 调用正则配置语法
Match_Regular
# delete 语句####################################################################################################################################
    if [[ ${Delete_Line} -eq 1 ]];then
        # 获取where条件
        Where_Info=$(echo "${line}"|sed -n 's/^delete\s\+from\s\+\([`a-zA-Z0-9_.]*\)\s\+WHERE\s\+\(.*\);/\2/Ip')
        # 获取表名
        MySQL_TableName=$(echo "${line}"|sed -n 's/^delete\s\+from\s\+\([`a-zA-Z0-9_.]*\)\s\+WHERE\s\+\(.*\);/\1/Ip'|sed  's#`##g'|awk -F'.' '{print $NF}')
        # 获取库表是否存在
        ${MySQL_Connection} -N -e "desc ${MySQL_database}.${MySQL_TableName}" &>/dev/null
            if [[ $? -ne 0 ]];then
                echo "${MySQL_database}.${MySQL_TableName} 库表不存在或mysql无法连接"
                exit 1
            fi
        # 获取备份的行数
        Sql_Count=$(${MySQL_Connection} -N  -e "select count(1) from ${MySQL_database}.${MySQL_TableName} where ${Where_Info}" 2>/dev/null)
            if [[ ${Sql_Count} -ge ${Rows_Sum} ]];then
                echo "${MySQL_TableName} 表备份的数据量为${Sql_Count}"
                read -t 20  -e -p "是否继续(y/n)" Answer
                case $Answer in
                Y | y)
                    echo "确认继续"
                    ;;
                N | n)
                    echo "确认退出"
                    exit 1
                    ;;
                *)
                    echo "输入有误"
                    exit 1
                    ;;
                esac
            fi
# update 语句####################################################################################################################################
    elif [[ ${Update_Line} -eq 1 ]];then
        # 获取where条件
        Where_Info=$(echo "${line}"|sed -E -n 's/^update\s+(`?[a-zA-Z0-9_]+`?\.)?(`?[a-zA-Z0-9_]+`?)\s+(join\s+(`?[a-zA-Z0-9_]+`?\.)?(`?[a-zA-Z0-9_]+`?)\s+on\s+.+\s+)?set\s+(.*)\s+where\s+(.*);/\7/Ip')
        # 获取表名
        MySQL_TableName=$(echo "${line}"|sed -E -n 's/^update\s+(`?[a-zA-Z0-9_]+`?\.)?(`?[a-zA-Z0-9_]+`?)\s+(join\s+(`?[a-zA-Z0-9_]+`?\.)?(`?[a-zA-Z0-9_]+`?)\s+on\s+.+\s+)?set\s+(.*)\s+where\s+(.*);/\2/Ip'|sed 's/`//g')
        # 获取库表是否存在
        ${MySQL_Connection} -N -e "desc ${MySQL_database}.${MySQL_TableName}" &>/dev/null
            if [[ $? -ne 0 ]];then
                echo "${MySQL_database}.${MySQL_TableName} 库表不存在或mysql无法连接"
                exit 1
            fi
        # 获取备份的行数
        Sql_Count=$(${MySQL_Connection} -N  -e "select count(1) from ${MySQL_database}.${MySQL_TableName} where ${Where_Info}" 2>/dev/null)
            if [[ ${Sql_Count} -ge ${Rows_Sum} ]];then
                echo "${MySQL_TableName} 表备份的数据量为${Sql_Count}"
                read -t 20  -e -p "是否继续(y/n)" Answer
                case $Answer in
                Y | y)
                    echo "确认继续"
                    ;;
                N | n)
                    echo "确认退出"
                    exit 1
                    ;;
                *)
                    echo "输入有误"
                    exit 1
                    ;;
                esac
            fi
            
# insert 语句####################################################################################################################################
    elif [[ ${Insert_Line} -eq 1 ]];then
        MySQL_TableName=$(echo "${line}"|egrep -i 'INSERT\s+INTO\s+.*\s+VALUES.*;'|sed -n 's/insert\s\+into\s\+\([^ ]*\).*values\s*(.*)\s*;/\1/Ip'|awk -F'(' '{print $1}'|awk -F'.' '{print $NF}'|sed  's#`##g')
        # 获取库表是否存在
        ${MySQL_Connection} -N -e "desc ${MySQL_database}.${MySQL_TableName}" &>/dev/null
            if [[ $? -ne 0 ]];then
                echo "${MySQL_database}.${MySQL_TableName} 库表不存在或mysql无法连接"
                exit 1
            fi
# alter 语句####################################################################################################################################
    # 提取DML语句表名
    elif [[ ${Alter_Line} -eq 1 ]];then
        MySQL_TableName=$(echo "${line}"|sed -En 's/^alter\s+table\s+(`?[a-zA-Z0-9_]+`?\.)?(`?[a-zA-Z0-9_]+`?)\s+(ADD|MODIFY|DROP|RENAME|ENGINE|CHARSET|AUTO_INCREMENT|COMMENT)?.*;/\2/Ip'|sed 's/`//g')
        # 获取库表是否存在
        ${MySQL_Connection} -N -e "desc ${MySQL_database}.${MySQL_TableName}" &>/dev/null
            if [[ $? -ne 0 ]];then
                echo "${MySQL_database}.${MySQL_TableName} 库表不存在或mysql无法连接"
                exit 1
            fi
        # 获取表的行数
        Sql_Count=$(${MySQL_Connection} -N  -e "select count(1) from ${MySQL_database}.${MySQL_TableName}" 2>/dev/null)
            if [[ ${Sql_Count} -ge ${Rows_Sum} ]];then
                echo "${MySQL_TableName} 表备份的数据量为${Sql_Count}"
                read -t 20  -e -p "是否继续(y/n)" Answer
                case $Answer in
                Y | y)
                    echo "确认继续"
                    ;;
                N | n)
                    echo "确认退出"
                    exit 1
                    ;;
                *)
                    echo "输入有误"
                    exit 1
                    ;;
                esac
            fi
# create index语句支持#############################################################################################################################
    # 提取create index 语句表名
    elif [[ ${Create_index_Line} -eq 1 ]];then
        MySQL_TableName=$(echo "${line}"|egrep -i 'CREATE\s+(UNIQUE|FULLTEXT|SPATIAL)?\s*INDEX\s+.*\s+ON*\(*\)*'|sed -n "s/create\s\+.*\s*index\s\+.*\s\+ON\s\+\([^ ]*\)\s*(.*).*/\1/Ip"|awk -F. '{print $NF}'|sed 's/`//g')
        MySQL_TableIndex=$(echo "${line}"|egrep -i 'CREATE\s+(UNIQUE|FULLTEXT|SPATIAL)?\s*INDEX\s+.*\s+ON*\(*\)*'|sed -n "s/create\s\+.*\s*index\s\+\([^ ]*\)\s\+ON\s\+\([^ ]*\)\s*(.*).*/\1/Ip"|sed 's/`//g')
        # 获取库表是否存在
        ${MySQL_Connection} -N -e "desc ${MySQL_database}.${MySQL_TableName}" &>/dev/null
            if [[ $? -ne 0 ]];then
                echo "${MySQL_database}.${MySQL_TableName} 库表不存在或mysql无法连接"
                exit 1
            fi
        # 检查索引是否存在
        Index_exists=$(${MySQL_Connection} -N -e "use ${MySQL_database};show index from ${MySQL_database}.${MySQL_TableName} where key_name=\"${MySQL_TableIndex}\";" 2>/dev/null | grep -ci  "${MySQL_TableIndex}")
            if [[ Index_exists -ne 0 ]];then
                echo "${MySQL_database}.${MySQL_TableName} 表的${MySQL_TableIndex} 索引已存在"
                exit 1
            fi
        # 获取表的行数
        Sql_Count=$(${MySQL_Connection} -N  -e "select count(1) from ${MySQL_database}.${MySQL_TableName}" 2>/dev/null)
            if [[ ${Sql_Count} -ge ${Rows_Sum} ]];then
                echo "${MySQL_TableName} 表备份的数据量为${Sql_Count}"
                read -t 20  -e -p "是否继续(y/n)" Answer
                case $Answer in
                Y | y)
                    echo "确认继续"
                    ;;
                N | n)
                    echo "确认退出"
                    exit 1
                    ;;
                *)
                    echo "输入有误"
                    exit 1
                    ;;
                esac
            fi
# drop index  语句支持#############################################################################################################################
    # 提取drop index 语句表名
    elif [[ ${Drop_index_Line} -eq 1 ]];then
        MySQL_TableName=$(echo "${line}"|egrep -i '^drop\s+INDEX\s+\w+\s+ON\s+(`)?(\w+)?(`)?(.)?(`)?\w+(`)?\s*;'|sed -En 's/^drop\s+index\s+\w+\s+ON\s+(`?[a-zA-Z0-9_]+`?\.)?(`?[a-zA-Z0-9_]+`?).*;/\2/Ip'|sed 's/`//g')
        MySQL_TableIndex=$(echo "${line}"|egrep -i '^drop\s+INDEX\s+(`?[a-zA-Z0-9_]+`?)\s+ON\s+(`)?(\w+)?(`)?(.)?(`)?\w+(`)?\s*;'|sed -En 's/^drop\s+index\s+`?(\w+)`?\s+ON\s+(`)?(\w+)?(`)?(.)?(`)?\w+(`)?\s*;/\1/Ip')
        # 获取库表是否存在
        ${MySQL_Connection} -N -e "desc ${MySQL_database}.${MySQL_TableName}" &>/dev/null
            if [[ $? -ne 0 ]];then
                echo "${MySQL_database}.${MySQL_TableName} 库表不存在或mysql无法连接"
                exit 1
            fi
        # 检查索引是否存在
        Index_exists=$(${MySQL_Connection} -N -e "use ${MySQL_database};show index from ${MySQL_database}.${MySQL_TableName} where key_name=\"${MySQL_TableIndex}\";" 2>/dev/null | grep -ci  "${MySQL_TableIndex}")
            if [[ Index_exists -ne 1 ]];then
                echo "${MySQL_database}.${MySQL_TableName} 表的${MySQL_TableIndex} 索引不存在"
                exit 1
            fi
        # 获取表的行数
        Sql_Count=$(${MySQL_Connection} -N  -e "select count(1) from ${MySQL_database}.${MySQL_TableName}" 2>/dev/null)
            if [[ ${Sql_Count} -ge ${Rows_Sum} ]];then
                echo "${MySQL_TableName} 表备份的数据量为${Sql_Count}"
                read -t 20  -e -p "是否继续(y/n)" Answer
                case $Answer in
                Y | y)
                    echo "确认继续"
                    ;;
                N | n)
                    echo "确认退出"
                    exit 1
                    ;;
                *)
                    echo "输入有误"
                    exit 1
                    ;;
                esac
            fi
# Create  table 语句支持###########################################################################################################################
    elif [[ ${Create_table_Line} -eq 1 ]];then
        MySQL_TableName=$(echo "${line}"|sed -n  's/create\s\+table\s\+\([^ ]*\)\s*(.*).*;/\1/Ip'|sed  's#`##g'|awk -F'.' '{print $NF}')
        # 获取库表是否存在
        ${MySQL_Connection} -N -e "desc ${MySQL_database}.${MySQL_TableName}" &>/dev/null
            if [[ $? -eq 0 ]];then
                echo "${MySQL_database}.${MySQL_TableName} 库表已存在"
                exit 1
            fi
    else
        continue
    fi
done 3< ${MySQL_Read_SqlFile}
echo 'SQL语法检查完成'
}
# 4、执行备份
function Execute_backup() {
while read line
do
# 调用正则配置语法
Match_Regular
# delete 语句#####################################################################################################################################
    if [[ ${Delete_Line} -eq 1 ]];then
        # 获取where条件
        Where_Info=$(echo "${line}"|sed -n 's/^delete\s\+from\s\+\([`a-zA-Z0-9_.]*\)\s\+WHERE\s\+\(.*\);/\2/Ip')
        # 获取表名
        MySQL_TableName=$(echo "${line}"|sed -n 's/^delete\s\+from\s\+\([`a-zA-Z0-9_.]*\)\s\+WHERE\s\+\(.*\);/\1/Ip'|sed  's#`##g'|awk -F'.' '{print $NF}')
    # 带where条件备份
    ${MysqlDump_Command} -u${MySQL_user} -p${MySQL_password} -h${MySQL_host} -P${MySQL_port}  --no-create-info --single-transaction   --skip-extended-insert    --where="${Where_Info}" ${MySQL_database} ${MySQL_TableName} 2>/dev/null  >> ${MySQL_bak_dir}/${MySQL_database}.${MySQL_TableName}_${Date}.sql
        # 判断是否备份成功
        if [[ ${PIPESTATUS[0]} -eq 0 && ${PIPESTATUS[1]} -eq 0 ]];then
                echo "${MySQL_TableName} 表备份完成"
        else
                echo "${MySQL_TableName} 表备份失败"
                exit 1
        fi
# update 语句#####################################################################################################################################
    elif [[ ${Update_Line} -eq 1 ]];then
        # 获取where条件
        Where_Info=$(echo "${line}"|sed -E -n 's/^update\s+(`?[a-zA-Z0-9_]+`?\.)?(`?[a-zA-Z0-9_]+`?)\s+(join\s+(`?[a-zA-Z0-9_]+`?\.)?(`?[a-zA-Z0-9_]+`?)\s+on\s+.+\s+)?set\s+(.*)\s+where\s+(.*);/\7/Ip')
        # 获取表名
        MySQL_TableName=$(echo "${line}"|sed -E -n 's/^update\s+(`?[a-zA-Z0-9_]+`?\.)?(`?[a-zA-Z0-9_]+`?)\s+(join\s+(`?[a-zA-Z0-9_]+`?\.)?(`?[a-zA-Z0-9_]+`?)\s+on\s+.+\s+)?set\s+(.*)\s+where\s+(.*);/\2/Ip'|sed 's/`//g')
    # 带where条件备份
    ${MysqlDump_Command} -u${MySQL_user} -p${MySQL_password} -h${MySQL_host} -P${MySQL_port}  --no-create-info --single-transaction   --skip-extended-insert    --where="${Where_Info}" ${MySQL_database} ${MySQL_TableName} 2>/dev/null  >> ${MySQL_bak_dir}/${MySQL_database}.${MySQL_TableName}_${Date}.sql
        # 判断是否备份成功
        if [[ ${PIPESTATUS[0]} -eq 0 && ${PIPESTATUS[1]} -eq 0 ]];then
                echo "${MySQL_TableName} ���备份完成"
        else
                echo "${MySQL_TableName} 表备份失败"
                exit 1
        fi
# alter 语句######################################################################################################################################
    # 提取DML语句表名
    elif [[ ${Alter_Line} -eq 1 ]];then
        MySQL_TableName=$(echo "${line}"|sed -En 's/^alter\s+table\s+(`?[a-zA-Z0-9_]+`?\.)?(`?[a-zA-Z0-9_]+`?)\s+(ADD|MODIFY|DROP|RENAME|ENGINE|CHARSET|AUTO_INCREMENT|COMMENT)?.*;/\2/Ip'|sed 's/`//g')
    # 备份表
    ${MysqlDump_Command} -u${MySQL_user} -p${MySQL_password} -h${MySQL_host} -P${MySQL_port}   --single-transaction   --skip-extended-insert     ${MySQL_database} ${MySQL_TableName} 2>/dev/null  >> ${MySQL_bak_dir}/${MySQL_database}.${MySQL_TableName}_${Date}.sql
        # 判断是否备份成功
        if [[ ${PIPESTATUS[0]} -eq 0 && ${PIPESTATUS[1]} -eq 0 ]];then
                echo "${MySQL_TableName} 表备份完成"
        else
                echo "${MySQL_TableName} 表备份失败"
                exit 1
        fi
# create index 语句支持############################################################################################################################
    # 提取DML语句表名
    elif [[ ${Create_index_Line} -eq 1 ]];then
         MySQL_TableName=$(echo "${line}"|egrep -i 'CREATE\s+(UNIQUE|FULLTEXT|SPATIAL)?\s*INDEX\s+.*\s+ON*\(*\)*'|sed -n "s/create\s\+.*\s*index\s\+.*\s\+ON\s\+\([^ ]*\)\s*(.*).*/\1/Ip"|awk -F. '{print $NF}'|sed 's/`//g')
    # 备份表
    ${MysqlDump_Command} -u${MySQL_user} -p${MySQL_password} -h${MySQL_host} -P${MySQL_port}   --single-transaction   --skip-extended-insert     ${MySQL_database} ${MySQL_TableName} 2>/dev/null  >> ${MySQL_bak_dir}/${MySQL_database}.${MySQL_TableName}_${Date}.sql
        # 判断是否备份成功
        if [[ ${PIPESTATUS[0]} -eq 0 && ${PIPESTATUS[1]} -eq 0 ]];then
                echo "${MySQL_TableName} 表备份完成"
        else
                echo "${MySQL_TableName} 表备份失败"
                exit 1
        fi
# drop index 语句支持#############################################################################################################################
    # 提取DML语句表名
    elif [[ ${Drop_index_Line} -eq 1 ]];then
        MySQL_TableName=$(echo "${line}"|egrep -i '^drop\s+INDEX\s+\w+\s+ON\s+(`)?(\w+)?(`)?(.)?(`)?\w+(`)?\s*;'|sed -En 's/^drop\s+index\s+\w+\s+ON\s+(`?[a-zA-Z0-9_]+`?\.)?(`?[a-zA-Z0-9_]+`?).*;/\2/Ip'|sed 's/`//g')
    # 备份表
    ${MysqlDump_Command} -u${MySQL_user} -p${MySQL_password} -h${MySQL_host} -P${MySQL_port}   --single-transaction   --skip-extended-insert     ${MySQL_database} ${MySQL_TableName} 2>/dev/null  >> ${MySQL_bak_dir}/${MySQL_database}.${MySQL_TableName}_${Date}.sql
        # 判断是否备份成功
        if [[ ${PIPESTATUS[0]} -eq 0 && ${PIPESTATUS[1]} -eq 0 ]];then
                echo "${MySQL_TableName} 表备份完成"
        else
                echo "${MySQL_TableName} 表备份失败"
                exit 1
        fi
# insert 语句支持#################################################################################################################################
    elif [[ ${Insert_Line} -eq 1 ]];then
        MySQL_TableName=$(echo "${line}"|egrep -i 'INSERT\s+INTO\s+.*\s+VALUES.*;'|sed -n 's/insert\s\+into\s\+\([^ ]*\).*values\s*(.*)\s*;/\1/Ip'|awk -F'(' '{print $1}'|awk -F'.' '{print $NF}'|sed  's#`##g')
        echo "${MySQL_TableName} 表为insert语句跳过备份"
        continue
# Create table 语句支持###########################################################################################################################
    elif [[ ${Create_table_Line} -eq 1 ]];then
        MySQL_TableName=$(echo "${line}"|sed -nE  's/create\s+table\s+(`?[a-zA-Z0-9_]+`?\.)?(`?[a-zA-Z0-9_]+`?)\s*(.*).*;/\2/Ip'|sed 's/`//g')
        echo "${MySQL_TableName} 表为create table语句跳过备份"
        continue
# backup table 支持##############################################################################################################################
    elif [[ ${Bak_table_Line} -eq 1 ]];then
        MySQL_TableName=$(echo "${line}"|egrep -i '^(`)?[a-zA-Z0-9_]*(`)?$'|sed 's/`//g')
    # 备份表
    ${MysqlDump_Command} -u${MySQL_user} -p${MySQL_password} -h${MySQL_host} -P${MySQL_port}   --single-transaction   --skip-extended-insert    ${MySQL_database} ${MySQL_TableName} 2>/dev/null  >> ${MySQL_bak_dir}/${MySQL_database}.${MySQL_TableName}_${Date}.sql
        # 判断是否备份成功
        if [[ ${PIPESTATUS[0]} -eq 0 && ${PIPESTATUS[1]} -eq 0 ]];then
                echo "${MySQL_TableName} 表备份完成"
        else
                echo "${MySQL_TableName} 表备份失败"
                exit 1
        fi
    fi
done < ${MySQL_Read_SqlFile}
}
# 5、执行SQL
function Execute_SQL() {
while read line
do
    if [[ ${Bak_table_Line_Format} -ne 0 ]];then
        continue
    else
    ${MySQL_Connection} -N -vv  -e "use ${MySQL_database};${line}" |fmt
        if [[ ${PIPESTATUS[0]} -ne 0 || ${PIPESTATUS[1]} -ne 0 ]];then
            echo "${line} SQL执行失败"
        fi
    fi
done < ${MySQL_Read_SqlFile}
}
# 将多行的SQL转化为一行
# 去除文件中的空行和注释行
function Format_SQL() {
if [[ ${Bak_table_Line_Format} -eq 0 ]];then
    cat ${MySQL_SqlInfo_file}|egrep -v '^$|^#|^\s+#'  |awk -F ';'  BEGIN{RS=EOF}'{gsub(/\n/," ");print}' |awk 'BEGIN{i=1}{gsub(/;/,";""\n");i++;print}'|sed 's/^[[:space:]]*//'|grep -v '^$' >${MySQL_Read_SqlFile}
else
    cat ${MySQL_SqlInfo_file}|egrep -v '^$|^#|^\s+#'|sed -n 's/\s*\([a-zA-Z0-9_]*\)\s*/\1/Ip'|sed 's/`//g' >${MySQL_Read_SqlFile}
fi
}
# 1、格式化SQL
Format_SQL
# 2、检查语法
Check_Syntax
# 3、检查库表行数
Check_database_table_rows
# 4、执行备份
Execute_backup
# 5、执行SQL
Execute_SQL

执行脚本

# 创建备份保存目录
mkdir -p /root/dba/bak
# 粘贴过来需要执行的 SQL
vim /root/1_sql_info.txt  
delete from t1 where id = 12;
delete from t1 where id = 13;
delete from t1 where id in (1,2,3);
update t2 set name='tom' where id=9;
alter table t3 add index idx_name_age(name,age);
create index idx_name_age on t4 (name,age);
# 执行脚本
sh -x /root/2_sql_bak_exec.sh

本内容仅供参考，如需在生产环境使用，请自行验证。


文章标签：
云数据库 RDS MySQL 版
客服工作台
关系型数据库
MySQL
SQL
关键词：
云数据库 RDS MySQL 版脚本
客服工作台脚本
云数据库 RDS MySQL 版解放
相关实践学习
如何在云端创建MySQL数据库
开始实验后，系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
hh真是个慢性子
目录
相关文章
hh真是个慢性子
|
3月前
|
SQL 监控 关系型数据库
MySQL优化: CPU高 处理脚本 pt-kill脚本
MySQL优化: CPU高 处理脚本 pt-kill脚本
hh真是个慢性子
96 0
愿天堂没有BUG（公众号同名）
|
5月前
|
关系型数据库 MySQL 数据库
数据迁移脚本优化过程：从 MySQL 到 Django 模型表
在大规模的数据迁移过程中，性能问题往往是开发者面临的主要挑战之一。本文将分析一个数据迁移脚本的优化过程，展示如何从 MySQL 数据库迁移数据到 Django 模型表，并探讨优化前后的性能差异。
愿天堂没有BUG（公众号同名）
82 1
nanshaws
|
1月前
|
SQL 关系型数据库 MySQL
数据库是mysql，使用DBeaver的SQL编辑器执行sql脚本文件时，报错：No active connection 。
遇到这种问题，多半是因为没有与数据库关联
nanshaws
95 1
数据库是mysql，使用DBeaver的SQL编辑器执行sql脚本文件时，报错：No active connection 。
刘大猫.
|
19天前
|
SQL 关系型数据库 MySQL
mysql编写sql脚本：要求表没有主键，但是想查询没有相同值的时候才进行插入
mysql编写sql脚本：要求表没有主键，但是想查询没有相同值的时候才进行插入
刘大猫.
30 0
蓝易云
|
2月前
|
SQL 关系型数据库 MySQL
MySQL数据库中给表添加字段并设置备注的脚本编写
通过上述步骤，你可以在MySQL数据库中给表成功添加新字段并为其设置备注。这样的操作对于保持数据库结构的清晰和最新非常重要，同时也帮助团队成员理解数据模型的变化和字段的具体含义。在实际操作中，记得调整脚本以适应具体的数据库和表名称，以及字段的详细规范。
蓝易云
59 8
pbeskoyq7ffm4
|
3月前
|
存储 关系型数据库 MySQL
实战！MySQL主从复制一键搭建脚本分享
实战！MySQL主从复制一键搭建脚本分享
pbeskoyq7ffm4
68 2
pbeskoyq7ffm4
|
3月前
|
关系型数据库 MySQL Shell
MySQL数据库一键安装脚本，适合任何版本
MySQL数据库一键安装脚本，适合任何版本
pbeskoyq7ffm4
82 2
pbeskoyq7ffm4
|
3月前
|
关系型数据库 MySQL 网络安全
全网首例！MySQL8 MGR多主一键搭建脚本分享
全网首例！MySQL8 MGR多主一键搭建脚本分享
pbeskoyq7ffm4
62 1
hh真是个慢性子
|
3月前
|
关系型数据库 MySQL Shell
MySQL回滚脚本: 误操作delete binlog回滚shell脚本
MySQL回滚脚本: 误操作delete binlog回滚shell脚本
hh真是个慢性子
38 1
pbeskoyq7ffm4
|
3月前
|
缓存 关系型数据库 MySQL
分享一个实用的MySQL一键巡检脚本
分享一个实用的MySQL一键巡检脚本
pbeskoyq7ffm4
57 0

热门文章

最新文章

  • 1
    测试开启MySQL performance_schema后对性能的影响
  • 2
    RDS入门——Excel文件转存到RDS数据库实践
  • 3
    MySql解决mysql没有root用户问题
  • 4
    Linux操作系统上的mysql安装
  • 5
    MySQl复制---基于行的复制
  • 6
    mysql查询拼接
  • 7
    PostgreSQL 12 preview - CTE 增强，支持用户语法层控制 materialized 优化
  • 8
    icinga2 check_mysql_health插件
  • 9
    mysql常用操作
  • 10
    Mariadb/Mysql TEMPORARY表
  • 1
    希望阿里的小伙伴在控制台的易用性多上点心，每次问客服好像都是外包人员，啥也不会
    144
  • 2
    解码客服工单系统：选型指南让您信手拈来
    195
  • 3
    开源即时通讯IM框架 MobileIMSDK v6.5 发布
    141
  • 4
    即时通讯技术文集（第37期）：IM代码入门实践(Part1) [共16篇]
    65
  • 5
    智能客服助手自动化
    66
  • 6
    自动化客服响应与知识库查询
    78
  • 7
    稳扎稳打 部署丝滑 开源即时通讯（IM）项目OpenIM源码部署流程（linux windows mac）稳扎稳打 部署丝滑 开源即时通讯（IM）项目OpenIM源码部署流程（linux windows mac）
    377
  • 8
    数据管理DMS产品使用合集之要在DMS中实现数据库工单发布时必须经过人工审核才能进入下一步，我该怎么配置
    87
  • 9
    总结反思 持续进步-开源即时通讯（IM）项目OpenIM 新版本release-v3.7发布
    142
  • 10
    电话客服热线系统的详细搭建方案（十大关键要素）
    761

    • 相关课程

    更多
  • MySQL企业常见架构与调优经验分享
  • 云数据库MySQL版快速上手教程
  • 阿里云云原生数据仓库AnalyticDB MySQL版 使用教程
  • MySQL实战进阶
  • 数据库及SQL/MySQL基础
  • 云数据库MySQL快速入门

    • 相关电子书

    更多
  • One Box： 解读事务与分析一体化数据库 HybridDB for MySQL
  • One Box：解读事务与分析一体化数据库HybridDB for MySQL
  • 如何支撑HTAP场景-HybridDB for MySQL系统架构和技术演进

    • 相关实验场景

    更多
  • MySQL引擎及架构优化
  • 基于EBS部署高性能的MySQL服务
  • AnalyticDB MySQL游戏行业数据分析实践
  • 5分钟上手Flink MySQL连接器
  • 云端MySQL的安装及应用
  • 手动部署MySQL数据库（CentOS 7）

    • 推荐镜像

    更多
  • mysql
  • mariadb
  • postgresql
    • 下一篇
    阿里云OSS设置跨域访问