python - How to execute DDL statement in a different schema?

Question

I'd like to execute a DDL statement (for example: create table test(id int, str varchar)) in different DB schemas.

In order to execute this DDL i was going to use the following code:

from sqlalchemy import DDL, text, create_engine

engine = create_engine(...)

ddl_cmd = "create table test(id int, str varchar)"

DDL(ddl_cmd).execute(bind=engine)

How can I specify in which DB schema to execute this DDL statement, not changing the DDL command itself?

I don't understand why such a basic parameter like schema is missing in the DDL().execute() method. I guess I'm missing some important concept, but I couldn't figure it out.

---

UPD: I've found the "schema_translate_map" execution option, but it didn't work for me - the table will be still created in the default schema.

Here are my attempts:

conn = engine.connect().execution_options(schema_translate_map={None: "my_schema"})

then i tried different variants:

# variant 1
conn.execute(ddl_cmd)
# variant 2
conn.execution_options(schema_translate_map={None: "my_schema"}).execute()
# variant 3
DDL(ddl_cmd).compile(bind=conn).execute()
# variant 4
DDL(ddl_cmd).compile(bind=conn).execution_options(schema_translate_map={None: "my_schema"})

but every time the table will be created in the default schema. :(

Answer 1

等待大神答复