pymysq与pandasl查询带上字段名，删除与修改某一列数据

import pymysql
import pandas as pd

conn = pymysql.connect(
    host=‘127.0.0.1‘,
    port=3306,
    user=‘root‘,
    password=‘&mpegsQp‘,
    db=‘test‘,
    charset=‘utf8‘,
    # 这里加上配置之后，查询的时候会带上字段名
    cursorclass=pymysql.cursors.DictCursor
)

cursor = conn.cursor()
def save_to_par():
    try:
        sql = """
            select * from asharettmandmrq;
        """
        cursor.execute(sql)
        conn.commit()
        res2 = cursor.fetchall()

        df = pd.DataFrame(res2)
        # 删除某一列的数据
        df = df.drop(columns=[‘OBJECT_ID‘])

        # 对某一列的数据进行操作
        df[‘S_INFO_WINDCODE‘] = df[‘S_INFO_WINDCODE‘].map(lambda x: x.split(‘.‘)[0])
        df.to_parquet(‘/data/par/ttm_mrq.par‘)
        print(df)
        cursor.close()
        conn.close()

    except Exception as e:
        print(e)
        cursor.close()
        conn.close()


if __name__ == ‘__main__‘:
    save_to_par()

pymysq与pandasl查询带上字段名，删除与修改某一列数据

原文：https://www.cnblogs.com/liuhuan086/p/14233654.html