从Python缓慢插入MySQL

2024-09-30 01:18:52 发布

您现在位置:Python中文网/ 问答频道 /正文

我试图使用python(pymysql连接器)将一些数据插入到MySQL数据库中,但是性能非常差(大约每秒插入10行)。这个表是InnoDB,我使用了一个multiple values insert语句,并确保autocommit被关闭。你知道为什么我的插页这么慢吗?在

我最初认为autocommit没有被正确地禁用,但是我添加了一些代码来测试它在每次连接期间是否被禁用(=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秒的时间来执行。在


Tags: 代码iddatedefmysqlparamsconnectionquery

热门问题