v0.4.0

What's Changed

• Support for SQLAlchemy 2 by @obendidi in #70

New Contributors

• @obendidi made their first contribution in #70

Full Changelog: v0.3.2...v0.4.0

v0.3.2

What's Changed

• Update Logo URLs by @zzstoatzz in #68

New Contributors

• @zzstoatzz made their first contribution in #68

Full Changelog: v0.3.1...v0.3.2

v0.3.1

What's Changed

• 'Update the pin on prefect version' by @urimandujano in #66
• Bumps build's python version by @urimandujano in #67

New Contributors

• @urimandujano made their first contribution in #66

Full Changelog: v0.3.0...v0.3.1

v0.3.0

What's Changed

• Update CODEOWNERS to Open Source GH team by @desertaxle in #58
• Conditional imports to support operating with pydantic>2 installed by @chrisguidry in #64

New Contributors

• @chrisguidry made their first contribution in #64

Full Changelog: v0.2.4...v0.3.0

v0.2.4

0.2.4

Released on February 15th, 2023.

Fixed

• Initializing _unique_results and _exit_stack so fetch_* is able to run - #49

v0.2.3

0.2.3

Released on February 10th, 2022.

Changed

• Delay start of engine until necessary - #46

Fixed

• Using SQLite driver in sync context - #45

v0.2.2

0.2.2

Released on December 30th, 2022.

This release introduced a new SqlAlchmeyConnector block which allows users to both store credentials for their database, and perform SQL queries and operations against their database!

Here's an example of how to use this new block!

from prefect_sqlalchemy import SqlAlchemyConnector, SyncDriver, ConnectionComponents

with SqlAlchemyConnector(
    connection_info=ConnectionComponents(
        driver=SyncDriver.SQLITE_PYSQLITE,
        database="my.db"
    ),
) as database_credentials:
    database_credentials.execute(
        "CREATE TABLE IF NOT EXISTS customers (name varchar, address varchar);"
    )
    database_credentials.execute(
        "INSERT INTO customers (name, address) VALUES (:name, :address);",
        parameters={"name": "Marvin", "address": "Highway 42"},
    )
    database_credentials.execute_many(
        "INSERT INTO customers (name, address) VALUES (:name, :address);",
        seq_of_parameters=[
            {"name": "Ford", "address": "Highway 42"},
            {"name": "Unknown", "address": "Highway 42"},
        ],
    )
    # Repeated fetch* calls using the same operation will skip re-executing and instead return the next set of results
    print(database_credentials.fetch_many("SELECT * FROM customers", size=2))
    print(database_credentials.fetch_one("SELECT * FROM customers"))

Added

• SqlAlchemyConnector database block - #35
• ConnectionComponents base model - #35

Deprecated

• DatabaseCredentials and all tasks in prefect_sqlalchemy.database, in favor of SqlAlchemyConnector - #35

v0.2.1

0.2.1

Released on December 15th, 2022.

Fixed

• Serialization of DatabaseCredentials.rendered_url - #36

v0.2.0

0.2.0

Released on September 1st, 2022.

Changed

• DatabaseCredentials now only accepts a str in URL format - #29

Fixed

• Fixed registration error by changing url type to AnyUrl - #29

v0.1.2

0.1.2

Released on August 1st, 2022.

Fixed

• Fixed sqlite+* drivers by dropping 'username' from the required input keywords - #23
• Fixed sqlalchemy_query for drivers that require the connection to be alive while fetching - #23