Function _to_sql_chunk

dask/dataframe/io/sql.py:410–419

(d, uri, engine_kwargs=None, **kwargs)

def _to_sql_chunk(d, uri, engine_kwargs=None, **kwargs):
    import sqlalchemy as sa

    engine_kwargs = engine_kwargs or {}
    engine = sa.create_engine(uri, **engine_kwargs)

    q = d.to_sql(con=engine, **kwargs)
    engine.dispose()

    return q


def to_sql(