热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

数据库技术:Python实现mysql数据库中的SQL文件生成和导入分享

目录1、将mysql数据导出到SQL文件中(数据库存在的情况)2、将现有的sql文件数据导入到数据库中(前提数据库存在) 3、利用Navicat导出SQL文件和导入SQL文件1)从

目录

1、将mysql数据导出到SQL文件中(数据库存在的情况)

2、将现有的sql文件数据导入到数据库中(前提数据库存在) 

3、利用Navicat导出SQL文件和导入SQL文件

1)从数据库导出SQL文件

2)导入SQL文件到数据库 

1、将mysql数据导出到SQL文件中(数据库存在的情况)

主要需要修改数据库的相关信息,端口号、用户名、密码等

其中数据库得存在,不然会报错 :

Python实现mysql数据库中的SQL文件生成和导入

#!/usr/bin/env python # -*- coding: utf-8 -*- # @description:导出数据库文件sql import os class InitSql(object):     sql_file = "A.sql"     def import_server_db(self):         mysqldump_commad_dict = {'dumpcommad': 'mysqldump ', 'server': 'localhost', 'user': 'root',                                  'password': 'root', 'port': 3306, 'db': 'studentmanagersystem'}         # mysqldump 命令         sqlfromat = "mysqldump --column-statistics=0 -h%s -u%s -p%s -P%s %s > %s"         # 生成相应的sql语句         sql = (sqlfromat % (mysqldump_commad_dict['server'],                             mysqldump_commad_dict['user'],                             mysqldump_commad_dict['password'],                             mysqldump_commad_dict['port'],                             mysqldump_commad_dict['db'],                             self.sql_file))         print("执行的导出数据库的sql:" + sql)         result = os.system(sql)         return result if __name__ == '__main__':     initSql = InitSql()     initSql.import_server_db()

生成的sql文件如下所示:

-- MySQL dump 10.13  Distrib 8.0.29, for Win64 (x86_64) -- -- Host: localhost    Database: studentmanagersystem -- ------------------------------------------------------ -- Server version  8.0.29 /*!40101 SET @OLD_CHARACTER_SET_CLIENT=@@CHARACTER_SET_CLIENT */; /*!40101 SET @OLD_CHARACTER_SET_RESULTS=@@CHARACTER_SET_RESULTS */; /*!40101 SET @OLD_COLLATION_COnNECTION=@@COLLATION_CONNECTION */; /*!50503 SET NAMES utf8mb4 */; /*!40103 SET @OLD_TIME_ZOnE=@@TIME_ZONE */; /*!40103 SET TIME_ZOnE='+00:00' */; /*!40014 SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0 */; /*!40014 SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0 */; /*!40101 SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE='NO_AUTO_VALUE_ON_ZERO' */; /*!40111 SET @OLD_SQL_NOTES=@@SQL_NOTES, SQL_NOTES=0 */; -- -- Table structure for table `studenttable` -- DROP TABLE IF EXISTS `studenttable`; /*!40101 SET @saved_cs_client     = @@character_set_client */; /*!50503 SET character_set_client = utf8mb4 */; CREATE TABLE `studenttable` (   `number` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NOT NULL,   `name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL,   `sex` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL,   `classes` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL,   `floor` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL,   `room` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL,   `tel` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL,   `money` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL,   PRIMARY KEY (`number`) USING BTREE ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci ROW_FORMAT=DYNAMIC; /*!40101 SET character_set_client = @saved_cs_client */; -- -- Dumping data for table `studenttable` -- LOCK TABLES `studenttable` WRITE; /*!40000 ALTER TABLE `studenttable` DISABLE KEYS */; INSERT INTO `studenttable` VALUES ('2201','刘同学','男','1班','A1','101','1112','30'),('2202','张同学','男','2班','A2','211','1121','13'),('2203','管同学','女','2班','A3','121','1122','11'),('2204','管同学','女','2班','A3','121','1122','11'),('2205','刘同学','女','2班','A3','121','1122','11'),('2206','张同学','男','2班','A2','211','1121','13'),('2208','杨同学','男','1班','A1','101','1112','30'),('2209','蔡同学','男','1班','A1','101','1112','30'); /*!40000 ALTER TABLE `studenttable` ENABLE KEYS */; UNLOCK TABLES; /*!40103 SET TIME_ZOnE=@OLD_TIME_ZONE */; /*!40101 SET SQL_MODE=@OLD_SQL_MODE */; /*!40014 SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS */; /*!40014 SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS */; /*!40101 SET CHARACTER_SET_CLIENT=@OLD_CHARACTER_SET_CLIENT */; /*!40101 SET CHARACTER_SET_RESULTS=@OLD_CHARACTER_SET_RESULTS */; /*!40101 SET COLLATION_COnNECTION=@OLD_COLLATION_CONNECTION */; /*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */; -- Dump completed on 2022-06-05  0:30:03 2、将现有的sql文件数据导入到数据库中(前提数据库存在) 

这里的话其实就是将SQL文件进行分割成一条条SQL语句,然后顺序执行即可

import pymysql from pathlib import Path class ConnectMsql:     def __init__(self, host='localhost', port=3306, user='root',                  password='root', database="studentmanagersystem", filename: str = "studenttable.sql"):         """         :param host:        域名         :param port:        端口         :param user:        用户名         :param password:    密码         :param database:    数据库名         :param filename:    文件名称         """         self._host: str = host         self._port: int = port         self._user: str = user         self._password: str = password         self._database: str = database         self._file_path = Path(__file__).parent.joinpath(filename)     def _show_databases_and_create(self):         """         查询数据库是否存在,不存在则进行新建操作         :return:         """         cOnnection= pymysql.connect(host=self._host, port=self._port, user=self._user, password=self._password,                                      cursorclass=pymysql.cursors.DictCursor)         with connection:             with connection.cursor() as cursor:                 cursor.execute('show databases;')                 result = cursor.fetchall()                 results = self._database not in tuple(x["Database"] for x in result)         if results:             with connection.cursor() as cursor:                 cursor.execute(f'create database {self._database};')             with connection.cursor() as cursor:                 cursor.execute('show databases;')                 result = cursor.fetchall()                 results = self._database in tuple(x["Database"] for x in result)             return results if results else result         else:             return True     def _export_databases_data(self):         """         读取.sql文件,解析处理后,执行sql语句         :return:         """         if self._show_databases_and_create() is True:             cOnnection= pymysql.connect(host=self._host, port=self._port, user=self._user, password=self._password,                                          database=self._database, charset='utf8')             # 读取sql文件,并提取出sql语句             results, results_list = "", []             with open(self._file_path, mode="r+", encoding="utf-8") as r:                 for sql in r.readlines():                     # 去除数据中的“n”和“r”字符                     sql = sql.replace("n", "").replace("r", "")                     # 获取不是“--”开头且不是“--”结束的数据                     if not sql.startswith("--") and not sql.endswith("--"):                         # 获取不是“--”的数据                         if not sql.startswith("--"):                             results = results + sql                 # 根据“;”分割数据,处理后插入列表中                 for i in results.split(";"):                     if i.startswith("/*"):                         results_list.append(i.split("*/")[1] + ";")                         # print(i.split("*/")[1] + ";")                     else:                         results_list.append(i + ";")                         # print(i + ";")             # 执行sql语句             with connection:                 with connection.cursor() as cursor:                     # 循环获取sql语句                     for x in results_list[:-1]:                         if x != ";":                             print(x)                             # 执行sql语句                             cursor.execute(x)                             # 提交事务                             connection.commit()                     else:                         return "sql全部语句执行成功 !"     @property     def sql_run(self):         """         执行方法         :return:         """         return self._export_databases_data() if __name__ == '__main__':     res = ConnectMsql().sql_run     print(res)

利用Navicat软件可视化数据库,可以看到导入SQL文件成功

Python实现mysql数据库中的SQL文件生成和导入

3、利用Navicat导出SQL文件和导入SQL文件 1)从数据库导出SQL文件

选择需要导出的数据表——右键——转储为SQL文件——数据和结构

这样就可以将数据表的结构和数据都一起保存在SQL文件中

2)导入SQL文件到数据库 

右键选中需要导入的数据库——运行SQL文件

Python实现mysql数据库中的SQL文件生成和导入

点击开始后,即开始运行SQL文件,出现下述字样表明导入SQL文件成功

Python实现mysql数据库中的SQL文件生成和导入

到此这篇关于Python实现mysql数据库中的SQL文件生成和导入的文章就介绍到这了,更多相关SQL文件生成内容请搜索<编程笔记>以前的文章或继续浏览下面的相关文章希望大家以后多多支持<编程笔记>!

上述就是数据库技术:Python实现mysql数据库中的SQL文件生成和导入分享的全部内容,如果对大家有所用处且需要了解更多关于mysql数据库学习教程,希望大家多多关注—编程笔记


推荐阅读
  • 使用Vultr云服务器和Namesilo域名搭建个人网站
    本文详细介绍了如何通过Vultr云服务器和Namesilo域名搭建一个功能齐全的个人网站,包括购买、配置服务器以及绑定域名的具体步骤。文章还提供了详细的命令行操作指南,帮助读者顺利完成建站过程。 ... [详细]
  • 本文详细介绍如何使用Python进行配置文件的读写操作,涵盖常见的配置文件格式(如INI、JSON、TOML和YAML),并提供具体的代码示例。 ... [详细]
  • 本文详细介绍了 Dockerfile 的编写方法及其在网络配置中的应用,涵盖基础指令、镜像构建与发布流程,并深入探讨了 Docker 的默认网络、容器互联及自定义网络的实现。 ... [详细]
  • 本文介绍如何使用阿里云的fastjson库解析包含时间戳、IP地址和参数等信息的JSON格式文本,并进行数据处理和保存。 ... [详细]
  • Linux 系统启动故障排除指南:MBR 和 GRUB 问题
    本文详细介绍了 Linux 系统启动过程中常见的 MBR 扇区和 GRUB 引导程序故障及其解决方案,涵盖从备份、模拟故障到恢复的具体步骤。 ... [详细]
  • 1:有如下一段程序:packagea.b.c;publicclassTest{privatestaticinti0;publicintgetNext(){return ... [详细]
  • 1.如何在运行状态查看源代码?查看函数的源代码,我们通常会使用IDE来完成。比如在PyCharm中,你可以Ctrl+鼠标点击进入函数的源代码。那如果没有IDE呢?当我们想使用一个函 ... [详细]
  • 解决PHP与MySQL连接时出现500错误的方法
    本文详细探讨了当使用PHP连接MySQL数据库时遇到500内部服务器错误的多种解决方案,提供了详尽的操作步骤和专业建议。无论是初学者还是有经验的开发者,都能从中受益。 ... [详细]
  • 本文详细介绍了如何通过多种编程语言(如PHP、JSP)实现网站与MySQL数据库的连接,包括创建数据库、表的基本操作,以及数据的读取和写入方法。 ... [详细]
  • 掌握远程执行Linux脚本和命令的技巧
    本文将详细介绍如何利用Python的Paramiko库实现远程执行Linux脚本和命令,帮助读者快速掌握这一实用技能。通过具体的示例和详尽的解释,让初学者也能轻松上手。 ... [详细]
  • 从 .NET 转 Java 的自学之路:IO 流基础篇
    本文详细介绍了 Java 中的 IO 流,包括字节流和字符流的基本概念及其操作方式。探讨了如何处理不同类型的文件数据,并结合编码机制确保字符数据的正确读写。同时,文中还涵盖了装饰设计模式的应用,以及多种常见的 IO 操作实例。 ... [详细]
  • 本文详细记录了在基于Debian的Deepin 20操作系统上安装MySQL 5.7的具体步骤,包括软件包的选择、依赖项的处理及远程访问权限的配置。 ... [详细]
  • PHP 5.2.5 安装与配置指南
    本文详细介绍了 PHP 5.2.5 的安装和配置步骤,帮助开发者解决常见的环境配置问题,特别是上传图片时遇到的错误。通过本教程,您可以顺利搭建并优化 PHP 运行环境。 ... [详细]
  • CentOS7源码编译安装MySQL5.6
    2019独角兽企业重金招聘Python工程师标准一、先在cmake官网下个最新的cmake源码包cmake官网:https:www.cmake.org如此时最新 ... [详细]
  • 网络运维工程师负责确保企业IT基础设施的稳定运行,保障业务连续性和数据安全。他们需要具备多种技能,包括搭建和维护网络环境、监控系统性能、处理突发事件等。本文将探讨网络运维工程师的职业前景及其平均薪酬水平。 ... [详细]
author-avatar
U友48805799
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有