> ## Documentation Index > Fetch the complete documentation index at: https://docs.activeviam.com/llms.txt > Use this file to discover all available pages before exploring further. # atoti_jdbc.JdbcLoad ### *final class* atoti\_jdbc.JdbcLoad The definition of a JDBC query. ```pycon theme={"languages":{"custom":["/engine/python-sdk/0.9/languages/pycon.tmLanguage.json"]}} >>> from atoti_jdbc import JdbcLoad >>> url = f"h2:{database_path};USER=root;PASSWORD=pass" >>> jdbc_load = JdbcLoad("SELECT * FROM MYTABLE", url=url) ``` Inferring data types: ```pycon theme={"languages":{"custom":["/engine/python-sdk/0.9/languages/pycon.tmLanguage.json"]}} >>> data_types = session.tables.infer_data_types(jdbc_load) >>> data_types {'ID': 'int', 'CITY': 'String', 'MY_VALUE': 'long'} ``` Creating a table from the inferred data types: ```pycon theme={"languages":{"custom":["/engine/python-sdk/0.9/languages/pycon.tmLanguage.json"]}} >>> table = session.create_table("Cities", data_types=data_types, keys={"ID"}) ``` Loading query results into the table: ```pycon theme={"languages":{"custom":["/engine/python-sdk/0.9/languages/pycon.tmLanguage.json"]}} >>> table.load(jdbc_load) >>> table.head().sort_index() CITY MY_VALUE ID 1 Paris 100 2 London 80 3 New York 90 4 Berlin 70 5 Jakarta 75 ``` Using a parametrized query: ```pycon theme={"languages":{"custom":["/engine/python-sdk/0.9/languages/pycon.tmLanguage.json"]}} >>> table.drop() >>> table.load( ... JdbcLoad( ... "SELECT * FROM MYTABLE WHERE City IN (?, ?)", ... parameters=["Paris", "New York"], ... url=url, ... ) ... ) >>> table.head().sort_index() CITY MY_VALUE ID 1 Paris 100 3 New York 90 ``` The following SQLite database has a table with a MY\_VALUE column typed as integer but with a string on row #3: ```pycon theme={"languages":{"custom":["/engine/python-sdk/0.9/languages/pycon.tmLanguage.json"]}} >>> import sqlite3 >>> query = "SELECT * FROM MYTABLE" >>> url = f"sqlite:{database_path}" >>> with sqlite3.connect(database_path) as connection: ... pd.read_sql(query, connection).set_index("ID") CITY MY_VALUE ID 1 Paris 100 2 London 80 3 New York wrong type 4 Berlin 70 5 Jakarta 75 ``` Atoti enforces strong typing for primitive data types so row #3 cannot be loaded successfully. The outcome of the [`load()`](./atoti.Table.load#atoti.Table.load) operation depends on [`error_handling`](#atoti_jdbc.JdbcLoad.error_handling): * With `"log"` or `"skip"`: ```pycon theme={"languages":{"custom":["/engine/python-sdk/0.9/languages/pycon.tmLanguage.json"]}} >>> table.drop() >>> table.load(JdbcLoad(query, error_handling="skip", url=url)) >>> table.head().sort_index() CITY MY_VALUE ID 1 Paris 100 2 London 80 4 Berlin 70 5 Jakarta 75 ``` * With `"warn"`: ```pycon theme={"languages":{"custom":["/engine/python-sdk/0.9/languages/pycon.tmLanguage.json"]}} >>> table.drop() >>> import warnings >>> with warnings.catch_warnings(record=True) as warning_messages: ... warnings.simplefilter("always") ... table.load(JdbcLoad(query, error_handling="warn", url=url)) >>> len(warning_messages) 1 >>> table.head().sort_index() CITY MY_VALUE ID 1 Paris 100 2 London 80 4 Berlin 70 5 Jakarta 75 ``` * With `"error"`: ```pycon theme={"languages":{"custom":["/engine/python-sdk/0.9/languages/pycon.tmLanguage.json"]}} >>> table.drop() >>> table.load( ... JdbcLoad(query, error_handling="fail", url=url) ... ) Traceback (most recent call last): ... py4j.protocol.Py4JError: ... ``` The content of the table after an invalid row occurred is undefined: some rows may or may not have been loaded. Use [`data_transaction()`](./atoti.tables.Tables.data_transaction#atoti.tables.Tables.data_transaction) to keep the operation atomic: ```pycon theme={"languages":{"custom":["/engine/python-sdk/0.9/languages/pycon.tmLanguage.json"]}} >>> table.drop() >>> table += (0, "Rome", 42) >>> with session.tables.data_transaction(): ... table.load(JdbcLoad(query, error_handling="fail", url=url)) Traceback (most recent call last): ... py4j.protocol.Py4JError: ... >>> table.head() CITY MY_VALUE ID 0 Rome 42 ``` **See also**: The other [`DataLoad`](./atoti.data_load.data_load#atoti.data_load.DataLoad) implementations. #### driver *: Annotated\[[str](https://docs.python.org/3/library/stdtypes.html#str) | [None](https://docs.python.org/3/library/constants.html#None), AfterValidator(\_validate\_driver)]* *= None* The Java class name of the [`driver`](./atoti_jdbc.driver#module-atoti_jdbc.driver) to use. This defines Hibernate’s [DRIVER](https://javadoc.io/static/org.hibernate/hibernate-core/5.6.15.Final/org/hibernate/cfg/AvailableSettings.html#DRIVER) option. Inferred from [`url`](#atoti_jdbc.JdbcLoad.url) if `None`. #### error\_handling *: ErrorHandling* *= 'fail'* How to handle rows that cannot be loaded. * `"fail"`: raise an error on the first invalid row and interrupt the load. * `"warn"`: skip invalid rows and raise a warning if any was found. * `"log"`: skip invalid rows and log each of them. * `"skip"`: skip invalid rows without logging. Health events are still dispatched for observability. #### parameters *: FrozenSequence\[Constant]* *= ()* The query parameters, sometimes also called *bind variables*. #### query *: [str](https://docs.python.org/3/library/stdtypes.html#str)* The query (usually SQL) to execute. #### url *: Annotated\[[str](https://docs.python.org/3/library/stdtypes.html#str), AfterValidator(normalize\_jdbc\_url)]* The JDBC connection string of the database. The `"jdbc"` scheme is optional but the database specific scheme (such as `"h2"`) is mandatory. For instance: * `"h2:/home/user/database/file/path;USER=username;PASSWORD=passwd"` * `"postgresql://postgresql.db.server:5430/example?user=username&password=passwd"` More examples can be found [here](https://www.baeldung.com/java-jdbc-url-format). This defines Hibernate’s [URL](https://javadoc.io/static/org.hibernate/hibernate-core/5.6.15.Final/org/hibernate/cfg/AvailableSettings.html#URL) option.