GPDBcurrenttransactionisaborted-mysql教程-PHP中文网

GPDBcurrenttransactionisaborted

php中文网

发布： 2016-06-07 16:12:38

原创

1435人浏览过

在用python操作gpdb的时候遇到报错如下 gpmg.manager_tabl1eerror 'ERROR: relation gpmg.manager_tabl1e does not exist' in 'select pg_total_relation_size('gpmg.manager_tabl1e');'gpmg.manager_tableerror 'ERROR: current transaction is aborted, co

在用python操作gpdb的时候遇到报错如下

gpmg.manager_tabl1e
error 'ERROR:  relation "gpmg.manager_tabl1e" does not exist
' in 'select pg_total_relation_size('gpmg.manager_tabl1e');'
gpmg.manager_table
error 'ERROR:  current transaction is aborted, commands ignored until end of transaction block
' in 'select pg_total_relation_size('gpmg.manager_table');'

登录后复制

这个在一个循环当中，收集对象大小并插入结果表，出现这个错误的原因是因为在GPDB中如果有出现任何错误，将导致后续的会话报错。

Python代码块如下

sql = "select v1,v2,v3 from test order by 2"
cur.execute(sql)
for ret in cur.fetchall():
    v_schemaname = ret[0]
    v_tablename = ret[1]
    v_tableowner = ret[2]
    v_object = v_schemaname &#43; "." &#43; v_tablename
    try:
        cur.execute("select pg_total_relation_size('" &#43; v_object &#43; "');")
        v_totalsize = cur.fetchone()[0]
        cur.execute("insert into gpmg.table_size_info (ctime,schemaname,tablename,tableowner,totalsize) values(%s,%s,%s,%s,%s)", (ctime,v_schemaname,v_tablename,v_ta
bleowner,v_totalsize))
    except Exception, e:
        print v_object
        print e

登录后复制

改进之后如下

MarsCode

字节跳动旗下的免费AI编程工具

279

查看详情

try:
    for ret in cur.fetchall():
        v_schemaname = ret[0]
        v_tablename = ret[1]
        v_tableowner = ret[2]
        v_object = v_schemaname &#43; "." &#43; v_tablename
        try:
            cur.execute("select pg_total_relation_size('" &#43; v_object &#43; "');")
            v_totalsize = cur.fetchone()[0]
            cur.execute("insert into gpmg.table_size_info (ctime,schemaname,tablename,tableowner,totalsize) values(%s,%s,%s,%s,%s)", (ctime,v_schemaname,v_tablename,v_tableowner,v_totalsize))
            db.commit()
        except Exception, e:
            db.commit()
            print v_object, '--', e
            continue
except Exception, e:
    pass    
finally:
    db.commit()
    db.close()
    os.system('rm -rf ' &#43; pf)

登录后复制

这样就算比较完美咯。

-EOF-