1

我正在尝试使用 python（pymysql 连接器）将一些数据插入 MySQL 数据库，但性能非常差（每秒插入大约 10 行）。该表是 InnoDB，我正在使用多值插入语句并确保关闭自动提交。任何想法为什么我的插入仍然这么慢？

我最初认为自动提交没有被正确禁用，但我添加了代码来测试它在每次连接期间被禁用（=0）。

这是我的示例代码：

for i in range(1,500):
    params.append([i,i,i,i,i,i])
insertDB(params)

def insertDB(params):
    query = """INSERT INTO test (o_country_id, i_country_id,c_id,period_id,volume,date_created,date_updated)
        VALUES (%s,%s,%s,%s,%s,NOW(),NOW())
        ON DUPLICATE KEY UPDATE trade_volume = %s, date_updated = NOW();"""
    db.insert_many(query,params)

def insert_many(query,params=None):
    cur = _connection.cursor()
    try:
        _connection.autocommit(False)
        cur.executemany(query,params)
        _connection.commit()
    except pymysql.Error, e:
        print ("MySQL error %d: %s" %
            (e.args[0], e.args[1]))
    cur.close()

还有什么问题？上面的例子需要大约 110 秒的时间来执行。

4

1 回答 1

0

不知道出了什么问题，但我会尝试 mysqldb 和/或 mysql 连接器模块，看看我是否得到相同的性能数字。

于 2014-10-14T03:11:42.993 回答