kasteph
03/27/2023, 8:57 AMcursor.execute
with the SqlAlchemy block doesn't persist inserts. The block can connect to the db just fine and even fetch records just fine. But it can neither do inserts nor updates. FWIW, I'm executing from a jinja template like so: cursor.execute(insert_records.render())
Ryan Peden
03/27/2023, 11:24 AMkasteph
03/27/2023, 3:19 PMRyan Peden
03/27/2023, 3:38 PMkasteph
03/27/2023, 3:38 PMkasteph
03/27/2023, 3:39 PM@flow
def contracts(network: str):
logger = get_run_logger()
connector: SqlAlchemyConnector = SqlAlchemyConnector.load(network)
with connector.get_connection() as c:
<http://logger.info|logger.info>(f"connected to sqlalchemy db: {network}")
<http://logger.info|logger.info>("updating contracts rollup")
c.execute(update_contracts_tpl.render())
kasteph
03/27/2023, 3:39 PMRyan Peden
03/27/2023, 3:44 PM@flow
def contracts(network: str):
logger = get_run_logger()
connector: SqlAlchemyConnector = SqlAlchemyConnector.load(network)
<http://logger.info|logger.info>(f"connected to sqlalchemy db: {network}")
<http://logger.info|logger.info>("updating contracts rollup")
connector.execute(update_contracts_tpl.render())
kasteph
03/27/2023, 3:45 PMRyan Peden
03/27/2023, 3:47 PM@flow
def contracts(network: str):
logger = get_run_logger()
connector: SqlAlchemyConnector = SqlAlchemyConnector.load(network)
with connector.get_connection() as c:
<http://logger.info|logger.info>(f"connected to sqlalchemy db: {network}")
<http://logger.info|logger.info>("updating contracts rollup")
c.execute(update_contracts_tpl.render())
c.commit()
It should auto commit - but if this works, it will give useful feedback on what's going wrong.kasteph
03/27/2023, 3:47 PMkasteph
03/27/2023, 3:51 PMAttributeError: 'Connection' object has no attribute 'commit'
kasteph
03/27/2023, 4:07 PM