PostgreSQL - Pour vous qui voulez INSÉRER à grande vitesse

Améliorons les performances des inserts de masse

Pour les insertions en masse dans PostgresQL Utilisez l'utilitaire pour insérer plusieurs enregistrements ensemble. Vous pouvez également revoir la fréquence d'exécution des validations pour réduire les coûts de traitement inutiles.

Mesurez en fait avec plusieurs modèles et comparez les performances. Dans psycopg2, l'une des bibliothèques qui accèdent à PostgreSQL avec Python En tant qu'utilitaire pour insérer plusieurs éléments à la fois Utilisez une fonction appelée execute_values. Modifiez également l'unité d'exécution de la validation et modifiez l'intervalle d'exécution de la validation pour la mesure réelle.

Préparation à la confirmation

Table de test

Tester DDL

CREATE TABLE test01
(key serial PRIMARY KEY,
 text_val text);

Programme de test

Pour plus de simplicité, nous allons vous permettre de saisir le nombre d'exécutions et de commits de manière interactive. Incluez la partie qui crée les paramètres afin qu'ils puissent être comparés autant que possible dans la même plage de temps. Initialisez les valeurs des objets TRUNCATE et SEQUENCE pour réinitialiser la table à chaque fois avant l'exécution.

execute_values prend par défaut 100 lignes. Si vous entrez plus que cela, vous devez passer plus que le nombre d'entrées à l'argument taille_page.

Programme de test

import psycopg2
from psycopg2.extras import execute_values
from time import time

_text = 'test' * 300

conn = psycopg2.connect('dbname=dbname host=localhost user=username password=password')
cur = conn.cursor()

#Réinitialisation de la table
reset_query_tbl = "TRUNCATE TABLE test01;"
cur.execute(reset_query_tbl)
reset_query_seq = "SELECT setval ('test01_key_seq', 1, false);"
cur.execute(reset_query_seq)
count_query = "SELECT count(key) FROM test01;"
cur.execute(count_query)
(count,) = cur.fetchone()
conn.commit()
print('■ État avant exécution')
print('Nombre de données: ', count)
print()

#Paramètres de test
print('■ Méthode INSERT')
print('Veuillez sélectionner la méthode INSERT parmi les suivantes(0/1/2/3)')
print('　0:INSÉRER un par un&commit.')
print('　1:INSÉRER un par un&Engagement collectif multiple.')
print('　2:INSÉRER un par un&Tous les cas s'engagent collectivement.')
print('　3:INSÉRER collectivement&commit.')
test_type = int(input('INSERT, méthode>'))
test_cnt  = int(input('Nombre d'INSERTs>'))
if test_type == 1:
    commit_cnt  = int(input('Intervalle COMMIT>'))

#Exécution du test et résultat
print()
print('■ Résultat de l'exécution')
if test_type==0:

    query = "INSERT INTO test01 (text_val) VALUES ('%s');" % _text
    st = time()
    for _ in range(test_cnt):
        cur.execute(query)
        conn.commit()

    elapsed_time = time() - st
    print('temps écoulé(s): ', elapsed_time)

if test_type==1:
    query = "INSERT INTO test01 (text_val) VALUES ('%s');" % _text
    st = time()
    for i in range(test_cnt):
        cur.execute(query)
        if (i + 1) % commit_cnt == 0:
            conn.commit()

    conn.commit()

    elapsed_time = time() - st
    print('temps écoulé(s): ', elapsed_time)

if test_type==2:

    query = "INSERT INTO test01 (text_val) VALUES ('%s');" % _text
    st = time()
    for _ in range(test_cnt):
        cur.execute(query)

    conn.commit()

    elapsed_time = time() - st
    print('temps écoulé(s): ', elapsed_time)

if test_type==3:

    query = "INSERT INTO test01 (text_val) VALUES %s;"
    st = time()

    params = []
    for _ in range(test_cnt):
        params += [(_text,)]

    ret = execute_values(cur, query, params, page_size=test_cnt)
    conn.commit()
    elapsed_time = time() - st
    print('temps écoulé(s): ', elapsed_time)

cur.execute(count_query)
(count,) = cur.fetchone()
print('Nombre de données: ', count)

cur.close()
conn.close()

Résultats de performance

Les résultats sont à titre indicatif seulement. Bien entendu, cela dépend de l'environnement et des spécifications de la machine.

--Windows10 64 bits / nombre de processeurs logiques 4 / mémoire 8 Go

• PostgreSQL11 --PostgreSQL config est la valeur par défaut.

Conclusion

execute_values, rapide. Utilisez-le si vous le pouvez.