当前位置：首页 > news >正文

【Python】mysql数据库增删查改

news 来源：原创 2025/5/23 8:06:30

操作总结

该处使用的是pymysql，也可以选择使用其他的

创建表

import pymysql

# 连接到数据库
try:
    db = pymysql.connect(
        host="192.168.1.170",
        user="aics",
        password="aics",
        port=3306,
        database="aics"  # 使用已存在的数据库aics
    )
    print("数据库连接成功")
except pymysql.MySQLError as err:
    print(f"数据库连接失败: {err}")
    exit(1)  # 连接失败则退出程序

# 创建游标对象
cursor = db.cursor()

# 创建数据库表
def create_table():
    try:
        query = '''
        CREATE TABLE IF NOT EXISTS your_table_name (
            id INT AUTO_INCREMENT PRIMARY KEY,
            column1 VARCHAR(255),
            column2 VARCHAR(255)
        )
        '''
        cursor.execute(query)
        print("表格创建成功或已经存在")
    except Exception as e:
        print(f"创建表格时出错: {e}")

数据表中插入数据

def insert_data():
    try:
        query = "INSERT INTO your_table_name (column1, column2) VALUES (%s, %s)"
        values = ("001", "小明")  # 数据插入值
        cursor.execute(query, values)
        query = "INSERT INTO your_table_name (column1, column2) VALUES (%s, %s)"
        values = ("002", "小红")  # 数据插入值
        cursor.execute(query, values)
        db.commit()  # 提交更改
        print("数据插入成功")
    except Exception as e:
        db.rollback()  # 发生错误时回滚
        print(f"插入数据时出错: {e}")

# 调用插入数据函数
insert_data()

查看数据库中所有的数据

def query_all_data():
    try:
        query = "SELECT * FROM your_table_name"
        cursor.execute(query)
        results = cursor.fetchall()
        if results:
            for row in results:
                print(row)
        else:
            print("没有查询到数据")
    except Exception as e:
        print(f"查询数据时出错: {e}")

删除用户数据

def delete_data():
    try:
        query = "DELETE FROM your_table_name WHERE column1 = %s"
        value = ("001",)  # 根据某一列的值删除数据
        cursor.execute(query, value)
        db.commit()  # 提交更改
        print(f"已删除值为 '{value[0]}' 的数据")
    except Exception as e:
        db.rollback()  # 发生错误时回滚
        print(f"删除数据时出错: {e}")