python3.5远程连接Oracle及类的封装

坑点：1. 想远程连接Oracle必须安装客户端（将客户端解压即可）;
2. 需要将oci.dll， oraocci**.dll，oraociei**.dll 拷贝到项目的lib\site-packages中；
3. 要将Oracle的客户端解压后的路径配置到path中。
如图所示以上几点：
python3.5远程连接Oracle及类的封装

话不多说上代码：

import cx_Oracle
import logging
import sys
from general.project_config import db_oracle_config


# 加入日志
# 获取logger实例
logger = logging.getLogger("baseSpider")
# 指定输出格式
formatter = logging.Formatter('%(asctime)s\
              %(levelname)-8s:%(message)s')
# 文件日志
file_handler = logging.FileHandler("operation_database.log")
file_handler.setFormatter(formatter)
# 控制台日志
console_handler = logging.StreamHandler(sys.stdout)
console_handler.setFormatter(formatter)

# 为logge添加具体的日志处理器
logger.addHandler(file_handler)
logger.addHandler(console_handler)

logger.setLevel(logging.INFO)

class DBHelper():
    #构造函数，初始化数据库连接
    def __init__(self,sql):
        self.sql = sql
        self.conn = None
        self.cur = None

    #连接数据库操作
    def connectiondatabase(self):
        print(db_oracle_config['username'],db_oracle_config['password'],db_oracle_config['tns'])
        try:
            self.conn = cx_Oracle.connect(db_oracle_config['username'],db_oracle_config['password'],
                                           db_oracle_config['tns'])
        except:
            logger.error("connect_Oracle_Database is failed")
            return False
        self.cur = self.conn.cursor()
        return True

    # 关闭数据库
    def closedatabase(self):
        # 如果数据打开，则关闭；否则没有操作
        if self.conn and self.cur:
            self.cur.close()
            self.conn.close()
        return True

    # 执行数据库的sq语句,主要用来做插入操作
    def execute(self):
        self.connectiondatabase()
        try:
            if self.conn and self.cur:
                # 正常逻辑，执行sql，提交操作
                self.cur.execute(self.sql)
                self.conn.commit()
        except:
            logger.error("execute failed: " + self.sql)
            self.closedatabase()
            return False
        return True

    # 用来查询表数据
    def select(self):
        self.connectiondatabase()
        self.cur.execute(self.sql)
        result = self.cur.fetchall()
        print(result)
        return result


sql1 = "Oracle_SQL"
insertsql = DBHelper(sql1)
insertsql.select()

连接Mysql和Oracle的过程中最主要的区别是Oracle需要本地安装客户端，将那三个文件拷贝及环境变量的配置，希望能帮到各位。

python3.5远程连接Oracle及类的封装

相关推荐