sql >> Databasteknik >  >> RDS >> PostgreSQL

Hur skapar man en SQL-vy med SQLAlchemy?

Uppdatering: Se även användningsreceptet för SQLAlchemy här

Att skapa en (skrivskyddad icke-materialiserad) vy stöds inte direkt så vitt jag vet. Men att lägga till denna funktionalitet i SQLAlchemy 0.7 är enkelt (liknar exemplet jag gav här). Du behöver bara skriva ett kompilatortillägg CreateView . Med detta tillägg kan du sedan skriva (förutsatt att t är ett tabellobjekt med kolumnen id )

createview = CreateView('viewname', t.select().where(t.c.id>5))
engine.execute(createview)

v = Table('viewname', metadata, autoload=True)
for r in engine.execute(v.select()):
    print r

Här är ett fungerande exempel:

from sqlalchemy import Table
from sqlalchemy.ext.compiler import compiles
from sqlalchemy.sql.expression import Executable, ClauseElement

class CreateView(Executable, ClauseElement):
    def __init__(self, name, select):
        self.name = name
        self.select = select

@compiles(CreateView)
def visit_create_view(element, compiler, **kw):
    return "CREATE VIEW %s AS %s" % (
         element.name,
         compiler.process(element.select, literal_binds=True)
         )

# test data
from sqlalchemy import MetaData, Column, Integer
from sqlalchemy.engine import create_engine
engine = create_engine('sqlite://')
metadata = MetaData(engine)
t = Table('t',
          metadata,
          Column('id', Integer, primary_key=True),
          Column('number', Integer))
t.create()
engine.execute(t.insert().values(id=1, number=3))
engine.execute(t.insert().values(id=9, number=-3))

# create view
createview = CreateView('viewname', t.select().where(t.c.id>5))
engine.execute(createview)

# reflect view and print result
v = Table('viewname', metadata, autoload=True)
for r in engine.execute(v.select()):
    print r

Om du vill kan du även specialisera dig på en dialekt, t.ex.

@compiles(CreateView, 'sqlite')
def visit_create_view(element, compiler, **kw):
    return "CREATE VIEW IF NOT EXISTS %s AS %s" % (
         element.name,
         compiler.process(element.select, literal_binds=True)
         )


  1. Hur ställer man in variabel från en SQL-fråga?

  2. Hur last_insert_rowid() fungerar i SQLite

  3. Hur man aktiverar/inaktiverar dataåtkomst i SQL Server (T-SQL-exempel)

  4. TNSPING OK men sqlplus ger ORA-12154?