-
Notifications
You must be signed in to change notification settings - Fork 4k
Add implementation of SQL connection #6381
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add implementation of SQL connection #6381
Conversation
c872658 to
98976a0
Compare
ea0e408 to
33b300e
Compare
98976a0 to
1cfede6
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I still believe we need some way for additional secrets to be added as arguments in this call.
A good concrete example is BigQuery. I'd like to be able to configure my credentials_info in secrets.toml or provide a credentials_path and have them passed to create_engine().
Cite: https://github.com/googleapis/python-bigquery-sqlalchemy#authentication
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Ack -- I'll address this when circling back to merging config options / params from various places for both this connector and the Snowpark one
33b300e to
151e36d
Compare
1cfede6 to
6245642
Compare
lukasmasuch
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM 👍
* Add implementation of SQL connection * Use sqlalchemy.text for 2.0 compatibility * Add unit tests for SQL connection * Add autocommit kwarg to connection_factory overload
* Add implementation of SQL connection * Use sqlalchemy.text for 2.0 compatibility * Add unit tests for SQL connection * Add autocommit kwarg to connection_factory overload
* Add implementation of SQL connection * Use sqlalchemy.text for 2.0 compatibility * Add unit tests for SQL connection * Add autocommit kwarg to connection_factory overload
* Add implementation of SQL connection * Use sqlalchemy.text for 2.0 compatibility * Add unit tests for SQL connection * Add autocommit kwarg to connection_factory overload
* Add implementation of SQL connection * Use sqlalchemy.text for 2.0 compatibility * Add unit tests for SQL connection * Add autocommit kwarg to connection_factory overload
* Add implementation of SQL connection * Use sqlalchemy.text for 2.0 compatibility * Add unit tests for SQL connection * Add autocommit kwarg to connection_factory overload
* Add implementation of SQL connection * Use sqlalchemy.text for 2.0 compatibility * Add unit tests for SQL connection * Add autocommit kwarg to connection_factory overload
* Add implementation of SQL connection * Use sqlalchemy.text for 2.0 compatibility * Add unit tests for SQL connection * Add autocommit kwarg to connection_factory overload
* Add implementation of SQL connection * Use sqlalchemy.text for 2.0 compatibility * Add unit tests for SQL connection * Add autocommit kwarg to connection_factory overload
* Add implementation of SQL connection * Use sqlalchemy.text for 2.0 compatibility * Add unit tests for SQL connection * Add autocommit kwarg to connection_factory overload
* Add implementation of SQL connection * Use sqlalchemy.text for 2.0 compatibility * Add unit tests for SQL connection * Add autocommit kwarg to connection_factory overload
* Add implementation of SQL connection * Use sqlalchemy.text for 2.0 compatibility * Add unit tests for SQL connection * Add autocommit kwarg to connection_factory overload
Note: This PR is being merged into
feature/st.experimental_connection.📚 Context
This PR adds an implementation for one of our first party connection classes: the
SQLconnection.The SQL connection is a simple wrapper around SQLAchemy that plays nicely with a developer's
secrets.tomlfile and thest.experimental_connectionfactory function.There are a few notable things missing from the
SQLconnection class for now. Notably,read_sqlmethod still need to be implemented.We need to add some unit tests for the class itself. This will be done in a later PR.