python 往oracle里面写DataFrame(二)

系统 520 0

之前写了python 往oracle里面DataFrame, 在自己的笔记本上奏效,但是放在集群上去,就会失效了,报错内容为:
sqlalchemy.exc.DatabaseError: (cx_Oracle.DatabaseError) ORA-12505: TNS: 监听程序当前无法识别连接描述符中所给出的 SID

解决方案为创建引擎的方式有所变化,具体的代码入下

            
              from sqlalchemy.dialects.oracle import \
            BFILE, BLOB, CHAR, CLOB, DATE, \
            DOUBLE_PRECISION, FLOAT, INTERVAL, LONG, NCLOB, \
            NUMBER, NVARCHAR, NVARCHAR2, RAW, TIMESTAMP, VARCHAR, \
            VARCHAR2
def mapping_df_types(df):
    dtypedict = {}
    for i, j in zip(df.columns, df.dtypes):
        if "object" in str(j):
            dtypedict.update({i: VARCHAR(256)})
        if "float" in str(j):
            dtypedict.update({i: NUMBER(19,8)})
        if "int" in str(j):
            dtypedict.update({i: VARCHAR(19)})
    return dtypedict
## 往集群oracle写入数据
def put_df_toOracle_cluster(df_data , tableName , ip , port ,uname,pwd , tnsname):    
    import cx_Oracle as cx_Oracle
    from sqlalchemy import create_engine
#    ip = 'localhost'
#    port = '1521'
#    uname = 'chensq' # 用户名
#    pwd = '123456' # 密码
#    tnsname = 'orcl' # 实例名
     dsnStr = cx_Oracle.makedsn(ip, port, service_name=tnsname)
     connect_str = "oracle://%s:%s@%s" %(uname, pwd, dsnStr)
     engine = create_engine(connect_str, encoding=encoding)
     from sqlalchemy.dialects.oracle import \
            BFILE, BLOB, CHAR, CLOB, DATE, \
            DOUBLE_PRECISION, FLOAT, INTERVAL, LONG, NCLOB, \
            NUMBER, NVARCHAR, NVARCHAR2, RAW, TIMESTAMP, VARCHAR, \
            VARCHAR2
    dtypedict = mapping_df_types(df_data)
    print(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>开始")
    print(dtypedict)
    print(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>结束")
    df_data.to_sql(tableName,engine,index=False,if_exists='append',dtype=dtypedict,chunksize=None)
#------------------------------


            
          

参考博客为:
【1】https://blog.csdn.net/AlanGuoo/article/details/88255194
【2】: https://blog.csdn.net/walking_visitor/article/details/84023393


更多文章、技术交流、商务合作、联系博主

微信扫码或搜索:z360901061

微信扫一扫加我为好友

QQ号联系: 360901061

您的支持是博主写作最大的动力,如果您喜欢我的文章,感觉我的文章对您有帮助,请用微信扫描下面二维码支持博主2元、5元、10元、20元等您想捐的金额吧,狠狠点击下面给点支持吧,站长非常感激您!手机微信长按不能支付解决办法:请将微信支付二维码保存到相册,切换到微信,然后点击微信右上角扫一扫功能,选择支付二维码完成支付。

【本文对您有帮助就好】

您的支持是博主写作最大的动力,如果您喜欢我的文章,感觉我的文章对您有帮助,请用微信扫描上面二维码支持博主2元、5元、10元、自定义金额等您想捐的金额吧,站长会非常 感谢您的哦!!!

发表我的评论
最新评论 总共0条评论