DatabaseError

问题：

pd.read_sql(sql的filename)出现异常

处理过程：

1.查看pandas.read_sql()源码

图片.png

我传入的参数是sql语句的文件名，因此下一步执行的是else语句中的pandas_sql.read_query()，进入read_query()源码

图片.png
从上图看，通过self.execute方法进行数据的获取。那么我们再进入execute源码。
图片.png

先执行execute，若发生异常进行rollback回滚，若rollback回滚也产生异常，那么抛出DatabaseError,并且raise_with_traceback(ex)。
所以进行异常Exception捕获处理即可

其它

1.AnalysisException

图片.png

该异常是spark端的
2.self.conn.connect是impyla.impala.dbapi

图片.png
其连接实质是HiveServer2Connection
图片.png

3.HiveServer2Connection.rollback

图片.png