Pycharm访问MySQL数据库·下

🕗 发布于 2024-12-13 09:55 数据库 pycharm mysql

1.数据库连接池

1.1 什么是连接池

连接池（Connection Pool）是一种用于管理数据库连接的技术。它通过预先创建一组数据库连接，并在需要时将这些连接提供给应用程序，从而避免了频繁地打开和关闭数据库连接的开销。

连接池在代码中的作用：

资源复用：连接池预先创建了一定数量的数据库连接，并存储在池中。当应用程序需要与数据库交互时，它可以从连接池中获取一个已经建立的连接，而不是每次都创建新的连接。这样可以显著减少创建和销毁连接的开销。

1.2 连接池案例

# 构建连接池工具
import mysql.connector.pooling
config = {
    "host": "localhost",
    "port": 3306,
    "user": "root",
    "password": "888888",
    "database": "demo"
}
try:
    #创建连接池 pool_size=10：连接池的连接数量
    pool = mysql.connector.pooling.MySQLConnectionPool(**config,pool_size=10)
    #从连接池中获得连接项
    conn = pool.get_connection()
    conn.start_transaction() # 开启事务
    cursor = conn.cursor()
    sql = "update t_emp set sal = %s where ename = %s"
    cursor.execute(sql,(2000,"ZOYA"))
    conn.commit()
except Exception as e:
    print(e) # 打印异常信息，用于分析异常问题
    if "conn" in dir():
        conn.rollback()

2.Connector删除数据

2.1 Truncate table与Delete

截断数据表（TRUNCATE TABLE）是一个SQL命令，用于快速删除数据库表中的所有行。

截断数据表用于整表删除,不能回滚，且不能写where条件。

与DELETE相比，速度远远高于delete,数据量越多效果越明显。

2.2 删除表实例

import mysql.connector.pooling
config = {
    "host": "localhost",
    "port": 3306,
    "user": "root",
    "password": "888888",
    "database": "demo"
}
try:
    pool = mysql.connector.pooling.MySQLConnectionPool(**config,pool_size=10)
    conn = pool.get_connection()
    conn.start_transaction()
    cursor = conn.cursor()
    # sql = "delete from t_emp"
    # 截断数据表
    sql = "truncate table t_emp"
    cursor.execute(sql)
    conn.commit()
except Exception as e:
    print(e) # 打印异常信息，用于分析异常问题
    if "conn" in dir():
        conn.rollback()

3.循环执行SQL语句

import mysql.connector.pooling
config = {
    "host": "localhost",
    "port": 3306,
    "user": "root",
    "password": "888888",
    "database": "demo"
}
try:
    pool = mysql.connector.pooling.MySQLConnectionPool(**config,pool_size=10)
    conn = pool.get_connection()
    conn.start_transaction()
    cursor = conn.cursor()
    # 循环执行sql语句
    sql = "insert into t_dept(deptno,dname,loc)values(%s,%s,%s)"
    data = [[120,"C部门","沈阳"],[130,"D部门","大连"]]
    cursor.executemany(sql,data) # 执行循环操
    conn.commit()
except Exception as e:
    print(e) # 打印异常信息，用于分析异常问题
    if "conn" in dir():
        conn.rollback()

4.综合练习

4.1 练习一

使用INSERT语句，把部门平均底薪超过公司平均底薪的这个部门里的员工信息导入到t_emp_new表里面，并且让这些员工隶属于sales部门。

编程思路：

构建连接池：使用mysql.connector.pooling.MySQLConnectionPool创建一个连接池，配置信息包括主机、端口、用户名、密码和数据库名。
获取连接并开启事务：从连接池中获取一个连接，并开启事务。
删除数据表t_emp_new：为了避免重名，首先删除已存在的t_emp_new表。
创建数据表t_emp_new：创建一个新的表t_emp_new，结构与t_emp表相同。
计算平均底薪：查询t_emp表的平均底薪。
查询大于平均底薪的部门：查询t_emp表中，平均底薪大于或等于上一步计算出的平均底薪的部门编号。
向新表中添加数据：将上一步查询出的部门的数据插入到t_emp_new表中。
删除原表t_emp中的数据：删除t_emp表中大于平均底薪的部门信息。注意：这里有一个小错误，表名应该是t_emp而不是t_emp_。
查询部门编号：查询t_emp表中部门名为SALES的部门编号。
更新表中的部门编号：更新t_emp_new表中的所有记录的部门编号为上一步查询出的SALES部门编号。
异常处理：捕获并打印异常信息，如果发生异常则回滚事务。

import mysql.connector.pooling
config = {
    "host": "localhost",
    "port": 3306,
    "user": "root",
    "password": "888888",
    "database": "demo"
}
try:
    pool = mysql.connector.pooling.MySQLConnectionPool(**config,pool_size=10)
    conn = pool.get_connection()
    conn.start_transaction()
    cursor = conn.cursor()
    # 1.删除数据表t_emp_new,避免重名
    sql = "drop table t_emp_new"
    cursor.execute(sql)
    # 2.创建数据表t_emp_new
    # sql = "create table t_emp_new as (select * from t_emp)"
    sql = "create table t_emp_new like t_emp"
    cursor.execute(sql)
    # 3.完成业务 ①获得平均底薪
    sql = "select avg(sal) as avg from t_emp"
    cursor.execute(sql)
    avg = cursor.fetchone()[0]
    # ②查询大于平均底薪的部门
    sql = "select deptno from t_emp group by deptno having avg(sal) >= %s"
    cursor.execute(sql, [avg])
    temp = cursor.fetchall()
    # ③向新表中添加②中查询出的数据
    sql = "insert into t_emp_new select * from t_emp where deptno in ("
    for index in range(len(temp)):
        one = temp[index][0]
        if index < len(temp) - 1:
            sql += str(one)+ ","
        else:
            sql += str(one)
    sql += ")"
    cursor.execute(sql)
    # ④删除原表t_emp大于平均底薪的部门信息,SQL片段
    sql = "delete from t_emp where deptno in ("
    for index in range(len(temp)):
        one = temp[index][0]
        if index < len(temp) - 1:
            sql += str(one) + ","
        else:
            sql += str(one)
    sql += ")"
    cursor.execute(sql)
    # ⑤查询部门编号
    sql = "select deptno from t_dept where dname=%s"
    cursor.execute(sql, ['SALES'])
    deptno = cursor.fetchone()[0]
    # ⑥更新表中的部门编号
    sql = "update t_emp_new set deptno=%s"
    cursor.execute(sql, [deptno])
    conn.commit()
except Exception as e:
    print(e) # 打印异常信息，用于分析异常问题
    if "conn" in dir():
        conn.rollback()

4.2 练习二

编写一个INSERT语句向部门表插入两条记录，每条记录都在部门原有最大主键值的基础上+10。

import mysql.connector.pooling
config = {
    "host": "localhost",
    "port": 3306,
    "user": "root",
    "password": "888888",
    "database": "demo"
}
try:
    pool = mysql.connector.pooling.MySQLConnectionPool(**config,pool_size=10)
    conn = pool.get_connection()
    conn.start_transaction()
    cursor = conn.cursor()
    #完成业务
    sql = "insert into t_dept (select max(deptno)+10,%s,%s from t_dept union select max(deptno)+20,%s,%s from t_dept)"
    cursor.execute(sql,("A部门","北京","B部门","上海"))
    conn.commit()
except Exception as e:
    print(e) # 打印异常信息，用于分析异常问题
    if "conn" in dir():
        conn.rollback()

原文地址：https://blog.csdn.net/Tttian622/article/details/144418147

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：【代码pycharm】动手学深度学习v2-09 Softmax 回归 + 损失函数 + 图片分类数据集
下一篇：VScode 配置 debug环境

.NET(C#) 如何配置用户首选项及保存用户设置
.NET(C#) 如何配置用户首选项及保存用户设置
阅读更多2024-12-14
【最新】北大数字普惠金融指数数据集-省市县（2011-2023年）
郭峰,王靖一,王芳,孔涛,张勋,程志云.测度中国数字普惠金融发展:指数编制与空间特征[J].经济学(季刊),2020,19(04):1401-1418.时间跨度：省级和城市级指数时间跨度为2011-2
阅读更多2024-12-14
GESP202412 四级【Recamán】题解（AC）
a11ak−1−kkakak−1−kak−1k小杨想知道 Recamán 数列的前n项从小到大排序后的结果。手动计算非常困难，小杨希望你能帮他解决这个问题。
阅读更多2024-12-14
IDEA遇到EasyConnect中的网络资源无法访问的问题
版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。原文链接：https://blog.csdn.net/wanshanyu_/article/de
阅读更多2024-12-14
双目摄像头标定方法
此时已经完成标定，左下角为反投影误差，右边为外参可视化。将双目左右目拍的图像上传（左右目最好不少于20张）此时回到主页面，即可看到成功导出。把这些误差大的删除即可。
阅读更多2024-12-14
Servlet、omcat服务器架构与工作原理
Servlet是运行在服务器端的Java程序，它的主要职责之一是接收并处理来自客户端（如浏览器）的HTTP请求。当客户端发送一个请求到服务器时，Servlet可以解析请求中的信息，例如请求的URL路径
阅读更多2024-12-14
Vue生命周期钩子函数：深入解析与实践
作为高级Vue前端开发人员，对Vue组件的生命周期钩子函数有着深刻的理解是至关重要的。生命周期钩子函数是指在Vue组件的创建、更新、销毁等过程中，Vue自动调用的一系列方法。通过这些钩子函数，我们可以
阅读更多2024-12-14
安卓开发--使用android studio发布APP
app发布
阅读更多2024-12-14
数据结构与算法学习笔记----拓扑排序
@ author: 明月清了个风。
阅读更多2024-12-14
python 将数据保存到现有的Excel文件的新工作表
out_file = ‘query.xlsx’df1 = pd.DataFrame(out_data)若直接写入：df1.to_excel(out_file, index=False, sheet_n
阅读更多2024-12-14