【Python学习笔记】第二十五节 Python MySQL

news/2024/7/23 9:30:53 标签: 学习, 人工智能, python, 数据分析

Python 连接到 MySQL 数据库有几种不同的连接方法，而且不是所有的方法都能与不同的操作系统很好地配合.

MySQL connector/Python模块是Oracle支持的官方驱动，用于通过Python连接MySQL。该连接器完全是Python语言，而mysqlclient是用C语言编写的。它也是独立的，意味着它不需要MySQL客户端库或标准库以外的任何Python模块。

注意，MySQL Connector/Python不支持旧的MySQL服务器认证方法，这意味着4.1之前的MySQL版本不能工作。

本文实例的运行环境：

  • Windows 10

  • MySQL 8.0

一、创建数据库连接

1、首先安装mysql-connector-python模块。

python">python">python -m pip install mysql-connector

2、连接数据库：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root"  # 数据库密码
)

print(mydb)

运行结果

python">python"><mysql.connector.connection.MySQLConnection object at 0x000002B399503AC0>

二、创建数据库

1、创建数据库使用 "CREATE DATABASE" 语句，以下创建一个名为 python_demo 的数据库：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root"  # 数据库密码
)

print(mydb)

myCursor = mydb.cursor()

myCursor.execute("CREATE DATABASE python_demo")

2、使用 "SHOW DATABASES" 语句来查看数据库是否存在：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root"  # 数据库密码
)

print(mydb)

myCursor = mydb.cursor()

# myCursor.execute("CREATE DATABASE python_demo")
myCursor.execute("SHOW DATABASES")

for x in myCursor:
    print(x)

  • 我们可以直接连接数据库，如果数据库不存在，会输出错误信息：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

print(mydb)

三、创建数据表

创建数据表使用 "CREATE TABLE" 语句，创建数据表前，需要确保数据库已存在，以下创建一个名为 user 自增主键的数据表：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

# print(mydb)

myCursor = mydb.cursor()
myCursor.execute("CREATE TABLE user (id int(11) primary key not null auto_increment,name VARCHAR(64), mobile VARCHAR(32), address VARCHAR(255))")

  • 如果我们的表已经创建，我们需要使用 ALTER TABLE 来给表添加主键：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

# print(mydb)

myCursor = mydb.cursor()
myCursor.execute("ALTER TABLE user ADD COLUMN id INT AUTO_INCREMENT PRIMARY KEY")

四、插入数据

  • 插入数据使用 "INSERT INTO" 语句：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

# print(mydb)

myCursor = mydb.cursor()

sql = "INSERT INTO user (name, mobile,address) VALUES (%s, %s, %s)"
val = ("Lily", "13866669999", "America")
myCursor.execute(sql, val)
mydb.commit()  # 提交

print(myCursor.rowcount, "插入成功。")

  • 批量插入

批量插入使用 executemany() 方法，该方法的第二个参数是一个元组列表，包含了我们要插入的数据：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

# print(mydb)

myCursor = mydb.cursor()

sql = "INSERT INTO user (name, mobile,address) VALUES (%s, %s, %s)"
# val = ("Lily", "13866669999", "America")

val = [
    ("LiLei", "13866668888", "China"),
    ("Jim", "13855558888", "America"),
    ("HanMeimei", "13811113333", "China")
]
# myCursor.execute(sql, val)
myCursor.executemany(sql, val)

mydb.commit()  # 提交

print(myCursor.rowcount, "插入成功。")

python">python">3 插入成功。

五、查询数据

1、查询数据使用 SELECT 语句：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()

myCursor.execute("SELECT * FROM user")

result = myCursor.fetchall()  # fetchall() 获取所有记录

for x in result:
    print(x)

  • 读取指定的字段数据：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()

# myCursor.execute("SELECT * FROM user")
myCursor.execute("SELECT name, mobile, address FROM user")
result = myCursor.fetchall()  # fetchall() 获取所有记录

for x in result:
    print(x)

  • 读取一条数据，可以使用 fetchone() 方法：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()

# myCursor.execute("SELECT * FROM user")
myCursor.execute("SELECT name, mobile, address FROM user")
# result = myCursor.fetchall()  # fetchall() 获取所有记录
result = myCursor.fetchone()  # fetchall() 获取一条记录
print(result)


python">python">('Lily', '13866669999', 'America')

2、where 条件语句

如果我们要读取指定条件的数据，可以使用 where 语句：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()

# myCursor.execute("SELECT * FROM user")
myCursor.execute("SELECT * FROM user where address ='America'")
result = myCursor.fetchall()  # fetchall() 获取所有记录
# result = myCursor.fetchone()  # fetchall() 获取一条记录
# print(result)
for x in result:
    print(x)

python">python">(1, 'Lily', '13866669999', 'America')
(3, 'Jim', '13855558888', 'America')

  • 为了防止数据库查询发生 SQL 注入的攻击，我们可以使用 %s 占位符来转义查询的条件：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()
# myCursor.execute("SELECT * FROM user where address ='America'")

sql = "SELECT * FROM user where address = %s"
param = ("China",)

myCursor.execute(sql, param)


result = myCursor.fetchall()  # fetchall() 获取所有记录

for x in result:
    print(x)

python">python">(2, 'LiLei', '13866668888', 'China')
(4, 'HanMeimei', '13811113333', 'China')

3、排序

查询结果排序可以使用 ORDER BY 语句，默认的排序方式为升序，关键字为 ASC，如果要设置降序排序，可以设置关键字 DESC。

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()
# myCursor.execute("SELECT * FROM user  ORDER BY name")
sql = "SELECT * FROM user ORDER BY name"
myCursor.execute(sql)
result = myCursor.fetchall()  # fetchall() 获取所有记录

for x in result:
    print(x)

python">python">(4, 'HanMeimei', '13811113333', 'China')
(3, 'Jim', '13855558888', 'America')
(2, 'LiLei', '13866668888', 'China')
(1, 'Lily', '13866669999', 'America')

  • 降序排序实例：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()
# myCursor.execute("SELECT * FROM user  ORDER BY name")
sql = "SELECT * FROM user ORDER BY address DESC "
myCursor.execute(sql)
result = myCursor.fetchall()  # fetchall() 获取所有记录

for x in result:
    print(x)

python">python">(2, 'LiLei', '13866668888', 'China')
(4, 'HanMeimei', '13811113333', 'China')
(1, 'Lily', '13866669999', 'America')
(3, 'Jim', '13855558888', 'America')

4、Limit

如果我们要设置查询的数据量，可以通过 "LIMIT" 语句来指定

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()
# myCursor.execute("SELECT * FROM user  ORDER BY name")
sql = "SELECT * FROM user LIMIT 2 "

myCursor.execute(sql)
result = myCursor.fetchall()  # fetchall() 获取所有记录

for x in result:
    print(x)

python">python">(1, 'Lily', '13866669999', 'America')
(2, 'LiLei', '13866668888', 'China')

  • 指定起始位置，使用的关键字是 OFFSET：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()
# sql = "SELECT * FROM user LIMIT 2 "
sql = "SELECT * FROM user LIMIT 2 OFFSET 1"

myCursor.execute(sql)
result = myCursor.fetchall()  # fetchall() 获取所有记录

for x in result:
    print(x)

python">python">(2, 'LiLei', '13866668888', 'China')
(3, 'Jim', '13855558888', 'America')

六、删除记录

删除记录使用 "DELETE FROM" 语句：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()
sql = "DELETE FROM user WHERE name = 'Jim'"

myCursor.execute(sql)
mydb.commit()

print(myCursor.rowcount, " 条记录删除")

python">python">1  条记录删除

  • 为了防止数据库查询发生 SQL 注入的攻击，我们可以使用 %s 占位符来转义删除语句的条件：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()

sql = "DELETE FROM user WHERE name = %s"
param = ("HanMeimei",)

myCursor.execute(sql, param)
mydb.commit()

print(myCursor.rowcount, " 条记录删除")

python">python">1  条记录删除

七、更新表数据

数据表更新使用 "UPDATE" 语句：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()

sql = "UPDATE user SET name = 'Lucy' WHERE name = 'Lily'"

myCursor.execute(sql)
mydb.commit()

print(myCursor.rowcount, " 条记录被修改")

python">python">1  条记录被修改

  • 为了防止数据库查询发生 SQL 注入的攻击，我们可以使用 %s 占位符来转义更新语句的条件：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()

sql = "UPDATE user SET name = %s WHERE name = %s"
param = ("HanMeimei", "LiLei")

myCursor.execute(sql, param)
mydb.commit()

print(myCursor.rowcount, " 条记录被修改")

python">python">1  条记录被修改

八、删除表

删除表使用 "DROP TABLE" 语句， IF EXISTS 关键字是用于判断表是否存在，只有在存在的情况才删除：

python">python"># coding=utf-8

import mysql.connector

mydb = mysql.connector.connect(
    host="127.0.0.1",  # 数据库主机地址
    user="root",  # 数据库用户名
    passwd="root",  # 数据库密码
    database="python_demo"  # 指定数据库
)

myCursor = mydb.cursor()

myCursor.execute("SHOW TABLES")

for x in myCursor:
    print(x)

sql = "DROP TABLE IF EXISTS user_info"  # 删除数据表 user_info
myCursor.execute(sql)

print(" 删除数据表 user_info")

myCursor.execute("SHOW TABLES")

for x in myCursor:
    print(x)

python">python">('user',)
('user_info',)
 删除数据表 user_info
('user',)


http://www.niftyadmin.cn/n/114323.html

相关文章

SYSU程设c++（第二周） string、函数重载、constexpr、auto

SYSU程设c++（第二周） string、函数重载、constexpr、auto

创建string对象&#xff1a; string s1; // s1 未使用初始化参数&#xff0c;即默认初始化为空字符串 string s2 "c" ; //不是赋值运算&#xff0c;它等价于 string s2("c") ,是初始化 string s3 (5, s); // s4 初始化为 5 个 s&#xff1b; string…
阅读更多...
计算机网络安全基础知识2：http超文本传输协议，请求request消息的get和post，响应response消息的格式，响应状态码

计算机网络安全基础知识2：http超文本传输协议，请求request消息的get和post，响应response消息的格式，响应状态码

计算机网络安全基础知识&#xff1a; 2022找工作是学历、能力和运气的超强结合体&#xff0c;遇到寒冬&#xff0c;大厂不招人&#xff0c;可能很多算法学生都得去找开发&#xff0c;测开 测开的话&#xff0c;你就得学数据库&#xff0c;sql&#xff0c;oracle&#xff0c;尤…
阅读更多...
Oracle 使用SQL*Loader导入文本数据

Oracle 使用SQL*Loader导入文本数据

把txt或者csv文件导入oracle最方便的方法是通过plsql的文本导入器导入&#xff0c;但是导入大批量数据时文本导入器效率慢&#xff0c;可以使用oracle命令行sqlldr导入更快速。 sqlldr介绍&#xff1a; SQL*Loader将外部文件中的数据加载到Oracle数据库表中&#xff0c;SQL使…
阅读更多...
sdwan方案有哪些 SD-WAN怎么搭建

sdwan方案有哪些 SD-WAN怎么搭建

随着sdwan网络架构的形成到目前的广泛应用到各行业之中&#xff0c;足见sdwan方案已经逐步的走向成熟。sdwan软件定义网络可在包括公共Internet&#xff0c;MPLS和宽带在内的标准网络传输服务上运行&#xff0c;解决了很多跨区域之间网络传输数据的难题。那么&#xff0c;sdwan…
阅读更多...
【项目实战】为什么我选择使用CloseableHttpClient，而不是HttpClient，他们俩有什么区别？

【项目实战】为什么我选择使用CloseableHttpClient，而不是HttpClient，他们俩有什么区别？

一、HttpClient介绍 HttpClient是Commons HttpClient的老版本&#xff0c;已被抛弃&#xff0c;不推荐使用&#xff1b; HttpClient是一个接口&#xff0c;定义了客户端HTTP协议的操作方法。 它可以用于发送HTTP请求和接收HTTP响应。 HttpClient接口提供了很多方法来定制请求…
阅读更多...
Centos7 + Django外网无法访问

Centos7 + Django外网无法访问

问题一、Centos7&#xff0c;放开防火墙端口访问8000&#xff0c;浏览器访问时仍然找不到网址 在防火墙启动的状态下开放端口firewall-cmd --zonepublic --add-port8000/tcp --permanent然后刷新防火墙systemctl reload firewalld systemctl restart firewalld(ll_env) [rootl…
阅读更多...
【文本对齐】

【文本对齐】

提示：文章写完后，目录可以自动生成，如何生成可参考右边的帮助文档 文章目录 前言一、一级标题二级标题三级标题四级标题五级标题六级标题总结前言 提示：这里可以添加本文要记录的大概内容： 例如：以下是官方博客例子浅析 先加入相关的头文件和库文件。 提示：以下是本篇…
阅读更多...
网络安全入门学习：社会工程学

网络安全入门学习：社会工程学

在电影《我是谁&#xff1a;没有绝对安全的系统》中&#xff0c;主角本杰明充分利用自己高超的黑客技术&#xff0c;非法入侵国际安全系统&#xff0c;并在最后逃之夭夭。在电影中&#xff0c;有一句经典的台词&#xff1a; 所有黑客手段中最有效的、最伟大的幻想艺术——社会…
阅读更多...
最新文章

Copyright @ 2022~2023