PyPostgreSQLWrapper
PyPostgreSQLWrapper is a simple adapter for PostgreSQL with connection pooling
Configuration
The configuration can be done through JSON file or by Dict following the pattern described below:
{
"database": "postgres",
"host": "localhost",
"max_connection": 10,
"password": "postgres",
"port": 5432,
"print_sql": true,
"username": "postgres"
}Usage
PyPostgreSQLWrapper usage description:
Delete
Delete with where
from py_postgresql_wrapper.database import Database
with Database() as database:
database.delete('test').where('id', 1).execute()Delete with like condition
from py_postgresql_wrapper.database import Database
with Database() as database:
database.delete('test').where('description', 'Test%', operator='like').execute()Insert
from py_postgresql_wrapper.database import Database
with Database() as database:
database.insert('test').set('id', 1).set('description', 'Test').execute()Paging
Paging with where
from py_postgresql_wrapper.database import Database
with Database() as database:
database.select('test').fields('id', 'description').where('id', 3, operator='<').order_by('id').paging(0, 2)Paging without where
from py_postgresql_wrapper.database import Database
with Database() as database:
database.select('test').paging(0, 2)Select
Fetch all
from py_postgresql_wrapper.database import Database
with Database() as database:
database.select('test').execute().fetch_all()Fetch many
from py_postgresql_wrapper.database import Database
with Database() as database:
database.select('test').execute().fetch_many(1)Fetch one
from py_postgresql_wrapper.database import Database
with Database() as database:
database.select('test').execute().fetch_one()Select by file
from py_postgresql_wrapper.database import Database
with Database() as database:
database.execute('find_test_by_id', {'id': 1}).fetch_one()Select by query
from py_postgresql_wrapper.database import Database
with Database() as database:
database.execute('select id, description from test where id = %(id)s', {'id': 1}).fetch_one()SQL
from py_postgresql_wrapper.database import Database
with Database() as database:
database.execute('''
create table test (
id int primary key,
description varchar(255)
)
''')Update
Update with where
from py_postgresql_wrapper.database import Database
with Database() as database:
database.update('test').set('description', 'New Test 1').where('id', 1).execute()Update with where all
from py_postgresql_wrapper.database import Database
with Database() as database:
database.update('test').set('description', 'New Test 1').where_all({'id': 1, 'description': 'Test 1'}).execute()
