美文网首页
python3连接oracle数据库

python3连接oracle数据库

作者: 逍遥_yjz | 来源:发表于2020-12-01 16:58 被阅读0次

    安装navicat 时, 还有一点要注意,Oracle9i或以上版本的,要安装Install Client11或以下;Oracle8或8i服务器,需要安装Install Client10或以下。这个问题不大,因为我们现在的Oracle都是10或11了,注意一下就好。

    1.首先安装cx_Oracle包

    pip install cx_Oracle
    Python3.6

    2.下载软件包

    instantclient-basic-windows.x64-12.1.0.2.0.zip
    https://www.oracle.com/cn/database/technology/instant-client.html
    或者
    链接:https://pan.baidu.com/s/1A-b1sU-Xj0vra3HQiCMixA
    提取码:dyrm

    3. 配置

    将instantclient下所有.dll文件到python\Lib\site-packages\下

    4. 测试代码如下

    示例 1:

    import cx_Oracle #导入包
    db = cx_Oracle.connect('用户名','用户密码','ip:端口号/数据库名') #连接数据库
    print(db.version) #打印版本看看 显示 11.2.0.1.0
    cur = db.cursor() # 游标操作
    cur.execute('select * from table') # 执行sql语句
    rows = cur.fetchall() # 获取数据
    # 打印数据
    for row in rows[:10]:
       print(f"{row[0]} ,",end='')
    

    结果如下所示:


    示例 2:
    安装
    pip install sqlalchemy -i http://pypi.douban.com/simple --trusted-host pipy.douban.com
    

    SQLAlchemy本身无法操作数据库,其必须以来cx_Oracle等第三方插件,Dialect用于和数据API进行交流,根据配置文件的不同调用不同的数据库API,从而实现对数据库的操作,如:

    MySQL-Python
        mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname>
    
    pymysql
        mysql+pymysql://<username>:<password>@<host>/<dbname>[?<options>]
    
    MySQL-Connector
        mysql+mysqlconnector://<user>:<password>@<host>[:<port>]/<dbname>
    
    cx_Oracle
        oracle+cx_oracle://user:pass@host:port/dbname[?key=value&key=value...]
    
    from sqlalchemy import create_engine # 导入包
    engine = create_engine('oracle+cx_oracle://user:pass@host:port/dbname') # 创建连接引擎
    conn = engine.connect() # 连接数据库
    res = conn.execute('select * from table') # 执行sql
    res = res.fetchall() # 获取所有数据,这里返回的是list
    print(res[:5]) #查看前5个数据
    

    结果如下所示:

    [('41403700', datetime.datetime(2020, 11, 21, 8, 0), Decimal('248.18'), Decimal('0.13'), Decimal('30.41'), None, None, '5', None, None, None, '20201123'), ('41403700', datetime.datetime(2020, 11, 11, 8, 0), Decimal('248.12'), Decimal('0.17'), Decimal('30.28'), None, None, '4', None, None, None, '20201118'), ('41403700', datetime.datetime(2020, 11, 1, 8, 0), Decimal('248.05'), Decimal('0.17'), Decimal('30.12'), None, None, '5', None, None, None, '20201108'), ('41403700', datetime.datetime(2020, 10, 21, 8, 0), Decimal('247.98'), Decimal('0.23'), Decimal('29.96'), None, None, '5', None, None, None, '20201026'), ('41403700', datetime.datetime(2020, 10, 11, 8, 0), Decimal('247.87'), Decimal('0.23'), Decimal('29.74'), None, None, '5', None, None, None, '20201018')]

    中文乱码的解决方案:

    在python脚本中加入这几句:

    # -*- coding: utf-8 -*- 
    import os 
    os.environ['NLS_LANG'] = 'SIMPLIFIED CHINESE_CHINA.UTF8'
    

    6. 回到pandas

    经历了sqlalchemy, 终于大概知道是怎么回事了,现在不影响我们使用pandas了,我们再次尝试pandas的用法。

    #! /usr/bin/env python
    # -*- coding: utf-8 -*-
    
    # 导入包
    import os
    from sqlalchemy import create_engine
    import pandas as pd
    
    os.environ['NLS_LANG'] = 'SIMPLIFIED CHINESE_CHINA.UTF8'
    
    # 同样的套路,创建连接引擎
    engine = create_engine('oracle+cx_oracle://user:pass@host:port/dbname')  
    
    # with管理安全
    with engine.connect() as conn, conn.begin():
        # 直接给出要查的表名,sql原生语句都不用写了
        data = pd.read_sql_table('table_name', conn) 
    print(data.head())  # 查看前5个数据
    

    没有得出结果,原因未知。

    相关文章

      网友评论

          本文标题:python3连接oracle数据库

          本文链接:https://www.haomeiwen.com/subject/qgmswktx.html