Generate SQL tables, load and extract data, based on JSON Table Schema descriptors.
Project description
tableschema-sql-py
Generate and load SQL tables based on Table Schema descriptors.
Features
- implements
tableschema.Storage
interface - provides additional features like indexes and updating
Contents
Getting Started
Installation
The package use semantic versioning. It means that major versions could include breaking changes. It's highly recommended to specify package
version range in your setup/requirements
file e.g. package>=1.0,<2.0
.
pip install tableschema-sql
Documentation
from datapackage import Package
from tableschema import Table
from sqlalchemy import create_engine
# Create sqlalchemy engine
engine = create_engine('sqlite://')
# Save package to SQL
package = Package('datapackage.json')
package.save(storage='sql', engine=engine)
# Load package from SQL
package = Package(storage='sql', engine=engine)
package.resources
API Reference
Storage
Storage(self, engine, dbschema=None, prefix='', reflect_only=None, autoincrement=None)
SQL storage
Package implements Tabular Storage interface (see full documentation on the link):
Only additional API is documented
Arguments
- engine (object):
sqlalchemy
engine - dbschema (str): name of database schema
- prefix (str): prefix for all buckets
- reflect_only (callable): a boolean predicate to filter the list of table names when reflecting
- autoincrement (str/dict):
add autoincrement column at the beginning.
- if a string it's an autoincrement column name
- if a dict it's an autoincrements mapping with column
names indexed by bucket names, for example,
{'bucket1': 'id', 'bucket2': 'other_id}
storage.create
storage.create(self, bucket, descriptor, force=False, indexes_fields=None)
Create bucket
Arguments
- indexes_fields (str[]): list of tuples containing field names, or list of such lists
storage.write
storage.write(self, bucket, rows, keyed=False, as_generator=False, update_keys=None, buffer_size=1000, use_bloom_filter=True)
Write to bucket
Arguments
- keyed (bool): accept keyed rows
- as_generator (bool): returns generator to provide writing control to the client
- update_keys (str[]): update instead of inserting if key values match existent rows
- buffer_size (int=1000): maximum number of rows to try and write to the db in one batch
- use_bloom_filter (bool=True): should we use a bloom filter to optimize DB update performance (in exchange for some setup time)
Contributing
The project follows the Open Knowledge International coding standards.
Recommended way to get started is to create and activate a project virtual environment. To install package and development dependencies into active environment:
$ make install
To run tests with linting and coverage:
$ make test
Changelog
Here described only breaking and the most important changes. The full changelog and documentation for all released versions could be found in nicely formatted commit history.
v1.3
- Implemented constraints loading to a database
v1.2
- Add option to configure buffer size, bloom filter use (#77)
v1.1
- Added support for the
autoincrement
parameter to be a mapping - Fixed autoincrement support for SQLite and MySQL
v1.0
- Initial driver implementation.
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Hashes for tableschema_sql-2.0.1-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | cf2da48bef2e7ad7d912cdcc0992c32d74a66cc900bf32809cfc89b647acd5d3 |
|
MD5 | 11d560899b0e9574025f1dc2382c9cf2 |
|
BLAKE2b-256 | f2205a8bf56cc40f102e2ff3ddeced440e81b83abfa4b49a9308305ec52e8764 |