25 lines
796 B
Python
25 lines
796 B
Python
|
from superset.app import create_app
|
||
|
|
|
||
|
|
app = create_app()
|
||
|
|
with app.app_context():
|
||
|
|
from superset import db
|
||
|
|
from superset.connectors.sqla.models import SqlaTable
|
||
|
|
from superset.models.core import Database
|
||
|
|
|
||
|
|
t = db.session.query(SqlaTable).filter_by(table_name="historical_sales").first()
|
||
|
|
pg = (
|
||
|
|
db.session.query(Database)
|
||
|
|
.filter(Database.database_name.like("%PostgreSQL Sales%"))
|
||
|
|
.first()
|
||
|
|
)
|
||
|
|
t.database_id = pg.id
|
||
|
|
t.schema = "public"
|
||
|
|
db.session.commit()
|
||
|
|
try:
|
||
|
|
t.fetch_metadata()
|
||
|
|
db.session.commit()
|
||
|
|
except Exception as e:
|
||
|
|
print("fetch_metadata warn:", str(e)[:200])
|
||
|
|
print("repointed dataset", t.id, "-> db", pg.id, pg.database_name,
|
||
|
|
"schema", t.schema, "cols", [c.column_name for c in t.columns])
|