import pymysql
import pandas as pd


DB = {'host': '****',
      'port': ####,
      'user': 'root',
      'password': '#####',
      'dbname': '%%%%'}


def data_out_msql(DB, msql):
    conn = pymysql.connect(host=DB['host'], port=DB['port'], user=DB['user'], passwd=DB['password'], db=DB['dbname'],
                           charset='utf8', cursorclass=pymysql.cursors.DictCursor)
    # 创建游标
    cursor = conn.cursor()
    # 执行sql语句
    cursor.execute(msql)
    y = cursor.fetchall()

    for value in y:
        write = pymysql.connect(host=DB['host'], port=DB['port'], user=DB['user'], passwd=DB['password'], db=DB['dbname'],
                           charset='utf8', cursorclass=pymysql.cursors.DictCursor)
        Wcursor = write.cursor()

        value=value["id"]
        try:
            Wcursor.execute("insert into b (id) values (%s)",(value))
            write.commit()
        except:
            write.rollback()
        write.close()
    cursor.close()
    conn.close()
    return y

if __name__ == '__main__':


    mysql="""
    select id from a

    """
    a=data_out_msql(DB,mysql)
    print(a)

 

相关文章:

  • 2021-12-15
  • 2021-10-29
  • 2021-09-17
  • 2022-12-23
  • 2022-12-23
  • 2021-10-10
  • 2021-07-01
  • 2021-04-05
猜你喜欢
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2021-11-16
  • 2022-12-23
  • 2021-11-19
相关资源
相似解决方案