Tibs
01/05/2023, 1:16 PMAndrew Huang
01/05/2023, 4:55 PMTibs
01/05/2023, 6:23 PMAndrew Huang
01/05/2023, 6:34 PMfrom prefect_sqlalchemy import SqlAlchemyConnector
with SqlAlchemyConnector.load("MY_BLOCK") as database:
results = database.fetch_all("SELECT * FROM customers WHERE name = :name", parameters={"name": "Me"}, multi=True)
Tibs
01/06/2023, 9:51 AMAndrew Huang
01/06/2023, 4:29 PMTibs
01/09/2023, 10:34 AMdef create_db_credentials(database: str):
sqlalchemy_credentials = DatabaseCredentials(
driver=SyncDriver.MYSQL_PYMYSQL,
username=,
password=,
host=,
port=,
database=database,
connect_args={"client_flag": CLIENT.MULTI_STATEMENTS}, "autocommit": True
)
return sqlalchemy_credentials
{"client_flag": CLIENT.MULTI_STATEMENTS} for PyMySQL allows me to execute multiple statements queries.Andrew Huang
01/09/2023, 4:47 PMTibs
01/10/2023, 7:18 AM