Python导入数据库,python把数据写入数据库
这篇文章主要介绍了大蟒实现关系型数据库数据库中的结构化查询语言文件生成和导入，首先通过将关系型数据库数据导出到结构化查询语言文件中展开详细内容需要的小伙伴可以参考一下
目录
1、将关系型数据库数据导出到结构化查询语言文件中（数据库存在的情况)2、将现有的结构化查询语言文件数据导入到数据库中（前提数据库存在)3、利用Navicat导出结构化查询语言文件和导入结构化查询语言文件1)从数据库导出结构化查询语言文件2)导入结构化查询语言文件到数据库
1、将mysql数据导出到SQL文件中（数据库存在的情况）
主要需要修改数据库的相关信息，端口号、用户名、密码等
其中数据库得存在，不然会报错 ：
#!/usr/bin/env python
# -*-编码： utf-8 -*-
# @description:导出数据库文件结构化查询语言
导入操作系统
InitSql类（对象):
sql_file=A.sql
定义导入_服务器_数据库（自身):
MySQL dump _ commad _ dict={ dump commad : MySQL dump ， server: localhost ， user: root ，
密码： 根，端口： 3306， db : studentmanagersystem }
# mysqldump命令
SQL format= mysqldump-column-statistics=0-h % s-u % s-P % s-P % s % s % s
# 生成相应的结构化查询语言语句
SQL=(SQL format %(MySQL dump _ commad _ dict[ server ]，
mysqldump_commad_dict[user]，
mysqldump _ commad _ dict[ password ]，
mysqldump_commad_dict[port]，
mysqldump_commad_dict[db]，
self.sql_file))
打印(执行的导出数据库的sql: sql)
result=os.system(sql)
回送结果
if __name__==__main__:
initSql=InitSql()
initSql.import_server_db()
生成的sql文件如下所示：
- MySQL转储10.13发行版8.0.29,适用于Win64 (x86_64)
-
-主机：本地主机数据库：学生管理系统
- -
-服务器版本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集合名称utf8mb 4 */；
/*!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 pymysqlfrom 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(fcreate 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文件成功
3、利用Navicat导出SQL文件和导入SQL文件
1）从数据库导出SQL文件
选择需要导出的数据表——右键——转储为SQL文件——数据和结构
这样就可以将数据表的结构和数据都一起保存在SQL文件中
2）导入SQL文件到数据库
右键选中需要导入的数据库——运行SQL文件
点击开始后，即开始运行SQL文件，出现下述字样表明导入SQL文件成功
到此这篇关于Python实现mysql数据库中的SQL文件生成和导入的文章就介绍到这了,更多相关SQL文件生成内容请搜索盛行IT软件开发工作室以前的文章或继续浏览下面的相关文章希望大家以后多多支持盛行IT软件开发工作室！
郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。