SQL-Abfrage mit Elixir ausführen

Question

Ich verwende Elixir in einem Projekt, das eine Verbindung zu einer Postgres-Datenbank herstellt. Ich möchte die folgende Abfrage für die Datenbank ausführen, mit der ich verbunden bin, aber ich weiß nicht, wie ich das machen soll, da ich für Elixir und SQLAlchemy ziemlich neu bin. Wer weiß wie?

VACUUM FULL ANALYZE table

aktualisieren

Der Fehler ist: "UnboundExecutionError: Es konnte keine bind konfiguriert SQL-Expression oder diese Sitzung lokalisieren". Und das gleiche Ergebnis mit session.close() zuvor ausgegeben. Ich habe versucht, metadata.bind.execute() und das für eine einfache Auswahl funktioniert. Aber für die VACUUM hieß es - "InternalError: (InternalError) VACUUM kann nicht innerhalb eines Transaktionsblocks laufen", also versuche ich jetzt herauszufinden, wie ich das ausschalten kann.

Update 2

ich die Abfrage bekommen kann ausführen, aber ich bin immer noch die gleichen Fehler - auch wenn ich eine neue Sitzung erstellt und die vorherigen schließen.

from sqlalchemy import create_engine 
from sqlalchemy.orm import sessionmaker 

# ... insert stuff 
old_session.commit() 
old_session.close() 

new_sess = sessionmaker(autocommit=True) 
new_sess.configure(bind=create_engine('postgres://user:pw@host/db', echo=True)) 
sess = new_sess() 
sess.execute('VACUUM FULL ANALYZE table') 
sess.close() 

und die Ausgabe ich erhalte, ist

2009-12-10 10:00:16,769 INFO sqlalchemy.engine.base.Engine.0x...05ac VACUUM FULL ANALYZE table 
2009-12-10 10:00:16,770 INFO sqlalchemy.engine.base.Engine.0x...05ac {} 
2009-12-10 10:00:16,770 INFO sqlalchemy.engine.base.Engine.0x...05ac ROLLBACK 
finishing failed run, (InternalError) VACUUM cannot run inside a transaction block 
'VACUUM FULL ANALYZE table' {} 

Update 3

Vielen Dank an alle, die geantwortet haben. Ich war nicht in der Lage, die Lösung zu finden, die ich wollte, aber ich denke, ich gehe nur mit dem hier beschriebenen PostgreSQL - how to run VACUUM from code outside transaction block?. Es ist nicht ideal, aber es funktioniert.

Answer 1

Dammit. Ich wusste, dass die Antwort direkt vor meiner Nase sein würde. Angenommen, Sie richten Ihre Verbindung so ein wie ich.

metadata.bind = 'postgres://user:pw@host/db' 

Die Lösung hierfür war so einfach wie

conn = metadata.bind.engine.connect() 

old_lvl = conn.connection.isolation_level 
conn.connection.set_isolation_level(0) 
conn.execute('vacuum analyze table') 
conn.connection.set_isolation_level(old_lvl) 

Dies ähnlich ist, was hier PostgreSQL - how to run VACUUM from code outside transaction block? weil unter vorgeschlagen wurde allen, sqlalchemy psycopg verwendet die Verbindung zu Postgres zu machen. Connection.connection ist ein Proxy für die psycopg-Verbindung. Als mir das klar wurde, kam mir dieses Problem wieder in den Sinn und ich beschloss, einen weiteren Schlag zu machen.

Hoffentlich hilft das jemand.

Answer 2

Wenn Sie Zugriff auf SQLAlchemy Sitzung haben, können Sie beliebige SQL-Anweisungen über seine execute Methode ausführen:

session.execute("VACUUM FULL ANALYZE table") 

Answer 3

(Abhängig von der Postgres-Version) Sie höchstwahrscheinlich do not want laufen "VACUUM FULL".

Answer 4

UnboundExecutionError besagt, dass Ihre Sitzung nicht an eine Engine gebunden ist und es keine Möglichkeit gibt, die Engine aus der Abfrage zu ermitteln, die an übergeben wurde. Sie können entweder engine.execute() direkt verwenden oder den zusätzlichen mapper-Parameter (entweder Mapper oder zugeordnetes Modell, der der in der Abfrage verwendeten Tabelle entspricht) an session.execute() übergeben, damit SQLAlchemy die richtige Engine erkennt.

Die InternalError besagt, dass Sie versuchen, diese Anweisung innerhalb explizit (mit BEGIN-Anweisung) gestarteter Transaktion auszuführen. Haben Sie schon einige Anweisungen davor ausgegeben, ohne commit() anzurufen? Wenn ja, rufen Sie einfach die Methode commit() oder rollback() auf, um die Transaktion zu schließen, bevor Sie VACUUM ausführen. Beachten Sie auch, dass es mehrere Parameter zu sessionmaker() gibt, die SQLAlchemy mitteilen, wann die Transaktion gestartet werden soll.

Answer 5

Sie müssen die Sitzung zu einem Motor binden

session.bind = metadata.bind 
session.execute('YOUR SQL STATEMENT')