Ubuntu下通过python使用MySQL

参考资料

  1. MySQL Connector/Python Developer Guide
  2. python_mysql_tutorial

环境

  1. Ubuntu 20.04
  2. Python 3.8.10
  3. MySQL Server 8.0.34
  4. mysql-connector-python 8.1.0

安装MySQL

pip install mysql-connector-python	# 注意，不要安装成 mysql-connector 了

环境测试

注意：

  1. 千万不能命名为mysql.py!
  2. 千万不能命名为mysql.py!
  3. 千万不能命名为mysql.py!
import mysql.connectordef get_connection():connection = mysql.connector.connect(host='localhost',database='python_db',user='root',password='root')return connectiondef close_connection(connection):if connection:connection.close()def read_database_version():try:connection = get_connection()cursor = connection.cursor()cursor.execute("SELECT version();")db_version = cursor.fetchone()print("You are connected to MySQL version: ", db_version)close_connection(connection)except (Exception, mysql.connector.Error) as error:print("Error while getting data", error)print("Question 1: Print Database version")
read_database_version()

MySQL 的连接和关闭

关于下列代码中 ** 的解释：python中星号的意义

import mysql.connector
from mysql.connector import errorcodeconfig = {'user': 'root','password': 'root','database': 'mydb','host': 'localhost','raise_on_warnings': True
}try:cnx = mysql.connector.connect(**config)
except mysql.connector.Error as err:    # if except happen will executeprint("Database operation ERR")if err.errno == errorcode.ER_ACCESS_DENIED_ERROR:print("Something is wrong with your user name or password")elif err.errno == errorcode.ER_BAD_DB_ERROR:print("Database does not exist")else:print(err)
else:   # if no except happen will executecnx.close()print("Database operation OK")
finally:    # always executeprint("Finish")

MySQL创建数据库

import mysql.connectorconn = mysql.connector.connect(user='root', password='root')
cursor = conn.cursor()
cursor.execute("drop database if exists my_database")		# 通过 if exists 防止数据不存在而报错
sql = "create database my_database"
cursor.execute(sql)					# 创建数据库
print("List of databases: ")
cursor.execute("show databases")	# 执行 SQL 语句
print(cursor.fetchall())			# 获取 MySQL 的输出，有 fetchone() fetchmany() fetchall() 三个接口
conn.close()

MySQL创建表格及数据库

以下表格数据下载：employees database

import mysql.connector
from mysql.connector import errorcodeDB_NAME = 'employees'TABLES = {}
TABLES['employees'] = ("create table `employees` (""   `emp_no` int(11) NOT NULL AUTO_INCREMENT,""   `birth_date` date NOT NULL,""   `first_name` varchar(14) NOT NULL,""   `last_name` varchar(16) NOT NULL,""   `gender` enum('M', 'F') NOT NULL,""   `hire_date` date NOT NULL,""   primary key (`emp_no`)"") engine=InnoDB")TABLES['departments'] = ("create table `departments` (""   `dept_no` char(4) NOT NULL,""   `dept_name` varchar(40) NOT NULL,""   primary key (`dept_no`), unique key `dept_name` (`dept_name`)"") engine=InnoDB")TABLES['salaries'] = ("create table `salaries` (""   `emp_no` int(11) NOT NULL,""   `salary` int(11) NOT NULL,""   `from_date` date NOT NULL,""   `to_date` date NOT NULL,""   primary key (`emp_no`, `from_date`), key `emp_no` (`emp_no`),""   constraint `salaries_ibfk_1` foreign key (`emp_no`) ""       references `employees` (`emp_no`) on delete cascade"") engine=InnoDB")TABLES['dept_emp'] = ("create table `dept_emp` (""   `emp_no` int(11) NOT NULL,""   `dept_no` char(4) NOT NULL,""   `from_date` date NOT NULL,""   `to_date` date NOT NULL,""   primary key (`emp_no`, `dept_no`), key `emp_no` (`emp_no`),""   key `dept_no` (`dept_no`),""   constraint `dept_emp_ibfk_1` foreign key (`emp_no`) ""       references `employees` (`emp_no`) on delete cascade,""   constraint `dept_emp_ibfk_2` foreign key (`dept_no`) ""       references `departments` (`dept_no`) on delete cascade"") engine=InnoDB") TABLES['dept_manager'] = ("create table `dept_manager` (""   `emp_no` int(11) NOT NULL,""   `dept_no` char(4) NOT NULL,""   `from_date` date NOT NULL,""   `to_date` date NOT NULL,""   primary key (`emp_no`, `dept_no`),""   key `emp_no` (`emp_no`),""   key `dept_no` (`dept_no`),""   constraint `dept_manager_ibfk_1` foreign key (`emp_no`) ""       references `employees` (`emp_no`) on delete cascade,""   constraint `dept_manager_ibfk_2` foreign key (`dept_no`) ""       references `departments` (`dept_no`) on delete cascade"") engine=InnoDB")TABLES['titles'] = ("create table `titles` (""   `emp_no` int(11) NOT NULL,""   `title` varchar(50) NOT NULL,""   `from_date` date NOT NULL,""   `to_date` date NOT NULL,""   primary key (`emp_no`, `title`, `from_date`), key `emp_no` (`emp_no`),""   constraint `title_ibfk_1` foreign key (`emp_no`)""       references `employees` (`emp_no`) on delete cascade"") engine=InnoDB")def create_database(cursor):try:cursor.execute("create database {} default character set 'utf8'".format(DB_NAME))except mysql.connector.Error as err:print("Failed creating database: {}".format(err))exit(1)cnx = mysql.connector.connect(user='root', password='root')
cursor = cnx.cursor()try:cursor.execute("USE {}".format(DB_NAME))
except mysql.connector.Error as err:print("Database {} does not exists.".format(DB_NAME))if err.errno == errorcode.ER_BAD_DB_ERROR:create_database(cursor)print("Database {} created successfully.".format(DB_NAME))cnx.database = DB_NAMEelse:print(err)exit(1)for table_name in TABLES:table_description = TABLES[table_name]try:print("Creating table {}: ".format(table_name), end='')cursor.execute(table_description)except mysql.connector.Error as err:if err.errno == errorcode.ER_TABLE_EXISTS_ERROR:print("already exist.")else:print(err.msg)else:print("OK")cursor.close()		# cursor 也需要关闭
cnx.close()

import mysql.connectorconn = mysql.connector.connect(user='root', password='root')
cursor = conn.cursor()
cursor.execute("show databases")
print(cursor.fetchall())		# 获取并打印 MySQL 的输出
cursor.execute("use mydb")		# 选择数据库
cursor.execute("drop table if exists employee")		# 如果已经存在 employee 表格，则删除# 除了上面在双引号中添加SQL语句，还可以利用 python 多行字符串的语法，在三引号中添加 SQL 语句，这样就没有这么多的引号，看起来清晰很多
sql = '''create table employee(first_name char(20) not null,last_name char(20),age int,sex char(1),income float)
'''
cursor.execute(sql)		# 新建 employee 表格
cursor.execute("desc employee")		# 显示表格详情
print(cursor.fetchall())
cursor.execute("show create table employee")	# 显示创建表格的源码！
print(cursor.fetchall())
cursor.close()
conn.close()

插入数据 INSERT INTO

import mysql.connectorconn = mysql.connector.connect(user='root', password='root', database='mydb')
cursor = conn.cursor()sql = '''insert into employee(first_name, last_name, age, sex, income) values('Mac', 'Mohan', 20, 'M', 2000)
'''try:cursor.execute(sql)conn.commit()print("commit")
except:conn.rollback()print(rollback)conn.close()

import mysql.connectorconn = mysql.connector.connect(user='root', password='root', database='mydb')
cursor = conn.cursor()
# 还可以通过这种方式执行 SQL 语句，这样就不需要重复写 SQL 语句了，只需要写需要使用的数据即可
sql = '''insert into employee(first_name, last_name, age, sex, income) values(%s, %s, %s, %s, %s)
'''
data1 = ('Ramya', 'Ramapriya', 25, 'F', 5000)
data2 = ('shadow3d', 'Denis', 28, 'M', 30000)try:cursor.execute(sql, data1)cursor.execute(sql, data2)conn.commit()print("insert OK, commit")
except:print("insert failed, rollback")conn.rollback()conn.close()

查看数据 select

import mysql.connectorconn = mysql.connector.connect(user='root', password='root', database='mydb')
cursor = conn.cursor()sql = "select * from employee"# 通过 fetchone() 每次只读一行，可以更直观的显示查询结果
print("read one by one:")
cursor.execute(sql)
result = cursor.fetchone()
while result:print("\t", result)result = cursor.fetchone()# 通过 fetchmany() 指定每次读取的行数
print("\nread two by two:")
cursor.execute(sql)
result = cursor.fetchmany(size=2)
while result:print("\t", result)result = cursor.fetchmany(size=2)conn.close()

错误及原因

  1. ModuleNotFoundError: No module named 'mysql.connector'; 'mysql' is not a package
    以上错误是由于将本地的python文件命名成了mysql.py导致，改个名字就好了；
  2. mysql.connector.errors.NotSupportedError: Authentication plugin 'caching_sha2_password' is not supported
    以上错误是由于安装的模块错了，我们需要安装mysql-connector-python，而安装成了mysql-connector;

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/73159.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

WPF命令

WPF命令

在设计良好的Windows应用程序中，应用程序逻辑不应位于事件处理程序中，而应在更高层的方法中编写代码。其中的每个方法都代表单独的应用程序任务。每个任务可能依赖其他库。 使用这种设计最明显的方式是在需要的地方添加事件处理程序，并使用各…
阅读更多...
八 动手学深度学习v2 ——卷积神经网络之卷积+填充步幅+池化

八 动手学深度学习v2 ——卷积神经网络之卷积+填充步幅+池化

图像卷积总结 二维卷积层的核心计算是二维互相关运算。最简单的形式是，对二维输入数据和卷积核执行互相关操作，然后添加一个偏置。核矩阵和偏移是可学习的参数核矩阵大小是超参数 填充和步幅 padding和stride 填充： 在应用多层卷积时&…
阅读更多...
Linux Debian12将本地项目上传到码云(gitee)远程仓库

Linux Debian12将本地项目上传到码云(gitee)远程仓库

一、注册码云gitee账号 这个可以参考其他教程，本文不做介绍。 gitee官网：https://gitee.com/ 二、Linux Debian12安装git 如果Linux系统没有安装git，可以使用下面命令安装git sudo apt install git 三、gitee新建仓库 我这只做测试&…
阅读更多...
关于mysql数据文件损坏导致的mysql无法启动的问题

关于mysql数据文件损坏导致的mysql无法启动的问题

环境 rocky linux 9 （跟centos几乎一模一样） myqsl 8.0， 存储引擎使用innodb 问题描述 1. 服务器异常关机，重启启动后发现mysql无法连接，使用命令查看mysql状态： systemctl status mysqld 发现mysql服…
阅读更多...
69、配置AWS服务，接收来自RTSP流的推送

69、配置AWS服务，接收来自RTSP流的推送

基本思想：在上一篇的基础和视频教程之后，进行简单的aws服务，进行RTSP流的接收 第一步： 第二步：配置video_stream,记得选择香港节点 同时记录这个信息，后面的策略需要填充 第三步：进行策略设置 第四步：策略设置，选中右上角的创建策略 第五步、进行json填充 第六步：填…
阅读更多...
抓取ajax加载的数据

抓取ajax加载的数据

""" https://www.duitang.com/napi/blogv2/list/by_search/?堆糖页面分析：使用Ajax加载，aferid是控制加载的图片和页面，从零开始，会提前加载下一页的Ajax数据第一页的图片是after_id从0到120，会提前…
阅读更多...
精益创业的三个测量方法

精益创业的三个测量方法

精益创业三个测量工具【安志强趣讲282期】 趣讲大白话：没法度量就没法改进 **************************** 工具1：AB对比测试 就是产品有两个或多个版本 然后通过外部客户或内部人员评测 可以组织天使用户群：愿意参与的专业人士 工具2&#x…
阅读更多...
微服务井喷时代，我们如何规模化运维？

微服务井喷时代，我们如何规模化运维？

随着云原生技术发展及相关技术被越来越多运用到公司生产实践当中，有两种不可逆转的趋势： 1、微服务数量越来越多。原来巨型单体服务不断被拆解成一个个微服务，在方便功能复用及高效迭代的同时，也给运维带来了不少挑战：…
阅读更多...
磐基2.0 部署nacos集群连接磐维1.0数据库

磐基2.0 部署nacos集群连接磐维1.0数据库

nacos官网 https://nacos.io/zh-cn/docs/use-nacos-with-kubernetes.html Kubernetes Nacos nacos 集群架构 https://blog.csdn.net/u013716737/article/details/130966482 Nacos高可用集群搭建与使用 nacos链接pg数据库，参考 https://blog.csdn.net/longyuhome/…
阅读更多...
大数据技术之Hadoop：MapReduce与Yarn概述（六）

大数据技术之Hadoop：MapReduce与Yarn概述（六）

目录 一、分布式计算 二、分布式资源调度 2.1 什么是分布式资源调度 2.2 yarn的架构 2.2.1 核心架构 2.2.2 辅助架构 前面我们提到了Hadoop的三大核心功能：分布式存储、分布式计算和资源调度，分别由Hadoop的三大核心组件可以担任。 即HDFS是分布式…
阅读更多...
基于Docker从零到一实操MySql的主从复制

基于Docker从零到一实操MySql的主从复制

文章目录 一、在Docker上安装，启动MySQL查看docker是否安装成功安装mysql查看mysql镜像进入mysql后台操作docker Volume（卷）入门 MySql的主从复制1. 创建MySQL主从复制的网络2. 创建MySQL主服务器3. 创建MySQL从服务器4. 配置主从同步5.测试主…
阅读更多...
什么是CI/CD：持续集成与持续交付？（InsCode AI 创作助手）

什么是CI/CD：持续集成与持续交付？（InsCode AI 创作助手）

在现代软件开发领域，CICD（Continuous Integration and Continuous Delivery）是一种关键性的开发实践，它有助于提高软件交付的质量和效率。本文将深入探讨CICD的定义、原理和重要性，以及如何在项目中实施CICD流程。 什…
阅读更多...
2023高教社杯数学建模E题思路代码 - 黄河水沙监测数据分析

2023高教社杯数学建模E题思路代码 - 黄河水沙监测数据分析

# 1 赛题 E 题 黄河水沙监测数据分析 黄河是中华民族的母亲河。研究黄河水沙通量的变化规律对沿黄流域的环境治理、气候变 化和人民生活的影响， 以及对优化黄河流域水资源分配、协调人地关系、调水调沙、防洪减灾 等方面都具有重要的理论指导意义。 附件 1 给出了位…
阅读更多...
在学习编程的过程中，我会记录下以下内容：

在学习编程的过程中，我会记录下以下内容：

在学习编程的过程中，我会记录下以下内容： 常用代码片段：我会记录一些常用的代码片段，例如文件读写、列表操作、字符串处理等。这些代码片段可以在日常编程中快速复用，提高编码效率。 # 文件读取 with open(file.txt,…
阅读更多...
vue + video.js 加载多种视频流（HLS、FLV、RTMP、RTSP）

vue + video.js 加载多种视频流（HLS、FLV、RTMP、RTSP）

起因： 由于需要在一个项目内接入多种常用的视频流，所以接触到video.js，这里就做个记录。 框架： vue2 video.js videojs-contrib-hls videojs-flvjs-es6 videojs-flash video-js.swf vue安装就不讲了，直接从项目…
阅读更多...
软考高级架构师下篇-14面向服务架构设计理论

软考高级架构师下篇-14面向服务架构设计理论

目录 1. 引言2. SOA的相关概念3. SOA的发展历史4. SOA的参考架构5. SOA 主要协议和规范6. SOA设计的标准要求7. SOA的作用与设计原则8. SOA的设计模式9. SOA构建与实施10. 前文回顾1. 引言 在面向服务的体系结构（Service-Oriented Architecture，SOA）中，服务的概念有了延伸…
阅读更多...
使用EMgu检测人脸

使用EMgu检测人脸

1，安装EMgu 在NuGet中，查找并安装EMgu 2,做人脸检测 首先，声明几个重要的类 //Thread.Sleep(3000);matImg = new Mat();capture.Retrieve(matImg, 0); frame=new Image<Bgr, byte>(matImg.Bitmap); 当，frame != null时，检测到人脸 3，给人脸画框 i…
阅读更多...
苹果macOS 13.5.2正式发布 修复ImageIO进程

苹果macOS 13.5.2正式发布 修复ImageIO进程

9 月 8 日消息&#xff0c;苹果今日向 Mac 电脑用户推送了 macOS 13.5.2 更新&#xff08;内部版本号&#xff1a;22G91&#xff09;&#xff0c;本次更新距离上次发布隔了 21 天。 需要注意的是&#xff0c;因苹果各区域节点服务器配置缓存问题&#xff0c;可能有些地方探测到…
阅读更多...
利用go多态实现一个简单工厂模式

利用go多态实现一个简单工厂模式

go的多态只能用接口来实现&#xff0c;不能用嵌入结构体的继承方式来实现。 go的多态和java很像&#xff0c;结合下面代码中的例子很容易就能理解。 在下面代码中&#xff0c;我们定义了一个接口DatabaseConnection&#xff0c;代表着数据库连接。这个接口有三个具体实现&…
阅读更多...
WordPress 提示“此站点遇到了致命错误”的解决方法

WordPress 提示“此站点遇到了致命错误”的解决方法

WordPress 提示“此站点遇到了致命错误”的解决方法 WordPress 网站博客提示“此站点遇到了致命错误。”如何解决&#xff1f;今天老唐不幸遇到了这个问题&#xff0c;搜了一下解决方法&#xff0c;发现致命错误原因有很多&#xff0c;所以需要先打开 WordPress 的 WP_DEBUG 功…
阅读更多...
最新文章

Copyright @ 2022~2023