python连接数据库

太过爱你忘了你带给我的痛 2024-03-27 08:59 74阅读 0赞

## python连接数据库 ##

### 安装 ###

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

PyMySQL 遵循 Python 数据库 API v2.0 规范，并包含了 pure-Python MySQL 客户端库。

首先是安装环境,下载pymysql

`pip3 install pymysql`  
![在这里插入图片描述][63c69e5aa5374100bf0e04851904f04c.png]

### 代码演示 ###

#### 连接数据库 ####

打开Navicat在其中选择一个数据库进行演示，我这里就选择了projectdatabase进行演示。

![在这里插入图片描述][ed619e387e3445e5bbab075832b837cc.png]

**导入库**  
`import pymysql`

**连接数据库的代码**  
放好自己的配置文件信息，本地就是localhost，其他的地方的就是按照别人的域名来看，然后就是用户名，密码，数据库的名字。

**运行结果**  
![在这里插入图片描述][a5fdadb42ddd411f9d7c9a9713a7d8d8.png]

#### 创建新表 ####

1、声明一个游标

`cur = db.cursor()`

2、创建表之前先检查是否存在，如果存在则删除

`cur.execute('DROP TABLE IF EXISTS Student')`

3、编辑sql语句

sqlQuery = "CREATE TABLE Student(Name CHAR(20) NOT NULL ,Email CHAR(20),Age int )"
    
    cur.execute(sqlQuery)

**完整代码**

import pymysql
    DBHOST = 'localhost'
    DBUSER = 'root'
    DBPASS = '123456'
    DBNAME = 'projectdatabase'
    
    try:
        db = pymysql.connect(host=DBHOST,user=DBUSER, password=DBPASS, database=DBNAME)
        print('数据库连接成功!')
    except pymysql.Error as e:
        print('数据库连接失败'+str(e))
    
    # 这里创建游标
    cur = db.cursor()
    cur.execute('DROP TABLE IF EXISTS Student')
    # 这里输入sql语句
    sqlQuery = "CREATE TABLE Student(Name CHAR(20) NOT NULL ,Email CHAR(20),Age int )"
    
    cur.execute(sqlQuery)

**运行结果**  
![在这里插入图片描述][7f39172cc6bd4676ad7a4b6fe4692150.png]

#### 插入数据 ####

**编写sql语句**

sqlQuery=" INSERT INTO Student (Name, Email, Age) VALUE (%s,%s,%s) "

**设置具体的值**

value=('jake','123456@qq.com',20)

**完整代码**

import pymysql
    DBHOST = 'localhost'
    DBUSER = 'root'
    DBPASS = '123456'
    DBNAME = 'projectdatabase'
    
    try:
        db = pymysql.connect(host=DBHOST,user=DBUSER, password=DBPASS, database=DBNAME)
        print('数据库连接成功!')
        # 这里创建游标
        cur = db.cursor()
        
        # 这里输入sql语句
        sqlQuery = " INSERT INTO Student (Name, Email, Age) VALUE (%s,%s,%s) "
        value = ('jake', '123456@qq.com', 20)
        cur.execute(sqlQuery, value)
    
        db.commit()
        print('数据插入成功！')
    except pymysql.Error as e:
        print("数据插入失败：" + str(e))
        # 如果数据插入失败的话 就事件回滚
        db.rollback()
    
    db.close()

**运行结果**  
![在这里插入图片描述][96ab9cbead424976babc0c6091a94e92.png]  
![在这里插入图片描述][6b851091474344d38d313738d9902b43.png]

#### 查询全部数据 ####

**编写sql语句**  
`sqlQuery = "SELECT * FROM Student"`

**完整代码**  
python的这个代码有点奇怪，特别需要注意的是这游标需要先执行运行这个sql语句，之后才可以执行fetchall方法，不然会查询失败。

import pymysql
    DBHOST = 'localhost'
    DBUSER = 'root'
    DBPASS = '123456'
    DBNAME = 'projectdatabase'
    
    try:
        db = pymysql.connect(host=DBHOST,user=DBUSER, password=DBPASS, database=DBNAME)
        print('数据库连接成功!')
        # 这里创建游标
        cur = db.cursor()
    
        # 这里输入sql语句
        sqlQuery = "SELECT * FROM Student"
        col = cur.execute(sqlQuery) # 查询之前需要先运行sql语句
        results = cur.fetchall() # 只有上面先运行了sql语句这句话才可以运行成功
        print(col) # 结果为影响的条数
        for row in results:
            name = row[0]
            email = row[1]
            age = row[2]
            print('Name:%s,Email:%s,Age:%s'%(name,email,age))
    except pymysql.Error as e:
        print("数据查询失败：" + str(e))
    
    db.close()

**运行结果**  
![在这里插入图片描述][e5275e419ecf44aa88b1a54e2515d7cb.png]

#### 更新表中的数据 ####

**编写sql语句**  
`sqlQuery = "UPDATE Student SET Name= %s WHERE Name=%s"`  
`value = ('John', 'jake')`  
**完整代码**

import pymysql
    DBHOST = 'localhost'
    DBUSER = 'root'
    DBPASS = '123456'
    DBNAME = 'projectdatabase'
    
    try:
        db = pymysql.connect(host=DBHOST,user=DBUSER, password=DBPASS, database=DBNAME)
        print('数据库连接成功!')
        # 这里创建游标
        cur = db.cursor()
    
        # 这里输入sql语句
        sqlQuery = "UPDATE Student SET Name= %s WHERE Name=%s"
        value = ('John', 'jake')
    
        cur.execute(sqlQuery, value)
        db.commit()
        print('数据更新成功！')
    except pymysql.Error as e:
        print("数据更新失败：" + str(e))
        # 发生错误时回滚
        db.rollback()
    
    
    db.close()

**运行结果**  
通过运行结果可以看出来，对于表格的更新成功了。  
![在这里插入图片描述][4ddae775d6234c57a6da48f5b4b2ff00.png]  
![在这里插入图片描述][cc490c3994dd489ea3763dfc9374d9cc.png]

#### 删除表中的数据 ####

**编写sql语句**

sqlQuery = "delete from student where name=%s"
    value = ('John')

**完整代码**

import pymysql
    DBHOST = 'localhost'
    DBUSER = 'root'
    DBPASS = '123456'
    DBNAME = 'projectdatabase'
    
    try:
        db = pymysql.connect(host=DBHOST,user=DBUSER, password=DBPASS, database=DBNAME)
        print('数据库连接成功!')
        # 这里创建游标
        cur = db.cursor()
    
        # 这里输入sql语句
        sqlQuery = "delete from student where name=%s"
        value = ('John')
    
        cur.execute(sqlQuery, value)
        db.commit()
        print('数据更新成功！')
    except pymysql.Error as e:
        print("数据更新失败：" + str(e))
        # 发生错误时回滚
        db.rollback()
    db.close()

**运行结果**  
数据库中的对应的数据也被删除了。  
![在这里插入图片描述][fda2f7b35a4440cfbd4a58e5e4edbf75.png]  
![在这里插入图片描述][2a6debdad2ac497ba533959e0ef169eb.png]

#### 删除一张表 ####

**编写sql语句**  
`sqlQuery='DROP TABLE IF EXISTS Student'`

**完整代码**

import pymysql
    DBHOST = 'localhost'
    DBUSER = 'root'
    DBPASS = '123456'
    DBNAME = 'projectdatabase'
    
    try:
        db = pymysql.connect(host=DBHOST,user=DBUSER, password=DBPASS, database=DBNAME)
        print('数据库连接成功!')
        # 这里创建游标
        cur = db.cursor()
    
        # 这里输入sql语句
        sqlQuery='DROP TABLE IF EXISTS Student'
        cur.execute(sqlQuery)
        db.commit()
        print('数据表删除成功！')
    except pymysql.Error as e:
        print("数据表删除失败：" + str(e))
        # 发生错误时回滚
        db.rollback()
    db.close()

**运行结果**  
数据库中的这张表也不见了。  
![在这里插入图片描述][ce501b63a5a143aab2af5d54136f21fb.png]  
![在这里插入图片描述][c9c88e8d23eb4e61be39803c0807aa22.png]

[63c69e5aa5374100bf0e04851904f04c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/eb1198e08bfe4367855fda4523ae03d6.png
[ed619e387e3445e5bbab075832b837cc.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/eb256e2885da4eca9c56e9c79ddcbbf7.png
[a5fdadb42ddd411f9d7c9a9713a7d8d8.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/3a4c36ff768543979dd1c0d3feeef9f5.png
[7f39172cc6bd4676ad7a4b6fe4692150.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/60f9f91d54564ae5add0d439ab734602.png
[96ab9cbead424976babc0c6091a94e92.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/f7dae6ccdd084e0d83fc62c21f328cb0.png
[6b851091474344d38d313738d9902b43.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/d4f21dcfd8464ff2b2fa33e1ffa8a24e.png
[e5275e419ecf44aa88b1a54e2515d7cb.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/73f169cb8a89410dba26d8e6af6a526c.png
[4ddae775d6234c57a6da48f5b4b2ff00.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/1093acc077e249d4825a925eea268c37.png
[cc490c3994dd489ea3763dfc9374d9cc.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/a07e619bbf0d448ba97c44472819ac75.png
[fda2f7b35a4440cfbd4a58e5e4edbf75.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/2653c9ee2ce44fa383201d766a017bd2.png
[2a6debdad2ac497ba533959e0ef169eb.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/e774674b4bd44565831ec41d9d69d544.png
[ce501b63a5a143aab2af5d54136f21fb.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/e376ecf40162400bb2421f7a87a742e1.png
[c9c88e8d23eb4e61be39803c0807aa22.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/5ccbf94bfe9e4765a893b69138e0903c.png