zoukankan      html  css  js  c++  java
  • 利用Python从一个数据库中查询结果插入到另一个数据库中

    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)
  • 相关阅读:
    Solaris+Oracle安装(详细图解)
    linux卸载和安装jdk
    UTF8, Unicode, GB2312格式串转换之C语言版
    linux安装ant
    在 Linux 平台下使用 JNI
    华为C/C++笔试题(1)
    c面试
    mongodb数据库
    YARN
    NPM(包管理器)
  • 原文地址:https://www.cnblogs.com/wutanghua/p/14221331.html
Copyright © 2011-2022 走看看