Python项目中对MySQL数据库重命名的方法有哪些

Admin 2022-07-01 群英技术资讯 364 次浏览

今天这篇我们来学习和了解“Python项目中对MySQL数据库重命名的方法有哪些”,下文的讲解详细,步骤过程清晰,对大家进一步学习和理解“Python项目中对MySQL数据库重命名的方法有哪些”有一定的帮助。有这方面学习需要的朋友就继续往下看吧!


目录
  • 常规思路
  • 更快捷的方法
    • 使用方法

对数据库的表进行重命名可以使用以下原生sql:

RENAME TABLE old_table TO new_table;  

窘境:但是MySQL并没有直接支持对数据库进行重命名

那么如何运用Python快速的对现有的数据库进行重命名呢?

比如项目初期,对数据库的命名(db_ridingroad)没有规划好,
然后在下面创建了大量的表和写入了大量的数据,现在需要对数据库的名字进行重命名为(db_news_website)

常规思路

下面的方法步骤较为繁琐

-- 数据库备份
mysqldump �Cu [UserName] �Cp[Password] �CR [DB_Name] > [DB_Name].sql
-- 创建新数据库
create database [New_DB_Name];
-- 把备份的数据导入到新数据库
mysql �Cu [UserName] �Cp[Password] [New_DB_Name] < [DB_Name].sql
-- 删除旧数据库
drop database [DB_Name];

更快捷的方法

只需要执行下面这条命令即可

python rename_database.py old_db_name new_db_name

我们可以使用表重命名的方法,把表重命名到新的数据库之下。基本逻辑如下:

  1. 创建新数据库
  2. 获取旧数据库下所有的表名
  3. 把表重命名到新的数据库名下
  4. 删除旧数据库

下面使用Python代码去实现,主要代码(完整代码见文末):

def rename_db(old_name, new_name):
    """
    数据库重命名
    :param old_name: 原来的数据库名
    :param new_name: 新数据库名
    :return: 成功返回True, 失败返回False
    """
    # 获取所有的表名
    sql = """SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES WHERE table_schema=%s"""
    conn, cursor = context()
    try:
        # 创建新数据库名
        cursor.execute('create database if not exists {}'.format(new_name))

        cursor.execute(sql, (old_name, ))
        results = cursor.fetchall()
        # 获取表明,循环处理放到新的数据库名下
        for r in results:
            tb = r['TABLE_NAME']
            rename_sql = """RENAME TABLE {}.{} to {}.{}""".format(old_name, tb, new_name, tb)
            cursor.execute(rename_sql)
        # 把旧数据库删掉
        cursor.execute('drop database {}'.format(old_name))
    except Exception as ex:
        conn.rollback()
        print("rename_db Exception: {},{}".format(sql, ex))
        return False
    else:
        # 如果没有发生异常,则提交事务
        conn.commit()
    finally:
        conn.close()
    return True

使用方法

1.安装PyMySQL

pip install PyMySQL

2.修改脚本中关于数据库账号配置信息部分

MYSQL_HOST = '127.0.0.1'
MYSQL_PORT = 3306
MYSQL_USER = 'ridingroad'
MYSQL_PASSWORD = 'xxxxyyyy'
MYSQL_DATABASE = 'db_ridingroad'

3.切换到脚本所在目录,执行以下命令即可(数据无价,请先mysqldump备份)

python rename_database.py old_db_name new_db_name

完整代码如下:

import sys
import pymysql


MYSQL_HOST = '127.0.0.1'
MYSQL_PORT = 3306
MYSQL_USER = 'ridingroad'
MYSQL_PASSWORD = 'xxxxyyyy'
MYSQL_DATABASE = 'db_ridingroad'
MYSQL_CHARSET = 'utf8'


def context(is_dict_cursor=True, database=MYSQL_DATABASE):
    """
    创建数据库连接, 数据以字典结构返回
    :param is_dict_cursor: 是否返回字典结构的数据
    :param database: 默认连接的数据库
    :return: 返回一个连接和一个浮标
    """
    try:
        config = {
            'host': MYSQL_HOST,
            'port': MYSQL_PORT,
            'user': MYSQL_USER,
            'password': MYSQL_PASSWORD,
            'database': database,
            'charset': MYSQL_CHARSET,
        }

        conn = pymysql.connect(**config)
        if is_dict_cursor:
            cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
        else:
            cursor = conn.cursor()
        return conn, cursor
    except Exception as ex:
        print("connect database failed, {},{}".format(400, ex))
        raise Exception({'code': 400, 'msg': ex})


def rename_db(old_name, new_name):
    """
    数据库重命名
    :param old_name: 原来的数据库名
    :param new_name: 新数据库名
    :return: 成功返回True, 失败返回False
    """
    # 获取所有的表名
    sql = """SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES WHERE table_schema=%s"""
    conn, cursor = context()
    try:
        conn.begin()
        # 创建新数据库名
        cursor.execute('create database if not exists {}'.format(new_name))

        cursor.execute(sql, (old_name, ))
        results = cursor.fetchall()
        # 获取表明,循环处理放到新的数据库名下
        for r in results:
            tb = r['TABLE_NAME']
            rename_sql = """RENAME TABLE {}.{} to {}.{}""".format(old_name, tb, new_name, tb)
            cursor.execute(rename_sql)
        # 把旧数据库删掉
        cursor.execute('drop database {}'.format(old_name))
    except Exception as ex:
        conn.rollback()
        print("rename_db Exception: {},{}".format(sql, ex))
        return False
    else:
        # 如果没有发生异常,则提交事务
        conn.commit()
    finally:
        conn.close()
    return True


if __name__ == '__main__':
    old_db = sys.argv[1]
    new_db = sys.argv[2]
    rename_db(old_name=old_db, new_name=new_db)

以上就是关于“Python项目中对MySQL数据库重命名的方法有哪些”的相关知识,感谢各位的阅读,想要掌握这篇文章的知识点还需要大家自己动手实践使用过才能领会,如果想了解更多相关内容的文章,欢迎关注群英网络,小编每天都会为大家更新不同的知识。
群英智防CDN,智能加速解决方案

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:mmqy2019@163.com进行举报,并提供相关证据,查实之后,将立刻删除涉嫌侵权内容。

猜你喜欢

成为群英会员,开启智能安全云计算之旅

立即注册
专业资深工程师驻守
7X24小时快速响应
一站式无忧技术支持
免费备案服务
免费拨打  400-678-4567
免费拨打  400-678-4567 免费拨打 400-678-4567 或 0668-2555555
在线客服
微信公众号
返回顶部
返回顶部 返回顶部
在线客服
在线客服