30

我正在尝试使用 cx_Oracle 连接到 Oracle 实例并执行一些 DDL 语句：

db = None
try:
    db = cx_Oracle.connect('username', 'password', 'hostname:port/SERVICENAME')
#print(db.version)
except cx_Oracle.DatabaseError as e:
    error, = e.args
    if error.code == 1017:
        print('Please check your credentials.')
        # sys.exit()?
    else:
        print('Database connection error: %s'.format(e))
cursor = db.cursor()
try:
    cursor.execute(ddl_statements)
except cx_Oracle.DatabaseError as e:
    error, = e.args
    if error.code == 955:
        print('Table already exists')
    if error.code == 1031:
        print("Insufficient privileges - are you sure you're using the owner account?")
    print(error.code)
    print(error.message)
    print(error.context)
cursor.close()
db.commit()
db.close()

但是，我不太确定这里异常处理的最佳设计是什么。

首先，我db在 try 块中创建对象，以捕获任何连接错误。

但是，如果它无法连接，那么db将不会存在进一步向下 - 这就是我在db = None上面设置的原因。然而，这是好的做法吗？

理想情况下，我需要捕获连接错误，然后是运行 DDL 语句的错误，等等。

嵌套异常是个好主意吗？或者有没有更好的方法来处理这样的依赖/级联异常？

此外，我希望脚本在某些部分（例如连接失败）中终止 - 因此被注释掉的sys.exit()调用。但是，我听说像这样对流控制使用异常处理是不好的做法。想法？

4

2 回答 2

38

但是，如果它无法连接，那么db将不会存在进一步向下 - 这就是我在db = None上面设置的原因。然而，这是好的做法吗？

不，设置db = None不是最佳实践。有两种可能性，连接到数据库将起作用或不起作用。

  • 连接到数据库不起作用：

    由于引发的异常已被捕获且未重新引发，因此您继续直到到达cursor = db.Cursor().

    db == NoneTypeError: 'NoneType' object has no attribute 'Cursor'，因此，将引发类似的异常。由于数据库连接失败时产生的异常已经被捕获，所以失败的原因是伪装的。

    就个人而言，除非您很快再试一次，否则我总是会引发连接异常。如何捕捉它取决于你；如果错误仍然存​​在，我会通过电子邮件说“去检查数据库”。

  • 连接到数据库确实有效：

    该变量在您的块db中分配。try:... except如果该connect方法确实有效，则将db其替换为连接对象。

db无论哪种方式，都不会使用的初始值。

但是，我听说像这样对流控制使用异常处理是不好的做法。

与其他语言不同，Python确实使用异常处理来进行流控制。在我的回答结束时，我已经链接到 Stack Overflow 和 Programmers 上提出类似问题的几个问题。在每个示例中，您都会看到“但在 Python 中”的字样。

这并不是说你应该过分，但 Python 通常使用EAFP的口头禅，“请求宽恕比请求许可更容易。” 如何检查变量是否存在？是如何同时使用流量控制的好例子。

嵌套异常是个好主意吗？或者有没有更好的方法来处理这样的依赖/级联异常？

嵌套异常并没有什么问题，只要你理智地做一遍。考虑你的代码。您可以删除所有异常并将整个事物包装在一个try:... except块中。如果引发了异常，那么您就会知道它是什么，但是要准确找出问题所在就有点困难了。

如果您想在失败时向自己发送电子邮件，会发生cursor.execute什么？cursor.execute为了执行这项任务，您应该有一个例外。然后，您重新引发异常，以便将其捕获在您的外部try:.... 不重新引发将导致您的代码继续执行，就好像什么都没发生一样，并且您在外部try:...处理异常的任何逻辑都将被忽略。

最终，所有异常都继承自BaseException.

此外，有一些部分（例如连接失败）我希望脚本终止 - 因此注释掉 sys.exit() 调用。

我添加了一个简单的类以及如何调用它，这大致就是我将如何做你想做的事情。如果这要在后台运行，那么打印错误是不值得的——人们不会坐在那里手动寻找错误。他们应该以您的标准方式登录，并通知适当的人。出于这个原因，我删除了打印并替换为记录提醒。

connect当方法失败并引发异常时，我已将类拆分为多个函数，因此execute在尝试断开连接后，调用将不会运行并且脚本将完成。

import cx_Oracle

class Oracle(object):

    def connect(self, username, password, hostname, port, servicename):
        """ Connect to the database. """

        try:
            self.db = cx_Oracle.connect(username, password
                                , hostname + ':' + port + '/' + servicename)
        except cx_Oracle.DatabaseError as e:
            # Log error as appropriate
            raise

        # If the database connection succeeded create the cursor
        # we-re going to use.
        self.cursor = self.db.cursor()

    def disconnect(self):
        """
        Disconnect from the database. If this fails, for instance
        if the connection instance doesn't exist, ignore the exception.
        """

        try:
            self.cursor.close()
            self.db.close()
        except cx_Oracle.DatabaseError:
            pass

    def execute(self, sql, bindvars=None, commit=False):
        """
        Execute whatever SQL statements are passed to the method;
        commit if specified. Do not specify fetchall() in here as
        the SQL statement may not be a select.
        bindvars is a dictionary of variables you pass to execute.
        """

        try:
            self.cursor.execute(sql, bindvars)
        except cx_Oracle.DatabaseError as e:
            # Log error as appropriate
            raise

        # Only commit if it-s necessary.
        if commit:
            self.db.commit()

然后调用它：

if __name__ == "__main__":

    oracle = Oracle.connect('username', 'password', 'hostname'
                           , 'port', 'servicename')

    try:
        # No commit as you don-t need to commit DDL.
        oracle.execute('ddl_statements')

    # Ensure that we always disconnect from the database to avoid
    # ORA-00018: Maximum number of sessions exceeded. 
    finally:
        oracle.disconnect()

进一步阅读：

cx_Oracle文件

为什么不使用异常作为常规控制流？
python 异常处理是否比 PHP 和/或其他语言更有效？
支持或反对使用 try catch 作为逻辑运算符的论据

于 2012-03-24T16:23:41.817 回答
1

一个不同且可能优雅的解决方案是对数据库调用函数使用装饰器。装饰器能够修复错误并再次尝试数据库调用。对于过时的连接，补救措施是重新连接并重新发出呼叫。这是对我有用的装饰器：

####### Decorator named dbReconnect ########
#Retry decorator
#Retries a database function twice when  the 1st fails on a stale connection
def dbReconnect():
    def real_decorator(function):
        def wrapper(*args, **kwargs):
            try:
                return function(*args, **kwargs)
            except  Exception as inst:
                print ("DB error({0}):".format(inst))
                print ("Reconnecting")
                #...Code for reconnection is to be placed here..
                ......
                #..end of code for reconnection
            return function(*args, **kwargs)
        return wrapper
    return real_decorator

###### Decorate the DB Call like this: #####
    @dbReconnect()
    def DB_FcnCall(...):
    ....

有关 Github 的更多详细信息：https ://github.com/vvaradarajan/DecoratorForDBReconnect/wiki

注意：如果您使用连接池，内部连接池技术检查连接并在陈旧时刷新它，也将解决问题。

于 2016-11-16T15:10:20.573 回答