pymysql数据查询更新

以下是使用pymysql进行数据查询和更新的示例：

1. 数据查询：

import pymysql
import pandas as pd

def con_sql(db, sql):
    # 创建连接
    db = pymysql.connect(host='127.0.0.1', port=3308, user='name', passwd='password', db=db, charset='utf8')
    # 创建游标
    cursor = db.cursor()
    # 执行SQL语句
    cursor.execute(sql)
    # 获取查询结果
    result = cursor.fetchall()
    # 将结果转为DataFrame实例
    df = pd.DataFrame(result)
    # 关闭游标和连接
    cursor.close()
    db.close()
    return df

# 示例查询语句
sql = "SELECT * FROM table_name"
# 调用函数进行查询
df = con_sql('database_name', sql)
# 打印查询结果
print(df)

2. 数据更新：

import pymysql

def update_sql(db, sql):
    # 创建连接
    db = pymysql.connect(host='127.0.0.1', port=3308, user='name', passwd='password', db=db, charset='utf8')
    # 创建游标
    cursor = db.cursor()
    # 执行SQL语句
    cursor.execute(sql)
    # 提交事务
    db.commit()
    # 关闭游标和连接
    cursor.close()
    db.close()

# 示例更新语句
sql = "UPDATE table_name SET column_name = 'new_value' WHERE condition"
# 调用函数进行更新
update_sql('database_name', sql)