Python连接MySQL数据库(简单便捷)

Posted 2023-04-08 Enovo_飞鱼

🐒，本文中，使用到的工具有：Pycharm，Anaconda，mysql 5.5，spyder(Anaconda)

什么是 PyMySQL？

PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库，Python2 中则使用 mysqldb。

一、🏔环境准备

1、安装pymysql：

进行Python连接mysql数据库之前，需要先安装一下pymysql。

直接在终端执行下面的命令即可。(在此处我将指定1.0.2版本)

pip install pymysql==1.0.2

2、查询安装：

下载完成后，在终端输入 pip list 即可看到下图：

pip list

可以看到我们的PyMySQL是1.0.2版本的。

3、Anaconda下载pymysql：

打开Anaconda，选择 Environments 点击右上方的的搜索框 输入 pymysql

 点击方框，即可下载

方式一🏔：

        此处我们可以选择 spyder 或者 pycharm 首先为大家介绍一下 spyder 我们只需要直接导入 pymysql 库即可 

方式二🏔： 

        4、Pycharm下载pymysql

打开 Pycharm 选择文件，点击设置，

 下划，选择python解释器，这里我的Pycharm已经配置了Anaconda环境

如果没有查询到 pymysql 可以在 Pycharm 终端中下载 pymysql 库

以上我们的环境就准备好了，下面我们进行编写程序 ☀

 二、🏔代码编写，连接数据库

1、导入数据库表 

import pymysql

 数据库连接：

连接数据库前，请先确认以下事项：

• 连接数据库使用的用户名为 "root" ，密码为 "dai324542",创建了数据库 runoob
• 你可以可以自己设定或者直接使用root用户名及其密码

db = pymysql.connect(host='localhost',
                     user='root',
                     password='dai324542',
                     database='runoob',
                     charset='utf8')
 
# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()
 
# 使用 execute()  方法执行 SQL 查询 
cursor.execute("SELECT VERSION()")
 
# 使用 fetchone() 方法获取单条数据.
data = cursor.fetchone()
 
print ("数据库连接成功！")
 
# 关闭数据库连接
db.close()

 2、创建数据库表

# 创建表
sql="""CREATE TABLE test (
          FIRST_  CHAR(20) NOT NULL,
          SECOND_  CHAR(20),
          THIRD_ INT,
          FOURTH_ CHAR(1),
          FIFTH_ FLOAT )"""
# 运行sql语句
cursor.execute(sql)

这里我们所运用的sql语句是不是很熟悉了😊

下面即是运行结果了，再mysql中可以刷新看到，我输出了一个提示 victory 

 

 3、数据库插入操作

此处我只是随便进行了一个举例，通过更改创建表时的操作可以插入不同类型的数据

try:
    sql = "insert into test(FIRST_,SECOND_,THIRD_,FOURTH_,FIFTH_) values ('MAC','MOTH','20','M','2000')"

    # 运行sql语句
    cursor.execute(sql)
    # 修改
    db.commit()
    # 关闭游标
    cursor.close()
    # 关闭连接
    db.close()
    print("victory!")
except:
    print("false")

 4、查询其中一个表的数据

# 查询语句
try:
    cursor = db.cursor()
    sql = "select * from student"
    cursor.execute(sql)
    result = cursor.fetchall()
    for data in result:
        print(data)
except Exception:
    print("查询失败")

 

 5、删除表中的一条数据

# SQL 删除语句
sql = "DELETE FROM student WHERE Sno='20111107'"
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 向数据库提交
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()
# 关闭连接
db.close()
# 成功提示
print("victory!")

注意：Python中的MySQL默认事务打开，需要我们手动提交事务，否则操作无效

写到这里，这篇博客就又又又结束了，很感谢大家的观看，如果对大家有所帮助希望可以留下一个小小的👍，🙇‍。因才学疏浅，如果各位大佬发现其中存在错误，敬请指出，(ง •_•)ง！

Python3.5 MySQL 数据库连接

Python3.5  MySQL 数据库连接

在本文中介绍 Python3 使用PyMySQL连接数据库，并实现简单的增删改查

为什么使用PyMySQL？

　　PyMySQL是在Pyhton3.x版本中用于连接MySQL数据库的一个库，Python2中则使用mysqldb库。

PyMySQL安装

　　在使用PyMySQL之前，需要确保安装PyMySQL库。

可以使用pip进行安装

　　

pip install PyMySQL

 数据库连接

连接数据库前，请先确认以下事项：

• 您已经创建了数据库 TESTDB.
• 在TESTDB数据库中您已经创建了表 t_table
• t_table表字段为 FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。
• 连接数据库TESTDB使用的用户名为 "testuser" ，密码为 "test123",你可以可以自己设定或者直接使用root用户名及其密码，Mysql数据库用户授权请使用Grant命令。

实例

以下示例是连接MySQL数据库中的TESTDB数据库：

#!/usr/bin/python3

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()

# 使用 execute()  方法执行 SQL 查询 
cursor.execute("SELECT VERSION()")

# 使用 fetchone() 方法获取单条数据.
data = cursor.fetchone()

print ("Database version : %s " % data)

# 关闭数据库连接
db.close()

创建数据库表

如果数据库连接存在，可以使用execute()方法为数据库创建表，如下所示创建表t_table

#!/usr/bin/python3

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()

# 使用 execute() 方法执行 SQL，如果表存在则删除
cursor.execute("DROP TABLE IF EXISTS t_table")

# 使用预处理语句创建表
sql = """CREATE TABLE t_table(
         FIRST_NAME  CHAR(20) NOT NULL,
         LAST_NAME  CHAR(20),
         AGE INT,  
         SEX CHAR(1),
         INCOME FLOAT )"""

cursor.execute(sql)

# 关闭数据库连接
db.close()

数据库插入操作

以下示例使用执行SQL insert 语句 向表t_table中插入一条记录：

#!/usr/bin/python3

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 插入语句
sql = """INSERT INTO t_table(FIRST_NAME,
         LAST_NAME, AGE, SEX, INCOME)
         VALUES (‘Mac‘, ‘Mohan‘, 20, ‘M‘, 2000)"""
try:
   # 执行sql语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # 如果发生错误则回滚
   db.rollback()

# 关闭数据库连接
db.close()

数据库查询操作

Python查询MySQL使用fetchone()方法获取单条记录，使用fetchall()方法获取多条记录。

• fetchone()：该方法获取下一个查询结果集，结果集是一个对象
• fetchall():该方法接收全部返回结果集
• fetchnum(n)
• rowcount:这是一个只读属性，并返回执行execute()方法后影响的行数

#!/usr/bin/python3

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 查询语句
sql = "SELECT * FROM t_table        WHERE INCOME > ‘%d‘" % (1000)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 获取所有记录列表
   results = cursor.fetchall()
   for row in results:
      fname = row[0]
      lname = row[1]
      age = row[2]
      sex = row[3]
      income = row[4]
       # 打印结果
      print ("fname=%s,lname=%s,age=%d,sex=%s,income=%d" %              (fname, lname, age, sex, income ))
except:
   print ("Error: unable to fecth data")

# 关闭数据库连接
db.close()

以上脚本执行结果如下：

fname=Mac, lname=Mohan, age=20, sex=M, income=2000

 

数据库更新操作

更新操作用于更新数据表的的数据，以下实例将 t_table表中的 SEX 字段全部修改为 ‘M‘，AGE 字段递增1：

 

#!/usr/bin/python3

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 更新语句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1
                          WHERE SEX = ‘%c‘" % (‘M‘)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 提交到数据库执行
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()

# 关闭数据库连接
db.close()

删除操作

#!/usr/bin/python3

import pymysql

# 打开数据库连接
db = pymysql.connect("localhost","testuser","test123","TESTDB" )

# 使用cursor()方法获取操作游标 
cursor = db.cursor()

# SQL 删除语句
sql = "DELETE FROM t_table WHERE AGE > ‘%d‘" % (20)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 提交修改
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()

# 关闭连接
db.close()

执行事务

事务机制可以确保数据一致性。

事务应该具有4个属性：原子性、一致性、隔离性、持久性。这四个属性通常称为ACID特性。

• 原子性（atomicity）。一个事务是一个不可分割的工作单位，事务中包括的诸操作要么都做，要么都不做。
• 一致性（consistency）。事务必须是使数据库从一个一致性状态变到另一个一致性状态。一致性与原子性是密切相关的。
• 隔离性（isolation）。一个事务的执行不能被其他事务干扰。即一个事务内部的操作及使用的数据对并发的其他事务是隔离的，并发执行的各个事务之间不能互相干扰。
• 持久性（durability）。持续性也称永久性（permanence），指一个事务一旦提交，它对数据库中数据的改变就应该是永久性的。接下来的其他操作或故障不应该对其有任何影响。

Python DB API 2.0 的事务提供了两个方法 commit 或 rollback。

# SQL删除记录语句
sql = "DELETE FROM EMPLOYEE WHERE AGE > ‘%d‘" % (20)
try:
   # 执行SQL语句
   cursor.execute(sql)
   # 向数据库提交
   db.commit()
except:
   # 发生错误时回滚
   db.rollback()

 

对于支持事务的数据库， 在Python数据库编程中，当游标建立之时，就自动开始了一个隐形的数据库事务。

commit()方法游标的所有更新操作，rollback（）方法回滚当前游标的所有操作。每一个方法都开始了一个新的事务。

 

 

转自：http://www.runoob.com/python3/python3-mysql.html