Source code for dae.utils.sql_utils

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


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


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