A simple psycopg2 based wrapper for nosql like database interaction with python.
Project description
A simple psycopg2 based wrapper for nosql like database interaction with python.
Why another wrapper?
The wrapper was developed to work with JSON postgres storage like a real NoSQL DB (e.g. MongoDB). After a long research with google there was no library found which helps to work with JSON and PostgreSQL so I decided to develop one.
The strength of the wrapper is that you still can have multiple relational colums in your table.
Installation
Using Python Package Index (PIP)
Just run the command: pip install pg4nosql
During alpha stage the api will change with each build. So try to stay with one version if you want to use it.
The hacky way
download or clone this repository
run the command python setup.py install
Changelog
Version 0.3.6
id datatype can be set on table creation
Version 0.3.3
project cleanup
Version 0.3.1
auto-commit for very operation as default
save does not affect saving object anymore
bug fixes
Version 0.2.4
a lot of bug fixes
Version 0.2.0
added port argument
replaced dictionary argument with **keyword syntax
switched result.relational with result.json
add bracket syntax to get database or table
renamed table.get_or_create to match codestyle
Example
These examples show the funcionality of the wrapper. There are some functions which are not covered by the examples (like removing of a table) but the importent ones are explained.
Dataschema Creation
To create the dataschema you can use normal database tools if you want. A document table has two fields:
id with data type serial
json with data type JSON which represents the document
But pg4nosql also provides methods to create your database schema on the fly. This is useful to create tables and databases software controlled.
This example shows how to create a database and their tables. The cities table is special because it also contains relational data like a normal table would:
# create pg4nosql client
pg4nosql = PostgresNoSQLClient(host='localhost')
# create demo database
demo_db = pg4nosql['demo']
# create document only table
users = demo_db['users']
# create document & relational table
cities = demo_db.get_or_create_table('cities', size='real NOT NULL')
Row Identifier Type
By default the id row type is SERIAL but in some cases it is necessary to define the type yourself. This is possible with the row_identifier_type argument.
# create document table with bigserial
big_users = demo_db.create_table('big_users',
row_identifier_type='BIGSERIAL')
Insert Data
To insert data into the table you just hand over a dictionary or an object which is json serializable. If there are relational columns defined you can set those by the table name as keyword and the value:
# store data into users table
users.put({'name': 'Florian', 'age': 24})
users.put({'name': 'Markus', 'age': 24})
users.put({'name': 'Sara', 'age': 22})
users.put({'name': 'Thomas', 'age': 25})
# store data into cities table
cities.put({'name': 'Zurich'}, size=87.88)
cities.put({'name': 'Berlin'}, size=891.8)
cities.put({'name': 'Bern'}, size=51.6)
cities.put({'name': 'London'}, size=1572)
Lazy Commit
If you want to store or save multiple entries you can set the auto_commit argument to False and commit it yourself.
# store data with lazy commit
for i in range(0, 255):
users.put({'name': 'Test', 'age': i}, auto_commit=False)
# lazy commit data
users.commit()
Query Data
To get your data back you can run a query over it. This works like normal SQL WHERE queries. For JSON data you have to use the json column:
# query all users which are 24 years old
users_24 = users.query("json->>'age'='24'")
And here the result of the user query:
[
"{'json': {u'age': 24, u'name': u'Florian'}, 'id': 1}",
"{'json': {u'age': 24, u'name': u'Markus'}, 'id': 2}"
]
You can also combine relational and JSON queries together like this:
# query all cities which start with be and are bigger than 100 km
big_ber_cities = cities.query("json->>'name' LIKE 'Ber%'"
"AND size > 100")
Here the result of this query:
[
"{'json': {u'name': u'Berlin'}, 'id': 2, 'size': 891.8}"
]
Query Data Access
To access the JSON fields of the result there is an attribute called json:
# get first city of the result array
first_city = big_ber_cities[0]
# read JSON attribute
city_name = first_city.json['name']
To access the relational fields of the result you have to use square brackets ([]) on the result:
# read relational attribute
city_size = first_city['size']
Update Data
With those access methods you can also write into the result and change the values of the fields. To save it just call save(obj) on the table object.
# change florian's age
florian = users_24[0]
florian.json['age'] = 25
users.save(florian)
The same works also for the relational fields:
# make zurich a bit bigger
zurich = cities.query_one("data->>'name'='Zurich'")
zurich['size'] = 90
cities.save(zurich)
Close Connection
Finally don’t forget to close the connection to the database.
# close db
demo_db.close()
About
The wrapper has been written for a science project and is still an early alpha version! Idea and implementation by Florian (cansik)
MIT License Copyright (c) 2015
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
File details
Details for the file pg4nosql-0.3.6.tar.gz
.
File metadata
- Download URL: pg4nosql-0.3.6.tar.gz
- Upload date:
- Size: 6.3 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 2475650e02b5997b31e36ecbcd1c60ffff46c2893ff11006c13c3f8668e75185 |
|
MD5 | 38ec2a076dc90585efc31895d5a2c281 |
|
BLAKE2b-256 | 8c632deb044e4467cc628460eb373605e367c961a017105eaf3b70cbb16b4102 |