2

我有以下过程不会按预期将数据加载到表中：

def upload_data(parsed_buffer):  

    parsed_buffer.seek(0)

    try:

        con = psycopg2.connect(database=database, user=user, password=pw, host=host) 
        cur = con.cursor()
        try:
            cur.copy_from(parsed_buffer, 'staging.vcf_ht')
        except StandardError, err:
            conn.rollback()
            print("   Caught error (as expected):\n", err)

    except psycopg2.NotSupportedError as e:
        now = time.strftime("%H:%M:%S +0000", time.localtime())
        print("Copy failed at: " + now + " - " + e.pgerror)
        sys.exit(1)

    finally:

            if con:
                con.close()
                now = time.strftime("%H:%M:%S +0000", time.localtime())
                print('Finished loading data at:' + now)

在其他帖子中，他们讨论了在写入后添加搜索功能。那是在我的代码的第 3 行。这没有用。我检查了其他几件事。1. 字符串缓冲区填充有制表符分隔的数据。2. 如果我将输出重定向到一个文件并在 psql 中使用 \copy 命令，它会像宣传的那样工作。3. 如果我写一个插入语句而不是字符串缓冲区，这也可以工作（但这对性能不利）。此过程以抛出任何错误而终止。

4

1 回答 1

5

问题是没有提交声明。添加：con.commit()

于 2013-05-31T17:45:13.807 回答