sql >> Database teknologi >  >> RDS >> PostgreSQL

Postgresql OM KONFLIKT i sqlalchemy

Brug af Postgres 9.6.1, sqlachemy 1.1.4 og psychopg2 2.6.2:

  1. Konverter din datastruktur til en ordbog. Fra Pandas er det

    import pandas
    from sqlalchemy import MetaData
    from sqlalchemy.dialects.postgresql import insert
    import psycopg2
    
    # The dictionary should include all the values including index values
    insrt_vals = df.to_dict(orient='records')
    
  2. Opret forbindelse til databasen via sqlalchemy. Prøv i stedet psycog2-driveren nedenunder og den native COPY-funktion, som omgår al postgres-indeksering.

    csv_data = os.path.realpath('test.csv')
    con = psycopg2.connect(database = 'db01', user = 'postgres')
    cur = con.cursor()
    cur.execute("\copy stamm_data from '%s' DELIMITER ';' csv header" % csv_data)
    con.commit()
    
  3. Udfør

    results = engine.execute(do_nothing_stmt)
    # Get number of rows inserted
    rowcount = results.rowcount
    

Advarsel:

Denne metode virker ikke med NaT er ude af æsken.

Alt sammen

tst_df = pd.DataFrame({'colA':['a','b','c','a','z', 'q'],
              'colB': pd.date_range(end=datetime.datetime.now() , periods=6),
              'colC' : ['a1','b2','c3','a4','z5', 'q6']})


insrt_vals = tst_df.to_dict(orient='records')
engine =      sqlalchemy.create_engine("postgresql://user:[email protected]/postgres")
connect = engine.connect()
meta = MetaData(bind=engine)
meta.reflect(bind=engine)
table = meta.tables['tstbl']
insrt_stmnt = insert(table).values(insrt_vals)

do_nothing_stmt  = insrt_stmnt.on_conflict_do_nothing(index_elements=['colA','colB'])
results = engine.execute(do_nothing_stmt)

I stedet for trin 2 og 3 skal du bruge psycog2 driver med kopieringskommandoen i postgres er hurtigere for større filer (nærmer sig en koncert), fordi den slår al tabelindeksering fra.

csv_data = os.path.realpath('test.csv')


  1. Sådan forhindrer du et php-script i at få timeout på grund af en lang mysql-forespørgsel

  2. MySQL hente variabel fra Stored Procedure i PHP PDO

  3. Hvordan får man navnet på et dokument i Alfresco med SQL?

  4. PDO indsæt matrixværdier