Обновление базы данных с использованием python и sqlAlchemy - PullRequest
1 голос
/ 15 марта 2020

Я работаю с сервером табазы ​​в первый раз. И у меня есть несколько файлов PSV, которые я использую для обновления базы данных. Мне нужно было изменить значение в каждой строке таблицы, получая новое значение из файла PSV. Я смог сделать это, но мое решение очень медленное. Вот мой код

query = db.select([table])
ResultProxy = connection.execute(query)
ResultSet = ResultProxy.fetchall()

for row in ResultSet :
    testNum = row['num']
    rowDF = testDF[testDF['TSTNO'] == testNum] #testDF is DataFrame representation of a psv file
    newData = rowDF[' TSTCFND'].iloc[0]

    try :
        query = db.update(table).values(test_type = newData)
        query = query.where(table.columns.num == testNum)
        results = connection.execute(query)
    except :
        query = db.update(table).values(test_type = "unknown")
        query = query.where(table.columns.num == testNum)
        results = connection.execute(query)

Мне было интересно, есть ли лучший и более быстрый способ сделать это. Я не мог найти много онлайн.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...